656 lines
27 KiB
PHP
656 lines
27 KiB
PHP
<?php
|
|
/**
|
|
* ThinkShop商城系统 - 团队十年电商经验汇集巨献!
|
|
* =========================================================
|
|
* Copy right 2019-2029 成都云之牛科技有限公司, 保留所有权利。
|
|
* ----------------------------------------------
|
|
* 官方网址: https://www.cdcloudshop.com
|
|
* =========================================================
|
|
*/
|
|
|
|
namespace app\model\member;
|
|
|
|
use addon\aliapp\model\AliPayApplet;
|
|
use addon\wechat\model\Message as WechatMessage;
|
|
use app\model\BaseModel;
|
|
use app\model\message\Sms;
|
|
use think\Exception;
|
|
use think\facade\Db;
|
|
|
|
/**
|
|
* 登录
|
|
*
|
|
* @author Administrator
|
|
*
|
|
*/
|
|
class Login extends BaseModel{
|
|
/**
|
|
* 用户登录
|
|
* @param unknown $data 必然传输username
|
|
*/
|
|
public function login($data){
|
|
|
|
//必然传输usern
|
|
$info = model("member")->getInfo([
|
|
['username|mobile|email','=',$data['username']],
|
|
['password','=',data_md5($data['password'])],
|
|
['site_id','=',$data['site_id']],
|
|
['is_delete','=',0]
|
|
],'member_id,
|
|
username, nickname, mobile, email, status,last_login_time,can_receive_registergift');
|
|
if(empty($info)){
|
|
return $this->error('','USERNAME_OR_PASSWORD_ERROR');
|
|
}
|
|
elseif($info['status'] == 0){
|
|
return $this->error('','MEMBER_IS_LOCKED');
|
|
}
|
|
else{
|
|
if($info['can_receive_registergift'] == 1){
|
|
event("MemberReceiveRegisterGift",['member_id' => $info['member_id'],'site_id' => $data['site_id']]);
|
|
}
|
|
//更新登录时间
|
|
model("member")->update([
|
|
'login_time' => time(),
|
|
'last_login_time' => time(),
|
|
'can_receive_registergift' => 0,
|
|
'login_ip' => request()->ip(),
|
|
'login_type' => $data['app_type'] ?? '',
|
|
'login_type_name' => $data['app_type_name'] ?? '',
|
|
],[['member_id','=',$info['member_id']]]);
|
|
//执行登录奖励
|
|
event("MemberLogin",['member_id' => $info['member_id'],'site_id' => $data['site_id']],TRUE);
|
|
//用户第三方信息刷新
|
|
$this->refreshAuth($info['member_id'],$data);
|
|
return $this->success($info);
|
|
}
|
|
}
|
|
/**
|
|
* 第三方登录
|
|
* @param array $data 必然传输auth_tag, auth_openid
|
|
*/
|
|
public function authLogin($data){
|
|
$info = [];
|
|
$auth_tag = '';
|
|
foreach($data as $key => $value){
|
|
if(in_array($key,[
|
|
'wx_unionid',
|
|
'wx_openid',
|
|
'weapp_openid',
|
|
'qq_openid',
|
|
'ali_openid',
|
|
'baidu_openid',
|
|
'toutiao_openid'
|
|
])){
|
|
$auth_tag = $key;
|
|
if(empty($value)) return $this->error('','PARAMETER_ERROR');
|
|
$info = model("member")->getInfo([
|
|
[$key,'=',$value],
|
|
['site_id','=',$data['site_id']],
|
|
['is_delete','=',0]
|
|
],'member_id,username, nickname, mobile, email, status, last_login_time, can_receive_registergift');
|
|
if(!empty($info)) break;
|
|
}
|
|
}
|
|
if(empty($auth_tag)) return $this->error('','PARAMETER_ERROR');
|
|
if(empty($info)){
|
|
// 会员不存在 第三方自动注册开启 未开启绑定手机 则进行自动注册
|
|
$config = new Config();
|
|
$config_info = $config->getRegisterConfig($data['site_id'],'shop');
|
|
if($config_info['data']['value']['third_party'] && !$config_info['data']['value']['bind_mobile']){
|
|
$register = new Register();
|
|
$register_res = $register->authRegister($data);
|
|
if($register_res['code'] == 0){
|
|
$info = model("member")->getInfo([
|
|
[
|
|
'member_id',
|
|
'=',
|
|
$register_res['data']
|
|
]
|
|
],'member_id,username, nickname, mobile, email, status, last_login_time,can_receive_registergift');
|
|
$info['is_register'] = 1;
|
|
}
|
|
}
|
|
}
|
|
if(empty($info)){
|
|
return $this->error('','MEMBER_NOT_EXIST');
|
|
}
|
|
elseif($info['status'] == 0){
|
|
return $this->error('','MEMBER_IS_LOCKED');
|
|
}
|
|
else{
|
|
// 登录成功后信息处理
|
|
$this->loginSuccessOperation($info,$data);
|
|
//用户第三方信息刷新
|
|
if(!isset($info['is_register'])) $this->refreshAuth($info['member_id'],$data);
|
|
|
|
return $this->success($info);
|
|
}
|
|
}
|
|
|
|
// 承诺登录（需要同意承诺书后方可登录）
|
|
public function promiseLogin($data){
|
|
$data['wx_unionid'] = $data['wx_unionid'] ?? '';
|
|
$data['weapp_openid'] = $data['weapp_openid'] ?? '';
|
|
if(!$data['wx_unionid'] && !$data['weapp_openid']) return $this->error('','参数错误，微信登录失败！');
|
|
// 获取用户信息
|
|
$info = (array)Db::name('member')
|
|
->field('member_id,username, nickname, mobile, email, status, last_login_time, can_receive_registergift')
|
|
->where(function($query) use ($data){
|
|
if($data['weapp_openid'] && $data['wx_unionid']) $query->where('weapp_openid',$data['weapp_openid'])->whereOr('wx_unionid',$data['wx_unionid']);
|
|
else if($data['weapp_openid']) $query->where('weapp_openid',$data['weapp_openid']);
|
|
else if($data['wx_unionid']) $query->where('wx_unionid',$data['wx_unionid']);
|
|
})
|
|
->where('site_id',$data['site_id'])
|
|
->where('is_delete',0)
|
|
->find();
|
|
// 判断用户是否存在 进行对应的操作
|
|
if(!$info){
|
|
$config = new Config();
|
|
$configInfo = $config->getRegisterConfig($data['site_id'])['data'];
|
|
$configInfo = $configInfo['value'] ?? [];
|
|
// 会员不存在 并且存在承诺书 进行承诺书判断
|
|
if(trim($configInfo['promise']) && trim($data['promise_text']) != trim($configInfo['promise'])) {
|
|
if($data['request_type'] == 'login') return $this->error('','MEMBER_NOT_EXIST_REQUEST_REGISTER');
|
|
else return $this->error('','PLEASE_ENTER_THE_CORRECT_CONTENT_OF_THE_LETTER_OF_COMMITMENT');
|
|
}
|
|
// 会员不存在 第三方自动注册开启 未开启绑定手机 则进行自动注册
|
|
if($configInfo['third_party'] && !$configInfo['bind_mobile']){
|
|
$register = new Register();
|
|
$register_res = $register->authRegister($data);
|
|
if($register_res['code'] == 0){
|
|
$info = model("member")->getInfo([
|
|
[
|
|
'member_id',
|
|
'=',
|
|
$register_res['data']
|
|
]
|
|
],'member_id,username, nickname, mobile, email, status, last_login_time,can_receive_registergift');
|
|
$info['is_register'] = 1;
|
|
}
|
|
}
|
|
}
|
|
// 根据登录结果进行返回操作
|
|
if(!$info) return $this->error('','MEMBER_NOT_EXIST');
|
|
elseif($info['status'] == 0) return $this->error('','MEMBER_IS_LOCKED');
|
|
else{
|
|
// 登录成功后信息处理
|
|
$this->loginSuccessOperation($info,$data);
|
|
//用户第三方信息刷新
|
|
if(!isset($info['is_register'])) $this->refreshAuth($info['member_id'],$data);
|
|
return $this->success($info);
|
|
}
|
|
}
|
|
|
|
|
|
/**
|
|
* 授权登录仅登录
|
|
* @param $data
|
|
* @return array
|
|
*/
|
|
public function authOnlyLogin($data){
|
|
$info = [];
|
|
$auth_tag = '';
|
|
foreach($data as $key => $value){
|
|
if(in_array($key,[
|
|
'wx_unionid',
|
|
'wx_openid',
|
|
'weapp_openid',
|
|
'qq_openid',
|
|
'ali_openid',
|
|
'baidu_openid',
|
|
'toutiao_openid'
|
|
])){
|
|
$auth_tag = $key;
|
|
if(empty($value)) return $this->error('','PARAMETER_ERROR');
|
|
$info = model("member")->getInfo([
|
|
[$key,'=',$value],
|
|
['site_id','=',$data['site_id']],
|
|
['is_delete','=',0]
|
|
],'member_id,username, nickname, mobile, email, status, last_login_time, can_receive_registergift');
|
|
if(!empty($info)) break;
|
|
}
|
|
}
|
|
if(empty($auth_tag)) return $this->error('','PARAMETER_ERROR');
|
|
if(empty($info)){
|
|
return $this->error('','MEMBER_NOT_EXIST');
|
|
}
|
|
elseif($info['status'] == 0){
|
|
return $this->error('','MEMBER_IS_LOCKED');
|
|
}
|
|
else{
|
|
//更新登录时间
|
|
model("member")->update([
|
|
'login_time' => time(),
|
|
'last_login_time' => time(),
|
|
'can_receive_registergift' => 0,
|
|
'login_ip' => request()->ip(),
|
|
'login_type' => $data['app_type'] ?? '',
|
|
'login_type_name' => $data['app_type_name'] ?? '',
|
|
],[['member_id','=',$info['member_id']]]);
|
|
//执行登录奖励
|
|
event("MemberLogin",['member_id' => $info['member_id'],'site_id' => $data['site_id']],TRUE);
|
|
//用户第三方信息刷新
|
|
$this->refreshAuth($info['member_id'],$data);
|
|
return $this->success($info);
|
|
}
|
|
}
|
|
/**
|
|
* 刷新第三方信息
|
|
* @param unknown $member_id
|
|
* @param unknown $data
|
|
* @return multitype:string
|
|
*/
|
|
private function refreshAuth($member_id,$data){
|
|
Member::modifyLastVisitTime($member_id);
|
|
$data = [
|
|
'qq_openid' => isset($data['qq_openid']) ? $data['qq_openid'] : '',
|
|
'wx_openid' => isset($data['wx_openid']) ? $data['wx_openid'] : '',
|
|
'weapp_openid' => isset($data['weapp_openid']) ? $data['weapp_openid'] : '',
|
|
'wx_unionid' => isset($data['wx_unionid']) ? $data['wx_unionid'] : '',
|
|
'ali_openid' => isset($data['ali_openid']) ? $data['ali_openid'] : '',
|
|
'baidu_openid' => isset($data['baidu_openid']) ? $data['baidu_openid'] : '',
|
|
'toutiao_openid' => isset($data['toutiao_openid']) ? $data['toutiao_openid'] : '',
|
|
'site_id' => $data['site_id']
|
|
];
|
|
if(!empty($data['qq_openid'])){
|
|
model("member")->update(['qq_openid' => ''],[
|
|
['qq_openid','=',$data['qq_openid']],
|
|
['site_id','=',$data['site_id']]
|
|
]);
|
|
model("member")->update(['qq_openid' => $data['qq_openid']],[
|
|
['member_id','=',$member_id],
|
|
['site_id','=',$data['site_id']]
|
|
]);
|
|
}
|
|
if(!empty($data['wx_openid'])){
|
|
model("member")->update(['wx_openid' => ''],[
|
|
['wx_openid','=',$data['wx_openid']],
|
|
['site_id','=',$data['site_id']]
|
|
]);
|
|
model("member")->update(['wx_openid' => $data['wx_openid']],[
|
|
['member_id','=',$member_id],
|
|
['site_id','=',$data['site_id']]
|
|
]);
|
|
}
|
|
if(!empty($data['weapp_openid'])){
|
|
model("member")->update(['weapp_openid' => ''],[
|
|
['weapp_openid','=',$data['weapp_openid']],
|
|
['site_id','=',$data['site_id']]
|
|
]);
|
|
model("member")->update(['weapp_openid' => $data['weapp_openid']],[
|
|
['member_id','=',$member_id],
|
|
['site_id','=',$data['site_id']]
|
|
]);
|
|
}
|
|
if(!empty($data['wx_unionid'])){
|
|
model("member")->update(['wx_unionid' => ''],[
|
|
['wx_unionid','=',$data['wx_unionid']],
|
|
['site_id','=',$data['site_id']]
|
|
]);
|
|
model("member")->update(['wx_unionid' => $data['wx_unionid']],[
|
|
['member_id','=',$member_id],
|
|
['site_id','=',$data['site_id']]
|
|
]);
|
|
}
|
|
if(!empty($data['ali_openid'])){
|
|
model("member")->update(['ali_openid' => ''],[
|
|
['ali_openid','=',$data['ali_openid']],
|
|
['site_id','=',$data['site_id']]
|
|
]);
|
|
model("member")->update(['ali_openid' => $data['ali_openid']],[
|
|
['member_id','=',$member_id],
|
|
['site_id','=',$data['site_id']]
|
|
]);
|
|
}
|
|
if(!empty($data['baidu_openid'])){
|
|
model("member")->update(['baidu_openid' => ''],[
|
|
['baidu_openid','=',$data['baidu_openid']],
|
|
['site_id','=',$data['site_id']]
|
|
]);
|
|
model("member")->update(['baidu_openid' => $data['baidu_openid']],[
|
|
['member_id','=',$member_id],
|
|
['site_id','=',$data['site_id']]
|
|
]);
|
|
}
|
|
if(!empty($data['toutiao_openid'])){
|
|
model("member")->update(['toutiao_openid' => ''],[
|
|
['toutiao_openid','=',$data['toutiao_openid']],
|
|
['site_id','=',$data['site_id']]
|
|
]);
|
|
model("member")->update(['toutiao_openid' => $data['toutiao_openid']],[
|
|
['member_id','=',$member_id],
|
|
['site_id','=',$data['site_id']]
|
|
]);
|
|
}
|
|
return $this->success();
|
|
}
|
|
/**
|
|
* 检测openid是否存在
|
|
* @param array $data
|
|
*/
|
|
public function openidIsExits(array $data){
|
|
if(isset($data['wx_unionid']) && !empty($data['wx_unionid'])){
|
|
$count = model("member")->getCount([
|
|
['wx_unionid','=',$data['wx_unionid']],
|
|
['site_id','=',$data['site_id']],
|
|
['is_delete','=',0]
|
|
]);
|
|
if($count) return $this->success($count);
|
|
}
|
|
if(isset($data['wx_openid']) && !empty($data['wx_openid'])){
|
|
$count = model("member")->getCount([
|
|
['wx_openid','=',$data['wx_openid']],
|
|
['site_id','=',$data['site_id']],
|
|
['is_delete','=',0]
|
|
]);
|
|
if($count) return $this->success($count);
|
|
}
|
|
if(isset($data['weapp_openid']) && !empty($data['weapp_openid'])){
|
|
$count = model("member")->getCount([
|
|
['weapp_openid','=',$data['weapp_openid']],
|
|
['site_id','=',$data['site_id']],
|
|
['is_delete','=',0]
|
|
]);
|
|
if($count) return $this->success($count);
|
|
}
|
|
if(isset($data['qq_openid']) && !empty($data['qq_openid'])){
|
|
$count = model("member")->getCount([
|
|
['qq_openid','=',$data['qq_openid']],
|
|
['site_id','=',$data['site_id']],
|
|
['is_delete','=',0]
|
|
]);
|
|
if($count) return $this->success($count);
|
|
}
|
|
if(isset($data['ali_openid']) && !empty($data['ali_openid'])){
|
|
$count = model("member")->getCount([
|
|
['ali_openid','=',$data['ali_openid']],
|
|
['site_id','=',$data['site_id']],
|
|
['is_delete','=',0]
|
|
]);
|
|
if($count) return $this->success($count);
|
|
}
|
|
if(isset($data['baidu_openid']) && !empty($data['baidu_openid'])){
|
|
$count = model("member")->getCount([
|
|
['baidu_openid','=',$data['baidu_openid']],
|
|
['site_id','=',$data['site_id']],
|
|
['is_delete','=',0]
|
|
]);
|
|
if($count) return $this->success($count);
|
|
}
|
|
if(isset($data['toutiao_openid']) && !empty($data['toutiao_openid'])){
|
|
$count = model("member")->getCount([
|
|
['toutiao_openid','=',$data['toutiao_openid']],
|
|
['site_id','=',$data['site_id']],
|
|
['is_delete','=',0]
|
|
]);
|
|
if($count) return $this->success($count);
|
|
}
|
|
return $this->success(0);
|
|
}
|
|
/**
|
|
* 用户登录
|
|
* @param unknown $data 必然传输username
|
|
*/
|
|
public function mobileLogin($data){
|
|
//必然传输usern
|
|
$info = model("member")->getInfo([
|
|
['mobile','=',$data['mobile']],
|
|
['site_id','=',$data['site_id']],
|
|
['is_delete','=',0]
|
|
],'member_id,username, nickname, mobile, email, status,last_login_time, can_receive_registergift');
|
|
if(empty($info)){
|
|
return $this->error('','MEMBER_NOT_EXIST');
|
|
}
|
|
elseif($info['status'] == 0){
|
|
return $this->error('','MEMBER_IS_LOCKED');
|
|
}
|
|
else{
|
|
if($info['can_receive_registergift'] == 1){
|
|
event("MemberReceiveRegisterGift",['member_id' => $info['member_id'],'site_id' => $data['site_id']]);
|
|
}
|
|
//更新登录时间
|
|
model("member")->update([
|
|
'login_time' => time(),
|
|
'last_login_time' => time(),
|
|
'can_receive_registergift' => 0,
|
|
'login_ip' => request()->ip(),
|
|
'login_type' => $data['app_type'] ?? '',
|
|
'login_type_name' => $data['app_type_name'] ?? '',
|
|
],[['member_id','=',$info['member_id']]]);
|
|
event("MemberLogin",['member_id' => $info['member_id'],'site_id' => $data['site_id']],TRUE);
|
|
//用户第三方信息刷新
|
|
$this->refreshAuth($info['member_id'],$data);
|
|
return $this->success($info);
|
|
}
|
|
}
|
|
/**
|
|
* 登录动态码
|
|
* @param $data
|
|
*/
|
|
public function loginCode($data){
|
|
//发送短信
|
|
$sms_model = new Sms();
|
|
$var_parse = [
|
|
"code" => $data["code"],
|
|
];
|
|
$data["sms_account"] = $data["mobile"] ?? '';//手机号
|
|
$data["var_parse"] = $var_parse;
|
|
$sms_result = $sms_model->sendMessage($data);
|
|
if($sms_result["code"] < 0) return $sms_result;
|
|
return $this->success();
|
|
}
|
|
/**
|
|
* 登录通知
|
|
* @param $data
|
|
* @return array|mixed|void
|
|
*/
|
|
public function loginSuccess($data){
|
|
$member_model = new Member();
|
|
$member_info_result = $member_model->getMemberInfo([
|
|
[
|
|
"member_id",
|
|
"=",
|
|
$data["member_id"]
|
|
]
|
|
],"username,mobile,email,reg_time,wx_openid,last_login_type,login_time, nickname");
|
|
$member_info = $member_info_result["data"];
|
|
//发送短信
|
|
$sms_model = new Sms();
|
|
$name = $member_info["nickname"] == '' ? $member_info["mobile"] : $member_info["nickname"];
|
|
$var_parse = [
|
|
"name" => replaceSpecialChar($name),//验证码
|
|
];
|
|
$data["sms_account"] = $member_info["mobile"] ?? '';//手机号
|
|
$data["var_parse"] = $var_parse;
|
|
$sms_result = $sms_model->sendMessage($data);
|
|
// if($sms_result["code"] < 0)
|
|
// return $sms_result;
|
|
//发送模板消息
|
|
$wechat_model = new WechatMessage();
|
|
$data["openid"] = $member_info["wx_openid"];
|
|
// if(!empty($member_info["username"])){
|
|
// $user_account = $member_info["username"];
|
|
// }else{
|
|
// if(!empty($member_info["mobile"])){
|
|
// $user_account = $member_info["mobile"];
|
|
// }else{
|
|
// $user_account = $member_info["email"];
|
|
// }
|
|
// }
|
|
$data["template_data"] = [
|
|
'keyword1' => !empty($member_info["nickname"]) ? $member_info["nickname"] : $member_info["mobile"],
|
|
'keyword2' => '登录成功',
|
|
'keyword3' => time_to_date($member_info["login_time"]),
|
|
];
|
|
$data["page"] = '';
|
|
$wechat_model->sendMessage($data);
|
|
return $this->success();
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
* Common: 支付宝小程序登录 —— 开始处理
|
|
* Author: wu-hui
|
|
* Time: 2023/01/05 15:02
|
|
* @param $wholeParams
|
|
* @return array
|
|
* @throws Exception
|
|
* @throws \think\db\exception\DataNotFoundException
|
|
* @throws \think\db\exception\DbException
|
|
* @throws \think\db\exception\ModelNotFoundException
|
|
*/
|
|
public function alipayLoginHandle($wholeParams){
|
|
$aliPayAppletModel = new AliPayApplet($wholeParams['site_id']);
|
|
// 获取用户基本信息
|
|
$baseInfo = $aliPayAppletModel->loginBaseInfo($wholeParams['code']);
|
|
if($baseInfo['code'] != 0) throw new Exception($baseInfo['message']);
|
|
// 获取用户详细信息
|
|
$detailsInfo = $aliPayAppletModel->loginDetailsInfo($baseInfo['data']['access_token']);
|
|
if($detailsInfo['code'] != 0) throw new Exception($detailsInfo['message']);
|
|
// 处理用户信息
|
|
$loginInfo = array_merge($baseInfo['data'],$detailsInfo['data']);
|
|
$loginInfo['site_id'] = $wholeParams['site_id'];
|
|
$loginInfo['provider'] = $wholeParams['provider'];
|
|
$loginInfo['app_type'] = $wholeParams['app_type'];
|
|
// 获取用户本平台信息
|
|
$userInfo = $this->alipayLoginGetUserInfo($loginInfo['user_id'],$wholeParams['site_id']);
|
|
if(!$userInfo) $userInfo = $this->alipayLoginRegister($wholeParams,$loginInfo);
|
|
// 粉丝信息处理
|
|
$this->loginFansHandle($userInfo,$loginInfo);
|
|
// 登录成功后的操作
|
|
$this->loginSuccessOperation($userInfo,$wholeParams);
|
|
|
|
return $this->success($userInfo);
|
|
}
|
|
/**
|
|
* Common: 支付宝小程序登录 —— 获取用户信息
|
|
* Author: wu-hui
|
|
* Time: 2023/01/05 14:37
|
|
* @param $userId
|
|
* @return array|mixed|Db|\think\Model|null
|
|
* @throws \think\db\exception\DataNotFoundException
|
|
* @throws \think\db\exception\DbException
|
|
* @throws \think\db\exception\ModelNotFoundException
|
|
*/
|
|
public function alipayLoginGetUserInfo($userId,$siteId){
|
|
return Db::name('member')
|
|
->field('member_id,username,headimg,nickname, mobile, email, status, last_login_time, can_receive_registergift')
|
|
->where('site_id',$siteId)
|
|
->where('ali_openid',$userId)
|
|
->find();
|
|
}
|
|
/**
|
|
* Common: 支付宝小程序登录 —— 用户注册
|
|
* Author: wu-hui
|
|
* Time: 2023/01/05 14:48
|
|
* @param $wholeParams
|
|
* @param $loginInfo
|
|
* @return array|mixed|Db|\think\Model
|
|
* @throws Exception
|
|
* @throws \think\db\exception\DataNotFoundException
|
|
* @throws \think\db\exception\DbException
|
|
* @throws \think\db\exception\ModelNotFoundException
|
|
*/
|
|
public function alipayLoginRegister($wholeParams,$loginInfo){
|
|
$registerData = [
|
|
'site_id' => $wholeParams['site_id'] ?? '',
|
|
'source_member' => $wholeParams['source_member'] ?? '',
|
|
'nickName' => $loginInfo['nick_name'] ?? '',
|
|
'ali_openid' => $loginInfo['user_id'] ?? '',
|
|
'avatarUrl' => $loginInfo['avatar'] ?? '',
|
|
'app_type' => $wholeParams['app_type'] ?? '',
|
|
'app_type_name' => $wholeParams['app_type_name'] ?? '',
|
|
];
|
|
|
|
$registerResult = (new Register())->authRegister($registerData);
|
|
if($registerResult['code'] == 0){
|
|
$userInfo = $this->alipayLoginGetUserInfo($loginInfo['user_id'],$wholeParams['site_id']);
|
|
$userInfo['is_register'] = 1;
|
|
|
|
return $userInfo;
|
|
}
|
|
|
|
throw new Exception('注册失败：'.$registerResult['message']);
|
|
}
|
|
/**
|
|
* Common: 登录处理 —— 粉丝信息处理
|
|
* Author: wu-hui
|
|
* Time: 2023/01/05 15:28
|
|
* @param $userInfo
|
|
* @param $loginInfo
|
|
* @throws \think\db\exception\DbException
|
|
*/
|
|
public function loginFansHandle($userInfo,$loginInfo){
|
|
$time = time();
|
|
$ip = request()->ip();
|
|
// 判断：粉丝是否存在
|
|
$has = (int)Db::name('uni_fans')->where('site_id',$loginInfo['site_id'])->where('uid',$userInfo['member_id'])->value('id');
|
|
if($has > 0){
|
|
// 用户存在 修改信息
|
|
$updateData = [
|
|
'update_time' => $time,
|
|
'login_time' => $time,
|
|
'login_ip' => $ip,
|
|
];
|
|
Db::name('uni_fans')->where('site_id',$loginInfo['site_id'])->where('uid',$userInfo['member_id'])->update($updateData);
|
|
}
|
|
else{
|
|
// 用户不存在 添加
|
|
$insertData = [
|
|
'site_id' => $loginInfo['site_id'],
|
|
'uid' => $userInfo['member_id'],
|
|
'app_type' => $loginInfo['app_type'],
|
|
'open_id' => $loginInfo['user_id'] ?? '',
|
|
'unionid' => $loginInfo['unionid'] ?? '',
|
|
'nickname' => $userInfo['nickname'] ?? '',
|
|
'headimg' => $userInfo['headimg'] ?? '',
|
|
'create_time' => $time,
|
|
'update_time' => $time,
|
|
'login_time' => $time,
|
|
'login_ip' => $ip,
|
|
];
|
|
|
|
Db::name('uni_fans')->insert($insertData);
|
|
}
|
|
}
|
|
/**
|
|
* Common: 登录处理 —— 登录成功后的信息处理
|
|
* Author: wu-hui
|
|
* Time: 2023/01/05 14:58
|
|
* @param $userInfo
|
|
* @param $wholeParams
|
|
* @throws \think\db\exception\DbException
|
|
*/
|
|
public function loginSuccessOperation($userInfo,$wholeParams){
|
|
$time = time();
|
|
// 是否可以领取新人礼包
|
|
if($userInfo['can_receive_registergift'] == 1) {
|
|
$params = [
|
|
'member_id' => $userInfo['member_id'],
|
|
'site_id' => $wholeParams['site_id']
|
|
];
|
|
event("MemberReceiveRegisterGift",$params);
|
|
}
|
|
// 更新用户信息
|
|
$updateLoginTime = [
|
|
'login_time' => $time,
|
|
'last_login_time' => $time,
|
|
'last_visit_time' => $time,
|
|
'can_receive_registergift' => 0,
|
|
'login_ip' => request()->ip(),
|
|
'login_type' => $wholeParams['app_type'] ?? '',
|
|
'login_type_name' => $wholeParams['app_type_name'] ?? '',
|
|
];
|
|
Db::name('member')->where('site_id',$wholeParams['site_id'])->where('member_id',$userInfo['member_id'])->update($updateLoginTime);
|
|
// 执行登录奖励
|
|
$loginReward = [
|
|
'member_id' => $userInfo['member_id'],
|
|
'site_id' => $wholeParams['site_id']
|
|
];
|
|
event("MemberLogin",$loginReward,TRUE);
|
|
}
|
|
|
|
|
|
|
|
} |