diff --git a/app/controller/api/user/User.php b/app/controller/api/user/User.php index f18e25dc..bac18f0e 100644 --- a/app/controller/api/user/User.php +++ b/app/controller/api/user/User.php @@ -30,6 +30,7 @@ use think\App; use think\db\exception\DataNotFoundException; use think\db\exception\DbException; use think\db\exception\ModelNotFoundException; +use think\facade\Db; class User extends BaseController { @@ -201,6 +202,29 @@ class User extends BaseController $data = ['account' => $data['phone'], 'phone' => $data['phone']]; } $this->repository->update($this->request->uid(), $data); + $msg=Db::connect('nongke')->name('szxc_information_usermsg')->where('phone',$data['phone'])->find(); + //绑定农科用户 + if ($msg){ + $find=Db::name('nk_user')->where('n_user_id',$msg['user_id'])->find(); + $users=Db::connect('nongke')->name('user')->where('id',$msg['user_id'])->find(); + if ($find && $find['user_id']==0){ + Db::name('nk_user')->where('id',$find['id'])->update(['user_id'=>$this->request->uid(),'group_id'=>$users['group_id']]); + }else{ + $datas=[ + 'user_id'=>$this->request->uid(), + 'n_user_id'=>$users['id'], + 'group_id'=>$users['group_id'] + ]; + Db::name('nk_user')->insert($datas); + } + }else{ + $datas=[ + 'user_id'=>$this->request->uid(), + 'n_user_id'=>0, + 'group_id'=>1 + ]; + Db::name('nk_user')->insert($datas); + } return app('json')->success('绑定成功'); }