Merge branch 'jiang_fix_20210902' into 'master'

Jiang fix 20210902

See merge request bp/goods!29

application/exception/custom/UserException.php

@@ -23,5 +23,7 @@ class UserException extends BaseException
         9 => '该手机号已绑定其他用户不能重复绑定',
         10 => 'mysql 异常',
         11 => '头像昵称更新失败',
+        12 => '绑定手机号保存失败',
+        13 => '请求太频繁，稍后重试',
     ];
 }
\ No newline at end of file

application/services/user/UserService.php

@@ -14,6 +14,8 @@ use Api\PhpServices\Idgen\Idgen;
 use Api\PhpUtils\Redis\RedisUtil;
 use Api\PhpServices\JwUser\JwUser;
 use App\Services\common\CommonService;
+use Api\PhpUtils\Log\FileLog;
+use Api\PhpUtils\Lock\FrequencyLockUtil;
 
 class UserService
 {
@@ -23,12 +25,21 @@ class UserService
 
     public static function wechatLogin($params)
     {
+
         $code = !empty($params['code']) ? $params['code'] : '';//小程序授权code
         $openid = !empty($params['openid']) ? $params['openid'] : '';//小程序授权code
         if (empty($code) && empty($openid)) {
+            FileLog::error("wechatLogin:获取参数为空", json_encode($params, JSON_UNESCAPED_UNICODE),'','jianghaiming@yidian-inc.com');
             throw new UserException(['cus' => 0]);
         }
 
+        //频率锁
+        $key = "wx_wechat_login".$params['code'];
+        $lock = FrequencyLockUtil::isLocked($key);
+        if ($lock) {
+            FileLog::error("wechatLogin:请求频繁", json_encode($params, JSON_UNESCAPED_UNICODE),'','jianghaiming@yidian-inc.com');
+            throw new UserException(['cus' => 13]);
+        }
 
         //需要授权微信
         //if (empty($openid)) {
@@ -51,6 +62,7 @@ class UserService
 
             if (empty($response) || array_key_exists('errcode', $response)) {
                 //throw new \Exception('获取openid失败:' . $response['errcode']);
+                FileLog::error("wechatLogin：获取openid失败", json_encode($params, JSON_UNESCAPED_UNICODE),'','jianghaiming@yidian-inc.com');
                 throw new UserException(['cus' => 1]);
             }
             //检查系统是已注册
@@ -68,8 +80,13 @@ class UserService
                 'create_time' => date("Y-m-d H:i:s")
             ];
 
-            $newWechatId = UserWechatBind::save($insert);
+            $sessionKey = !empty($response['session_key']) ? $response['session_key'] : '';
+
+            //$newWechatId = UserWechatBind::save($insert);
+            $newWechatId =UserWechatBind::insertDuplicate($insert, ['session_key' => $sessionKey,'create_time' => date("Y-m-d H:i:s")]);
             if (!$newWechatId) {
+                FileLog::error("wechatLogin：登陆创建用户失败", json_encode($params, JSON_UNESCAPED_UNICODE),'','jianghaiming@yidian-inc.com');
+                FileLog::error("wechatLogin：登陆创建用户失败--insert", json_encode($insert, JSON_UNESCAPED_UNICODE),'','jianghaiming@yidian-inc.com');
                 throw new UserException(['cus' => 2]);
             }
 
@@ -78,13 +95,17 @@ class UserService
             $user['session_key'] = $response['session_key'];
         }else{
             if (empty($user)) {
+                FileLog::error("wechatLogin：登陆创建用户失败-- 微信response", json_encode($response, JSON_UNESCAPED_UNICODE),'','jianghaiming@yidian-inc.com');
                 throw new UserException(['cus' => 2]);
             }
 
+            if (empty($response)){
+                FileLog::error("wechatLogin：登陆创建用户失败-- 微信response 获取失败", json_encode($params, JSON_UNESCAPED_UNICODE),'','jianghaiming@yidian-inc.com');
+                throw new UserException(['cus' => 2]);
+            }
             $insert = [
                 'session_key' => !empty($response['session_key']) ? $response['session_key'] : '',
             ];
-            
             $newWechatId = UserWechatBind::save($insert,['openid' => $openid]);
         }
 
@@ -102,47 +123,47 @@ class UserService
         $appid = \Yaf\Registry::get('config')->wechat->appid;
  
         if (!$encryptedData) {
+            FileLog::error("bindPhone：encryptedData 为空", json_encode($params, JSON_UNESCAPED_UNICODE),'','jianghaiming@yidian-inc.com');
             throw new UserException(['cus' => 3]);
         }
 
         if (!$iv) {
+            FileLog::error("bindPhone：iv 为空", json_encode($params, JSON_UNESCAPED_UNICODE),'','jianghaiming@yidian-inc.com');
             throw new UserException(['cus' => 4]);
         }
 
-        $userInfo = UserWechatBind::getRecord(['openid' => $openid]);
+        $userInfo = UserWechatBind::getRecordMaster(['openid' => $openid]);
         $sessionKey = !empty($userInfo['session_key']) ? $userInfo['session_key'] : '';
         $openid = isset($userInfo['openid']) && $userInfo['openid'] ? $userInfo['openid'] : '';
         if (empty($userInfo) || !$sessionKey || !$openid) {
+            FileLog::error("bindPhone：userInfo获取失败", json_encode($userInfo, JSON_UNESCAPED_UNICODE),'','jianghaiming@yidian-inc.com');
             throw new UserException(['cus' => 5]);
         }
 
-        
-       
-
-    
- 
         //解密
         $decryptData = [];
         $wXBizDataCrypt = new WxBizDataCrypt($appid, $sessionKey);
         $errCode = $wXBizDataCrypt->decryptData($encryptedData, $iv, $decryptData);
 
-
-
-
         if ($errCode) {
+            FileLog::error("bindPhone：解密失败", json_encode($params, JSON_UNESCAPED_UNICODE),'','jianghaiming@yidian-inc.com');
             throw new UserException(['cus' => 6]);
         }
 
-        // 手机号解密成功
+        // 手机号解密失败
         if (empty($decryptData['phoneNumber'])) {
+            FileLog::error("bindPhone：手机号解密失败", json_encode($params, JSON_UNESCAPED_UNICODE),'','jianghaiming@yidian-inc.com');
+            FileLog::error("bindPhone：手机号解密失败--decryptData", json_encode($decryptData, JSON_UNESCAPED_UNICODE),'','jianghaiming@yidian-inc.com');
             throw new UserException(['cus' => 7]);
         }
 
         $phoneNumber = strval($decryptData['phoneNumber']);
 
         //判断是否已
-        $user = UserWechatBind::getRecord(['phone' => $phoneNumber]);
+        $user = UserWechatBind::getRecordMaster(['phone' => $phoneNumber]);
         if (!empty($user) &&  $openid != $user['openid']) {
+            FileLog::error("bindPhone：该手机号已绑定其他用户不能重复绑定", json_encode($params, JSON_UNESCAPED_UNICODE),'','jianghaiming@yidian-inc.com');
+            FileLog::error("bindPhone：该手机号已绑定其他用户不能重复绑定--user", json_encode($user, JSON_UNESCAPED_UNICODE),'','jianghaiming@yidian-inc.com');
             throw new UserException(['cus' => 9]);
         }
 
@@ -160,12 +181,16 @@ class UserService
         ];
         $bindStatus = UserWechatBind::save($update,['wechat_id' => $userInfo['wechat_id']]);
 
+        if (empty($bindStatus)){
+            FileLog::error("bindPhone：绑定手机号保存失败", json_encode($update, JSON_UNESCAPED_UNICODE),'','jianghaiming@yidian-inc.com');
+            throw new UserException(['cus' => 12]);
+        }
+
         if (!$phoneNumber) {
+            FileLog::error("bindPhone：该手机号已绑定其他用户不能重复绑定--user", json_encode($user, JSON_UNESCAPED_UNICODE),'','jianghaiming@yidian-inc.com');
             throw new UserException(['cus' => 8]);
         }
 
-        CommonService::isNewUser($params);
-        
         $isNewUser =  CommonService::isNewUser(['openid' => $openid]);
         if (!empty($isNewUser) && $isNewUser['is_new_user'] == 1) {
              $userInfo['is_pop_up'] = 1;
@@ -219,6 +244,8 @@ class UserService
             $bindStatus = UserWechatBind::save($update,['openid' => $params['openid']]);
         }
         if (!$bindStatus) {
+            FileLog::error("bindAvatar：绑定头像失败", json_encode($params, JSON_UNESCAPED_UNICODE),'','jianghaiming@yidian-inc.com');
+            FileLog::error("bindAvatar：绑定头像失败--update", json_encode($update, JSON_UNESCAPED_UNICODE),'','jianghaiming@yidian-inc.com');
             throw new UserException(['cus' => 11]);
         }
         return $update;