<?php

namespace App\Http\Controllers\admin;

use App\Http\Controllers\AgentApiController;
use App\Models\Agent\Agent as AgentModel;
use App\Models\Agent\AgentCommission;
use App\Models\Agent\AgentCommissionRule;
use App\Models\Agent\AgentLoginLog;
use App\Models\Agent\AgentWithdrawal;
use App\Models\EgameItem;
use App\Models\User;
use App\Services\Agent\AgentCommissionService;
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 Illuminate\Http\Request;
use Illuminate\Validation\Rule;
use Illuminate\Support\Facades\DB;
use App\Rules\DecimalNumber;
use App\Constants\Util;

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'])->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'])->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 (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();
                }
                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'],
                '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)
    {
        return $this->execute(function () use ($request) {
            $data = $request->validate(['agent_id' => ['required', 'integer', 'exists:agents,id']]);
            $agent = AgentModel::query()->findOrFail($data['agent_id']);
            $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) {
                    $platform->logo = Util::ensureUrl($platform->logo);
                    return $platform;
                });
            return [
                'balance' => (string) $agent->balance,
                'frozen_balance' => (string) $agent->frozen_balance,
                'quota_mode' => 'internal',
                'provider_wallet_supported' => false,
                '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');
        });
    }

    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 commissionRules(Request $request)
    {
        return $this->execute(function () use ($request) {
            $data = $request->validate(['agent_id' => ['nullable', 'integer']]);
            return AgentCommissionRule::query()->with('agent:id,username')->when(!empty($data['agent_id']), fn($q) => $q->where('agent_id', $data['agent_id']))
                ->orderByDesc('effective_from')->get();
        });
    }

    public function saveFlowCommissionRule(Request $request, AgentCommissionService $commissions)
    {
        return $this->execute(function () use ($request, $commissions) {
            $data = $request->validate([
                'agent_id' => ['required', 'integer', 'exists:agents,id'],
                'flow_rate' => ['required', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
                'effective_from' => ['required', 'date_format:Y-m-d', 'date_equals:' . now()->toDateString()],
            ]);
            return $commissions->saveFlowRate(AgentModel::query()->findOrFail($data['agent_id']), (string) $data['flow_rate'], $data['effective_from'], (int) request()->user->id);
        });
    }

    public function saveProfitCommissionRule(Request $request, AgentCommissionService $commissions)
    {
        return $this->execute(function () use ($request, $commissions) {
            $data = $request->validate([
                'agent_id' => ['required', 'integer', 'exists:agents,id'],
                'profit_rate' => ['required', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
                'effective_from' => ['required', 'date_format:Y-m-d', 'date_equals:' . now()->toDateString()],
            ]);
            return $commissions->saveProfitRate(AgentModel::query()->findOrFail($data['agent_id']), (string) $data['profit_rate'], $data['effective_from'], (int) request()->user->id);
        });
    }

    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'], 'type' => ['nullable', 'in:flow,profit'], 'status' => ['nullable', 'in:pending,credited'],
                'start_date' => ['nullable', 'date_format:Y-m-d'], 'end_date' => ['nullable', 'date_format:Y-m-d', 'after_or_equal:start_date'],
            ]);
            $query = AgentCommission::query()->with('agent:id,username');
            foreach (['agent_id', 'type', 'status'] as $field) if (!empty($data[$field])) $query->where($field, $data[$field]);
            if (!empty($data['start_date'])) $query->where('settlement_date', '>=', $data['start_date']);
            if (!empty($data['end_date'])) $query->where('settlement_date', '<=', $data['end_date']);
            return $this->paginate($query, $data, 'settlement_date', false);
        });
    }

    private function rules(bool $update = false): array
    {
        return [
            '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' => ['nullable', 'integer', 'exists:agents,id'], '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' => $update ? ['prohibited'] : ['nullable', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
            'profit_commission_rate' => $update ? ['prohibited'] : ['nullable', 'numeric', 'between:0,100', new DecimalNumber(3, 4)],
            '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): 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('created_at', '>=', $data['start_date'] . ' 00:00:00');
        if ($filterCreatedAt && !empty($data['end_date'])) $query->where('created_at', '<=', $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(),
        ]);
    }
}