新增升级代理接口

app/controller/AdminUser.php

@@ -167,8 +167,6 @@ class AdminUser extends BaseController
         // 清空缓存
         $login_user_data = Cache::store('redis')->get('login_user_data');
         if ($login_user_data) Cache::store('redis')->delete('login_admin_user_data');
-        $login_agent_user_data = Cache::store('redis')->get('login_agent_user_data');
-        if ($login_agent_user_data) Cache::store('redis')->delete('login_agent_user_data');
         $login_admin_user_data = Cache::store('redis')->get('login_admin_user_data');
         if ($login_admin_user_data) Cache::store('redis')->delete('login_admin_user_data');
         $login_admin_user_data = Cache::store('redis')->get('user_recharge_set');

app/controller/AdminUserTeam.php

@@ -8,6 +8,7 @@ use app\event\UserPasswordChange;
 use app\middleware\CheckAdmin;
 use app\model\AdminDownScoresRecords;
 use app\model\AdminUpScoresRecords;
+use app\model\AgentInfo;
 use app\model\RechargeRecords;
 use app\model\User;
 use app\model\WithdrawalRecords;
@@ -37,7 +38,7 @@ class AdminUserTeam extends BaseController
 
         $limit = $request['limit'] ?? 10;
 
-        $where = [];
+        $where = ['identity' => 3];
 
         $UserModel = new User();
 
@@ -175,7 +176,7 @@ class AdminUserTeam extends BaseController
             AdminUpScoresRecords::createRecords($user_id,$adminUser['id'],$quota,$userBalance);
 
             # 用户充值记录-上分
-            RechargeRecords::createRecords($user_id,$quota,$userBalance,1,2);
+            RechargeRecords::createRecords($user_id,$quota,$userBalance,1,2,$adminUser['id']);
 
             $connection->commit();
             return $this->renderSuccess('上分成功');
@@ -220,7 +221,7 @@ class AdminUserTeam extends BaseController
             AdminDownScoresRecords::createRecords($user_id,$adminUser['id'],$quota,$userBalance);
 
             # 用户提现记录-下分
-            WithdrawalRecords::createRecords($user_id,$quota,$userBalance,1,2);
+            WithdrawalRecords::createRecords($user_id,$quota,$userBalance,1,2,$adminUser['id']);
 
             $connection->commit();
             return $this->renderSuccess('下分成功');
@@ -231,4 +232,40 @@ class AdminUserTeam extends BaseController
             return $this->renderError($exception->getMessage());
         }
     }
+
+    /**
+     * 升级为代理
+     * @return array
+     */
+    public function upGradationAgent()
+    {
+        $request = Request::param();
+
+        $connection = Db::connect();
+        try {
+            validate()->rule(['aid' => 'require|number'])->check($request);
+            $aid = $request['aid'];
+            $User = new User();
+            $UserRes = $User->find($aid);
+            if (empty($UserRes)) throw new ValidateException('用户不存在');
+            if ($UserRes['identity'] != 3) {
+                throw new ValidateException('当前用户已是'.$User->identityArr[$UserRes['identity']]);
+            }
+
+            # 开启事务
+            $connection->startTrans();
+            # 创建代理信息
+            AgentInfo::createInfo($aid);
+            # 升级为代理
+            User::changeIdentity($aid);
+
+            $connection->commit();
+            return $this->renderSuccess('成功');
+        } catch (ValidateException $e) {
+            return $this->renderError($e->getMessage());
+        } catch (\Exception $exception) {
+            $connection->rollback();
+            return $this->renderError($exception->getMessage());
+        }
+    }
 }