bot-28/app/Services/UserService.php

<?php


namespace App\Services;


use App\Http\Controllers\api\TelegramWebHook;
use App\Services\BaseService;
use App\Models\User;
use App\Models\BalanceLog;
use Illuminate\Support\Facades\App;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Cache;
use Telegram\Bot\Api;
use Telegram\Bot\Exceptions\TelegramSDKException;
use App\Http\Controllers\api\Home;

class UserService extends BaseService
{
    public static string $MODEL = User::class;

    /**
     * @description: 模型
     * @return {string}
     */
    public static function model(): string
    {
        return User::class;
    }

    /**
     * @description: 枚举
     * @return {*}
     */
    public static function enum(): string
    {
        return '';
    }

    /**
     * @description: 获取查询条件
     * @param {array} $search 查询内容
     * @return {array}
     */
    public static function getWhere(array $search = []): array
    {
        $where = [];
        if (isset($search['id']) && !empty($search['id'])) {
            $where[] = ['users.id', '=', $search['id']];
        }

        if (isset($search['register_ip']) && !empty($search['register_ip'])) {
            $where[] = ['users.register_ip', '=', $search['register_ip']];
        }

        if (isset($search['member_id']) && !empty($search['member_id'])) {
            $where[] = ['users.member_id', '=', $search['member_id']];
        }
        if (isset($search['account']) && $search['account'] !== '') {
            $where[] = ['users.account', '=', $search['account']];
        }
        if (isset($search['first_name']) && !empty($search['first_name'])) {
            $where[] = ['users.first_name', '=', $search['first_name']];
        }
        if (isset($search['username']) && !empty($search['username'])) {
            $where[] = ['users.username', '=', $search['username']];
        }
        if (isset($search['like_first_name']) && !empty($search['like_first_name'])) {
            $where[] = ['users.first_name', 'like', "%" . $search['like_first_name'] . "%"];
        }
        if (isset($search['user_code']) && !empty($search['user_code'])) {
            $where[] = ['users.user_code', '=', $search['user_code']];
        }
        if (isset($search['agent_user_code']) && !empty($search['agent_user_code'])) {
            $where[] = ['users.agent_user_code', '=', $search['agent_user_code']];
        }
        if (isset($search['level']) && !empty($search['level'])) {
            $where[] = ['users.level', '=', $search['level']];
        }
        // 用户类型/注册来源：-1 tg用户，0 后台客服账号，1 真实用户，2 虚拟用户
        // 不能用 empty()，否则 from=0（后台客服）会被误判为空
        if (array_key_exists('from', $search) && $search['from'] !== null && $search['from'] !== '') {
            $where[] = ['users.from', '=', $search['from']];
        }
        if (!empty($search['start_time'])) {
            $startTime = $search['start_time'] . " 00:00:00";
            $where[] = ['users.created_at', '>=', $startTime];
        }
        if (!empty($search['end_time'])) {
            $endTime = $search['end_time'] . " 23:59:59";
            $where[] = ['users.created_at', '<=', $endTime];
        }
        if (!empty($search['agent_id'])) {
            $where[] = ['users.agent_id', '=', (int) $search['agent_id']];
        }
        if (!empty($search['recharge_channel_group_id'])) {
            $where[] = ['users.recharge_channel_group_id', '=', $search['recharge_channel_group_id']];
        }
        return $where;
    }

    /**
     * @description: 查询单条数据
     * @param array $search
     * @return \App\Models\User|null
     */
    public static function findOne(array $search): ?User
    {
        return static::$MODEL::where(self::getWhere($search))->first();
    }

    /**
     * @description: 查询所有数据
     * @param array $search
     * @return \Illuminate\Database\Eloquent\Collection
     */
    public static function findAll(array $search = [])
    {
        return static::$MODEL::where(self::getWhere($search))->get();
    }

    /**
     * @description: 分页查询
     * @param array $search
     * @return \Illuminate\Contracts\Pagination\LengthAwarePaginator
     */
    /** @var list<string> wallets 表排序字段（与 GET /admin/user 的 sort_field 一致） */
    private const PAGINATE_WALLET_SORT_FIELDS = [
        'available_balance',
        'frozen_balance',
        'yuebao',
        'wager_required',
        'wager_completed',
    ];

    /** @var list<string> users 表排序字段 */
    private const PAGINATE_USER_SORT_FIELDS = [
        'created_at',
        'last_active_time',
        'third_game_total_balance',
    ];

    public static function paginate(array $search = [], $sortOrder = 'desc', $sortField = 'created_at')
    {
        $limit = isset($search['limit']) ? $search['limit'] : 15;
        $page = isset($search['page']) ? $search['page'] : 1;
        $query = static::$MODEL::where(self::getWhere($search));
        [$onlineSql, $onlineBindings] = OnlineUserService::onlineStatusSql($query->getConnection()->getTablePrefix() . 'users');
        if (isset($search['is_online'])) {
            $query->whereRaw("{$onlineSql} = ?", [...$onlineBindings, (int) $search['is_online']]);
        }
        $total = $query->count();
        $sortOrder = strtolower($sortOrder) === 'asc' ? 'asc' : 'desc';

        // agent：邀请人（会员）；systemAgent：所属的独立代理（合营 / 入股）
        $agentColumns = 'systemAgent:id,username,real_name,type' . (\App\Support\StatsScope::enabled() ? ',is_test' : '');
        $query->with(['wallet', 'level', 'agent', $agentColumns])
            ->leftJoin('wallets', 'users.member_id', '=', 'wallets.member_id')
            ->withCasts(['is_online' => 'boolean']);
        self::applyPaginateSort($query, $sortField, $sortOrder);
        $list = $query->select('users.*')->selectRaw("{$onlineSql} AS is_online", $onlineBindings)->forPage($page, $limit)->get();

        foreach ($list as &$item) {
            $item->real_name = $item->real_name ?? null;
            $item->makeVisible('real_name');
            $item['total_consume'] = BalanceLog::getTotalConsume($item->member_id);//用户累计消费总额
            $item['third_game_total_balance'] = data_get($item, 'third_game_total_balance');
            $item['superior'] = self::superior($item);
            // 无合营代理、无邀请人时，列表可「绑定上级」（POST /admin/user/bindSuperior）
            $item['can_bind_superior'] = (int) $item->from !== 2 && $item->agent_id === null && in_array(trim((string) $item->agent_user_code), ['', '0'], true);
            // 当前周期打码量：wager_required 所需、wager_completed 当前打码量、wager_remaining 剩余打码量（提现后重置）
            foreach (WageringService::summary($item->wallet) as $key => $value) {
                $item[$key] = $value;
            }
        }
        return ['total' => $total, 'data' => $list];
    }

    /**
     * 列表「上级」列：会员属于独立代理（合营 / 入股）时显示代理账号；否则显示邀请人会员；都没有为 null。
     * type：agent 代理 / member 会员；label 直接展示，如「合营：agent01」「入股：agent02」「邀请人：member01」。
     */
    public static function superior($user): ?array
    {
        $agent = $user->relationLoaded('systemAgent') ? $user->systemAgent : null;
        if ($agent) {
            return ['type' => 'agent', 'type_text' => '代理', 'id' => (int) $agent->id, 'account' => (string) $agent->username,
                'label' => $agent->type_text . '：' . $agent->username . ((int) ($agent->is_test ?? 0) === 1 ? '（测试）' : ''),
                'agent_type' => (int) $agent->type, 'agent_type_text' => (string) $agent->type_text, 'is_test' => (int) ($agent->is_test ?? 0)];
        }
        $inviter = $user->relationLoaded('agent') ? $user->agent : null;
        if ($inviter) {
            $account = (string) ($inviter->account ?: $inviter->first_name);
            return ['type' => 'member', 'type_text' => '会员', 'id' => (int) $inviter->id, 'account' => $account, 'label' => '邀请人：' . $account,
                'member_id' => (string) $inviter->member_id];
        }
        return null;
    }

    private static function applyPaginateSort($query, string $sortField, string $sortOrder): void
    {
        if ($sortField === 'total_consume') {
            $query->leftJoinSub(self::totalConsumeSubquery(), 'user_total_consume', 'users.member_id', '=', 'user_total_consume.member_id')
                ->orderBy('user_total_consume.total_consume', $sortOrder);
        } elseif ($sortField === 'wager_remaining') {
            $direction = $sortOrder === 'asc' ? 'ASC' : 'DESC';
            $grammar = $query->getQuery()->getGrammar();
            $required = $grammar->wrap('wallets.wager_required');
            $completed = $grammar->wrap('wallets.wager_completed');
            $query->orderByRaw(
                "GREATEST(COALESCE({$required}, 0) - COALESCE({$completed}, 0), 0) {$direction}"
            );
        } elseif (in_array($sortField, self::PAGINATE_WALLET_SORT_FIELDS, true)) {
            $query->orderBy("wallets.{$sortField}", $sortOrder);
        } elseif (in_array($sortField, self::PAGINATE_USER_SORT_FIELDS, true)) {
            $query->orderBy('users.' . $sortField, $sortOrder);
        } else {
            $query->orderBy('users.created_at', $sortOrder);
        }
        $query->orderByDesc('users.created_at')->orderByDesc('users.id');
    }

    private static function totalConsumeSubquery()
    {
        return BalanceLog::query()
            ->select('member_id')
            ->groupBy('member_id')
            ->selectRaw(
                "GREATEST(ABS(COALESCE(SUM(CASE WHEN type = 1 AND change_type LIKE '%投注%' THEN amount ELSE 0 END), 0))"
                . " - COALESCE(SUM(CASE WHEN type = 1 AND change_type LIKE '%彩退款' THEN amount ELSE 0 END), 0), 0) AS total_consume"
            );
    }

    //设置游戏ID
    public function setGameID($chatId, $gameId)
    {
        $gameId = trim($gameId);
        if (!$gameId) return ['chat_id' => $chatId, 'text' => '❌游戏ID设置失败，请输入正确的游戏ID'];

        if (User::where('game_id', $gameId)->where('member_id', '<>', $chatId)->first()) {
            return ['chat_id' => $chatId, 'text' => '❌游戏ID设置失败，游戏ID已绑定其他用户'];
        }
        $user = User::where('member_id', $chatId)->first();
        $user->game_id = $gameId;
        $user->save();
        return ['chat_id' => $chatId, 'text' => "✅ 游戏ID设置成功\n游戏ID：{$gameId}"];
    }

    /**
     * @param Api $telegram
     * @param $data
     * @param $chatId
     * @param $firstName
     * @param $messageId
     * @return void
     * @throws TelegramSDKException
     */
    public static function init(Api $telegram, $data, $chatId, $firstName, $messageId): void
    {
        $pattern = "/^setLanguage@@.*$/";
        if (preg_match($pattern, $data)) {
            $language = preg_replace('/^setLanguage@@/', '', $data);
            $res = UserService::setLanguage($chatId, $language);
            $telegram->deleteMessage(['chat_id' => $chatId, 'message_id' => $messageId]);
            TelegramWebHook::setReplyKeyboard($chatId, $language);
//            $telegram->sendMessage($res);
        }
    }


    public static function getIsBanned($memberId)
    {
        $user = User::where('member_id', $memberId)->first();
        return $user->is_banned == 1;
    }


    public static function setLanguage($chatId, $language): array
    {
        $userInfo = self::findOne(['member_id' => $chatId]);
        $userInfo->setLanguage($language);
        $userInfo->save();
        App::setLocale($language);
        (new Home)->setMyCommands();
        return self::getLanguages($chatId);
    }

    public static function getLanguages($chatId): array
    {
        $keyboard = [
            [['text' => lang('en'), 'callback_data' => "setLanguage@@en"]],
            [['text' => lang('zh'), 'callback_data' => "setLanguage@@zh"]],
            [['text' => lang('vi'), 'callback_data' => "setLanguage@@vi"]],
            [['text' => lang('❌取消'), 'callback_data' => "message@@close"]],
        ];
        return [
            'chat_id' => $chatId,
            'text' => lang("请选择您的语言"),
            'reply_markup' => json_encode(['inline_keyboard' => $keyboard]),
            'protect_content' => true
        ];
    }

}