fastadmin第三方登录

admin

1. 
   
2.     /**
   
3.      * 第三方登录
   
4.      * @param string $platform 平台
   
5.      * @param array  $params   参数
   
6.      * @param array  $extend   会员扩展信息
   
7.      * @param int    $keeptime 有效时长
   
8.      * @return boolean
   
9.      */
   
10.     public static function connect($platform, $params = [], $extend = [], $keeptime = 0)
    
11.     {
    
12. 
    
13.         $time = time();
    
14.         $nickname = $params['nickname'] ?? ($params['userinfo']['nickname'] ?? '');
    
15.         $avatar = $params['avatar'] ?? ($params['userinfo']['avatar'] ?? '');
    
16.         $access_token = $params['access_token'] ?? '';
    
17.         $refresh_token = $params['refresh_token'] ?? '';
    
18.         $expires_in = $params['expires_in'] ?? 0;
    
19.         $values = [
    
20.             'platform'      => $platform,
    
21.             'openid'        => $params['openid'],
    
22.             'openname'      => $nickname,
    
23.             'avatar'        => $avatar,
    
24.             'access_token'  => $access_token,
    
25.             'refresh_token' => $refresh_token,
    
26.             'expires_in'    => $expires_in,
    
27.             'logintime'     => $time,
    
28.             'expiretime'    => $time + $expires_in,
    
29.         ];
    
30.         $values = array_merge($values, $params);
    
31. 
    
32.         $auth = \app\common\library\Auth::instance();
    
33. 
    
34.         $auth->keeptime($keeptime);
    
35.         //是否有自己的
    
36.         $third = self::get(['platform' => $platform, 'openid' => $params['openid']], 'user');
    
37.         if ($third) {
    
38.             if (!$third->user) {
    
39.                 $third->delete();
    
40.             } else {
    
41.                 $third->allowField(true)->save($values);
    
42.                 // 写入登录Cookies和Token
    
43.                 return $auth->direct($third->user_id);
    
44.             }
    
45.         }
    
46. 
    
47.         //存在unionid就需要判断是否需要生成新记录
    
48.         if (isset($params['unionid']) && !empty($params['unionid'])) {
    
49.             $third = self::get(['platform' => $platform, 'unionid' => $params['unionid']], 'user');
    
50.             if ($third) {
    
51.                 if (!$third->user) {
    
52.                     $third->delete();
    
53.                 } else {
    
54.                     // 保存第三方信息
    
55.                     $values['user_id'] = $third->user_id;
    
56.                     $third = self::create($values, true);
    
57.                     // 写入登录Cookies和Token
    
58.                     return $auth->direct($third->user_id);
    
59.                 }
    
60.             }
    
61.         }
    
62. 
    
63.         if ($auth->id) {
    
64.             if (!$third) {
    
65.                 $values['user_id'] = $auth->id;
    
66.                 self::create($values, true);
    
67.             }
    
68.             $user = $auth->getUser();
    
69.         } else {
    
70.             // 先随机一个用户名,随后再变更为u+数字id
    
71.             $username = Random::alnum(20);
    
72.             $password = Random::alnum(6);
    
73.             $domain = request()->host();
    
74. 
    
75.             Db::startTrans();
    
76.             try {
    
77.                 // 默认注册一个会员
    
78.                 $result = $auth->register($username, $password, $username . '@' . $domain, '', $extend);
    
79.                 if (!$result) {
    
80.                     throw new Exception($auth->getError());
    
81.                 }
    
82.                 $user = $auth->getUser();
    
83.                 $fields = ['username' => 'u' . $user->id, 'email' => 'u' . $user->id . '@' . $domain];
    
84.                 if ($nickname) {
    
85.                     $fields['nickname'] = $nickname;
    
86.                 }
    
87.                 if ($avatar) {
    
88.                     $fields['avatar'] = function_exists("xss_clean") ? xss_clean(strip_tags($avatar)) : strip_tags($avatar);
    
89.                 }
    
90. 
    
91.                 // 更新会员资料
    
92.                 $user = User::get($user->id);
    
93.                 $user->save($fields);
    
94. 
    
95.                 // 保存第三方信息
    
96.                 $values['user_id'] = $user->id;
    
97.                 self::create($values, true);
    
98.                 Db::commit();
    
99.             } catch (\Exception $e) {
    
100.                 Db::rollback();
     
101.                 $auth->logout();
     
102.                 return false;
     
103.             }
     
104.         }
     
105.         // 写入登录Cookies和Token
     
106.         return $auth->direct($user->id);
     
107.     }

复制代码