<?php

namespace App\Http\Controllers\admin;

use App\Constants\HttpStatus;
use App\Http\Controllers\Controller;
use App\Models\ShareBlacklist;
use App\Services\Sharing\ShareAdminService;
use App\Models\User;
use App\Services\OperationAuditService;
use App\Services\ShareEarningReportService;
use Illuminate\Support\Facades\DB;
use Illuminate\Validation\Rule;
use Illuminate\Validation\ValidationException;
use Illuminate\Database\QueryException;
use Illuminate\Support\Facades\Log;
use Throwable;

class ShareEarning extends Controller
{
    public function memberList(ShareEarningReportService $service)
    {
        return $this->report(fn ($params) => $service->memberDays($params), $this->dateListRules());
    }

    public function promoterDetails(ShareEarningReportService $service)
    {
        return $this->report(fn ($params) => $service->promoterDetails($params), $this->detailRules());
    }

    public function registrationDetails(ShareEarningReportService $service)
    {
        return $this->report(fn ($params) => $service->registrationDetails($params), $this->detailRules());
    }

    public function summary(ShareEarningReportService $service)
    {
        return $this->report(fn ($params) => $service->summary($params), $this->dateListRules([
            'account' => ['nullable', 'string', 'max:100'],
        ]));
    }

    public function settings(ShareAdminService $service)
    {
        return $this->run(fn () => $service->settings());
    }

    public function saveSettings(ShareAdminService $service)
    {
        return $this->run(fn () => $service->saveSettings(request()->all()));
    }

    public function blacklists()
    {
        return $this->run(function () {
            $params = request()->validate([
                'page' => ['nullable', 'integer', 'min:1'],
                'limit' => ['nullable', 'integer', 'min:1', 'max:200'],
                'account' => ['nullable', 'string', 'max:100'],
            ]);
            $query = ShareBlacklist::query();
            if (!empty($params['account'])) {
                $ids = User::query()->where('account', 'like', '%' . $params['account'] . '%')->pluck('id');
                $query->whereIn('user_id', $ids);
            }
            $total = $query->count();
            $rows = $query->orderByDesc('id')->forPage((int)($params['page'] ?? 1), (int)($params['limit'] ?? 20))->get();
            $users = User::query()->whereIn('id', $rows->pluck('user_id'))->get()->keyBy('id');
            $rows->each(function ($row) use ($users) {
                $user = $users->get($row->user_id);
                $row->account = (string)($user->account ?? '');
                $row->nickname = (string)($user->first_name ?? '');
            });
            return ['total' => $total, 'data' => $rows];
        });
    }

    public function saveBlacklist()
    {
        return $this->run(function () {
            $params = request()->validate([
                'id' => ['nullable', 'integer'],
                'account' => ['required_without:id', 'string', 'max:100'],
                'blocked_categories' => ['required', 'array', 'min:1'],
                'blocked_categories.*' => [Rule::in(['sports', 'lottery', 'third_party_game'])],
                'status' => ['nullable', Rule::in([0, 1])],
            ]);
            return DB::transaction(function () use ($params) {
                $id = (int)($params['id'] ?? 0);
                $model = $id ? ShareBlacklist::query()->lockForUpdate()->findOrFail($id) : new ShareBlacklist();
                $before = $model->exists ? $model->toArray() : [];
                if (!$id) {
                    $user = User::query()->where('account', $params['account'])->first();
                    if (!$user) throw new \RuntimeException('会员账号不存在');
                    $existing = ShareBlacklist::withTrashed()->where('user_id', $user->id)->lockForUpdate()->first();
                    if ($existing && !$existing->trashed()) throw new \RuntimeException('该会员已在禁止推广列表');
                    if ($existing) {
                        $model = $existing;
                        $model->restore();
                        $before = [];
                    } else {
                        $model->user_id = $user->id;
                        $model->member_id = (string)$user->member_id;
                    }
                }
                $model->blocked_categories = array_values(array_unique($params['blocked_categories']));
                $model->status = (int)($params['status'] ?? ($model->status ?? 1));
                $model->fill(OperationAuditService::actor())->save();
                OperationAuditService::record('share_blacklist', (int)$model->id, $id ? 'update' : 'create', $before, $model);
                return $model->fresh();
            });
        });
    }

    public function blacklistStatus()
    {
        return $this->run(function () {
            $params = request()->validate(['id' => ['required', 'integer'], 'status' => ['required', Rule::in([0, 1])]]);
            return DB::transaction(function () use ($params) {
                $model = ShareBlacklist::query()->lockForUpdate()->findOrFail($params['id']);
                $before = $model->toArray();
                $model->fill(['status' => $params['status']] + OperationAuditService::actor())->save();
                OperationAuditService::record('share_blacklist', (int)$model->id, 'status', $before, $model);
                return $model->fresh();
            });
        });
    }

    public function deleteBlacklist()
    {
        return $this->run(function () {
            $params = request()->validate(['id' => ['required', 'integer']]);
            return DB::transaction(function () use ($params) {
                $model = ShareBlacklist::query()->lockForUpdate()->findOrFail($params['id']);
                $before = $model->toArray();
                $model->delete();
                OperationAuditService::record('share_blacklist', (int)$model->id, 'delete', $before, []);
                return [];
            });
        });
    }

    private function dateListRules(array $extra = []): array
    {
        return [
            'page' => ['nullable', 'integer', 'min:1'],
            'limit' => ['nullable', 'integer', 'min:1', 'max:200'],
            'start_date' => ['nullable', 'date_format:Y-m-d'],
            'end_date' => ['nullable', 'date_format:Y-m-d', 'after_or_equal:start_date'],
        ] + $extra;
    }

    private function detailRules(): array
    {
        return [
            'date' => ['required', 'date_format:Y-m-d'],
            'page' => ['nullable', 'integer', 'min:1'],
            'limit' => ['nullable', 'integer', 'min:1', 'max:200'],
            'member_id' => ['nullable', 'string', 'max:64'],
            'account' => ['nullable', 'string', 'max:100'],
        ];
    }

    private function report(callable $callback, array $rules)
    {
        return $this->run(fn () => $callback(request()->validate($rules)));
    }

    private function run(callable $callback)
    {
        try {
            return $this->success($callback());
        } catch (ValidationException $e) {
            return $this->error(HttpStatus::CUSTOM_ERROR, $e->validator->errors()->first());
        } catch (QueryException $e) {
            Log::error('share_earning_database_error', ['exception' => $e]);
            return $this->error(HttpStatus::CUSTOM_ERROR, '分享服务暂不可用，请稍后重试');
        } catch (Throwable $e) {
            return $this->error(HttpStatus::CUSTOM_ERROR, $e->getMessage());
        }
    }
}