bot-28/app/Http/Controllers/admin/Agent.php

<?php

namespace App\Http\Controllers\admin;

use App\Http\Controllers\AgentApiController;
use App\Models\Agent\Agent as AgentModel;
use App\Models\Agent\AgentLoginLog;
use App\Models\Agent\AgentWithdrawal;
use App\Models\Agent\AgentRebateRecord;
use App\Models\EgameItem;
use App\Models\User;
use App\Services\Agent\AgentDomainService;
use App\Services\Agent\AgentReportService;
use App\Services\Agent\AgentService;
use App\Services\Agent\AgentWalletService;
use App\Services\Agent\AgentWithdrawalService;
use App\Services\Agent\AgentFlowCommissionProfileService;
use App\Services\Agent\AgentProfitCommissionProfileService;
use Illuminate\Http\Request;
use Illuminate\Validation\Rule;
use Illuminate\Support\Facades\DB;
use App\Rules\DecimalNumber;
use App\Constants\Util;
use App\Services\ThirdGameBalanceService;

class Agent extends AgentApiController
{
    public function index(Request $request, AgentDomainService $domains)
    {
        return $this->execute(function () use ($request, $domains) {
            $data = $request->validate([
                'page' => ['nullable', 'integer', 'min:1'], 'limit' => ['nullable', 'integer', 'min:1', 'max:100'],
                'username' => ['nullable', 'string', 'max:64'], 'real_name' => ['nullable', 'string', 'max:128'],
                'parent_id' => ['nullable', 'integer'], 'status' => ['nullable', 'integer', 'in:0,1'],
                'start_date' => ['nullable', 'date_format:Y-m-d'], 'end_date' => ['nullable', 'date_format:Y-m-d', 'after_or_equal:start_date'],
            ]);
            $page = max(1, (int) ($data['page'] ?? 1));
            $limit = min(100, max(1, (int) ($data['limit'] ?? 20)));
            $query = AgentModel::query()->with(['parent:id,username', 'token:id,agent_id,expires_at,last_used_at', 'flowCommissionProfile', 'profitCommissionProfile'])->withCount(['children', 'members']);
            if (!empty($data['username'])) $query->where('username', 'like', '%' . $data['username'] . '%');
            if (!empty($data['real_name'])) $query->where('real_name', 'like', '%' . $data['real_name'] . '%');
            if (!empty($data['parent_id'])) $query->where('parent_id', $data['parent_id']);
            if (isset($data['status'])) $query->where('status', $data['status']);
            if (!empty($data['start_date'])) $query->where('created_at', '>=', $data['start_date'] . ' 00:00:00');
            if (!empty($data['end_date'])) $query->where('created_at', '<=', $data['end_date'] . ' 23:59:59');
            $total = (clone $query)->count();
            $list = $query->orderByDesc('id')->forPage($page, $limit)->get()->map(fn(AgentModel $agent) => $this->formatAgent($agent, $domains));
            return compact('total', 'page', 'limit', 'list');
        });
    }

    public function show(Request $request, AgentDomainService $domains)
    {
        return $this->execute(function () use ($request, $domains) {
            $data = $request->validate(['id' => ['required', 'integer', 'exists:agents,id']]);
            $agent = AgentModel::query()->with(['parent:id,username', 'token:id,agent_id,expires_at,last_used_at', 'flowCommissionProfile', 'profitCommissionProfile'])->withCount(['children', 'members'])->findOrFail($data['id']);
            return $this->formatAgent($agent, $domains);
        });
    }

    public function store(Request $request, AgentService $service)
    {
        return $this->execute(function () use ($request, $service) {
            $data = $request->validate($this->rules());
            return DB::transaction(function () use ($data, $service) {
                $agent = $service->create($data, (int) request()->user->id);
                if (!empty($data['owner_user_id'])) {
                    $agent = app(\App\Services\Agent\AgentApplicationService::class)->bindMember($agent, (int) $data['owner_user_id']);
                }
                if (bccomp((string) ($data['initial_balance'] ?? 0), '0', 4) > 0) {
                    app(AgentWalletService::class)->adjust(
                        (int) $agent->id,
                        (string) $data['initial_balance'],
                        'credit',
                        '新增代理初始额度',
                        'agent-initial:' . $agent->id,
                        'admin',
                        (int) request()->user->id
                    );
                    $agent = $agent->fresh(['flowCommissionProfile', 'profitCommissionProfile']);
                }
                return $agent;
            });
        });
    }

    public function update(Request $request, AgentService $service)
    {
        return $this->execute(function () use ($request, $service) {
            $data = $request->validate(array_merge(['id' => ['required', 'integer', 'exists:agents,id']], $this->rules(true)));
            return DB::transaction(function () use ($service, $data) {
                $agent = $service->update(
                    AgentModel::query()->findOrFail($data['id']),
                    $data,
                    null,
                    (int) request()->user->id
                );
                if (!empty($data['owner_user_id'])) {
                    $agent = app(\App\Services\Agent\AgentApplicationService::class)->bindMember($agent, (int) $data['owner_user_id']);
                }
                return $agent;
            });
        });
    }

    public function domains(Request $request, AgentDomainService $service)
    {
        return $this->execute(function () use ($request, $service) {
            $data = $request->validate([
                'id' => ['required', 'integer', 'exists:agents,id'],
                'pc' => ['nullable', 'string', 'max:255'], 'h5' => ['nullable', 'string', 'max:255'],
            ]);
            return $service->save(AgentModel::query()->findOrFail($data['id']), $data);
        });
    }

    public function adjust(Request $request, AgentWalletService $wallets)
    {
        return $this->execute(function () use ($request, $wallets) {
            $data = $request->validate([
                'agent_id' => ['required', 'integer', 'exists:agents,id'], 'type' => ['required', 'in:credit,debit'],
                'amount' => ['required', 'numeric', 'min:0.0001', new DecimalNumber()], 'remark' => ['required', 'string', 'max:500'],
                'request_id' => ['required', 'string', 'max:64'],
            ]);
            return $wallets->adjust(
                (int) $data['agent_id'], (string) $data['amount'], $data['type'], $data['remark'],
                'admin:' . request()->user->id . ':' . $data['request_id'], 'admin', (int) request()->user->id
            );
        });
    }

    public function quota(Request $request, ThirdGameBalanceService $thirdGame)
    {
        return $this->execute(function () use ($request, $thirdGame) {
            $data = $request->validate([
                'agent_id' => ['required', 'integer', 'exists:agents,id'],
                'refresh' => ['nullable', 'boolean'],
            ]);
            $agent = AgentModel::query()->findOrFail($data['agent_id']);
            $provider = $thirdGame->agentBalances((int) $agent->id, $request->boolean('refresh'));
            if (empty($provider['ok'])) {
                throw new \RuntimeException((string) ($provider['msg'] ?? '三方平台余额查询失败'));
            }
            $balances = is_array($provider['balances'] ?? null) ? $provider['balances'] : [];
            $platforms = EgameItem::query()->where('item_type', EgameItem::TYPE_PLATFORM)->where('game_type', 0)
                ->where('status', EgameItem::STATUS_ENABLED)->orderByDesc('sort')->get(['plat_type', 'name', 'logo'])
                ->map(function (EgameItem $platform) use ($balances) {
                    $key = strtolower((string) $platform->plat_type);
                    $platform->logo = Util::ensureUrl($platform->logo);
                    $platform->setAttribute('balance', $balances[$key] ?? '0.0000000000');
                    $platform->setAttribute('account_opened', array_key_exists($key, $balances) ? 1 : 0);
                    return $platform;
                });
            return [
                'agent_id' => (int) $agent->id,
                'player_id' => (string) $provider['player_id'],
                'currency' => (string) $provider['currency'],
                'balance' => (string) $agent->balance,
                'frozen_balance' => (string) $agent->frozen_balance,
                'quota_mode' => 'provider',
                'provider_wallet_supported' => true,
                'platforms' => $platforms,
            ];
        });
    }

    public function bindMember(Request $request)
    {
        return $this->execute(function () use ($request) {
            $data = $request->validate([
                'user_id' => ['required', 'integer', 'exists:users,id'],
                'agent_id' => ['nullable', 'integer', 'exists:agents,id'],
            ]);
            $user = User::query()->findOrFail($data['user_id']);
            $user->agent_id = $data['agent_id'] ?? null;
            $user->save();
            return ['user_id' => (int) $user->id, 'agent_id' => $user->agent_id === null ? null : (int) $user->agent_id];
        });
    }

    public function loginLogs(Request $request)
    {
        return $this->execute(function () use ($request) {
            $data = $request->validate([
                'page' => ['nullable', 'integer', 'min:1'], 'limit' => ['nullable', 'integer', 'min:1', 'max:100'],
                'agent_id' => ['nullable', 'integer'], 'username' => ['nullable', 'string', 'max:64'],
                'ip' => ['nullable', 'string', 'max:64'], 'device' => ['nullable', 'in:mobile,pc'],
                'start_date' => ['nullable', 'date_format:Y-m-d'], 'end_date' => ['nullable', 'date_format:Y-m-d', 'after_or_equal:start_date'],
            ]);
            $query = AgentLoginLog::query();
            foreach (['agent_id', 'username', 'ip', 'device'] as $field) if (!empty($data[$field])) $query->where($field, $data[$field]);
            return $this->paginate($query, $data, 'login_at', true, 'login_at');
        });
    }

    public function withdrawals(Request $request)
    {
        return $this->execute(function () use ($request) {
            $data = $request->validate([
                'page' => ['nullable', 'integer', 'min:1'], 'limit' => ['nullable', 'integer', 'min:1', 'max:100'],
                'agent_id' => ['nullable', 'integer'], 'order_no' => ['nullable', 'string', 'max:40'],
                'status' => ['nullable', 'in:pending,approved,rejected,paid'],
                'start_date' => ['nullable', 'date_format:Y-m-d'], 'end_date' => ['nullable', 'date_format:Y-m-d', 'after_or_equal:start_date'],
            ]);
            $query = AgentWithdrawal::query()->with('agent:id,username,real_name');
            foreach (['agent_id', 'order_no', 'status'] as $field) if (!empty($data[$field])) $query->where($field, $data[$field]);
            return $this->paginate($query, $data);
        });
    }

    public function auditWithdrawal(Request $request, AgentWithdrawalService $service)
    {
        return $this->execute(function () use ($request, $service) {
            $data = $request->validate([
                'id' => ['required', 'integer', 'exists:agent_withdrawals,id'],
                'action' => ['required', 'in:approve,reject,paid'], 'remark' => ['nullable', 'string', 'max:500'],
            ]);
            return $service->audit((int) $data['id'], $data['action'], (int) request()->user->id, (string) ($data['remark'] ?? ''));
        });
    }

    public function reports(Request $request, AgentReportService $reports)
    {
        return $this->execute(function () use ($request, $reports) {
            $data = $request->validate([
                'page' => ['nullable', 'integer', 'min:1'], 'limit' => ['nullable', 'integer', 'min:1', 'max:20'],
                'username' => ['nullable', 'string', 'max:64'], 'start_date' => ['required', 'date_format:Y-m-d'],
                'end_date' => ['required', 'date_format:Y-m-d', 'after_or_equal:start_date'],
            ]);
            return $reports->reportRows(null, $data);
        });
    }

    public function commissions(Request $request)
    {
        return $this->execute(function () use ($request) {
            $data = $request->validate([
                'page' => ['nullable', 'integer', 'min:1'], 'limit' => ['nullable', 'integer', 'min:1', 'max:100'],
                'agent_id' => ['nullable', 'integer'], 'order_no' => ['nullable', 'string', 'max:48'],
                'username' => ['nullable', 'string', 'max:64'],
                'platform' => ['nullable', 'string', 'max:32'],
                'flow_status' => ['nullable', 'in:pending,credited'],
                'profit_status' => ['nullable', 'in:pending,credited'],
                'settlement_date' => ['nullable', 'date_format:Y-m-d'],
                'start_date' => ['nullable', 'date_format:Y-m-d'], 'end_date' => ['nullable', 'date_format:Y-m-d', 'after_or_equal:start_date'],
            ]);
            $query = AgentRebateRecord::query()->with('agent:id,username');
            foreach (['agent_id', 'order_no', 'platform', 'flow_status', 'profit_status'] as $field) {
                if (!empty($data[$field])) $query->where($field, $data[$field]);
            }
            if (!empty($data['username'])) {
                $query->whereHas('agent', fn($query) => $query->where('username', 'like', '%' . $data['username'] . '%'));
            }
            if (!empty($data['settlement_date'])) $query->where('settlement_date', $data['settlement_date']);
            if (!empty($data['start_date'])) $query->where('created_at', '>=', $data['start_date'] . ' 00:00:00');
            if (!empty($data['end_date'])) $query->where('created_at', '<=', $data['end_date'] . ' 23:59:59');
            return $this->paginate($query, $data, 'settlement_date', false);
        });
    }

    public function profitCommissionProfiles(Request $request, AgentProfitCommissionProfileService $service)
    {
        return $this->execute(function () use ($request, $service) {
            $data = $request->validate([
                'page' => ['nullable', 'integer', 'min:1'], 'limit' => ['nullable', 'integer', 'min:1', 'max:100'],
                'name' => ['nullable', 'string', 'max:128'],
            ]);
            return $service->paginate($data);
        });
    }

    public function flowCommissionProfiles(Request $request, AgentFlowCommissionProfileService $service)
    {
        return $this->execute(function () use ($request, $service) {
            $data = $request->validate([
                'page' => ['nullable', 'integer', 'min:1'], 'limit' => ['nullable', 'integer', 'min:1', 'max:100'],
                'name' => ['nullable', 'string', 'max:128'],
            ]);
            return $service->paginate($data);
        });
    }

    public function saveFlowCommissionProfile(Request $request, AgentFlowCommissionProfileService $service)
    {
        return $this->execute(function () use ($request, $service) {
            $id = (int)$request->input('id', 0);
            $data = $request->validate([
                'id' => ['nullable', 'integer', 'exists:agent_flow_commission_profiles,id'],
                'name' => ['required', 'string', 'max:128', Rule::unique('agent_flow_commission_profiles', 'name')->whereNull('owner_agent_id')->ignore($id)],
                'live_rate' => ['required', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
                'slot_rate' => ['required', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
                'lottery_rate' => ['required', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
                'sport_rate' => ['required', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
                'esports_rate' => ['required', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
                'fishing_rate' => ['required', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
                'chess_rate' => ['required', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
                'is_default' => ['required', 'boolean'],
            ]);
            return $service->save($data, (int)request()->user->id);
        });
    }

    public function deleteFlowCommissionProfile(Request $request, AgentFlowCommissionProfileService $service)
    {
        return $this->execute(function () use ($request, $service) {
            $data = $request->validate(['id' => ['required', 'integer', 'exists:agent_flow_commission_profiles,id']]);
            $service->delete((int)$data['id'], (int)request()->user->id);
            return [];
        });
    }

    public function saveProfitCommissionProfile(Request $request, AgentProfitCommissionProfileService $service)
    {
        return $this->execute(function () use ($request, $service) {
            $id = (int) $request->input('id', 0);
            $data = $request->validate([
                'id' => ['nullable', 'integer', 'exists:agent_profit_commission_profiles,id'],
                'name' => ['required', 'string', 'max:128', Rule::unique('agent_profit_commission_profiles', 'name')->whereNull('owner_agent_id')->ignore($id)],
                'live_rate' => ['required', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
                'slot_rate' => ['required', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
                'lottery_rate' => ['required', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
                'sport_rate' => ['required', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
                'esports_rate' => ['required', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
                'fishing_rate' => ['required', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
                'chess_rate' => ['required', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
                'is_default' => ['required', 'boolean'],
            ]);
            return $service->save($data, (int) request()->user->id);
        });
    }

    public function deleteProfitCommissionProfile(Request $request, AgentProfitCommissionProfileService $service)
    {
        return $this->execute(function () use ($request, $service) {
            $data = $request->validate(['id' => ['required', 'integer', 'exists:agent_profit_commission_profiles,id']]);
            $service->delete((int) $data['id'], (int) request()->user->id);
            return [];
        });
    }

    private function rules(bool $update = false): array
    {
        return [
            'language' => ['sometimes', 'required', 'in:zh,en,vi'],
            'owner_user_id' => ['nullable', 'integer', 'min:1', 'exists:users,id'],
            'username' => $update
                ? ['sometimes', 'string', 'min:4', 'max:64', 'alpha_dash', Rule::unique('agents', 'username')->ignore((int) request()->input('id'))]
                : ['required', 'string', 'min:4', 'max:64', 'alpha_dash', 'unique:agents,username'],
            'password' => [$update ? 'nullable' : 'required', 'string', 'min:6', 'max:100'],
            'withdraw_password' => ['nullable', 'string', 'min:6', 'max:100'], 'real_name' => ['nullable', 'string', 'max:128'],
            'parent_id' => $update ? ['nullable', 'integer', 'exists:agents,id'] : ['prohibited'],
            'deposit_fee_rate' => ['nullable', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
            'withdraw_fee_rate' => ['nullable', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
            'flow_commission_rate' => ['prohibited'],
            'profit_commission_rate' => ['prohibited'],
            'flow_commission_profile_id' => $update
                ? ['nullable', 'integer', Rule::exists('agent_flow_commission_profiles', 'id')->whereNull('owner_agent_id')]
                : ['required', 'integer', Rule::exists('agent_flow_commission_profiles', 'id')->whereNull('owner_agent_id')],
            'profit_commission_profile_id' => ['nullable', 'integer', Rule::exists('agent_profit_commission_profiles', 'id')->whereNull('owner_agent_id')],
            'status' => ['nullable', 'integer', 'in:0,1'],
            'initial_balance' => $update ? ['prohibited'] : ['nullable', 'numeric', 'min:0', new DecimalNumber()],
        ];
    }

    private function paginate($query, array $data, string $orderBy = 'id', bool $filterCreatedAt = true, string $dateColumn = 'created_at'): array
    {
        $page = max(1, (int) ($data['page'] ?? 1));
        $limit = min(100, max(1, (int) ($data['limit'] ?? 20)));
        if ($filterCreatedAt && !empty($data['start_date'])) $query->where($dateColumn, '>=', $data['start_date'] . ' 00:00:00');
        if ($filterCreatedAt && !empty($data['end_date'])) $query->where($dateColumn, '<=', $data['end_date'] . ' 23:59:59');
        $total = (clone $query)->count();
        $list = $query->orderByDesc($orderBy)->orderByDesc('id')->forPage($page, $limit)->get();
        return compact('total', 'page', 'limit', 'list');
    }

    private function formatAgent(AgentModel $agent, AgentDomainService $domains): array
    {
        $token = $agent->token;
        $online = $token
            && $token->expires_at->isFuture()
            && $token->last_used_at
            && $token->last_used_at->gte(now()->subMinutes(config('agent.online_minutes', 5)));
        $data = $agent->toArray();
        unset($data['token']);
        return array_merge($data, $domains->format($agent), [
            'login_status' => $online ? 1 : 0,
            'login_status_text' => $online ? '在线' : '离线',
            'last_active_at' => $token?->last_used_at?->toDateTimeString(),
        ]);
    }
}