<?php

namespace App\Http\Controllers\Admin;

use App\Http\Controllers\Concerns\ResolvesPlatformAdminContext;
use App\Http\Controllers\Controller;
use App\Models\PlatformOrder;
use App\Support\SubscriptionActivationService;
use Illuminate\Database\Eloquent\Builder;
use Illuminate\Http\RedirectResponse;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\DB;
use Illuminate\View\View;
use Symfony\Component\HttpFoundation\StreamedResponse;

class PlatformOrderController extends Controller
{
    use ResolvesPlatformAdminContext;

    public function index(Request $request): View
    {
        $this->ensurePlatformAdmin($request);

        $filters = [
            'status' => trim((string) $request->query('status', '')),
            'payment_status' => trim((string) $request->query('payment_status', '')),
            'merchant_id' => trim((string) $request->query('merchant_id', '')),
            'plan_id' => trim((string) $request->query('plan_id', '')),
            'fail_only' => (string) $request->query('fail_only', ''),
            'synced_only' => (string) $request->query('synced_only', ''),
            'sync_status' => trim((string) $request->query('sync_status', '')),
            'keyword' => trim((string) $request->query('keyword', '')),
            // 只看“可同步订阅”的订单：已支付 + 已生效 + 未同步（用于运营快速处理）
            'syncable_only' => (string) $request->query('syncable_only', ''),
            // 只看最近 24 小时批量同步过的订单（可治理追踪）
            'batch_synced_24h' => (string) $request->query('batch_synced_24h', ''),
        ];

        $orders = $this->applyFilters(PlatformOrder::query()->with(['merchant', 'plan', 'siteSubscription']), $filters)
            ->latest('id')
            ->paginate(10)
            ->withQueryString();

        $baseQuery = $this->applyFilters(PlatformOrder::query(), $filters);

        // 同步失败原因聚合（Top 5）：用于运营快速判断“常见失败原因”
        // 注意：这里用 JSON_EXTRACT 做 group by，MySQL 会返回带引号的 JSON 字符串，展示时做一次 trim 处理。
        $failedReasonRows = (clone $baseQuery)
            ->whereRaw("JSON_EXTRACT(meta, '$.subscription_activation_error.message') IS NOT NULL")
            ->selectRaw("JSON_EXTRACT(meta, '$.subscription_activation_error.message') as reason, count(*) as cnt")
            ->groupBy('reason')
            ->orderByDesc('cnt')
            ->limit(5)
            ->get();

        $failedReasonStats = $failedReasonRows->map(function ($row) {
            $reason = (string) ($row->reason ?? '');
            $reason = trim($reason, "\" ");

            return [
                'reason' => $reason !== '' ? $reason : '（空）',
                'count' => (int) ($row->cnt ?? 0),
            ];
        })->values()->all();

        return view('admin.platform_orders.index', [
            'orders' => $orders,
            'filters' => $filters,
            'filterOptions' => [
                'statuses' => $this->statusLabels(),
                'paymentStatuses' => $this->paymentStatusLabels(),
            ],
            'merchants' => PlatformOrder::query()->with('merchant')
                ->select('merchant_id')
                ->whereNotNull('merchant_id')
                ->distinct()
                ->get()
                ->pluck('merchant')
                ->filter()
                ->unique('id')
                ->values(),
            'plans' => PlatformOrder::query()->with('plan')
                ->select('plan_id')
                ->whereNotNull('plan_id')
                ->distinct()
                ->get()
                ->pluck('plan')
                ->filter()
                ->unique('id')
                ->values(),
            'statusLabels' => $this->statusLabels(),
            'paymentStatusLabels' => $this->paymentStatusLabels(),
            'summaryStats' => [
                'total_orders' => (clone $baseQuery)->count(),
                'paid_orders' => (clone $baseQuery)->where('payment_status', 'paid')->count(),
                'activated_orders' => (clone $baseQuery)->where('status', 'activated')->count(),
                'synced_orders' => (clone $baseQuery)
                    ->whereRaw("JSON_EXTRACT(meta, '$.subscription_activation.subscription_id') IS NOT NULL")
                    ->count(),
                'failed_sync_orders' => (clone $baseQuery)
                    ->whereRaw("JSON_EXTRACT(meta, '$.subscription_activation_error.message') IS NOT NULL")
                    ->count(),
                'unsynced_orders' => (clone $baseQuery)
                    ->whereRaw("JSON_EXTRACT(meta, '$.subscription_activation.subscription_id') IS NULL")
                    ->whereRaw("JSON_EXTRACT(meta, '$.subscription_activation_error.message') IS NULL")
                    ->count(),
                'total_payable_amount' => (float) ((clone $baseQuery)->sum('payable_amount') ?: 0),
                'total_paid_amount' => (float) ((clone $baseQuery)->sum('paid_amount') ?: 0),
                'syncable_orders' => (clone $baseQuery)
                    ->where('payment_status', 'paid')
                    ->where('status', 'activated')
                    ->whereRaw("JSON_EXTRACT(meta, '$.subscription_activation.subscription_id') IS NULL")
                    ->count(),
                'batch_synced_24h_orders' => (function () use ($baseQuery) {
                    $since = now()->subHours(24)->format('Y-m-d H:i:s');

                    $q = (clone $baseQuery)
                        ->whereRaw("JSON_EXTRACT(meta, '$.batch_activation.at') IS NOT NULL");

                    $driver = $q->getQuery()->getConnection()->getDriverName();
                    if ($driver === 'sqlite') {
                        $q->whereRaw("JSON_EXTRACT(meta, '$.batch_activation.at') >= ?", [$since]);
                    } else {
                        $q->whereRaw("JSON_UNQUOTE(JSON_EXTRACT(meta, '$.batch_activation.at')) >= ?", [$since]);
                    }

                    return $q->count();
                })(),
            ],
            'failedReasonStats' => $failedReasonStats,
        ]);
    }

    public function show(Request $request, PlatformOrder $order): View
    {
        $this->ensurePlatformAdmin($request);

        $order->loadMissing(['merchant', 'plan', 'siteSubscription']);

        return view('admin.platform_orders.show', [
            'order' => $order,
            'statusLabels' => $this->statusLabels(),
            'paymentStatusLabels' => $this->paymentStatusLabels(),
        ]);
    }

    public function activateSubscription(Request $request, PlatformOrder $order, SubscriptionActivationService $service): RedirectResponse
    {
        $admin = $this->ensurePlatformAdmin($request);

        try {
            $subscription = $service->activateOrder($order->id, $admin->id);

            // 同步成功：清理失败记录（若存在）
            $meta = (array) ($order->meta ?? []);
            data_forget($meta, 'subscription_activation_error');
            $order->meta = $meta;
            $order->save();
        } catch (\Throwable $e) {
            // 同步失败：写入错误信息，便于运营排查（可治理）
            $meta = (array) ($order->meta ?? []);
            data_set($meta, 'subscription_activation_error', [
                'message' => $e->getMessage(),
                'at' => now()->toDateTimeString(),
                'admin_id' => $admin->id,
            ]);
            $order->meta = $meta;
            $order->save();

            return redirect()->back()->with('error', '订阅同步失败：' . $e->getMessage());
        }

        return redirect()->back()->with('success', '订阅已同步：' . $subscription->subscription_no);
    }

    public function markPaidAndActivate(Request $request, PlatformOrder $order, SubscriptionActivationService $service): RedirectResponse
    {
        $admin = $this->ensurePlatformAdmin($request);

        // 最小状态推进：将订单标记为已支付 + 已生效，并补齐时间与金额字段
        $now = now();
        $order->payment_status = 'paid';
        $order->status = 'activated';
        $order->paid_at = $order->paid_at ?: $now;
        $order->activated_at = $order->activated_at ?: $now;
        $order->paid_amount = $order->paid_amount > 0 ? $order->paid_amount : $order->payable_amount;
        $order->save();

        // 立刻同步订阅
        try {
            $subscription = $service->activateOrder($order->id, $admin->id);

            $meta = (array) ($order->meta ?? []);
            data_forget($meta, 'subscription_activation_error');
            $order->meta = $meta;
            $order->save();
        } catch (\Throwable $e) {
            $meta = (array) ($order->meta ?? []);
            data_set($meta, 'subscription_activation_error', [
                'message' => $e->getMessage(),
                'at' => now()->toDateTimeString(),
                'admin_id' => $admin->id,
            ]);
            $order->meta = $meta;
            $order->save();

            return redirect()->back()->with('error', '订单已标记为已支付/已生效，但订阅同步失败：' . $e->getMessage());
        }

        return redirect()->back()->with('success', '订单已标记支付并生效，订阅已同步：' . $subscription->subscription_no);
    }

    public function export(Request $request): StreamedResponse
    {
        $this->ensurePlatformAdmin($request);

        $filters = [
            'status' => trim((string) $request->query('status', '')),
            'payment_status' => trim((string) $request->query('payment_status', '')),
            'merchant_id' => trim((string) $request->query('merchant_id', '')),
            'plan_id' => trim((string) $request->query('plan_id', '')),
            'fail_only' => (string) $request->query('fail_only', ''),
            'synced_only' => (string) $request->query('synced_only', ''),
            'sync_status' => trim((string) $request->query('sync_status', '')),
            'keyword' => trim((string) $request->query('keyword', '')),
            // 只看“可同步订阅”的订单：已支付 + 已生效 + 未同步（用于运营快速处理）
            'syncable_only' => (string) $request->query('syncable_only', ''),
            // 只看最近 24 小时批量同步过的订单（可治理追踪）
            'batch_synced_24h' => (string) $request->query('batch_synced_24h', ''),
        ];

        $includeMeta = (string) $request->query('include_meta', '') === '1';

        $query = $this->applyFilters(
            PlatformOrder::query()->with(['merchant', 'plan', 'siteSubscription']),
            $filters
        )->orderBy('id');

        $filename = 'platform_orders_' . now()->format('Ymd_His') . '.csv';

        return response()->streamDownload(function () use ($query, $includeMeta) {
            $out = fopen('php://output', 'w');

            // UTF-8 BOM，避免 Excel 打开中文乱码
            fwrite($out, "\xEF\xBB\xBF");

            $headers = [
                'ID',
                '订单号',
                '站点',
                '套餐',
                '订单类型',
                '订单状态',
                '支付状态',
                '应付金额',
                '已付金额',
                '下单时间',
                '支付时间',
                '生效时间',
                '同步状态',
                '订阅号',
                '订阅到期',
                '同步时间',
                '同步失败原因',
                '同步失败时间',
            ];

            if ($includeMeta) {
                $headers[] = '原始meta(JSON)';
            }

            fputcsv($out, $headers);

            $query->chunkById(500, function ($orders) use ($out, $includeMeta) {
                foreach ($orders as $order) {
                    $syncedId = (int) data_get($order->meta, 'subscription_activation.subscription_id', 0);
                    $syncErr = (string) (data_get($order->meta, 'subscription_activation_error.message') ?? '');

                    if ($syncedId > 0) {
                        $syncStatus = '已同步';
                    } elseif ($syncErr !== '') {
                        $syncStatus = '同步失败';
                    } else {
                        $syncStatus = '未同步';
                    }

                    $row = [
                        $order->id,
                        $order->order_no,
                        $order->merchant?->name ?? '',
                        $order->plan_name ?: ($order->plan?->name ?? ''),
                        $order->order_type,
                        $order->status,
                        $order->payment_status,
                        (float) $order->payable_amount,
                        (float) $order->paid_amount,
                        optional($order->placed_at)->format('Y-m-d H:i:s') ?: '',
                        optional($order->paid_at)->format('Y-m-d H:i:s') ?: '',
                        optional($order->activated_at)->format('Y-m-d H:i:s') ?: '',
                        $syncStatus,
                        $order->siteSubscription?->subscription_no ?: '',
                        optional($order->siteSubscription?->ends_at)->format('Y-m-d H:i:s') ?: '',
                        (string) (data_get($order->meta, 'subscription_activation.synced_at') ?? ''),
                        $syncErr,
                        (string) (data_get($order->meta, 'subscription_activation_error.at') ?? ''),
                    ];

                    if ($includeMeta) {
                        $row[] = json_encode($order->meta, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES);
                    }

                    fputcsv($out, $row);
                }
            });

            fclose($out);
        }, $filename, [
            'Content-Type' => 'text/csv; charset=UTF-8',
        ]);
    }

    public function batchActivateSubscriptions(Request $request, SubscriptionActivationService $service): RedirectResponse
    {
        $admin = $this->ensurePlatformAdmin($request);

        // 支持两种 scope：
        // - scope=filtered：只处理当前筛选范围内的订单（更安全，默认）
        // - scope=all：处理全部订单（谨慎）
        $scope = (string) $request->input('scope', 'filtered');

        $filters = [
            'status' => trim((string) $request->input('status', '')),
            'payment_status' => trim((string) $request->input('payment_status', '')),
            'merchant_id' => trim((string) $request->input('merchant_id', '')),
            'plan_id' => trim((string) $request->input('plan_id', '')),
            'fail_only' => (string) $request->input('fail_only', ''),
            'synced_only' => (string) $request->input('synced_only', ''),
            'sync_status' => trim((string) $request->input('sync_status', '')),
            'keyword' => trim((string) $request->input('keyword', '')),
            'syncable_only' => (string) $request->input('syncable_only', ''),
            'batch_synced_24h' => (string) $request->input('batch_synced_24h', ''),
        ];

        // 防误操作：批量同步默认要求先勾选“只看可同步”，避免无意识扩大处理范围
        if ($scope === 'filtered' && ($filters['syncable_only'] ?? '') !== '1') {
            return redirect()->back()->with('warning', '为避免误操作，请先在筛选条件中勾选「只看可同步」，再执行批量同步订阅。');
        }

        // 防误操作：scope=all 需要二次确认
        if ($scope === 'all' && (string) $request->input('confirm', '') !== 'YES') {
            return redirect()->back()->with('warning', '为避免误操作，执行全量批量同步前请在确认框输入 YES。');
        }

        $query = PlatformOrder::query();

        if ($scope === 'filtered') {
            $query = $this->applyFilters($query, $filters);
        }

        // 只处理“可同步”的订单（双保险，避免误操作）
        $query = $query
            ->where('payment_status', 'paid')
            ->where('status', 'activated')
            ->whereRaw("JSON_EXTRACT(meta, '$.subscription_activation.subscription_id') IS NULL");

        $limit = (int) $request->input('limit', 50);
        $limit = max(1, min(500, $limit));

        $matchedTotal = (clone $query)->count();

        // 默认按最新订单优先处理：避免 seed/demo 数据干扰测试，同时也更符合“先处理新问题”的运营直觉
        $orders = $query->orderByDesc('id')->limit($limit)->get(['id']);
        $processed = $orders->count();

        $success = 0;
        $failed = 0;
        $failedReasonCounts = [];

        foreach ($orders as $orderRow) {
            try {
                $service->activateOrder($orderRow->id, $admin->id);

                // 轻量审计：记录批量同步动作（方便追溯）
                $order = PlatformOrder::query()->find($orderRow->id);
                if ($order) {
                    $meta = (array) ($order->meta ?? []);
                    $audit = (array) (data_get($meta, 'audit', []) ?? []);
                    $nowStr = now()->toDateTimeString();
                    $audit[] = [
                        'action' => 'batch_activate_subscription',
                        'scope' => $scope,
                        'at' => $nowStr,
                        'admin_id' => $admin->id,
                    ];
                    data_set($meta, 'audit', $audit);

                    // 便于筛选/统计：记录最近一次批量同步信息（扁平字段）
                    data_set($meta, 'batch_activation', [
                        'at' => $nowStr,
                        'admin_id' => $admin->id,
                        'scope' => $scope,
                    ]);

                    $order->meta = $meta;
                    $order->save();
                }

                $success++;
            } catch (\Throwable $e) {
                $failed++;

                $reason = trim((string) $e->getMessage());
                $reason = $reason !== '' ? $reason : '未知错误';
                $failedReasonCounts[$reason] = ($failedReasonCounts[$reason] ?? 0) + 1;

                // 批量同步失败也需要可治理：写入失败原因到订单 meta，便于后续筛选/导出/清理
                $order = PlatformOrder::query()->find($orderRow->id);
                if ($order) {
                    $meta = (array) ($order->meta ?? []);
                    data_set($meta, 'subscription_activation_error', [
                        'message' => $reason,
                        'at' => now()->toDateTimeString(),
                        'admin_id' => $admin->id,
                    ]);
                    $order->meta = $meta;
                    $order->save();
                }
            }
        }

        $msg = '批量同步订阅完成：成功 ' . $success . ' 条，失败 ' . $failed . ' 条（命中 ' . $matchedTotal . ' 条，本次处理 ' . $processed . ' 条，limit=' . $limit . '）';

        if ($failed > 0 && count($failedReasonCounts) > 0) {
            arsort($failedReasonCounts);
            $top = array_slice($failedReasonCounts, 0, 3, true);
            $topText = collect($top)->map(function ($cnt, $reason) {
                $reason = mb_substr((string) $reason, 0, 60);
                return $reason . '（' . $cnt . '）';
            })->implode('；');

            $msg .= '；失败原因Top：' . $topText;
        }

        return redirect()->back()->with('success', $msg);
    }

    public function clearSyncErrors(Request $request): RedirectResponse
    { 
        $this->ensurePlatformAdmin($request);

        // 支持两种模式：
        // - scope=all（默认）：清理所有订单的失败标记
        // - scope=filtered：仅清理当前筛选结果命中的订单（更安全）
        $scope = (string) $request->input('scope', 'all');

        $filters = [
            'status' => trim((string) $request->input('status', '')),
            'payment_status' => trim((string) $request->input('payment_status', '')),
            'merchant_id' => trim((string) $request->input('merchant_id', '')),
            'plan_id' => trim((string) $request->input('plan_id', '')),
            'fail_only' => (string) $request->input('fail_only', ''),
            'synced_only' => (string) $request->input('synced_only', ''),
            'sync_status' => trim((string) $request->input('sync_status', '')),
            'keyword' => trim((string) $request->input('keyword', '')),
            'syncable_only' => (string) $request->input('syncable_only', ''),
            'batch_synced_24h' => (string) $request->input('batch_synced_24h', ''),
        ];

        $query = PlatformOrder::query()
            ->whereRaw("JSON_EXTRACT(meta, '$.subscription_activation_error.message') IS NOT NULL");

        if ($scope === 'filtered') {
            $query = $this->applyFilters($query, $filters);
        }

        $orders = $query->get(['id', 'meta']);
        $matched = $orders->count();

        $cleared = 0;
        foreach ($orders as $order) {
            $meta = (array) ($order->meta ?? []);
            if (! data_get($meta, 'subscription_activation_error')) {
                continue;
            }

            data_forget($meta, 'subscription_activation_error');

            // 轻量审计：记录清理动作（不做独立表，先落 meta，便于排查）
            $audit = (array) (data_get($meta, 'audit', []) ?? []);
            $audit[] = [
                'action' => 'clear_sync_error',
                'scope' => $scope,
                'at' => now()->toDateTimeString(),
                'admin_id' => $this->platformAdminId($request),
            ];
            data_set($meta, 'audit', $audit);

            $order->meta = $meta;
            $order->save();
            $cleared++;
        }

        $msg = $scope === 'filtered'
            ? '已清除当前筛选范围内的同步失败标记：'
            : '已清除全部订单的同步失败标记：';

        return redirect()->back()->with('success', $msg . $cleared . ' 条（命中 ' . $matched . ' 条）');
    }

    protected function applyFilters(Builder $query, array $filters): Builder
    {
        return $query
            ->when($filters['status'] !== '', fn (Builder $builder) => $builder->where('status', $filters['status']))
            ->when($filters['payment_status'] !== '', fn (Builder $builder) => $builder->where('payment_status', $filters['payment_status']))
            ->when(($filters['merchant_id'] ?? '') !== '', fn (Builder $builder) => $builder->where('merchant_id', (int) $filters['merchant_id']))
            ->when(($filters['plan_id'] ?? '') !== '', fn (Builder $builder) => $builder->where('plan_id', (int) $filters['plan_id']))
            ->when(($filters['fail_only'] ?? '') !== '', function (Builder $builder) {
                // 只看同步失败：meta.subscription_activation_error.message 存在即视为失败
                $builder->whereRaw("JSON_EXTRACT(meta, '$.subscription_activation_error.message') IS NOT NULL");
            })
            ->when(($filters['synced_only'] ?? '') !== '', function (Builder $builder) {
                // 只看已同步：meta.subscription_activation.subscription_id 存在即视为已同步
                $builder->whereRaw("JSON_EXTRACT(meta, '$.subscription_activation.subscription_id') IS NOT NULL");
            })
            ->when(($filters['sync_status'] ?? '') !== '', function (Builder $builder) use ($filters) {
                // 同步状态筛选：unsynced / synced / failed
                if (($filters['sync_status'] ?? '') === 'synced') {
                    $builder->whereRaw("JSON_EXTRACT(meta, '$.subscription_activation.subscription_id') IS NOT NULL")
                        ->whereRaw("JSON_EXTRACT(meta, '$.subscription_activation_error.message') IS NULL");
                } elseif (($filters['sync_status'] ?? '') === 'failed') {
                    $builder->whereRaw("JSON_EXTRACT(meta, '$.subscription_activation_error.message') IS NOT NULL");
                } elseif (($filters['sync_status'] ?? '') === 'unsynced') {
                    $builder->whereRaw("JSON_EXTRACT(meta, '$.subscription_activation.subscription_id') IS NULL")
                        ->whereRaw("JSON_EXTRACT(meta, '$.subscription_activation_error.message') IS NULL");
                }
            })
            ->when(($filters['keyword'] ?? '') !== '', function (Builder $builder) use ($filters) {
                // 关键词搜索：订单号 / 站点名称 / 订阅号
                $kw = trim((string) ($filters['keyword'] ?? ''));
                if ($kw === '') {
                    return;
                }

                $builder->where(function (Builder $q) use ($kw) {
                    $q->where('order_no', 'like', '%' . $kw . '%')
                        ->orWhere('order_type', 'like', '%' . $kw . '%')
                        ->orWhere('plan_name', 'like', '%' . $kw . '%')
                        ->orWhereHas('merchant', function (Builder $mq) use ($kw) {
                            $mq->where('name', 'like', '%' . $kw . '%')
                                ->orWhere('slug', 'like', '%' . $kw . '%');
                        })
                        ->orWhereHas('siteSubscription', function (Builder $sq) use ($kw) {
                            $sq->where('subscription_no', 'like', '%' . $kw . '%');
                        });

                    if (ctype_digit($kw)) {
                        $q->orWhere('id', (int) $kw);
                    }
                });
            })
            ->when(($filters['syncable_only'] ?? '') !== '', function (Builder $builder) {
                // 只看可同步：已支付 + 已生效 + 尚未写入 subscription_activation.subscription_id
                $builder->where('payment_status', 'paid')
                    ->where('status', 'activated')
                    ->whereRaw("JSON_EXTRACT(meta, '$.subscription_activation.subscription_id') IS NULL");
            })
            ->when(($filters['batch_synced_24h'] ?? '') !== '', function (Builder $builder) {
                // 只看最近 24 小时批量同步过的订单（基于 meta.batch_activation.at）
                $since = now()->subHours(24)->format('Y-m-d H:i:s');

                $builder->whereRaw("JSON_EXTRACT(meta, '$.batch_activation.at') IS NOT NULL");

                // sqlite 测试库没有 JSON_UNQUOTE()，需要做兼容
                $driver = $builder->getQuery()->getConnection()->getDriverName();
                if ($driver === 'sqlite') {
                    $builder->whereRaw("JSON_EXTRACT(meta, '$.batch_activation.at') >= ?", [$since]);
                } else {
                    $builder->whereRaw("JSON_UNQUOTE(JSON_EXTRACT(meta, '$.batch_activation.at')) >= ?", [$since]);
                }
            });
    }

    protected function statusLabels(): array
    {
        return [
            'pending' => '待处理',
            'paid' => '已支付',
            'activated' => '已生效',
            'cancelled' => '已取消',
            'refunded' => '已退款',
        ];
    }

    protected function paymentStatusLabels(): array
    {
        return [
            'unpaid' => '未支付',
            'paid' => '已支付',
            'partially_refunded' => '部分退款',
            'refunded' => '已退款',
            'failed' => '支付失败',
        ];
    }
}