799 lines
27 KiB
PHP
Executable File
799 lines
27 KiB
PHP
Executable File
<?php
|
||
// +----------------------------------------------------------------------
|
||
// | likeshop开源商城系统
|
||
// +----------------------------------------------------------------------
|
||
// | 欢迎阅读学习系统程序代码，建议反馈是我们前进的动力
|
||
// | gitee下载：https://gitee.com/likeshop_gitee
|
||
// | github下载：https://github.com/likeshop-github
|
||
// | 访问官网：https://www.likeshop.cn
|
||
// | 访问社区：https://home.likeshop.cn
|
||
// | 访问手册：http://doc.likeshop.cn
|
||
// | 微信公众号：likeshop技术社区
|
||
// | likeshop系列产品在gitee、github等公开渠道开源版本可免费商用，未经许可不能去除前后端官方版权标识
|
||
// | likeshop系列产品收费版本务必购买商业授权，购买去版权授权后，方可去除前后端官方版权标识
|
||
// | 禁止对系统程序代码以任何目的，任何形式的再发布
|
||
// | likeshop团队版权所有并拥有最终解释权
|
||
// +----------------------------------------------------------------------
|
||
// | author: likeshop.cn.team
|
||
// +----------------------------------------------------------------------
|
||
|
||
|
||
namespace app\api\logic;
|
||
|
||
use app\api\cache\TokenCache;
|
||
use app\api\model\User;
|
||
use app\api\service\UserServer;
|
||
use app\common\logic\AccountLogLogic;
|
||
use app\common\model\account\AccountLog;
|
||
use app\common\model\NoticeSetting;
|
||
use app\common\model\user\UserAuth;
|
||
use app\common\model\user\UserLevel;
|
||
use app\common\service\FileServer;
|
||
use app\common\service\wechat\WeChatMnpService;
|
||
use app\common\service\WeChatServer;
|
||
use app\common\logic\LogicBase;
|
||
use app\common\model\Client_;
|
||
use app\common\service\ConfigServer;
|
||
use app\common\service\UrlServer;
|
||
use EasyWeChat\Factory;
|
||
use EasyWeChat\Kernel\Exceptions\Exception;
|
||
use Requests;
|
||
use think\facade\Db;
|
||
use think\facade\Config;
|
||
use think\facade\Cache;
|
||
use think\facade\Hook;
|
||
|
||
class LoginLogic extends LogicBase
|
||
{
|
||
public static function register($post){
|
||
$client =Client_::mnp;
|
||
switch ($post['client']){
|
||
case 2:
|
||
$client = Client_::oa;
|
||
break;
|
||
case 3:
|
||
$client = Client_::ios;
|
||
break;
|
||
case 4:
|
||
$client = Client_::android;
|
||
break;
|
||
case 5:
|
||
$client = Client_::pc;
|
||
break;
|
||
case 6:
|
||
$client = Client_::h5;
|
||
break;
|
||
}
|
||
$time = time();
|
||
$salt = substr(md5($time . $post['mobile']), 0, 4);//随机4位密码盐
|
||
$password = create_password($post['password'], $salt);//生成密码
|
||
$user_data = [
|
||
'avatar' => ConfigServer::get('website', 'user_image'),
|
||
'sn' => create_user_sn(),
|
||
'mobile' => $post['mobile'],
|
||
'salt' => $salt,
|
||
'password' => $password,
|
||
'create_time' => $time,
|
||
'distribution_code' => generate_invite_code(),//分销邀请码
|
||
'is_distribution' => DistributionLogic::isDistributionMember(),//是否为分销会员
|
||
];
|
||
|
||
$user_data['nickname'] = '用户'.$user_data['sn'];
|
||
|
||
$user = new User();
|
||
$user->save($user_data);
|
||
|
||
$token = self::createSession($user->id, $client);
|
||
|
||
//生成会员分销扩展表
|
||
DistributionLogic::createUserDistribution($user->id);
|
||
// 生成分销会员基础表
|
||
\app\common\logic\DistributionLogic::add($user->id);
|
||
|
||
//注册赠送
|
||
self::registerAward($user->id);
|
||
//消息通知
|
||
Hook::listen('notice', [
|
||
'user_id' => $user->id,
|
||
'scene' => NoticeSetting::REGISTER_SUCCESS_NOTICE,
|
||
]);
|
||
return $token;
|
||
}
|
||
/**
|
||
* User: 意象信息科技 lr
|
||
* Desc: 小程序登录
|
||
* @param $post
|
||
* @return array|\PDOStatement|string|\think\Model|null
|
||
* @throws Exception
|
||
* @throws \EasyWeChat\Kernel\Exceptions\DecryptException
|
||
* @throws \EasyWeChat\Kernel\Exceptions\InvalidConfigException
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
* @throws \think\exception\PDOException
|
||
*/
|
||
public static function mnpLogin($post)
|
||
{
|
||
//微信调用
|
||
try {
|
||
$config = WeChatServer::getMnpConfig();
|
||
$app = Factory::miniProgram($config);
|
||
$response = $app->auth->session($post['code']);
|
||
if (!isset($response['openid']) || empty($response['openid'])) {
|
||
throw new Exception('获取openID失败');
|
||
}
|
||
} catch (Exception $e) {
|
||
return self::dataError('登录失败:' . $e->getMessage());
|
||
}catch (\think\Exception $e){
|
||
return self::dataError('登录失败:' . $e->getMessage());
|
||
}
|
||
|
||
//添加或更新用户
|
||
$user_id = Db::name('user_auth au')
|
||
->join('user u', 'au.user_id=u.id')
|
||
->where(['u.del' => 0])
|
||
->where(function ($query) use ($response) {
|
||
$query->whereOr(['au.openid' => $response['openid']]);
|
||
if(isset($response['unionid']) && !empty($response['unionid'])){
|
||
$query->whereOr(['au.unionid' => $response['unionid']]);
|
||
}
|
||
})
|
||
->value('user_id');
|
||
|
||
if (empty($user_id)) {
|
||
$user_info = UserServer::createUser($response, Client_::mnp);
|
||
} else {
|
||
$user_info = UserServer::updateUser($response, Client_::mnp, $user_id);
|
||
}
|
||
|
||
if ($user_info['disable']) {
|
||
return self::dataError('账号已被禁用');
|
||
}
|
||
|
||
|
||
if (empty($user_info)) {
|
||
return self::dataError('登录失败:user');
|
||
}
|
||
|
||
//创建会话
|
||
$user_info['token'] = self::createSession($user_info['id'], Client_::mnp);
|
||
|
||
|
||
unset($user_info['id']);
|
||
unset($user_info['disable']);
|
||
return self::dataSuccess('登录成功', $user_info);
|
||
|
||
}
|
||
|
||
/**
|
||
* 获取code的url
|
||
* @param $url
|
||
* @return string
|
||
*/
|
||
public static function codeUrl($url)
|
||
{
|
||
$config = WeChatServer::getOaConfig();
|
||
$app = Factory::officialAccount($config);
|
||
$response = $app
|
||
->oauth
|
||
->scopes(['snsapi_userinfo'])
|
||
->redirect($url)
|
||
->getTargetUrl();
|
||
return $response;
|
||
}
|
||
|
||
|
||
/**
|
||
* User: 意象信息科技 lr
|
||
* Desc: 微信公众号登录
|
||
* @param $post
|
||
* @return array|\PDOStatement|string|\think\Model|null
|
||
* @throws Exception
|
||
* @throws \EasyWeChat\Kernel\Exceptions\DecryptException
|
||
* @throws \EasyWeChat\Kernel\Exceptions\InvalidConfigException
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
* @throws \think\exception\PDOException
|
||
*/
|
||
public static function oaLogin($post)
|
||
{
|
||
//微信调用
|
||
try {
|
||
$config = WeChatServer::getOaConfig();
|
||
$app = Factory::officialAccount($config);
|
||
$response = $app
|
||
->oauth
|
||
->scopes(['snsapi_userinfo'])
|
||
->getAccessToken($post['code']);
|
||
if (!isset($response['openid']) || empty($response['openid'])) {
|
||
throw new Exception();
|
||
}
|
||
$user = $app->oauth->user($response);
|
||
$user = $user->getOriginal();
|
||
} catch (Exception $e) {
|
||
return self::dataError('登录失败:' . $e->getMessage());
|
||
}catch (\think\Exception $e){
|
||
return self::dataError('登录失败:' . $e->getMessage());
|
||
}
|
||
|
||
//添加或更新用户
|
||
$user_id = Db::name('user_auth au')
|
||
->join('user u', 'au.user_id=u.id')
|
||
->where(['u.del' => 0])
|
||
->where(function ($query) use ($user) {
|
||
$query->whereOr(['au.openid' => $user['openid']]);
|
||
if(isset($user['unionid']) && !empty($user['unionid'])){
|
||
$query->whereOr(['au.unionid' => $user['unionid']]);
|
||
}
|
||
})
|
||
->value('user_id');
|
||
|
||
if (empty($user_id)) {
|
||
$user_info = UserServer::createUser($user, Client_::oa);
|
||
} else {
|
||
$user_info = UserServer::updateUser($user, Client_::oa, $user_id);
|
||
}
|
||
|
||
if (empty($user_info)) {
|
||
return self::dataError('登录失败:user');
|
||
}
|
||
|
||
if ($user_info['disable']) {
|
||
return self::dataError('账号已被禁用');
|
||
}
|
||
|
||
//创建会话
|
||
$user_info['token'] = self::createSession($user_info['id'], Client_::oa);
|
||
|
||
|
||
unset($user_info['id']);
|
||
unset($user_info['disable']);
|
||
return self::dataSuccess('登录成功', $user_info);
|
||
|
||
}
|
||
|
||
/**
|
||
* User: 意象信息科技 lr
|
||
* Desc: 微信第三方app登录
|
||
* @param $post
|
||
* @return array|\PDOStatement|string|\think\Model|null
|
||
* @throws Exception
|
||
* @throws \EasyWeChat\Kernel\Exceptions\DecryptException
|
||
* @throws \EasyWeChat\Kernel\Exceptions\InvalidConfigException
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
* @throws \think\exception\PDOException
|
||
*/
|
||
public static function opLogin($post)
|
||
{
|
||
//微信调用
|
||
try {
|
||
$config = WeChatServer::getOpConfig();
|
||
$app = Factory::officialAccount($config);
|
||
$response = $app
|
||
->oauth
|
||
->scopes(['snsapi_userinfo'])
|
||
->getAccessToken($post['code']);
|
||
$app->access_token->setToken($response->offsetGet('access_token'));
|
||
|
||
//sdk不支持app登录，直接调用微信接口
|
||
$requests = Requests::get('https://api.weixin.qq.com/sns/userinfo?openid=' . 'openid=' . $response->offsetGet('openid') . '&access_token=' . $response->offsetGet('access_token')
|
||
);
|
||
$user = json_decode($requests->body, true);
|
||
} catch (Exception $e) {
|
||
return self::dataError('登录失败:' . $e->getMessage());
|
||
}catch (\think\Exception $e){
|
||
return self::dataError('登录失败:' . $e->getMessage());
|
||
}
|
||
|
||
|
||
//添加或更新用户
|
||
$user_id = Db::name('user_auth au')
|
||
->join('user u', 'au.user_id=u.id')
|
||
->where(['u.del' => 0])
|
||
->where(function ($query) use ($user) {
|
||
$query->whereOr(['au.openid' => $user['openid']])
|
||
->whereOr(['au.unionid' => $user['unionid']]);
|
||
})
|
||
->value('user_id');
|
||
|
||
if (empty($user_id)) {
|
||
$user_info = UserServer::createUser($user, $post['client']);
|
||
} else {
|
||
$user_info = UserServer::updateUser($user, $post['client'], $user_id);
|
||
}
|
||
|
||
if (empty($user_info)) {
|
||
return self::dataError('登录失败:user');
|
||
}
|
||
|
||
if ($user_info['disable']) {
|
||
return self::dataError('账号已被禁用');
|
||
}
|
||
|
||
//创建会话
|
||
$user_info['token'] = self::createSession($user_info['id'], $post['client']);
|
||
|
||
|
||
unset($user_info['id']);
|
||
unset($user_info['disable']);
|
||
return self::dataSuccess('登录成功', $user_info);
|
||
|
||
}
|
||
|
||
/**
|
||
* app登录
|
||
* @param $post
|
||
* @return array|\PDOStatement|string|\think\Model|null
|
||
* @throws \think\Exception
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
* @throws \think\exception\PDOException
|
||
*/
|
||
public static function login($post)
|
||
{
|
||
$user_info = Db::name('user')
|
||
->field(['id', 'nickname', 'avatar', 'level', 'disable', 'distribution_code'])
|
||
->where(['account|mobile' => $post['account']])
|
||
->find();
|
||
$user_info['token'] = self::createSession($user_info['id'], $post['client']);
|
||
if (empty($user_info['avatar'])) {
|
||
$user_info['avatar'] = UrlServer::getFileUrl(ConfigServer::get('website', 'user_image'));
|
||
} else {
|
||
$user_info['avatar'] = UrlServer::getFileUrl($user_info['avatar']);
|
||
}
|
||
return $user_info;
|
||
}
|
||
|
||
/**
|
||
* 退出登录
|
||
* @param $user_id
|
||
* @param $client
|
||
* @return string
|
||
* @throws \think\Exception
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
* @throws \think\exception\PDOException
|
||
*/
|
||
public static function logout($user_id, $client)
|
||
{
|
||
return self::expirationSession($user_id, $client);
|
||
}
|
||
|
||
|
||
/**
|
||
* 设置会话过期
|
||
* @param $user_id
|
||
* @param $client
|
||
* @throws \think\Exception
|
||
* @throws \think\exception\PDOException
|
||
*/
|
||
public static function expirationSession($user_id, $client)
|
||
{
|
||
$time = time();
|
||
$token = Db::name('session')
|
||
->where(['user_id' => $user_id, 'client' => $client])
|
||
->value('token');
|
||
$token_cache = new TokenCache($token);
|
||
$token_cache->del();
|
||
return Db::name('session')
|
||
->where(['user_id' => $user_id, 'client' => $client])
|
||
->update(['update_time' => $time, 'expire_time' => $time]);
|
||
}
|
||
|
||
|
||
/**
|
||
* 创建会话
|
||
* @param $user_id
|
||
* @param $client
|
||
* @return string
|
||
* @throws \think\Exception
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
* @throws \think\exception\PDOException
|
||
*/
|
||
public static function createSession($user_id, $client)
|
||
{
|
||
|
||
//清除之前缓存
|
||
$token = Db::name('session')
|
||
->where(['user_id' => $user_id, 'client' => $client])
|
||
->value('token');
|
||
if($token) {
|
||
$token_cache = new TokenCache($token);
|
||
$token_cache->del();
|
||
}
|
||
|
||
$result = Db::name('session')
|
||
->where(['user_id' => $user_id, 'client' => $client])
|
||
->find();
|
||
|
||
$time = time();
|
||
$expire_time = $time + Config::get('project.token_expire_time');
|
||
$token = md5($user_id . $client . $time);
|
||
$data = [
|
||
'user_id' => $user_id,
|
||
'token' => $token,
|
||
'client' => $client,
|
||
'update_time' => $time,
|
||
'expire_time' => $expire_time,
|
||
];
|
||
|
||
if (empty($result)) {
|
||
Db::name('session')->insert($data);
|
||
} else {
|
||
Db::name('session')
|
||
->where(['user_id' => $user_id, 'client' => $client])
|
||
->update($data);
|
||
}
|
||
|
||
//更新登录信息
|
||
$login_ip = $ip = request()->ip();
|
||
Db::name('user')
|
||
->where(['id' => $user_id])
|
||
->update(['login_time' => $time, 'login_ip' => $login_ip]);
|
||
|
||
//创建新的缓存
|
||
(new TokenCache($token, ['token' => $token]))->set(300);
|
||
return $token;
|
||
}
|
||
|
||
public static function registerAward($user_id){
|
||
$register_award_integral_status = ConfigServer::get('marketing','register_award_integral_status',0);
|
||
$register_award_coupon_status = ConfigServer::get('marketing','register_award_coupon_status',0);
|
||
//赠送积分
|
||
if($register_award_integral_status){
|
||
$register_award_integral = ConfigServer::get('marketing','register_award_integral',0);
|
||
//赠送的积分
|
||
if($register_award_integral > 0){
|
||
Db::name('user')->where(['id'=>$user_id])->setInc('user_integral',$register_award_integral);
|
||
AccountLogLogic::AccountRecord($user_id,$register_award_integral,1,AccountLog::register_add_integral,'');
|
||
}
|
||
}
|
||
//注册账号，首次进入首页时领取优惠券
|
||
$register_award_coupon = ConfigServer::get('marketing','register_award_coupon','');
|
||
if($register_award_coupon_status && $register_award_coupon){
|
||
Cache::tag('register_coupon')->set('register_coupon_'.$user_id,$register_award_coupon);
|
||
}
|
||
//会员等级
|
||
$user_level = Db::name('user_level')->where(['del'=>0,'growth_value'=>0])->find();
|
||
if($user_level){
|
||
Db::name('user')->where(['id'=>$user_id])->update(['level'=>$user_level['id']]);
|
||
}
|
||
}
|
||
|
||
|
||
/**
|
||
* Notes: uniApp微信登录
|
||
* @param $post
|
||
* @author 段誉(2021/3/16 16:17)
|
||
* @return array
|
||
* @throws \think\Exception
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
* @throws \think\exception\PDOException
|
||
*/
|
||
public static function uinAppLogin($post)
|
||
{
|
||
//微信调用
|
||
try {
|
||
if (empty($post['openid']) || empty($post['access_token']) || empty($post['client'])){
|
||
throw new \think\Exception('参数缺失');
|
||
}
|
||
|
||
//sdk不支持app登录，直接调用微信接口
|
||
$requests = Requests::get('https://api.weixin.qq.com/sns/userinfo?openid=' . 'openid=' . $post['openid'] . '&access_token=' . $post['access_token']);
|
||
$user = json_decode($requests->body, true);
|
||
} catch (Exception $e) {
|
||
return self::dataError('登录失败:' . $e->getMessage());
|
||
}catch (\think\Exception $e){
|
||
return self::dataError('登录失败:' . $e->getMessage());
|
||
}
|
||
|
||
//添加或更新用户
|
||
$user_id = Db::name('user_auth au')
|
||
->join('user u', 'au.user_id=u.id')
|
||
->where(['u.del' => 0])
|
||
->where(function ($query) use ($user) {
|
||
$query->whereOr(['au.openid' => $user['openid']])
|
||
->whereOr(['au.unionid' => $user['unionid']]);
|
||
})
|
||
->value('user_id');
|
||
|
||
if (empty($user_id)) {
|
||
$user_info = UserServer::createUser($user, $post['client']);
|
||
} else {
|
||
$user_info = UserServer::updateUser($user, $post['client'], $user_id);
|
||
}
|
||
|
||
//验证用户信息
|
||
$check_res = self::checkUserInfo($user_info);
|
||
if (true !== $check_res) {
|
||
return self::dataError($check_res);
|
||
}
|
||
|
||
//创建会话
|
||
$user_info['token'] = self::createSession($user_info['id'], $post['client']);
|
||
|
||
unset($user_info['id']);
|
||
unset($user_info['disable']);
|
||
return self::dataSuccess('登录成功', $user_info);
|
||
}
|
||
|
||
|
||
|
||
|
||
|
||
|
||
/**
|
||
* Notes: 根据微信返回信息查询当前用户id
|
||
* @param $response
|
||
* @author 段誉(2021/4/19 16:52)
|
||
* @return mixed
|
||
*/
|
||
public static function getUserByWechatResponse($response)
|
||
{
|
||
$user_id = Db::name('user_auth')->alias('au')
|
||
->join('user u', 'au.user_id=u.id')
|
||
->where(['u.del' => 0])
|
||
->where(function ($query) use ($response) {
|
||
$query->whereOr(['au.openid' => $response['openid']]);
|
||
if(isset($response['unionid']) && !empty($response['unionid'])){
|
||
$query->whereOr(['au.unionid' => $response['unionid']]);
|
||
}
|
||
})
|
||
->value('user_id');
|
||
return $user_id;
|
||
}
|
||
|
||
|
||
|
||
|
||
/**
|
||
* Notes: 根据code 获取微信信息(openid, unionid)
|
||
* @param $post
|
||
* @author 段誉(2021/4/19 16:52)
|
||
* @return array|\EasyWeChat\Kernel\Support\Collection|object|\Psr\Http\Message\ResponseInterface|string
|
||
* @throws Exception
|
||
* @throws \EasyWeChat\Kernel\Exceptions\InvalidConfigException
|
||
*/
|
||
public static function getWechatResByCode($post)
|
||
{
|
||
$config = WeChatServer::getMnpConfig();
|
||
$response = (new WeChatMnpService())->getMnpResByCode($post['code']);
|
||
// $app = Factory::miniProgram($config);
|
||
// $response = $app->auth->session($post['code']);
|
||
if (!isset($response['openid']) || empty($response['openid'])) {
|
||
throw new Exception('获取openID失败');
|
||
}
|
||
return $response;
|
||
}
|
||
|
||
|
||
/**
|
||
* Notes: 检车用户信息
|
||
* @param $user_info
|
||
* @author 段誉(2021/4/19 16:54)
|
||
* @return bool|string
|
||
*/
|
||
public static function checkUserInfo($user_info)
|
||
{
|
||
if (empty($user_info)) {
|
||
return '登录失败:user';
|
||
}
|
||
|
||
if ($user_info['disable']) {
|
||
return '账号已被禁用';
|
||
}
|
||
|
||
return true;
|
||
}
|
||
|
||
|
||
/**
|
||
* Notes: 旧用户登录
|
||
* @param $post
|
||
* @author 段誉(2021/4/19 16:57)
|
||
* @return array
|
||
* @throws \think\Exception
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
* @throws \think\exception\PDOException
|
||
*/
|
||
public static function silentLogin($post)
|
||
{
|
||
try {
|
||
//通过code获取微信 openid
|
||
$response = self::getWechatResByCode($post);
|
||
//通过获取到的openID或unionid获取当前 系统 用户id
|
||
$user_id = self::getUserByWechatResponse($response);
|
||
|
||
} catch (Exception $e) {
|
||
return self::dataError('登录失败:' . $e->getMessage());
|
||
} catch (\think\Exception $e) {
|
||
return self::dataError('登录失败:' . $e->getMessage());
|
||
}
|
||
|
||
if (empty($user_id)) {
|
||
//系统中没有用户-调用authlogin接口生成新用户
|
||
return self::dataSuccess('', []);
|
||
} else {
|
||
$user_info = UserServer::updateUser($response, Client_::mnp, $user_id);
|
||
}
|
||
|
||
//验证用户信息
|
||
$check_res = self::checkUserInfo($user_info);
|
||
if (true !== $check_res) {
|
||
return self::dataError($check_res);
|
||
}
|
||
|
||
//创建会话
|
||
$user_info['token'] = self::createSession($user_info['id'], Client_::mnp);
|
||
|
||
unset($user_info['id'], $user_info['disable']);
|
||
return self::dataSuccess('登录成功', $user_info);
|
||
}
|
||
|
||
|
||
/**
|
||
* Notes: 新用户登录
|
||
* @param $post
|
||
* @author 段誉(2021/4/19 16:57)
|
||
* @return array
|
||
* @throws \think\Exception
|
||
* @throws \think\db\exception\DataNotFoundException
|
||
* @throws \think\db\exception\ModelNotFoundException
|
||
* @throws \think\exception\DbException
|
||
* @throws \think\exception\PDOException
|
||
*/
|
||
public static function authLogin($post)
|
||
{
|
||
try {
|
||
//通过code获取微信 openid
|
||
$response = self::getWechatResByCode($post);
|
||
$response['headimgurl'] = $post['headimgurl'] ?? '';
|
||
$response['nickname'] = $post['nickname'] ?? '';
|
||
//通过获取到的openID或unionid获取当前 系统 用户id
|
||
$user_id = self::getUserByWechatResponse($response);
|
||
|
||
} catch (Exception $e) {
|
||
return self::dataError('登录失败:' . $e->getMessage());
|
||
} catch (\think\Exception $e) {
|
||
return self::dataError('登录失败:' . $e->getMessage());
|
||
}
|
||
|
||
if (empty($user_id)) {
|
||
$user_info = UserServer::createUser($response, Client_::mnp);
|
||
} else {
|
||
$user_info = UserServer::updateUser($response, Client_::mnp, $user_id);
|
||
}
|
||
|
||
//验证用户信息
|
||
$check_res = self::checkUserInfo($user_info);
|
||
if (true !== $check_res) {
|
||
return self::dataError($check_res);
|
||
}
|
||
|
||
//创建会话
|
||
$user_info['token'] = self::createSession($user_info['id'], Client_::mnp);
|
||
|
||
unset($user_info['id'], $user_info['disable']);
|
||
return self::dataSuccess('登录成功', $user_info);
|
||
}
|
||
|
||
/**
|
||
* @notes 更新用户头像昵称
|
||
* @param $post
|
||
* @param $user_id
|
||
* @return array
|
||
* @throws \think\Exception
|
||
* @throws \think\exception\PDOException
|
||
* @author ljj
|
||
* @date 2023/2/1 3:45 下午
|
||
*/
|
||
public static function updateUser($post,$user_id)
|
||
{
|
||
// $user = Db::name('user')->where(['id'=>$user_id])->find();
|
||
// if ($user['is_new_user'] == 0) {
|
||
// return self::dataError('非新用户无法使用此接口更新用户信息');
|
||
// }
|
||
Db::name('user')->where(['id'=>$user_id])->update(['nickname'=>$post['nickname'],'avatar'=>UrlServer::setFileUrl($post['avatar']),'is_new_user'=>0]);
|
||
return self::dataSuccess('操作成功');
|
||
}
|
||
|
||
|
||
/**
|
||
* @notes 小程序端绑定微信
|
||
* @param array $params
|
||
* @return bool
|
||
* @author lbzy
|
||
* @datetime 2023-11-29 10:57:29
|
||
*/
|
||
public function mnpAuthLogin(array $params)
|
||
{
|
||
try {
|
||
//通过code获取微信openid
|
||
$config = WeChatServer::getMnpConfig();
|
||
$app = Factory::miniProgram($config);
|
||
$response = $app->auth->session($params['code']);
|
||
if (empty($response['openid'])) {
|
||
throw new Exception('获取openID失败');
|
||
}
|
||
|
||
$userAuth = UserAuth::where('openid', $response['openid'])->findOrEmpty();
|
||
if (isset($userAuth['id'])) {
|
||
if ($userAuth['user_id'] == $params['user_id']) {
|
||
return true;
|
||
}
|
||
throw new \Exception('该微信已绑定其他用户');
|
||
}
|
||
|
||
UserAuth::create([
|
||
'user_id' => $params['user_id'],
|
||
'openid' => $response['openid'],
|
||
'create_time' => time(),
|
||
'unionid' => $response['unionid'] ?? '',
|
||
'client' => Client_::mnp,
|
||
]);
|
||
|
||
return true;
|
||
|
||
} catch (\Exception $e) {
|
||
self::$error = $e->getMessage();
|
||
return false;
|
||
}
|
||
}
|
||
|
||
/**
|
||
* @notes 公众号端绑定微信
|
||
* @param array $params
|
||
* @return bool
|
||
* @author lbzy
|
||
* @datetime 2023-11-29 10:57:24
|
||
*/
|
||
public function oaAuthLogin(array $params)
|
||
{
|
||
try {
|
||
//通过code获取微信openid
|
||
$config = WeChatServer::getOaConfig();
|
||
$app = Factory::officialAccount($config);
|
||
$response = $app
|
||
->oauth
|
||
->scopes(['snsapi_userinfo'])
|
||
->getAccessToken($params['code']);
|
||
if (empty($response['openid'])) {
|
||
throw new Exception();
|
||
}
|
||
|
||
$userAuth = UserAuth::where('openid', $response['openid'])->findOrEmpty();
|
||
if (isset($userAuth['id'])) {
|
||
if ($userAuth['user_id'] == $params['user_id']) {
|
||
return true;
|
||
}
|
||
throw new \Exception('该微信已绑定其他用户');
|
||
}
|
||
|
||
UserAuth::create([
|
||
'user_id' => $params['user_id'],
|
||
'openid' => $response['openid'],
|
||
'create_time' => time(),
|
||
'unionid' => $response['unionid'] ?? '',
|
||
'client' => Client_::oa,
|
||
]);
|
||
|
||
return true;
|
||
|
||
} catch (\Exception $e) {
|
||
self::$error = $e->getMessage();
|
||
return false;
|
||
}
|
||
}
|
||
|
||
} |