Merge branch 'main' of s.long.bid:liu/merchant_admin

app/common/CommonMerchantUserAndBalance.php

@@ -0,0 +1,69 @@
+<?php
+
+namespace app\common;
+
+use think\facade\Db;
+
+class CommonMerchantUserAndBalance
+{
+
+    const merchant_user_table = 'tp_merchants_user';
+    const merchant_user_balance_table = 'tp_merchants_user_balance';
+    const merchant_user_game_rtp_win_bet = "tp_game_rtp_win_bet";
+    const table_name = 'fortue_tiger';
+
+
+    public static function getFortueTigerTable()
+    {
+        return Db::connect(self::table_name);
+    }
+
+    /**
+     * 获取指定用户的游戏 rtp win bet
+     * @param $wheres
+     * @param $field
+     * @return mixed
+     */
+    public static function getMerchantUserGameRtpWinBetInfo($wheres, $field = [])
+    {
+        $query = self::getFortueTigerTable()->table(self::merchant_user_game_rtp_win_bet)->where($wheres);
+        if(!empty($field)){
+            $query = $query->field($field);
+        }
+        return $query->select()->toArray();
+    }
+
+    /**
+     * 批量获取用户余额
+     * @param $userIds
+     * @return array
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     */
+    public static function getMerchantUserBalance($userIds, $field = ['user_id', 'balance']) {
+        $query = self::getFortueTigerTable()->table(self::merchant_user_balance_table)->whereIn('user_id', $userIds);
+        if(!empty($field)) {
+            $query = $query->field($field);
+        }
+        return $query->select()->toArray();
+    }
+
+    /**
+     * 批量获取用户信息
+     * @param $userIds
+     * @return array
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     */
+    public static function getMerchantUser($userIds, $field = ['user_id', 'nickname'])
+    {
+        $query = self::getFortueTigerTable()->table(self::merchant_user_table)->whereIn('user_id', $userIds);
+        if(!empty($field)){
+            $query = $query->field($field);
+        }
+        return $query->select()->toArray();
+    }
+
+}

app/controller/PlayerControl.php

@@ -0,0 +1,341 @@
+<?php
+
+namespace app\controller;
+
+use app\BaseController;
+use app\common\CommonUtils;
+use app\common\CommonMerchantUserAndBalance;
+use app\model\GameModel;
+use app\model\MerchantsUserModel;
+use app\model\PlayerControlModel;
+use app\model\UserModel;
+use think\facade\Request;
+
+class PlayerControl extends BaseController
+{
+    /**
+     * 添加或更新 点控设置
+     * {"account_ids":["115"],"game_ids":[1],"rtp":9900,"max_win_multi":500,"auto_cancel_rtp":100,"agent_id":6027,"win_pro":-1}
+     */
+    public function updatePlayerControl()
+    {
+        $userInfo = $this->request->userInfo;
+        $data = Request::param([
+            'account_ids' => "",
+            'game_ids' => "",
+            'rtp' => 0,
+            'max_win_multi' => 0,
+            'auto_cancel_rtp' => 0
+        ]);
+
+        // 判断RTP
+        if(empty($data['rtp'])) {
+            return json_error([], 'RTP错误');
+        }
+
+        $account_ids = $data['account_ids'] ?? "";
+        $game_ids = $data['game_ids'] ?? "";
+        // 游戏平台ID和游戏ID不能为空
+        if(empty($account_ids) || empty($game_ids)) {
+            return json_error([], '平台ID和游戏ID不能为空');
+        }
+
+
+        $account_ids = explode(",", $account_ids);
+        $game_ids = explode(",", $game_ids);
+
+        $unameList = [];
+        $emptyUnameList = [];
+        foreach ($account_ids as $account_id) {
+            $account_id = trim($account_id);
+            if(!empty($account_id) && preg_match("/^[1-9]\d*$/", $account_id)) {
+                $unameList[] = $account_id;
+            }else {
+                $emptyUnameList[] = $account_id;
+            }
+        }
+        if(!empty($emptyUnameList)) {
+            return json_error([], '不存在玩家：' . implode(",", $emptyUnameList));
+        }
+
+        $gameList = [];
+        foreach ($game_ids as $game_id) {
+            $game_id = trim($game_id);
+            if(!empty($game_id)) {
+                $gameList[] = $game_id;
+            }
+        }
+
+        // 过滤掉 游戏平台ID和游戏ID不能为空
+        if(empty($unameList) || empty($gameList)) {
+            return json_error([], '平台ID和游戏ID不能为空');
+        }
+
+        $allGameList = GameModel::getGames($userInfo['merchant_id']);
+        $gameIds = array_column($allGameList, 'game_id');
+        $emptyIds = [];
+        foreach ($gameList as $gameId) {
+            if(!in_array($gameId, $gameIds)) {
+                $emptyIds[] = $gameId;
+            }
+        }
+        if(!empty($emptyIds)) {
+            return json_error([], "不存在游戏：" . implode(", ", $emptyIds));
+        }
+
+
+        $merchantsUserList = MerchantsUserModel::getPlayerListByIds($userInfo['merchant_id'], [
+            ['uname', 'in', $unameList]
+        ]);
+
+        $merchantsUserList = array_column($merchantsUserList, null, 'uname');
+
+        $merchantsUserIds = array_column($merchantsUserList, 'user_id');
+        $userBalanceList = CommonMerchantUserAndBalance::getMerchantUserBalance($merchantsUserIds);
+        $userBalanceList = array_column($userBalanceList, null, 'user_id');
+
+        foreach ($account_ids as $accountId) {
+            $merchantsUserInfo = $merchantsUserList[$accountId] ?? [];
+            if(empty($merchantsUserInfo)) {
+                continue;
+            }
+
+            $user_id = $merchantsUserInfo['user_id'];
+            $rtpGameLIst = CommonMerchantUserAndBalance::getMerchantUserGameRtpWinBetInfo([
+                ['user_id', '=' , $user_id],
+                ['game_id', 'in', $gameIds],
+            ], ['rtp','game_id']);
+
+            $gameRtp = [];
+            foreach ($rtpGameLIst as $item) {
+                $gameRtp[$item['game_id']] = $item['rtp'];
+            }
+
+
+            foreach ($game_ids as $gameId) {
+                $old_rtp = $gameRtp[$gameId] ?? 0;
+                $info = PlayerControlModel::getPlayerControlInfo($userInfo['merchant_id'], $user_id, $gameId);
+
+                if(!empty($info) && $info->status == 0) {
+                    $info = null;
+                }
+
+                $balanceInfo = $userBalanceList[$user_id] ?? [];
+                if(!empty($info)) {
+                    // 需要更新
+                    $info->control_rpt = bcmul( $data['rtp'], 100);
+                    $info->auto_cancel_rtp = bcmul($data['auto_cancel_rtp'], 100);
+                    $info->max_win_multi = $data['max_win_multi'];
+                    $info->old_rtp = $old_rtp;
+                    $info->save();
+                }else {
+                    $item =  [
+                        'app_id' => $userInfo['merchant_id'],
+                        'user_id' => $userInfo['user_id'],
+                        'player_id' => $merchantsUserInfo['user_id'],// 玩家id
+                        'game_id' => $gameId,
+                        'old_rtp' => $old_rtp,
+                        'control_rpt' => bcmul( $data['rtp'], 100),
+                        'auto_cancel_rtp' => bcmul($data['auto_cancel_rtp'], 100), // 达到RTP值取消
+                        'max_win_multi' => $data['max_win_multi'], // 最高倍数
+                        'control_balance' => CommonUtils::convertBalance( $balanceInfo['balance'], false), // 设置时点控那刻当前余额
+                    ];
+                    PlayerControlModel::create($item);
+                }
+            }
+        }
+        return json_success([],'操作成功');
+    }
+
+    /**
+     * 获取点控列表
+     * @return \think\response\Json
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     */
+    public function getPlayerControlList()
+    {
+        // 获取当前用户信息
+        $userInfo = $this->getUserInfo();
+
+        // 获取查询参数
+        $page = Request::get('page', 1, 'intval');
+        $limit = Request::get('limit', 10, 'intval');
+
+        // 过滤条件
+        // 筛选条件
+        $filters = [
+            // 时间筛选
+            'start_time' => Request::get('start_time', '', 'trim'),
+            'end_time' => Request::get('end_time', '', 'trim'),
+            // 游戏筛选
+            'game_id' => Request::get('game_id', '', 'trim'),
+            // 平台ID筛选
+            'uname' => Request::get('uname', '', 'trim'),
+            // 玩家ID筛选
+            'player_id' => Request::get('user_id', '', 'trim'),
+            // 平台昵称
+            'nickname' => Request::get('nickname', '', 'trim'),
+        ];
+
+        $is_end = Request::get('is_end_time', 0);
+
+
+        $controlWhere = [];
+        $controlWhere[] = ['user_id', '=', $userInfo['user_id']];
+
+
+        $where = [];
+        $isFindUserId = false;
+        // 平台ID筛选
+        if (!empty($filters['uname'])) {
+            $where[] = ['uname', '=', $filters['uname']];
+            $isFindUserId = true;
+        }
+        // 平台昵称筛选
+        if (!empty($filters['nickname'])) {
+            $where[] = ['nickname', 'like', '%' . $filters['nickname'] . '%'];
+            $isFindUserId = true;
+        }
+        // 玩家id筛选
+        if (!empty($filters['player_id'])) {
+            $where[] = ['user_id', 'like', '%' . $filters['player_id'] . '%'];
+            $isFindUserId = true;
+        }
+        if($isFindUserId) {
+            $merchantsUserIds = MerchantsUserModel::getPlayerListByIds($userInfo['merchant_id'], $where, ['user_id']);
+            $controlWhere[] = ['user_id', 'in', array_column($merchantsUserIds, 'user_id')];
+        }
+
+        if(!empty($filters['game_id'])) {
+            $controlWhere[] = ['game_id', 'in', explode(",", $filters['game_id'])];
+        }
+
+        if(!empty($filters['start_time']) && !empty($filters['end_time'])) {
+
+            $controlWhere[] = [$is_end ? 'end_time' : 'update_time', '>=', strtotime($filters['start_time'] . " 00:00:00")];
+            $controlWhere[] = [$is_end ? 'end_time' :'update_time', '<=', strtotime($filters['end_time'] . " 23:59:59")];
+        }
+
+        $controlWhere[] = ['status', '=',  $is_end ? 0 : 1];
+
+        $results = PlayerControlModel::getPlayerControlList($userInfo['merchant_id'], $page, $limit, $controlWhere);
+
+        $allGameList = GameModel::getGames($userInfo['merchant_id'], [], ['id', 'game_id', 'title', 'game_platform']);
+        $gameConfig = array_column($allGameList, null, 'game_id');
+
+        $player_ids = array_column($results['list'],  'player_id');
+
+        $playerConfig = CommonMerchantUserAndBalance::getMerchantUser($player_ids, ['user_id','uname','nickname']);
+        $playerConfig = array_column($playerConfig, null, 'user_id');
+
+
+        $userListBalance = CommonMerchantUserAndBalance::getMerchantUserBalance($player_ids);
+        $userBalanceConfig = [];
+        foreach ($userListBalance as $item) {
+            $userBalanceConfig[$item['user_id']] = $item['balance'];
+        }
+
+        $rtpUserList = [];
+        foreach ($results['list'] as $item) {
+            $player_id = $item['player_id'];
+            if(empty($rtpUserList[$player_id])) {
+                $rtpUserList[$player_id] = [];
+            }
+            $rtpUserList[$player_id][] = $item['game_id'];
+        }
+        $rtpConfigList = [];
+        foreach ($rtpUserList as $player_id => $gameIds) {
+            $temp = CommonMerchantUserAndBalance::getMerchantUserGameRtpWinBetInfo([
+                ['user_id', '=' , $player_id],
+                ['game_id', 'in', $gameIds],
+            ], ['rtp','game_id']);
+            foreach ($temp as $item) {
+                $game_id = $item['game_id'];
+                $rtp = $item['rtp'];
+                $key = "{$player_id}_{$game_id}";
+                $rtpConfigList[$key] = $rtp;
+            }
+        }
+
+
+        foreach ($results['list'] as $key => $item) {
+            $game_id = $item['game_id'];
+            $player_id = $item['player_id'];
+            $one_key = "{$player_id}_{$game_id}";
+            $gameInfo = $gameConfig[$game_id] ?? [];
+            if (!empty($gameInfo))
+            {
+                $gameImages = CommonUtils::getGameDefaultImage($gameInfo);
+            }
+            $item['game_image_url'] = $gameImages['image_url'] ?? '';
+            $item['game_title'] = $gameInfo['title'] ?? '';
+            $item['game_type_text'] = CommonUtils::getGameTypeConfig($gameInfo['game_platform']);
+            $item['balance'] = CommonUtils::convertBalance($userBalanceConfig[$player_id] ?? 0, false);
+            $item['bet_amount'] = CommonUtils::convertBalance($item['bet_amount'] ?? 0, false);
+            $item['total_win_amount'] = CommonUtils::convertBalance($item['total_win_amount'] ?? 0, false);
+            $item['control_rpt'] = bcdiv($item['control_rpt'], 100, 2) . "%";
+            $item['old_rtp'] = bcdiv($item['old_rtp'], 100, 2) . "%";
+            $item['now_rtp'] = bcdiv($rtpConfigList[$one_key] ?? 0, 100, 2) . "%";
+
+            if(!empty($item['auto_cancel_rtp'])) {
+                $item['auto_cancel_rtp'] = bcdiv($item['auto_cancel_rtp'], 100, 2) . "%";
+            }
+
+            $playerInfo = $playerConfig[$player_id] ?? [];
+            $item['uname'] = $playerInfo['uname'] ?? '';
+            $item['nickname'] = $playerInfo['nickname'] ?? '';
+            $adminInfo = UserModel::find($item['user_id']);
+            $item['admin_name'] = "";
+            if(!empty($adminInfo)) {
+                $item['admin_name'] = $adminInfo['nick_name'] ?? '';
+            }
+
+            if(!empty($item['end_time'])) {
+                $item['end_time'] = date('Y-m-d H:i:s', $item['end_time']);
+            }
+
+            $results['list'][$key] = $item;
+        }
+
+        return json_success($results);
+
+    }
+
+
+    /**
+     * 取消点控设置
+     * @return \think\response\Json
+     * @throws \think\db\exception\DataNotFoundException
+     * @throws \think\db\exception\DbException
+     * @throws \think\db\exception\ModelNotFoundException
+     */
+    public function cancelPlayerControlInfo()
+    {
+        $userInfo = $this->getUserInfo();
+        $control_id = Request::post('control_id','', 'trim');
+        if(empty($control_id)) {
+            return json_error([], '参数错误');
+        }
+        $info = PlayerControlModel::where(['control_id' => $control_id, 'user_id' => $userInfo['user_id']])->find();
+        if(!empty($info)) {
+            $info->end_time = time();
+            $info->status = 0;
+            $info->save();
+        }
+        return json_success([],'操作成功');
+    }
+
+    /**
+     * 一键取消全部点控
+     * @return \think\response\Json
+     */
+    public function cancelAllPlayerControlInfo()
+    {
+        $userInfo = $this->getUserInfo();
+        PlayerControlModel::where(['user_id' => $userInfo['user_id']])->save(['status' => 0, 'end_time' => time()]);
+        return json_success([],'操作成功');
+    }
+
+}

app/model/GameBetGameModel.php

@@ -3,8 +3,8 @@ declare (strict_types = 1);
 
 namespace app\model;
 
+use app\common\CommonMerchantUserAndBalance;
 use think\Model;
-use think\facade\Db;
 
 /**
  * 游戏记录模型 - 基于tp_game_bet_game表
@@ -135,17 +135,9 @@ class GameBetGameModel extends Model
         
         if (!empty($userIds)) {
             // 获取用户信息
-            $users = self::table('tp_merchants_user')
-                ->whereIn('user_id', $userIds)
-                ->field(['user_id', 'nickname'])
-                ->select()
-                ->toArray();
+            $users = CommonMerchantUserAndBalance::getMerchantUser($userIds);
             // 获取用户余额    
-            $userBanlance = self::table('tp_merchants_user_balance')
-                ->whereIn('user_id', $userIds)
-                ->field(['user_id', 'balance'])
-                ->select()
-                ->toArray();
+            $userBanlance = CommonMerchantUserAndBalance::getMerchantUserBalance($userIds);
 
             $users = array_column($users, null, 'user_id');
             $userBanlance = array_column($userBanlance, null, 'user_id');
@@ -212,18 +204,11 @@ class GameBetGameModel extends Model
         $userIds = array_column($list, 'user_id');
         
         if (!empty($userIds)) {
+
             // 获取用户信息
-            $users = self::table('tp_merchants_user')
-                ->whereIn('user_id', $userIds)
-                ->field(['user_id', 'nickname'])
-                ->select()
-                ->toArray();
-            // 获取用户余额    
-            $userBanlance = self::table('tp_merchants_user_balance')
-                ->whereIn('user_id', $userIds)
-                ->field(['user_id', 'balance'])
-                ->select()
-                ->toArray();
+            $users = CommonMerchantUserAndBalance::getMerchantUser($userIds);
+            // 获取用户余额
+            $userBanlance = CommonMerchantUserAndBalance::getMerchantUserBalance($userIds);
 
             $users = array_column($users, null, 'user_id');
             $userBanlance = array_column($userBanlance, null, 'user_id');
@@ -290,17 +275,9 @@ class GameBetGameModel extends Model
         
         if (!empty($userIds)) {
             // 获取用户信息
-            $users = self::table('tp_merchants_user')
-                ->whereIn('user_id', $userIds)
-                ->field(['user_id', 'nickname'])
-                ->select()
-                ->toArray();
-            // 获取用户余额    
-            $userBanlance = self::table('tp_merchants_user_balance')
-                ->whereIn('user_id', $userIds)
-                ->field(['user_id', 'balance'])
-                ->select()
-                ->toArray();
+            $users = CommonMerchantUserAndBalance::getMerchantUser($userIds);
+            // 获取用户余额
+            $userBanlance = CommonMerchantUserAndBalance::getMerchantUserBalance($userIds);
 
             $users = array_column($users, null, 'user_id');
             $userBanlance = array_column($userBanlance, null, 'user_id');

app/model/GameModel.php

@@ -172,7 +172,7 @@ class GameModel extends Model
         ];
     }
 
-    public static function getGames($merchantId, $filters = [])
+    public static function getGames($merchantId, $filters = [], $field = ['id', 'game_id', 'title'])
     {
         $query = self::where('merchant_id', $merchantId);
         // 排序
@@ -180,7 +180,7 @@ class GameModel extends Model
         $sort = $filters['sort'] ?? 'desc';
         $query->order($order, $sort);
 
-        return $query->field(['id', 'game_id', 'title'])->select()->toArray();
+        return $query->field($field)->select()->toArray();
     }    
 
     /**

app/model/MerchantsUserModel.php

@@ -93,6 +93,21 @@ class MerchantsUserModel extends Model
         return $disabledMap[$disabled] ?? '未知';
     }
 
+    /**
+     * 通过unameList批量获取指定平台用户详情
+     * @param $merchantId
+     * @param $wheres
+     * @return mixed
+     */
+    public static function getPlayerListByIds($merchantId, $wheres = [], $field = [])
+    {
+        $query = self::where('app_id', $merchantId)->where($wheres);
+        if(!empty($field)) {
+            $query = $query->field($field);
+        }
+        return $query->select()->toArray();
+    }
+
     /**
      * 根据商户ID获取玩家列表
      */

app/model/PlayerControlModel.php

@@ -0,0 +1,82 @@
+<?php
+
+namespace app\model;
+use think\Model;
+class PlayerControlModel extends Model
+{
+    // 设置表名
+    protected $name = 'player_control';
+
+    protected $connection = 'fortue_tiger';
+
+    // 设置主键
+    protected $pk = 'control_id';
+    // 设置自动时间戳
+    protected $autoWriteTimestamp = 'int';
+
+    // 设置字段类型
+    protected $type = [
+        'control_id' => 'int',
+        'app_id' => 'int', // 商户ID
+        'user_id' => 'int', // 用户ID
+        'player_id' => 'int', // 玩家ID
+        'game_id' => 'string', // 游戏ID
+        'old_rtp' => 'int', // 设置时当前RTP值,
+        'control_rpt' => 'int', // 设置的RTP值
+        'auto_cancel_rtp' => 'int', // 达到此RTP解除点控
+        'max_win_multi' => 'int', // 赢取倍数限制
+        'control_balance' => 'decimal', // 设置时点控那刻当前余额
+        'bet_amount' => 'int', // 点控期间 下注总分数
+        'bet_count' => 'int', // 点控期间 下单总数量
+        'total_win_amount' => 'int', // 点控期间总输赢
+        'status' => 'int', // 状态 1 正常，0 取消
+        'create_time' => 'int',
+        'update_time' => 'int',
+        'end_time' => 'int',
+    ];
+
+    /**
+     * 获取点控详情
+     * @param $merchantId
+     * @param $uname
+     * @param $game_id
+     * @return mixed
+     */
+    public static function getPlayerControlInfo($merchantId, $player_id, $game_id)
+    {
+        return self::where(['app_id' => $merchantId, 'player_id' => $player_id, 'game_id' => $game_id])->find();
+    }
+
+    /**
+     * 根据商户ID获取玩家列表
+     */
+    public static function getPlayerControlList($merchantId, $page = 1, $limit = 10, $wheres = [])
+    {
+
+        $query = self::where($wheres);
+        $order = $filters['order'] ?? 'create_time';
+        $sort = $filters['sort'] ?? 'desc';
+        $query->order($order, $sort);
+
+        // 获取总数
+        $total = $query->count();
+        // 获取列表
+        $list = $query->page($page, $limit)->select()->toArray();
+
+        return [
+            'list' => $list,
+            'total' => $total,
+            'page' => $page,
+            'limit' => $limit
+        ];
+    }
+
+    /**
+     * 创建角色
+     * @param array $data 角色数据
+     */
+    public static function updatePlayerControl(array $data)
+    {
+        self:create($data);
+    }
+}

route/app.php

@@ -58,6 +58,14 @@ Route::group('game', function () {
     Route::get('export', 'Game/export');
 })->middleware([\app\middleware\AuthMiddleware::class, \app\middleware\BehaviorLogMiddleware::class]);
 
+Route::group('player_control', function () {
+    Route::post('update', 'PlayerControl/updatePlayerControl');
+    Route::get('list', 'PlayerControl/getPlayerControlList');
+    Route::post('cancel', 'PlayerControl/cancelPlayerControlInfo');
+    Route::post('all_cancel', 'PlayerControl/cancelAllPlayerControlInfo');
+})->middleware([\app\middleware\AuthMiddleware::class, \app\middleware\BehaviorLogMiddleware::class]);
+
+
 // 登录日志相关路由
 Route::group('login_log', function () {
     Route::get('list', 'LoginLog/list');