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\AgentBalanceLog;
use App\Models\Agent\AgentLoginLog;
use App\Models\Agent\AgentManualCreditLock;
use App\Models\Agent\AgentWithdrawal;
use App\Models\Agent\AgentRebateRecord;
use App\Models\EgameItem;
use App\Services\Agent\AgentDomainService;
use App\Services\Agent\AgentEquityAllocation;
use App\Services\Agent\AgentEquityService;
use App\Services\Agent\AgentReportService;
use App\Services\Agent\AgentService;
use App\Services\Agent\AgentWalletService;
use App\Services\Agent\AgentWithdrawalService;
use App\Services\Agent\AgentPlanApplicationService;
use App\Services\Agent\AgentRechargeService;
use App\Services\Agent\AgentPaymentService;
use App\Models\Agent\AgentSetting;
use App\Models\Agent\AgentRecharge;
use App\Models\Agent\AgentProfitEntry;
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'],
                'type' => ['nullable', 'integer', 'in:1,2'], 'status' => ['nullable', 'integer', 'in:0,1'], 'is_test' => ['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(['token:id,agent_id,expires_at,last_used_at', 'profitCommissionProfile'])->withCount(['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['type'])) $query->where('type', $data['type']);
            if (isset($data['status'])) $query->where('status', $data['status']);
            if (isset($data['is_test'])) $query->where('is_test', $data['is_test']);
            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(['token:id,agent_id,expires_at,last_used_at', 'profitCommissionProfile'])->withCount(['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 (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(['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 $service->update(AgentModel::query()->findOrFail($data['id']), $data);
        });
    }

    public function domains(Request $request, AgentDomainService $service)
    {
        return $this->execute(function () use ($request, $service) {
            $data = $request->validate([
                'id' => ['required', 'integer', 'exists:agents,id'],
                // domains：域名数组（整体替换，空数组为清空），也可以是字符串（一个域名）
                'domains' => ['present', function ($attribute, $value, $fail) {
                    if (!is_string($value) && !is_array($value)) $fail('域名格式错误');
                    elseif (is_string($value) && mb_strlen($value) > 255) $fail('域名不能超过255个字符');
                }],
                'domains.*' => ['nullable', 'string', 'max:255'],
            ]);
            $domains = $request->input('domains');
            $values = is_array($domains) ? $domains : ($domains === null ? [] : [(string) $domains]);
            return $service->save(AgentModel::query()->findOrFail($data['id']), $values);
        });
    }

    public function adjust(Request $request, AgentWalletService $wallets, AgentEquityService $equity)
    {
        return $this->execute(function () use ($request, $wallets, $equity) {
            $data = $request->validate([
                'agent_id' => ['required', 'integer', 'exists:agents,id'], 'type' => ['required', 'in:credit,debit,margin_credit,margin_refund'],
                'amount' => ['required', 'numeric', 'min:0.0001', new DecimalNumber()], 'remark' => ['required', 'string', 'max:500'],
                'request_id' => ['required', 'string', 'max:64'],
            ]);
            $log = $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,
                freezeEquityCredit: true,
            );
            if ($log->wasRecentlyCreated && $log->reference_type === AgentManualCreditLock::REFERENCE_TYPE) {
                try {
                    $equity->fulfillPending((int) $data['agent_id']);
                } catch (\Throwable $e) {
                    report($e);
                }
            }
            return $log;
        });
    }

    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 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 balanceLogs(Request $request)
    {
        return $this->execute(function () use ($request) {
            $data = $request->validate([
                'agent_id' => ['required', 'integer', 'min:1'],
                'page' => ['nullable', 'integer', 'min:1'],
                'limit' => ['nullable', 'integer', 'min:1', 'max:100'],
                'type' => ['nullable', 'string', 'max:32'],
                'start_date' => ['nullable', 'date_format:Y-m-d'],
                'end_date' => ['nullable', 'date_format:Y-m-d', 'after_or_equal:start_date'],
            ]);
            $query = AgentBalanceLog::query()->where('agent_id', $data['agent_id']);
            if (!empty($data['type'])) {
                $query->where('type', $data['type']);
            }
            $result = $this->paginate($query, $data);
            $types = AgentWalletService::TYPE_NAMES;
            $result['list']->each(fn (AgentBalanceLog $log) => $log->setAttribute('type_text', $types[$log->type] ?? $log->type));
            $result['types'] = array_map(fn (string $type, string $label) => [
                'value' => $type, 'label' => $label,
            ], array_keys($types), array_values($types));
            return $result;
        });
    }

    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,processing,rejected,paid,failed'], 'channel' => ['nullable', 'string', 'max:32'],
                '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,type');
            foreach (['agent_id', 'order_no', 'status'] as $field) if (!empty($data[$field])) $query->where($field, $data[$field]);
            if (!empty($data['channel'])) $query->where('account_type', $data['channel']);
            $result = $this->paginate($query, $data);
            $result['list']->each->makeVisible(AgentWithdrawal::ADMIN_ONLY);
            return $result;
        });
    }

    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'],
                'category' => ['nullable', 'string', 'max:32'],
                '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');
            if (!empty($data['category'])) $query->where('platform', $data['category']);
            foreach (['agent_id', 'order_no', 'platform', '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 saveProfitCommissionProfile(Request $request, AgentProfitCommissionProfileService $service)
    {
        return $this->execute(function () use ($request, $service) {
            $data = $request->validate([
                'id' => ['nullable', 'integer', 'exists:agent_profit_commission_profiles,id'],
                'name' => ['required', 'string', 'max:128'],
                'margin_amount' => ['required', 'numeric', 'min:0', new DecimalNumber()],
                'f1_lottery_rate' => ['required', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
                'f1_sport_rate' => ['required', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
                'live_rate' => ['required', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
                'slot_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)],
            ]);
            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']);
            return [];
        });
    }

    /** 代理全局配置：停止分成阈值（方案保证金的百分比）、入股价格与可购买区间。 */
    public function settings()
    {
        return $this->execute(fn () => AgentSetting::current());
    }

    public function saveSettings(Request $request)
    {
        return $this->execute(function () use ($request) {
            $data = $request->validate([
                'margin_stop_percent' => ['required', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
                'equity_enabled' => ['required', 'boolean'],
                'equity_price_per_percent' => ['required', 'numeric', 'min:0', new DecimalNumber()],
                'equity_min_percent' => ['required', 'numeric', 'gt:0', 'max:100', new DecimalNumber(3, 4)],
                'equity_max_percent' => ['required', 'numeric', 'gte:equity_min_percent', 'max:100', new DecimalNumber(3, 4)],
                'company_equity_percent' => ['sometimes', 'required', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
                'equity_recharge_lock_days' => ['nullable', 'integer', 'between:0,365'],
                'recharge_channel_group_id' => ['nullable', 'integer', \Illuminate\Validation\Rule::exists('recharge_channel_group', 'id')->whereNull('deleted_at')],
            ]);
            if (array_key_exists('recharge_channel_group_id', $data)) $data['recharge_channel_group_id'] = (int) ($data['recharge_channel_group_id'] ?: 1);
            if (array_key_exists('equity_recharge_lock_days', $data) && $data['equity_recharge_lock_days'] === null) unset($data['equity_recharge_lock_days']);
            return DB::transaction(function () use ($data, $request) {
                $setting = AgentSetting::lockCurrent();
                if (isset($data['company_equity_percent'])) {
                    $companyPercent = (string) $data['company_equity_percent'];
                    if (bccomp($companyPercent, $setting->company_equity_percent, 4) !== 0
                        && bccomp(AgentEquityAllocation::available($companyPercent), '0', 4) < 0) {
                        throw new \InvalidArgumentException('公司持股、已开通股份和待付款股份合计不能超过100%');
                    }
                }
                $setting->fill($data + ['updated_by' => (int) request()->user->id]);
                $setting->equity_enabled = $request->boolean('equity_enabled') ? 1 : 0;
                $setting->save();
                return $setting->fresh();
            });
        });
    }

    public function planApplications(Request $request, AgentPlanApplicationService $service)
    {
        return $this->execute(function () use ($request, $service) {
            $data = $request->validate([
                'page' => ['nullable', 'integer', 'min:1'], 'limit' => ['nullable', 'integer', 'min:1', 'max:100'],
                'agent_id' => ['nullable', 'integer'], 'username' => ['nullable', 'string', 'max:64'],
                'status' => ['nullable', 'in:pending,approved,rejected'],
            ]);
            return $service->paginate($data);
        });
    }

    public function auditPlanApplication(Request $request, AgentPlanApplicationService $service)
    {
        return $this->execute(function () use ($request, $service) {
            $data = $request->validate([
                'id' => ['required', 'integer'], 'status' => ['required', 'in:approved,rejected'],
                'reject_reason' => ['required_if:status,rejected', 'nullable', 'string', 'max:500'],
            ]);
            return $service->audit((int) $data['id'], $data['status'], (int) request()->user->id, (string) ($data['reject_reason'] ?? ''));
        });
    }

    /** 入股购买记录（全部代理）。 */
    public function equityOrders(Request $request, \App\Services\Agent\AgentEquityService $service)
    {
        return $this->execute(function () use ($request, $service) {
            $data = $request->validate([
                'page' => ['nullable', 'integer', 'min:1'], 'limit' => ['nullable', 'integer', 'min:1', 'max:100'],
                'agent_id' => ['nullable', 'integer'], 'username' => ['nullable', 'string', 'max:64'],
                'order_no' => ['nullable', 'string', 'max:40'], 'status' => ['nullable', 'in:pending_payment,completed,cancelled'],
                'date_type' => ['nullable', 'in:created_at,completed_at'],
                'start_date' => ['nullable', 'date_format:Y-m-d'], 'end_date' => ['nullable', 'date_format:Y-m-d', 'after_or_equal:start_date'],
            ]);
            return $service->paginate($data);
        });
    }

    /** 取消代理的待付款入股订单。 */
    public function cancelEquityOrder(Request $request, \App\Services\Agent\AgentEquityService $service)
    {
        return $this->execute(function () use ($request, $service) {
            $data = $request->validate(['id' => ['required', 'integer'], 'remark' => ['required', 'string', 'max:255']]);
            return $service->adminCancel((int) $data['id'], (int) request()->user->id, (string) $data['remark']);
        });
    }

    public function recharges(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'],
                'txid' => ['nullable', 'string', 'max:100'], 'type' => ['nullable', 'integer', 'in:1,2'],
                'status' => ['nullable', 'integer', 'in:0,1,2,3'],
                'start_date' => ['nullable', 'date_format:Y-m-d'], 'end_date' => ['nullable', 'date_format:Y-m-d', 'after_or_equal:start_date'],
            ]);
            $query = AgentRecharge::query()->with('agent:id,username,real_name,type');
            foreach (['agent_id', 'order_no', 'txid', 'type'] as $field) if (!empty($data[$field])) $query->where($field, $data[$field]);
            if (isset($data['status'])) $query->where('status', (int) $data['status']);
            return $this->paginate($query, $data);
        });
    }

    public function auditRecharge(Request $request, AgentRechargeService $service)
    {
        return $this->execute(function () use ($request, $service) {
            $data = $request->validate([
                'id' => ['required', 'integer'], 'status' => ['required', 'integer', 'in:1,2'],
                'remark' => ['required_if:status,2', 'nullable', 'string', 'max:500'],
            ]);
            return $service->audit((int) $data['id'], (int) $data['status'], (int) request()->user->id, (string) ($data['remark'] ?? ''));
        });
    }

    /** 代理人民币充值（在线代收 + 人工充值）。 */
    public function paymentOrders(Request $request, AgentPaymentService $service)
    {
        return $this->execute(function () use ($request, $service) {
            $data = $request->validate([
                'page' => ['nullable', 'integer', 'min:1'], 'limit' => ['nullable', 'integer', 'min:1', 'max:100'],
                'agent_id' => ['nullable', 'integer'], 'order_no' => ['nullable', 'string', 'max:64'],
                'type' => ['nullable', 'integer', 'in:1,3'], 'channel' => ['nullable', 'string', 'max:50'],
                'payment_type' => ['nullable', 'integer'], 'status' => ['nullable', 'integer', 'between:0,7'],
                'start_date' => ['nullable', 'date_format:Y-m-d'], 'end_date' => ['nullable', 'date_format:Y-m-d', 'after_or_equal:start_date'],
            ]);
            return $service->paginate($data);
        });
    }

    public function paymentOrderPayData(Request $request, AgentPaymentService $service)
    {
        return $this->execute(function () use ($request, $service) {
            $data = $request->validate([
                'ids' => ['required', 'array', 'min:1'], 'ids.*' => ['required', 'integer', 'min:1'],
                'payment_type' => ['required', 'integer'], 'pay_data' => ['required', 'string'],
            ]);
            return ['updated' => $service->setPayData($data['ids'], (int) $data['payment_type'], $data['pay_data'])];
        });
    }

    public function auditPaymentOrder(Request $request, AgentPaymentService $service)
    {
        return $this->execute(function () use ($request, $service) {
            $data = $request->validate([
                'id' => ['required', 'integer'], 'status' => ['required', 'integer', 'in:2,3'],
                'remark' => ['required_if:status,3', 'nullable', 'string', 'max:255'],
            ]);
            return $service->manualAudit((int) $data['id'], (int) $data['status'], (string) ($data['remark'] ?? ''), (int) request()->user->id);
        });
    }

    public function rejectPaymentOrder(Request $request, AgentPaymentService $service)
    {
        return $this->execute(function () use ($request, $service) {
            $data = $request->validate(['id' => ['required', 'integer'], 'remark' => ['nullable', 'string', 'max:120']]);
            return $service->reject((int) $data['id'], (string) ($data['remark'] ?? ''), (int) request()->user->id);
        });
    }

    public function queryPaymentOrder(Request $request, AgentPaymentService $service)
    {
        return $this->execute(function () use ($request, $service) {
            $data = $request->validate(['id' => ['required', 'integer']]);
            $result = $service->query((int) $data['id']);
            return ['paid' => (int) ($result['code'] ?? 0) === 1, 'msg' => (string) ($result['msg'] ?? '')];
        });
    }

    public function profitEntries(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'], 'user_id' => ['nullable', 'integer'], 'category' => ['nullable', 'string', 'max:32'],
                'status' => ['nullable', 'in:counted,skipped_inactive,skipped_no_plan,skipped_category'],
                'start_date' => ['nullable', 'date_format:Y-m-d'], 'end_date' => ['nullable', 'date_format:Y-m-d', 'after_or_equal:start_date'],
            ]);
            $query = AgentProfitEntry::query();
            foreach (['agent_id', 'user_id', 'category', 'status'] as $field) if (!empty($data[$field])) $query->where($field, $data[$field]);
            if (!empty($data['start_date'])) $query->where('settle_date', '>=', $data['start_date']);
            if (!empty($data['end_date'])) $query->where('settle_date', '<=', $data['end_date']);
            $page = max(1, (int) ($data['page'] ?? 1));
            $limit = min(100, max(1, (int) ($data['limit'] ?? 20)));
            $total = (clone $query)->count();
            $list = $query->orderByDesc('id')->forPage($page, $limit)->get()->each->makeVisible('realtime_balance_after');
            return compact('total', 'page', 'limit', 'list');
        });
    }

    private function rules(bool $update = false): array
    {
        return [
            'language' => ['sometimes', 'required', 'in:zh,en,vi'],
            'type' => [$update ? 'nullable' : 'required', 'integer', 'in:1,2'],
            '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'],
            'deposit_fee_rate' => ['nullable', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
            'withdraw_fee_rate' => ['nullable', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
            'status' => ['nullable', 'integer', 'in:0,1'],
            // 测试代理：名下会员和自身资金不参与总后台统计
            'is_test' => ['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']);
        $wallets = app(AgentWalletService::class);
        return array_merge($data, $domains->format($agent), $wallets->funds($agent), [
            // 总后台可以看到实时保证金；代理端不返回。
            'realtime_balance' => (string) $agent->realtime_balance,
            'realtime_margin' => $agent->isJoint() ? $wallets->effectiveMargin($agent) : null,
            'login_status' => $online ? 1 : 0,
            'login_status_text' => $online ? '在线' : '离线',
            'last_active_at' => $token?->last_used_at?->toDateTimeString(),
        ]);
    }
}