huahuibao/console/controllers/ClearController.php

<?php

namespace console\controllers;

use bizGhs\clear\classes\OrderCgClearClass;
use bizGhs\clear\models\Clear;
use bizGhs\order\classes\OrderClearClass;
use bizGhs\order\classes\OrderClass;
use bizHd\purchase\classes\PurchaseClass;
use bizHd\purchase\classes\PurchaseClearClass;
use common\components\dict;
use Yii;
use yii\console\Controller;
use yii\console\ExitCode;

class ClearController extends Controller
{

    /** @var int 是否仅预览，1=是 */
    public $dryRun = 0;

    /** @var int 每批扫描 xhClear 条数（宜小，减轻锁与内存） */
    public $batchSize = 50;

    /** @var int 每批之间休眠毫秒数，降低对线上库压力 */
    public $sleepMs = 100;

    /** @var int 指定结账单 ID，0=全部 */
    public $clearId = 0;

    /** @var int 是否重置进度从最大 id 重跑，1=是 */
    public $reset = 0;

    /** @var int 本次最多处理 xhClear 条数，0=不限制 */
    public $limit = 0;

    /** @var int 每处理多少条输出一次进度，0=仅每批汇总 */
    public $logEvery = 500;

    /** @var int 每种 clearStyle 抽样条数（check-order-cg-clear-sample 默认 5000） */
    public $samplePerStyle = 5000;

    /** @var int 抽样检查最多打印的问题明细条数 */
    public $showIssues = 30;

    /** @var string 回填进度文件后缀（内部使用） */
    private $backfillProgressKey = '';

    public function options($actionID)
    {
        $options = array_merge(parent::options($actionID), [
            'dryRun',
            'batchSize',
            'sleepMs',
            'clearId',
            'reset',
            'limit',
            'logEvery',
        ]);
        if ($actionID === 'check-order-cg-clear-sample') {
            $options[] = 'samplePerStyle';
            $options[] = 'showIssues';
        }
        return $options;
    }

    //更新 ssh 2023503
    public function actionUpdate()
    {
        ini_set('memory_limit', '2045M');
        set_time_limit(0);
        $list = OrderClearClass::getAllByCondition(['status' => 2], null, '*', null, true);
        if (!empty($list)) {
            foreach ($list as $clear) {
                $payTime = $clear->payTime ?? '';
                $saleIds = $clear->saleIds ?? '';
                $ids = explode(',', trim($saleIds));
                print_r($ids);
                if (!empty($ids)) {
                    OrderClass::updateByIds($ids, ['clearTime' => $payTime]);
                }
                $purchaseIds = $clear->purchaseIds ?? '';
                $purchaseIds = explode(',', $purchaseIds);
                print_r($purchaseIds);
                if (!empty($purchaseIds)) {
                    PurchaseClass::updateByIds($purchaseIds, ['clearTime' => $payTime]);
                }
                echo "-----------------\n";
            }
        }

    }

    /**
     * 抽样检查 xhOrderCgClear：clearStyle 1/2/3 各抽 N 条（默认 5000），检查是否有漏补问题
     *
     * 用法:
     *   php yii clear/check-order-cg-clear-sample
     *   php yii clear/check-order-cg-clear-sample --samplePerStyle=5000
     *   php yii clear/check-order-cg-clear-sample --dryRun=0   # 发现问题顺带漏补
     */
    public function actionCheckOrderCgClearSample()
    {
        if (!$this->isCliOptionPassed('dryRun')) {
            $this->dryRun = 1;
        }
        return $this->runSampleCheckOrderCgClear();
    }

    /**
     * 补写 xhOrderCgClear 中 amount=0 的行（取关联订单/采购单 actPrice）
     *
     * 用法:
     *   php yii clear/patch-order-cg-clear-amount --dryRun=1 --limit=1000
     *   php yii clear/patch-order-cg-clear-amount --reset=1 --batchSize=100 --sleepMs=200
     */
    public function actionPatchOrderCgClearAmount()
    {
        ini_set('memory_limit', '512M');
        set_time_limit(0);

        if ($this->batchSize < 1) {
            $this->stderr("batchSize 必须大于 0\n");
            return ExitCode::UNSPECIFIED_ERROR;
        }

        $this->backfillProgressKey = 'amount';
        $pending = OrderCgClearClass::countZeroAmountRelationRows();

        if ($this->reset) {
            $this->clearBackfillProgress();
            $this->stdout("已重置补 amount 进度\n");
        }

        $cursorId = $this->loadBackfillProgress();
        $total = 0;
        $updated = 0;
        $skipped = 0;
        $batchNo = 0;

        $this->stdout(sprintf(
            "补写 amount | 待处理约 %d 行 | dryRun=%d batchSize=%d sleepMs=%d limit=%d | 续跑 id<%s | 进度=%s\n",
            $pending,
            (int)$this->dryRun,
            $this->batchSize,
            $this->sleepMs,
            (int)$this->limit,
            $cursorId === null ? 'max' : (string)$cursorId,
            $this->getBackfillProgressFile()
        ));

        while (true) {
            if ($this->limit > 0 && $total >= $this->limit) {
                break;
            }
            $fetchLimit = $this->batchSize;
            if ($this->limit > 0) {
                $fetchLimit = min($fetchLimit, $this->limit - $total);
                if ($fetchLimit < 1) {
                    break;
                }
            }

            $rows = OrderCgClearClass::fetchZeroAmountRelationBatch($cursorId, $fetchLimit);
            if (empty($rows)) {
                break;
            }
            $batchNo++;
            $batchMinId = null;

            $result = OrderCgClearClass::patchZeroAmountRows($rows, (bool)$this->dryRun);
            $batchUpdated = intval($result['updated'] ?? 0);
            $batchSkipped = intval($result['skipped'] ?? 0);
            $updated += $batchUpdated;
            $skipped += $batchSkipped;
            $total += count($rows);

            foreach ($rows as $row) {
                $batchMinId = intval($row['id']);
                $cursorId = $batchMinId;
            }

            if (!$this->dryRun && $batchMinId !== null) {
                $this->saveBackfillProgress($batchMinId);
            }

            $this->stdout(sprintf(
                "第 %d 批：扫描 %d 行，补写 %d，跳过 %d，checkpoint id=%d\n",
                $batchNo,
                count($rows),
                $batchUpdated,
                $batchSkipped,
                (int)$batchMinId
            ));

            if (count($rows) < $fetchLimit) {
                break;
            }
            $this->sleepBetweenBatch();
        }

        if (!$this->dryRun && $cursorId !== null) {
            $this->stdout("进度已保存，下次从 id < {$cursorId} 继续\n");
        }
        $remaining = OrderCgClearClass::countZeroAmountRelationRows();
        $this->stdout(sprintf(
            "完成：处理 %d 行，补写 %d，跳过 %d，剩余 amount=0 约 %d 行\n",
            $total,
            $updated,
            $skipped,
            $remaining
        ));
        return ExitCode::OK;
    }

    /**
     * 漏补 xhOrderCgClear：clearStyle 1(hd2Gys) + 2(gys2Hd) + 3(gys2KmGys) 统一扫描
     *
     * 仅处理：无关系行 / 关系行不足 / amount 为空 / gys2KmGys 旧格式；已完整则跳过。
     *
     * 用法:
     *   php yii clear/backfill-order-cg-clear --dryRun=1 --limit=1000
     *   php yii clear/backfill-order-cg-clear --reset=1 --batchSize=50 --sleepMs=200
     *   php yii clear/backfill-order-cg-clear --clearId=123
     */
    public function actionBackfillOrderCgClear()
    {
        return $this->runBackfillOrderCgClear(
            OrderCgClearClass::getRelationClearStyles(),
            'all',
            'hd2Gys(1)+gys2Hd(2)+gys2KmGys(3)',
            true
        );
    }

    /**
     * @deprecated 请改用 backfill-order-cg-clear（已合并 1+2+3）
     */
    public function actionBackfillOrderCgClearHdGys()
    {
        $this->stderr("已合并至: php yii clear/backfill-order-cg-clear\n");
        return $this->runBackfillOrderCgClear(
            [
                intval(dict::getDict('clearStyle', 'hd2Gys')),
                intval(dict::getDict('clearStyle', 'gys2Hd')),
            ],
            'hd_gys',
            'hd2Gys(1)+gys2Hd(2)',
            false
        );
    }

    /**
     * @deprecated 请改用 backfill-order-cg-clear（已合并 1+2+3）
     */
    public function actionBackfillOrderCgClearKmGys()
    {
        $this->stderr("已合并至: php yii clear/backfill-order-cg-clear\n");
        return $this->runBackfillOrderCgClear(
            [intval(dict::getDict('clearStyle', 'gys2KmGys'))],
            'km_gys',
            'gys2KmGys(3)',
            true
        );
    }

    /**
     * 迁移 gys2KmGys 关系行：orderId/cgId 旧格式 -> cgId 存 xhGhsCgOrder、orderId=0
     *
     * 用法:
     *   php yii clear/migrate-gys2-km-gys-order-cg-clear --dryRun=1
     *   php yii clear/migrate-gys2-km-gys-order-cg-clear
     *
     * 注意：若仍存在唯一索引 order_id_clear_id(clearId,orderId)，请先执行 rebuild-order-cg-clear-index
     */
    public function actionMigrateGys2KmGysOrderCgClear()
    {
        set_time_limit(0);
        $this->stdout("迁移 gys2KmGys 关系行 | dryRun={$this->dryRun} batchSize={$this->batchSize}\n");
        $count = OrderCgClearClass::migrateLegacyGys2KmGysRows((bool)$this->dryRun, $this->batchSize, $this->sleepMs);
        $this->stdout(($this->dryRun ? '预览' : '完成') . "：处理 {$count} 行\n");
        return ExitCode::OK;
    }

    /**
     * 重建 xhOrderCgClear 唯一索引为 (clearId, cgId, orderId)
     *
     * 用法:
     *   php yii clear/rebuild-order-cg-clear-index --dryRun=1
     *   php yii clear/rebuild-order-cg-clear-index
     */
    public function actionRebuildOrderCgClearIndex()
    {
        set_time_limit(0);
        if ($this->dryRun) {
            $info = OrderCgClearClass::rebuildRelationUniqueIndex(true);
            $this->stdout(sprintf(
                "预览：旧索引=%s 新索引=%s 待迁移旧格式行=%d\n",
                !empty($info['hasLegacyIndex']) ? '有' : '无',
                !empty($info['hasNewIndex']) ? '有' : '无',
                (int)($info['legacyRows'] ?? 0)
            ));
            return ExitCode::OK;
        }
        $this->stdout("开始重建唯一索引 uk_clear_cg_order(clearId,cgId,orderId)\n");
        $result = OrderCgClearClass::rebuildRelationUniqueIndex(false);
        $this->stdout(sprintf(
            "完成：删旧索引=%s 建新索引=%s 迁移旧格式行=%d\n",
            !empty($result['droppedLegacyIndex']) ? '是' : '否',
            !empty($result['addedNewIndex']) ? '是' : '否',
            (int)($result['migratedLegacyRows'] ?? 0)
        ));
        return ExitCode::OK;
    }

    /**
     * clearStyle 1/2/3 各抽样 samplePerStyle 条，检查关系表是否有漏补问题
     */
    private function runSampleCheckOrderCgClear()
    {
        ini_set('memory_limit', '512M');
        set_time_limit(0);

        $sampleSize = intval($this->samplePerStyle);
        if ($sampleSize < 1) {
            $this->stderr("samplePerStyle 必须大于 0\n");
            return ExitCode::UNSPECIFIED_ERROR;
        }

        $styleLabels = [
            intval(dict::getDict('clearStyle', 'hd2Gys')) => 'hd2Gys(1)',
            intval(dict::getDict('clearStyle', 'gys2Hd')) => 'gys2Hd(2)',
            intval(dict::getDict('clearStyle', 'gys2KmGys')) => 'gys2KmGys(3)',
        ];

        $this->stdout(sprintf(
            "抽样检查 xhOrderCgClear | 各 clearStyle 抽 %d 条(id DESC) | dryRun=%d | 最多展示 %d 条问题明细\n",
            $sampleSize,
            (int)$this->dryRun,
            (int)$this->showIssues
        ));

        $totalSampled = 0;
        $totalIssues = 0;
        $totalFixed = 0;
        $allIssues = [];
        $reasonStats = [];

        foreach ($styleLabels as $clearStyle => $label) {
            $list = $this->fetchClearSampleByStyle($clearStyle, $sampleSize);
            $sampled = count($list);
            $totalSampled += $sampled;

            if ($sampled === 0) {
                $this->stdout("{$label}：无数据\n");
                continue;
            }

            $clearIds = array_map('intval', array_column($list, 'id'));
            $emptyAmountClearIds = OrderCgClearClass::getClearIdsWithEmptyAmount($clearIds);
            $legacyGys2KmGysClearIds = OrderCgClearClass::getClearIdsWithLegacyGys2KmGysRows($clearIds);
            $relationCountMap = OrderCgClearClass::getRelationCountMap($clearIds);

            $styleIssues = 0;
            $styleFixed = 0;

            foreach ($list as $clear) {
                $currentClearId = intval($clear['id'] ?? 0);
                $relationCount = $relationCountMap[$currentClearId] ?? 0;
                $issue = OrderCgClearClass::detectBackfillIssue(
                    $clear,
                    $relationCount,
                    $emptyAmountClearIds,
                    $legacyGys2KmGysClearIds
                );
                if ($issue === null) {
                    continue;
                }

                $styleIssues++;
                $totalIssues++;
                $reason = $issue['reason'];
                $reasonStats[$reason] = ($reasonStats[$reason] ?? 0) + 1;

                $allIssues[] = [
                    'clearId' => $currentClearId,
                    'clearStyle' => $clearStyle,
                    'label' => $label,
                    'reason' => $reason,
                    'relationCount' => $issue['relationCount'],
                    'expected' => $issue['expected'],
                ];

                if (!$this->dryRun) {
                    $count = OrderCgClearClass::backfillFromClear($clear, true);
                    if ($count > 0) {
                        $styleFixed++;
                        $totalFixed += $count;
                    }
                }
            }

            $this->stdout(sprintf(
                "%s：抽样 %d 条，问题 %d 条%s\n",
                $label,
                $sampled,
                $styleIssues,
                !$this->dryRun ? "，已写入关系 {$styleFixed} 行" : ''
            ));
        }

        if (!empty($reasonStats)) {
            $this->stdout("问题类型汇总：\n");
            foreach ($reasonStats as $reason => $cnt) {
                $this->stdout("  {$reason}：{$cnt}\n");
            }
        }

        $showLimit = max(0, intval($this->showIssues));
        if ($showLimit > 0 && !empty($allIssues)) {
            $this->stdout("问题明细（前 {$showLimit} 条）：\n");
            foreach (array_slice($allIssues, 0, $showLimit) as $item) {
                $this->stdout(sprintf(
                    "  clearId=%d %s %s 已有=%d 应有≈%d\n",
                    $item['clearId'],
                    $item['label'],
                    $item['reason'],
                    $item['relationCount'],
                    $item['expected']
                ));
            }
            if (count($allIssues) > $showLimit) {
                $this->stdout('  ... 还有 ' . (count($allIssues) - $showLimit) . " 条未展示\n");
            }
        }

        $this->stdout(sprintf(
            "检查完成：共抽样 %d 条，发现问题结账单 %d 个%s\n",
            $totalSampled,
            $totalIssues,
            $totalIssues === 0 ? '，未发现漏补' : ''
        ));
        if (!$this->dryRun && $totalFixed > 0) {
            $this->stdout("已漏补写入关系 {$totalFixed} 行\n");
        }
        if ($this->dryRun && $totalIssues > 0) {
            $this->stdout("请加 --dryRun=0 执行漏补，或运行 backfill-order-cg-clear --reset=1 全量漏补\n");
        }

        return $totalIssues > 0 ? ExitCode::UNSPECIFIED_ERROR : ExitCode::OK;
    }

    private function fetchClearSampleByStyle($clearStyle, $limit)
    {
        return Yii::$app->db->createCommand(
            'SELECT id, orderSn, saleIds, purchaseIds, status, clearStyle FROM ' . Clear::tableName()
            . ' WHERE clearStyle = :style ORDER BY id DESC LIMIT ' . intval($limit)
        )->bindValue(':style', intval($clearStyle))->queryAll();
    }

    /**
     * @param int[] $clearStyles
     * @param string $progressKey 进度文件后缀
     * @param string $label 日志标签
     * @param bool $checkLegacyGys2KmGys 是否检测 gys2KmGys 旧格式行
     */
    private function runBackfillOrderCgClear(array $clearStyles, $progressKey, $label, $checkLegacyGys2KmGys)
    {
        ini_set('memory_limit', '512M');
        set_time_limit(0);

        if ($this->batchSize < 1) {
            $this->stderr("batchSize 必须大于 0\n");
            return ExitCode::UNSPECIFIED_ERROR;
        }
        if ($this->sleepMs < 0) {
            $this->stderr("sleepMs 不能小于 0\n");
            return ExitCode::UNSPECIFIED_ERROR;
        }

        $this->backfillProgressKey = $progressKey;

        if ($this->reset && $this->clearId <= 0) {
            $this->clearBackfillProgress();
            $this->stdout("已重置回填进度 [{$progressKey}]\n");
        }

        $cursorId = $this->clearId > 0 ? null : $this->loadBackfillProgress();
        $total = 0;
        $inserted = 0;
        $skipped = 0;
        $needBackfill = 0;
        $batchNo = 0;
        $styleStats = [];

        $this->stdout(sprintf(
            "开始漏补 xhOrderCgClear [%s] | id DESC 分批 | dryRun=%d batchSize=%d sleepMs=%d limit=%d | 续跑 id<%s | 进度=%s\n",
            $label,
            (int)$this->dryRun,
            $this->batchSize,
            $this->sleepMs,
            (int)$this->limit,
            $cursorId === null ? 'max' : (string)$cursorId,
            $this->getBackfillProgressFile()
        ));

        while (true) {
            if ($this->limit > 0 && $total >= $this->limit) {
                break;
            }
            $fetchLimit = $this->batchSize;
            if ($this->limit > 0) {
                $fetchLimit = min($fetchLimit, $this->limit - $total);
                if ($fetchLimit < 1) {
                    break;
                }
            }

            $list = $this->fetchClearBatch($clearStyles, $cursorId, $fetchLimit);
            if (empty($list)) {
                break;
            }
            $batchNo++;
            $batchMinId = null;
            $clearIds = array_map('intval', array_column($list, 'id'));
            $emptyAmountClearIds = OrderCgClearClass::getClearIdsWithEmptyAmount($clearIds);
            $legacyGys2KmGysClearIds = $checkLegacyGys2KmGys
                ? OrderCgClearClass::getClearIdsWithLegacyGys2KmGysRows($clearIds)
                : [];
            $relationCountMap = OrderCgClearClass::getRelationCountMap($clearIds);

            foreach ($list as $clear) {
                $total++;
                $currentClearId = intval($clear['id'] ?? 0);
                $clearStyle = intval($clear['clearStyle'] ?? 0);
                $batchMinId = $currentClearId;
                $cursorId = $currentClearId;

                if (!isset($styleStats[$clearStyle])) {
                    $styleStats[$clearStyle] = ['scan' => 0, 'need' => 0, 'skip' => 0];
                }
                $styleStats[$clearStyle]['scan']++;

                $saleIds = trim($clear['saleIds'] ?? '');
                $purchaseIds = trim($clear['purchaseIds'] ?? '');
                if ($saleIds === '' && $purchaseIds === '') {
                    $skipped++;
                    $styleStats[$clearStyle]['skip']++;
                    continue;
                }

                $relationCount = $relationCountMap[$currentClearId] ?? 0;
                if (OrderCgClearClass::shouldSkipBackfill(
                    $clear,
                    $relationCount,
                    $emptyAmountClearIds,
                    $legacyGys2KmGysClearIds
                )) {
                    $skipped++;
                    $styleStats[$clearStyle]['skip']++;
                    continue;
                }

                $needBackfill++;
                $styleStats[$clearStyle]['need']++;

                if ($this->dryRun) {
                    $expected = OrderCgClearClass::expectedRelationCountFromClear($clear);
                    $this->stdout(sprintf(
                        "需漏补 clearId=%d clearStyle=%d 已有关系=%d 应有≈%d\n",
                        $currentClearId,
                        $clearStyle,
                        $relationCount,
                        $expected
                    ));
                    if ($this->logEvery > 0 && $needBackfill % $this->logEvery === 0) {
                        $this->stdout("dryRun 需漏补累计 {$needBackfill} 条\n");
                    }
                    continue;
                }

                $count = OrderCgClearClass::backfillFromClear($clear, true);
                if ($count > 0) {
                    $inserted += $count;
                } else {
                    $skipped++;
                    $styleStats[$clearStyle]['skip']++;
                    $styleStats[$clearStyle]['need']--;
                    $needBackfill--;
                }
                if ($this->logEvery > 0 && $total % $this->logEvery === 0) {
                    $this->stdout("进度：扫描 {$total}，需漏补 {$needBackfill}，写入关系 {$inserted} 行，跳过 {$skipped}，当前 clearId={$currentClearId}\n");
                }
            }

            if (!$this->dryRun && $this->clearId <= 0 && $batchMinId !== null) {
                $this->saveBackfillProgress($batchMinId);
            }

            $this->stdout(sprintf(
                "第 %d 批完成：本批 %d 条，累计扫描 %d，需漏补 %d，写入关系 %d 行，跳过 %d，checkpoint id=%d\n",
                $batchNo,
                count($list),
                $total,
                $needBackfill,
                $inserted,
                $skipped,
                (int)$batchMinId
            ));

            if ($this->clearId > 0 || count($list) < $fetchLimit) {
                break;
            }
            $this->sleepBetweenBatch();
        }

        if (!$this->dryRun && $this->clearId <= 0 && $cursorId !== null) {
            $this->stdout("进度已保存，下次从 id < {$cursorId} 继续\n");
        }
        $this->stdout(sprintf(
            "全部完成 [%s]：扫描 %d 条 xhClear，需漏补 %d 条，写入 %d 行关系，跳过 %d 条\n",
            $label,
            $total,
            $needBackfill,
            $inserted,
            $skipped
        ));
        if (!empty($styleStats)) {
            ksort($styleStats);
            foreach ($styleStats as $style => $stat) {
                $this->stdout(sprintf(
                    "  clearStyle=%d：扫描 %d，需漏补 %d，跳过 %d\n",
                    $style,
                    (int)$stat['scan'],
                    (int)$stat['need'],
                    (int)$stat['skip']
                ));
            }
        }
        return ExitCode::OK;
    }

    /**
     * 按主键倒序轻量拉取一批 xhClear（只查回填所需字段，LIMIT 走主键索引）
     */
    private function fetchClearBatch(array $clearStyles, $cursorId, $limit)
    {
        $clearStyles = array_values(array_unique(array_filter(array_map('intval', $clearStyles))));
        if (empty($clearStyles)) {
            return [];
        }
        $inParts = [];
        $params = [];
        foreach ($clearStyles as $idx => $style) {
            $key = ':s' . $idx;
            $inParts[] = $key;
            $params[$key] = $style;
        }
        $inSql = implode(',', $inParts);

        if ($this->clearId > 0) {
            $params[':id'] = intval($this->clearId);
            $row = Yii::$app->db->createCommand(
                'SELECT id, orderSn, saleIds, purchaseIds, status, clearStyle FROM ' . Clear::tableName()
                . ' WHERE id = :id AND clearStyle IN (' . $inSql . ') LIMIT 1'
            )->bindValues($params)->queryOne();
            return $row ? [$row] : [];
        }

        $sql = 'SELECT id, orderSn, saleIds, purchaseIds, status, clearStyle FROM ' . Clear::tableName()
            . ' WHERE clearStyle IN (' . $inSql . ')';
        if ($cursorId !== null) {
            $sql .= ' AND id < :cursorId';
            $params[':cursorId'] = intval($cursorId);
        }
        $sql .= ' ORDER BY id DESC LIMIT ' . intval($limit);
        return Yii::$app->db->createCommand($sql)->bindValues($params)->queryAll();
    }

    private function sleepBetweenBatch()
    {
        if ($this->sleepMs > 0) {
            usleep($this->sleepMs * 1000);
        }
    }

    private function getBackfillProgressFile()
    {
        $key = $this->backfillProgressKey !== '' ? $this->backfillProgressKey : 'all';
        return Yii::getAlias('@console/runtime/order_cg_clear_backfill_' . $key . '.last_id');
    }

    private function loadBackfillProgress()
    {
        $file = $this->getBackfillProgressFile();
        if (!is_file($file)) {
            return null;
        }
        $id = intval(trim((string)file_get_contents($file)));
        return $id > 0 ? $id : null;
    }

    private function saveBackfillProgress($clearId)
    {
        if ($this->dryRun || $this->clearId > 0) {
            return;
        }
        $clearId = intval($clearId);
        if ($clearId <= 0) {
            return;
        }
        $file = $this->getBackfillProgressFile();
        $dir = dirname($file);
        if (!is_dir($dir)) {
            mkdir($dir, 0777, true);
        }
        file_put_contents($file, (string)$clearId);
    }

    private function clearBackfillProgress()
    {
        $file = $this->getBackfillProgressFile();
        if (is_file($file)) {
            unlink($file);
        }
    }

    private function isCliOptionPassed($name)
    {
        foreach ($_SERVER['argv'] ?? [] as $arg) {
            if ($arg === '--' . $name || strpos($arg, '--' . $name . '=') === 0) {
                return true;
            }
        }
        return false;
    }

}