mkm/shop-php
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修复注册用户录入错误

Browse Source
This commit is contained in:
mkm 2023-02-02 11:55:44 +08:00
parent 4752d306d2
commit 17a7c82c5e
1 changed files with 43 additions and 33 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

76
app/controller/api/Auth.php
View File

@ -356,43 +356,53 @@ class Auth extends BaseController
// if (!$sms_code) return app('json')->fail('验证码不正确');
$user = $repository->accountByUser($data['phone']);
$auth = $this->parseAuthToken($data['auth_token']);
if (!$user) {
$user = $repository->registr($data['phone'], null, $data['user_type']);
$msg=Db::connect('nongke')->table('fa_szxc_information_usermsg')->where('phone',$data['phone'])->find();
if ($msg){
$nk_user=Db::name('nk_user')->where('n_user_id',$msg['user_id'])->find();
$users=Db::connect('nongke')->table('fa_user')->where('id',$msg['user_id'])->find();
if (!$nk_user){
$datas=[
'user_id'=>$user['uid'],
'n_user_id'=>$msg['user_id'],
'group_id'=>$users['group_id']
Db::startTrans();
try {
if (!$user) {
$user = $repository->registr($data['phone'], null, $data['user_type']);
$msg = Db::connect('nongke')->table('fa_szxc_information_usermsg')->where('phone', $data['phone'])->find();
if ($msg) {
$nk_user = Db::name('nk_user')->where('n_user_id', $msg['user_id'])->find();
$users = Db::connect('nongke')->table('fa_user')->where('id', $msg['user_id'])->find();
if (!$nk_user) {
$datas = [
'user_id' => $user['uid'],
'n_user_id' => $msg['user_id'],
'group_id' => $users['group_id']
];
Db::name('nk_user')->insert($datas);
} else {
Db::name('nk_user')->where('id', $nk_user['id'])->update(['user_id' => $user['uid'], 'group_id' => $users['group_id']]);
}
} else {
$time = time();
$user_data = [
'openid' => 'wx' . $time,
'group_id' => 1,
'username' => 'wx' . $time,
'nickname' => '微信用户' . $time,
'avatar' => 'https://lihai001.oss-cn-chengdu.aliyuncs.com/uploads/20230104/32a639be4ee32349705e947fbbd1e114.png',
'level' => 1,
'prevtime' => $time,
'jointime' => $time,
'createtime' => $time,
'updatetime' => $time,
'status' => 'normal'
];
$n_user_id = Db::connect('nongke')->table('fa_user')->insertGetId($user_data);
$datas = [
'user_id' => $user['uid'],
'n_user_id' => $n_user_id,
'group_id' => 1
];
Db::name('nk_user')->insert($datas);
}else{
Db::name('nk_user')->where('id',$nk_user['id'])->update(['user_id'=>$user['uid'],'group_id'=>$users['group_id']]);
}
}else{
$time=time();
$user_data=[
'openid'=>'wx'.$time,
'group_id'=>1,
'username'=>'wx'.$time,
'nickname'=>'微信用户'.$time,
'avatar'=>'https://lihai001.oss-cn-chengdu.aliyuncs.com/uploads/20230104/32a639be4ee32349705e947fbbd1e114.png',
'level'=>1,
'createtime'=>$time,
'updatetime'=>$time,
'status'=>'normal'
];
$n_user_id= Db::connect('nongke')->table('fa_user')->insertGetId($user_data);
$datas=[
'user_id'=>$user['uid'],
'n_user_id'=>$n_user_id,
'group_id'=>1
];
Db::name('nk_user')->insert($datas);
}
Db::commit();
} catch (\Exception $e) {
// 回滚事务
Db::rollback();
return app('json')->error($e->getMessage());
}
if ($auth && !$user['wechat_user_id']){
$repository->syncBaseAuth($auth, $user);