<?php

declare(strict_types=1);

namespace app\command;

use app\common\model\tcm\PrescriptionOrder;
use app\common\service\ExpressTrackingService;
use think\console\Command;
use think\console\Input;
use think\console\input\Option;
use think\console\Output;

/**
 * 批量回填处方业务订单「签收时间」到物流库（express_tracking / express_trace）。
 *
 * 背景：导出列表的「签收日期」来自库表（ExpressTrackingService::batchResolveSignUnixFromDbForOrders，无 HTTP）。
 * 终态订单（已完成3/已签收6）被 express:auto-update 排除、或从未创建过物流追踪记录时，库内就没有签收时间，
 * 导出便显示为空。本命令对这些订单逐单走一次快递100 并落库（queryAndUpdate 会写入 sign_time + 轨迹），
 * 之后导出直接读库即可，既快又不空。
 *
 * 使用方法：
 *   php think tcm:backfill-sign-time --dry-run
 *   php think tcm:backfill-sign-time --limit=300 --sleep-ms=200
 *   php think tcm:backfill-sign-time --fulfillment-status=3,5,6 --days=90
 *   php think tcm:backfill-sign-time --order-id=474
 *   php think tcm:backfill-sign-time --force          # 库内已有签收时间也重查
 *   php think tcm:backfill-sign-time --include-gancao  # 同时处理甘草托管单（默认跳过，由甘草侧拉取）
 *
 * 履约状态代码（fulfillment_status）：1待双审通过 2待发货 3已完成 4已取消 5已发货 6已签收
 *   7进行中 8暂不制药 9拒收 10退款 11保留药方 12制药缓发
 *
 * 建议配 crontab（如每小时一次，限量推进历史欠数据）：
 *   0 * * * * cd /path/to/server && php think tcm:backfill-sign-time --limit=300 >> /dev/null 2>&1
 */
class TcmBackfillPrescriptionOrderSignTime extends Command
{
    /**
     * 默认不按履约状态过滤：只要订单有运单号（tracking_number）即视为已发货，纳入回填。
     * 按 fulfillment_status 过滤会漏掉「物流已送达、但业务状态滞后（如进行中）」的单子。
     * 仍可用 --fulfillment-status 显式收窄。
     */
    private const DEFAULT_FULFILLMENT_STATUSES = [];

    protected function configure(): void
    {
        $this->setName('tcm:backfill-sign-time')
            ->setDescription('批量回填处方业务订单签收时间到物流库（导出读库即可，不再逐单 HTTP）')
            ->addOption('dry-run', null, Option::VALUE_NONE, '只列出待处理订单，不发起查询/不落库')
            ->addOption('limit', 'l', Option::VALUE_OPTIONAL, '本次最多补查（HTTP）订单数', 300)
            ->addOption('order-id', null, Option::VALUE_OPTIONAL, '仅处理指定 prescription_order.id', null)
            ->addOption('min-id', null, Option::VALUE_OPTIONAL, '仅 id>=该值', null)
            ->addOption('max-id', null, Option::VALUE_OPTIONAL, '仅 id<=该值', null)
            ->addOption('days', null, Option::VALUE_OPTIONAL, '仅处理近 N 天创建的订单（0=不限）', 0)
            ->addOption(
                'fulfillment-status',
                null,
                Option::VALUE_OPTIONAL,
                '仅处理指定履约状态，逗号分隔数字（如 3,5,6）；默认不限（有运单号即处理）',
                null
            )
            ->addOption('repair-db', null, Option::VALUE_NONE, '仅按库内轨迹重算并修复 sign_time 列（零 HTTP，修复历史「拉取当天」污染）')
            ->addOption('include-gancao', null, Option::VALUE_NONE, '同时处理甘草托管单（默认跳过）')
            ->addOption('force', 'f', Option::VALUE_NONE, '库内已有签收时间也重新查询落库')
            ->addOption('sleep-ms', null, Option::VALUE_OPTIONAL, '每次 HTTP 查询后休眠毫秒，减轻快递100 压力', 200)
            ->addOption('detail', 'd', Option::VALUE_NONE, '打印每条明细');
    }

    /**
     * @return int[]|null 解析失败（传了非法值）返回 null；未传返回默认集
     */
    private static function parseFulfillmentStatusOption(?string $raw): ?array
    {
        if ($raw === null || trim($raw) === '') {
            return self::DEFAULT_FULFILLMENT_STATUSES;
        }
        $seen = [];
        foreach (explode(',', $raw) as $part) {
            $n = (int) trim($part);
            if ($n >= 1 && $n <= 12) {
                $seen[$n] = true;
            }
        }
        $ids = array_keys($seen);
        sort($ids);

        return $ids !== [] ? $ids : null;
    }

    protected function execute(Input $input, Output $output): int
    {
        $dryRun        = (bool) $input->getOption('dry-run');
        $verbose       = (bool) $input->getOption('detail');
        $force         = (bool) $input->getOption('force');
        $includeGancao = (bool) $input->getOption('include-gancao');
        $limit         = max(1, (int) $input->getOption('limit'));
        $sleepMs       = max(0, (int) $input->getOption('sleep-ms'));
        $days          = max(0, (int) $input->getOption('days'));

        $onlyOrderId = $input->getOption('order-id');
        $onlyOrderId = $onlyOrderId !== null && $onlyOrderId !== '' ? (int) $onlyOrderId : null;
        $minId       = $input->getOption('min-id');
        $minId       = $minId !== null && $minId !== '' ? (int) $minId : null;
        $maxId       = $input->getOption('max-id');
        $maxId       = $maxId !== null && $maxId !== '' ? (int) $maxId : null;

        $fsRaw = $input->getOption('fulfillment-status');
        $fulfillmentStatuses = self::parseFulfillmentStatusOption($fsRaw !== null ? (string) $fsRaw : null);
        if ($fulfillmentStatuses === null) {
            $output->error('--fulfillment-status 格式无效，请传入 1–12 的数字，英文逗号分隔，例如：3,5,6');

            return 1;
        }

        $output->writeln('========================================');
        $output->writeln('批量回填业务订单签收时间（快递100 落库）');
        $output->writeln('========================================');

        // 纯库内修复模式：用现有轨迹重算签收时间，覆盖被写成「同步当天」的 sign_time 列（零 HTTP）
        if ((bool) $input->getOption('repair-db')) {
            $output->writeln('模式：仅修复 sign_time 列（按库内轨迹重算，不查快递100）...');
            $stat = ExpressTrackingService::repairSignTimeFromDbTraces($dryRun, $dryRun ? 0 : $limit);
            $output->writeln('');
            $output->writeln('========================================');
            $output->writeln(sprintf(
                '修复完成：扫描已签收运单 %d，修正 sign_time %d，无需修正 %d（dry-run=%s）',
                $stat['scanned'],
                $stat['updated'],
                $stat['skipped'],
                $dryRun ? 'yes' : 'no'
            ));
            $output->writeln('========================================');

            return 0;
        }

        $q = PrescriptionOrder::whereNull('delete_time')
            ->whereRaw("TRIM(COALESCE(`tracking_number`, '')) <> ''")
            ->order('id', 'desc');

        if ($onlyOrderId !== null && $onlyOrderId > 0) {
            $q->where('id', $onlyOrderId);
        } else {
            // 空集 = 不按履约状态过滤（默认）：有运单号即纳入，避免漏掉业务状态滞后的已送达单
            if ($fulfillmentStatuses !== []) {
                $q->whereIn('fulfillment_status', $fulfillmentStatuses);
            }
            if (!$includeGancao) {
                $q->whereRaw("TRIM(COALESCE(`gancao_reciperl_order_no`, '')) = ''");
            }
            if ($minId !== null && $minId > 0) {
                $q->where('id', '>=', $minId);
            }
            if ($maxId !== null && $maxId > 0) {
                $q->where('id', '<=', $maxId);
            }
            if ($days > 0) {
                $q->where('create_time', '>=', time() - $days * 86400);
            }
            // 多取一些候选，DB 已可解析的会被跳过，确保「需要补查」的能凑够 limit
            $q->limit($limit * 5);
        }

        $rows = $q->field(['id', 'order_no', 'tracking_number', 'fulfillment_status', 'create_time'])
            ->select()
            ->toArray();
        if ($rows === []) {
            $output->warning('没有符合条件的订单。');

            return 0;
        }

        // 先批量从库表解析，跳过已有签收时间的（除非 --force），避免无谓 HTTP
        $dbSignByPo = [];
        if (!$force) {
            $signItems = [];
            foreach ($rows as $r) {
                $signItems[] = [
                    'order_id'        => (int) ($r['id'] ?? 0),
                    'tracking_number' => trim((string) ($r['tracking_number'] ?? '')),
                ];
            }
            try {
                $dbSignByPo = ExpressTrackingService::batchResolveSignUnixFromDbForOrders($signItems);
            } catch (\Throwable $e) {
                $output->warning('批量库表解析失败，将逐单补查：' . $e->getMessage());
                $dbSignByPo = [];
            }
        }

        $candidates = [];
        $alreadyInDb = 0;
        foreach ($rows as $r) {
            $id = (int) ($r['id'] ?? 0);
            if ($id <= 0) {
                continue;
            }
            if (!$force && (int) ($dbSignByPo[$id] ?? 0) > 0) {
                $alreadyInDb++;
                continue;
            }
            $candidates[] = $r;
            if (count($candidates) >= $limit) {
                break;
            }
        }

        $output->writeln(sprintf(
            '候选 %d 条（库内已有签收 %d 条已跳过）；本次最多补查 %d 条（dry-run=%s force=%s sleep-ms=%d）',
            count($rows),
            $alreadyInDb,
            $limit,
            $dryRun ? 'yes' : 'no',
            $force ? 'yes' : 'no',
            $sleepMs
        ));

        if ($candidates === []) {
            $output->writeln('无需补查：候选订单签收时间均已在库。');

            return 0;
        }

        $resolved = 0;   // 查到并落库了签收时间
        $empty    = 0;   // 查询成功但暂无签收（在途等）
        $failed   = 0;

        $totalToDo = count($candidates);
        // 每单一次快递100 HTTP + sleep，串行较慢；定期打印进度，避免看起来卡住。
        $progressEvery = max(1, (int) min(20, max(5, (int) ceil($totalToDo / 20))));
        if (!$dryRun) {
            $output->writeln(sprintf(
                '开始逐单补查（共 %d 单，每单一次快递100 查询 + %dms 间隔，请耐心等待，每 %d 单报告一次进度）...',
                $totalToDo,
                $sleepMs,
                $progressEvery
            ));
        }
        $startTs = microtime(true);

        $done = 0;
        foreach ($candidates as $r) {
            $id = (int) ($r['id'] ?? 0);
            $tn = trim((string) ($r['tracking_number'] ?? ''));

            if ($dryRun) {
                if ($verbose) {
                    $output->writeln(sprintf('#%d %s 运单=%s （dry-run，跳过查询）', $id, (string) ($r['order_no'] ?? ''), $tn));
                }
                continue;
            }

            try {
                $signTs = ExpressTrackingService::syncSignUnixFromLogisticsForPrescriptionOrder($id, true);
                if ($signTs > 0) {
                    $resolved++;
                    if ($verbose) {
                        $output->writeln(sprintf('#%d 运单=%s → 签收 %s', $id, $tn, date('Y-m-d H:i:s', $signTs)));
                    }
                } else {
                    $empty++;
                    if ($verbose) {
                        $output->writeln(sprintf('#%d 运单=%s → 暂无签收（在途/未匹配）', $id, $tn));
                    }
                }
            } catch (\Throwable $e) {
                $failed++;
                if ($verbose) {
                    $output->writeln("<error>#{$id} 运单={$tn} 失败：{$e->getMessage()}</error>");
                }
            }

            $done++;
            // 非明细模式也给出心跳进度（明细模式已逐单打印，无需重复）
            if (!$verbose && ($done % $progressEvery === 0 || $done === $totalToDo)) {
                $elapsed = max(0.001, microtime(true) - $startTs);
                $rate = $done / $elapsed;
                $eta = $rate > 0 ? (int) round(($totalToDo - $done) / $rate) : 0;
                $output->writeln(sprintf(
                    '  进度 %d/%d（落库 %d，暂无 %d，失败 %d）已用 %ds，预计剩余 %ds',
                    $done,
                    $totalToDo,
                    $resolved,
                    $empty,
                    $failed,
                    (int) round($elapsed),
                    $eta
                ));
            }

            if ($sleepMs > 0) {
                usleep($sleepMs * 1000);
            }
        }

        $output->writeln('');
        $output->writeln('========================================');
        $output->writeln(sprintf('完成：落库签收 %d，暂无签收 %d，失败 %d', $resolved, $empty, $failed));
        $output->writeln('========================================');

        return $failed > 0 ? 2 : 0;
    }
}