|
|
@@ -0,0 +1,260 @@
|
|
|
+<?php
|
|
|
+declare (strict_types = 1);
|
|
|
+
|
|
|
+namespace app\model;
|
|
|
+
|
|
|
+use think\Model;
|
|
|
+
|
|
|
+/**
|
|
|
+ * 商户用户模型 - 连接到fortue_tiger数据库的tp_merchants_user表
|
|
|
+ */
|
|
|
+class MerchantsUserModel extends Model
|
|
|
+{
|
|
|
+ // 设置数据库连接
|
|
|
+ protected $connection = 'fortue_tiger';
|
|
|
+
|
|
|
+ // 设置表名
|
|
|
+ protected $name = 'merchants_user';
|
|
|
+
|
|
|
+ // 设置主键
|
|
|
+ protected $pk = 'user_id';
|
|
|
+
|
|
|
+ // 设置自动时间戳
|
|
|
+ protected $autoWriteTimestamp = 'int';
|
|
|
+
|
|
|
+ // 设置字段类型
|
|
|
+ protected $type = [
|
|
|
+ 'user_id' => 'int',
|
|
|
+ 'app_id' => 'int',
|
|
|
+ 'uname' => 'int',
|
|
|
+ 'nickname' => 'string',
|
|
|
+ 'cid' => 'int',
|
|
|
+ 'token' => 'string',
|
|
|
+ 'short_token' => 'string',
|
|
|
+ 'login_time' => 'int',
|
|
|
+ 'reg_ip' => 'string',
|
|
|
+ 'login_ip' => 'string',
|
|
|
+ 'today_count' => 'int',
|
|
|
+ 'history_day_count' => 'int',
|
|
|
+ 'adjust_status' => 'int',
|
|
|
+ 'status' => 'int',
|
|
|
+ 'disabled_login' => 'int',
|
|
|
+ 'create_time' => 'int',
|
|
|
+ 'update_time' => 'int',
|
|
|
+ ];
|
|
|
+
|
|
|
+ // 状态常量
|
|
|
+ const STATUS_NORMAL = 1; // 正常
|
|
|
+ const STATUS_FROZEN = 0; // 冻结
|
|
|
+
|
|
|
+ // 禁止登录状态
|
|
|
+ const LOGIN_ENABLED = 1; // 允许登录
|
|
|
+ const LOGIN_DISABLED = 0; // 禁止登录
|
|
|
+
|
|
|
+ // 调控状态常量
|
|
|
+ const ADJUST_STATUS_NORMAL = 1; // 正常
|
|
|
+ const ADJUST_STATUS_WIN = 2; // 放水(赢)
|
|
|
+ const ADJUST_STATUS_LOSE = 3; // 收割(输)
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 获取状态文本
|
|
|
+ */
|
|
|
+ public static function getStatusText($status): string
|
|
|
+ {
|
|
|
+ $statusMap = [
|
|
|
+ self::STATUS_NORMAL => '正常',
|
|
|
+ self::STATUS_FROZEN => '冻结',
|
|
|
+ ];
|
|
|
+ return $statusMap[$status] ?? '未知';
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 获取调控状态文本
|
|
|
+ */
|
|
|
+ public static function getAdjustStatusText($adjustStatus): string
|
|
|
+ {
|
|
|
+ $adjustStatusMap = [
|
|
|
+ self::ADJUST_STATUS_NORMAL => '正常',
|
|
|
+ self::ADJUST_STATUS_WIN => '放水',
|
|
|
+ self::ADJUST_STATUS_LOSE => '收割',
|
|
|
+ ];
|
|
|
+ return $adjustStatusMap[$adjustStatus] ?? '未知';
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 获取禁止登录状态文本
|
|
|
+ */
|
|
|
+ public static function getDisabledLoginText($disabled): string
|
|
|
+ {
|
|
|
+ $disabledMap = [
|
|
|
+ self::LOGIN_ENABLED => '允许',
|
|
|
+ self::LOGIN_DISABLED => '禁止',
|
|
|
+ ];
|
|
|
+ return $disabledMap[$disabled] ?? '未知';
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 根据商户ID获取玩家列表
|
|
|
+ */
|
|
|
+ public static function getPlayerListByMerchant($merchantId, $page = 1, $limit = 10, $filters = [])
|
|
|
+ {
|
|
|
+ $query = self::where('app_id', $merchantId);
|
|
|
+
|
|
|
+ // 应用过滤条件
|
|
|
+ if (!empty($filters['uname'])) {
|
|
|
+ $query->where('uname', 'like', '%' . $filters['uname'] . '%');
|
|
|
+ }
|
|
|
+
|
|
|
+ if (!empty($filters['nickname'])) {
|
|
|
+ $query->where('nickname', 'like', '%' . $filters['nickname'] . '%');
|
|
|
+ }
|
|
|
+
|
|
|
+ if (!empty($filters['user_id'])) {
|
|
|
+ $query->where('user_id', $filters['user_id']);
|
|
|
+ }
|
|
|
+
|
|
|
+ if (isset($filters['status']) && $filters['status'] !== '') {
|
|
|
+ $query->where('status', $filters['status']);
|
|
|
+ }
|
|
|
+
|
|
|
+ if (isset($filters['adjust_status']) && $filters['adjust_status'] !== '') {
|
|
|
+ $query->where('adjust_status', $filters['adjust_status']);
|
|
|
+ }
|
|
|
+
|
|
|
+ if (!empty($filters['login_ip'])) {
|
|
|
+ $query->where('login_ip', 'like', '%' . $filters['login_ip'] . '%');
|
|
|
+ }
|
|
|
+
|
|
|
+ if (!empty($filters['reg_ip'])) {
|
|
|
+ $query->where('reg_ip', 'like', '%' . $filters['reg_ip'] . '%');
|
|
|
+ }
|
|
|
+
|
|
|
+ // 登录时间范围
|
|
|
+ if (!empty($filters['login_time_start'])) {
|
|
|
+ $query->where('login_time', '>=', strtotime($filters['login_time_start']));
|
|
|
+ }
|
|
|
+ if (!empty($filters['login_time_end'])) {
|
|
|
+ $query->where('login_time', '<=', strtotime($filters['login_time_end']));
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ $order = $filters['order'] ?? 'user_id';
|
|
|
+ $sort = $filters['sort'] ?? 'desc';
|
|
|
+ $query->order($order, $sort);
|
|
|
+
|
|
|
+ // 获取总数
|
|
|
+ $total = $query->count();
|
|
|
+
|
|
|
+ // 获取列表
|
|
|
+ $list = $query->page($page, $limit)->select()->toArray();
|
|
|
+
|
|
|
+ // 转换字段名以保持与原有接口的兼容性
|
|
|
+ foreach ($list as &$item) {
|
|
|
+ $item['merchant_id'] = $item['app_id'];
|
|
|
+ $item['today_login_count'] = $item['today_count'];
|
|
|
+ $item['history_login_count'] = $item['history_day_count'];
|
|
|
+ // 添加原系统中可能需要但新表中没有的字段
|
|
|
+ $item['balance'] = 0;
|
|
|
+ $item['today_win_amount'] = 0;
|
|
|
+ $item['history_win_amount'] = 0;
|
|
|
+ $item['today_bet_amount'] = 0;
|
|
|
+
|
|
|
+ // 移除字段
|
|
|
+ unset($item['app_id']);
|
|
|
+ unset($item['token']);
|
|
|
+ unset($item['short_token']);
|
|
|
+ }
|
|
|
+
|
|
|
+ return [
|
|
|
+ 'list' => $list,
|
|
|
+ 'total' => $total,
|
|
|
+ 'page' => $page,
|
|
|
+ 'limit' => $limit
|
|
|
+ ];
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 获取玩家详情
|
|
|
+ */
|
|
|
+ public static function getPlayerDetail($playerId, $merchantId)
|
|
|
+ {
|
|
|
+ $player = self::where('uname', $playerId)
|
|
|
+ ->where('app_id', $merchantId)
|
|
|
+ ->find();
|
|
|
+
|
|
|
+ if ($player) {
|
|
|
+ $player = $player->toArray();
|
|
|
+ // 移除敏感字段
|
|
|
+ unset($player['token']);
|
|
|
+ unset($player['short_token']);
|
|
|
+
|
|
|
+ // 转换字段名
|
|
|
+ $player['player_id'] = $player['uname'];
|
|
|
+ $player['merchant_id'] = $player['app_id'];
|
|
|
+ $player['today_login_count'] = $player['today_count'];
|
|
|
+ $player['history_login_count'] = $player['history_day_count'];
|
|
|
+ // 添加原系统中可能需要但新表中没有的字段
|
|
|
+ $player['balance'] = 0;
|
|
|
+ $player['today_win_amount'] = 0;
|
|
|
+ $player['history_win_amount'] = 0;
|
|
|
+ $player['today_bet_amount'] = 0;
|
|
|
+ }
|
|
|
+
|
|
|
+ return $player;
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 更新玩家状态
|
|
|
+ */
|
|
|
+ public static function updatePlayerStatus($playerIds, $merchantId, $status)
|
|
|
+ {
|
|
|
+ return self::where('app_id', $merchantId)
|
|
|
+ ->whereIn('uname', $playerIds)
|
|
|
+ ->update(['status' => $status]);
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 更新玩家调控状态
|
|
|
+ */
|
|
|
+ public static function updatePlayerAdjustStatus($playerIds, $merchantId, $adjustStatus)
|
|
|
+ {
|
|
|
+ return self::where('app_id', $merchantId)
|
|
|
+ ->whereIn('uname', $playerIds)
|
|
|
+ ->update(['adjust_status' => $adjustStatus]);
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 更新玩家禁止登录状态
|
|
|
+ */
|
|
|
+ public static function updatePlayerLoginStatus($playerIds, $merchantId, $disabledLogin)
|
|
|
+ {
|
|
|
+ return self::where('app_id', $merchantId)
|
|
|
+ ->whereIn('uname', $playerIds)
|
|
|
+ ->update(['disabled_login' => $disabledLogin]);
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 获取玩家统计信息
|
|
|
+ */
|
|
|
+ public static function getPlayerStatistics($merchantId)
|
|
|
+ {
|
|
|
+ $today = strtotime(date('Y-m-d'));
|
|
|
+
|
|
|
+ return [
|
|
|
+ 'total_players' => self::where('app_id', $merchantId)->count(),
|
|
|
+ 'active_players' => self::where('app_id', $merchantId)
|
|
|
+ ->where('status', self::STATUS_NORMAL)
|
|
|
+ ->count(),
|
|
|
+ 'today_new_players' => self::where('app_id', $merchantId)
|
|
|
+ ->where('create_time', '>=', $today)
|
|
|
+ ->count(),
|
|
|
+ 'today_login_players' => self::where('app_id', $merchantId)
|
|
|
+ ->where('login_time', '>=', $today)
|
|
|
+ ->count(),
|
|
|
+ 'total_balance' => 0, // 新表中没有余额字段
|
|
|
+ 'today_bet_amount' => 0, // 新表中没有下注金额字段
|
|
|
+ 'today_win_amount' => 0, // 新表中没有输赢金额字段
|
|
|
+ 'history_win_amount' => 0, // 新表中没有历史输赢字段
|
|
|
+ ];
|
|
|
+ }
|
|
|
+}
|
aiden