diff --git a/app/controller/AdminUser.php b/app/controller/AdminUser.php index e9cf421..40f3481 100644 --- a/app/controller/AdminUser.php +++ b/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'); diff --git a/app/controller/AdminUserTeam.php b/app/controller/AdminUserTeam.php index edf2566..d00f87c 100644 --- a/app/controller/AdminUserTeam.php +++ b/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()); + } + } }