进销存：入库明细支持页面导入 (#473)

账户简称表头筛选改为可输入、可点选的搜索框，并保留原有筛选逻辑。

.dockerignore

@@ -10,6 +10,7 @@ runtime
 *.md
 JetBrainsMono-字体
 node_modules
+**/__pycache__
 vendor
 bootstrap/cache/*
 .caiwu-build

.github/workflows/tests.yml

@@ -38,8 +38,14 @@ jobs:
       - name: Copy .env
         run: cp .env.testing .env
 
+      - name: Setup Node
+        uses: actions/setup-node@v7
+        with:
+          node-version-file: '.nvmrc'
+          cache: 'npm'
+
       - name: Install NPM
-        run: npm install
+        run: npm ci --legacy-peer-deps --no-audit --no-fund
 
       - name: Compile assets
         run: npm run production

.gitignore

@@ -113,6 +113,7 @@ modules/*
 .workbuddy/
 runtime/.env
 /.private/kaifa-progress-sync/
+__pycache__/
 public/net-layer-demo.html
 public/perf-diff-plan.html
 public/plan-a-changes-202608.csv

.nvmrc

@@ -0,0 +1 @@
+24.22.1

AGENTS.md

@@ -38,6 +38,15 @@
 - 数据页面按本次影响验证代表性数据量下的首页、翻页和筛选耗时；明显长时间等待不能以“返回正确”判定通过。低风险改动不增加重复或仅复述实现的测试。
 - 明确区分：本地已验证、已提交/推送、已合并、已上线和仍需生产验收。
 
+### 性能与资源验收（强制）
+
+- 涉及查询、报表、导入导出、同步或后台任务时，开发前先确认实际数据规模、单次数据量、文件大小和运行频率，并据此选择实现与验收数据；不能只验证几十行样例。
+- Excel/CSV 必须流式读取；表扫描、关联和排序使用合适索引，页面数据使用分页。分批写库只控制写入批次，不能据此声称读取过程内存受控。
+- 重型任务复用项目现有独立批处理容器，完成命令登记，并明确内存上限、超时、互斥和失败恢复；不得占用网页服务资源执行全量处理。
+- 禁止通过取消 `memory_limit`、无限重试、放大数据库参数或其他绕过资源边界的办法掩盖性能问题。
+- 使用代表性数据测量耗时、进程峰值内存和数据库开销，并在交付说明中写明测量范围、数据量及未验证项。生产环境不运行压测，不随意重跑全量任务。
+- 性能优化不得改变金额口径、筛选范围或现有业务结果；相关金额和功能回归必须同时通过。
+
 ## 5. 前端与视觉
 
 - 只有前端任务需要先阅读根目录 `DESIGN.md`；`.impeccable/design.json` 是同源机器规范。
@@ -64,12 +73,14 @@
 
 ## 8. 构建与生产部署
 
+- 发布脚本会拒绝覆盖“不在本次版本里”的线上提交（防止互相冲掉已上线的改动）。热修复必须基于线上当前版本构建，发布后立即合入 `main`；遇到拦截先 `git fetch` 并合入最新 `main` 或线上热修复分支，不得随手加 `-AllowRollback`（`--allow-rollback`），撤回线上发布需负责人明确决定。
 - 普通代码发布由任务 Codex 在完成验证与合并后直接执行，不要求用户再次说“部署、上线”；用户明确要求仅本地开发、仅审查或暂不上线时遵循其范围。正式发布只使用已合并的最新 `main`。
 - Windows 开发机统一使用 `scripts/deploy-from-workstation.ps1`，macOS 开发机使用 `bash scripts/deploy-from-mac.sh`；两者流程一致（本机构建前端与镜像、迁移拦截、增量推送服务器本机 Registry、激活与健康检查、双版本保留）。服务器只运行开发机已构建的 `caiwu_akaunting:<commit>` 镜像，禁止在服务器执行 Composer、npm 或 Docker 构建。
 - 新人只需表达部署需求；Codex 使用默认生产入口运行脚本。首次通过本机窗口提供一次服务器密码后，加密保存在本人电脑供后续自动使用，不要求新人准备私钥、执行命令或每次重输密码。已有私钥认证仍兼容。
 - 当前生产入口为 `https://caiwu.jiansuntuzhi.cn:8442`；公网仍只使用 `8442`，日常发布不得改成无端口地址。
 - 发布脚本检测到新增数据库迁移时，由 Codex 核对全部待执行迁移。仅涉及本任务共享镜像建表、字段、索引和同步登记的迁移，完成备份后自主使用 `-AllowMigrations`（macOS 为 `--allow-migrations`）；其他迁移仍按第 6 节确认授权。不能因需要迁移开关就把镜像接入停给负责人。
 - 容器内 Laravel 命令使用 `www-data`。发布后只需确认部署 SHA、应用容器健康、受影响的真实页面/接口、迁移是否执行，以及当前和上一版镜像可回滚。
+- 生产重型 CLI 导入统一使用 `sh /opt/caiwuxitong/run-finance-batch.sh <命令> <原参数>`，不得在网页容器内直接执行或取消 PHP 内存限制。新增导入登记 `deploy/finance-batch-imports.json`；入口提供独立容器、互斥、资源与时间上限，主应用保留自己的内存边界。
 - 程序静态资源随应用镜像同源发布；七牛只存用户上传的业务图片、票据和附件。
 - 只有本地初始化、服务器维护、生产发布或数据库迁移任务需要读取 `docs/开发与部署SOP.md` 的对应章节；普通功能开发无需加载整份 SOP。
 

app/Business/InventoryInboundDetailImporter.php

@@ -0,0 +1,237 @@
+<?php
+
+namespace App\Business;
+
+use App\Models\Business\InventoryWarehouseNameMapping;
+use DateTimeImmutable;
+use Illuminate\Support\Facades\DB;
+use PhpOffice\PhpSpreadsheet\IOFactory;
+use RuntimeException;
+
+class InventoryInboundDetailImporter
+{
+    private const TABLE = 'inventory_inbound_detail_rows';
+
+    /**
+     * Replace the imported inbound detail snapshot only after the workbook has
+     * been opened successfully. The delete and inserts share one transaction,
+     * so a malformed file cannot leave the page with a partially imported table.
+     *
+     * @return array{imported:int,mapped:int,skipped:int,total:int}
+     */
+    public function import(string $file, string $forcedMonth = ''): array
+    {
+        $path = realpath($file);
+        if ($path === false || ! is_file($path) || ! is_readable($path)) {
+            throw new RuntimeException('入库明细文件不存在或不可读取。');
+        }
+
+        $forcedMonth = $this->normalizeForcedMonth($forcedMonth);
+        $connection = (string) config('upstream_mirrors.connection', 'business_mirror');
+        $now = now();
+        $maps = $this->shortNameMap();
+
+        $reader = IOFactory::createReaderForFile($path);
+        $reader->setReadDataOnly(true);
+        $spreadsheet = $reader->load($path);
+        $sheet = $spreadsheet->getSheet(0);
+
+        try {
+            return DB::connection($connection)->transaction(function () use (
+                $connection,
+                $sheet,
+                $maps,
+                $forcedMonth,
+                $now,
+            ): array {
+                DB::connection($connection)->table(self::TABLE)->delete();
+
+                $batch = [];
+                $imported = 0;
+                $mapped = 0;
+                $skipped = 0;
+
+                foreach ($sheet->getRowIterator(2) as $row) {
+                    $rowNumber = $row->getRowIndex();
+                    $cells = [];
+                    foreach ($row->getCellIterator('A', 'U') as $cell) {
+                        $cells[] = $cell->getFormattedValue();
+                    }
+
+                    $warehouse = trim((string) ($cells[14] ?? ''));
+                    $createdRaw = trim((string) ($cells[16] ?? ''));
+                    if ($warehouse === '' && $createdRaw === '') {
+                        $skipped++;
+                        continue;
+                    }
+
+                    $month = $forcedMonth !== '' ? $forcedMonth : $this->monthOf($createdRaw);
+                    if ($month === '') {
+                        $skipped++;
+                        continue;
+                    }
+
+                    // 代发仓按仓储方匹配；其它仓库按仓库名称做唯一匹配。
+                    $shortName = '';
+                    if ($warehouse !== '') {
+                        $shortName = str_contains($warehouse, '代发仓')
+                            ? ($maps['provider'][$warehouse] ?? $maps['warehouse'][$warehouse] ?? '')
+                            : ($maps['warehouse'][$warehouse] ?? '');
+                    }
+                    if ($shortName !== '') {
+                        $mapped++;
+                    }
+
+                    $batch[] = [
+                        'report_month' => $month,
+                        'row_key' => sha1(substr($month, 0, 7) . '|' . $rowNumber),
+                        'source_no' => $this->text($cells[0] ?? ''),
+                        'document_no' => $this->text($cells[1] ?? ''),
+                        'created_serial' => $this->text($cells[2] ?? ''),
+                        'supplier' => $this->text($cells[3] ?? ''),
+                        'item_no' => $this->text($cells[4] ?? ''),
+                        'barcode' => $this->text($cells[5] ?? ''),
+                        'spec_name' => $this->text($cells[6] ?? ''),
+                        'quantity' => $this->number($cells[7] ?? ''),
+                        'unit_price' => $this->number($cells[8] ?? ''),
+                        'amount' => $this->number($cells[9] ?? ''),
+                        'estimated_unit_price' => $this->number($cells[10] ?? ''),
+                        'estimated_amount' => $this->number($cells[11] ?? ''),
+                        'supplier_barcode' => $this->text($cells[12] ?? ''),
+                        'remark' => $this->text($cells[13] ?? ''),
+                        'warehouse' => $warehouse !== '' ? $warehouse : null,
+                        'warehouse_short_name' => $shortName !== '' ? $shortName : null,
+                        'created_at_raw' => $this->moment($createdRaw),
+                        'express_name' => $this->text($cells[17] ?? ''),
+                        'express_no' => $this->text($cells[18] ?? ''),
+                        'not_sent' => $this->text($cells[19] ?? ''),
+                        'owner_name' => $this->text($cells[20] ?? ''),
+                        'imported_at' => $now,
+                    ];
+                    $imported++;
+
+                    if (count($batch) >= 1000) {
+                        DB::connection($connection)->table(self::TABLE)->insertOrIgnore($batch);
+                        $batch = [];
+                    }
+                }
+
+                if ($batch !== []) {
+                    DB::connection($connection)->table(self::TABLE)->insertOrIgnore($batch);
+                }
+                if ($imported === 0) {
+                    throw new RuntimeException('入库明细文件中没有可导入的数据。');
+                }
+
+                return [
+                    'imported' => $imported,
+                    'mapped' => $mapped,
+                    'skipped' => $skipped,
+                    'total' => DB::connection($connection)->table(self::TABLE)->count(),
+                ];
+            });
+        } finally {
+            $spreadsheet->disconnectWorksheets();
+        }
+    }
+
+    private function normalizeForcedMonth(string $month): string
+    {
+        $month = trim($month);
+        if ($month === '') {
+            return '';
+        }
+        if (preg_match('/^\d{4}-\d{2}$/', $month) === 1) {
+            return $month . '-01';
+        }
+        if (preg_match('/^\d{4}-\d{2}-\d{2}$/', $month) === 1) {
+            return $month;
+        }
+
+        throw new RuntimeException('指定月份格式应为 YYYY-MM。');
+    }
+
+    /** @return array{warehouse:array<string,string>,provider:array<string,string>} */
+    private function shortNameMap(): array
+    {
+        $rows = InventoryWarehouseNameMapping::withoutGlobalScopes()
+            ->get(['warehouse_provider', 'warehouse', 'warehouse_short_name']);
+        $grouped = [];
+        foreach ($rows as $row) {
+            $warehouse = trim((string) $row->warehouse);
+            if ($warehouse === '') {
+                continue;
+            }
+            $grouped[$warehouse][] = trim((string) $row->warehouse_short_name);
+        }
+
+        $byWarehouse = [];
+        foreach ($grouped as $warehouse => $names) {
+            $unique = array_values(array_unique($names));
+            if (count($unique) === 1 && $unique[0] !== '') {
+                $byWarehouse[$warehouse] = $unique[0];
+            }
+        }
+
+        $byProvider = [];
+        foreach ($rows as $row) {
+            $provider = trim((string) $row->warehouse_provider);
+            if ($provider !== '') {
+                $byProvider[$provider][] = trim((string) $row->warehouse_short_name);
+            }
+        }
+        foreach ($byProvider as $provider => $names) {
+            $unique = array_values(array_unique($names));
+            if (count($unique) === 1 && $unique[0] !== '') {
+                $byProvider[$provider] = $unique[0];
+            }
+        }
+
+        return ['warehouse' => $byWarehouse, 'provider' => $byProvider];
+    }
+
+    private function monthOf(string $value): string
+    {
+        $value = trim($value);
+        if ($value === '') {
+            return '';
+        }
+        foreach (['Y/m/d H:i:s', 'Y-m-d H:i:s', 'Y/m/d', 'Y-m-d'] as $format) {
+            $parsed = DateTimeImmutable::createFromFormat($format, $value);
+            if ($parsed instanceof DateTimeImmutable) {
+                return $parsed->format('Y-m') . '-01';
+            }
+        }
+        $timestamp = strtotime($value);
+
+        return $timestamp === false ? '' : date('Y-m-01', $timestamp);
+    }
+
+    private function moment(string $value): ?string
+    {
+        $value = trim($value);
+        if ($value === '') {
+            return null;
+        }
+        $timestamp = strtotime($value);
+
+        return $timestamp === false ? null : date('Y-m-d H:i:s', $timestamp);
+    }
+
+    private function text(mixed $value): ?string
+    {
+        $text = trim((string) $value);
+
+        return $text === '' ? null : $text;
+    }
+
+    private function number(mixed $value): ?float
+    {
+        $text = str_replace(',', '', trim((string) $value));
+        if ($text === '' || ! is_numeric($text)) {
+            return null;
+        }
+
+        return (float) $text;
+    }
+}

app/Business/JstOrderLabelImporter.php

@@ -63,6 +63,7 @@ class JstOrderLabelImporter
                 ->where('ordered_at', '>=', $start)
                 ->where('ordered_at', '<', $end)
                 ->delete();
+            app(PlantingOrderLabelLookup::class)->forget($companyId);
         }
 
         $now = now();
@@ -71,9 +72,10 @@ class JstOrderLabelImporter
         $noLabelOrders = 0;
         $buffer = [];
 
-        $flush = function () use (&$buffer, &$rows, $target): void {
+        $flush = function () use (&$buffer, &$rows, $target, $companyId): void {
             foreach (array_chunk($buffer, self::INSERT_CHUNK) as $chunk) {
                 $target->table('jst_order_labels')->insert($chunk);
+                app(PlantingOrderLabelLookup::class)->forget($companyId);
                 $rows += count($chunk);
             }
             $buffer = [];
@@ -191,6 +193,7 @@ class JstOrderLabelImporter
                 ->where('ordered_at', '>=', $start)
                 ->where('ordered_at', '<', $end)
                 ->delete();
+            app(PlantingOrderLabelLookup::class)->forget($companyId);
         };
         $cleared = ! $replace;
 
@@ -203,9 +206,10 @@ class JstOrderLabelImporter
         $orderSeen = [];
         $buffer = [];
 
-        $flush = function () use (&$buffer, &$rows, $target): void {
+        $flush = function () use (&$buffer, &$rows, $target, $companyId): void {
             foreach (array_chunk($buffer, self::INSERT_CHUNK) as $chunk) {
                 $target->table('jst_order_labels')->insert($chunk);
+                app(PlantingOrderLabelLookup::class)->forget($companyId);
                 $rows += count($chunk);
             }
             $buffer = [];

app/Business/JstOrderLabelPlantingRules.php

@@ -82,6 +82,7 @@ class JstOrderLabelPlantingRules
     public function forget(int $companyId): void
     {
         Cache::forget($this->key($companyId));
+        app(PlantingOrderLabelLookup::class)->forget($companyId);
     }
 
     private function key(int $companyId): string

app/Business/PlantingOrderLabelLookup.php

@@ -0,0 +1,68 @@
+<?php
+
+namespace App\Business;
+
+use Illuminate\Support\Facades\Cache;
+use Illuminate\Support\Facades\DB;
+
+/** Reuse label classification across monthly/platform jobs; writers invalidate it. */
+class PlantingOrderLabelLookup
+{
+    /** @param list<string> $positiveLabels @return list<string> */
+    public function orderNumbers(int $companyId, array $positiveLabels): array
+    {
+        sort($positiveLabels, SORT_STRING);
+        $rules = hash('sha256', json_encode($positiveLabels, JSON_THROW_ON_ERROR));
+        $key = $this->key($companyId);
+        $read = function () use ($key, $rules, $companyId): ?array {
+            $cached = Cache::get($key);
+
+            return is_array($cached) && ($cached['rules'] ?? null) === $rules
+                && ($cached['revision'] ?? null) === $this->revision($companyId)
+                ? $cached['orders'] : null;
+        };
+        if (($orders = $read()) !== null) {
+            return $orders;
+        }
+
+        return Cache::lock($key . ':build', 300)->block(305, function () use ($companyId, $positiveLabels, $key, $rules, $read): array {
+            if (($orders = $read()) !== null) {
+                return $orders;
+            }
+            $revision = $this->revision($companyId);
+            $orders = [];
+            foreach (DB::table('jst_order_labels')->where('company_id', $companyId)
+                ->where(function ($query) use ($positiveLabels): void {
+                    if ($positiveLabels !== []) {
+                        $query->whereIn('label', $positiveLabels);
+                    }
+                    $query->orWhereRaw('FIND_IN_SET(?, item_code) > 0', [JstOrderLabelPlantingRules::PLANTING_ITEM_CODE]);
+                })->select('order_no')->distinct()->cursor() as $row) {
+                $orders[] = (string) $row->order_no;
+            }
+            // An import/rule change during the scan must not publish an old result.
+            if ($this->revision($companyId) === $revision) {
+                Cache::put($key, ['rules' => $rules, 'revision' => $revision, 'orders' => $orders], now()->addHours(24));
+            }
+
+            return $orders;
+        });
+    }
+
+    public function forget(int $companyId): void
+    {
+        $key = $this->key($companyId);
+        Cache::store('upstream_shared')->forever($key . ':revision', bin2hex(random_bytes(16)));
+        Cache::forget($key);
+    }
+
+    public function revision(int $companyId): ?string
+    {
+        return Cache::store('upstream_shared')->get($this->key($companyId) . ':revision');
+    }
+
+    private function key(int $companyId): string
+    {
+        return 'planting-order-labels:v1:' . $companyId;
+    }
+}

app/Console/Commands/BackfillWorkOrderWaybillLookup.php

@@ -0,0 +1,29 @@
+<?php
+
+namespace App\Console\Commands;
+
+use Illuminate\Console\Command;
+use Illuminate\Support\Facades\Cache;
+use Modules\EcommerceFinance\Services\WorkOrderWaybillLookup;
+
+class BackfillWorkOrderWaybillLookup extends Command
+{
+    protected $signature = 'business-mirror:index-work-order-waybills {--batch=500} {--max-batches=2} {--pause-ms=50}';
+    protected $description = '按稳定游标建立查件运单小索引；生产须使用 run-finance-batch.sh 执行';
+
+    public function handle(WorkOrderWaybillLookup $lookup): int
+    {
+        $lock = Cache::store('upstream_shared')->lock('work-order-waybill-lookup:backfill', 3600);
+        if (! $lock->get()) {
+            $this->info('已有运单索引任务运行，本轮跳过。');
+            return self::SUCCESS;
+        }
+        try {
+            $result = $lookup->backfill((int) $this->option('batch'), max(0, (int) $this->option('max-batches')), max(0, (int) $this->option('pause-ms')));
+            $this->info(json_encode($result));
+            return self::SUCCESS;
+        } finally {
+            $lock->release();
+        }
+    }
+}

app/Console/Commands/ImportAfterSalesCostRows.php

@@ -0,0 +1,326 @@
+<?php
+
+namespace App\Console\Commands;
+
+use Illuminate\Console\Command;
+use Illuminate\Support\Facades\DB;
+use Modules\EcommerceFinance\Repositories\AfterSalesCostRowRepository;
+use XMLReader;
+use ZipArchive;
+
+/**
+ * 导入聚水潭「商品利润 → 导出明细数据 → 订单售后费用数据」Excel。
+ *
+ * 该报表已按商品编码（组合装拆成组件）给出每行和成本，导入后订单售后费用明细页面
+ * 在覆盖的店铺/日期范围内直接按这些明细行展示。
+ */
+class ImportAfterSalesCostRows extends Command
+{
+    protected $signature = 'order-data:import-after-sales-cost {file : Excel 文件路径} {--chunk=500 : 每批写入行数} {--dry-run : 只解析不入库}';
+
+    protected $description = '导入聚水潭「订单售后费用数据」Excel 到订单售后费用明细';
+
+    public function handle(): int
+    {
+        $path = (string) $this->argument('file');
+
+        if (! is_file($path)) {
+            $this->error('文件不存在：' . $path);
+
+            return self::FAILURE;
+        }
+
+        $headers = (array) config('order_after_sales_cost.headers', []);
+        $numberKeys = array_flip((array) config('order_after_sales_cost.number_keys', []));
+
+        if ($headers === []) {
+            $this->error('缺少表头映射：config/order_after_sales_cost.php');
+
+            return self::FAILURE;
+        }
+
+        $this->info('流式读取文件：' . $path);
+
+        $sheetPath = $this->firstSheetPath($path);
+
+        if ($sheetPath === null) {
+            $this->error('不是有效的 xlsx（缺少工作表）。');
+
+            return self::FAILURE;
+        }
+
+        try {
+            $sharedStrings = $this->readSharedStrings($path);
+        } catch (\Throwable $exception) {
+            $this->error('读取共享字符串失败：' . $exception->getMessage());
+
+            return self::FAILURE;
+        }
+
+        $columns = [];
+        $first = true;
+        $chunkSize = max((int) $this->option('chunk'), 100);
+        $dryRun = (bool) $this->option('dry-run');
+        $buffer = [];
+        $total = 0;
+        $written = 0;
+        $skipped = 0;
+        $shops = [];
+        $minDate = null;
+        $maxDate = null;
+        $importedAt = now()->toDateTimeString();
+
+        $reader = new XMLReader();
+
+        if (! $reader->open('zip://' . $path . '#' . $sheetPath)) {
+            $this->error('无法打开工作表：' . $sheetPath);
+
+            return self::FAILURE;
+        }
+
+        while ($reader->read()) {
+            if ($reader->nodeType !== XMLReader::ELEMENT || $reader->localName !== 'row') {
+                continue;
+            }
+
+            $cells = $this->readRow($reader, $sharedStrings);
+
+            if ($first) {
+                $first = false;
+
+                foreach ($cells as $index => $header) {
+                    $header = self::normalizeHeader((string) $header);
+
+                    if ($header !== '' && isset($headers[$header])) {
+                        $columns[$index] = $headers[$header];
+                    }
+                }
+
+                if ($columns === []) {
+                    $reader->close();
+                    $this->error('表头和配置的映射对不上，请检查文件或 config/order_after_sales_cost.php');
+
+                    return self::FAILURE;
+                }
+
+                continue;
+            }
+
+            $total++;
+            $payload = [];
+
+            foreach ($columns as $index => $key) {
+                $value = $cells[$index] ?? null;
+
+                if (is_string($value)) {
+                    $value = trim($value);
+                }
+
+                if ($value === '' || $value === null) {
+                    continue;
+                }
+
+                if (isset($numberKeys[$key])) {
+                    $value = is_numeric($value) ? (float) $value : 0.0;
+                } elseif (self::isDateKey($key)) {
+                    $value = self::dateValue($value);
+                }
+
+                $payload[$key] = $value;
+            }
+
+            $shop = trim((string) ($payload['shop_name'] ?? ''));
+
+            if ($shop === '' || empty($payload['product_code'])) {
+                $skipped++;
+
+                continue;
+            }
+
+            $buffer[] = AfterSalesCostRowRepository::toRecord($payload, $importedAt);
+            $shops[$shop] = true;
+            $orderTime = $payload['order_time'] ?? null;
+
+            if (is_string($orderTime) && $orderTime !== '') {
+                $minDate = $minDate === null || $orderTime < $minDate ? $orderTime : $minDate;
+                $maxDate = $maxDate === null || $orderTime > $maxDate ? $orderTime : $maxDate;
+            }
+
+            if (! $dryRun && count($buffer) >= $chunkSize) {
+                $written += $this->flush($buffer);
+                $buffer = [];
+                $this->output->write("\r写入 " . $written . ' 行');
+            }
+
+            if ($dryRun && $buffer !== []) {
+                $buffer = [];
+            }
+        }
+
+        $reader->close();
+
+        if (! $dryRun && $buffer !== []) {
+            $written += $this->flush($buffer);
+        }
+
+        $this->newLine(2);
+        $this->info(sprintf(
+            '完成：读取 %d 行，写入 %d 行，跳过 %d 行；店铺 %d 个；订单时间 %s ~ %s；峰值内存 %.1f MB',
+            $total,
+            $written,
+            $skipped,
+            count($shops),
+            $minDate ?? '-',
+            $maxDate ?? '-',
+            memory_get_peak_usage(true) / 1048576,
+        ));
+
+        return self::SUCCESS;
+    }
+
+    private function firstSheetPath(string $path): ?string
+    {
+        $zip = new ZipArchive();
+
+        if ($zip->open($path) !== true) {
+            return null;
+        }
+
+        $sheet = null;
+
+        if ($zip->locateName('xl/worksheets/sheet1.xml') !== false) {
+            $sheet = 'xl/worksheets/sheet1.xml';
+        } else {
+            for ($i = 1; $i <= 30; $i++) {
+                $name = 'xl/worksheets/sheet' . $i . '.xml';
+
+                if ($zip->locateName($name) !== false) {
+                    $sheet = $name;
+                    break;
+                }
+            }
+        }
+
+        $zip->close();
+
+        return $sheet;
+    }
+
+    /** @return array<int,string> */
+    private function readSharedStrings(string $path): array
+    {
+        $strings = [];
+        $reader = new XMLReader();
+
+        if (! $reader->open('zip://' . $path . '#xl/sharedStrings.xml')) {
+            return $strings;
+        }
+
+        while ($reader->read()) {
+            if ($reader->nodeType === XMLReader::ELEMENT && $reader->localName === 'si') {
+                $xml = $reader->readOuterXml();
+                $strings[] = html_entity_decode(strip_tags($xml), ENT_QUOTES | ENT_XML1, 'UTF-8');
+            }
+        }
+
+        $reader->close();
+
+        return $strings;
+    }
+
+    /** @param array<int,string> $shared @return array<int,mixed> */
+    private function readRow(XMLReader $reader, array $shared): array
+    {
+        $cells = [];
+        $xml = $reader->readOuterXml();
+
+        if ($xml === '') {
+            return $cells;
+        }
+
+        $row = simplexml_load_string($xml, 'SimpleXMLElement', LIBXML_NOCDATA);
+
+        if ($row === false) {
+            return $cells;
+        }
+
+        foreach ($row->c as $cell) {
+            $index = self::columnIndex((string) $cell['r']);
+            $type = (string) $cell['t'];
+
+            if ($type === 's') {
+                $value = $shared[(int) $cell->v] ?? '';
+            } elseif ($type === 'inlineStr') {
+                $value = (string) $cell->is->t;
+            } else {
+                $value = (string) $cell->v;
+            }
+
+            $cells[$index] = $value;
+        }
+
+        return $cells;
+    }
+
+    private static function columnIndex(string $reference): int
+    {
+        $letters = preg_replace('/[^A-Z]/', '', strtoupper($reference)) ?? '';
+        $index = 0;
+
+        foreach (str_split($letters) as $letter) {
+            $index = $index * 26 + (ord($letter) - 64);
+        }
+
+        return $index - 1;
+    }
+
+    /** @param list<array<string,mixed>> $rows */
+    private function flush(array $rows): int
+    {
+        DB::table('ops_after_sales_cost_rows')->upsert(
+            $rows,
+            ['row_key'],
+            [
+                'shop_name', 'shop_code', 'online_order_no', 'internal_order_no', 'product_code',
+                'order_time', 'product_quantity', 'product_amount', 'product_cost', 'cost_source',
+                'combine_type', 'payload', 'imported_at', 'updated_at',
+            ],
+        );
+
+        return count($rows);
+    }
+
+    private static function normalizeHeader(string $header): string
+    {
+        $header = str_replace(["\u{3000}", "\u{00A0}"], ' ', $header);
+        $header = preg_replace('/\s+/u', ' ', $header) ?? $header;
+
+        return trim($header);
+    }
+
+    private static function isDateKey(string $key): bool
+    {
+        return in_array($key, [
+            'pay_time', 'order_complete_time', 'send_time', 'order_time', 'registration_time',
+            'confirmation_time', 'warehouse_entry_time',
+        ], true);
+    }
+
+    private static function dateValue(mixed $value): ?string
+    {
+        if ($value instanceof \DateTimeInterface) {
+            return $value->format('Y-m-d H:i:s');
+        }
+
+        if (is_numeric($value) && (float) $value > 20000 && (float) $value < 80000) {
+            // Excel 序列日期（1899-12-30 起算），按本地时间格式化。
+            $timestamp = ((float) $value - 25569) * 86400;
+
+            return gmdate('Y-m-d H:i:s', (int) $timestamp);
+        }
+
+        $timestamp = strtotime((string) $value);
+
+        return $timestamp === false ? null : date('Y-m-d H:i:s', $timestamp);
+    }
+}

app/Console/Commands/ImportCourierQuoteBillingRules.php

@@ -0,0 +1,280 @@
+<?php
+
+namespace App\Console\Commands;
+
+use App\Models\Business\CourierQuoteVersion;
+use App\Models\Common\Company;
+use App\Support\CourierQuoteStructure;
+use Illuminate\Console\Command;
+use Illuminate\Support\Facades\DB;
+use RuntimeException;
+
+/**
+ * 把整理好的结构化计费规则（标准计费规则_导入用.json）写入现有报价版本，供运费核算使用。
+ * 只写 billing_structure / billing_rows 两列，原始报价单元格、执行日期、状态都不动。
+ */
+class ImportCourierQuoteBillingRules extends Command
+{
+    protected $signature = 'courier-quotes:import-billing-rules {file : 标准计费规则 JSON}
+        {--company= : 报价所属公司ID}
+        {--dry-run : 只校验并输出结果，不写入}
+        {--force : 覆盖已有且内容不同的计费规则}';
+
+    protected $description = '把存量报价的结构化计费规则批量写入报价版本（按版本号匹配，整批事务）';
+
+    private const MODES = ['waybill_rate', 'first_additional', 'flat_bands', 'flat_then', CourierQuoteStructure::SEGMENTS];
+
+    public function handle(): int
+    {
+        $companyId = (int) $this->option('company');
+        if ($companyId <= 0 || ! Company::query()->where('id', $companyId)->exists()) {
+            $this->error('请指定有效的 --company。');
+
+            return self::FAILURE;
+        }
+
+        $payload = json_decode((string) @file_get_contents((string) $this->argument('file')), true);
+        $items = is_array($payload) ? ($payload['versions'] ?? null) : null;
+        if (! is_array($items) || $items === []) {
+            $this->error('文件不是有效的计费规则 JSON（缺少 versions）。');
+
+            return self::FAILURE;
+        }
+
+        $plan = [];
+        $report = [];
+        $seen = [];
+        foreach ($items as $item) {
+            if (! is_array($item)) {
+                $report[] = ['', '', '错误', '版本条目必须是对象'];
+                continue;
+            }
+            $code = (string) ($item['version_id'] ?? '');
+            if (isset($seen[$code])) {
+                $report[] = [$code, '', '错误', '同一文件中的版本号不能重复'];
+                continue;
+            }
+            $seen[$code] = true;
+            [$status, $note, $data] = $this->prepare($companyId, $item);
+            $report[] = [$code, (string) ($item['company_name'] ?? ''), $status, $note];
+            if ($data !== null) {
+                $plan[] = $data;
+            }
+        }
+
+        $this->table(['版本', '快递公司', '结果', '说明'], $report);
+        $counts = array_count_values(array_column($report, 2));
+        $summary = collect($counts)->map(fn ($n, $k) => "{$k} {$n}")->implode('，');
+
+        if (isset($counts['错误'])) {
+            $this->error('存在错误，整批未写入：' . $summary);
+
+            return self::FAILURE;
+        }
+        if ($this->option('dry-run')) {
+            $this->info('校验通过，未写入（dry-run）：' . $summary);
+
+            return self::SUCCESS;
+        }
+
+        try {
+            DB::transaction(function () use ($plan): void {
+                foreach ($plan as [$version, $structure, $rows]) {
+                    $current = DB::table($version->getTable())->where('id', $version->id)->lockForUpdate()->first();
+                    if (! $current || $current->company_name !== $version->company_name
+                        || json_decode($current->billing_structure ?? 'null', true) != $version->billing_structure
+                        || json_decode($current->billing_rows ?? 'null', true) != $version->billing_rows) {
+                        throw new RuntimeException('报价在校验后被其他操作修改，整批未写入，请重新校验。');
+                    }
+                    $version->forceFill(['billing_structure' => $structure, 'billing_rows' => $rows])->save();
+                }
+            });
+        } catch (RuntimeException $exception) {
+            $this->error($exception->getMessage());
+            return self::FAILURE;
+        }
+        $this->info('导入完成：' . $summary);
+
+        return self::SUCCESS;
+    }
+
+    /**
+     * @param array<string,mixed> $item
+     * @return array{0:string,1:string,2:?array}
+     */
+    private function prepare(int $companyId, array $item): array
+    {
+        $code = (string) ($item['version_id'] ?? '');
+        $version = CourierQuoteVersion::query()->allCompanies()->where('company_id', $companyId)->where('version_code', $code)->first();
+        if ($version === null) {
+            return ['错误', '系统中找不到该版本号', null];
+        }
+        if (trim((string) $version->company_name) !== trim((string) ($item['company_name'] ?? ''))) {
+            return ['错误', '快递名称不一致：系统为「' . $version->company_name . '」', null];
+        }
+        if (($item['conversion'] ?? '') === 'manual') {
+            return ['跳过', '特殊计费（' . ($item['manual_reason'] ?? '按体积/条码') . '），需人工核算', null];
+        }
+        if (($error = $this->inputError($item)) !== null) {
+            return ['错误', $error, null];
+        }
+
+        $source = (array) ($item['structure'] ?? []);
+        $segments = ($item['conversion'] ?? '') === 'needs_segment_mode';
+        $mode = $segments ? CourierQuoteStructure::SEGMENTS : (string) ($source['mode'] ?? '');
+        if (! in_array($mode, self::MODES, true)) {
+            return ['错误', '不支持的计费方式：' . $mode, null];
+        }
+
+        $params = (array) ($item['params'] ?? []);
+        $perTicket = 0.0;
+        foreach ((array) ($params['surcharges'] ?? []) as $surcharge) {
+            if (($surcharge['condition'] ?? '') === '每票' && is_numeric($surcharge['amount'] ?? null)) {
+                $perTicket += (float) $surcharge['amount'];
+            }
+        }
+        $structure = [
+            'mode' => $mode,
+            'flat_bands' => $segments ? [] : $this->numbers($source['flat_bands'] ?? []),
+            'then_mode' => $segments ? '' : (string) ($source['then_mode'] ?? ''),
+            'first_weight' => ! $segments && is_numeric($source['first_weight'] ?? null) ? (float) $source['first_weight'] : null,
+            'rate_tiers' => $segments ? [] : $this->numbers($source['rate_tiers'] ?? []),
+            'rounding' => in_array($source['rounding'] ?? 'none', array_keys(CourierQuoteStructure::ROUNDING), true) ? (string) ($source['rounding'] ?? 'none') : 'none',
+            'volumetric_divisor' => is_numeric($params['volumetric_divisor'] ?? null) ? (int) $params['volumetric_divisor'] : null,
+            'weight_limit' => is_numeric($params['weight_limit_kg'] ?? null) ? (float) $params['weight_limit_kg'] : null,
+            'min_weight' => is_numeric($source['min_weight'] ?? $params['min_weight_kg'] ?? null) ? (float) ($source['min_weight'] ?? $params['min_weight_kg']) : null,
+            'per_ticket_surcharge' => $perTicket > 0 ? $perTicket : null,
+            'notes' => array_values(array_map('strval', (array) ($params['notes'] ?? []))),
+            'imported_from' => 'stock-quote-billing-import',
+        ];
+
+        $rows = [];
+        foreach ((array) ($segments ? ($item['segments_rows'] ?? []) : ($item['rows'] ?? [])) as $row) {
+            $region = trim((string) ($row['region'] ?? ''));
+            if ($region === '') {
+                return ['错误', '存在没有地区名的行', null];
+            }
+            if ($segments) {
+                $list = [];
+                foreach ((array) ($row['segments'] ?? []) as $s) {
+                    $list[] = array_filter([
+                        'lo' => (float) ($s['lo'] ?? 0),
+                        'hi' => is_numeric($s['hi'] ?? null) ? (float) $s['hi'] : null,
+                        'type' => (string) ($s['type'] ?? ''),
+                        'price' => $this->number($s['price'] ?? null),
+                        'base' => $this->number($s['base'] ?? null),
+                        'rate' => $this->number($s['rate'] ?? null),
+                        'fw' => $this->number($s['fw'] ?? null),
+                    ], static fn ($v, $k) => $v !== null || $k === 'hi', ARRAY_FILTER_USE_BOTH);
+                }
+                $rows[] = ['region' => $region, 'segments' => $list];
+            } else {
+                $rows[] = [
+                    'region' => $region,
+                    'flat' => array_map(fn ($v) => $this->number($v), array_values((array) ($row['flat'] ?? []))),
+                    'base' => $this->number($row['base'] ?? null),
+                    'rates' => array_map(fn ($v) => $this->number($v), array_values((array) ($row['rates'] ?? []))),
+                ];
+            }
+        }
+        if ($rows === []) {
+            return ['错误', '没有任何地区价格', null];
+        }
+
+        $existing = $version->billing_structure;
+        $note = CourierQuoteStructure::describe($structure) . '，' . count($rows) . ' 个地区';
+        if (is_array($existing) && $existing !== []) {
+            if ($existing == $structure && $version->billing_rows == $rows) {
+                return ['跳过', '已导入且内容相同', null];
+            }
+            if (! $this->option('force')) {
+                return ['错误', '已有不同的计费规则，如需覆盖请加 --force', null];
+            }
+
+            return ['覆盖', $note, [$version, $structure, $rows]];
+        }
+
+        return ['写入', $note, [$version, $structure, $rows]];
+    }
+
+    private function number(mixed $value): ?float
+    {
+        return is_numeric($value) ? round((float) $value, 4) : null;
+    }
+
+    /** 金额导入拒绝负数、歧义分段和不支持的附加条件，不静默改写计费含义。 */
+    private function inputError(array $item): ?string
+    {
+        $structure = $item['structure'] ?? null;
+        $params = $item['params'] ?? [];
+        if (! is_array($structure) || ! is_array($params)) {
+            return 'structure 和 params 必须是对象';
+        }
+        if (! array_key_exists($structure['rounding'] ?? 'none', CourierQuoteStructure::ROUNDING)) {
+            return '不支持的重量取整方式';
+        }
+        $valid = static fn ($v): bool => is_numeric($v) && is_finite((float) $v) && (float) $v >= 0;
+        foreach ([$params['volumetric_divisor'] ?? null, $params['weight_limit_kg'] ?? null,
+            $structure['min_weight'] ?? $params['min_weight_kg'] ?? null, $structure['first_weight'] ?? null] as $v) {
+            if ($v !== null && ! $valid($v)) return '重量、体积系数必须是非负有限数字';
+        }
+        if (isset($params['volumetric_divisor']) && (float) $params['volumetric_divisor'] <= 0) return '体积系数必须大于0';
+        $minimum = (float) ($structure['min_weight'] ?? $params['min_weight_kg'] ?? 0);
+        if (($params['weight_limit_kg'] ?? 0) > 0 && $minimum > $params['weight_limit_kg']) return '起算重量不能大于限重';
+        foreach (['flat_bands', 'rate_tiers'] as $field) {
+            $previous = 0;
+            if (! is_array($structure[$field] ?? [])) return '重量分段必须是数组';
+            foreach ($structure[$field] ?? [] as $edge) {
+                if (! $valid($edge) || (float) $edge <= $previous) return '重量节点必须为严格递增的正数';
+                $previous = (float) $edge;
+            }
+        }
+        $mode = ($item['conversion'] ?? '') === 'needs_segment_mode' ? CourierQuoteStructure::SEGMENTS : ($structure['mode'] ?? '');
+        if (in_array($mode, ['flat_bands', 'flat_then'], true) && empty($structure['flat_bands'])) return '缺少一口价重量节点';
+        if ($mode === 'flat_then' && ! in_array($structure['then_mode'] ?? '', ['waybill_rate', 'first_additional'], true)) return '不支持的超重计费方式';
+        if (CourierQuoteStructure::usesFirstWeight($mode, $structure['then_mode'] ?? '') && ! (($structure['first_weight'] ?? 0) > 0)) return '首重必须大于0';
+        if ($mode === 'flat_then' && ! empty($structure['rate_tiers']) && min($structure['rate_tiers']) <= max($structure['flat_bands'])) return '超重费率节点必须大于一口价最后节点';
+        if (! is_array($params['surcharges'] ?? [])) return '附加费必须是数组';
+        foreach ($params['surcharges'] ?? [] as $fee) {
+            if (! is_array($fee) || ($fee['condition'] ?? '') !== '每票' || ! $valid($fee['amount'] ?? null)) return '附加费条件不支持自动核算，需人工核对';
+        }
+        $rows = $item[$mode === CourierQuoteStructure::SEGMENTS ? 'segments_rows' : 'rows'] ?? null;
+        if (! is_array($rows) || $rows === []) return '没有任何地区价格';
+        $regions = [];
+        foreach ($rows as $row) {
+            if (! is_array($row) || ! is_string($row['region'] ?? null) || trim($row['region']) === '') return '地区行格式不正确';
+            $region = mb_strtolower(preg_replace('/\s+/u', '', $row['region']));
+            if (isset($regions[$region])) return '存在重复地区行';
+            $regions[$region] = true;
+            if ($mode === CourierQuoteStructure::SEGMENTS) {
+                if (! is_array($row['segments'] ?? null) || $row['segments'] === []) return '缺少地区计费分段';
+                $previous = 0.0;
+                foreach ($row['segments'] as $segment) {
+                    if (! is_array($segment) || ! $valid($segment['lo'] ?? null)
+                        || (float) $segment['lo'] < $previous || ! in_array($segment['type'] ?? '', ['flat', 'waybill', 'first_add'], true)) return '分段类型不支持或存在重叠';
+                    $hi = $segment['hi'] ?? null;
+                    if ($hi !== null && (! $valid($hi) || (float) $hi <= (float) $segment['lo'])) return '分段上限必须大于下限';
+                    $previous = $hi === null ? INF : (float) $hi;
+                    foreach (['price', 'base', 'rate', 'fw'] as $key) {
+                        if (isset($segment[$key]) && ! $valid($segment[$key])) return '分段金额和重量必须是非负有限数字';
+                    }
+                    if ($segment['type'] === 'first_add' && ! $valid($segment['fw'] ?? null)) return '分段首重缺失';
+                }
+            } else {
+                if (! is_array($row['flat'] ?? []) || ! is_array($row['rates'] ?? [])) return '价格必须是数组';
+                if (count($row['flat'] ?? []) !== count($structure['flat_bands'] ?? [])
+                    || (CourierQuoteStructure::usesRates($mode) && count($row['rates'] ?? []) !== count($structure['rate_tiers'] ?? []) + 1)) return '价格列数与重量节点不匹配';
+                foreach (array_merge($row['flat'] ?? [], $row['rates'] ?? [], [$row['base'] ?? null]) as $v) {
+                    if ($v !== null && ! $valid($v)) return '价格必须是非负有限数字或null（不发）';
+                }
+            }
+        }
+        return null;
+    }
+
+    /** @return list<float> */
+    private function numbers(mixed $values): array
+    {
+        return array_values(array_map('floatval', array_filter((array) $values, 'is_numeric')));
+    }
+}

app/Console/Commands/ImportFinanceLedgerBase.php

@@ -0,0 +1,49 @@
+<?php
+
+namespace App\Console\Commands;
+
+use Illuminate\Console\Command;
+use Modules\EcommerceFinance\Services\FinanceLedgerBaseImporter;
+use Throwable;
+
+class ImportFinanceLedgerBase extends Command
+{
+    protected $signature = 'finance-ledger:import-base
+        {path : 《银行当前余额-*.xlsx》路径}
+        {--opening-date= : 期初日期，默认读取配置}
+        {--recalculate : 导入后立即重算每日流水}';
+
+    protected $description = '导入财务台账的账户、店铺、公司、期初余额（全量覆盖）';
+
+    public function handle(FinanceLedgerBaseImporter $importer): int
+    {
+        try {
+            $result = $importer->import(
+                (string) $this->argument('path'),
+                $this->option('opening-date') ?: null,
+            );
+        } catch (Throwable $exception) {
+            $this->error($exception->getMessage());
+
+            return self::FAILURE;
+        }
+
+        $this->table(['项目', '数量/金额'], [
+            ['账户', $result['accounts']],
+            ['店铺', $result['shops']],
+            ['公司', $result['companies']],
+            ['期初账户', $result['opening_rows']],
+            ['期初合计', number_format($result['opening_sum'], 2)],
+            ['账户余额合计', number_format($result['account_balance_sum'], 2)],
+            ['期初日期', $result['opening_date']],
+        ]);
+
+        if ($this->option('recalculate')) {
+            $this->call('finance-ledger:recalculate');
+        }
+
+        $this->info('财务台账基础数据导入完成。');
+
+        return self::SUCCESS;
+    }
+}

app/Console/Commands/ImportFinanceLedgerSnapshot.php

@@ -0,0 +1,42 @@
+<?php
+
+namespace App\Console\Commands;
+
+use Illuminate\Console\Command;
+use Modules\EcommerceFinance\Services\FinanceLedgerSnapshotImporter;
+use Throwable;
+
+class ImportFinanceLedgerSnapshot extends Command
+{
+    protected $signature = 'finance-ledger:import-snapshot
+        {path : 已核对的 ledger_raw.json 路径}
+        {--no-recalculate : 只导入明细，不重算流水}';
+
+    protected $description = '导入财务台账动账明细快照（本地开发或首次建账使用）';
+
+    public function handle(FinanceLedgerSnapshotImporter $importer): int
+    {
+        try {
+            $result = $importer->import(
+                (string) $this->argument('path'),
+                ! $this->option('no-recalculate'),
+            );
+        } catch (Throwable $exception) {
+            $this->error($exception->getMessage());
+
+            return self::FAILURE;
+        }
+
+        $this->table(['项目', '值'], [
+            ['明细行数', $result['rows']],
+            ['收入合计', number_format($result['income'], 2)],
+            ['支出合计', number_format($result['expense'], 2)],
+            ['日期范围', $result['from'] . ' ~ ' . $result['to']],
+            ['每日流水行数', $result['recalculated']['flows'] ?? '-'],
+            ['期末余额合计', isset($result['recalculated']) ? number_format($result['recalculated']['balance_sum'], 2) : '-'],
+        ]);
+        $this->info('财务台账动账明细导入完成。');
+
+        return self::SUCCESS;
+    }
+}

app/Console/Commands/ImportInventoryInboundDetail.php

@@ -2,11 +2,9 @@
 
 namespace App\Console\Commands;
 
-use App\Models\Business\InventoryWarehouseNameMapping;
-use Carbon\CarbonImmutable;
+use App\Business\InventoryInboundDetailImporter;
 use Illuminate\Console\Command;
-use Illuminate\Support\Facades\DB;
-use PhpOffice\PhpSpreadsheet\IOFactory;
+use Throwable;
 
 /**
  * 进销存报表 → 入库明细数据：按原始 Excel 原样导入，仓库简称用仓库名称映射表按「仓库」唯一匹配。
@@ -17,194 +15,28 @@ class ImportInventoryInboundDetail extends Command
 
     protected $description = '导入进销存报表的入库明细数据';
 
-    public function handle(): int
+    public function handle(InventoryInboundDetailImporter $importer): int
     {
         $file = (string) $this->argument('file');
-        $connection = (string) config('upstream_mirrors.connection', 'business_mirror');
-        $table = 'inventory_inbound_detail_rows';
         $forcedMonth = trim((string) ($this->option('month') ?? ''));
-        $now = now();
 
-        $maps = $this->shortNameMap();
-        $this->info('仓库名称映射：仓库名 ' . count($maps['warehouse']) . ' 个、仓储方 ' . count($maps['provider']) . ' 个可唯一匹配');
+        try {
+            $result = $importer->import($file, $forcedMonth);
+            $this->info(sprintf(
+                '导入完成：%d 行，仓库简称匹配上 %d 行，跳过 %d 行；库中该表共 %d 行',
+                $result['imported'],
+                $result['mapped'],
+                $result['skipped'],
+                $result['total'],
+            ));
 
-        // 原样导入：以本次文件为准整体重建，不做去重、不做加工。
-        DB::connection($connection)->table($table)->delete();
+            return self::SUCCESS;
+        } catch (Throwable $exception) {
+            report($exception);
+            $this->error('入库明细导入失败：' . $exception->getMessage());
+            $this->warn('已保留上一版有效数据。');
 
-        $reader = IOFactory::createReaderForFile($file);
-        $reader->setReadDataOnly(true);
-        $sheet = $reader->load($file)->getSheet(0);
-
-        $batch = [];
-        $imported = 0;
-        $mapped = 0;
-        $skipped = 0;
-        foreach ($sheet->getRowIterator(2) as $row) {
-            $rowNumber = $row->getRowIndex();
-            $cells = [];
-            foreach ($row->getCellIterator('A', 'U') as $cell) {
-                $cells[] = $cell->getFormattedValue();
-            }
-            $warehouse = trim((string) ($cells[14] ?? ''));
-            $createdRaw = trim((string) ($cells[16] ?? ''));
-            if ($warehouse === '' && $createdRaw === '') {
-                $skipped++;
-                continue;
-            }
-
-            $month = $forcedMonth !== '' ? $forcedMonth : $this->monthOf($createdRaw);
-            if ($month === '') {
-                $skipped++;
-                continue;
-            }
-
-            // 一般用"仓库"匹配仓库简称；含"代发仓"字样的按"仓储方"匹配。
-            $shortName = '';
-            if ($warehouse !== '') {
-                $shortName = str_contains($warehouse, '代发仓')
-                    ? ($maps['provider'][$warehouse] ?? $maps['warehouse'][$warehouse] ?? '')
-                    : ($maps['warehouse'][$warehouse] ?? '');
-            }
-            if ($shortName !== '') {
-                $mapped++;
-            }
-
-            $batch[] = [
-                'report_month' => $month . '-01',
-                // 唯一键按 Excel 行号生成，保留原表每一行（含重复行）。
-                'row_key' => sha1($month . '|' . $rowNumber),
-                'source_no' => $this->text($cells[0] ?? ''),
-                'document_no' => $this->text($cells[1] ?? ''),
-                'created_serial' => $this->text($cells[2] ?? ''),
-                'supplier' => $this->text($cells[3] ?? ''),
-                'item_no' => $this->text($cells[4] ?? ''),
-                'barcode' => $this->text($cells[5] ?? ''),
-                'spec_name' => $this->text($cells[6] ?? ''),
-                'quantity' => $this->number($cells[7] ?? ''),
-                'unit_price' => $this->number($cells[8] ?? ''),
-                'amount' => $this->number($cells[9] ?? ''),
-                'estimated_unit_price' => $this->number($cells[10] ?? ''),
-                'estimated_amount' => $this->number($cells[11] ?? ''),
-                'supplier_barcode' => $this->text($cells[12] ?? ''),
-                'remark' => $this->text($cells[13] ?? ''),
-                'warehouse' => $warehouse !== '' ? $warehouse : null,
-                'warehouse_short_name' => $shortName !== '' ? $shortName : null,
-                'created_at_raw' => $this->moment($createdRaw),
-                'express_name' => $this->text($cells[17] ?? ''),
-                'express_no' => $this->text($cells[18] ?? ''),
-                'not_sent' => $this->text($cells[19] ?? ''),
-                'owner_name' => $this->text($cells[20] ?? ''),
-                'imported_at' => $now,
-            ];
-            $imported++;
-
-            if (count($batch) >= 1000) {
-                DB::connection($connection)->table($table)->insertOrIgnore($batch);
-                $this->info('已写入 ' . $imported . ' 行');
-                $batch = [];
-            }
+            return self::FAILURE;
         }
-
-        if ($batch !== []) {
-            DB::connection($connection)->table($table)->insertOrIgnore($batch);
-        }
-
-        $this->info(sprintf(
-            '导入完成：%d 行，仓库简称匹配上 %d 行，跳过 %d 行；库中该表共 %d 行',
-            $imported,
-            $mapped,
-            $skipped,
-            DB::connection($connection)->table($table)->count(),
-        ));
-
-        return self::SUCCESS;
-    }
-
-    /**
-     * @return array{warehouse:array<string,string>,provider:array<string,string>}
-     *         仅保留能唯一匹配的键
-     */
-    private function shortNameMap(): array
-    {
-        $rows = InventoryWarehouseNameMapping::withoutGlobalScopes()
-            ->get(['warehouse_provider', 'warehouse', 'warehouse_short_name']);
-        $grouped = [];
-        foreach ($rows as $row) {
-            $warehouse = trim((string) $row->warehouse);
-            if ($warehouse === '') {
-                continue;
-            }
-            $grouped[$warehouse][] = trim((string) $row->warehouse_short_name);
-        }
-
-        $byWarehouse = [];
-        foreach ($grouped as $warehouse => $names) {
-            $unique = array_values(array_unique($names));
-            if (count($unique) === 1 && $unique[0] !== '') {
-                $byWarehouse[$warehouse] = $unique[0];
-            }
-        }
-
-        $byProvider = [];
-        foreach ($rows as $row) {
-            $provider = trim((string) $row->warehouse_provider);
-            if ($provider === '') {
-                continue;
-            }
-            $byProvider[$provider][] = trim((string) $row->warehouse_short_name);
-        }
-        foreach ($byProvider as $provider => $names) {
-            $unique = array_values(array_unique($names));
-            if (count($unique) === 1 && $unique[0] !== '') {
-                $byProvider[$provider] = $unique[0];
-            }
-        }
-
-        return ['warehouse' => $byWarehouse, 'provider' => $byProvider];
-    }
-
-    private function monthOf(string $value): string
-    {
-        $value = trim($value);
-        if ($value === '') {
-            return '';
-        }
-        foreach (['Y/m/d H:i:s', 'Y-m-d H:i:s', 'Y/m/d', 'Y-m-d'] as $format) {
-            $parsed = \DateTimeImmutable::createFromFormat($format, $value);
-            if ($parsed instanceof \DateTimeImmutable) {
-                return $parsed->format('Y-m');
-            }
-        }
-        $timestamp = strtotime($value);
-
-        return $timestamp === false ? '' : date('Y-m', $timestamp);
-    }
-
-    private function moment(string $value): ?string
-    {
-        $value = trim($value);
-        if ($value === '') {
-            return null;
-        }
-        $timestamp = strtotime($value);
-
-        return $timestamp === false ? null : date('Y-m-d H:i:s', $timestamp);
-    }
-
-    private function text(mixed $value): ?string
-    {
-        $text = trim((string) $value);
-
-        return $text === '' ? null : $text;
-    }
-
-    private function number(mixed $value): ?float
-    {
-        $text = str_replace(',', '', trim((string) $value));
-        if ($text === '' || ! is_numeric($text)) {
-            return null;
-        }
-
-        return (float) $text;
     }
 }

app/Console/Commands/ImportSupplierBookkeepingConfigs.php

@@ -0,0 +1,28 @@
+<?php
+
+namespace App\Console\Commands;
+
+use Illuminate\Console\Command;
+use Modules\EcommerceFinance\Services\SupplierBookkeepingConfigImporter;
+use Modules\EcommerceFinance\Services\SupplierBookkeepingConfigStore;
+
+class ImportSupplierBookkeepingConfigs extends Command
+{
+    protected $signature = 'supplier-bookkeeping:import-configs {file} {--dry-run : 仅检查文件并输出条数，不写入}';
+    protected $description = '导入财务提供的厂家记账配置 Excel（供应商、厂家是否记账）；新增/更新/跳过，任一行无法识别整批不写入';
+
+    public function handle(SupplierBookkeepingConfigImporter $importer, SupplierBookkeepingConfigStore $store): int
+    {
+        $path = (string) $this->argument('file');
+        $rows = $importer->read($path);
+        if ($this->option('dry-run')) {
+            $this->info('文件校验通过，共' . count($rows) . '条；未写入。');
+
+            return self::SUCCESS;
+        }
+        $result = $store->import($rows, '命令行导入', hash_file('sha256', $path));
+        $this->info("导入完成：新增{$result['added']}条，更新{$result['updated']}条，未变化{$result['skipped']}条。");
+
+        return self::SUCCESS;
+    }
+}

app/Console/Commands/RecalculateFinanceLedger.php

@@ -0,0 +1,35 @@
+<?php
+
+namespace App\Console\Commands;
+
+use Illuminate\Console\Command;
+use Modules\EcommerceFinance\Services\FinanceLedgerCalculator;
+use Throwable;
+
+class RecalculateFinanceLedger extends Command
+{
+    protected $signature = 'finance-ledger:recalculate';
+
+    protected $description = '重算财务台账的每日资金流水、账户余额和店铺余额';
+
+    public function handle(FinanceLedgerCalculator $calculator): int
+    {
+        try {
+            $result = $calculator->recalculate();
+        } catch (Throwable $exception) {
+            $this->error($exception->getMessage());
+
+            return self::FAILURE;
+        }
+
+        $this->table(['项目', '值'], [
+            ['账户数', $result['accounts']],
+            ['流水行数', $result['flows']],
+            ['期末余额合计', number_format($result['balance_sum'], 2)],
+            ['期初日期', $result['opening_date']],
+        ]);
+        $this->info('财务台账流水重算完成。');
+
+        return self::SUCCESS;
+    }
+}

app/Console/Commands/RefreshStoreReportPaidSales.php

@@ -0,0 +1,19 @@
+<?php
+
+namespace App\Console\Commands;
+
+use Illuminate\Console\Command;
+use Modules\EcommerceFinance\Services\StoreReportMirrorSynchronizer;
+
+class RefreshStoreReportPaidSales extends Command
+{
+    protected $signature = 'business-mirror:refresh-paid-sales {--full : 强制全量校准派生汇总}';
+    protected $description = '只刷新业绩明细派生的销量汇总，不修改原始财务明细';
+
+    public function handle(StoreReportMirrorSynchronizer $synchronizer): int
+    {
+        $result = $synchronizer->syncPaidSales((bool) $this->option('full'));
+        $this->info(json_encode($result));
+        return $result['status'] === 'succeeded' ? self::SUCCESS : self::FAILURE;
+    }
+}

app/Console/Commands/RunAccountBillsExportQueue.php

@@ -0,0 +1,24 @@
+<?php
+
+namespace App\Console\Commands;
+
+use Illuminate\Console\Command;
+use Modules\EcommerceFinance\Services\AccountBillsExportTasks;
+
+class RunAccountBillsExportQueue extends Command
+{
+    protected $signature = 'account-bills:exports:run {--max-jobs=1}';
+    protected $description = '依次消费账单导出任务，生产从受限批容器启动';
+
+    public function handle(AccountBillsExportTasks $tasks): int
+    {
+        $limit = max(0, (int) $this->option('max-jobs'));
+        for ($processed = 0; $limit === 0 || $processed < $limit; $processed++) {
+            $task = $tasks->nextQueued();
+            if ($task === null) break;
+            $code = $this->call('account-bills:export-run', ['token' => $task['token']]);
+            if ($code === 75) break;
+        }
+        return self::SUCCESS;
+    }
+}

app/Console/Commands/RunAccountBillsExportTask.php

@@ -28,6 +28,17 @@ class RunAccountBillsExportTask extends Command
     protected $description = '执行店铺收款账户账单导出任务（后台进程调用）';
 
     public function handle(AccountBillsExportTasks $tasks, AccountLedgerRemarkMap $remarkMap): int
+    {
+        $lock = \Illuminate\Support\Facades\Cache::store('upstream_shared')->lock('account-bills:export-worker', 10800);
+        if (! $lock->get()) return 75;
+        try {
+            return $this->runTask($tasks, $remarkMap);
+        } finally {
+            $lock->release();
+        }
+    }
+
+    private function runTask(AccountBillsExportTasks $tasks, AccountLedgerRemarkMap $remarkMap): int
     {
         $token = (string) $this->argument('token');
         $task = $this->findTask($tasks, $token);
@@ -36,6 +47,7 @@ class RunAccountBillsExportTask extends Command
 
             return self::FAILURE;
         }
+        if (($task['status'] ?? '') !== 'queued') return self::SUCCESS;
 
         $task = $tasks->patch($task, ['status' => 'running', 'started_at' => AccountBillsExportTasks::beijingNow()]);
 
@@ -110,7 +122,7 @@ class RunAccountBillsExportTask extends Command
 
     private function findTask(AccountBillsExportTasks $tasks, string $token): ?array
     {
-        $root = storage_path('app/account-bills-exports');
+        $root = $tasks->rootDir();
         foreach (glob($root . '/*/' . $token . '.json') ?: [] as $path) {
             $task = json_decode((string) file_get_contents($path), true);
             if (is_array($task) && ($task['token'] ?? null) === $token) {

app/Console/Commands/RunAccountMappingResync.php

@@ -0,0 +1,112 @@
+<?php
+
+namespace App\Console\Commands;
+
+use Illuminate\Console\Command;
+use Illuminate\Support\Facades\Cache;
+use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Facades\Log;
+use Modules\EcommerceFinance\Services\AccountMappingResyncDispatcher;
+use Symfony\Component\Process\Process;
+use Throwable;
+
+/**
+ * 科目映射表变更后的业绩明细自动重跑队列。
+ *
+ * 每轮按预算处理队列里的「平台 × 月份」；实际同步放在独立 PHP 子进程中，
+ * 避免大平台重跑时的内存累积，并让其它同步有机会取得全局锁。
+ */
+class RunAccountMappingResync extends Command
+{
+    protected $signature = 'store-receipt:auto-resync {--max-jobs=1 : 每轮最多任务数，0为不限} {--max-seconds=300 : 单个任务结束后检查本轮时间预算}';
+
+    protected $description = '处理科目映射表变更触发的业绩明细重跑队列';
+
+    public function handle(AccountMappingResyncDispatcher $dispatcher): int
+    {
+        // 页面（Apache）与每分钟 cron 都以 www-data 运行，使用共享数据库锁，
+        // 不受 storage/framework/cache 文件属主影响，也能避免多容器重复消费。
+        $lock = Cache::store('upstream_shared')->lock('store-receipt:auto-resync', 86400);
+        if (! $lock->get()) {
+            // 已有进程在跑；本次新入队的任务会在当前进程下一轮循环或每分钟兜底时执行。
+            return self::SUCCESS;
+        }
+
+        try {
+            // 进程崩溃遗留的 running 任务超过 60 分钟视为可重试。
+            DB::table(AccountMappingResyncDispatcher::JOBS_TABLE)
+                ->where('status', 'running')
+                ->where('updated_at', '<', now()->subMinutes(60))
+                ->update(['status' => 'pending', 'updated_at' => now()]);
+
+            $processed = 0;
+            $maxJobs = max(0, (int) $this->option('max-jobs'));
+            $deadline = microtime(true) + max(1, (int) $this->option('max-seconds'));
+            while (($maxJobs === 0 || $processed < $maxJobs) && microtime(true) < $deadline) {
+                $job = DB::table(AccountMappingResyncDispatcher::JOBS_TABLE)
+                    ->where('status', 'pending')
+                    ->orderBy('id')
+                    ->first();
+                if ($job === null) {
+                    break;
+                }
+                $processed++;
+
+                DB::table(AccountMappingResyncDispatcher::JOBS_TABLE)
+                    ->where('id', $job->id)
+                    ->where('status', 'pending')
+                    ->update([
+                        'status' => 'running',
+                        'attempts' => DB::raw('attempts + 1'),
+                        'updated_at' => now(),
+                    ]);
+
+                try {
+                    [$succeeded, $output] = $this->runSync($job);
+
+                    // 同步期间又保存了映射时，dispatchFor 已把状态改回 pending；
+                    // 这里只在仍为 running 时写 done，不能吞掉新请求。
+                    DB::table(AccountMappingResyncDispatcher::JOBS_TABLE)
+                        ->where('id', $job->id)
+                        ->where('status', 'running')
+                        ->update([
+                            'status' => $succeeded ? 'done' : 'failed',
+                            'message' => mb_substr(
+                                $output !== '' ? $output : ($succeeded ? 'OK' : '同步命令执行失败'),
+                                0,
+                                1000
+                            ),
+                            'updated_at' => now(),
+                        ]);
+                } catch (Throwable $exception) {
+                    Log::error('科目映射表自动重跑失败：' . $exception->getMessage());
+                    DB::table(AccountMappingResyncDispatcher::JOBS_TABLE)
+                        ->where('id', $job->id)
+                        ->where('status', 'running')
+                        ->update([
+                            'status' => 'failed',
+                            'message' => mb_substr($exception->getMessage(), 0, 1000),
+                            'updated_at' => now(),
+                        ]);
+                }
+            }
+        } finally {
+            $lock->release();
+        }
+
+        return self::SUCCESS;
+    }
+
+    /** @return array{bool,string} */
+    protected function runSync(object $job): array
+    {
+        $process = new Process([
+            PHP_BINARY ?: 'php', 'artisan', 'store-receipt:order-match:sync',
+            (string) $job->month, '--platform=' . $job->platform,
+        ], base_path());
+        $process->setTimeout(7200);
+        $process->run();
+
+        return [$process->isSuccessful(), trim($process->getOutput() . "\n" . $process->getErrorOutput())];
+    }
+}

app/Console/Commands/SyncFinanceLedgerRpt.php

@@ -0,0 +1,60 @@
+<?php
+
+namespace App\Console\Commands;
+
+use Illuminate\Console\Command;
+use Modules\EcommerceFinance\Services\FinanceLedgerRptSynchronizer;
+use Throwable;
+
+class SyncFinanceLedgerRpt extends Command
+{
+    protected $signature = 'finance-ledger:sync-rpt
+        {--from= : 业务日期起，默认读取配置}
+        {--to= : 业务日期止，默认读取配置或当天}
+        {--days= : 只拉取最近 N 天并合并到现有明细}
+        {--merge : 合并到现有明细，不删除历史}
+        {--no-recalculate : 只同步明细，不重算流水}';
+
+    protected $description = '从 AI 库 rpt 同步财务台账动账明细，并重算每日流水';
+
+    public function handle(FinanceLedgerRptSynchronizer $synchronizer): int
+    {
+        $days = (int) ($this->option('days') ?: 0);
+        $from = $this->option('from') ?: null;
+        $merge = (bool) $this->option('merge');
+        if ($days > 0) {
+            $from = now()->subDays(max(1, $days) - 1)->toDateString();
+            $merge = true;
+        }
+
+        try {
+            $result = $synchronizer->sync(
+                ! $this->option('no-recalculate'),
+                $from,
+                $this->option('to') ?: null,
+                $merge,
+            );
+        } catch (Throwable $exception) {
+            $this->error($exception->getMessage());
+
+            return self::FAILURE;
+        }
+
+        $this->table(['项目', '值'], [
+            ['明细行数', $result['rows']],
+            ['收入合计', number_format($result['income'], 2)],
+            ['支出合计', number_format($result['expense'], 2)],
+            ['日期范围', $result['from'] . ' ~ ' . $result['to']],
+            ['每日流水行数', $result['recalculated']['flows'] ?? '-'],
+            ['期末余额合计', isset($result['recalculated']) ? number_format($result['recalculated']['balance_sum'], 2) : '-'],
+        ]);
+
+        $this->line('来源分布：');
+        foreach (($result['source_counts'] ?? []) as $source => $count) {
+            $this->line('  ' . $source . ': ' . $count);
+        }
+        $this->info('财务台账 rpt 同步完成。');
+
+        return self::SUCCESS;
+    }
+}

app/Console/Commands/SyncJstOrderLabelItemCodes.php

@@ -142,7 +142,12 @@ class SyncJstOrderLabelItemCodes extends Command
 
         $params = array_merge($bindings, [$companyId], $orderNos, [$start, $end]);
 
-        return DB::connection()->update($sql, $params);
+        $updated = DB::connection()->update($sql, $params);
+        if ($updated > 0) {
+            app(\App\Business\PlantingOrderLabelLookup::class)->forget($companyId);
+        }
+
+        return $updated;
     }
 
     /** @return array{0:string,1:string} 起止日期（Y-m-d） */

app/Console/Commands/SyncJushuitanCostPriceHistory.php

@@ -6,12 +6,14 @@ use Illuminate\Console\Command;
 use Illuminate\Support\Facades\Log;
 use Modules\EcommerceFinance\Repositories\JushuitanCostPriceHistoryMirrorRepository;
 use Modules\EcommerceFinance\Services\JushuitanCostPriceHistorySynchronizer;
+use Modules\EcommerceFinance\Services\JushuitanCostPriceSnapshotDiffer;
 use Throwable;
 
 class SyncJushuitanCostPriceHistory extends Command
 {
     protected $signature = 'business-mirror:sync-jushuitan-cost-price-history
         {--full : 强制启动或继续首次全量同步}
+        {--source=open_api : open_api 为正式操作历史；snapshot 为独立的镜像价格观测}
         {--page-size= : 聚水潭接口每页读取条数，最大 50}
         {--max-pages= : 本轮最多读取页数，0 表示直到完成}';
 
@@ -25,6 +27,25 @@ class SyncJushuitanCostPriceHistory extends Command
             return self::SUCCESS;
         }
 
+        if ($this->option('source') === 'snapshot') {
+            try {
+                $result = app(JushuitanCostPriceSnapshotDiffer::class)->sync(
+                    $this->option('page-size') === null ? 500 : (int) $this->option('page-size'),
+                    $this->option('max-pages') === null ? 20 : (int) $this->option('max-pages'),
+                );
+                $this->info(sprintf('镜像价格观测：%s，本轮读取 %d 条，发现 %d 次价格变化；不代表完整操作历史。', $result['status'], $result['rows'], $result['changes']));
+                return self::SUCCESS;
+            } catch (Throwable $exception) {
+                Log::error('镜像价格观测失败。', ['exception' => $exception::class]);
+                $this->error('镜像价格观测失败，已保留基线、记录和续传游标。');
+                return self::FAILURE;
+            }
+        }
+        if ($this->option('source') !== 'open_api') {
+            $this->error('source 仅支持 open_api 或 snapshot。');
+            return self::FAILURE;
+        }
+
         try {
             $state = $mirror->state();
             $full = $this->shouldRunFull($state);

app/Console/Commands/SyncStoreReceiptProductCost.php

@@ -34,6 +34,28 @@ class SyncStoreReceiptProductCost extends Command
     /** 虚拟条码（信誉订单/虚拟订单）不是真实商品，不计入商品成本。 */
     private const VIRTUAL_SKU_PREFIX = 'X0000';
 
+    /** 套餐 / 服务及指定配件占位编码：不是实际成本商品，商品成本全局不取数。 */
+    private const EXCLUDED_SKUS = [
+        'TCXJ',
+        'FUWU',
+        'AZF',
+        'DF-PJZY0001',
+        'JIAXIANGJIANCAIJIAJUZIZHUANG964A',
+    ];
+
+    /** 组合装条码前缀；条码结构为「前缀-组件条码-数量-组件条码-数量」。 */
+    private const COMBO_PREFIXES = ['ZH-', 'MKH-'];
+
+    /**
+     * 发货仓库黑名单：这些仓不是实际销售发货仓，整仓不参与商品成本；
+     * 例外：常州简尚家居有限公司里商品编码以 DF- 开头的行保留。
+     */
+    private const EXCLUDED_WAREHOUSES = [
+        '常州简尚家居有限公司',
+        '简尚-苏州福利品仓',
+        '简尚-自动发货仓',
+    ];
+
     private const REMARK_NO_WAREHOUSE = '未匹配仓库简称';
 
     private const REMARK_NO_PRICE = '未匹配商品单价';
@@ -54,6 +76,9 @@ class SyncStoreReceiptProductCost extends Command
 
     private const PRICE_SOURCE_DING = '线上代发价格-代发单价';
 
+    /** 最后兜底：普通商品资料（operations_replica.rpt.jst_sku）里的成本价。 */
+    private const PRICE_SOURCE_CATALOG = '普通商品资料成本价';
+
     /** 线上代发价格的采购单来源（与「线上代发价格」页面同一口径）。 */
     private const PURCHASE_PRICE_TABLE = 'product_purchase_price_mirror_rows';
 
@@ -114,10 +139,15 @@ class SyncStoreReceiptProductCost extends Command
         // 账单侧取数：业绩明细里本月（可按平台限定）的账单行，一行 = 一个店铺的一个订单。
         // 只取「收入金额有数据且不为 0」的账单行：收入为 0 的行是补出来的优惠/冲减/无收款账单行，
         // 没有对应的收款商品，不参与商品成本。
+        // 「种菜金额」有数据（>0）的账单行整条排除，不参与匹配。
         $billQuery = $mirror->table(self::SOURCE_TABLE)
             ->where('report_month', $reportMonth)
             ->whereNotNull('income_amount')
-            ->where('income_amount', '!=', 0);
+            ->where('income_amount', '!=', 0)
+            ->where(static function ($query): void {
+                $query->whereNull('planting_amount')
+                    ->orWhere('planting_amount', '<=', 0);
+            });
         if ($platform !== '') {
             $billQuery->where('platform', $platform);
         }
@@ -166,20 +196,24 @@ class SyncStoreReceiptProductCost extends Command
         }
         $this->info('订单侧候选单号：' . count($candidates));
 
-        /** @var array<string,list<array{sku:string,qty:float,amount:float,warehouse:string}>> $lines */
+        /** @var array<string,list<array{sku:string,qty:float,amount:float,warehouse:string,o_id:string,parent_o_id:string,row_key:string,status:string}>> $lines */
         $lines = [];
+        $excludedSkuSql = "'" . implode("','", self::EXCLUDED_SKUS) . "'";
         foreach (self::SOURCES as $source) {
             try {
                 $rows = $mirror->select(
                     "SELECT o.so_id as so_id, "
                     . $source['warehouse'] . " as warehouse_code, "
                     . " COALESCE(wh.name, '') as warehouse_name, "
-                    . " i.sku_id as sku_id, i.qty as qty, i.amount as amount
+                    . " o.o_id as o_id, o.link_o_id as parent_o_id, "
+                    . " CONCAT(o.o_id, '-', i.oi_id) as row_key, "
+                    . " i.sku_id as sku_id, i.qty as qty, i.amount as amount, o.status as status
                      FROM tmp_cost_order_nos t
                      STRAIGHT_JOIN {$source['orders']} o ON o.so_id = t.no
                      STRAIGHT_JOIN {$source['items']} i ON i.o_id = o.o_id
                      LEFT JOIN ops_jst_warehouse_info wh ON wh.wms_co_id = o.wms_co_id
-                     WHERE COALESCE(i.sku_id, '') NOT LIKE 'X0000%'"
+                     WHERE COALESCE(i.sku_id, '') NOT LIKE 'X0000%'
+                       AND UPPER(TRIM(COALESCE(i.sku_id, ''))) NOT IN ({$excludedSkuSql})"
                 );
             } catch (Throwable $exception) {
                 $this->error('订单明细查询失败（' . $source['items'] . '）：' . $exception->getMessage());
@@ -210,13 +244,36 @@ class SyncStoreReceiptProductCost extends Command
                         $warehouse = '';
                     }
                 }
-                $lines[$core][] = [
-                    // 月加权平均单价表里的商品编码统一大写，订单侧可能小写，统一成大写再比。
-                    'sku' => mb_strtoupper($sku),
-                    'qty' => $qty,
-                    'amount' => $amount,
-                    'warehouse' => $warehouse,
-                ];
+
+                // 发货仓库过滤（在商品编码全局排除之后执行）：
+                // 默认排除常州简尚家居有限公司 / 简尚-苏州福利品仓 / 简尚-自动发货仓；
+                // 例外：常州简尚家居有限公司里「DF-」开头的商品行保留。
+                if (in_array($warehouse, self::EXCLUDED_WAREHOUSES, true)) {
+                    $isDfException = $warehouse === '常州简尚家居有限公司'
+                        && str_starts_with(mb_strtoupper($sku), 'DF-');
+                    if (! $isDfException) {
+                        continue;
+                    }
+                }
+
+                // 组合装条码（ZH-/MKH-条码-数量-条码-数量）按子订单拆成组件行：
+                // 一个订单有几个发货仓库、商品编码、数量就分开列，组件数量 = 明细数量 × 组件倍数。
+                // 解析不了的组合条码（条码被截断等）保持原样，避免丢行。
+                foreach (self::expandComboSku($sku, $qty) as [$code, $codeQty, $isComponent]) {
+                    $lines[$core][] = [
+                        // 月加权平均单价表里的商品编码统一大写，订单侧可能小写，统一成大写再比。
+                        'sku' => mb_strtoupper($code),
+                        'qty' => $codeQty,
+                        // 组合装明细金额对应整包，拆到组件后不再参与「数量×单价 vs 明细金额」校验。
+                        'amount' => $isComponent ? 0.0 : $amount,
+                        'warehouse' => $warehouse,
+                        // 拆单层级：o_id 与上级 link_o_id，用于只保留末级发货行（叶子行）。
+                        'o_id' => (string) $row->o_id,
+                        'parent_o_id' => (string) ($row->parent_o_id ?? ''),
+                        'status' => (string) ($row->status ?? ''),
+                        'row_key' => (string) $row->row_key,
+                    ];
+                }
             }
         }
         $this->info('订单侧命中核心单号：' . count($lines));
@@ -225,11 +282,14 @@ class SyncStoreReceiptProductCost extends Command
         $prices = $this->weightedAverageUnitPrices($mirror, $reportMonth);
         // 月加权平均单价匹配不到时，用「线上代发价格」（采购单价 / 钉钉代发单价）兜底。
         $fallbackPrices = $this->onlineDaifaUnitPrices($mirror);
+        // 代发价格也没有时，再用普通商品资料里的商品成本价兜底。
+        $catalogPrices = $this->catalogCostPrices($mirror);
         $this->info(sprintf(
-            '仓库映射条目：%d，月加权单价条目：%d，线上代发价格条目：%d',
+            '仓库映射条目：%d，月加权单价条目：%d，线上代发价格条目：%d，商品资料成本价条目：%d',
             count($shortNames['by_provider']),
             count($prices),
-            count($fallbackPrices)
+            count($fallbackPrices),
+            count($catalogPrices)
         ));
 
         $this->pruneTarget($connection, $reportMonth, $platform);
@@ -243,13 +303,17 @@ class SyncStoreReceiptProductCost extends Command
         $missingPriceRows = 0;
         $missingWarehouseRows = 0;
         $fallbackPriceRows = 0;
+        $catalogPriceRows = 0;
         $mismatchRows = 0;
 
         foreach ($billByCore as $core => $bill) {
+            // 展示单号与业绩明细完全一致；$core 只用于订单侧清洗后匹配。
+            $displayOrderNo = (string) ($bill->online_order_no ?? '');
+            if ($displayOrderNo === '') {
+                $displayOrderNo = $core;
+            }
             foreach ($this->costLines($lines[$core] ?? []) as $line) {
-                $short = $shortNames['by_warehouse'][$line['warehouse']]
-                    ?? $shortNames['by_provider'][$line['warehouse']]
-                    ?? '';
+                $short = $shortNames['by_provider'][$line['warehouse']] ?? '';
                 $price = $short !== '' ? ($prices[$short . "\0" . $line['sku']] ?? null) : null;
                 $priceSource = $price === null ? null : self::PRICE_SOURCE_WEIGHTED;
                 // 月加权平均单价按「仓库简称 + 商品编码」匹配不到时，退回线上代发价格（按商品编码）。
@@ -261,6 +325,15 @@ class SyncStoreReceiptProductCost extends Command
                         $fallbackPriceRows++;
                     }
                 }
+                // 线上代发价格也没有时，最后用普通商品资料的商品成本价兜底。
+                if ($price === null) {
+                    $catalogPrice = $catalogPrices[$line['sku']] ?? null;
+                    if ($catalogPrice !== null) {
+                        $price = $catalogPrice;
+                        $priceSource = self::PRICE_SOURCE_CATALOG;
+                        $catalogPriceRows++;
+                    }
+                }
                 $quantity = round($line['qty'], 4);
                 $unitPrice = $price === null ? null : round((float) $price, 2);
                 $cost = $unitPrice === null ? null : round($quantity * $unitPrice, 2);
@@ -302,7 +375,7 @@ class SyncStoreReceiptProductCost extends Command
                     'platform' => $bill->platform,
                     'occurred_date' => $bill->occurred_date,
                     'store_name' => $bill->store_name,
-                    'online_order_no' => $core,
+                    'online_order_no' => $displayOrderNo,
                     'warehouse' => $line['warehouse'] !== '' ? $line['warehouse'] : null,
                     'warehouse_short_name' => $short !== '' ? $short : null,
                     'product_code' => $line['sku'],
@@ -331,9 +404,10 @@ class SyncStoreReceiptProductCost extends Command
         $this->info(sprintf('  商品数量合计：%s', number_format($quantityTotal, 2)));
         $this->info(sprintf('  商品成本合计：%s', number_format($costTotal, 2)));
         $this->info(sprintf(
-            '  未匹配仓库简称：%d 行；线上代发价格兜底：%d 行；仍未匹配商品单价：%d 行；数量与单价口径不一致（不计成本）：%d 行',
+            '  未匹配仓库简称：%d 行；线上代发价格兜底：%d 行；商品资料成本价兜底：%d 行；仍未匹配商品单价：%d 行；数量与单价口径不一致（不计成本）：%d 行',
             $missingWarehouseRows,
             $fallbackPriceRows,
+            $catalogPriceRows,
             $missingPriceRows,
             $mismatchRows
         ));
@@ -342,11 +416,18 @@ class SyncStoreReceiptProductCost extends Command
     }
 
     /**
-     * 拆单去重：聚水潭的拆单子单会把主单的商品行再列一遍，同一批商品只算一次；
-     * 同一商品在同一订单里既有真实发货仓库行、又有无仓库的占位行时，丢掉占位行，
-     * 这样「同一单分多仓发货」会按子单的实际仓库分行。
+     * 拆单取数：聚水潭拆单后，主单/中间汇总单（被其他行 link 到的 o_id）只是汇总记录，
+     * 最末级订单行（没有任何下级）才是实际发货行。
      *
-     * @param  list<array{sku:string,qty:float,amount:float,warehouse:string}>  $rows
+     * 取数规则：
+     * 1) 按「o_id + oi_id + 商品编码」去掉完全重复行；
+     * 2) 只保留叶子行——凡是被同一订单其他行 link_o_id 引用过的 o_id 全部剔除，
+     *    避免主单、中间汇总层与末级发货行重复计数；
+     * 3) 订单内只要存在带仓库的行，就丢弃空仓库的汇总/占位行；
+     *    如果带仓库的行全部是 Cancelled，则整单不参与商品成本；
+     * 4) 排除 Cancelled 行，同一订单的多条末级行按「发货仓库 + 商品编码」汇总数量。
+     *
+     * @param  list<array{sku:string,qty:float,amount:float,warehouse:string,o_id:string,parent_o_id:string,row_key:string,status:string}>  $rows
      * @return list<array{sku:string,qty:float,amount:float,warehouse:string}>
      */
     private function costLines(array $rows): array
@@ -355,28 +436,54 @@ class SyncStoreReceiptProductCost extends Command
             return [];
         }
 
-        // 1) 完全相同的行（商品 + 数量 + 金额 + 仓库）只保留一条。
+        // 1) 先按订单明细主键去掉上游的完全重复行（同一 o_id + oi_id 只算一次）。
         $unique = [];
         foreach ($rows as $row) {
-            $key = $row['sku'] . "\0" . $row['qty'] . "\0" . $row['amount'] . "\0" . $row['warehouse'];
+            $key = $row['row_key'] . "\0" . $row['sku'];
             $unique[$key] = $row;
         }
 
-        // 2) 有真实仓库的同一（商品 + 数量 + 金额），优先于无仓库的占位行。
-        $withWarehouse = [];
+        // 2) 只保留叶子行：o_id 没有被同组其他行的 link_o_id 引用的，才是实际发货行。
+        $parentIds = [];
         foreach ($unique as $row) {
-            if ($row['warehouse'] !== '') {
-                $withWarehouse[$row['sku'] . "\0" . $row['qty'] . "\0" . $row['amount']] = true;
+            $parent = trim((string) ($row['parent_o_id'] ?? ''));
+            if ($parent !== '' && $parent !== '0') {
+                $parentIds[$parent] = true;
             }
         }
-        foreach ($unique as $key => $row) {
-            if ($row['warehouse'] === ''
-                && isset($withWarehouse[$row['sku'] . "\0" . $row['qty'] . "\0" . $row['amount']])) {
-                unset($unique[$key]);
+        if ($parentIds !== []) {
+            $leaves = array_filter(
+                $unique,
+                static fn (array $row): bool => ! isset($parentIds[trim((string) $row['o_id'])])
+            );
+            // 兜底：理论上不会出现全部被过滤（除非数据自相矛盾），真有则保留原集合避免整单丢失。
+            if ($leaves !== []) {
+                $unique = $leaves;
             }
         }
 
-        // 3) 汇总到「发货仓库 + 商品编码」。
+        // 3) 组内只要出现带仓库的行，空仓库行就是汇总/占位行，直接丢弃。
+        $hasWarehouse = false;
+        foreach ($unique as $row) {
+            if (trim((string) $row['warehouse']) !== '') {
+                $hasWarehouse = true;
+                break;
+            }
+        }
+        if ($hasWarehouse) {
+            $unique = array_filter(
+                $unique,
+                static fn (array $row): bool => trim((string) $row['warehouse']) !== ''
+            );
+        }
+
+        // 4) 排除已取消行；若带仓库行全部取消，上面已把空仓库汇总行丢掉，这里结果为空 → 整单不计。
+        $unique = array_filter(
+            $unique,
+            static fn (array $row): bool => strtoupper(trim((string) ($row['status'] ?? ''))) !== 'CANCELLED'
+        );
+
+        // 5) 汇总到「发货仓库 + 商品编码」。
         $aggregated = [];
         foreach ($unique as $row) {
             $key = $row['warehouse'] . "\0" . $row['sku'];
@@ -391,6 +498,62 @@ class SyncStoreReceiptProductCost extends Command
         return array_values($aggregated);
     }
 
+    /**
+     * 组合装条码拆组件：聚水潭的组合装 sku 形如
+     *   ZH-<条码>-<数量>[-<条码>-<数量>...]
+     *   MKH-<条码>-<数量>[-<条码>-<数量>...]
+     * 条码本身含横杠，所以按「纯数字段」识别数量，再按组件展开。
+     *
+     * 返回 [条码, 数量, 是否组件]；非组合装或解析失败时返回原条码 / 原数量。
+     *
+     * @return list<array{0:string,1:float,2:bool}>
+     */
+    private static function expandComboSku(string $sku, float $quantity): array
+    {
+        $prefix = null;
+        foreach (self::COMBO_PREFIXES as $candidate) {
+            if (str_starts_with(mb_strtoupper($sku), $candidate)) {
+                $prefix = $candidate;
+                break;
+            }
+        }
+        if ($prefix === null) {
+            return [[$sku, $quantity, false]];
+        }
+
+        $parts = explode('-', substr($sku, strlen($prefix)));
+        $components = [];
+        $buffer = [];
+        foreach ($parts as $part) {
+            if ($part === '') {
+                return [[$sku, $quantity, false]];
+            }
+            if (preg_match('/^\d+(\.\d+)?$/', $part) === 1) {
+                if ($buffer === []) {
+                    return [[$sku, $quantity, false]];
+                }
+                $components[] = [implode('-', $buffer), (float) $part];
+                $buffer = [];
+                continue;
+            }
+            $buffer[] = $part;
+        }
+        if ($buffer !== [] || $components === []) {
+            return [[$sku, $quantity, false]];
+        }
+
+        $expanded = [];
+        foreach ($components as [$code, $multiplier]) {
+            // 组合装里如果拆出套餐/服务占位编码，同样不取数。
+            if (in_array(mb_strtoupper(trim($code)), self::EXCLUDED_SKUS, true)) {
+                continue;
+            }
+            $expanded[] = [$code, $quantity * $multiplier, true];
+        }
+
+        return $expanded === [] ? [] : $expanded;
+    }
+
     /**
      * 仓库映射表：发货仓库 → 仓库简称。
      *
@@ -402,7 +565,6 @@ class SyncStoreReceiptProductCost extends Command
     private function warehouseShortNames(): array
     {
         $byProvider = [];
-        $byWarehouse = [];
         foreach (DB::table(self::WAREHOUSE_MAPPING_TABLE)
             ->get(['warehouse_provider', 'warehouse', 'warehouse_short_name']) as $mapping) {
             $provider = trim((string) $mapping->warehouse_provider);
@@ -411,19 +573,30 @@ class SyncStoreReceiptProductCost extends Command
             if ($short === '') {
                 continue;
             }
-            if ($warehouse !== '' && ! isset($byWarehouse[$warehouse])) {
-                $byWarehouse[$warehouse] = $short;
-            }
             if ($provider === '') {
                 continue;
             }
+            // 只认「仓储方 + 仓库含主仓」的那条：发货仓库是仓储方级别的名称，
+            // 次品仓 / 销退仓 / 客退仓这些行的简称（多为「-不看」）不能套到主仓发货上。
             $isMain = str_contains($warehouse, '主仓');
-            if ($isMain || ! isset($byProvider[$provider])) {
+            if ($isMain) {
+                $byProvider[$provider] = $short;
+                continue;
+            }
+            // 映射表没有主仓行时，仅接受「仓库名 = 仓储方名」这种同名仓库（如重庆渝北仓），
+            // 其余（次品仓、配件单仓等）不再兜底，避免把主仓订单误判成不看仓。
+            if ($warehouse === $provider && ! isset($byProvider[$provider])) {
+                $byProvider[$provider] = $short;
+                continue;
+            }
+            // 业务确认：常州简尚家居有限公司的发货仓对应映射表里的「配件单仓」行
+            // （仓储方=常州简尚家居有限公司 / 仓库=配件单仓 → 配件单仓-不看）。
+            if (str_contains($warehouse, '配件单仓') && ! isset($byProvider[$provider])) {
                 $byProvider[$provider] = $short;
             }
         }
 
-        return ['by_provider' => $byProvider, 'by_warehouse' => $byWarehouse];
+        return ['by_provider' => $byProvider];
     }
 
     /**
@@ -532,6 +705,32 @@ class SyncStoreReceiptProductCost extends Command
         return $prices;
     }
 
+    /**
+     * 普通商品资料（operations_replica.rpt.jst_sku → ops_jst_sku）里的商品成本价：
+     * 只取普通商品（sku_type=normal）且成本价大于 0 的记录，按商品编码建索引。
+     *
+     * @return array<string,float>
+     */
+    private function catalogCostPrices($mirror): array
+    {
+        $prices = [];
+        try {
+            foreach ($mirror->table('ops_jst_sku')
+                ->where('sku_type', 'normal')
+                ->where('cost_price', '>', 0)
+                ->get(['sku_id', 'cost_price']) as $row) {
+                $sku = mb_strtoupper(trim((string) $row->sku_id));
+                if ($sku !== '') {
+                    $prices[$sku] = round((float) $row->cost_price, 2);
+                }
+            }
+        } catch (Throwable $exception) {
+            $this->warn('普通商品资料成本价读取失败（跳过该兜底来源）：' . $exception->getMessage());
+        }
+
+        return $prices;
+    }
+
     private function pruneTarget(string $connection, string $reportMonth, string $platform): void
     {
         $query = DB::connection($connection)->table(self::TARGET_TABLE)->where('report_month', $reportMonth);

app/Console/Commands/SyncStoreReportPaidSales.php

@@ -7,7 +7,8 @@ use Modules\EcommerceFinance\Services\StoreReportMirrorSynchronizer;
 use Throwable;
 
 /**
- * 店铺维度报表的「销量」汇总：业绩明细「订单实付/实收金额」按「店铺名称 + 发生日期」预汇总。
+ * 店铺维度报表的「销量」汇总：业绩明细「收入金额 + 优惠金额 + 冲减金额 + 退款金额」
+ * 按「店铺名称 + 发生日期」预汇总。
  *
  * 业绩明细同步（store-receipt:order-match:sync）结束后会自动刷新一次；
  * 这个命令用于单独重跑（例如补数据或按最新代码强制重建）。
@@ -17,7 +18,7 @@ class SyncStoreReportPaidSales extends Command
     protected $signature = 'business-mirror:sync-store-report-paid-sales
         {--force : 忽略来源指纹，强制重建销量汇总}';
 
-    protected $description = '把业绩明细的订单实付/实收金额按店铺和发生日期汇总，供店铺维度报表销量列读取';
+    protected $description = '把业绩明细的收入/优惠/冲减/退款金额按店铺和发生日期汇总，供店铺维度报表销量列读取';
 
     public function handle(StoreReportMirrorSynchronizer $synchronizer): int
     {

app/Console/Commands/VerifyErpDailyBillCoverage.php

@@ -0,0 +1,172 @@
+<?php
+
+namespace App\Console\Commands;
+
+use Illuminate\Console\Command;
+use Illuminate\Support\Carbon;
+use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Facades\Schema;
+
+class VerifyErpDailyBillCoverage extends Command
+{
+    protected $signature = 'business-mirror:verify-erp-daily-coverage
+        {--from=2026-07-01 : 起始日期 YYYY-MM-DD}
+        {--to= : 截止日期 YYYY-MM-DD，默认昨日}
+        {--json : 输出 JSON}';
+
+    protected $description = '核对京东日账单、京东钱包、头条放心购的月份与截止日覆盖是否完整';
+
+    private const TARGETS = [
+        'jd-daily' => [
+            'label' => '京东日账单',
+            'periods' => 'jd_daily_bill_periods',
+            'rows' => 'jd_daily_bill_rows',
+        ],
+        'jd-wallet' => [
+            'label' => '京东钱包',
+            'periods' => 'jd_wallet_bill_periods',
+            'rows' => 'jd_wallet_bill_rows',
+        ],
+        'douyin' => [
+            'label' => '头条放心购',
+            'periods' => 'douyin_authoritative_periods',
+            'rows' => 'douyin_authoritative_bills',
+        ],
+    ];
+
+    public function handle(): int
+    {
+        $fromText = (string) $this->option('from');
+        $toText = (string) ($this->option('to') ?: now('Asia/Shanghai')->subDay()->toDateString());
+        $from = $this->date($fromText);
+        $to = $this->date($toText);
+
+        if ($from === null || $to === null || $from->gt($to)) {
+            $this->error('日期范围无效，应为 from <= to，格式 YYYY-MM-DD。');
+            return self::FAILURE;
+        }
+
+        $db = DB::connection(config('upstream_mirrors.connection', 'business_mirror'));
+        $schema = Schema::connection(config('upstream_mirrors.connection', 'business_mirror'));
+        $results = [];
+        $failed = false;
+
+        foreach (self::TARGETS as $key => $target) {
+            if (! $schema->hasTable($target['periods']) || ! $schema->hasTable($target['rows'])) {
+                $results[] = [
+                    'dataset' => $key,
+                    'label' => $target['label'],
+                    'month' => null,
+                    'required_start' => $from->toDateString(),
+                    'required_through' => $to->toDateString(),
+                    'imported_start' => null,
+                    'imported_end' => null,
+                    'row_count' => 0,
+                    'registered_rows' => null,
+                    'income' => null,
+                    'expense' => null,
+                    'status' => 'missing_table',
+                    'issue' => '镜像表不存在',
+                ];
+                $failed = true;
+                continue;
+            }
+
+            $month = $from->copy()->startOfMonth();
+            while ($month->lte($to)) {
+                $monthEnd = $month->copy()->endOfMonth();
+                $requiredStart = ($month->lt($from) ? $from->copy() : $month->copy())->startOfDay();
+                $requiredThrough = ($monthEnd->gt($to) ? $to->copy() : $monthEnd->copy())->startOfDay();
+                $requiredEndExclusive = $requiredThrough->copy()->addDay();
+                $period = $db->table($target['periods'])
+                    ->where('period_start', $month->toDateString())
+                    ->first();
+
+                $status = 'ok';
+                $rowCount = 0;
+                $issue = null;
+                $summary = null;
+
+                if ($period === null) {
+                    $status = 'missing_month';
+                    $issue = '缺少该月份导入记录';
+                } elseif (Carbon::parse((string) $period->period_end)->lt($requiredEndExclusive)) {
+                    $status = 'partial';
+                    $issue = '导入截止日早于要求日期';
+                } else {
+                    $summary = $db->table($target['rows'])
+                        ->where('generation', $period->active_generation)
+                        ->selectRaw('COUNT(*) AS rows_count, COALESCE(SUM(income), 0) AS income, COALESCE(SUM(expense), 0) AS expense')
+                        ->first();
+                    $rowCount = (int) ($summary->rows_count ?? 0);
+                    if ($rowCount === 0) {
+                        $status = 'empty';
+                        $issue = '有效版本没有明细';
+                    } elseif ($rowCount !== (int) $period->row_count) {
+                        $status = 'row_count_mismatch';
+                        $issue = '有效版本实际行数与期间登记不一致';
+                    } elseif (abs(round((float) $summary->income, 2) - (float) $period->income) > 0.005
+                        || abs(round((float) $summary->expense, 2) - (float) $period->expense) > 0.005) {
+                        $status = 'amount_mismatch';
+                        $issue = '有效版本收支合计与期间登记不一致';
+                    }
+                }
+
+                if ($status !== 'ok') {
+                    $failed = true;
+                }
+
+                $results[] = [
+                    'dataset' => $key,
+                    'label' => $target['label'],
+                    'month' => $month->format('Y-m'),
+                    'required_start' => $requiredStart->toDateString(),
+                    'required_through' => $requiredThrough->toDateString(),
+                    'imported_start' => $period?->period_start,
+                    'imported_end' => $period?->period_end,
+                    'row_count' => $rowCount,
+                    'registered_rows' => $period === null ? null : (int) $period->row_count,
+                    'income' => isset($summary) ? round((float) $summary->income, 2) : null,
+                    'expense' => isset($summary) ? round((float) $summary->expense, 2) : null,
+                    'status' => $status,
+                    'issue' => $issue,
+                ];
+
+                unset($summary);
+                $month->addMonthNoOverflow()->startOfMonth();
+            }
+        }
+
+        if ($this->option('json')) {
+            $this->line(json_encode($results, JSON_UNESCAPED_UNICODE | JSON_UNESCAPED_SLASHES));
+        } else {
+            $this->table(
+                ['数据集', '月份', '要求覆盖', '导入覆盖', '实际行数', '登记行数', '收入', '支出', '状态', '说明'],
+                array_map(static fn (array $row): array => [
+                    $row['label'],
+                    $row['month'] ?? '—',
+                    ($row['required_start'] ?? '—') . ' ~ ' . ($row['required_through'] ?? '—'),
+                    ($row['imported_start'] ?? '—') . ' ~ ' . ($row['imported_end'] ?? '—'),
+                    number_format((int) $row['row_count']),
+                    $row['registered_rows'] === null ? '—' : number_format((int) $row['registered_rows']),
+                    $row['income'] === null ? '—' : number_format((float) $row['income'], 2),
+                    $row['expense'] === null ? '—' : number_format((float) $row['expense'], 2),
+                    $row['status'],
+                    $row['issue'] ?? '',
+                ], $results),
+            );
+        }
+
+        return $failed ? self::FAILURE : self::SUCCESS;
+    }
+
+    private function date(string $value): ?Carbon
+    {
+        if (preg_match('/^\d{4}-\d{2}-\d{2}$/', $value) !== 1) {
+            return null;
+        }
+
+        $date = Carbon::createFromFormat('!Y-m-d', $value, 'Asia/Shanghai');
+        return $date !== false && $date->format('Y-m-d') === $value ? $date : null;
+    }
+}

app/Console/Commands/VerifyFinanceLedger.php

@@ -0,0 +1,70 @@
+<?php
+
+namespace App\Console\Commands;
+
+use Illuminate\Console\Command;
+use Illuminate\Support\Facades\DB;
+
+class VerifyFinanceLedger extends Command
+{
+    protected $signature = 'finance-ledger:verify';
+
+    protected $description = '校验财务台账数量、金额勾稽和流水平衡（只读）';
+
+    public function handle(): int
+    {
+        $db = DB::connection((string) config('upstream_mirrors.connection', 'business_mirror'));
+        $accounts = (int) $db->table('fin_accounts')->count();
+        $shops = (int) $db->table('fin_shops')->count();
+        $companies = (int) $db->table('fin_companies')->count();
+        $openingRows = (int) $db->table('fin_account_opening')->count();
+        $transactions = (int) $db->table('fin_transactions')->count();
+        $flows = (int) $db->table('fin_daily_flows')->count();
+        $maps = (int) $db->table('fin_account_map')->count();
+        $mapped = (int) $db->table('fin_account_map')->whereNotNull('account_short')->where('account_short', '<>', '')->count();
+
+        $accountBalance = round((float) $db->table('fin_accounts')->sum('current_balance'), 2);
+        $openingSum = round((float) $db->table('fin_account_opening')->sum('opening_balance'), 2);
+        $income = round((float) $db->table('fin_transactions')->sum('income'), 2);
+        $expense = round((float) $db->table('fin_transactions')->sum('expense'), 2);
+        $flowOpening = round((float) $db->table('fin_daily_flows')->sum('opening_balance'), 2);
+        $flowInflow = round((float) $db->table('fin_daily_flows')->sum('inflow'), 2);
+        $flowOutflow = round((float) $db->table('fin_daily_flows')->sum('outflow'), 2);
+        $flowClosing = round((float) $db->table('fin_daily_flows')->sum('closing_balance'), 2);
+        $diff = round($flowOpening + $flowInflow - $flowOutflow - $flowClosing, 2);
+
+        $this->table(['项目', '值'], [
+            ['账户', $accounts],
+            ['店铺', $shops],
+            ['公司', $companies],
+            ['期初账户', $openingRows],
+            ['期初合计', number_format($openingSum, 2)],
+            ['账户余额合计', number_format($accountBalance, 2)],
+            ['动账明细', $transactions],
+            ['收入合计', number_format($income, 2)],
+            ['支出合计', number_format($expense, 2)],
+            ['每日流水', $flows],
+            ['流水期末合计', number_format($flowClosing, 2)],
+            ['流水勾稽差异', number_format($diff, 2)],
+            ['映射记录', $maps],
+            ['已映射', $mapped],
+        ]);
+
+        $errors = [];
+        if (abs($openingSum - $accountBalance) > 0.01) {
+            $errors[] = '期初合计与账户余额合计不一致。';
+        }
+        if (abs($diff) > 0.01) {
+            $errors[] = '每日流水期末不等于期初+入账-出账。';
+        }
+        if ($openingRows !== $flows) {
+            $errors[] = '期初账户数与当前流水行数不一致（期初日应一账户一行）。';
+        }
+
+        foreach ($errors as $error) {
+            $this->error($error);
+        }
+
+        return $errors === [] ? self::SUCCESS : self::FAILURE;
+    }
+}

app/Console/Commands/WarmOrderDataShopCandidates.php

@@ -9,14 +9,14 @@ use Throwable;
 
 class WarmOrderDataShopCandidates extends Command
 {
-    protected $signature = 'order-data:warm-shop-candidates';
+    protected $signature = 'order-data:warm-shop-candidates {--full : 全量核对店铺候选（夜间维护）}';
 
-    protected $description = '预热订单售后费用明细的店铺候选（要扫两张百万级订单宽表，不能放在页面请求里）';
+    protected $description = '增量预热订单售后费用明细的店铺候选，夜间使用 --full 全量核对';
 
     public function handle(OrderDataMirrorRepository $orders): int
     {
         try {
-            $names = $orders->refreshShopNamesCache();
+            $names = $orders->refreshShopNamesCache((bool) $this->option('full'));
             $this->info(sprintf('店铺候选已预热，共 %d 个店铺。', count($names)));
 
             return self::SUCCESS;

app/Console/Kernel.php

@@ -76,6 +76,14 @@ class Kernel extends ConsoleKernel
             ->withoutOverlapping(30)
             ->runInBackground();
 
+        // 财务台账：从 AI 库 rpt 同步动账明细，按日重算账户流水。
+        // 生产宿主机 cron 仍需配置对应的 finance-ledger:sync-rpt 入口。
+        $schedule->command('finance-ledger:sync-rpt --days=7 --merge')
+            ->dailyAt('02:30')
+            ->timezone('Asia/Shanghai')
+            ->withoutOverlapping(120)
+            ->runInBackground();
+
         $schedule->command('business-mirror:sync-third-party-warehouse-storage --max-batches=0')
             ->dailyAt('00:00')
             ->withoutOverlapping(180)
@@ -88,12 +96,13 @@ class Kernel extends ConsoleKernel
                 ->runInBackground();
         }
 
-        // 聚水潭发货数据每日重拉最近三天，覆盖副本库迟到更新。
+        // 聚水潭发货数据：凌晨重拉最近 40 天。聚水潭常在发货后数天到数周内换单/改快递公司/作废采购退货出库，
+        // 只拉最近几天会让上月数据停在旧值(快递名称不一致、已作废的单仍在)；40 天覆盖上月结算期。
         // 默认关闭(JST_SYNC_ENABLED=false);填好凭证并完成迁移后再打开。
         if ((bool) env('JST_SYNC_ENABLED', false)) {
-            $schedule->command('jushuitan:sync-shipping --days=3')
+            $schedule->command('jushuitan:sync-shipping --days=40')
                 ->dailyAt('01:28')
-                ->withoutOverlapping(120)
+                ->withoutOverlapping(300)
                 ->runInBackground();
             // 凌晨副本库最近一两天的订单/商品明细常未到齐(视图、订单商品表滞后)，
             // 早上再拉一次最近 3 天，补齐凌晨只写入单号、缺商品明细的包裹。

app/Http/Controllers/Auth/DingTalkLogin.php

@@ -157,7 +157,10 @@ class DingTalkLogin extends Controller
 
         $url = $this->applicationRoute($user->landing_page, ['company_id' => $company->id]);
 
-        return redirect()->intended($url);
+        // 免登后固定回到首页（财务驾驶舱），不再回跳上次打开的业务页面。
+        $request->session()->forget('url.intended');
+
+        return redirect()->to($url);
     }
 
     protected function failed(): RedirectResponse

app/Http/Controllers/Auth/Login.php

@@ -107,8 +107,11 @@ class Login extends Controller
         // Redirect to landing page if is user
         $url = route($user->landing_page, ['company_id' => $company->id]);
 
+        // 登录后固定回到首页（财务驾驶舱），不再回跳上次打开/被拦截的业务页面。
+        $request->session()->forget('url.intended');
+
         if (! $request->expectsJson()) {
-            return redirect()->intended($url);
+            return redirect()->to($url);
         }
 
         return response()->json([
@@ -117,7 +120,7 @@ class Login extends Controller
             'error' => false,
             'message' => trans('auth.login_redirect'),
             'data' => null,
-            'redirect' => redirect()->intended($url)->getTargetUrl(),
+            'redirect' => url($url),
         ]);
     }
 

app/Http/Controllers/Business/AccountMappingActions.php

@@ -12,6 +12,7 @@ use Modules\EcommerceFinance\Services\AccountMappingCoa;
 use Modules\EcommerceFinance\Services\AccountMappingStore;
 use Modules\EcommerceFinance\Services\AccountMappingValidator;
 use Modules\EcommerceFinance\Services\AccountMappingWorkbookImporter;
+use Modules\EcommerceFinance\Services\AccountMappingResyncDispatcher;
 use RuntimeException;
 use Symfony\Component\HttpFoundation\StreamedResponse;
 
@@ -42,6 +43,7 @@ class AccountMappingActions extends Controller
         'memo' => '财务备注',
         'invoice' => '票据口径',
         'category' => '大类',
+        'feeMemo' => '费用备注',
         'dAcct' => '借方科目',
         'dSub' => '借方二级',
         'cAcct' => '贷方科目',
@@ -74,27 +76,37 @@ class AccountMappingActions extends Controller
 
         $this->store->create($values, $this->userId());
 
-        return response()->json(['message' => '已新增 1 条规则。'] + $this->payload());
+        $hint = $this->dispatchResync([(string) ($values['platform'] ?? '')]);
+
+        return response()->json(['message' => '已新增 1 条规则。' . $hint] + $this->payload());
     }
 
     public function update(Request $request, int $id): JsonResponse
     {
-        if ($this->store->find($id) === null) {
+        $before = $this->store->find($id);
+        if ($before === null) {
             throw ValidationException::withMessages(['id' => '这条规则已经不存在了，请刷新页面。']);
         }
 
-        $this->store->update($id, $this->payloadValues($request), $this->userId());
+        $values = $this->payloadValues($request);
+        $after = $this->store->update($id, $values, $this->userId());
 
-        return response()->json(['message' => '已保存。'] + $this->payload());
+        $hint = AccountMappingStore::requiresReceiptResync($before, $after)
+            ? $this->dispatchResync([(string) ($before['platform'] ?? ''), (string) ($after['platform'] ?? '')]) : '';
+
+        return response()->json(['message' => '已保存。' . $hint] + $this->payload());
     }
 
     public function destroy(int $id): JsonResponse
     {
+        $before = $this->store->find($id);
         if (! $this->store->destroy($id, $this->userId())) {
             throw ValidationException::withMessages(['id' => '这条规则已经不存在了，请刷新页面。']);
         }
 
-        return response()->json(['message' => '已删除 1 条规则。'] + $this->payload());
+        $hint = $this->dispatchResync([(string) ($before['platform'] ?? '')]);
+
+        return response()->json(['message' => '已删除 1 条规则。' . $hint] + $this->payload());
     }
 
     /**
@@ -181,21 +193,24 @@ class AccountMappingActions extends Controller
             }
 
             $restored = $this->store->create($before, $this->userId());
+            $hint = $this->dispatchResync([(string) ($restored['platform'] ?? '')]);
 
             return response()->json([
-                'message' => '已恢复「' . $restored['platform'] . ' · ' . $restored['item'] . '」（新记录 #' . (int) $restored['id'] . '）。',
+                'message' => '已恢复「' . $restored['platform'] . ' · ' . $restored['item'] . '」（新记录 #' . (int) $restored['id'] . '）。' . $hint,
             ] + $this->payload());
         }
 
         if ($action === 'update') {
-            if ($this->store->find($ruleId) === null) {
+            $current = $this->store->find($ruleId);
+            if ($current === null) {
                 throw ValidationException::withMessages(['history' => '这条规则已经被删掉了，请用同一条的「删除」记录恢复。']);
             }
 
             $this->store->update($ruleId, $before, $this->userId());
+            $hint = $this->dispatchResync([(string) ($current['platform'] ?? ''), (string) ($before['platform'] ?? '')]);
 
             return response()->json([
-                'message' => '已恢复成这次修改前的内容（记录 #' . $ruleId . '）。',
+                'message' => '已恢复成这次修改前的内容（记录 #' . $ruleId . '）。' . $hint,
             ] + $this->payload());
         }
 
@@ -227,6 +242,8 @@ class AccountMappingActions extends Controller
         $parsed = $this->importer->parse($file);
         $result = $this->store->importRows($parsed['rows'], $request->boolean('overwrite'), $this->userId());
         $message = "导入完成：识别 {$result['total']} 行，新增 {$result['created']} 条，更新 {$result['updated']} 条，跳过重复 {$result['skipped']} 条。";
+        $platforms = $result['resync_platforms'];
+        $message .= $this->dispatchResync($platforms);
 
         return response()->json(['message' => $message, 'result' => $result] + $this->payload());
     }
@@ -302,7 +319,7 @@ class AccountMappingActions extends Controller
     {
         $total = $this->store->reset($this->userId());
 
-        return response()->json(['message' => "已恢复为初始 {$total} 条规则。"] + $this->payload());
+        return response()->json(['message' => "已恢复为初始 {$total} 条规则。" . $this->dispatchResyncAll()] + $this->payload());
     }
 
     /** 账套科目（一级 + 各一级下的明细），供下拉使用 */
@@ -353,8 +370,8 @@ class AccountMappingActions extends Controller
     public function template(): StreamedResponse
     {
         $samples = [
-            ['得物', '平台服务费', '平台服务费', '0.06', '费用', '销售费用', '平台佣金', '其他货币资金', '', '支出基准'],
-            ['淘宝', '交易收入', '订单', '-', '收入', '其他货币资金', '', '主营业务收入', '', '收入基准'],
+            ['得物', '平台服务费', '平台服务费', '-', '0.06', '费用', '平台服务费', '销售费用', '平台服务费', '其他货币资金', '', '支出基准'],
+            ['淘宝', '交易收入', '订单', '-', '-', '收入', '收入', '其他货币资金', '', '主营业务收入', '', '收入基准'],
         ];
 
         return response()->streamDownload(function () use ($samples): void {
@@ -406,6 +423,44 @@ class AccountMappingActions extends Controller
         return user_id() ? (int) user_id() : null;
     }
 
+    /**
+     * 保存映射后把受影响的平台排进后台重跑队列。
+     *
+     * 映射表本身是实时读取的，但业绩明细的优惠/冲减/退款金额是同步时落库的，
+     * 所以保存成功后需要自动重跑对应平台和月份。队列创建失败不能把已经保存成功的规则回滚。
+     *
+     * @param list<string> $platforms
+     */
+    private function dispatchResync(array $platforms): string
+    {
+        try {
+            $result = app(AccountMappingResyncDispatcher::class)->dispatchFor($platforms);
+        } catch (\Throwable $exception) {
+            report($exception);
+
+            return ' 业绩明细自动重跑任务创建失败，请稍后重试保存或联系管理员。';
+        }
+
+        return $result['jobs'] > 0
+            ? " 业绩明细已自动排队重跑：{$result['jobs']} 个平台×月份任务，后台依次执行。"
+            : '';
+    }
+
+    private function dispatchResyncAll(): string
+    {
+        try {
+            $result = app(AccountMappingResyncDispatcher::class)->dispatchAll();
+        } catch (\Throwable $exception) {
+            report($exception);
+
+            return ' 业绩明细自动重跑任务创建失败，请稍后重试或联系管理员。';
+        }
+
+        return $result['jobs'] > 0
+            ? " 业绩明细已自动排队重跑：{$result['jobs']} 个平台×月份任务，后台依次执行。"
+            : '';
+    }
+
     /**
      * 原始操作记录 + 页面/CSV 直接可用的字段（变更内容与操作人只在服务端算一次）。
      *

app/Http/Controllers/Business/PlantingWorkOrders.php

@@ -0,0 +1,84 @@
+<?php
+
+namespace App\Http\Controllers\Business;
+
+use Illuminate\Routing\Controller;
+use Modules\EcommerceFinance\Services\PlantingLossCalculator;
+use Modules\EcommerceFinance\View\PlantingLossPageData;
+use Modules\EcommerceFinance\View\PlantingReimbursementPageData;
+
+/** 种菜数据汇总：种菜报销 / 种菜损耗 导出（与页面同一筛选口径）。 */
+class PlantingWorkOrders extends Controller
+{
+    public function exportReimbursements(PlantingReimbursementPageData $data)
+    {
+        $filters = $data->filters();
+
+        return $this->csv(
+            PlantingReimbursementPageData::TITLE . '-' . $filters['month'],
+            $data->exportColumns(),
+            static fn () => $data->rows($filters),
+        );
+    }
+
+    public function exportLoss(PlantingLossPageData $data)
+    {
+        $filters = $data->filters();
+        $suffix = match ($filters['result']) {
+            PlantingLossCalculator::RESULT_EXEMPT => '-不扣款拍A发B',
+            PlantingLossCalculator::RESULT_FREE_GOODS => '-不扣款虚拟条码挂钩',
+            PlantingLossCalculator::RESULT_UNMATCHED => '-未匹配发货',
+            'all' => '-全部',
+            default => '-扣款',
+        };
+
+        // 发运营的拍A发B 名单直接按「种菜报销」的字段导出。
+        if (request()->query('format') === 'reimbursement') {
+            return $this->csv(
+                '拍A发B发运营-' . $filters['month'],
+                PlantingReimbursementPageData::COLUMNS,
+                static fn () => $data->rows($filters),
+            );
+        }
+
+        return $this->csv(
+            PlantingLossPageData::TITLE . '-' . $filters['month'] . $suffix,
+            $data->exportColumns(),
+            static fn () => $data->rows($filters),
+        );
+    }
+
+    /** @param array<string,string> $columns @param callable():iterable<array<string,mixed>> $rows */
+    private function csv(string $name, array $columns, callable $rows)
+    {
+        $file = tmpfile();
+        abort_if($file === false, 500, '无法创建导出文件。');
+
+        try {
+            fwrite($file, "\xEF\xBB\xBF");
+            fputcsv($file, array_values($columns));
+            foreach ($rows() as $row) {
+                $values = [];
+                foreach (array_keys($columns) as $key) {
+                    $values[] = $row[$key] ?? '';
+                }
+                fputcsv($file, array_map(static function (mixed $value): string {
+                    $value = (string) $value;
+
+                    // 长数字单号/账号保留文本，避免 Excel 截断；同时阻止公式执行。
+                    return preg_match('/^[=+\-@\t\r\n]|^\d{12,}$/u', $value) ? "'" . $value : $value;
+                }, $values));
+            }
+            rewind($file);
+        } catch (\Throwable $exception) {
+            fclose($file);
+            report($exception);
+            abort(503, '聚工单镜像或发货数据未就绪，未生成不完整的导出文件，请稍后重试。');
+        }
+
+        return response()->streamDownload(static function () use ($file): void {
+            fpassthru($file);
+            fclose($file);
+        }, $name . '-' . now()->format('YmdHis') . '.csv', ['Content-Type' => 'text/csv; charset=UTF-8']);
+    }
+}

app/Http/Controllers/Business/SupplierBookkeeping.php

@@ -0,0 +1,44 @@
+<?php
+
+namespace App\Http\Controllers\Business;
+
+use Illuminate\Routing\Controller;
+use Modules\EcommerceFinance\View\SupplierBookkeepingPageData;
+
+class SupplierBookkeeping extends Controller
+{
+    public function export(SupplierBookkeepingPageData $data)
+    {
+        $filters = $data->filters();
+        $columns = $data->exportColumns();
+        $file = tmpfile();
+        abort_if($file === false, 500, '无法创建导出文件。');
+
+        try {
+            fwrite($file, "\xEF\xBB\xBF");
+            fputcsv($file, array_values($columns));
+            foreach ($data->rows($filters) as $row) {
+                $values = [];
+                foreach (array_keys($columns) as $key) {
+                    $values[] = $row[$key] ?? '';
+                }
+                fputcsv($file, array_map(static function (mixed $value): string {
+                    $value = (string) $value;
+
+                    // 长数字单号保留文本，避免 Excel 截断；同时阻止公式执行。
+                    return preg_match('/^[=+\-@\t\r\n]|^\d{12,}$/u', $value) ? "'" . $value : $value;
+                }, $values));
+            }
+            rewind($file);
+        } catch (\Throwable $exception) {
+            fclose($file);
+            report($exception);
+            abort(503, '聚工单镜像未就绪或读取失败，未生成不完整的厂家记账，请稍后重试。');
+        }
+
+        return response()->streamDownload(static function () use ($file): void {
+            fpassthru($file);
+            fclose($file);
+        }, SupplierBookkeepingPageData::TITLE . '-' . now()->format('YmdHis') . '.csv', ['Content-Type' => 'text/csv; charset=UTF-8']);
+    }
+}

app/Http/Controllers/Business/SupplierBookkeepingConfigs.php

@@ -0,0 +1,100 @@
+<?php
+
+namespace App\Http\Controllers\Business;
+
+use Illuminate\Http\Request;
+use Illuminate\Routing\Controller;
+use Illuminate\Validation\Rule as ValidationRule;
+use Modules\EcommerceFinance\Services\SupplierBookkeepingConfigImporter;
+use Modules\EcommerceFinance\Services\SupplierBookkeepingConfigStore;
+use Modules\EcommerceFinance\Services\SupplierBookkeepingDeductionRule as Rule;
+use Modules\EcommerceFinance\View\SupplierBookkeepingConfigPageData;
+use PhpOffice\PhpSpreadsheet\Cell\DataType;
+use PhpOffice\PhpSpreadsheet\Spreadsheet;
+use PhpOffice\PhpSpreadsheet\Writer\Xlsx;
+
+class SupplierBookkeepingConfigs extends Controller
+{
+    public function __construct(private readonly SupplierBookkeepingConfigStore $store) {}
+
+    public function store(Request $request)
+    {
+        $this->store->save($this->validated($request), $this->actor());
+
+        return $this->back('厂家记账配置已新增，厂家记账明细按新配置重新判定。');
+    }
+
+    public function update(Request $request, int $configId)
+    {
+        $this->store->save($this->validated($request), $this->actor(), $configId);
+
+        return $this->back('厂家记账配置已更新，厂家记账明细按新配置重新判定。');
+    }
+
+    public function destroy(int $configId)
+    {
+        $this->store->changeDeleted($configId, true, $this->actor());
+
+        return $this->back('配置已删除，该供应商视同不在配置表，按正常记账扣款。');
+    }
+
+    public function restore(int $configId)
+    {
+        $this->store->changeDeleted($configId, false, $this->actor());
+
+        return $this->back('厂家记账配置已恢复。');
+    }
+
+    public function import(Request $request, SupplierBookkeepingConfigImporter $importer)
+    {
+        $request->validate(['file' => ['required', 'file', 'mimes:xlsx', 'max:10240']]);
+        $path = $request->file('file')->getRealPath();
+        $result = $this->store->import($importer->read($path), $this->actor(), hash_file('sha256', $path));
+
+        return $this->back("导入完成：新增{$result['added']}条，更新{$result['updated']}条，未变化{$result['skipped']}条。");
+    }
+
+    public function export(SupplierBookkeepingConfigPageData $data)
+    {
+        $rows = $this->store->filtered($data->filters())->get();
+        $book = new Spreadsheet();
+        $sheet = $book->getActiveSheet();
+        $sheet->setTitle('厂家记账配置');
+        $sheet->fromArray([['供应商', '记账方式', '生效开始日期', '生效结束日期', '原始说明', '创建人', '更新时间', '删除状态']]);
+        foreach ($rows as $index => $row) {
+            $values = [$row->supplier_name, Rule::MODES[$row->mode] ?? $row->mode, $row->effective_from, $row->effective_to, $row->source_text, $row->creator, $row->updated_at, $row->deleted_at ? '已删除' : '正常'];
+            foreach ($values as $column => $value) {
+                $sheet->setCellValueExplicit([$column + 1, $index + 2], (string) $value, DataType::TYPE_STRING);
+            }
+        }
+        foreach (['A' => 24, 'B' => 20, 'C' => 14, 'D' => 14, 'E' => 44, 'F' => 16, 'G' => 20, 'H' => 10] as $column => $width) {
+            $sheet->getColumnDimension($column)->setWidth($width);
+        }
+        $sheet->freezePane('A2');
+
+        return response()->streamDownload(function () use ($book): void {
+            try { (new Xlsx($book))->save('php://output'); } finally { $book->disconnectWorksheets(); }
+        }, '厂家记账配置.xlsx', ['Content-Type' => 'application/vnd.openxmlformats-officedocument.spreadsheetml.sheet']);
+    }
+
+    private function validated(Request $request): array
+    {
+        return $request->validate([
+            'supplier_name' => ['required', 'string', 'max:191'],
+            'mode' => ['required', ValidationRule::in(array_keys(Rule::MODES))],
+            'effective_from' => ['nullable', 'date_format:Y-m-d'],
+            'effective_to' => ['nullable', 'date_format:Y-m-d', 'after_or_equal:effective_from'],
+            'source_text' => ['nullable', 'string', 'max:255'],
+        ], [], ['supplier_name' => '供应商', 'mode' => '记账方式', 'effective_from' => '生效开始日期', 'effective_to' => '生效结束日期', 'source_text' => '备注']);
+    }
+
+    private function actor(): string
+    {
+        return mb_substr((string) user()->name, 0, 191);
+    }
+
+    private function back(string $message)
+    {
+        return redirect()->route('business.pages.show', ['section' => 'supplier-payables', 'page' => 'manufacturer-bookkeeping', 'bk_view' => 'config'])->with('bookkeeping_config_message', $message);
+    }
+}

app/Http/Controllers/Business/SupplierManagement.php

@@ -2,26 +2,41 @@
 
 namespace App\Http\Controllers\Business;
 
+use Illuminate\Http\JsonResponse;
+use Illuminate\Http\RedirectResponse;
 use Illuminate\Http\Request;
 use Illuminate\Routing\Controller;
+use Illuminate\Validation\ValidationException;
 use Modules\EcommerceFinance\Repositories\SupplierManagementMirrorRepository;
+use Modules\EcommerceFinance\Services\SupplierFreeShippingStore;
+use Modules\EcommerceFinance\Services\SupplierFreeShippingWorkbook;
 use Modules\EcommerceFinance\View\SupplierManagementPageData;
+use Symfony\Component\HttpFoundation\StreamedResponse;
 
 class SupplierManagement extends Controller
 {
-    public function export(Request $request, SupplierManagementMirrorRepository $repository, SupplierManagementPageData $page)
-    {
+    public function export(
+        Request $request,
+        SupplierManagementMirrorRepository $repository,
+        SupplierManagementPageData $page,
+        SupplierFreeShippingStore $freeShipping,
+    ): StreamedResponse {
         abort_unless($repository->ready(), 503, '供应商资料尚未完成首次同步，暂时不能导出。');
         $filters = $page->filters($request->query());
+        $columns = SupplierManagementPageData::columns();
+        $companyId = (int) (company_id() ?: 1);
 
-        return response()->streamDownload(static function () use ($repository, $filters): void {
+        return response()->streamDownload(static function () use ($repository, $filters, $columns, $freeShipping, $companyId): void {
             $csv = fopen('php://output', 'w');
             fputs($csv, "\xEF\xBB\xBF");
-            fputcsv($csv, array_values(SupplierManagementMirrorRepository::COLUMNS));
+            fputcsv($csv, array_values($columns));
             foreach ($repository->exportRows($filters) as $row) {
+                $row = $freeShipping->decorateRow($row, $companyId);
                 $values = [];
-                foreach (array_keys(SupplierManagementMirrorRepository::COLUMNS) as $column) {
-                    $value = (string) ($row->{$column} ?? '');
+                foreach (array_keys($columns) as $column) {
+                    $value = $column === SupplierManagementPageData::FREE_SHIPPING_COLUMN
+                        ? ((bool) ($row->{$column} ?? false) ? '包邮' : '')
+                        : (string) ($row->{$column} ?? '');
                     if ($column === 'coopersgn') $value = ['1' => '合作', '2' => '不合作'][$value] ?? '未维护';
                     // Excel 不能执行供应商提供的公式文本，且长编码保留为文本。
                     if (preg_match('/^[=+\-@\t\r\n]/', ltrim($value)) || preg_match('/^\d{12,}$/', $value)) $value = "'" . $value;
@@ -33,4 +48,114 @@ class SupplierManagement extends Controller
         }, 'supplier_management_' . now()->format('Ymd_His') . '.csv',
             ['Content-Type' => 'text/csv; charset=UTF-8', 'Cache-Control' => 'private, no-store']);
     }
+
+    public function template(SupplierFreeShippingWorkbook $workbook): StreamedResponse
+    {
+        return $workbook->template();
+    }
+
+    public function import(
+        Request $request,
+        SupplierManagementMirrorRepository $repository,
+        SupplierFreeShippingStore $freeShipping,
+        SupplierFreeShippingWorkbook $workbook,
+    ): RedirectResponse {
+        $request->validate(['import' => ['required', 'file', 'mimes:xlsx,xls,csv', 'max:10240']]);
+        abort_unless($repository->ready(), 503, '供应商资料尚未完成首次同步，暂时不能导入。');
+
+        $valuesByCode = $workbook->read($request->file('import'));
+        $suppliers = $repository->suppliersByCodes(array_keys($valuesByCode));
+        $matched = [];
+        foreach ($suppliers as $supplier) {
+            $code = mb_strtolower(trim((string) ($supplier->scmcode ?? '')));
+            if ($code !== '') {
+                $matched[$code][] = $supplier;
+            }
+        }
+
+        $missing = [];
+        $ambiguous = [];
+        $valuesBySupplierId = [];
+        foreach ($valuesByCode as $code => $isFreeShipping) {
+            $key = mb_strtolower(trim((string) $code));
+            if (! isset($matched[$key])) {
+                $missing[] = (string) $code;
+                continue;
+            }
+            if (count($matched[$key]) !== 1) {
+                $ambiguous[] = (string) $code;
+                continue;
+            }
+            $valuesBySupplierId[(int) $matched[$key][0]->Id] = $isFreeShipping;
+        }
+        if ($ambiguous !== []) {
+            throw ValidationException::withMessages([
+                'import' => '以下供应商代码在供应商主档中存在多条记录，未导入：' . implode('、', array_slice($ambiguous, 0, 8)),
+            ]);
+        }
+        if ($missing !== []) {
+            throw ValidationException::withMessages([
+                'import' => '以下供应商代码未找到，未导入：' . implode('、', array_slice($missing, 0, 8))
+                    . (count($missing) > 8 ? ' 等 ' . count($missing) . ' 条' : ''),
+            ]);
+        }
+
+        $result = $freeShipping->saveMany(
+            $valuesBySupplierId,
+            (int) (company_id() ?: 1),
+            user_id() ? (int) user_id() : null,
+            'import',
+        );
+
+        return $this->redirectToPage($request)->with(
+            'supplier_management_message',
+            "导入完成：新增 {$result['created']} 家供应商维护记录，更新 {$result['updated']} 家供应商维护记录。",
+        );
+    }
+
+    public function updateFreeShipping(
+        Request $request,
+        int $supplier,
+        SupplierManagementMirrorRepository $repository,
+        SupplierFreeShippingStore $freeShipping,
+    ): JsonResponse|RedirectResponse {
+        $request->validate(['value' => ['nullable', 'string', 'in:,包邮']]);
+        abort_unless($repository->ready(), 503, '供应商资料尚未完成首次同步，暂时不能编辑。');
+        abort_if($repository->supplierById($supplier) === null, 404, '供应商不存在。');
+
+        $isFreeShipping = $request->input('value') === '包邮';
+        $freeShipping->save(
+            $supplier,
+            $isFreeShipping,
+            (int) (company_id() ?: 1),
+            user_id() ? (int) user_id() : null,
+            'manual',
+        );
+
+        if ($request->expectsJson()) {
+            return response()->json([
+                'ok' => true,
+                'value' => $isFreeShipping ? '包邮' : '',
+                'display' => $isFreeShipping ? '包邮' : '-',
+            ]);
+        }
+
+        return $this->redirectToPage($request)->with('supplier_management_message', '是否包邮厂家已保存。');
+    }
+
+    private function redirectToPage(Request $request): RedirectResponse
+    {
+        $query = array_filter([
+            ...app(SupplierManagementPageData::class)->filters($request->query()),
+            'page' => max((int) $request->query('page', 1), 1),
+        ], static fn (mixed $value): bool => $value !== '');
+
+        $url = route('business.pages.show', [
+            'company_id' => company_id() ?: 1,
+            'section' => 'supplier-payables',
+            'page' => 'supplier-management',
+        ]);
+
+        return redirect()->to($url . ($query === [] ? '' : '?' . http_build_query($query)));
+    }
 }

app/Http/Controllers/Business/SupplierPortal.php

@@ -0,0 +1,18 @@
+<?php
+
+namespace App\Http\Controllers\Business;
+
+use Illuminate\Http\RedirectResponse;
+use Illuminate\Routing\Controller;
+
+class SupplierPortal extends Controller
+{
+    public function home(): RedirectResponse
+    {
+        return redirect()->route('business.pages.show', [
+            'company_id' => company_id(),
+            'section' => 'supplier-reconciliation',
+            'page' => 'supplier-data',
+        ]);
+    }
+}

app/Http/Controllers/Business/SupplierReconciliation.php

@@ -2,10 +2,12 @@
 
 namespace App\Http\Controllers\Business;
 
+use App\Services\Auth\SupplierPortalAccess;
 use Illuminate\Http\JsonResponse;
 use Illuminate\Http\RedirectResponse;
 use Illuminate\Http\Request;
 use Illuminate\Routing\Controller;
+use Modules\EcommerceFinance\Services\SupplierComparisonCsvExporter;
 use Modules\EcommerceFinance\Services\SupplierDingTalkNotifier;
 use Modules\EcommerceFinance\Services\SupplierReturnCsvExporter;
 use Modules\EcommerceFinance\Services\SupplierReturnConfirmation;
@@ -29,6 +31,8 @@ class SupplierReconciliation extends Controller
         private readonly SupplierReconciliationPageData $pageData,
         private readonly SupplierReturnCsvExporter $returnCsvExporter,
         private readonly SupplierDingTalkNotifier $dingTalkNotifier,
+        private readonly SupplierComparisonCsvExporter $comparisonCsvExporter,
+        private readonly SupplierPortalAccess $supplierPortalAccess,
     ) {
         $this->middleware('auth');
         $this->middleware('company.identify');
@@ -46,13 +50,9 @@ class SupplierReconciliation extends Controller
     {
         $request->validate([
             'import' => ['required', 'file', 'mimes:xlsx,xls,csv', 'max:51200'],
-            'supplier' => ['required', 'string', 'max:191'],
         ]);
 
-        $supplier = trim((string) $request->input('supplier'));
-        if ($supplier === '') {
-            abort(422, '请选择厂家。');
-        }
+        $supplier = $this->effectiveSupplier($request);
 
         $records = $this->template->parse($request->file('import'), $supplier);
         $rows = $this->statements->save(
@@ -105,6 +105,23 @@ class SupplierReconciliation extends Controller
         return $this->returnCsvExporter->download($rows, $supplier);
     }
 
+    public function exportComparison(Request $request): StreamedResponse
+    {
+        $request->validate([
+            'month' => ['nullable', 'string', 'regex:/^\d{4}-\d{2}$/'],
+            'reconciler' => ['nullable', 'string', 'max:191'],
+        ]);
+        [$supplier, $companyId] = $this->returnTarget($request);
+        $detail = $this->pageData->financeDetailForFilters($supplier, $companyId, $request->query());
+
+        return $this->comparisonCsvExporter->download(
+            $detail,
+            $supplier,
+            trim((string) $request->query('month', '')),
+            trim((string) $request->query('reconciler', '')),
+        );
+    }
+
     public function saveDingTalkRobot(Request $request): RedirectResponse
     {
         $request->validate([
@@ -131,9 +148,10 @@ class SupplierReconciliation extends Controller
             'month' => ['nullable', 'string', 'regex:/^\d{4}-\d{2}$/'],
             'reconciler' => ['nullable', 'string', 'max:191'],
             'scope' => ['required', 'in:all,row,selected'],
+            'purchase_no' => ['nullable', 'string', 'max:191'],
+            'date' => ['nullable', 'string', 'max:32'],
             'barcode' => ['nullable', 'string', 'max:191'],
             'difference_type' => ['nullable', 'string', 'max:32'],
-            'unit_price' => ['nullable', 'numeric'],
             'selected_rows' => ['nullable', 'array', 'max:600'],
             'selected_rows.*' => ['string', 'max:2048'],
         ]);
@@ -145,14 +163,16 @@ class SupplierReconciliation extends Controller
         ));
 
         if ($request->input('scope') === 'row') {
+            $purchaseNo = trim((string) $request->input('purchase_no'));
+            $date = trim((string) $request->input('date'));
             $barcode = trim((string) $request->input('barcode'));
             $type = trim((string) $request->input('difference_type'));
-            $unitPrice = (float) $request->input('unit_price');
             $differences = array_values(array_filter(
                 $differences,
-                static fn (array $row): bool => (string) ($row['barcode'] ?? '') === $barcode
+                static fn (array $row): bool => (string) ($row['purchaseNo'] ?? '') === $purchaseNo
+                    && (string) ($row['date'] ?? '') === $date
+                    && (string) ($row['barcode'] ?? '') === $barcode
                     && (string) ($row['type'] ?? '') === $type
-                    && abs((float) ($row['unitPrice'] ?? 0) - $unitPrice) < 0.005,
             ));
         } elseif ($request->input('scope') === 'selected') {
             $selected = [];
@@ -191,9 +211,14 @@ class SupplierReconciliation extends Controller
     {
         $request->validate(['key' => ['required', 'string', 'max:191']]);
         [$supplier, $companyId] = $this->returnTarget($request);
+        $key = (string) $request->input('key');
+        $owned = collect($this->pageData->returnRows($supplier, $companyId))
+            ->contains(static fn (array $row): bool => (string) ($row['_action_key'] ?? '') === $key);
+        abort_unless($owned, 403, '该退货明细不属于当前厂家账号。');
+
         $this->returnConfirmations->mark(
             $supplier,
-            (string) $request->input('key'),
+            $key,
             $status,
             $companyId,
             user_id() ? (int) user_id() : null,
@@ -205,18 +230,34 @@ class SupplierReconciliation extends Controller
     /** @return array{0:string,1:int} */
     private function returnTarget(Request $request): array
     {
-        $request->validate(['supplier' => ['required', 'string', 'max:191']]);
+        return [$this->effectiveSupplier($request), (int) (company_id() ?: 1)];
+    }
 
-        return [trim((string) $request->input('supplier')), (int) (company_id() ?: 1)];
+    private function effectiveSupplier(Request $request): string
+    {
+        $user = $request->user();
+        if ($user && SupplierPortalAccess::isSupplierUser($user)) {
+            $supplier = $this->supplierPortalAccess->supplierFor($user);
+            abort_if(! $supplier, 403, '当前钉钉账号未绑定有效供应商，请联系财务人员。');
+
+            return $supplier;
+        }
+
+        $request->validate(['supplier' => ['required', 'string', 'max:191']]);
+        $supplier = trim((string) $request->input('supplier'));
+        abort_if($supplier === '', 422, '请选择厂家。');
+
+        return $supplier;
     }
 
     /** @param array<string,mixed> $row */
     private function differenceRowKey(array $row): string
     {
         return implode("\0", [
+            trim((string) ($row['purchaseNo'] ?? $row['purchase_no'] ?? '')),
+            trim((string) ($row['date'] ?? '')),
             trim((string) ($row['barcode'] ?? '')),
             trim((string) ($row['type'] ?? '')),
-            number_format((float) ($row['unitPrice'] ?? 0), 4, '.', ''),
         ]);
     }
 

app/Http/Middleware/EnsureLimitedDingTalkPageAccess.php

@@ -2,6 +2,7 @@
 
 namespace App\Http\Middleware;
 
+use App\Services\Auth\SupplierPortalAccess;
 use App\Utilities\SidebarPermissions;
 use Closure;
 use Illuminate\Http\Request;
@@ -12,7 +13,35 @@ class EnsureLimitedDingTalkPageAccess
     {
         $user = $request->user();
         $route = $request->route();
-        if (! $user || ! $route?->hasParameter('company_id') || ! SidebarPermissions::hasLimitedDingTalkAccess($user)) {
+        if (! $user || ! SidebarPermissions::hasLimitedDingTalkAccess($user)) {
+            return $next($request);
+        }
+
+        if (SupplierPortalAccess::isSupplierUser($user)) {
+            if ($route?->named('logout', 'business.supplier-portal.home')) {
+                return $next($request);
+            }
+            if ($route?->named('dashboard') && $route->hasParameter('company_id')) {
+                return redirect()->route('business.supplier-portal.home', [
+                    'company_id' => $route->parameter('company_id'),
+                ]);
+            }
+            if ($route?->named('business.pages.show')
+                && $route->parameter('section') === 'supplier-reconciliation'
+                && $route->parameter('page') === 'supplier-data') {
+                return $next($request);
+            }
+            foreach ($route?->gatherMiddleware() ?? [] as $middleware) {
+                if (is_string($middleware) && str_starts_with($middleware, 'business.page:')
+                    && str_replace(',', '/', substr($middleware, strlen('business.page:'))) === SupplierPortalAccess::PAGE_KEY) {
+                    return $next($request);
+                }
+            }
+
+            abort(403, '当前账号没有该页面权限。');
+        }
+
+        if (! $route?->hasParameter('company_id')) {
             return $next($request);
         }
 

app/Http/Middleware/LogoutIfDingTalkBindingRevoked.php

@@ -3,8 +3,9 @@
 namespace App\Http\Middleware;
 
 use App\Models\Auth\DingTalkIdentity;
-use App\Services\Auth\FinanceRoster;
 use App\Services\Auth\DingTalkClosedAccess;
+use App\Services\Auth\FinanceRoster;
+use App\Services\Auth\SupplierPortalAccess;
 use Closure;
 use Throwable;
 
@@ -15,7 +16,11 @@ class LogoutIfDingTalkBindingRevoked
         $identityId = $request->session()->get('dingtalk_identity_id');
         $user = $request->user();
         if (! $identityId) {
-            if (! $user || ! in_array($user->created_from, ['dingtalk_roster', 'dingtalk_roster_limited'], true)) {
+            if (! $user || ! in_array($user->created_from, [
+                'dingtalk_roster',
+                'dingtalk_roster_limited',
+                SupplierPortalAccess::CREATED_FROM,
+            ], true)) {
                 return $next($request);
             }
             // A password reset must not bypass HR eligibility for provisioned
@@ -32,7 +37,9 @@ class LogoutIfDingTalkBindingRevoked
                 return $next($request);
             }
             try {
-                $eligible = app(FinanceRoster::class)->findEligible((string) $identity->dingtalk_user_id);
+                $eligible = SupplierPortalAccess::isSupplierUser($user)
+                    ? app(SupplierPortalAccess::class)->revalidate($user) !== null
+                    : app(FinanceRoster::class)->findEligible((string) $identity->dingtalk_user_id);
             } catch (Throwable) {
                 // Retain the session during an HR outage, but do not serve data
                 // using an expired authorization decision.
@@ -46,7 +53,11 @@ class LogoutIfDingTalkBindingRevoked
         }
 
         app(DingTalkClosedAccess::class)->audit('session_revoked', 'denied', $user?->id, null, $identity?->union_id, $request, [
-            'reason' => ! $user?->enabled ? 'local_account_ineligible' : (! $identity ? 'binding_revoked' : 'outside_finance_roster'),
+            'reason' => ! $user?->enabled
+                ? 'local_account_ineligible'
+                : (! $identity
+                    ? 'binding_revoked'
+                    : (SupplierPortalAccess::isSupplierUser($user) ? 'outside_supplier_roster' : 'outside_finance_roster')),
         ]);
         auth()->logout();
         $request->session()->invalidate();

app/Listeners/Common/RequireImportBatchContainer.php

@@ -0,0 +1,28 @@
+<?php
+
+namespace App\Listeners\Common;
+
+use Illuminate\Console\Events\CommandStarting;
+use RuntimeException;
+
+class RequireImportBatchContainer
+{
+    public function handle(CommandStarting $event): void
+    {
+        if (! app()->environment('production') || config('finance_batch.container')) {
+            return;
+        }
+
+        $command = (string) $event->command;
+        $registered = in_array($command, config('finance_batch.import_commands', []), true);
+        // New import commands must be registered before they can run in production.
+        $isImport = preg_match('/(^|:)import(?:$|[-:])/', $command) === 1;
+
+        if ($registered || $isImport) {
+            throw new RuntimeException(
+                '生产重型导入必须在受限独立批处理容器中执行，请使用：sh /opt/caiwuxitong/run-finance-batch.sh '
+                . $command . ' <原参数>。网页容器未执行本次导入。'
+            );
+        }
+    }
+}

app/Listeners/Menu/ShowInAdmin.php

@@ -113,9 +113,13 @@ class ShowInAdmin
                 continue;
             }
 
+            $sectionPages = array_values(array_filter(
+                $section['pages'] ?? [],
+                static fn (array $page): bool => ($page['show_in_section_menu'] ?? true) !== false
+            ));
             $pages = $section['slug'] === 'order-data'
-                ? array_values($section['pages'] ?? [])
-                : $this->sortByTitleLength($section['pages'] ?? []);
+                ? $sectionPages
+                : $this->sortByTitleLength($sectionPages);
             $order = ($sectionIndex + 1) * 10;
 
             if (empty($pages) || in_array($section['slug'], self::WORKSPACE_SECTION_SLUGS, true)) {

app/Models/Auth/SupplierPortalIdentity.php

@@ -0,0 +1,28 @@
+<?php
+
+namespace App\Models\Auth;
+
+use Illuminate\Database\Eloquent\Model;
+
+class SupplierPortalIdentity extends Model
+{
+    protected $fillable = [
+        'company_id',
+        'user_id',
+        'supplier_code',
+        'supplier_name',
+        'dingtalk_group_id',
+        'dingtalk_group_name',
+        'last_verified_at',
+    ];
+
+    protected $casts = [
+        'dingtalk_group_id' => 'integer',
+        'last_verified_at' => 'datetime',
+    ];
+
+    public function user()
+    {
+        return $this->belongsTo(User::class);
+    }
+}

app/Models/Auth/User.php

@@ -83,6 +83,11 @@ class User extends Authenticatable implements HasLocalePreference
         return $this->hasOne(DingTalkIdentity::class, 'user_id');
     }
 
+    public function supplierPortalIdentity()
+    {
+        return $this->hasOne(SupplierPortalIdentity::class, 'user_id');
+    }
+
     public function contact()
     {
         return $this->hasOne('App\Models\Common\Contact', 'user_id', 'id');

app/Models/Business/CourierQuoteVersion.php

@@ -14,6 +14,7 @@ class CourierQuoteVersion extends Model
         'company_id', 'version_code', 'source_quote_id', 'source_change_id', 'sheet_name', 'company_name',
         'carrier_name', 'courier_expcode', 'billing_rules', 'quote_type', 'effective_date', 'end_date', 'source_range', 'values_json', 'formulas_json',
         'status', 'signature_status', 'created_by', 'approved_by', 'void_reason', 'voided_at', 'voided_by',
+        'billing_structure', 'billing_rows',
     ];
 
     public const STATUS_APPROVED = 'approved';
@@ -26,6 +27,8 @@ class CourierQuoteVersion extends Model
         'effective_date' => 'date',
         'end_date' => 'date',
         'voided_at' => 'datetime',
+        'billing_structure' => 'array',
+        'billing_rows' => 'array',
     ];
 
     /** 短期（临时）变价：有结束日期，到期后回到原来的长期报价。 */
@@ -56,6 +59,14 @@ class CourierQuoteVersion extends Model
             : $this->effective_date->toDateString() . ' 起';
     }
 
+    /** 是否已有可用于运费核算的结构化计费规则。 */
+    public function hasBillingRules(): bool
+    {
+        $mode = $this->billing_structure['mode'] ?? null;
+
+        return is_string($mode) && $mode !== 'other' && is_array($this->billing_rows) && $this->billing_rows !== [];
+    }
+
     public function isVoided(): bool
     {
         return $this->status === self::STATUS_VOIDED;

app/Providers/Event.php

@@ -46,6 +46,7 @@ class Event extends Provider
         ],
         //'Illuminate\Console\Events\ScheduledTaskStarting' => [
         \Illuminate\Console\Events\CommandStarting::class => [
+            \App\Listeners\Common\RequireImportBatchContainer::class,
             \App\Listeners\Common\SkipScheduleInReadOnlyMode::class,
         ],
         \App\Events\Auth\LandingPageShowing::class => [

app/Services/Auth/DingTalkClosedAccess.php

@@ -28,9 +28,13 @@ class DingTalkClosedAccess
         }
 
         $roster = app(FinanceRoster::class)->findEligible((string) ($profile['dingtalk_user_id'] ?? ''));
-        if (! $roster) {
+        $supplierRoster = $roster ? null : app(SupplierPortalAccess::class)->resolve(
+            (string) ($profile['dingtalk_user_id'] ?? ''),
+            (string) ($profile['union_id'] ?? ''),
+        );
+        if (! $roster && ! $supplierRoster) {
             $this->audit('login_denied', 'denied', null, null, $profile['union_id'] ?? null, $request, [
-                'reason' => 'outside_finance_roster',
+                'reason' => 'outside_authorized_roster',
             ]);
             $request->attributes->set('dingtalk_denial', 'outside_roster');
             return null;
@@ -49,6 +53,23 @@ class DingTalkClosedAccess
 
                 return null;
             }
+            if (SupplierPortalAccess::isSupplierUser($identity->user)) {
+                $company = $this->enabledCompany($identity->user);
+                if (! $supplierRoster || ! $company) {
+                    $this->audit('login_denied', 'denied', $identity->user_id, null, $profile['union_id'], $request, [
+                        'reason' => 'outside_supplier_roster',
+                    ]);
+
+                    return null;
+                }
+                app(SupplierPortalAccess::class)->bind($identity->user, (int) $company->id, $supplierRoster);
+            } elseif (! $roster) {
+                $this->audit('login_denied', 'denied', $identity->user_id, null, $profile['union_id'], $request, [
+                    'reason' => 'outside_finance_roster',
+                ]);
+
+                return null;
+            }
 
             $identity->forceFill([
                 'open_id' => $profile['open_id'] ?: $identity->open_id,
@@ -69,7 +90,7 @@ class DingTalkClosedAccess
             return null;
         }
 
-        return DB::transaction(function () use ($profile, $roster, $request): ?DingTalkIdentity {
+        return DB::transaction(function () use ($profile, $roster, $supplierRoster, $request): ?DingTalkIdentity {
             // Serialize first-time provisioning on the target company. Both the
             // account and unique identity are committed together, including retries.
             $companies = Company::enabled()
@@ -92,10 +113,11 @@ class DingTalkClosedAccess
                 return null;
             }
 
-            $roleName = FinanceRoster::isDesignatedSuperAdmin((string) $profile['dingtalk_user_id'])
+            $supplierPortal = $supplierRoster !== null;
+            $roleName = ! $supplierPortal && FinanceRoster::isDesignatedSuperAdmin((string) $profile['dingtalk_user_id'])
                 ? SystemAccess::SUPER_ADMIN : SystemAccess::USER;
             $role = Role::where('name', $roleName)->firstOrFail();
-            $email = $this->normalizeEmail($profile['email'] ?? null);
+            $email = $supplierPortal ? null : $this->normalizeEmail($profile['email'] ?? null);
             if (! $email || User::withTrashed()->where('email', $email)->exists()) {
                 $email = 'ding-'.hash('sha256', $profile['union_id']).'@dingtalk.invalid';
             }
@@ -104,21 +126,25 @@ class DingTalkClosedAccess
                 return null;
             }
             $account = User::create([
-                'name' => Str::limit($profile['nickname'] ?: $roster['display_name'], 191, ''),
+                'name' => Str::limit($profile['nickname'] ?: ($roster['display_name'] ?? '供应商人员'), 191, ''),
                 'email' => $email,
                 'password' => Str::random(64),
                 'locale' => 'zh-CN',
                 'enabled' => true,
-                'landing_page' => 'dashboard',
+                'landing_page' => $supplierPortal ? 'business.supplier-portal.home' : 'dashboard',
                 'created_by' => 0,
-                'created_from' => FinanceRoster::isLimitedLoginUser((string) $profile['dingtalk_user_id'])
-                    ? 'dingtalk_roster_limited' : 'dingtalk_roster',
+                'created_from' => $supplierPortal
+                    ? SupplierPortalAccess::CREATED_FROM
+                    : (FinanceRoster::isLimitedLoginUser((string) $profile['dingtalk_user_id'])
+                        ? 'dingtalk_roster_limited' : 'dingtalk_roster'),
             ]);
             $account->roles()->attach($role->id);
             // Explicit designation controls the role; ordinary roster users get shell access.
             $account->permissions()->attach(Permission::where('name', 'read-admin-panel')->firstOrFail()->id);
             $account->companies()->attach($companies->first()->id);
-            if ($mobile = $this->normalizeMobile($profile['mobile'] ?? null)) {
+            if ($supplierPortal) {
+                app(SupplierPortalAccess::class)->bind($account, (int) $companies->first()->id, $supplierRoster);
+            } elseif ($mobile = $this->normalizeMobile($profile['mobile'] ?? null)) {
                 Contact::create([
                     'company_id' => $companies->first()->id, 'type' => Contact::EMPLOYEE_TYPE,
                     'user_id' => $account->id, 'name' => $account->name, 'email' => $email,
@@ -131,7 +157,12 @@ class DingTalkClosedAccess
                 'open_id' => $profile['open_id'], 'dingtalk_user_id' => $profile['dingtalk_user_id'],
                 'nickname' => $profile['nickname'], 'bound_at' => now(),
             ]);
-            $this->upsertRequest($profile, DingTalkBindingRequest::APPROVED, 'finance_roster_provisioned', $account->id);
+            $this->upsertRequest(
+                $profile,
+                DingTalkBindingRequest::APPROVED,
+                $supplierPortal ? 'supplier_roster_provisioned' : 'finance_roster_provisioned',
+                $account->id,
+            );
             $this->audit('account_auto_created', 'success', $account->id, null, $profile['union_id'], $request);
             return $identity->load('user');
         }, 3);
@@ -165,9 +196,12 @@ class DingTalkClosedAccess
 
     private function isEligible(?User $user): bool
     {
-        return $user
-            && $user->enabled
-            && $user->withoutEvents(fn () => $user->companies()->enabled()->exists());
+        return $user && $user->enabled && $this->enabledCompany($user) !== null;
+    }
+
+    private function enabledCompany(User $user): ?Company
+    {
+        return $user->withoutEvents(fn () => $user->companies()->enabled()->first());
     }
 
     private function upsertRequest(array $profile, string $status, string $reason, ?int $matchedUserId): void

app/Services/Auth/SupplierPortalAccess.php

@@ -0,0 +1,194 @@
+<?php
+
+namespace App\Services\Auth;
+
+use App\Models\Auth\DingTalkIdentity;
+use App\Models\Auth\SupplierPortalIdentity;
+use App\Models\Auth\User;
+use Modules\EcommerceFinance\Repositories\SupplierManagementMirrorRepository;
+use Modules\EcommerceFinance\Services\UpstreamReadOnlyQueryFactory;
+
+/**
+ * 钉钉企业组织中的供应商成员映射。
+ *
+ * 只有当前有效的钉钉企业员工、且其部门祖先精确对应唯一供应商主档名称时，
+ * 才建立供应商门户身份。财务花名册不是供应商人员的准入前提。
+ */
+class SupplierPortalAccess
+{
+    public const CREATED_FROM = 'dingtalk_supplier_portal';
+
+    public const PAGE_KEY = 'supplier-reconciliation/supplier-data';
+
+    public function __construct(
+        private readonly UpstreamReadOnlyQueryFactory $queries,
+        private readonly SupplierManagementMirrorRepository $suppliers,
+    ) {
+    }
+
+    public static function isSupplierUser(User $user): bool
+    {
+        return $user->created_from === self::CREATED_FROM;
+    }
+
+    /** @return array{supplier_name:string,supplier_code:string,dingtalk_group_id:int,dingtalk_group_name:string}|null */
+    public function resolve(string $userId, string $unionId = ''): ?array
+    {
+        $userId = trim($userId);
+        $unionId = trim($unionId);
+        if ($userId === '') {
+            return null;
+        }
+
+        $query = $this->queries->forSource('operations_replica');
+        $employees = $query->select(
+            'SELECT TOP (2) userid, unionid, name, active, dept_id_list
+             FROM rpt.hr_employee WHERE userid = ?',
+            [$userId],
+        );
+        if (count($employees) !== 1 || ! (bool) ($employees[0]['active'] ?? false)) {
+            return null;
+        }
+        $employee = $employees[0];
+        $employeeUnionId = trim((string) ($employee['unionid'] ?? ''));
+        if ($employeeUnionId === '' || ($unionId !== '' && ! hash_equals($employeeUnionId, $unionId))) {
+            return null;
+        }
+
+        $departmentIds = $this->departmentIds($employee['dept_id_list'] ?? null);
+        if ($departmentIds === [] || count($departmentIds) > 64) {
+            return null;
+        }
+
+        $placeholders = implode(',', array_fill(0, count($departmentIds), '?'));
+        $ancestors = $query->select(
+            'WITH lineage AS (
+                SELECT Id, parent_id, name, 0 AS depth FROM rpt.hr_groups WHERE Id IN ('.$placeholders.')
+                UNION ALL
+                SELECT parent.Id, parent.parent_id, parent.name, child.depth + 1
+                FROM rpt.hr_groups parent JOIN lineage child ON parent.Id = child.parent_id
+                WHERE child.depth < 20
+             ) SELECT TOP (256) Id, parent_id, name, depth FROM lineage',
+            $departmentIds,
+        );
+        if ($ancestors === [] || count($ancestors) >= 256
+            || array_filter($ancestors, static fn (array $row): bool => (int) ($row['depth'] ?? 0) >= 20)) {
+            return null;
+        }
+
+        $groupsByName = [];
+        foreach ($ancestors as $ancestor) {
+            $name = trim((string) ($ancestor['name'] ?? ''));
+            if ($name !== '') {
+                $groupsByName[$name][] = $ancestor;
+            }
+        }
+        if ($groupsByName === []) {
+            return null;
+        }
+
+        $supplierRows = $this->suppliers->suppliersByNames(array_keys($groupsByName));
+        $matchedSupplierNames = [];
+        foreach ($supplierRows as $supplier) {
+            $name = trim((string) ($supplier->scmname ?? ''));
+            if ($name !== '' && isset($groupsByName[$name])) {
+                $matchedSupplierNames[$name] = true;
+            }
+        }
+        if (count($matchedSupplierNames) !== 1) {
+            return null;
+        }
+
+        $supplierName = (string) array_key_first($matchedSupplierNames);
+        $matchingRows = array_values(array_filter(
+            $supplierRows,
+            static fn (object $supplier): bool => trim((string) ($supplier->scmname ?? '')) === $supplierName,
+        ));
+        if (count($matchingRows) !== 1) {
+            return null;
+        }
+
+        usort($groupsByName[$supplierName], static fn (array $left, array $right): int =>
+            (int) ($right['depth'] ?? 0) <=> (int) ($left['depth'] ?? 0));
+        $group = $groupsByName[$supplierName][0];
+
+        return [
+            'supplier_name' => $supplierName,
+            'supplier_code' => trim((string) ($matchingRows[0]->scmcode ?? '')),
+            'dingtalk_group_id' => (int) ($group['Id'] ?? 0),
+            'dingtalk_group_name' => $supplierName,
+        ];
+    }
+
+    public function bind(User $user, int $companyId, array $resolved): SupplierPortalIdentity
+    {
+        return SupplierPortalIdentity::query()->updateOrCreate(
+            ['user_id' => $user->id],
+            [
+                'company_id' => $companyId,
+                'supplier_code' => $resolved['supplier_code'] ?? null,
+                'supplier_name' => $resolved['supplier_name'],
+                'dingtalk_group_id' => (int) $resolved['dingtalk_group_id'],
+                'dingtalk_group_name' => $resolved['dingtalk_group_name'],
+                'last_verified_at' => now(),
+            ],
+        );
+    }
+
+    public function mappingFor(User $user): ?SupplierPortalIdentity
+    {
+        if (! self::isSupplierUser($user)) {
+            return null;
+        }
+
+        return SupplierPortalIdentity::query()
+            ->where('user_id', $user->id)
+            ->where('company_id', company_id())
+            ->first();
+    }
+
+    public function supplierFor(User $user): ?string
+    {
+        $mapping = $this->mappingFor($user);
+        $name = trim((string) ($mapping?->supplier_name ?? ''));
+
+        return $name !== '' ? $name : null;
+    }
+
+    public function revalidate(User $user): ?SupplierPortalIdentity
+    {
+        if (! self::isSupplierUser($user)) {
+            return null;
+        }
+
+        $dingTalk = DingTalkIdentity::query()->where('user_id', $user->id)->first();
+        $company = $user->withoutEvents(fn () => $user->companies()->enabled()->first());
+        if (! $dingTalk || ! $company) {
+            return null;
+        }
+
+        $resolved = $this->resolve(
+            (string) $dingTalk->dingtalk_user_id,
+            (string) $dingTalk->union_id,
+        );
+
+        return $resolved ? $this->bind($user, (int) $company->id, $resolved) : null;
+    }
+
+    private function departmentIds(mixed $value): array
+    {
+        $value = trim((string) $value);
+        if ($value === '') {
+            return [];
+        }
+        $parts = json_decode($value, true);
+        if (! is_array($parts)) {
+            $parts = preg_split('/[\[\]\/>,，;；|｜\s]+/u', $value, -1, PREG_SPLIT_NO_EMPTY);
+        }
+
+        return array_values(array_filter(array_map(
+            static fn (mixed $id): string => is_scalar($id) ? trim((string) $id) : '',
+            is_array($parts) ? $parts : [],
+        ), static fn (string $id): bool => ctype_digit($id) && (int) $id > 0));
+    }
+}

app/Services/Esign/EsignClient.php

@@ -12,6 +12,18 @@ final class EsignClient
 
     private readonly EsignRequestSigner $signer;
 
+    /**
+     * 骑缝章中心的纵向坐标（PDF 坐标，原点在左下角，A4 高 841.89）。
+     * 按企业签署方顺序依次取用：第一家偏上、第二家居中偏下、第三家靠下。
+     * 相邻两枚间隔 200，大于骑缝章高度 120，叠页后各自完整、互不重叠。
+     */
+    private const ACROSS_PAGE_SEAL_Y = [620.0, 420.0, 220.0];
+
+    private const ACROSS_PAGE_SEAL_SIZE = '120';
+
+    /** @var array<string, int> 本实例上传过的文件 ID => 页数（0 表示未能识别）。 */
+    private array $pageCounts = [];
+
     public function __construct(?EsignConfiguration $configuration = null)
     {
         $configuration ??= EsignConfiguration::fromConfig();
@@ -77,6 +89,7 @@ final class EsignClient
         }
 
         $this->waitUntilFileReady($fileId);
+        $this->pageCounts[$fileId] = self::pdfPageCount($bytes);
 
         return $fileId;
     }
@@ -119,6 +132,7 @@ final class EsignClient
                     ],
                 ]],
             ]];
+        $signerPayload = $this->withAcrossPageSeals($fileId, $signerPayload);
 
         $docs = [[
                 'fileId' => $fileId,
@@ -160,6 +174,49 @@ final class EsignClient
         return $signFlowId;
     }
 
+    /**
+     * 给主文件上的每个企业签署方各加一个固定位置的骑缝签署区，并按顺序错开纵向位置。
+     *
+     * 原来骑缝章由签署人在自由签模式下自己添加，E 签宝把各方的骑缝章放在同一默认高度，
+     * 双方的章会叠在一起，看起来像盖了两遍。现在由系统预先放好，每方一个高度。
+     * 个人签署方不加骑缝；主文件少于 2 页或页数识别不出时也不加。
+     */
+    private function withAcrossPageSeals(string $fileId, array $signerPayload): array
+    {
+        if (($this->pageCounts[$fileId] ?? 0) < 2) {
+            return $signerPayload;
+        }
+
+        $orgOrder = 0;
+        foreach ($signerPayload as $index => $payload) {
+            if (($payload['signerType'] ?? null) !== 1) {
+                continue;
+            }
+            $positionY = self::ACROSS_PAGE_SEAL_Y[$orgOrder++] ?? null;
+            if ($positionY === null) {
+                break;
+            }
+            $signerPayload[$index]['signFields'][] = [
+                'fileId' => $fileId,
+                'normalSignFieldConfig' => [
+                    'freeMode' => false,
+                    'movableSignField' => false,
+                    'signFieldStyle' => 2,
+                    'signFieldSize' => self::ACROSS_PAGE_SEAL_SIZE,
+                    'signFieldPosition' => ['acrossPageMode' => 'ALL', 'positionY' => $positionY],
+                ],
+            ];
+        }
+
+        return $signerPayload;
+    }
+
+    /** 统计 PDF 页数：数 /Type /Page 对象（不含 /Pages）。系统生成的 dompdf 文件可直接识别；识别不出返回 0。 */
+    private static function pdfPageCount(string $bytes): int
+    {
+        return (int) preg_match_all('#/Type\s*/Page(?![a-zA-Z])#', $bytes);
+    }
+
     private function signerPayload(string $fileId, array $signer, int $index): array
     {
         $type = (int) ($signer['signer_type'] ?? 1);

app/Support/CourierQuoteFreightCalculator.php

@@ -0,0 +1,157 @@
+<?php
+
+namespace App\Support;
+
+use App\Models\Business\CourierQuoteVersion;
+use DateTimeInterface;
+use Illuminate\Support\Collection;
+
+/**
+ * 按「快递编码 + 发货日期」找到当天生效的报价版本，用结构化计费规则算一票的运费。
+ *
+ * 计费重量 = max(实重, 体积重, 起算重量) 再按取整方式处理；超过限重不计算。
+ *
+ * 生效版本的判断与报价管理页一致（CourierRequoteService::resolveAt：未作废、已审核或已签署归档、
+ * 执行期间覆盖发货日期，短期变价优先）。没有结构化规则的版本（按体积、按条码等特殊计费）返回原因，交人工核算。
+ */
+class CourierQuoteFreightCalculator
+{
+    /** @var array<string,Collection<int,CourierQuoteVersion>> */
+    private array $versions = [];
+
+    /**
+     * @param string $courierExpcode 快递编码；没有编码的存量报价可传快递名称（如「沐野竹木顺丰」）
+     * @return array{
+     *   version_code:?string,company_name:?string,region:?string,gross_weight:float,volume_weight:?float,
+     *   billable_weight:?float,base_amount:?float,surcharge:float,amount:?float,formula:?string,reason:?string
+     * }
+     */
+    public function calculate(
+        string $courierExpcode,
+        DateTimeInterface $shipDate,
+        string $province,
+        float $grossWeight,
+        ?float $length = null,
+        ?float $width = null,
+        ?float $height = null,
+        ?string $city = null,
+        ?string $quoteType = null,
+    ): array {
+        $result = [
+            'version_code' => null, 'company_name' => null, 'region' => null, 'gross_weight' => $grossWeight,
+            'volume_weight' => null, 'billable_weight' => null, 'base_amount' => null, 'surcharge' => 0.0,
+            'amount' => null, 'formula' => null, 'reason' => null,
+        ];
+        if (! is_finite($grossWeight) || $grossWeight < 0
+            || collect([$length, $width, $height])->contains(static fn ($v) => $v !== null && (! is_finite($v) || $v < 0))) {
+            return ['reason' => '重量和尺寸必须是有效非负数字'] + $result;
+        }
+
+        $version = $this->versionAt(trim($courierExpcode), $shipDate, $quoteType);
+        if ($version === null) {
+            return ['reason' => '发货日期没有生效的报价'] + $result;
+        }
+        $result['version_code'] = $version->version_code;
+        $result['company_name'] = $version->company_name;
+        if (! $version->hasBillingRules()) {
+            return ['reason' => '该报价为特殊计费或尚未设置计费规则，需人工核算'] + $result;
+        }
+
+        $structure = (array) $version->billing_structure;
+        $row = $this->matchRow((array) $version->billing_rows, $province, $city);
+        if ($row === null) {
+            return ['reason' => '报价未覆盖目的地「' . trim($province . ' ' . $city) . '」或该地区不发'] + $result;
+        }
+        $result['region'] = (string) $row['region'];
+
+        $divisor = (float) ($structure['volumetric_divisor'] ?? 0);
+        $volume = $divisor > 0 && $length > 0 && $width > 0 && $height > 0 ? round($length * $width * $height / $divisor, 4) : null;
+        $settlement = max($grossWeight, (float) $volume);
+        $result['volume_weight'] = $volume;
+        if ($settlement <= 0) {
+            return ['reason' => '缺少重量，无法计算运费'] + $result;
+        }
+
+        $limit = (float) ($structure['weight_limit'] ?? 0);
+        if ($limit > 0 && $settlement > $limit + 1e-9) {
+            return ['reason' => '超出限重 ' . CourierQuoteStructure::kg($limit) . 'kg'] + $result;
+        }
+
+        // 起算重量：不足按起算重量计（如菏泽顺帆顺丰不足 5kg 按 5kg）
+        $minimum = (float) ($structure['min_weight'] ?? 0);
+        $billable = CourierQuoteStructure::roundWeight(max($settlement, $minimum), (string) ($structure['rounding'] ?? 'none'));
+        $result['billable_weight'] = $billable;
+        $freight = CourierQuoteStructure::freight($structure, $row, $billable);
+        if ($freight['amount'] === null) {
+            return ['reason' => $freight['reason']] + $result;
+        }
+
+        $surcharge = (float) ($structure['per_ticket_surcharge'] ?? 0);
+        $result['base_amount'] = round($freight['amount'], 2);
+        $result['surcharge'] = $surcharge;
+        $result['amount'] = round($freight['amount'] + $surcharge, 2);
+        $result['formula'] = $freight['formula'] . ($surcharge > 0 ? '+每票' . CourierQuoteStructure::kg($surcharge) : '');
+
+        return $result;
+    }
+
+    /** 省份名统一：去掉省/市/自治区后缀，黑龙→黑龙江、内蒙→内蒙古。 */
+    public static function regionKey(string $name): string
+    {
+        $text = (string) preg_replace('/\s+/u', '', $name);
+        $text = (string) preg_replace('/(维吾尔自治区|壮族自治区|回族自治区|自治区|特别行政区|省|市)$/u', '', $text);
+
+        return match ($text) {
+            '黑龙' => '黑龙江',
+            '内蒙' => '内蒙古',
+            default => $text,
+        };
+    }
+
+    private function versionAt(string $courierExpcode, DateTimeInterface $date, ?string $quoteType): ?CourierQuoteVersion
+    {
+        if ($courierExpcode === '') {
+            return null;
+        }
+        // 先按快递编码；部分存量版本没有编码，按快递名称（与报价管理页的分组口径一致）
+        $cacheKey = company_id() . ':' . $courierExpcode;
+        $versions = $this->versions[$cacheKey] ??= CourierQuoteVersion::query()
+            ->with(['signature', 'change'])
+            ->where(static fn ($query) => $query->where('courier_expcode', $courierExpcode)
+                ->orWhere(static fn ($q) => $q->where(static fn ($e) => $e->whereNull('courier_expcode')->orWhere('courier_expcode', ''))
+                    ->where('company_name', $courierExpcode)))
+            ->get();
+
+        return CourierRequoteService::resolveAt(
+            $quoteType === null ? $versions : $versions->where('quote_type', $quoteType),
+            $date,
+        );
+    }
+
+    /**
+     * 先按城市匹配单列的城市行（如「深圳(广东)」），再按省份匹配。
+     *
+     * @param list<array<string,mixed>> $rows
+     * @return array<string,mixed>|null
+     */
+    private function matchRow(array $rows, string $province, ?string $city): ?array
+    {
+        $cityKey = self::regionKey((string) $city);
+        if ($cityKey !== '') {
+            foreach ($rows as $row) {
+                if (is_array($row) && preg_match('/^(.+?)[（(](.+?)[）)]$/u', trim((string) ($row['region'] ?? '')), $parts)
+                    && self::regionKey($parts[1]) === $cityKey && self::regionKey($parts[2]) === self::regionKey($province)) {
+                    return $row;
+                }
+            }
+        }
+        $key = self::regionKey($province);
+        foreach ($rows as $row) {
+            if (is_array($row) && self::regionKey((string) ($row['region'] ?? '')) === $key) {
+                return $row;
+            }
+        }
+
+        return null;
+    }
+}

app/Support/CourierQuoteStructure.php

@@ -40,6 +40,13 @@ final class CourierQuoteStructure
         'round' => '四舍五入（如 4.4kg 按 4kg，4.5kg 按 5kg）',
     ];
 
+    /**
+     * 分段计费：不放进 MODES（入驻表单不提供），只用于存量报价导入。
+     * 每个省份行为 {region, segments:[{lo, hi, type: flat|waybill|first_add, price|base, rate, fw}]}，
+     * 重量落在 (lo, hi]（第一段含 0）就按该段计算；hi 为 null 表示不封顶。
+     */
+    public const SEGMENTS = 'segments';
+
     public const MAX_BANDS = 12;
 
     public const MAX_TIERS = 6;
@@ -272,10 +279,120 @@ final class CourierQuoteStructure
                     ? "首重{$fw}kg价+(重量-{$fw})*续重"
                     : '面单+重量*费率') . $tierNote,
             'other' => '特殊计费，见附件报价表',
+            self::SEGMENTS => '分段计费：每个重量段单独设一口价、面单+费率或首重+续重（可表示累进计费）',
             default => '面单+重量*费率' . $tierNote,
         };
     }
 
+    /**
+     * 按结构化报价计算一票的基础运费（不含计泡、限重、附加费，这些由调用方先处理）。
+     *
+     * 与 describe() 口径一致：费率分段按「总重量所在区间」取费率，区间上限含本数；
+     * 一口价/费率为空表示该重量段不发。$weight 应为已取整的计费重量。
+     *
+     * @param array<string,mixed> $structure
+     * @param array<string,mixed> $row
+     * @return array{amount:?float,formula:?string,reason:?string}
+     */
+    public static function freight(array $structure, array $row, float $weight): array
+    {
+        $mode = (string) ($structure['mode'] ?? 'waybill_rate');
+        $none = static fn (string $reason): array => ['amount' => null, 'formula' => null, 'reason' => $reason];
+        $ok = static fn (float $amount, string $formula): array => ['amount' => round($amount, 4), 'formula' => $formula, 'reason' => null];
+        if (! is_finite($weight) || $weight <= 0) {
+            return $none('缺少有效重量，无法计算运费');
+        }
+        $w = self::kg($weight);
+        $within = static fn (float $value, float $edge): bool => $value <= $edge + 1e-9;
+
+        if ($mode === self::SEGMENTS) {
+            foreach ((array) ($row['segments'] ?? []) as $segment) {
+                $lo = (float) ($segment['lo'] ?? 0);
+                $hi = isset($segment['hi']) ? (float) $segment['hi'] : INF;
+                if (! (($weight > $lo + 1e-9 || $lo <= 0.0) && $within($weight, $hi))) {
+                    continue;
+                }
+                $type = (string) ($segment['type'] ?? '');
+                if (! in_array($type, ['flat', 'waybill', 'first_add'], true)) {
+                    return $none('不支持的分段计费方式，需人工核算');
+                }
+                if ($type === 'flat') {
+                    return isset($segment['price']) ? $ok((float) $segment['price'], '一口价' . self::kg((float) $segment['price'])) : $none('该重量段不发');
+                }
+                if (! isset($segment['base'], $segment['rate'])) {
+                    return $none('该重量段不发');
+                }
+                $base = (float) $segment['base'];
+                $rate = (float) $segment['rate'];
+                if ($type === 'first_add') {
+                    $fw = (float) ($segment['fw'] ?? 0);
+
+                    return $within($weight, $fw)
+                        ? $ok($base, '首重' . self::kg($base))
+                        : $ok($base + ($weight - $fw) * $rate, self::kg($base) . '+(' . $w . '-' . self::kg($fw) . ')×' . self::kg($rate));
+                }
+
+                return $ok($base + $weight * $rate, self::kg($base) . '+' . $w . '×' . self::kg($rate));
+            }
+
+            return $none('超出报价重量范围');
+        }
+
+        if (! in_array($mode, ['waybill_rate', 'first_additional', 'flat_bands', 'flat_then'], true)) {
+            return $none('特殊计费，需人工核算');
+        }
+
+        $bands = array_map('floatval', array_values((array) ($structure['flat_bands'] ?? [])));
+        $flat = array_values((array) ($row['flat'] ?? []));
+        if (in_array($mode, ['flat_bands', 'flat_then'], true) && $bands !== [] && ($mode === 'flat_bands' || $within($weight, end($bands)))) {
+            foreach ($bands as $index => $edge) {
+                if ($within($weight, $edge)) {
+                    $price = $flat[$index] ?? null;
+
+                    return is_numeric($price) ? $ok((float) $price, '≤' . self::kg($edge) . 'kg 一口价' . self::kg((float) $price)) : $none('该重量段不发');
+                }
+            }
+
+            return $none('超出报价重量范围');
+        }
+
+        $tiers = array_map('floatval', array_values((array) ($structure['rate_tiers'] ?? [])));
+        $index = count($tiers);
+        foreach ($tiers as $i => $edge) {
+            if ($within($weight, $edge)) {
+                $index = $i;
+                break;
+            }
+        }
+        $rate = $row['rates'][$index] ?? null;
+        $base = $row['base'] ?? null;
+        if (! is_numeric($rate) || ! is_numeric($base)) {
+            return $none('该重量段不发');
+        }
+        $rate = (float) $rate;
+        $base = (float) $base;
+        $then = $mode === 'flat_then' ? (string) ($structure['then_mode'] ?? 'waybill_rate') : $mode;
+        if ($then === 'first_additional') {
+            $fw = (float) ($structure['first_weight'] ?? 0);
+
+            return $within($weight, $fw)
+                ? $ok($base, '首重' . self::kg($base))
+                : $ok($base + ($weight - $fw) * $rate, self::kg($base) . '+(' . $w . '-' . self::kg($fw) . ')×' . self::kg($rate));
+        }
+
+        return $ok($base + $weight * $rate, self::kg($base) . '+' . $w . '×' . self::kg($rate));
+    }
+
+    /** 按取整方式得到计费重量：ceil 向上取整，round 四舍五入（4.5 进为 5）。 */
+    public static function roundWeight(float $weight, string $rounding): float
+    {
+        return match ($rounding) {
+            'ceil' => (float) ceil(round($weight, 6)),
+            'round' => (float) floor($weight + 0.5),
+            default => $weight,
+        };
+    }
+
     public static function usesRates(string $mode): bool
     {
         return in_array($mode, ['waybill_rate', 'first_additional', 'flat_then'], true);

app/Support/QuoteManagementSnapshot.php

@@ -142,6 +142,23 @@ final class QuoteManagementSnapshot
         return $companyName !== '' ? $companyName : $name;
     }
 
+    /** 「查看」面板的计费规则一行：计费方式 + 取整/计泡/限重/每票加收。 */
+    private function billingSummary(CourierQuoteVersion $version): string
+    {
+        $structure = (array) $version->billing_structure;
+        $kg = static fn ($value): string => CourierQuoteStructure::kg((float) $value);
+        $parts = array_filter([
+            CourierQuoteStructure::describe($structure),
+            ($structure['rounding'] ?? 'none') !== 'none' ? (CourierQuoteStructure::ROUNDING[$structure['rounding']] ?? null) : null,
+            filled($structure['min_weight'] ?? null) ? '不足' . $kg($structure['min_weight']) . 'kg按' . $kg($structure['min_weight']) . 'kg计' : null,
+            filled($structure['volumetric_divisor'] ?? null) ? '计泡 ' . $structure['volumetric_divisor'] : null,
+            filled($structure['weight_limit'] ?? null) ? '限重 ' . $kg($structure['weight_limit']) . 'kg' : null,
+            filled($structure['per_ticket_surcharge'] ?? null) ? '每票加收 ' . $kg($structure['per_ticket_surcharge']) . ' 元' : null,
+        ]);
+
+        return implode('；', $parts) . '（' . count((array) $version->billing_rows) . ' 个地区）';
+    }
+
     private function normalizeVersion(CourierQuoteVersion $version): array
     {
         $values = $this->decodeMatrix($version->values_json);
@@ -155,6 +172,7 @@ final class QuoteManagementSnapshot
             'company_name' => $version->company_name,
             'courier_expcode' => $version->courier_expcode,
             'billing_rules' => $version->billing_rules,
+            'billing_summary' => $version->hasBillingRules() ? $this->billingSummary($version) : null,
             'carrier' => $version->carrier_name,
             'quote_type' => $version->quote_type,
             'effective_date' => $version->effective_date?->toDateString(),

app/Utilities/FinanceLedgerAccess.php

@@ -0,0 +1,48 @@
+<?php
+
+namespace App\Utilities;
+
+use App\Models\Auth\User;
+
+class FinanceLedgerAccess
+{
+    /**
+     * 账户映射的写权限：超级管理员，或配置中的财务台账管理员角色。
+     * 页面查看权限仍由 SidebarPermissions 的页面键控制。
+     */
+    public static function canEditMapping(?User $user = null): bool
+    {
+        if (SystemAccess::isSuperAdmin($user)) {
+            return true;
+        }
+
+        $user ??= user();
+        if (! $user) {
+            return false;
+        }
+
+        if (SystemAccess::roleName($user) === SystemAccess::ADMIN) {
+            return true;
+        }
+
+        $roles = array_values(array_filter(array_map(
+            'trim',
+            explode(',', (string) config('finance_ledger.mapping_editor_roles', '财务台账管理员')),
+        )));
+
+        return in_array(SystemAccess::roleName($user), $roles, true);
+    }
+
+    /**
+     * 账户状态、账户类型与账户映射使用同一组财务台账编辑角色。
+     */
+    public static function canEditAccountStatus(?User $user = null): bool
+    {
+        return self::canEditMapping($user);
+    }
+
+    public static function canEditAccountType(?User $user = null): bool
+    {
+        return self::canEditMapping($user);
+    }
+}

app/Utilities/FinanceLedgerAccountShouldKeep.php

@@ -0,0 +1,65 @@
+<?php
+
+namespace App\Utilities;
+
+use Illuminate\Database\Query\Builder;
+
+class FinanceLedgerAccountShouldKeep
+{
+    public const YES = '是';
+
+    public const NO = '否';
+
+    public const OPTIONS = [self::YES, self::NO];
+
+    public static function normalize(?string $value): string
+    {
+        $value = trim((string) $value);
+        if ($value === '') {
+            return '';
+        }
+
+        $compact = mb_strtoupper((string) preg_replace('/\s+/u', '', $value));
+        if (in_array($compact, ['是', '保留', '需要保留', '需要', 'Y', 'YES', 'TRUE', '1'], true)) {
+            return self::YES;
+        }
+        if (in_array($compact, ['否', '不保留', '不需要保留', '不需要', 'N', 'NO', 'FALSE', '0'], true)) {
+            return self::NO;
+        }
+
+        return $value;
+    }
+
+    public static function display(?string $explicitValue, ?string $companyPlan): string
+    {
+        $normalized = self::normalize($explicitValue);
+        if ($normalized !== '') {
+            return $normalized;
+        }
+
+        $plan = trim((string) $companyPlan);
+        if ($plan === '') {
+            return '';
+        }
+
+        return str_contains($plan, '保留') ? self::YES : self::NO;
+    }
+
+    public static function applyUnretainedCondition(
+        Builder $query,
+        string $explicitColumn = 'account_should_keep',
+        string $companyPlanColumn = 'company_plan',
+    ): Builder {
+        return $query->where(function (Builder $keep) use ($explicitColumn, $companyPlanColumn): void {
+            $keep->where($explicitColumn, self::NO)
+                ->orWhere(function (Builder $inferred) use ($explicitColumn, $companyPlanColumn): void {
+                    $inferred->where(function (Builder $blank) use ($explicitColumn): void {
+                        $blank->whereNull($explicitColumn)->orWhere($explicitColumn, '');
+                    })
+                        ->whereNotNull($companyPlanColumn)
+                        ->where($companyPlanColumn, '<>', '')
+                        ->where($companyPlanColumn, 'not like', '%保留%');
+                });
+        });
+    }
+}

app/Utilities/FinanceLedgerAccountStatus.php

@@ -0,0 +1,30 @@
+<?php
+
+namespace App\Utilities;
+
+final class FinanceLedgerAccountStatus
+{
+    public const NORMAL = 'normal';
+    public const ONLINE_BANKING_ABNORMAL = 'online_banking_abnormal';
+    public const LIMITED = 'limited';
+    public const BUSINESS_DEREGISTERED = 'business_deregistered';
+
+    public const OPTIONS = [
+        self::NORMAL => '正常',
+        self::ONLINE_BANKING_ABNORMAL => '网银异常',
+        self::LIMITED => '限额',
+        self::BUSINESS_DEREGISTERED => '工商注销',
+    ];
+
+    public static function normalize(?string $status): string
+    {
+        $status = trim((string) $status);
+
+        return array_key_exists($status, self::OPTIONS) ? $status : self::NORMAL;
+    }
+
+    public static function label(?string $status): string
+    {
+        return self::OPTIONS[self::normalize($status)];
+    }
+}

app/Utilities/FinanceLedgerAccountType.php

@@ -0,0 +1,54 @@
+<?php
+
+namespace App\Utilities;
+
+final class FinanceLedgerAccountType
+{
+    public const ALIPAY = '支付宝';
+
+    public const BANK_ACCOUNT_TYPES = ['公户', '个人卡', '网商银行'];
+
+    public const DEFAULT_OPTIONS = [
+        '个人卡',
+        '公户',
+        self::ALIPAY,
+        '网商银行',
+    ];
+
+    public static function options(array ...$groups): array
+    {
+        $types = self::DEFAULT_OPTIONS;
+        foreach ($groups as $group) {
+            foreach ($group as $type) {
+                $type = trim((string) $type);
+                if ($type !== '') {
+                    $types[] = $type;
+                }
+            }
+        }
+
+        $types = array_values(array_unique($types));
+        sort($types, SORT_NATURAL | SORT_FLAG_CASE);
+
+        return $types;
+    }
+
+    public static function last4(?string $accountType, ?string $accountNo, ?string $fallback = null): string
+    {
+        $type = trim((string) $accountType);
+        if ($type === self::ALIPAY) {
+            return '/';
+        }
+
+        if (in_array($type, self::BANK_ACCOUNT_TYPES, true)) {
+            $digits = preg_replace('/\D+/', '', (string) $accountNo);
+            if (strlen((string) $digits) >= 4) {
+                return substr((string) $digits, -4);
+            }
+        }
+
+        $fallback = trim((string) $fallback);
+
+        return $fallback !== '' ? $fallback : '/';
+    }
+}

app/Utilities/FocusMode.php

@@ -0,0 +1,18 @@
+<?php
+
+namespace App\Utilities;
+
+class FocusMode
+{
+    /**
+     * 单页模式（钉钉工作台入口，或显式 ?focus=1）：只保留该目录自己的页签，隐藏全局菜单。
+     * 网页端正常登录时不启用，避免页面上的目录页签和左侧菜单、已打开页面标签栏重复。
+     */
+    public static function activeFor(?string $sectionSlug = null): bool
+    {
+        $section = $sectionSlug ?: (string) (request()->route('section') ?: request()->segment(3));
+
+        return in_array($section, ['financial-risk-control'], true)
+            && (request()->boolean('focus') || str_contains((string) request()->userAgent(), 'DingTalk'));
+    }
+}

app/Utilities/SidebarMenu.php

@@ -0,0 +1,140 @@
+<?php
+
+namespace App\Utilities;
+
+use App\Models\Auth\User;
+
+class SidebarMenu
+{
+    /**
+     * 侧边栏与首页共用的功能分组，按当前账号可访问的页面过滤，标题跟随后台自定义名称。
+     *
+     * @return array<int, array{title: string, items: array<int, array{section: string, page: string, title: string, icon: string}>}>
+     */
+    public static function groups(?User $user = null): array
+    {
+        $user ??= user();
+
+        $groups = [
+            ['title' => '工作台', 'items' => [
+                ['workspace', 'overview', '经营总览', 'monitoring'],
+            ]],
+            ['title' => '经营报表', 'items' => [
+                ['financial-operations', 'ledger', '财务台账', 'menu_book'],
+                ['company-management', 'subject-operating-report', '主体维度经营报表', 'domain'],
+                ['company-management', 'company-cost-arrangement', '公司成本安排', 'account_balance_wallet'],
+                ['company-management', 'tax-forecast', '税金预测表', 'calculate'],
+                ['store-management', 'store-report', '店铺维度报表', 'storefront'],
+                ['store-management', 'internal-flow-report', '内部流转报表', 'swap_horiz'],
+                ['company-management', 'personnel-inventory', '人员盘点表', 'groups'],
+            ]],
+            ['title' => '基础资料', 'items' => [
+                ['store-management', 'basic-information', '店铺基础信息', 'shopping_bag'],
+                ['store-management', 'store-accounts', '店铺账号密码', 'key'],
+                ['company-management', 'basic-information', '公司基础信息', 'badge'],
+                ['trademark-management', 'information', '商标基础信息', 'workspace_premium'],
+            ]],
+            ['title' => '规则信息', 'items' => [
+                ['trademark-management', 'subject-trademark-rules', '主体商标规则', 'rule'],
+                ['trademark-management', 'store-change-rules', '店铺变更规则', 'rule'],
+                ['trademark-management', 'store-report-data-logic', '店铺维度报表逻辑配置', 'table_chart'],
+                ['trademark-management', 'tax-forecast-data-logic', '税金预测表逻辑配置', 'calculate'],
+            ]],
+            ['title' => '业务进度', 'items' => [
+                ['company-management', 'company-progress', '公司进度表', 'timeline'],
+                ['store-management', 'change-progress', '店铺变更进度表', 'swap_horiz'],
+                ['trademark-management', 'trademark-progress', '商标进度表', 'format_list_bulleted'],
+                ['workspace', 'tasks', '待办事项', 'assignment_turned_in'],
+                ['workspace', 'warnings', '预警页面', 'warning_amber'],
+            ]],
+            ['title' => '财务报表', 'items' => [
+                ['prototype-finance-reports', 'profit-report', '公司利润报表', 'request_quote'],
+                ['prototype-finance-reports', 'asset-report', '公司资产报表', 'account_balance'],
+            ]],
+        ];
+
+        $visiblePages = self::visiblePages($user);
+
+        $groups = array_map(function (array $group) use ($visiblePages): array {
+            $items = [];
+
+            foreach ($group['items'] as [$section, $page, $title, $icon]) {
+                $key = $section . '/' . $page;
+
+                if (! isset($visiblePages[$key])) {
+                    continue;
+                }
+
+                $items[] = [
+                    'section' => $section,
+                    'page' => $page,
+                    'title' => $visiblePages[$key],
+                    'icon' => $icon,
+                ];
+            }
+
+            $group['items'] = $items;
+
+            return $group;
+        }, $groups);
+
+        return array_values(array_filter($groups, static fn (array $group): bool => $group['items'] !== []));
+    }
+
+    /**
+     * 当前账号可访问的全部业务模块及页面，供首页做完整导航。
+     *
+     * @return array<int, array{slug: string, title: string, icon: string, pages: array<int, array{slug: string, title: string}>}>
+     */
+    public static function sections(?User $user = null): array
+    {
+        $user ??= user();
+
+        $sections = [];
+
+        foreach (SidebarPermissions::navigationFor($user) as $section) {
+            $pages = [];
+
+            foreach ($section['pages'] ?? [] as $page) {
+                $pages[] = ['slug' => $page['slug'], 'title' => $page['title']];
+
+                foreach ($page['children'] ?? [] as $child) {
+                    $pages[] = ['slug' => $child['slug'], 'title' => $child['title']];
+                }
+            }
+
+            if ($pages === []) {
+                continue;
+            }
+
+            $sections[] = [
+                'slug' => $section['slug'],
+                'title' => $section['title'],
+                'icon' => $section['icon'] ?? 'folder',
+                'pages' => $pages,
+            ];
+        }
+
+        return $sections;
+    }
+
+    /**
+     * @return array<string, string> 「section/page」 => 页面标题
+     */
+    private static function visiblePages(User $user): array
+    {
+        $pages = [];
+
+        foreach (SidebarPermissions::navigationFor($user) as $section) {
+            foreach ($section['pages'] ?? [] as $page) {
+                $pages[$section['slug'] . '/' . $page['slug']] = $page['title'];
+
+                foreach ($page['children'] ?? [] as $child) {
+                    $pages[$section['slug'] . '/' . $child['slug']] = $child['title'];
+                }
+            }
+        }
+
+        return $pages;
+    }
+}

app/Utilities/SidebarPermissions.php

@@ -5,11 +5,14 @@ namespace App\Utilities;
 use App\Models\Auth\User;
 use App\Models\Auth\UserAccessGroup;
 use App\Services\Auth\FinanceRoster;
+use App\Services\Auth\SupplierPortalAccess;
 
 class SidebarPermissions
 {
     private const LEGACY_PAGE_KEYS = [
         'refunds/small-payment-work-orders' => 'financial-operations/small-payment-work-orders',
+        'financial-ledger' => 'financial-operations/ledger',
+        'financial-ledger/ledger' => 'financial-operations/ledger',
     ];
 
     private const FINAL_SECTION_KEYS = [
@@ -43,6 +46,10 @@ class SidebarPermissions
     public static function allowedKeys(User $user): ?array
     {
         // Limited identities cannot inherit full navigation from roles, groups or user overrides.
+        if (SupplierPortalAccess::isSupplierUser($user)) {
+            return [SupplierPortalAccess::PAGE_KEY];
+        }
+
         if (self::hasLimitedDingTalkAccess($user)) {
             return config('dingtalk.limited_login_page_keys', []);
         }
@@ -75,7 +82,8 @@ class SidebarPermissions
 
     public static function hasLimitedDingTalkAccess(User $user): bool
     {
-        return $user->created_from === 'dingtalk_roster_limited'
+        return SupplierPortalAccess::isSupplierUser($user)
+            || $user->created_from === 'dingtalk_roster_limited'
             || (config('dingtalk.limited_login_user_ids', []) !== []
                 && FinanceRoster::isLimitedLoginUser((string) $user->dingtalkIdentity?->dingtalk_user_id));
     }

compose.jiangling.yml

@@ -68,6 +68,7 @@ services:
     volumes:
       - caiwu_clickhouse_database:/var/lib/clickhouse
       - caiwu_clickhouse_logs:/var/log/clickhouse-server
+      - ./clickhouse-resource-policy.xml:/etc/clickhouse-server/config.d/caiwu-resource-policy.xml:ro
     mem_limit: 4g
     cpus: "2.00"
     ulimits:
@@ -93,6 +94,9 @@ services:
     pull_policy: never
     container_name: caiwu_app
     restart: unless-stopped
+    # Web requests and small scheduled jobs have their own memory boundary.
+    mem_limit: 2g
+    memswap_limit: 2g
     depends_on:
       db:
         condition: service_healthy
@@ -100,6 +104,7 @@ services:
         condition: service_healthy
     environment:
       RUN_MIGRATIONS: ${RUN_MIGRATIONS:-0}
+      FINANCE_BATCH_WORKER_ENABLED: "1"
       SUPPLIER_PAYABLE_MAINTENANCE_DB_CONNECTION: business_mirror
       JST_DB_CONNECTION: business_mirror
     env_file:
@@ -121,6 +126,36 @@ services:
       retries: 10
       start_period: 45s
 
+  # Heavy CLI jobs use a separate cgroup from Apache.
+  batch:
+    image: caiwu_akaunting:${IMAGE_TAG:?IMAGE_TAG is required}
+    pull_policy: never
+    profiles: [batch]
+    user: www-data
+    entrypoint: [php, artisan]
+    command: [list]
+    restart: "no"
+    environment:
+      FINANCE_BATCH_CONTAINER: "1"
+      SUPPLIER_PAYABLE_MAINTENANCE_DB_CONNECTION: business_mirror
+      JST_DB_CONNECTION: business_mirror
+    env_file:
+      - ./runtime/qiniu-storage.env
+      - ./runtime/clickhouse.env
+    volumes:
+      - ./runtime/.env:/var/www/html/.env:ro
+      - caiwu_storage:/var/www/html/storage
+    cpus: "1.00"
+    mem_limit: ${FINANCE_BATCH_MEMORY_LIMIT:-3g}
+    memswap_limit: ${FINANCE_BATCH_MEMORY_LIMIT:-3g}
+    healthcheck:
+      disable: true
+    logging:
+      driver: json-file
+      options:
+        max-size: "10m"
+        max-file: "3"
+
 volumes:
   caiwu_database:
     name: caiwu_database

config/business_data.php

@@ -180,7 +180,7 @@ return [
         'store_report_paid_sales_rows' => [
             'role' => 'aggregate',
             'target_store' => 'mariadb',
-            'consumer' => '店铺维度报表销量（业绩明细订单实付/实收金额）',
+            'consumer' => '店铺维度报表销量（业绩明细收入+优惠+冲减+退款金额合计）',
         ],
     ],
 ];

config/business_navigation.php

@@ -252,7 +252,7 @@ $navigation = [
                 'directory' => [
                     'icon' => 'query_stats',
                     'status' => '共享镜像',
-                    'description' => '店铺资料、主体生效区间统一读取团队共享业务镜像；销量取业绩明细的「订单实付/实收金额」，按店铺和发生时间汇总后落到主体期间。',
+                    'description' => '店铺资料、主体生效区间统一读取团队共享业务镜像；销量取业绩明细的「收入金额 + 优惠金额 + 冲减金额 + 退款金额」合计，按店铺和发生日期逐日汇总后落到主体期间。',
                     'empty' => '店铺维度报表尚未完成共享数据导入。',
                     'fields' => [
                         ['name' => 'erp_store_name', 'label' => 'ERP系统店铺名称'],
@@ -540,6 +540,8 @@ $navigation = [
         'pages' => [
             ['slug' => 'planting-details', 'title' => '种菜明细表'],
             ['slug' => 'jst-order-labels', 'title' => '聚水潭订单标签明细'],
+            ['slug' => 'planting-reimbursements', 'title' => '种菜报销'],
+            ['slug' => 'planting-loss', 'title' => '种菜损耗'],
         ],
     ],
     [
@@ -695,6 +697,7 @@ $navigation = [
             ['slug' => 'advance-details', 'title' => '借支明细'],
             ['slug' => 'sample-deductions', 'title' => '样品扣款'],
             ['slug' => 'other-adjustments', 'title' => '其他扣款补款'],
+            ['slug' => 'manufacturer-bookkeeping', 'title' => '厂家记账'],
             [
                 'slug' => 'unpriced-details',
                 'title' => '未定价明细',
@@ -819,7 +822,7 @@ $navigation = [
                 'directory' => [
                     'icon' => 'receipt_long',
                     'status' => '共享镜像',
-                    'description' => '覆盖店铺收款账户账单各平台页签（总账备注＝订单收入），按「店铺 + 订单号」匹配订单侧商品金额与订单实付金额；一行 = 一个店铺的一个订单，商品金额只挂一次。「商品金额」按「主单（拆单子单不参与）→ 原单行（merge_so_id 为空）→ 全部行」优先级取数，合单发货（原单与合并行共用同一线上单号、没有主单）时只取本单原单行，避免把合并的另一单算进来；并排除虚拟条码（X0000x：信誉订单 / 虚拟订单）明细行；「订单实付金额」取订单级实付（同一套优先级，末档兜底取该单号下最大值）再减去虚拟条码行实付。「优惠金额」「冲减金额」另取总账备注＝优惠收入 / 冲减收入的账单金额，不计入收入金额；「退款金额」另取总账备注＝退款的账单金额，只单独列示，不计入收入金额、也不参与差额；「种菜金额」是订单号在种菜明细表或聚水潭订单标签明细（是否种菜订单＝是）任意一边出现过时，该订单的收入金额（两个条件是或的关系），只是收入金额里的一部分，不参与差额；差额＝（收入金额＋优惠金额＋冲减金额）−订单实付金额，匹配状态与差额异常备注同样按订单实付金额判定，未匹配到订单实付金额的行按订单实付金额＝0 计入差额，只反映真正对不上的部分。挂不到订单行的优惠/冲减会补成一行（收入/商品留空）。「差额异常备注」只说明差额为什么产生，按顺序自动判定：订单实付未匹配（未匹配到订单实付金额，具体原因看「匹配原因」列）；订单实付取数为0（种菜）（订单实付=0 且是种菜单）、订单实付取数为0（订单实付=0 但不是种菜单）、订单实付未减联合营销费（仅得物负差额：联合营销费未让利尾数对上才标注）、订单实付取供货价（仅京喜正差额：差额=该单直营服务费（供货模式净收）时标注）、差额=直营补贴款（待开票结算）（仅京喜账单·出类拔萃等 10 家京喜自营工厂店负差额且无退款（已逐店在结算单核实）：京东直营补贴款待开票结算时标注）、差额=直营补贴款（订单退款已冲回）（同批店负差额但订单已退款：补贴款已随退款冲回）、差额=订单实付包含商家承担优惠和以旧换新国补（仅京东账单·索菲亚客厅/办公/书房/功能、亿家达全屋、朴美家居店负差额、且该单含国补（聚水潭应付−账单收入＞0）：差额为商家承担优惠（店铺东券/单品折扣等）与以旧换新国补之和，已用营销对账逐单核实）、差额=订单实付包含商家承担优惠（同店负差额但不含国补的单：差额即商家承担优惠）、订单实付未减冲减（订单实付=收入+优惠 → 差额=冲减金额）、订单实付未减优惠（订单实付=收入+冲减 → 差额=优惠金额）、订单实付未减优惠和冲减（订单实付=收入 → 差额=优惠+冲减）（以上三档等式对带口径标识的行让位给口径兜底）、订单实付含已退款部分（抖音负差额：聚水潭退款单/取消子单金额≈差额，或退款合计＋账单退款净额≈实付−收入，或整单全退（退款合计≈实付）对上才标注；淘系支付宝/微信负差额：差额＝退款合计、或退款合计＝实付−收入（收款缺口）、或整单全退（退款合计≈实付）时同样标注（退款取聚水潭已确认记录））；都不满足时，若「卖家实收」或「应付/已付」能对上账单，差额按 0 计并在「匹配原因」列标注口径核对；其余标「差额待核实」。「匹配原因」单独一列，取值：账单无单号 / 账单无单号（采销收款）/ 单号格式异常 / 订单表无此单 / 1688采销收款（非销售单）/ 订单无实付金额 / 无收款账单（「采销收款」两档专指「支付宝-1688采销专用」账户：该账户收的是采销/供货结算款，不是店铺销售单收款，不按丢单处理）。',
+                    'description' => '覆盖店铺收款账户账单各平台页签（总账备注＝订单收入），按「店铺 + 订单号」匹配订单侧商品金额与订单实付金额；一行 = 一个店铺的一个订单，商品金额只挂一次。「商品金额」按「主单（拆单子单不参与）→ 原单行（merge_so_id 为空）→ 全部行」优先级取数，合单发货（原单与合并行共用同一线上单号、没有主单）时只取本单原单行，避免把合并的另一单算进来；并排除虚拟条码（X0000x：信誉订单 / 虚拟订单）明细行；「订单实付金额」取订单级实付（同一套优先级，末档兜底取该单号下最大值）再减去虚拟条码行实付。「优惠金额」「冲减金额」另取总账备注＝优惠收入 / 冲减收入的账单金额，不计入收入金额；「退款金额」另取总账备注＝退款的账单金额，只单独列示，不计入收入金额、也不参与差额；「种菜金额」是订单号在种菜明细表或聚水潭订单标签明细（是否种菜订单＝是）任意一边出现过时，该订单的收入金额（两个条件是或的关系），只是收入金额里的一部分，不参与差额；差额＝（收入金额＋优惠金额＋冲减金额）−订单实付金额，匹配状态与差额异常备注同样按订单实付金额判定，未匹配到订单实付金额的行按订单实付金额＝0 计入差额，只反映真正对不上的部分。挂不到订单行的优惠/冲减会补成一行（收入/商品留空）。「差额异常备注」只说明差额为什么产生，按顺序自动判定：订单实付未匹配（未匹配到订单实付金额，具体原因看「匹配原因」列）；订单实付取数为0（种菜）（订单实付=0 且是种菜单）、订单实付取数为0（订单实付=0 但不是种菜单）、订单实付未减联合营销费（仅得物负差额：联合营销费未让利尾数对上才标注）、订单实付取供货价（仅京喜正差额：差额=该单直营服务费（供货模式净收）时标注）、差额=直营补贴款（待开票结算）（仅京喜账单·京喜自营工厂店负差额且无退款（出类拔萃等 10 家已逐店核验，其余工厂店按实付≈商品金额的供货价特征识别）：京东直营补贴款待开票结算时标注）、差额=直营补贴款（订单退款已冲回）（同批店负差额但订单已退款：补贴款已随退款冲回）、差额=订单实付包含商家承担优惠和以旧换新国补（仅京东账单·索菲亚客厅/办公/书房/功能、亿家达全屋、朴美家居店负差额、且该单含国补（聚水潭应付−账单收入＞0）：差额为商家承担优惠（店铺东券/单品折扣等）与以旧换新国补之和，已用营销对账逐单核实）、差额=订单实付包含商家承担优惠（同店负差额但不含国补的单：差额即商家承担优惠）、订单实付未减冲减（订单实付=收入+优惠 → 差额=冲减金额）、订单实付未减优惠（订单实付=收入+冲减 → 差额=优惠金额）、订单实付未减优惠和冲减（订单实付=收入 → 差额=优惠+冲减）（以上三档等式对带口径标识的行让位给口径兜底）、订单实付含已退款部分（抖音负差额：聚水潭退款单/取消子单金额≈差额，或退款合计＋账单退款净额≈实付−收入，或整单全退（退款合计≈实付）对上才标注；淘系支付宝/微信负差额：差额＝退款合计、或退款合计＝实付−收入（收款缺口）、或整单全退（退款合计≈实付）时同样标注（退款取聚水潭已确认记录））；以上具体规则均未命中且相关金额在 2 分钱内精确对平时，退款及其与优惠/冲减的组合复用「订单实付含已退款部分」，优惠与冲减组合复用「订单实付未减优惠和冲减」，不新增同义备注；没有可复用的原备注时继续标「差额待核实」。都不满足时，若「卖家实收」或「应付/已付」能对上账单，差额按 0 计并在「匹配原因」列标注口径核对；其余标「差额待核实」。「匹配原因」单独一列，取值：账单无单号 / 账单无单号（采销收款）/ 单号格式异常 / 订单表无此单 / 1688采销收款（非销售单）/ 订单无实付金额 / 无收款账单（「采销收款」两档专指「支付宝-1688采销专用」账户：该账户收的是采销/供货结算款，不是店铺销售单收款，不按丢单处理）。',
                     'empty' => '店铺收款匹配订单明细尚未同步，请先执行 store-receipt:order-match:sync。',
                     'fields' => [
                         ['name' => 'platform', 'label' => '平台'],
@@ -831,6 +834,8 @@ $navigation = [
                         ['name' => 'offset_amount', 'label' => '冲减金额', 'kind' => 'number'],
                         ['name' => 'refund_amount', 'label' => '退款金额', 'kind' => 'number'],
                         ['name' => 'planting_amount', 'label' => '种菜金额', 'kind' => 'number'],
+                        ['name' => 'planting_reimbursement_amount', 'label' => '种菜报销', 'kind' => 'number'],
+                        ['name' => 'planting_unreimbursed_amount', 'label' => '种菜未报销', 'kind' => 'number'],
                         ['name' => 'product_amount', 'label' => '商品金额', 'kind' => 'number'],
                         ['name' => 'paid_amount', 'label' => '订单实付/实收金额', 'kind' => 'number'],
                         ['name' => 'difference', 'label' => '差额', 'kind' => 'number'],
@@ -876,6 +881,7 @@ $navigation = [
             ['slug' => 'bookkeeping-details', 'title' => '记账明细'],
             ['slug' => 'non-operating-expenses', 'title' => '营业外支出'],
             ['slug' => 'financial-analysis', 'title' => '财务经营分析表'],
+            ['slug' => 'ledger', 'title' => '财务台账', 'show_in_section_menu' => false],
         ],
     ],
     [
@@ -887,7 +893,7 @@ $navigation = [
             ['slug' => 'preview-statistics', 'title' => '预览统计'],
             [
                 'slug' => 'process-statistics',
-                'title' => '流程统计',
+                'title' => '店铺流程',
                 'directory' => [
                     'icon' => 'timeline',
                     'status' => '共享镜像',

config/finance_batch.php

@@ -0,0 +1,7 @@
+<?php
+
+return [
+    'container' => (bool) env('FINANCE_BATCH_CONTAINER', false),
+    // The host runner and application share this registry.
+    'import_commands' => json_decode(file_get_contents(base_path('deploy/finance-batch-imports.json')), true, 512, JSON_THROW_ON_ERROR),
+];

config/finance_ledger.php

@@ -0,0 +1,29 @@
+<?php
+
+return [
+    // 台账期初日，也是每日资金流水滚动的起点。
+    'opening_date' => env('FINANCE_LEDGER_OPENING_DATE', '2026-10-17'),
+
+    // 台账取数窗口。期初日可以晚于窗口结束日，二者互不影响。
+    'window_start' => env('FINANCE_LEDGER_WINDOW_START', '2026-04-18'),
+    // 留空表示同步到当天；首次建账快照截止日由导入文件自身决定。
+    'window_end' => env('FINANCE_LEDGER_WINDOW_END', ''),
+
+    // 动账明细的唯一上游来源；本地调试可切换到本地快照导入。
+    'source' => env('FINANCE_LEDGER_RPT_SOURCE', 'operations_replica'),
+
+    // 台账上游查询允许更长的超时；普通页面仍使用共享连接的 15 秒。
+    'query_timeout' => (int) env('FINANCE_LEDGER_QUERY_TIMEOUT', 120),
+
+    // 具备账户映射写权限的角色；超级管理员始终可写。
+    'mapping_editor_roles' => env('FINANCE_LEDGER_MAPPING_EDITOR_ROLES', '财务台账管理员'),
+
+    'dingtalk_process_codes' => [
+        'PROC-B290696F-EC2A-4F76-87BA-E0A12E10D09F' => '日常费用报销流程',
+        'PROC-C5159B8D-F412-4DF8-981D-64EBB8D03EB6' => '种菜报销流程',
+        'PROC-39DD70DE-DAB2-4A5F-B8F1-0B0B68BD0C88' => '应付申请流程',
+        'PROC-BBAC7187-9E59-4942-941A-59C7EAF0CEDA' => '快递面单应付流程',
+        'PROC-ACF09A14-B094-46B1-A9E2-8BB1F4E1FDCF' => '线上代发业务报销',
+        'PROC-6407E98B-040A-4C96-AA7D-696650FC1A25' => '固定资产报废或出售流程',
+    ],
+];

config/order_after_sales_cost.php

@@ -0,0 +1,143 @@
+<?php
+
+/*
+|--------------------------------------------------------------------------
+| 订单售后费用明细（聚水潭「订单售后费用数据」导出）
+|--------------------------------------------------------------------------
+|
+| 聚水潭导出文件是中文表头，这里把表头映射成页面字段键，导入时按这个映射入库。
+| 未列出的表头会忽略；新增表头时补在这里即可。
+*/
+
+return [
+    'headers' => [
+        '内部订单号' => 'internal_order_no',
+        '线上订单号' => 'online_order_no',
+        '子订单号' => 'sub_order_no',
+        '售后单号' => 'after_sales_no',
+        '支付时间' => 'pay_time',
+        '订单完成时间' => 'order_complete_time',
+        '发货时间' => 'send_time',
+        '订单时间' => 'order_time',
+        '店铺名称' => 'shop_name',
+        '店铺编码' => 'shop_code',
+        '商品编码' => 'product_code',
+        '款式编码' => 'style_code',
+        '款式编码(参考)' => 'style_code',
+        '店铺商品编码' => 'shop_product_code',
+        '店铺款式编码' => 'shop_style_code',
+        '链接' => 'product_link',
+        "链接\u{3000}" => 'product_link',
+        '品牌' => 'brand',
+        '分类' => 'category',
+        '虚拟分类' => 'virtual_category',
+        '颜色及规格' => 'color_spec',
+        '商品名称' => 'product_name',
+        '唯一码' => 'unique_code',
+        '商品数量' => 'product_quantity',
+        '商品金额' => 'product_amount',
+        '商品成本' => 'product_cost',
+        '成本来源' => 'cost_source',
+        '其中：红冲订单成本' => 'reversal_order_cost',
+        '手动调整收入' => 'manual_adjust_income',
+        '手动调整成本' => 'manual_adjust_cost',
+        '商家优惠' => 'merchant_discount',
+        '运费收入' => 'freight_income',
+        '付款金额' => 'payment_amount',
+        '其中：平台优惠' => 'platform_discount',
+        '其中：红冲订单金额' => 'reversal_order_amount',
+        '实发金额' => 'actual_shipped_amount',
+        '实发数量' => 'actual_shipped_quantity',
+        '实发成本' => 'actual_shipped_cost',
+        '订单类型' => 'order_type',
+        '登记时间' => 'registration_time',
+        '确认时间' => 'confirmation_time',
+        '进仓时间' => 'warehouse_entry_time',
+        '线上商品名称' => 'online_product_name',
+        '发货前申请数量' => 'pre_application_quantity',
+        '发货前申请金额' => 'pre_application_amount',
+        '发货前申请成本' => 'pre_application_cost',
+        '发货前退回数量' => 'pre_return_quantity',
+        '发货前退回金额' => 'pre_return_amount',
+        '发货前退回成本' => 'pre_return_cost',
+        '发货前退款金额' => 'pre_refund_amount',
+        '发货前退款成本' => 'pre_refund_cost',
+        '发货前退平台补贴' => 'pre_platform_subsidy',
+        '发货后申请数量' => 'post_application_quantity',
+        '发货后申请金额' => 'post_application_amount',
+        '发货后申请成本' => 'post_application_cost',
+        '发货后退回数量' => 'post_return_quantity',
+        '发货后退回金额' => 'post_return_amount',
+        '发货后退回成本' => 'post_return_cost',
+        '发货后退款金额' => 'post_refund_amount',
+        '发货后退款成本' => 'post_refund_cost',
+        '发货后退平台补贴' => 'post_platform_subsidy',
+        '其中:次品商品数量' => 'defective_quantity',
+        '退款类型' => 'refund_type',
+        '问题类型' => 'question_type',
+        '明细退货类型' => 'detail_return_type',
+        '分类单' => 'classification_order',
+        '赠品' => 'is_gift',
+        '组合装' => 'combine_type',
+        '订单标签' => 'order_tags',
+        '售后单标签' => 'after_sales_tags',
+        '商品标签' => 'item_tags',
+        '发货仓编号' => 'shipping_warehouse_code',
+        '发货仓库' => 'shipping_warehouse',
+        '运营云仓' => 'operation_cloud_warehouse',
+        '收货仓编号' => 'receiving_warehouse_code',
+        '收货仓' => 'receiving_warehouse',
+        '供销商编号' => 'supplier_code',
+        '供销商' => 'supplier_name',
+        '快递单号' => 'express_no',
+        '快递公司' => 'express_company',
+        '省' => 'province',
+        '市' => 'city',
+        '业务员' => 'salesperson',
+        '线下客户编号' => 'offline_customer_code',
+        '线下客户编码' => 'offline_customer_code',
+        '线下客户名称' => 'offline_customer_name',
+        '500112冲减收入' => 'account_500112',
+        '60031erp快递费' => 'account_60031',
+        '800101其他服务费' => 'account_800101',
+        '800103其他活动费用' => 'account_800103',
+        '800104违约赔付' => 'account_800104',
+        '800105平台佣金' => 'account_800105',
+        '800105佣金' => 'account_800105',
+        '800106保证金' => 'account_800106',
+        '800107推广充值' => 'account_800107',
+        '800108品牌新享' => 'account_800108',
+        '800109淘宝客/多多进宝' => 'account_800109',
+        '800110运费险' => 'account_800110',
+        '800114公益宝贝' => 'account_800114',
+        '8001201直通车/钻展/快车等' => 'account_8001201',
+        '8001202推广红包冲减' => 'account_8001202',
+        '800122售后补偿' => 'account_800122',
+        '800125红包' => 'account_800125',
+        '800127退货运费' => 'account_800127',
+        '800129退款' => 'account_800129',
+        '800130订单' => 'account_800130',
+        '800132其他费用' => 'account_800132',
+        '800133品牌新享-收入' => 'account_800133',
+        '800304售后补偿-聚工单' => 'account_800304',
+        '800501种菜佣金' => 'account_800501',
+        '800503发空包/赠品费用' => 'account_800503',
+    ],
+
+    'number_keys' => [
+        'product_quantity', 'product_amount', 'product_cost', 'reversal_order_cost',
+        'manual_adjust_income', 'manual_adjust_cost', 'merchant_discount', 'freight_income',
+        'payment_amount', 'platform_discount', 'reversal_order_amount', 'actual_shipped_amount',
+        'actual_shipped_quantity', 'actual_shipped_cost', 'pre_application_quantity',
+        'pre_application_amount', 'pre_application_cost', 'pre_return_quantity', 'pre_return_amount',
+        'pre_return_cost', 'pre_refund_amount', 'pre_refund_cost', 'pre_platform_subsidy',
+        'post_application_quantity', 'post_application_amount', 'post_application_cost',
+        'post_return_quantity', 'post_return_amount', 'post_return_cost', 'post_refund_amount',
+        'post_refund_cost', 'post_platform_subsidy', 'defective_quantity',
+        'account_500112', 'account_60031', 'account_800101', 'account_800103', 'account_800104',
+        'account_800105', 'account_800106', 'account_800107', 'account_800108', 'account_800109',
+        'account_800110', 'account_800114', 'account_8001201', 'account_8001202', 'account_800122',
+        'account_800125', 'account_800127', 'account_800129', 'account_800130', 'account_800132',
+        'account_800133', 'account_800304', 'account_800501', 'account_800503',
+    ],
+];

config/sidebar_links.php

@@ -0,0 +1,16 @@
+<?php
+
+/*
+|--------------------------------------------------------------------------
+| 侧边栏「常用网址」
+|--------------------------------------------------------------------------
+| 搜索框右侧的网址入口，按数组顺序展示，点击在新标签页打开。
+| 例：['title' => '聚水潭 ERP', 'url' => 'https://example.com'],
+*/
+
+return [
+    ['title' => '聚水潭', 'url' => 'https://w.erp321.com/login.aspx'],
+    ['title' => '工作平台', 'url' => 'https://www.jiansun.vip/MiniUI/Index'],
+    ['title' => '预策', 'url' => 'http://218.93.9.141:8088/#/site-view/RPucab5JJI/J18wWGR1uC'],
+    ['title' => '由壹点「脉象」', 'url' => 'https://yyd.jiansuntuzhi.cn/login'],
+];

config/upstream_mirrors.php

@@ -193,6 +193,13 @@ return [
     */
     'table_sync' => [
         'batch_size' => (int) env('BUSINESS_MIRROR_TABLE_BATCH_SIZE', 500),
+        // These wide SQL Server views time out when TOP/pagination is planned
+        // together with every payload column. Select the bounded keys first,
+        // then look up only those rows in the same read-only statement.
+        'key_first_datasets' => [
+            'operations_replica.rpt.jst_Orders',
+            'operations_replica.rpt.jst_originalBillInfo',
+        ],
         'max_batches_per_run' => (int) env('BUSINESS_MIRROR_TABLE_MAX_BATCHES', 2),
         'max_datasets_per_run' => (int) env('BUSINESS_MIRROR_MAX_DATASETS', 1),
         'overlap_hours' => (int) env('BUSINESS_MIRROR_OVERLAP_HOURS', 48),
@@ -318,9 +325,14 @@ return [
             'keys' => ['Id'],
             'watermark' => 'updateTime',
             'indexes' => [
+                ['Id'],
                 ['as_date', 'Id'],
                 ['o_id', 'Id'],
                 ['as_id', 'Id'],
+                ['shop_id', 'outer_as_id(100)'],
+                ['so_id(64)'],
+                ['outer_as_id(64)'],
+                ['as_date', 'Id', 'as_id', 'shop_site(300)'],
             ],
         ],
         'operations_replica.rpt.jst_returnAndRefundItem' => [
@@ -329,11 +341,14 @@ return [
             'object' => 'jst_returnAndRefundItem',
             'target' => 'ops_jst_return_refund_item',
             'keys' => ['Id'],
+            // The replica can replace historical detail IDs. Append-only sync
+            // cannot discover those changes; reconcile in bounded weekly runs.
+            'full_reconcile_hours' => 168,
             'indexes' => [
                 ['as_id', 'Id'],
             ],
         ],
-        'operations_replica.rpt.jst_shopInfo' => ['source_key' => 'operations_replica', 'schema' => 'rpt', 'object' => 'jst_shopInfo', 'target' => 'ops_jst_shop_info', 'keys' => ['Id'], 'watermark' => 'updateTime'],
+        'operations_replica.rpt.jst_shopInfo' => ['source_key' => 'operations_replica', 'schema' => 'rpt', 'object' => 'jst_shopInfo', 'target' => 'ops_jst_shop_info', 'keys' => ['Id'], 'watermark' => 'updateTime', 'indexes' => [['shop_id', 'Id']]],
 
         // 淘系（天猫/淘宝）订单与售后：聚水潭单独存放在 qmcust 这套表里，
         // 与 jst_Orders / jst_OrderItem / jst_returnAndRefundInfo 分开。
@@ -376,6 +391,8 @@ return [
                 ['as_id'],
                 ['o_id', 'as_id'],
                 ['as_date', 'as_id'],
+                ['so_id(64)'],
+                ['outer_as_id(64)'],
             ],
         ],
         'operations_replica.rpt.jst_qmcust_refundlist_item' => [
@@ -389,6 +406,35 @@ return [
                 ['as_id', 'asi_id'],
             ],
         ],
+
+        // 聚水潭「商品利润 → 导出明细数据 → 订单售后费用数据」的原表。
+        // 列名是 undefined1..undefinedN，中文表头由 ..._schemas 表提供映射。
+        'operations_replica.rpt.jst_goods_profit_kpi_items_afs' => [
+            'source_key' => 'operations_replica',
+            'schema' => 'rpt',
+            'object' => 'jst_goods_profit_kpi_items_afs',
+            'target' => 'ops_jst_goods_profit_kpi_items_afs',
+            'keys' => ['id'],
+            'watermark' => 'updatedAt',
+            'batch_size' => 2000,
+            'max_batches_per_run' => 4,
+            // 160 多个 nvarchar 列，整行按 VARCHAR 建表会超过 InnoDB 行长度上限。
+            'wide_strings' => true,
+            'indexes' => [
+                ['undefined8', 'undefined7'],
+                ['undefined1'],
+                ['undefined2'],
+                ['undefined10'],
+            ],
+        ],
+        'operations_replica.rpt.jst_goods_profit_kpi_items_afs_schemas' => [
+            'source_key' => 'operations_replica',
+            'schema' => 'rpt',
+            'object' => 'jst_goods_profit_kpi_items_afs_schemas',
+            'target' => 'ops_jst_goods_profit_kpi_items_afs_schemas',
+            'keys' => ['id'],
+            'watermark' => 'id',
+        ],
         'operations_replica.rpt.jst_originalBillInfo' => [
             'source_key' => 'operations_replica',
             'schema' => 'rpt',

config/upstream_pipeline.php

@@ -1,6 +1,7 @@
 <?php
 
 return [
+    'batch_worker_enabled' => (bool) env('FINANCE_BATCH_WORKER_ENABLED', false),
     // Connection records supply addresses and credentials, never these defaults.
     'defaults' => ['enabled' => false, 'connection' => ['connect_timeout' => 5, 'query_timeout' => 15]],
     'sync' => [

database/migrations/2026_10_18_000000_add_billing_structure_to_business_courier_quote_versions.php

@@ -0,0 +1,46 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+/**
+ * 报价版本增加结构化计费规则，供运费核算使用；原始单元格（values_json）保留不动。
+ *
+ * billing_structure：{mode, flat_bands, then_mode, first_weight, rate_tiers, rounding, volumetric_divisor,
+ *                     weight_limit, min_weight(起算重量), per_ticket_surcharge, notes}
+ * billing_rows：     [{region, flat, base, rates}] 或分段计费 [{region, segments}]
+ */
+return new class extends Migration
+{
+    public function up(): void
+    {
+        if (! Schema::hasTable('business_courier_quote_versions')) {
+            return;
+        }
+
+        Schema::table('business_courier_quote_versions', function (Blueprint $table): void {
+            if (! Schema::hasColumn('business_courier_quote_versions', 'billing_structure')) {
+                $table->longText('billing_structure')->nullable();
+            }
+            if (! Schema::hasColumn('business_courier_quote_versions', 'billing_rows')) {
+                $table->longText('billing_rows')->nullable();
+            }
+        });
+    }
+
+    public function down(): void
+    {
+        if (! Schema::hasTable('business_courier_quote_versions')) {
+            return;
+        }
+
+        Schema::table('business_courier_quote_versions', function (Blueprint $table): void {
+            foreach (['billing_structure', 'billing_rows'] as $column) {
+                if (Schema::hasColumn('business_courier_quote_versions', $column)) {
+                    $table->dropColumn($column);
+                }
+            }
+        });
+    }
+};

database/migrations/2026_10_18_220000_index_supplier_bookkeeping_work_orders.php

@@ -0,0 +1,41 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+/** 供应商应付「厂家记账」按工单类型 + 发起时间读取聚工单镜像。 */
+return new class extends Migration
+{
+    private const TABLE = 'js_jst_work_order_info';
+
+    private const INDEX = 'idx_supplier_bookkeeping_created';
+
+    public function up(): void
+    {
+        if (config('system_database.mode', 'bootstrap') === 'bootstrap') {
+            return;
+        }
+
+        $schema = Schema::connection((string) config('upstream_mirrors.connection', 'business_mirror'));
+        if (! $schema->hasTable(self::TABLE) || $schema->hasIndex(self::TABLE, self::INDEX)) {
+            return;
+        }
+
+        $schema->table(self::TABLE, static fn (Blueprint $table) => $table->index(['woTypeId', 'created', 'Id'], self::INDEX));
+    }
+
+    public function down(): void
+    {
+        if (config('system_database.mode', 'bootstrap') === 'bootstrap') {
+            return;
+        }
+
+        $schema = Schema::connection((string) config('upstream_mirrors.connection', 'business_mirror'));
+        if (! $schema->hasTable(self::TABLE) || ! $schema->hasIndex(self::TABLE, self::INDEX)) {
+            return;
+        }
+
+        $schema->table(self::TABLE, static fn (Blueprint $table) => $table->dropIndex(self::INDEX));
+    }
+};

database/migrations/2026_10_19_100000_create_supplier_bookkeeping_configs.php

@@ -0,0 +1,66 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Facades\Schema;
+
+/**
+ * 供应商应付「厂家记账」配置：按供应商记录厂家记账方式（正常记账 / 仅代发仓发错货记账 / 不记账）及生效期。
+ * 与聚工单镜像一样不区分公司；建表后导入财务提供的存量配置（resources/data/supplier-bookkeeping-configs.json）。
+ */
+return new class extends Migration {
+    public function up(): void
+    {
+        Schema::create('business_supplier_bookkeeping_configs', function (Blueprint $table): void {
+            $table->increments('id');
+            $table->string('supplier_name', 191)->unique('supplier_bookkeeping_config_supplier_unique');
+            $table->string('mode', 32);
+            $table->date('effective_from')->nullable();
+            $table->date('effective_to')->nullable();
+            $table->string('source_text', 255)->default('');
+            $table->string('creator', 191);
+            $table->timestamps();
+            $table->softDeletes();
+        });
+        Schema::create('business_supplier_bookkeeping_config_events', function (Blueprint $table): void {
+            $table->increments('id');
+            $table->unsignedInteger('config_id')->nullable()->index();
+            $table->string('actor', 191);
+            $table->string('action', 32);
+            $table->text('description');
+            $table->longText('details');
+            $table->dateTime('created_at');
+        });
+
+        $payload = json_decode((string) file_get_contents(resource_path('data/supplier-bookkeeping-configs.json')), true, 16, JSON_THROW_ON_ERROR);
+        $now = now(config('app.platform_timezone', 'Asia/Shanghai'))->format('Y-m-d H:i:s');
+        $rows = array_map(static fn (array $row): array => [
+            'supplier_name' => $row['supplier_name'],
+            'mode' => $row['mode'],
+            'effective_from' => $row['effective_from'],
+            'effective_to' => $row['effective_to'],
+            'source_text' => $row['source_text'],
+            'creator' => '存量配置导入',
+            'created_at' => $now,
+            'updated_at' => $now,
+        ], $payload['configs']);
+        foreach (array_chunk($rows, 100) as $chunk) {
+            DB::table('business_supplier_bookkeeping_configs')->insert($chunk);
+        }
+        DB::table('business_supplier_bookkeeping_config_events')->insert([
+            'config_id' => null,
+            'actor' => '存量配置导入',
+            'action' => 'import',
+            'description' => '导入存量厂家记账配置：新增' . count($rows) . '条',
+            'details' => json_encode(['added' => count($rows), 'source' => $payload['source']], JSON_UNESCAPED_UNICODE | JSON_THROW_ON_ERROR),
+            'created_at' => $now,
+        ]);
+    }
+
+    public function down(): void
+    {
+        Schema::dropIfExists('business_supplier_bookkeeping_config_events');
+        Schema::dropIfExists('business_supplier_bookkeeping_configs');
+    }
+};

database/migrations/2026_10_19_150000_add_fee_memo_to_account_mapping_rules.php

@@ -0,0 +1,22 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+return new class extends Migration
+{
+    public function up(): void
+    {
+        Schema::table('ec_account_mapping_rules', function (Blueprint $table): void {
+            $table->string('fee_memo', 191)->default('')->after('category');
+        });
+    }
+
+    public function down(): void
+    {
+        Schema::table('ec_account_mapping_rules', function (Blueprint $table): void {
+            $table->dropColumn('fee_memo');
+        });
+    }
+};

database/migrations/2026_10_19_150000_create_account_mapping_resync_jobs.php

@@ -0,0 +1,33 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+/**
+ * 科目映射表变更后，自动重跑业绩明细的待办队列。
+ *
+ * 一条 = 一个「同步平台 × 月份」，由后台命令 store-receipt:auto-resync 逐个消费。
+ */
+return new class extends Migration
+{
+    public function up(): void
+    {
+        Schema::create('ec_account_mapping_resync_jobs', function (Blueprint $table): void {
+            $table->bigIncrements('id');
+            $table->string('platform', 64);
+            $table->string('month', 7);
+            $table->string('status', 16)->default('pending');
+            $table->unsignedInteger('attempts')->default(0);
+            $table->text('message')->nullable();
+            $table->timestamps();
+
+            $table->unique(['platform', 'month'], 'ec_account_mapping_resync_unique');
+        });
+    }
+
+    public function down(): void
+    {
+        Schema::dropIfExists('ec_account_mapping_resync_jobs');
+    }
+};

database/migrations/2026_10_19_160000_create_finance_ledger_tables.php

@@ -0,0 +1,201 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+/**
+ * 财务台账：账户、店铺、公司、期初、动账明细、每日流水和账户映射。
+ *
+ * 财务台账是财务系统自己的业务主数据和派生数据，不是上游镜像，
+ * 因此统一落在 caiwu_business_mirror；不注册到 upstream_mirrors。
+ */
+return new class extends Migration
+{
+    private function connection(): string
+    {
+        return (string) config('upstream_mirrors.connection', 'business_mirror');
+    }
+
+    public function up(): void
+    {
+        $schema = Schema::connection($this->connection());
+
+        if (! $schema->hasTable('fin_accounts')) {
+            $schema->create('fin_accounts', function (Blueprint $table): void {
+                $table->bigIncrements('id');
+                $table->string('company_name', 100);
+                $table->string('account_short', 100);
+                $table->string('region', 50)->nullable();
+                $table->string('account_no', 50)->nullable();
+                $table->string('bank_name', 200)->nullable();
+                $table->string('bank_city_branch', 100)->nullable();
+                $table->string('account_type', 50)->nullable();
+                $table->string('company_plan', 50)->nullable();
+                $table->string('account_last4', 50)->nullable();
+                $table->string('single_limit', 50)->nullable();
+                $table->string('daily_limit', 50)->nullable();
+                $table->string('monthly_limit', 50)->nullable();
+                $table->string('yearly_limit', 50)->nullable();
+                $table->decimal('current_balance', 18, 2)->default(0);
+                $table->decimal('blocked_amount', 18, 2)->default(0);
+                $table->decimal('daily_available', 18, 2)->default(0);
+                $table->decimal('clearing_days', 10, 2)->nullable();
+                $table->string('raise_target', 50)->nullable();
+                $table->string('raise_status', 50)->nullable();
+                $table->string('raise_actions', 500)->nullable();
+                $table->string('done_actions', 500)->nullable();
+                $table->string('next_action', 200)->nullable();
+                $table->string('remark', 500)->nullable();
+                $table->string('owner', 50)->nullable();
+                $table->timestamps();
+
+                $table->index(['company_name'], 'fin_accounts_company_index');
+                $table->index(['account_short'], 'fin_accounts_short_index');
+                $table->index(['owner'], 'fin_accounts_owner_index');
+            });
+        }
+
+        if (! $schema->hasTable('fin_shops')) {
+            $schema->create('fin_shops', function (Blueprint $table): void {
+                $table->bigIncrements('id');
+                $table->string('shop_name', 200);
+                $table->string('platform', 50)->nullable();
+                $table->string('company_name', 100)->nullable();
+                $table->string('account_short', 100)->nullable();
+                $table->string('status', 50)->nullable();
+                $table->string('payout_account', 100)->nullable();
+                $table->decimal('shop_balance', 18, 2)->default(0);
+                $table->string('remark', 500)->nullable();
+                $table->timestamps();
+
+                $table->unique(['shop_name'], 'fin_shops_name_unique');
+                $table->index(['company_name'], 'fin_shops_company_index');
+                $table->index(['platform'], 'fin_shops_platform_index');
+            });
+        }
+
+        if (! $schema->hasTable('fin_companies')) {
+            $schema->create('fin_companies', function (Blueprint $table): void {
+                $table->bigIncrements('id');
+                $table->string('name', 200);
+                $table->string('register_place', 200)->nullable();
+                $table->string('business_type', 50)->nullable();
+                $table->string('tax_type', 50)->nullable();
+                $table->string('status', 20)->nullable();
+                $table->string('basic_bank', 200)->nullable();
+                $table->string('basic_account_last4', 50)->nullable();
+                $table->string('remark', 500)->nullable();
+                $table->timestamps();
+
+                $table->unique(['name'], 'fin_companies_name_unique');
+            });
+        }
+
+        if (! $schema->hasTable('fin_account_opening')) {
+            $schema->create('fin_account_opening', function (Blueprint $table): void {
+                $table->bigIncrements('id');
+                $table->string('account_short', 100);
+                $table->date('opening_date');
+                $table->decimal('opening_balance', 18, 2)->default(0);
+                $table->string('remark', 200)->nullable();
+                $table->timestamps();
+
+                $table->unique(['account_short', 'opening_date'], 'fin_opening_account_date_unique');
+                $table->index(['opening_date'], 'fin_opening_date_index');
+            });
+        }
+
+        if (! $schema->hasTable('fin_transactions')) {
+            $schema->create('fin_transactions', function (Blueprint $table): void {
+                $table->bigIncrements('id');
+                $table->date('txn_date');
+                $table->string('account_short', 100)->nullable();
+                $table->text('detail')->nullable();
+                $table->decimal('income', 18, 2)->default(0);
+                $table->decimal('expense', 18, 2)->default(0);
+                $table->string('approval_no', 100)->nullable();
+                $table->string('source', 20);
+                $table->string('source_value', 200)->nullable();
+                $table->string('process_type', 50)->nullable();
+                $table->string('row_key', 64);
+                $table->timestamp('synced_at')->nullable();
+                $table->timestamps();
+
+                $table->unique(['row_key'], 'fin_transactions_row_key_unique');
+                $table->index(['txn_date'], 'fin_transactions_date_index');
+                $table->index(['account_short'], 'fin_transactions_account_index');
+                $table->index(['source', 'source_value'], 'fin_transactions_source_index');
+                $table->index(['approval_no'], 'fin_transactions_approval_index');
+            });
+        }
+
+        if (! $schema->hasTable('fin_daily_flows')) {
+            $schema->create('fin_daily_flows', function (Blueprint $table): void {
+                $table->bigIncrements('id');
+                $table->date('flow_date');
+                $table->string('company_name', 100)->nullable();
+                $table->string('account_short', 100);
+                $table->decimal('opening_balance', 18, 2)->default(0);
+                $table->decimal('inflow', 18, 2)->default(0);
+                $table->decimal('outflow', 18, 2)->default(0);
+                $table->decimal('closing_balance', 18, 2)->default(0);
+                $table->string('remark', 200)->nullable();
+                $table->timestamps();
+
+                $table->unique(['flow_date', 'account_short'], 'fin_flows_date_account_unique');
+                $table->index(['account_short'], 'fin_flows_account_index');
+            });
+        }
+
+        if (! $schema->hasTable('fin_account_map')) {
+            $schema->create('fin_account_map', function (Blueprint $table): void {
+                $table->bigIncrements('id');
+                $table->string('source', 20);
+                $table->string('source_value', 200);
+                $table->string('account_short', 100)->nullable();
+                $table->unsignedInteger('txn_count')->default(0);
+                $table->decimal('income_sum', 18, 2)->default(0);
+                $table->decimal('expense_sum', 18, 2)->default(0);
+                $table->string('updated_by', 50)->nullable();
+                $table->timestamps();
+
+                $table->unique(['source', 'source_value'], 'fin_account_map_source_unique');
+                $table->index(['account_short'], 'fin_account_map_account_index');
+            });
+        }
+
+        if (! $schema->hasTable('fin_account_map_events')) {
+            $schema->create('fin_account_map_events', function (Blueprint $table): void {
+                $table->bigIncrements('id');
+                $table->string('source', 20);
+                $table->string('source_value', 200);
+                $table->string('old_account_short', 100)->nullable();
+                $table->string('new_account_short', 100)->nullable();
+                $table->unsignedBigInteger('user_id')->nullable();
+                $table->string('user_name', 100)->nullable();
+                $table->timestamp('created_at')->useCurrent();
+
+                $table->index(['source', 'source_value'], 'fin_map_events_source_index');
+            });
+        }
+    }
+
+    public function down(): void
+    {
+        $schema = Schema::connection($this->connection());
+
+        foreach ([
+            'fin_account_map_events',
+            'fin_account_map',
+            'fin_daily_flows',
+            'fin_transactions',
+            'fin_account_opening',
+            'fin_companies',
+            'fin_shops',
+            'fin_accounts',
+        ] as $table) {
+            $schema->dropIfExists($table);
+        }
+    }
+};

database/migrations/2026_10_19_170000_create_work_order_waybill_lookup.php

@@ -0,0 +1,38 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+return new class extends Migration
+{
+    public function up(): void
+    {
+        if (config('system_database.mode', 'bootstrap') === 'bootstrap') return;
+        $schema = Schema::connection((string) config('upstream_mirrors.connection', 'business_mirror'));
+        if (! $schema->hasTable('work_order_waybill_lookup')) {
+            $schema->create('work_order_waybill_lookup', function (Blueprint $table): void {
+                $table->char('mirror_key', 64)->primary();
+                $table->string('waybill', 191);
+                $table->unsignedBigInteger('source_id');
+                $table->index(['waybill', 'source_id'], 'work_order_waybill_source_idx');
+            });
+        }
+        if (! $schema->hasTable('work_order_waybill_lookup_states')) {
+            $schema->create('work_order_waybill_lookup_states', function (Blueprint $table): void {
+                $table->unsignedTinyInteger('id')->primary();
+                $table->char('cursor', 64)->nullable();
+                $table->timestamp('completed_at')->nullable();
+                $table->timestamp('updated_at')->nullable();
+            });
+        }
+    }
+
+    public function down(): void
+    {
+        if (config('system_database.mode', 'bootstrap') === 'bootstrap') return;
+        $schema = Schema::connection((string) config('upstream_mirrors.connection', 'business_mirror'));
+        $schema->dropIfExists('work_order_waybill_lookup_states');
+        $schema->dropIfExists('work_order_waybill_lookup');
+    }
+};

database/migrations/2026_10_19_171000_track_paid_sales_dirty_dates.php

@@ -0,0 +1,50 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+return new class extends Migration
+{
+    public function up(): void
+    {
+        if (config('system_database.mode', 'bootstrap') === 'bootstrap') return;
+        $schema = Schema::connection((string) config('upstream_mirrors.connection', 'business_mirror'));
+        if (! $schema->hasTable('store_report_paid_sales_dirty_dates')) {
+            $schema->create('store_report_paid_sales_dirty_dates', function (Blueprint $table): void {
+                $table->date('occurred_on')->primary();
+                $table->uuid('revision');
+            });
+        }
+        if ($schema->hasTable('store_receipt_order_match_rows')) {
+            $indexed = collect($schema->getIndexes('store_receipt_order_match_rows'))
+                ->contains(fn (array $index) => ($index['columns'][0] ?? null) === 'occurred_date');
+            if (! $indexed) {
+                $connection = $schema->getConnection();
+                if ($connection->getDriverName() === 'mysql') {
+                    // Fail quickly on metadata contention and require an online index build.
+                    $wait = (int) $connection->selectOne('SELECT @@SESSION.lock_wait_timeout AS seconds')->seconds;
+                    $connection->statement('SET SESSION lock_wait_timeout=5');
+                    try {
+                        $table = $connection->getQueryGrammar()->wrapTable('store_receipt_order_match_rows');
+                        $connection->statement('ALTER TABLE ' . $table . ' ADD INDEX store_receipt_paid_sales_date_index (occurred_date), ALGORITHM=INPLACE, LOCK=NONE');
+                    } finally {
+                        $connection->statement('SET SESSION lock_wait_timeout=' . $wait);
+                    }
+                } else {
+                    $schema->table('store_receipt_order_match_rows', fn (Blueprint $table) => $table->index('occurred_date', 'store_receipt_paid_sales_date_index'));
+                }
+            }
+        }
+    }
+
+    public function down(): void
+    {
+        if (config('system_database.mode', 'bootstrap') === 'bootstrap') return;
+        $schema = Schema::connection((string) config('upstream_mirrors.connection', 'business_mirror'));
+        $schema->dropIfExists('store_report_paid_sales_dirty_dates');
+        if ($schema->hasTable('store_receipt_order_match_rows') && collect($schema->getIndexes('store_receipt_order_match_rows'))->contains('name', 'store_receipt_paid_sales_date_index')) {
+            $schema->table('store_receipt_order_match_rows', fn (Blueprint $table) => $table->dropIndex('store_receipt_paid_sales_date_index'));
+        }
+    }
+};

database/migrations/2026_10_19_181000_cover_jd_daily_bill_summary_filters.php

@@ -0,0 +1,40 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+return new class extends Migration
+{
+    public function up(): void
+    {
+        if (config('system_database.mode', 'bootstrap') === 'bootstrap') return;
+        $schema = Schema::connection((string) config('upstream_mirrors.connection', 'business_mirror'));
+        if (! $schema->hasTable('jd_daily_bill_rows')) return;
+        if (collect($schema->getIndexes('jd_daily_bill_rows'))->contains('name', 'jd_daily_summary_cover')) return;
+        $columns = ['generation', 'occurred_at', 'income', 'expense', 'store_name', 'bill_item'];
+        $connection = $schema->getConnection();
+        if ($connection->getDriverName() === 'mysql') {
+            // Platform scope reads store_name: without it SUM must fetch every wide JSON row.
+            $wait = (int) $connection->selectOne('SELECT @@SESSION.lock_wait_timeout AS seconds')->seconds;
+            $connection->statement('SET SESSION lock_wait_timeout=5');
+            try {
+                $table = $connection->getQueryGrammar()->wrapTable('jd_daily_bill_rows');
+                $connection->statement('ALTER TABLE ' . $table . ' ADD INDEX jd_daily_summary_cover (generation, occurred_at, income, expense, store_name, bill_item), ALGORITHM=INPLACE, LOCK=NONE');
+            } finally {
+                $connection->statement('SET SESSION lock_wait_timeout=' . $wait);
+            }
+        } else {
+            $schema->table('jd_daily_bill_rows', fn (Blueprint $table) => $table->index($columns, 'jd_daily_summary_cover'));
+        }
+    }
+
+    public function down(): void
+    {
+        if (config('system_database.mode', 'bootstrap') === 'bootstrap') return;
+        $schema = Schema::connection((string) config('upstream_mirrors.connection', 'business_mirror'));
+        if ($schema->hasTable('jd_daily_bill_rows') && collect($schema->getIndexes('jd_daily_bill_rows'))->contains('name', 'jd_daily_summary_cover')) {
+            $schema->table('jd_daily_bill_rows', fn (Blueprint $table) => $table->dropIndex('jd_daily_summary_cover'));
+        }
+    }
+};

database/migrations/2026_10_19_190000_add_fee_item_to_store_receipt_order_match_rows.php

@@ -0,0 +1,45 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+/**
+ * 业绩明细新增「费用项」列：
+ * 按科目映射表的 fee_memo（费用备注）归集到订单，一单多费用时用顿号连接。
+ * 只用于展示，不参与收入、优惠、冲减、退款和差额计算。
+ */
+return new class extends Migration
+{
+    private function connection(): string
+    {
+        return (string) config('upstream_mirrors.connection', 'business_mirror');
+    }
+
+    public function up(): void
+    {
+        $schema = Schema::connection($this->connection());
+        if (! $schema->hasTable('store_receipt_order_match_rows')) {
+            return;
+        }
+
+        if (! $schema->hasColumn('store_receipt_order_match_rows', 'fee_item')) {
+            $schema->table('store_receipt_order_match_rows', function (Blueprint $table): void {
+                $table->string('fee_item', 191)->nullable()->after('planting_amount');
+            });
+        }
+    }
+
+    public function down(): void
+    {
+        $schema = Schema::connection($this->connection());
+        if (! $schema->hasTable('store_receipt_order_match_rows')
+            || ! $schema->hasColumn('store_receipt_order_match_rows', 'fee_item')) {
+            return;
+        }
+
+        $schema->table('store_receipt_order_match_rows', function (Blueprint $table): void {
+            $table->dropColumn('fee_item');
+        });
+    }
+};

database/migrations/2026_10_20_000000_purge_jd_wallet_from_performance_details.php

@@ -0,0 +1,33 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Facades\Schema;
+
+/**
+ * 京东网银钱包账户不再进入业绩明细：清理历史镜像行，收、支均不展示。
+ */
+return new class extends Migration
+{
+    private function connection(): string
+    {
+        return (string) config('upstream_mirrors.connection', 'business_mirror');
+    }
+
+    public function up(): void
+    {
+        if (! Schema::connection($this->connection())->hasTable('store_receipt_order_match_rows')) {
+            return;
+        }
+
+        DB::connection($this->connection())
+            ->table('store_receipt_order_match_rows')
+            ->where('platform', '京东网银钱包')
+            ->delete();
+    }
+
+    public function down(): void
+    {
+        // 历史镜像可由同步命令重建；本迁移只做排除清理，不回填已删除的数据。
+    }
+};

database/migrations/2026_10_20_010000_drop_fee_item_from_store_receipt_order_match_rows.php

@@ -0,0 +1,42 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+/**
+ * 撤销「费用项」功能：删除业绩明细镜像中的 fee_item 列。
+ */
+return new class extends Migration
+{
+    private function connection(): string
+    {
+        return (string) config('upstream_mirrors.connection', 'business_mirror');
+    }
+
+    public function up(): void
+    {
+        $schema = Schema::connection($this->connection());
+        if (! $schema->hasTable('store_receipt_order_match_rows')
+            || ! $schema->hasColumn('store_receipt_order_match_rows', 'fee_item')) {
+            return;
+        }
+
+        $schema->table('store_receipt_order_match_rows', function (Blueprint $table): void {
+            $table->dropColumn('fee_item');
+        });
+    }
+
+    public function down(): void
+    {
+        $schema = Schema::connection($this->connection());
+        if (! $schema->hasTable('store_receipt_order_match_rows')
+            || $schema->hasColumn('store_receipt_order_match_rows', 'fee_item')) {
+            return;
+        }
+
+        $schema->table('store_receipt_order_match_rows', function (Blueprint $table): void {
+            $table->string('fee_item', 191)->nullable()->after('planting_amount');
+        });
+    }
+};

database/migrations/2026_10_20_020000_add_planting_reimbursement_amount_to_store_receipt_order_match_rows.php

@@ -0,0 +1,46 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+/**
+ * 业绩明细新增「种菜报销」列（放在种菜金额后面）：
+ * 仅按「种菜明细表」的订单号命中，金额取该订单的收入金额。
+ */
+return new class extends Migration
+{
+    private function connection(): string
+    {
+        return (string) config('upstream_mirrors.connection', 'business_mirror');
+    }
+
+    public function up(): void
+    {
+        $schema = Schema::connection($this->connection());
+        if (! $schema->hasTable('store_receipt_order_match_rows')) {
+            return;
+        }
+
+        if (! $schema->hasColumn('store_receipt_order_match_rows', 'planting_reimbursement_amount')) {
+            $schema->table('store_receipt_order_match_rows', function (Blueprint $table): void {
+                $table->decimal('planting_reimbursement_amount', 20, 4)
+                    ->nullable()
+                    ->after('planting_amount');
+            });
+        }
+    }
+
+    public function down(): void
+    {
+        $schema = Schema::connection($this->connection());
+        if (! $schema->hasTable('store_receipt_order_match_rows')
+            || ! $schema->hasColumn('store_receipt_order_match_rows', 'planting_reimbursement_amount')) {
+            return;
+        }
+
+        $schema->table('store_receipt_order_match_rows', function (Blueprint $table): void {
+            $table->dropColumn('planting_reimbursement_amount');
+        });
+    }
+};

database/migrations/2026_10_20_030000_add_planting_unreimbursed_amount_to_store_receipt_order_match_rows.php

@@ -0,0 +1,46 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+/**
+ * 业绩明细新增「种菜未报销」列（放在种菜报销后面）：
+ * 按聚水潭订单标签明细「是否种菜订单=是」且未出现在种菜明细表的订单号命中，金额取收入金额。
+ */
+return new class extends Migration
+{
+    private function connection(): string
+    {
+        return (string) config('upstream_mirrors.connection', 'business_mirror');
+    }
+
+    public function up(): void
+    {
+        $schema = Schema::connection($this->connection());
+        if (! $schema->hasTable('store_receipt_order_match_rows')) {
+            return;
+        }
+
+        if (! $schema->hasColumn('store_receipt_order_match_rows', 'planting_unreimbursed_amount')) {
+            $schema->table('store_receipt_order_match_rows', function (Blueprint $table): void {
+                $table->decimal('planting_unreimbursed_amount', 20, 4)
+                    ->nullable()
+                    ->after('planting_reimbursement_amount');
+            });
+        }
+    }
+
+    public function down(): void
+    {
+        $schema = Schema::connection($this->connection());
+        if (! $schema->hasTable('store_receipt_order_match_rows')
+            || ! $schema->hasColumn('store_receipt_order_match_rows', 'planting_unreimbursed_amount')) {
+            return;
+        }
+
+        $schema->table('store_receipt_order_match_rows', function (Blueprint $table): void {
+            $table->dropColumn('planting_unreimbursed_amount');
+        });
+    }
+};

database/migrations/2026_10_20_120000_create_finance_ledger_account_statuses.php

@@ -0,0 +1,41 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+/**
+ * 财务台账账户状态。
+ *
+ * 状态由财务人员在页面维护，独立于可被全量覆盖的 fin_accounts 基础表，
+ * 因此重新导入《银行当前余额》不会丢失。
+ */
+return new class extends Migration
+{
+    private function connection(): string
+    {
+        return (string) config('upstream_mirrors.connection', 'business_mirror');
+    }
+
+    public function up(): void
+    {
+        $schema = Schema::connection($this->connection());
+
+        if (! $schema->hasTable('fin_account_statuses')) {
+            $schema->create('fin_account_statuses', function (Blueprint $table): void {
+                $table->bigIncrements('id');
+                $table->string('account_short', 100)->unique('fin_account_statuses_account_unique');
+                $table->string('status', 40)->default('normal');
+                $table->string('updated_by', 100)->nullable();
+                $table->timestamps();
+
+                $table->index(['status'], 'fin_account_statuses_status_index');
+            });
+        }
+    }
+
+    public function down(): void
+    {
+        Schema::connection($this->connection())->dropIfExists('fin_account_statuses');
+    }
+};

database/migrations/2026_10_20_140000_create_finance_ledger_account_type_overrides.php

@@ -0,0 +1,40 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+/**
+ * 财务台账账户类型人工维护值。
+ *
+ * 基础表 fin_accounts 在导入时会被全量覆盖，因此人工调整后的类型单独保存。
+ */
+return new class extends Migration
+{
+    private function connection(): string
+    {
+        return (string) config('upstream_mirrors.connection', 'business_mirror');
+    }
+
+    public function up(): void
+    {
+        $schema = Schema::connection($this->connection());
+
+        if (! $schema->hasTable('fin_account_type_overrides')) {
+            $schema->create('fin_account_type_overrides', function (Blueprint $table): void {
+                $table->bigIncrements('id');
+                $table->string('account_short', 100)->unique('fin_account_type_overrides_account_unique');
+                $table->string('account_type', 50)->nullable();
+                $table->string('updated_by', 100)->nullable();
+                $table->timestamps();
+
+                $table->index(['account_type'], 'fin_account_type_overrides_type_index');
+            });
+        }
+    }
+
+    public function down(): void
+    {
+        Schema::connection($this->connection())->dropIfExists('fin_account_type_overrides');
+    }
+};

database/migrations/2026_10_20_190000_create_jushuitan_cost_price_observations.php

@@ -0,0 +1,48 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+return new class extends Migration
+{
+    public function up(): void
+    {
+        if (app()->environment('testing') || config('system_database.mode', 'bootstrap') === 'bootstrap') {
+            return;
+        }
+        $schema = Schema::connection(config('upstream_mirrors.connection', 'business_mirror'));
+        // 生产可能保留旧 SKU 级快照；使用独立源行基线，不修改或删除旧表。
+        if (! $schema->hasTable('jushuitan_cost_price_observation_baselines')) {
+            $schema->create('jushuitan_cost_price_observation_baselines', function (Blueprint $table): void {
+                $table->char('source_key', 64)->primary();
+                $table->string('sku_id', 255);
+                $table->decimal('cost_price', 20, 4);
+                $table->dateTime('captured_at', 6);
+            });
+        }
+        if (! $schema->hasTable('jushuitan_cost_price_observations')) {
+            $schema->create('jushuitan_cost_price_observations', function (Blueprint $table): void {
+                $table->char('id', 64)->primary();
+                $table->char('source_key', 64);
+                $table->string('sku_id', 255);
+                $table->decimal('before_price', 20, 4);
+                $table->decimal('after_price', 20, 4);
+                $table->dateTime('previous_observed_at', 6);
+                $table->dateTime('observed_at', 6);
+                $table->dateTime('source_modified_at', 6)->nullable();
+                $table->index(['source_key', 'observed_at', 'id'], 'jst_cost_observations_lookup');
+            });
+        }
+    }
+
+    public function down(): void
+    {
+        if (app()->environment('testing') || config('system_database.mode', 'bootstrap') === 'bootstrap') {
+            return;
+        }
+        $schema = Schema::connection(config('upstream_mirrors.connection', 'business_mirror'));
+        $schema->dropIfExists('jushuitan_cost_price_observations');
+        $schema->dropIfExists('jushuitan_cost_price_observation_baselines');
+    }
+};

database/migrations/2026_10_21_100000_create_after_sales_cost_rows.php

@@ -0,0 +1,45 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+/**
+ * 聚水潭「商品利润 → 导出明细数据 → 订单售后费用数据」导入明细。
+ *
+ * 聚水潭报表已按商品编码（组合装拆成组件）给出行和成本，这里原样保留每行字段，
+ * 订单售后费用明细页面在导入数据覆盖的店铺/日期范围内优先读这张表。
+ */
+return new class extends Migration
+{
+    public function up(): void
+    {
+        Schema::create('ops_after_sales_cost_rows', function (Blueprint $table): void {
+            $table->bigIncrements('id');
+            $table->string('row_key', 40)->unique();
+            $table->string('shop_name', 191);
+            $table->string('shop_code', 64)->nullable();
+            $table->string('online_order_no', 64)->nullable();
+            $table->string('internal_order_no', 64)->nullable();
+            $table->string('product_code', 191)->nullable();
+            $table->dateTime('order_time')->nullable();
+            $table->decimal('product_quantity', 14, 2)->default(0);
+            $table->decimal('product_amount', 16, 2)->default(0);
+            $table->decimal('product_cost', 16, 2)->default(0);
+            $table->string('cost_source', 32)->nullable();
+            $table->string('combine_type', 32)->nullable();
+            $table->json('payload');
+            $table->timestamp('imported_at')->nullable();
+            $table->timestamps();
+
+            $table->index(['shop_name', 'order_time']);
+            $table->index('online_order_no');
+            $table->index('product_code');
+        });
+    }
+
+    public function down(): void
+    {
+        Schema::dropIfExists('ops_after_sales_cost_rows');
+    }
+};

database/migrations/2026_10_21_120000_add_account_should_keep_to_fin_accounts.php

@@ -0,0 +1,35 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+return new class extends Migration
+{
+    private function connection(): string
+    {
+        return (string) config('upstream_mirrors.connection', 'business_mirror');
+    }
+
+    public function up(): void
+    {
+        $schema = Schema::connection($this->connection());
+        if (! $schema->hasTable('fin_accounts') || $schema->hasColumn('fin_accounts', 'account_should_keep')) {
+            return;
+        }
+
+        $schema->table('fin_accounts', function (Blueprint $table): void {
+            $table->string('account_should_keep', 20)->nullable()->after('company_plan');
+        });
+    }
+
+    public function down(): void
+    {
+        $schema = Schema::connection($this->connection());
+        if ($schema->hasTable('fin_accounts') && $schema->hasColumn('fin_accounts', 'account_should_keep')) {
+            $schema->table('fin_accounts', function (Blueprint $table): void {
+                $table->dropColumn('account_should_keep');
+            });
+        }
+    }
+};

database/migrations/2026_10_21_150000_create_finance_ledger_account_todos.php

@@ -0,0 +1,39 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+return new class extends Migration
+{
+    private function connection(): string
+    {
+        return (string) config('upstream_mirrors.connection', 'business_mirror');
+    }
+
+    public function up(): void
+    {
+        $schema = Schema::connection($this->connection());
+        if (! $schema->hasTable('fin_accounts') || $schema->hasTable('fin_account_todos')) {
+            return;
+        }
+
+        $schema->create('fin_account_todos', function (Blueprint $table): void {
+            $table->bigIncrements('id');
+            $table->string('account_short', 100)->unique('fin_account_todos_account_unique');
+            $table->text('abnormal_reason')->nullable();
+            $table->string('handling_method', 20)->nullable();
+            $table->string('owner_name', 100)->nullable();
+            $table->dateTime('started_at')->nullable();
+            $table->dateTime('completed_at')->nullable();
+            $table->string('current_progress', 100)->nullable();
+            $table->string('updated_by', 100)->nullable();
+            $table->timestamps();
+        });
+    }
+
+    public function down(): void
+    {
+        Schema::connection($this->connection())->dropIfExists('fin_account_todos');
+    }
+};

database/migrations/2026_10_21_150000_create_supplier_portal_identities.php

@@ -0,0 +1,35 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+return new class extends Migration
+{
+    public function up(): void
+    {
+        if (Schema::hasTable('supplier_portal_identities')) {
+            return;
+        }
+
+        Schema::create('supplier_portal_identities', function (Blueprint $table): void {
+            $table->bigIncrements('id');
+            $table->unsignedInteger('company_id');
+            $table->unsignedInteger('user_id')->unique();
+            $table->string('supplier_code', 191)->nullable();
+            $table->string('supplier_name', 191);
+            $table->unsignedBigInteger('dingtalk_group_id');
+            $table->string('dingtalk_group_name', 191);
+            $table->timestamp('last_verified_at')->nullable();
+            $table->timestamps();
+
+            $table->index(['company_id', 'supplier_name'], 'supplier_portal_company_name');
+            $table->index(['company_id', 'dingtalk_group_id'], 'supplier_portal_company_group');
+        });
+    }
+
+    public function down(): void
+    {
+        Schema::dropIfExists('supplier_portal_identities');
+    }
+};

database/migrations/2026_10_21_160000_add_completion_status_to_finance_ledger_account_todos.php

@@ -0,0 +1,39 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+return new class extends Migration
+{
+    private function connection(): string
+    {
+        return (string) config('upstream_mirrors.connection', 'business_mirror');
+    }
+
+    public function up(): void
+    {
+        $schema = Schema::connection($this->connection());
+        if (! $schema->hasTable('fin_account_todos') || $schema->hasColumn('fin_account_todos', 'completion_status')) {
+            return;
+        }
+
+        $schema->table('fin_account_todos', function (Blueprint $table): void {
+            $table->string('completion_status', 20)->default('not_started')->after('current_progress');
+            $table->index(['completion_status'], 'fin_account_todos_completion_status_index');
+        });
+    }
+
+    public function down(): void
+    {
+        $schema = Schema::connection($this->connection());
+        if (! $schema->hasTable('fin_account_todos') || ! $schema->hasColumn('fin_account_todos', 'completion_status')) {
+            return;
+        }
+
+        $schema->table('fin_account_todos', function (Blueprint $table): void {
+            $table->dropIndex('fin_account_todos_completion_status_index');
+            $table->dropColumn('completion_status');
+        });
+    }
+};

database/migrations/2026_10_21_170000_create_finance_ledger_account_keep_todos.php

@@ -0,0 +1,39 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+return new class extends Migration
+{
+    private function connection(): string
+    {
+        return (string) config('upstream_mirrors.connection', 'business_mirror');
+    }
+
+    public function up(): void
+    {
+        $schema = Schema::connection($this->connection());
+        if (! $schema->hasTable('fin_accounts') || $schema->hasTable('fin_account_keep_todos')) {
+            return;
+        }
+
+        $schema->create('fin_account_keep_todos', function (Blueprint $table): void {
+            $table->bigIncrements('id');
+            $table->string('account_short', 100)->unique('fin_account_keep_todos_account_unique');
+            $table->string('handling_method', 20)->nullable();
+            $table->string('owner_name', 100)->nullable();
+            $table->dateTime('started_at')->nullable();
+            $table->dateTime('completed_at')->nullable();
+            $table->string('current_progress', 20)->default('not_started');
+            $table->string('updated_by', 100)->nullable();
+            $table->timestamps();
+            $table->index(['current_progress'], 'fin_account_keep_todos_progress_index');
+        });
+    }
+
+    public function down(): void
+    {
+        Schema::connection($this->connection())->dropIfExists('fin_account_keep_todos');
+    }
+};

database/migrations/2026_10_22_090000_add_manual_metadata_to_finance_ledger_transactions.php

@@ -0,0 +1,53 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Database\Schema\Blueprint;
+use Illuminate\Support\Facades\Schema;
+
+return new class extends Migration
+{
+    private function connection(): string
+    {
+        return (string) config('upstream_mirrors.connection', 'business_mirror');
+    }
+
+    public function up(): void
+    {
+        $schema = Schema::connection($this->connection());
+        if (! $schema->hasTable('fin_transactions')) {
+            return;
+        }
+
+        if (! $schema->hasColumn('fin_transactions', 'created_by')) {
+            $schema->table('fin_transactions', function (Blueprint $table): void {
+                $table->string('created_by', 100)->nullable()->after('updated_at');
+            });
+        }
+
+        if (! $schema->hasColumn('fin_transactions', 'updated_by')) {
+            $schema->table('fin_transactions', function (Blueprint $table): void {
+                $table->string('updated_by', 100)->nullable()->after('created_by');
+            });
+        }
+    }
+
+    public function down(): void
+    {
+        $schema = Schema::connection($this->connection());
+        if (! $schema->hasTable('fin_transactions')) {
+            return;
+        }
+
+        if ($schema->hasColumn('fin_transactions', 'updated_by')) {
+            $schema->table('fin_transactions', function (Blueprint $table): void {
+                $table->dropColumn('updated_by');
+            });
+        }
+
+        if ($schema->hasColumn('fin_transactions', 'created_by')) {
+            $schema->table('fin_transactions', function (Blueprint $table): void {
+                $table->dropColumn('created_by');
+            });
+        }
+    }
+};

database/migrations/2026_10_22_150000_index_goods_profit_afs_order_time.php

@@ -0,0 +1,42 @@
+<?php
+
+use Illuminate\Database\Migrations\Migration;
+use Illuminate\Support\Facades\DB;
+use Illuminate\Support\Facades\Schema;
+use Modules\EcommerceFinance\Services\GoodsProfitAfsLookupSchema;
+
+return new class extends Migration
+{
+    public function up(): void
+    {
+        if (config('system_database.mode', 'bootstrap') === 'bootstrap') return;
+
+        app(GoodsProfitAfsLookupSchema::class)->ensure(
+            DB::connection((string) config('upstream_mirrors.connection', 'business_mirror')),
+        );
+    }
+
+    public function down(): void
+    {
+        if (config('system_database.mode', 'bootstrap') === 'bootstrap') return;
+        $db = DB::connection((string) config('upstream_mirrors.connection', 'business_mirror'));
+        if (! in_array($db->getDriverName(), ['mysql', 'mariadb'], true)) return;
+        $schema = Schema::connection($db->getName());
+        if (! $schema->hasTable(GoodsProfitAfsLookupSchema::TABLE)) return;
+
+        $changes = [];
+        foreach (array_keys(GoodsProfitAfsLookupSchema::INDEXES) as $index) {
+            if ($schema->hasIndex(GoodsProfitAfsLookupSchema::TABLE, $index)) {
+                $changes[] = 'DROP INDEX `' . $index . '`';
+            }
+        }
+        if ($changes !== []) {
+            $db->statement('ALTER TABLE `' . GoodsProfitAfsLookupSchema::TABLE . '` '
+                . implode(', ', $changes) . ', ALGORITHM=INPLACE, LOCK=NONE');
+        }
+        if ($schema->hasColumn(GoodsProfitAfsLookupSchema::TABLE, GoodsProfitAfsLookupSchema::DATE_COLUMN)) {
+            $db->statement('ALTER TABLE `' . GoodsProfitAfsLookupSchema::TABLE . '` DROP COLUMN `'
+                . GoodsProfitAfsLookupSchema::DATE_COLUMN . '`, ALGORITHM=INPLACE, LOCK=NONE');
+        }
+    }
+};

deploy/Dockerfile

@@ -1,4 +1,11 @@
-FROM php:8.3-apache-bookworm@sha256:fa8852a2e01747ffe8c8768bfd6bbc2f296f974aa0de90ee157a66664996d263 AS php-base
+FROM php:8.3.36-apache-bookworm@sha256:cbd3b3d9011668443d54ab40ec31db56c73d91b4c8198935d639aa80d2d815c1 AS php-base
+
+# 国内构建机访问 deb.debian.org 常被代理拦截（502），统一改用清华 Debian 镜像。
+RUN set -eu; \
+    for f in /etc/apt/sources.list /etc/apt/sources.list.d/*.sources /etc/apt/sources.list.d/*.list; do \
+        [ -f "$f" ] || continue; \
+        sed -i 's|deb.debian.org|mirrors.tuna.tsinghua.edu.cn|g; s|security.debian.org|mirrors.tuna.tsinghua.edu.cn|g' "$f"; \
+    done
 
 RUN apt-get -o Acquire::Retries=3 update \
     && apt-get -o Acquire::Retries=3 install -y --no-install-recommends \

deploy/Dockerfile.local

@@ -4,7 +4,7 @@
 # 基于 deploy/Dockerfile，额外安装 composer 依赖与前端构建产物
 # 由 docker-compose.local.yml 使用
 
-FROM php:8.3-apache-bookworm
+FROM php:8.3.36-apache-bookworm@sha256:cbd3b3d9011668443d54ab40ec31db56c73d91b4c8198935d639aa80d2d815c1
 
 # ---------------- 系统依赖 + PHP 扩展 ----------------
 ENV DEBIAN_FRONTEND=noninteractive
@@ -41,7 +41,7 @@ RUN apt-get update \
         g++ \
     && docker-php-ext-configure gd --with-freetype --with-jpeg \
     && docker-php-ext-configure pdo_odbc --with-pdo-odbc=unixODBC,/usr \
-    && docker-php-ext-install -j"$(nproc)" \
+    && docker-php-ext-install -j2 \
         bcmath \
         curl \
         dom \
@@ -61,8 +61,8 @@ RUN apt-get update \
 COPY --from=composer:2 /usr/bin/composer /usr/bin/composer
 
 # ---------------- Node.js (LTS) ----------------
-COPY --from=node:20-bookworm-slim /usr/local/bin/node /usr/local/bin/node
-COPY --from=node:20-bookworm-slim /usr/local/lib/node_modules /usr/local/lib/node_modules
+COPY --from=node:24.22.1-bookworm-slim@sha256:55fb5f5a527ea2c5c4a95f963e48ef90aa38c7b346054fdc8ee9957a2b55d205 /usr/local/bin/node /usr/local/bin/node
+COPY --from=node:24.22.1-bookworm-slim@sha256:55fb5f5a527ea2c5c4a95f963e48ef90aa38c7b346054fdc8ee9957a2b55d205 /usr/local/lib/node_modules /usr/local/lib/node_modules
 RUN ln -s /usr/local/lib/node_modules/npm/bin/npm-cli.js /usr/local/bin/npm \
     && ln -s /usr/local/lib/node_modules/npm/bin/npx-cli.js /usr/local/bin/npx
 

deploy/activate-incremental-release.sh

@@ -7,6 +7,11 @@ REMOTE_DIR="${3:-/opt/caiwuxitong}"
 DEPLOY_SHA="${4:?DEPLOY_SHA is required}"
 RUN_MIGRATIONS="${5:-0}"
 KEEP_IMAGES="${6:-2}"
+EXPECTED_PREVIOUS_SHA="${7:?Checked production revision is required; update the deployment scripts}"
+DEPLOY_ACTOR="${8:-unknown}"
+RELEASE_APP_URL="${9:-}"
+RELEASE_DIR="$(CDPATH= cd -- "$(dirname -- "$0")" && pwd)"
+. "$RELEASE_DIR/release-guard.sh"
 IMAGE_NAME="caiwu_akaunting"
 LOCK_FILE="$REMOTE_DIR/.deploy.lock"
 REGISTRY_API="http://127.0.0.1:5000/v2/caiwuxitong/app"
@@ -65,6 +70,12 @@ if ! flock -n 9; then
     exit 1
 fi
 
+RELEASE_STARTED_AT="$(date -u +%Y-%m-%dT%H:%M:%SZ)"
+RELEASE_RESULT=blocked
+trap 'release_status=$?; caiwu_record_release_result "$release_status"' EXIT
+trap 'exit 130' INT
+trap 'exit 143' TERM
+
 # 容器替换会终止其中的同步进程；与生产刷新任务共享同一把锁。
 exec 8>/run/caiwu-upstream-sync.lock
 echo "Waiting for active upstream synchronization before replacing the application container"
@@ -74,7 +85,8 @@ if ! flock -w 1800 8; then
 fi
 
 PREVIOUS_IMAGE="$(docker inspect caiwu_app --format '{{.Config.Image}}' 2>/dev/null || true)"
-PREVIOUS_SHA="$(cat "$REMOTE_DIR/.deployed-sha" 2>/dev/null || true)"
+caiwu_verify_release_base
+RELEASE_RESULT=running
 
 restore_previous_image() {
     case "$PREVIOUS_IMAGE" in
@@ -96,6 +108,8 @@ if [ "$LOADED_SHA" != "$DEPLOY_SHA" ]; then
     exit 1
 fi
 
+caiwu_install_release_files
+
 cd "$REMOTE_DIR"
 export IMAGE_TAG RUN_MIGRATIONS
 
@@ -189,13 +203,15 @@ CRON_TZ=Asia/Shanghai
 * * * * * root /usr/bin/flock -n /run/caiwu-upstream-sync.lock /bin/sh -c '/usr/bin/docker exec -u www-data caiwu_app php artisan business-mirror:sync-product-catalog --quiet; /usr/bin/docker exec -u www-data caiwu_app php artisan business-mirror:sync-product-purchase-prices --quiet; /usr/bin/docker exec -u www-data caiwu_app php artisan upstream:snapshots:refresh-all --quiet; /usr/bin/docker exec -u www-data caiwu_app php artisan business-mirror:sync-product-prices --quiet; /usr/bin/docker exec -u www-data caiwu_app php artisan business-mirror:sync-tables --quiet' >/dev/null 2>&1
 # 店铺经营报表按 15 分钟刷新；单轮覆盖 50000 行回看窗口，避免空闲时持续重读千万级账单。
 7,22,37,52 * * * * root /usr/bin/flock -w 600 /run/caiwu-upstream-sync.lock /usr/bin/docker exec -u www-data caiwu_app php artisan business-mirror:sync-store-report --max-batches=12 --quiet >/dev/null 2>&1
-# 订单售后费用明细的店铺候选：完整列表要扫两张百万级订单宽表（约 2 分钟），放定时任务预热；
-# 页面冷缓存时先用毫秒级的店铺目录兜底，避免请求一直不结束、页面一直转圈。
+# 店铺候选平时仅读镜像变更；夜间全量核对历史名称。冷页面不扫描订单宽表。
 45 * * * * root /usr/bin/flock -w 600 /run/caiwu-upstream-sync.lock /usr/bin/docker exec -u www-data caiwu_app php artisan order-data:warm-shop-candidates --quiet >/dev/null 2>&1
+45 2 * * * root /bin/sh /opt/caiwuxitong/run-finance-batch.sh order-data:warm-shop-candidates --full --quiet >/dev/null 2>&1
 # 页面字段自动跟随上游：先刷新数据字典，再把上游新增字段补进镜像并建列，页面自动多出这一列。
 40 6 * * * root /usr/bin/flock -w 1800 /run/caiwu-upstream-sync.lock /usr/bin/docker exec -u www-data caiwu_app php artisan business-mirror:follow-upstream-columns --quiet >/dev/null 2>&1
 0 0 * * * root /usr/bin/flock -w 3600 /run/caiwu-upstream-sync.lock /bin/sh -c '/usr/bin/docker exec -u www-data caiwu_app php artisan business-mirror:sync-third-party-warehouse-storage --max-batches=0 --quiet && /usr/bin/docker exec -u www-data caiwu_app php artisan business-mirror:warm-report-caches --quiet' >/dev/null 2>&1
 0 0 * * * root /usr/bin/flock -w 3600 /run/caiwu-upstream-sync.lock /usr/bin/docker exec -u www-data caiwu_app php artisan business-mirror:sync-jushuitan-cost-price-history --quiet >/dev/null 2>&1
+# 镜像价格观测独立保存，按索引分批续传，不替代正式操作历史。
+3,13,23,33,43,53 * * * * root /usr/bin/flock -n /run/caiwu-upstream-sync.lock /usr/bin/docker exec -u www-data caiwu_app php artisan business-mirror:sync-jushuitan-cost-price-history --source=snapshot --page-size=500 --max-pages=20 --quiet >/dev/null 2>&1
 0 5 * * * root /usr/bin/flock -w 3600 /run/caiwu-upstream-sync.lock /bin/sh -c '/usr/bin/docker exec -u www-data caiwu_app php artisan business-mirror:sync-product-purchase-prices --quiet; /usr/bin/docker exec -u www-data caiwu_app php artisan business-mirror:sync-tables operations_replica.rpt.jst_Orders --quiet; /usr/bin/docker exec -u www-data caiwu_app php artisan business-mirror:sync-ding-online-daifa-price --quiet' >/dev/null 2>&1
 # 店铺违规信息预警：每天 05:30 把副本库抓取结果追平到统一表（本地补充字段不覆盖）。
 30 5 * * * root /usr/bin/flock -w 1800 /run/caiwu-upstream-sync.lock /usr/bin/docker exec -u www-data caiwu_app php artisan store-violations:sync --quiet >/dev/null 2>&1
@@ -205,7 +221,12 @@ CRON_TZ=Asia/Shanghai
 # 供应商管理每天北京时间 08:15 完整校准档案、合同、联系人与打款资料。
 15 8 * * * root /usr/bin/flock -w 3600 /run/caiwu-upstream-sync.lock /usr/bin/docker exec -u www-data caiwu_app php artisan business-mirror:sync-supplier-management --quiet >/dev/null 2>&1
 */2 * * * * root /usr/bin/flock -n /run/caiwu-esign-polling.lock /usr/bin/docker exec -u www-data caiwu_app php artisan esign:poll-signatures --quiet >/dev/null 2>&1
-28 1 * * * root /usr/bin/flock -w 1800 /run/caiwu-upstream-sync.lock /usr/bin/docker exec -u www-data caiwu_app php artisan jushuitan:sync-shipping --days=3 >/dev/null 2>&1
+# 财务台账：每天 02:30 从 AI 库 rpt 同步动账明细并重算流水。
+30 2 * * * root /usr/bin/flock -w 1800 /run/caiwu-upstream-sync.lock /usr/bin/docker exec -u www-data caiwu_app php artisan finance-ledger:sync-rpt --days=7 --merge --quiet >/dev/null 2>&1
+# 科目映射保存后保留自动重跑队列，每分钟在受限容器内串行消费。
+* * * * * root /usr/bin/flock -n /run/caiwu-account-mapping-resync.lock /bin/sh /opt/caiwuxitong/run-finance-batch.sh store-receipt:auto-resync --quiet >/dev/null 2>&1
+* * * * * root /usr/bin/flock -n /run/caiwu-account-bills-export.lock /bin/sh /opt/caiwuxitong/run-finance-batch.sh account-bills:exports:run --quiet >/dev/null 2>&1
+28 1 * * * root /bin/sh /opt/caiwuxitong/run-finance-batch.sh jushuitan:sync-shipping --days=3 >/dev/null 2>&1
 # 头条放心购（店铺收款账户账单 › 抖音账户）资金流水：每天 09:30 定点把该渠道所用
 # 原始账单镜像追平一次，保证上班前当日/前一日流水已进系统，而不是等每分钟轮转慢慢走。
 30 9 * * * root /usr/bin/flock -w 1800 /run/caiwu-upstream-sync.lock /usr/bin/docker exec -u www-data caiwu_app php artisan business-mirror:sync-tables operations_replica.rpt.jst_originalBillInfo --max-batches=20 --quiet >/dev/null 2>&1