Compare commits

...

12 Commits

Author SHA1 Message Date
54ad6aad89 Merge pull request 'fix(wle): 0 单不再冒充「全部正常」——窗口空时查数据源是否停更' (#94) from yanhui-wle-emptydata-1102 into main 2026-11-02 13:32:49 +08:00
555ac6b116 fix(wle): 0 单不再冒充「全部正常」——窗口空时查数据源是否停更
11-02 09:00 那批推到钉钉群的是「已发货 0 单 / 0 个包裹,异常 0 个包裹(0%)」,
业务问「怎么可能 0 单」。查库确认:物流镜像表 jst_order_express_details
最后灌库停在 2026-11-01 07:55,11-01 当天 12 个发货仓一条发货记录都没有
(订单表 jst_Orders 同日有 4601 单发货,说明货是真发了,只是物流没进库)。

根因不是口径,是「0 单没有告警」这个设计缺陷:freshness 只用本批窗口内行的
query_time 算,窗口一行都没有时 snapshotAt 为空串 → stale=false、hint='',
于是「上游没同步」和「当天真没发货」在页面和钉钉里长得完全一样,还写「全部正常」。

改动
- service:窗口 0 行时补查一次表级 MAX(query_time)(全表 13.5s,只在空窗口付这笔钱,
  随主结果进 5 分钟缓存),新增 freshness.emptyWindow / sourceLastUpdate /
  sourceAgeMinutes / sourceStale,并按「真停更 / 表新但当天无记录 / 取不到时间」
  三种情况给不同 hint。
- 钉钉正文:0 条时不再无脑写「本批无转运异常,全部正常」;真停更写
  「⚠️ 物流数据未同步:镜像表最后更新 …(已 N 小时未同步)… 0 单不代表当天没发货」,
  表新但当天无记录则说明「库里 0 条发货记录(数据源正常),请到聚水潭核对」。
- 前端:emptyWindow 走红条(原来只判 coversDeadline/stale,空窗口不告警),
  发货卡片副标改为「数据未同步,见上方红条」。
- 前端顺带修:钉钉消息链接带 ?date=YYYY-MM-DD,但页面从不读这个参数,
  点进去永远显示「今天这批」;现按 URL 初始化核验日。

验证
- npm --prefix backend run check:505 tests / 503 pass;新增 5 个用例
  (停更 hint、表新但 0 条、有行时不付全表 MAX、推送文案两态)全过。
  既有失败 2 个与本任务无关:cloudDatabaseConfigCache 负缓存 TTL、
  resilientSecretStore 的 Windows 0600 权限断言。
- 生产库实跑(本地 4002,直连 JSReportReplica):
  date=2026-11-02 → emptyWindow=true、sourceLastUpdate=2026-11-01 07:55:04、
  sourceAgeMinutes≈1590、hint 正确;date=2026-11-01 → 4390 单 / 9 异常、
  emptyWindow=false,原有「未覆盖核验时刻」提示不变。
- 钉钉 dryRun 正文实测:前 3 行即带「⚠️ 物流数据未同步 … 0 单不代表当天没发货」。
- Playwright 真渲染(5173):
  ?date=2026-11-02 → 红条 + 「数据未同步,见上方红条」,0 pageerror;
  ?date=2026-11-01 → 4,390 单 / 9 异常正常出表,且 URL 参数已生效。
- 前端 eslint 干净,vite build 通过。

风险与回退
- 只增字段与提示,不改任何统计口径;packageCount/shippedOrders 计算逻辑未动。
- 空窗口多一条全表 MAX 查询(13.5s),已用 5 分钟缓存兜住,且只在异常路径触发。
- 回退:单文件 revert 本提交即可,无数据结构变更。
2026-11-02 10:31:11 +08:00
b955e78ba2 Merge pull request 'fix(wst): 用聚水潭状态终态 + 销售出库单判作废/已发' (#93) from yanhui-wst-void-1029 into main 2026-10-29 15:38:51 +08:00
54518ab4d3 fix(wst): 把销售出库单纳入作废判据与停更监控
业务 14:34 点名 9992097 / 9992098 / 9992924 / 9992925 / 9992926 /
9993284 / 9993285 / 9995464 / 9995465「洛宁仓 16 单都是作废订单,为啥还在
考核之内」,并指明「在聚水潭的销售出库单里面找一下这个作废单据」。

## 查出来的事实

这 9 单在库里**三处全部显示「还在发货」**:

  订单表 qmcust      status=Delivering、send_date 空
  销售出库单         status=WaitConfirm(待出库)
  状态镜像表         order_status_name=发货中、logistics=无物流单

不是判据漏了,是**三条数据源全停在作废动作之前**(2026-10-29 15:13 实测):

  jst_Orders             14:45  正常
  qmcust                 13:25  滞后 1.8h
  状态镜像表              11:52  滞后 3.4h
  出库单(聚水潭/奇门)      03:10  滞后 12.0h  ← 作废就落在这张表上

聚水潭的作废落在**出库单** `status='Delete'` 上,而这张表今天凌晨 3 点后
零写入,所以上午作的废一条都没进来

## 改动

1. 新增 `loadOrderIoStatus()`:按 o_id 批量取出库单状态(两表、
   分批 500 / 并发 3),判据是 **「该 o_id 下没有任何非 Delete 的出库单」**。
   - 只对「发货中」生效:全库「出库单全 Delete」的候选单里 127/131
     状态表是「异常」,那批还挂着待处理,删出库单更可能是重开单,
     当成作废剔会让业务在「不计考核」里也看不到 → 丢可见性比漏剔更糟
   - 拆包/重开的单有多张出库单,删一张不算作废(实测 51 单里 7 单是这种)
   - **「没有出库单」绝不判作废**:近 3 天未发单 82%(1467/1790)本来就没出库单
2. 两张出库单表纳入 `loadSourceFreshness()`(用 local_updated / updateTime
   灌库时刻,**不能用 modified**,否则没变更时天天误报)
3. 新增 `freshness.voidJudgeReliable` + hint 明说「作废单/取消单可能判不出来」,
   告诉业务去聚水潭「销售出库单」核对
4. 明细加「销售出库单」列(已作废/待出库/已出库/未建单),导出同步加列

## 验证

- WST 单测 27/27(新增:出库单全删必剔 / 拆包重开不剔 / 异常单不剔 /
  无出库单不剔 / 停更时提示作废判不出来 / 源正常时不误报)
- 后端全量 498/500(2 个既有失败:负缓存 TTL、Windows 文件权限)
- 真实数据:ioVoidSkipped=11(发货中 + 出库单全删),overdue 仍 16 单
- 本地真渲染:表头有「销售出库单」、首行显示「待出库」、
  红条列出 5 个数据源停更状态、**pageerror 0**

## 没解决(已在页面明说,不掩盖)

这 9 单今天仍然判不出作废 —— 数据没进来,判据再准也没用。
根子在 ETL:出库单表停 12 小时。ETL 恢复后判据立即生效,
但那 9 单是否作废仍需 IT 修同步或业务在聚水潭复核。
2026-10-29 15:16:25 +08:00
1139e4c364 fix(wst): 用聚水潭状态终态判作废/已发,修「作废单已发单还在考核里」
业务 2026-10-29 第三次报同一件事:13:00 轮里作废的单、已经发货的单还在考核。
根因不是判定写错,而是**订单两表各自停更**,停更期间聚水潭做的「取消 / 发货」
订单表完全看不到 —— status 仍是 Delivering、send_date 仍是空。

## 现场证据(2026-10-29 13:00 轮)

- 当天 qmcust 停在 07:25(6 小时),13:00 轮 159 单**全部**来自它
- 订单表侧:159 单 status 全 Delivering、send_date 全空、labels 里**没有**
  「发货前售后」⟹ 原来的 `presaleVoid` 判据(订单表 labels 含关键词)完全失效
- 状态镜像表(停在 11:52,比订单表新鲜 4 小时):
  `order_status_name='已取消'` **11 单**,`order_labels` 里才有「发货前售后」
  「已打印被取消」;其余 145 单「发货中」

qmcust 13:25 补数后重算,误判量比想象大得多:
**overdue 159 → 16,作废剔除 195 单、已发剔除 17 单。**

## 改动

判据(新增,排在窗口判断与「不计考核」之前):

| 判据 | 处理 |
|---|---|
| `order_status_name='已取消'` | 作废,剔除(计 `stateVoidSkipped`) |
| `send_time` 有值 | 已发,剔除 |
| `order_status_name='已发货'` | 已发,剔除 |
| `logistic_status_name` ∈ 已揽收/运输中/派送中/已签收/拒收 | 已发,剔除 |

- `loadOaConfirmInfo` → `loadStateInfo`,同一次 IN 多取 4 个语义列,**不增加往返**
- ⚠️ **判据只用 `order_status_name`**:`aftersale_status_name='已作废'` 是「售后单被撤销、
  订单照常发货」,近 2 天 1387 单全是这种,混为一谈会把该考核的单全放跑
- ⚠️ `未揽收` / `无物流单` **不算已发**(后者是连快递单都没录,当天 39/159 单是这种)
- 状态镜像表纳入 `dataSources` 停更监控(它停了,「取消了吗」的依据就过期了)
- 明细/导出新增「聚水潭状态」「物流状态(聚水潭)」「状态表抓取时间」;
  页面「发货状态」列改优先显示聚水潭终态,与订单表不一致时打 ⚠

## 验证

- 后端 `npm run check` 496/498(2 个失败是老问题:负缓存 TTL、Windows 文件权限)
- WST 单测 **25/25**,新增两组:终态剔除(含「售后已作废不能误剔」的反向保护)、
  状态表纳入新鲜度监控
- 真实数据(本地直连生产 MSSQL,2026-10-29 13:00 轮):
  `overdue=16 / stateVoidSkipped=195 / stateShippedSkipped=17`,
  明细里「已取消」残留 **0**;剩余 16 单全是河南洛宁仓「发货中 + 无物流单」的真积压
- 作废证据交叉核对:状态表近 2 天「已取消」59263 单,94% 带「发货前售后」标签,
  与业务口径一致
2026-10-29 13:45:41 +08:00
c0e48688c1 Merge pull request 'feat(wst): 数据源停更熔断——订单表停更时醒目标注,别把「没同步」当「没发货」' (#92) from yanhui-wst-stale-1029 into main 2026-10-29 09:13:26 +08:00
cb7d06c20c feat(wst): 数据源停更熔断——订单表停更时醒目标注,别把「没同步」当「没发货」
## 业务问题

10-28 18:00 轮页面核验出 546 单超时未发,业务核对「基本都发了,怎么会核验出未发」。

## 根因(不是判定写错,是数据源停更)

`jst_Orders` 当时**从 14:40 就停止同步了**(停了 4 小时),停更之后发出的单
`send_date` 一直是空,因此全被判成「未发货」:

| 来源表 | 超时单数 | 该表状态 |
|---|---|---|
| `jst_Orders` | 540 | 最后更新 14:40(停 4 小时) |
| `jst_qmcust_orderlist` | 6 | 17:30 正常 |

两个订单表**各自独立同步**,同一天完全可能一个正常一个停更。原来只拿候选行的
`MAX(updated_at)` 判快照滞后,会被「碰巧新」的行掩盖 —— 必须直接问源表。

## 改动

后端 `warehouseShipTimelinessService.js`:

- 新增 `loadSourceFreshness()`:分别直接查 `jst_Orders.MAX(updateTime)` 与
  `jst_qmcust_orderlist.MAX(local_updated)`(限轮次窗口起 30 天,避免全表扫描),
  两源并行;按 `CANGKU_WST_SOURCE_STALE_MINUTES`(默认 60 分钟)判停更
  - 查询失败或取不到更新时间 → **不判停更**(宁可漏报,不谎报为停更)
- 明细行新增 `src` / `srcLabel` / `sourceStale`;`summary` 新增 `sourceStaleUnshipped`
- `freshness.stale` 改为「候选行滞后 **OR** 任一源停更」;`hint` 说清停更源、
  停更时刻、以及各源各贡献多少单(不能只写「这张表」)
- 导出数据带 `dataSources`,Excel 脱离页面也有上下文
- 响应新增 `dataSources` 数组(每源 label / lastUpdate / lagMinutes / stale)

前端 `WarehouseShipTimeliness/index.jsx`:

- 红条 Alert:「N 单所在订单表已停止同步,这些单很可能已经发货」(error 级),
  描述里逐源列出「最后同步 14:40:05(已 3.9 小时)」
- 超时统计卡下方小字:「其中 N 单数据未同步」(悬停有说明)
- 明细「内部单号」旁「未同步」红标签 + tooltip,一眼看出哪几行不可信
- 导出新增「数据源 / 数据源是否停更」两列(`是(该单可能已发)`)

## 验证

- 后端 `npm run check`:**494/496**,2 个失败是既有环境问题(负缓存 TTL 计时、
  Windows 文件权限 0o600),改动前同样失败
- `warehouseShipTimeliness.test.js` **23/23** 通过(含新增「停更表超时单必须打标
  并计入 sourceStaleUnshipped」用例)
- 本地真渲染(Playwright + 手签 token,localhost:5173):
  - 真数据:13:00 前 `notStarted` 正常展示「—」,无 pageerror
  - mock 停更数据:红条 / 逐源行 / 统计小字 / 3 行「未同步」标签全部渲染,无 pageerror
- 真实接口 10-28 13:00 轮:`dataSources` 正确识别 `jst_Orders` 停更(滞后 96 分钟)
  而 qmcust 正常;`sourceStaleUnshipped=1146` 与明细逐行打标同源同口径

## 风险与回退

- 只新增字段与展示,**不改动分轮、起算点、候选池口径** —— 超时单量本身不变
- 阈值可用 `CANGKU_WST_SOURCE_STALE_MINUTES` 调;不配默认 60 分钟
- 低峰期(凌晨)可能出现「1 小时无新单」被判停更,但页面只在 13:00 / 18:00
  核验时刻展示超时数据,这两个时点 1 小时不同步即属异常
- 回退:revert 本提交即可,无数据迁移、无新表、无新依赖
2026-10-29 08:25:41 +08:00
6b6dfdd1da Merge pull request 'fix(wst): 起算点改为「审核时间 / 订单 modified 取较晚者」,修 13:00 轮 65 单假超时' (#91) from yanhui-wst-modified-1028 into main 2026-10-28 17:07:11 +08:00
983fee0d8a fix(wst): 起算点改为「审核时间 / 订单 modified 取较晚者」,修 13:00 轮 65 单假超时
## 业务问题

业务举证:13:00 轮不该有那么多单 —— 「9 点前的单 13:00 前已经发完了」。
线上实测 65 单,逐单核对全部不该在 13:00 轮。

## 根因(两个,都指向「起算点取错」)

### ① 状态表的审核时间会严重滞后

业务给的举证单 9978643:

| 字段 | 值 |
|---|---|
| `qmcust.modified` | **2026-10-28 14:52:29** |
| 聚水潭页面真实审核时间 | **2026-10-28 14:52:28**(秒级吻合) |
| 状态表 `last_oa_confirm_time` | 2026-10-27 17:08:43(旧了一天) |
| 状态表 `query_time` | 2026-10-28 10:29:11(10:29 后没再抓) |

只信状态表 → 这单被当成「10-27 就审核了」,混进 13:00 轮超时,冤枉仓库。

### ② 审核时间为空的单回退 created,把今天的单按历史单算

65 单里 57 单状态表审核时间为 NULL。回退 `created` 后:

| o_id | created | modified | 回退后算成 | 真实 |
|---|---|---|---|---|
| 9964841 | 10-26 17:22 | **10-28 13:40** | 10-26 审核 → 进 13:00 轮 | 今天下午才审核 |
| 9949424 | 10-25 17:03 | **10-28 13:50** | 同上 | 同上 |
| 9983773 | 10-27 23:23 | **10-28 13:59** | 同上 | 同上 |

57 单的 `modified` 全部落在今天 13:40~15:03 —— 都是今天下午批量审核的。

## 改动

- **起算点** = `max(状态表 last_oa_confirm_time, 订单表 modified, 订单表 created)`
  - 取较晚者:修状态表滞后
  - 纳入 created:个别单 `modified` 早于 `created`(脏数据),起算点不该早于下单时刻
  - `benchmarkSource` 透出 `oa_confirm` / `modified` / `created`,页面 tooltip 说明来源
- **新增 `laterOf()`**:同格式 `YYYY-MM-DD HH:mm:ss` 直接字典序比较,不转 Date(避开时区坑)
- **主查询 SQL 增加 `x.modified`** 列(订单两表都有,无需额外查询)

## 性能修复(同批,线上 /list 曾 300s 超时)

上版状态表查询**串行 9 批实测 135s**,叠加主查询 63~105s 直接把接口顶过 300s,
页面打不开(实测 curl `--max-time 300` 超时)。改为**并发 6**:

| 方式 | 耗时 |
|---|---|
| 串行 9 批 | 135s |
| 并发 3 | 28.8s |
| **并发 6(本版)** | **10~15s** |

并发 6 是生产实测的安全值(单批约 15s,不至于把 402 万行视图的连接池打爆)。

## 改后效果(10-28 17:00 真实库)

| 轮次 | 改前 | 改后 |
|---|---|---|
| 13:00 轮 | 65 单 | **0 单** |
| 18:00 轮 | — | 927 单(全部今天 07:59~16:00 审核,无历史单) |

- `fallbackToCreated` 从 57 → **0**(不再有回退单)
- 9978643 ✅ 已剔除
- 两个轮次都验证「今天窗口上界之后起算的 = 0」

## 验证

- 后端 `npm run check`:**493/495**(2 个失败是既有环境问题:TTL 计时、Windows 权限,改动前同样失败)
- 新增 2 个测试锁定该口径:
  - `modified` 晚于窗口 → 必须剔除(9978643 那类单)
  - 状态表审核时间晚于 `modified` → 以状态表为准
  - `modified` 早于 `created` → 取 `created`,不倒退
- 前端 lint + build 通过(35.2s)
- 真实库双轮验证通过

## 风险与回退

- **`modified` 被客服改单/改备注刷新**时起算点会推后 → 少报超时(放行方向,不冤枉仓库)。
  业务已知悉并接受;这是当前唯一能拿到「今天真实审核时间」的可靠字段。
- 回退方式:`git revert <merge commit>` 即回到只认状态表审核时间的版本。
2026-10-28 17:02:54 +08:00
85c48ebe77 Merge pull request 'fix(wst): 起算点改回「最后审核时间」,并剔除订单表漏回写的已发单' (#90) 2026-10-28 15:40:56 +08:00
6c2686784d Merge pull request #88: 发货时效改用订单两表 + 起算点改为订单创建时间 2026-10-28 13:08:28 +08:00
913827000a Merge pull request 'feat(wst): 超时未发加「导出明细」+ 武进安能不考核 + 钉钉明细带快递;修复推送时区' (#87) from yanhui-wst-export-20261027 into main 2026-10-27 16:33:03 +08:00
10 changed files with 1235 additions and 94 deletions

View File

@ -245,8 +245,26 @@ function buildNotifyText(data = {}, options = {}) {
const typeLine = buildTypeLine(data);
if (typeLine) head.push(`类型:${typeLine}`);
// 🔥 2026-11-02 修:0 单有两种完全不同的含义,不能都写「全部正常」——
// ① 数据源没同步(镜像表窗口 0 行)→ 0 单是假的,写「全部正常」等于给群里发假绿;
// ② 当天确实没发货 → 0 单是真的,那也不叫「正常」,叫「无发货可核」。
const freshness = data.freshness || {};
if (totalPackages === 0) {
head.push('本批无转运异常,全部正常。');
if (freshness.emptyWindow && freshness.sourceStale) {
const hours = Number(freshness.sourceAgeMinutes) > 0
? `(已 ${Math.round((Number(freshness.sourceAgeMinutes) / 60) * 10) / 10} 小时未同步)`
: '';
head.push(`⚠️ 物流数据未同步:镜像表最后更新 ${freshness.sourceLastUpdate || '未知'}${hours},`
+ `${batch.shipDate || '该日'} 的发货记录一条都没进库 —— 上面 0 单不代表当天没发货,请先到聚水潭核对。`);
} else if (freshness.emptyWindow) {
head.push(`${batch.shipDate || '该日'} 在物流镜像表里 0 条发货记录`
+ `(表最后更新 ${freshness.sourceLastUpdate || '未知'},数据源本身正常)——`
+ ' 若当天确有发货,说明上游漏同步了这一天,请到聚水潭核对。');
} else if (shipped === 0) {
head.push('本批发货 0 单,无异常可核。');
} else {
head.push('本批无转运异常,全部正常。');
}
}
const excludedCount = (Number(exclusions.carrierPackages) || 0)

View File

@ -38,6 +38,10 @@ const EXPORT_DETAIL_LIMIT = 5000;
// 快照超过这么久没刷新 → 页面黄告警(这张表正常每小时刷一轮)
const SNAPSHOT_STALE_MINUTES = 120;
// 数据源(整张镜像表)多久没刷新算停更。与上面同值,但语义不同:
// SNAPSHOT_STALE_MINUTES 判的是「本批窗口内行的 query_time」,
// SOURCE_STALE_MINUTES 判的是「整张表最后被灌库的时刻」—— 窗口内 0 行时只能靠后者。
const SOURCE_STALE_MINUTES = Number(process.env.CANGKU_WLE_SOURCE_STALE_MINUTES) || 120;
const CACHE_TTL_MS = Number(process.env.CANGKU_WLE_CACHE_TTL_MS) || 5 * 60 * 1000;
// key = `${verifyDate}|${limit}`。用 Map 而不是单槽缓存:
@ -148,6 +152,36 @@ async function loadShippedPackages(batch) {
return rows || [];
}
/**
* 整张镜像表最后被灌库的时刻(表级新鲜度)。
*
* 🔥 2026-11-02 新增,起因:11-02 09:00 那批推出「已发货 0 单 / 0 个包裹,异常 0 个包裹」,
* 业务问「怎么可能 0 单」。查出来镜像表 **11-01 07:55 之后就没再灌过**,
* 而 v1 的 freshness 只用「本批窗口内行的 query_time」算 —— 窗口一行都没有时
* `snapshotAt` 是空串 → `stale=false`、`hint=''`,页面和钉钉于是把它当成
* 「本批确实没有发货 / 全部正常」。这是最危险的一种假绿。
*
* 成本:全表 `MAX(query_time)` 在一个 402 万行的视图上实测 **13.5s**(谓词下推差),
* 所以**只在窗口 0 行时才调**(正常批次一行都不用付这笔钱),结果随主结果进 5 分钟缓存。
*
* @returns {Promise<string>} 'YYYY-MM-DD HH:mm:ss',取不到返回空串
*/
async function loadSourceLastUpdate() {
try {
const rows = await cloudDatabase.query(
`SELECT MAX(e.query_time) AS max_q
FROM dbo.jst_order_express_details e WITH (NOLOCK)`,
{},
{ timeoutMs: 240000 }
);
return formatDateTime(rows?.[0]?.max_q);
} catch (err) {
// 探测失败不该让整页挂掉:退回「不知道」,hint 里会说明取不到表级时间
console.warn(`[WLE] 数据源新鲜度探测失败:${err.message}`);
return '';
}
}
// 售后拦截判定:一次 IN 多少单 + 查询超时。
// 这两张售后表在 rpt 副本里**都是堆表(零索引)**,`o_id IN (...)` 只能全表扫,
// 实测 125 万行的 returnAndRefund 4.5s、176 万行的 qmcust 8.5s —— 所以:
@ -315,7 +349,17 @@ async function getLogisticsExceptions(options = {}) {
orders: [],
detailLimit: limit,
truncated: false,
freshness: { snapshotAt: '', ageMinutes: null, stale: false, coversDeadline: null, hint: '' },
freshness: {
snapshotAt: '',
ageMinutes: null,
stale: false,
coversDeadline: null,
emptyWindow: false,
sourceLastUpdate: '',
sourceAgeMinutes: null,
sourceStale: false,
hint: '',
},
generatedAt,
cached: false,
cacheAgeSec: 0,
@ -510,11 +554,33 @@ async function getLogisticsExceptions(options = {}) {
}
// ── 新鲜度 ──────────────────────────────────────────────────────────
// 🔥 emptyWindow = 本批窗口里**一行都没取到**(12 仓范围)。
// 这时 snapshotAt 必然是空串,v1 的判据(coversDeadline=null、stale=false、hint='')
// 会让「上游没同步」和「当天真的没发货」长得一模一样,页面/钉钉都显示成 0 单全绿。
// 所以窗口为空时补查一次**表级**最后灌库时刻,把两种情形分开。
const emptyWindow = rows.length === 0;
const sourceLastUpdate = emptyWindow ? await loadSourceLastUpdate() : '';
const ageMinutes = snapshotAt ? diffMinutes(snapshotAt, generatedAt) : null;
const stale = ageMinutes !== null && ageMinutes > SNAPSHOT_STALE_MINUTES;
const sourceAgeMinutes = sourceLastUpdate ? diffMinutes(sourceLastUpdate, generatedAt) : null;
const sourceStale = sourceAgeMinutes !== null && sourceAgeMinutes > SOURCE_STALE_MINUTES;
const coversDeadline = snapshotAt ? snapshotAt >= batch.deadline : null;
let hint = '';
if (coversDeadline === false) {
if (emptyWindow) {
const lastText = sourceLastUpdate || '';
const hours = sourceAgeMinutes === null ? 0 : Math.round((sourceAgeMinutes / 60) * 10) / 10;
if (sourceStale) {
hint = `${batch.shipDate} 的发货记录在物流镜像表里一条都没有 —— 该表最后更新 ${lastText}(已 ${hours} 小时未同步)。`
+ ' 上面的「0 单 / 0 个包裹」是数据没进库,不代表当天没发货。'
+ ' 请先到聚水潭核对当天发货量,等上游同步后再刷新本页。';
} else if (lastText) {
hint = `${batch.shipDate} 在物流镜像表里 0 条发货记录(该表最后更新 ${lastText},数据源本身正常)。`
+ ' 若当天确实有发货,说明上游漏同步了这一天,请到聚水潭核对;若当天本就停发,这个 0 才是真的。';
} else {
hint = `${batch.shipDate} 在物流镜像表里 0 条发货记录,且取不到该表最后更新时间 ——`
+ ' 分不清是「当天没发货」还是「数据没同步」,请到聚水潭核对后再看本页。';
}
} else if (coversDeadline === false) {
hint = `物流快照最新只到 ${snapshotAt.slice(11, 16)},没覆盖本轮 ${batch.deadline.slice(11, 16)} 核验时刻 ——`
+ ' 之后才揽收/更新的轨迹没进来,异常量会偏大,请以上面「数据更新于」为准,或等上游同步后刷新。';
} else if (stale) {
@ -561,6 +627,12 @@ async function getLogisticsExceptions(options = {}) {
ageMinutes,
stale,
coversDeadline,
// 本批窗口 0 行:0 单含义不明,必须配合下面两个字段读
emptyWindow,
// 表级最后灌库时刻(只有 emptyWindow 时才探测,否则为空串)
sourceLastUpdate,
sourceAgeMinutes,
sourceStale,
hint,
},
generatedAt,

View File

@ -378,6 +378,64 @@ const VOID_ORDER_LABEL_KEYWORDS = Object.freeze(['发货前售后']);
// 万一哪天出现「发货中 + 已作废 + 订单表也不是 Sent」,不至于再被算成超时。
const AFTERSALE_VOID_STATUS = '已作废';
/**
* 状态镜像表 `jst_order_express_details.order_status_name` 的**终态**。
*
* 🔥 2026-10-29 血的教训(业务第三次报「作废单/已发单还在考核里」):
* 订单两表**会各自停更**(当天 qmcust 停在 07:25、jst_Orders 停在 12:45),
* 停更期间在聚水潭做的「取消 / 发货」动作,订单表里根本看不到 ——
* 订单 status 仍是 `Delivering`、`send_date` 仍是空,于是被当成真超时。
* 状态镜像表虽然也会停(当天 11:52),但**比订单表新鲜 4 小时**,
* 而且 `order_status_name` 是聚水潭订单状态的直接映射。
*
* 实测(2026-10-29 13:00 轮 159 单):
* · `order_status_name='已取消'` 11 单 —— 订单表的 `labels` 里**没有**「发货前售后」
* 这个关键词(`presaleVoid` 判据完全失效),状态表的 `order_labels` 才有,且带
* 「已打印被取消」。业务就是拿这 11 单说「作废的也在考核之内」。
* · `order_status_name='已发货'` 0 单 —— 机制上必须有,否则停更期发的货永远判不出。
*
* ⚠️ **`aftersale_status_name='已作废'` 不是作废单**!那是「售后单被撤销」,
* 订单照常发货、**仍然要考核**(近 2 天 1387 单都是这种)。别把两个混为一谈,
* 能判「这单不用发了」的只有 `order_status_name='已取消'`。
*/
const STATE_ORDER_VOID_STATUS = '已取消';
const STATE_ORDER_SHIPPED_STATUS = '已发货';
/**
* 销售出库单 `status` 里**等于单据作废**的值。
*
* 🔥 2026-10-29 新增(业务点名 9992097 等 9 单:「在聚水潭的销售出库单里找一下这个作废单据」)。
*
* 聚水潭的作废会落在**出库单**上:`jst_salesOutboundInfo.status` / `jst_qmcust_salesoutbound.status`
* 取值只有四种(近 2 天实测):`Confirmed` / `WaitConfirm` / `Delete` / `OuterConfirming`,
* 其中 `Delete` 就是单据作废。
*
* 为什么必须加这一条判据(状态表 `order_status_name='已取消'` 不够):
* · 出库单 `Delete` 的近 7 天样本里,**55 单订单表仍是 `Delivering`、36 单是 `Question`**,
* 这些单状态镜像表未必抓得到(它一天只抓几次),只能靠出库单判;
* · 出库单是仓库侧最贴身的单据,作废动作一定先落在这里。
*
* ⚠️ **不能只看「有 Delete 就算作废」**:一个订单可能有多张出库单(拆包 / 重开),
* 删掉旧的那张、新的还在 `WaitConfirm` —— 这种单照常要发。
* ⟹ 判据是「**该订单没有任何非 Delete 的出库单**」,见 service 里 ioAllDeleted 的说明。
*
* ⚠️ 也**不能**用「没有出库单」当判据:近 3 天未发单里 **82%(1467/1790)本来就没有出库单**
* (订单还没推下游),拿它判作废会把绝大多数正常待发单全放跑。
*/
const IO_VOID_STATUS = 'Delete';
/**
* 状态镜像表 `logistic_status_name` 里**等于已发**的值。
*
* `拒收` 也算已发 —— 快递拿走过了,客户拒收是后续环节,仓库的发货动作已完成。
* ⚠️ **`无物流单` 不算**(39/159 单是这种:单子还没录快递单,可能自提/待定),
* `未揽收` 也不算(只是打了单,快递还没来取)。
* ⚠️ 别拿 `logistic_time` 当发货时间:它多数是「快递员将上门取件」的预告。
*/
const STATE_LOGISTIC_SHIPPED_STATUSES = Object.freeze([
'已揽收', '运输中', '派送中', '已签收', '拒收',
]);
// 24 小时发货时效 —— ⚠️ 仅用于**页面命名/路由**,**不参与判定**。
// 2026-10-20 三次调整后判定改成「到 13:00 / 18:00 核验时刻仍未发即超时」,
// 没有滚动 24 小时窗口(见 SHIP_TIMELINESS_HOURS 的历史误用记录)。
@ -651,6 +709,10 @@ module.exports = {
VOID_QUESTION_STATUS,
VOID_ORDER_LABEL_KEYWORDS,
AFTERSALE_VOID_STATUS,
STATE_ORDER_VOID_STATUS,
STATE_ORDER_SHIPPED_STATUS,
STATE_LOGISTIC_SHIPPED_STATUSES,
IO_VOID_STATUS,
SHIP_TIMELINESS_HOURS,
toNumber,
};

View File

@ -107,6 +107,10 @@ const {
ORDER_QUESTION_STATUS,
ORDER_CANDIDATE_STATUSES,
VOID_ORDER_LABEL_KEYWORDS,
STATE_ORDER_VOID_STATUS,
STATE_ORDER_SHIPPED_STATUS,
STATE_LOGISTIC_SHIPPED_STATUSES,
IO_VOID_STATUS,
resolveCenter,
} = registry;
@ -118,6 +122,22 @@ const MAX_DETAIL_LIMIT = 2000;
// 2026-10-28 起数据源是订单表(`updateTime` / `local_updated`),实测滞后约 2 小时。
const STATE_STALE_MINUTES = 90;
/**
* 单个**订单表数据源**的滞后阈值(分钟)。
*
* 🔥 为什么必须按源单独判(2026-10-28 业务第二次质疑「18:00 轮基本都发了」时定型):
* 订单两表是**各自独立同步**的,同一天可以一个正常一个停更 ——
* 18:35 实测:`jst_Orders` 最后更新 **14:40**(停 4 小时),
* 而 `jst_qmcust_orderlist` 更新到 **17:30**(正常)。
* 只取候选行的 `MAX(updated_at)` 会被"碰巧新"的行掩盖,必须直接问源表。
*
* 影响:该源停更 ⟹ 停更之后发出的单,`send_date` 仍是 NULL ⟹ 被判「未发货」。
* 18:00 轮 546 单里 **540 单来自 jst_Orders**,全部是这种假超时。
*
* 所以停更源的单在页面上必须**明确标注**,绝不静默当成「确认未发」。
*/
const SOURCE_STALE_MINUTES = Number(process.env.CANGKU_WST_SOURCE_STALE_MINUTES) || 60;
/**
* 不参与发货时效考核的快递(业务 2026-10-20 / 2026-10-27 指定):
* 自提 —— 客户自己来拉,仓库不负责派送
@ -223,6 +243,20 @@ function formatDateTime(value) {
return s.replace('T', ' ').replace(/\.\d+Z?$/, '').slice(0, 19);
}
/**
* 取两个 `YYYY-MM-DD HH:mm:ss` 里较晚的那个(空值视为不存在)。
*
* 🔥 2026-10-28 下午:起算点必须在「状态表审核时间」和「订单表 modified」之间取较晚者。
* 同格式字符串可以直接字典序比较,不需要转 Date(避免时区/跨天坑)。
*/
function laterOf(a, b) {
const x = String(a || '');
const y = String(b || '');
if (!x) return y;
if (!y) return x;
return y > x ? y : x;
}
/** 两个时间文本相差多少分钟(to - from);任一为空返回 0 */
function diffMinutes(fromText, toText) {
const a = formatDateTime(fromText);
@ -294,12 +328,13 @@ async function loadPendingOrders(round) {
const rows = await cloudDatabase.querySlow(
`SELECT x.o_id, x.so_id, x.shop_name, x.status, x.created, x.pay_date,
x.logistics_company, x.l_id, x.presaleVoid, x.src,
x.updated_at, x.wms_co_id
x.updated_at, x.wms_co_id, x.modified
FROM (
SELECT o.o_id, o.so_id, o.shop_name, o.status, o.created, o.pay_date,
o.logistics_company, o.l_id, o.wms_co_id,
${presaleSql} AS presaleVoid,
o.updateTime AS updated_at,
o.modified,
N'jst_Orders' AS src
FROM rpt.jst_Orders o WITH (NOLOCK)
WHERE o.send_date IS NULL
@ -310,6 +345,7 @@ async function loadPendingOrders(round) {
c.logistics_company, c.l_id, c.wms_co_id,
${presaleSql} AS presaleVoid,
c.local_updated AS updated_at,
c.modified,
N'jst_qmcust_orderlist' AS src
FROM rpt.jst_qmcust_orderlist c WITH (NOLOCK)
WHERE c.send_date IS NULL
@ -325,7 +361,7 @@ async function loadPendingOrders(round) {
}
/**
* 批量取**审核时间**(起算点)—— 唯一来源是状态镜像表 `jst_order_express_details`。
* 批量取**状态镜像表**里的单号级信息(起算点 + 终态校验)。
*
* 为什么必须回状态表拿:
* · `jst_Orders` / `jst_qmcust_orderlist` **都没有审核时间字段**(85 列逐一看过,
@ -335,47 +371,273 @@ async function loadPendingOrders(round) {
* ⚠️ 只从它拿**这一个字段**,候选取舍(哪些单未发货)仍然只看订单两表 ——
* 状态表的 send_time 漏回写、会整批停更,那些坑一个都不能重新踩回来。
*
* 🔥 2026-10-29 扩展:**不止取时间,还要取终态**。
* 订单两表会各自停更(当天 qmcust 停在 07:25),停更期间聚水潭里的「取消 / 发货」
* 订单表根本看不到 —— 订单 status 仍是 Delivering、send_date 仍是空。
* 而状态表虽也停(11:52),却比订单表新鲜 4 小时,`order_status_name` 已经变成
* 「已取消」/「已发货」。业务当天报的「作废单还在考核里」11 单就是这么来的:
* 订单表 labels 里**没有**「发货前售后」,`presaleVoid` 完全失效。
*
* 业务口径(2026-10-28):起算点用 `last_oa_confirm_time`(业务选「最后审核时间」,
* 理由见文件头)。空值不在这里兜,交给调用方回退 `created`。
*
* 性能:`inner_order_id IN (...)` 一次 600 个约 **15s**(全表扫一次,402 万行视图)。
* 🔥 千万别改成逐单查 —— 实测单条 **14.5s**,599 条要 2.4 小时。
* 分批 600 是因为 T-SQL 单条语句 IN 列表太长会解析超时;两批各 600 / 剩余。
* 多取 4 个语义列(`order_status_name` 等)是同一批 IN 同一次扫描,
* **不增加往返**,实测耗时无变化。
*
* 失败降级:抛错由调用方 catch → 全部回退 created,并在 payload 里标 degraded,
* **不要因为状态表挂了就整页 500**(候选池在订单表,本来就有数据)。
*/
async function loadOaConfirmInfo(stateRows) {
async function loadStateInfo(stateRows) {
const ids = [...new Set(
(stateRows || []).map((r) => Number(r.o_id)).filter((n) => Number.isFinite(n))
)];
const map = new Map();
if (!ids.length) return map;
// 🔥 2026-10-28 下午:串行 9 批实测 **135s**(全并行 9 批只要 6s,并行 3 批 28.8s)。
// 生产上「主查询 63~105s + 状态表 135s」直接把 /list 顶过 300s 超时,
// 页面打不开 —— 所以**必须并发**。并发 6 是实测过的安全值:
// 单批约 15s,6 并发后整体 10~15s,且不至于把 402 万行视图的连接池打爆。
const BATCH = 600;
const CONCURRENCY = 6;
const chunks = [];
for (let i = 0; i < ids.length; i += BATCH) {
// ids 已用 Number.isFinite 过滤过,拼进 IN 是纯数字,无注入面
const chunk = ids.slice(i, i + BATCH);
const rows = await cloudDatabase.querySlow(
`SELECT inner_order_id, first_oa_confirm_time, last_oa_confirm_time, send_time
FROM rpt.jst_order_express_details WITH (NOLOCK)
WHERE inner_order_id IN (${chunk.join(',')})`,
{},
{ connectRequestTimeoutMs: 300000 }
);
for (const r of rows || []) {
map.set(Number(r.inner_order_id), {
first: formatDateTime(r.first_oa_confirm_time),
last: formatDateTime(r.last_oa_confirm_time),
// 顺带带回来做「已发」二次兜底:订单表 send_date 也有漏回写的情况
// (2026-10-28 实测 144 单里 6 单状态表 send_time 有值、订单表却是空)
sendTime: formatDateTime(r.send_time),
});
chunks.push(ids.slice(i, i + BATCH));
}
for (let i = 0; i < chunks.length; i += CONCURRENCY) {
const group = chunks.slice(i, i + CONCURRENCY);
// eslint-disable-next-line no-await-in-loop
const results = await Promise.all(group.map((chunk) => {
// ids 已用 Number.isFinite 过滤过,拼进 IN 是纯数字,无注入面
return cloudDatabase.querySlow(
`SELECT inner_order_id, first_oa_confirm_time, last_oa_confirm_time, send_time,
order_status_name, aftersale_status_name, logistic_status_name,
order_labels, query_time
FROM rpt.jst_order_express_details WITH (NOLOCK)
WHERE inner_order_id IN (${chunk.join(',')})`,
{},
{ connectRequestTimeoutMs: 300000 }
);
}));
for (const rows of results) {
for (const r of rows || []) {
map.set(Number(r.inner_order_id), {
first: formatDateTime(r.first_oa_confirm_time),
last: formatDateTime(r.last_oa_confirm_time),
// 顺带带回来做「已发」二次兜底:订单表 send_date 也有漏回写的情况
// (2026-10-28 实测 144 单里 6 单状态表 send_time 有值、订单表却是空)
sendTime: formatDateTime(r.send_time),
// ── 终态校验(2026-10-29 新增)────────────────────────────────
// 这两个是**聚水潭订单状态**的直接映射,订单表停更时只有它靠得住
orderStatus: String(r.order_status_name || '').trim(),
aftersaleStatus: String(r.aftersale_status_name || '').trim(),
logisticStatus: String(r.logistic_status_name || '').trim(),
// 状态表自己的抓取时刻:同一单可能 08:50 抓过就没再抓,判据可信度要看它
queryTime: formatDateTime(r.query_time),
});
}
}
}
return map;
}
/**
* 批量取**销售出库单**的状态 —— 判「这单在聚水潭里被作废了吗」。
*
* 🔥 2026-10-29 新增。业务原话:「9992097…这些订单都是作废订单,为啥还在考核之内」,
* 并指明「在聚水潭的**销售出库单**里面找一下这个作废单据」。
*
* 为什么必须补这一层(订单表 + 状态镜像表都不够):
* · 订单表 `labels` 的「发货前售后」判据,在停更/正常数据上都会漏(15:00 那批 0 命中);
* · 状态镜像表 `order_status_name='已取消'` 一天只抓几次,抓不到的作废就漏;
* · **出库单 `status='Delete'` 才是仓库侧最贴身的作废痕迹** —— 近 7 天实测:
* 出库单被删的 2209 单里,**55 单订单表仍是 `Delivering`、36 单 `Question`**,
* 这批人只能靠出库单判出来。
*
* 判据边界(血泪):
* · 一个订单可能有多张出库单(拆包 / 重开)→ **必须「该 o_id 下没有任何非 Delete 的出库单」**
* 才算作废。实测近 7 天 51 个「订单发货中但出库单被删」的单里,有 7 个挂着 2~8 张
* 出库单且全为 Delete(拆包重开),不能凭「有一张 Delete」就剔。
* · **没有出库单 ≠ 作废**:近 3 天未发单 **82%(1467/1790)压根没有出库单**
* (订单还没推下游),拿它判作废会把正常待发单全放跑。
*
* 性能:按来源表分别 `o_id IN (...)`,一批 500、并发 3(出库单表比状态表小得多,
* 实测单批 1~3s)。查询失败 → 返回空 Map,**不阻断页面**(判据退化成「不判」)。
*
* 🔴 2026-10-29 13:10 实测:两张出库单表 `local_updated` 一起停在 **03:10**(停更 11h),
* `modified` 也全是凌晨的。停更期间业务新作废的单在这里**永远是 WaitConfirm** ——
* 所以出库单也必须进 `loadSourceFreshness`,否则「查不到作废」会被误读成「没作废」。
*
* @param {Array} orderRows 候选订单行(含 `o_id` / `src`)
* @returns {Promise<Map<number, {status:string, statuses:string[], allDeleted:boolean, count:number}>>}
*/
async function loadOrderIoStatus(orderRows) {
const TABLE_BY_SRC = {
jst_Orders: 'rpt.jst_salesOutboundInfo',
jst_qmcust_orderlist: 'rpt.jst_qmcust_salesoutbound',
};
// src → 去重后的 o_id 列表
const idsBySrc = new Map();
for (const r of orderRows || []) {
const src = String(r.src || '');
if (!TABLE_BY_SRC[src]) continue;
const oid = Number(r.o_id);
if (!Number.isFinite(oid)) continue;
if (!idsBySrc.has(src)) idsBySrc.set(src, new Set());
idsBySrc.get(src).add(oid);
}
const result = new Map();
if (!idsBySrc.size) return result;
const BATCH = 500;
const CONCURRENCY = 3;
const tasks = [];
for (const [src, idSet] of idsBySrc) {
const ids = [...idSet];
for (let i = 0; i < ids.length; i += BATCH) {
tasks.push({ src, chunk: ids.slice(i, i + BATCH) });
}
}
for (let i = 0; i < tasks.length; i += CONCURRENCY) {
const group = tasks.slice(i, i + CONCURRENCY);
// eslint-disable-next-line no-await-in-loop
const settled = await Promise.allSettled(group.map((t) => cloudDatabase.querySlow(
// o_id 已用 Number.isFinite 过滤,拼进 IN 是纯数字,无注入面
`SELECT o_id, io_id, status FROM ${TABLE_BY_SRC[t.src]} WITH (NOLOCK)
WHERE o_id IN (${t.chunk.join(',')})`,
{},
{ connectRequestTimeoutMs: 120000 },
)));
for (const s of settled) {
if (s.status !== 'fulfilled') continue; // 单批失败不影响其它批
for (const r of s.value || []) {
const oid = Number(r.o_id);
if (!Number.isFinite(oid)) continue;
const st = String(r.status || '').trim();
if (!result.has(oid)) result.set(oid, { statuses: [], alive: 0, dead: 0 });
const rec = result.get(oid);
if (st && !rec.statuses.includes(st)) rec.statuses.push(st);
if (st === IO_VOID_STATUS) rec.dead += 1;
else rec.alive += 1; // 含空状态:认不出就当还活着(宁可漏判,不误剔)
}
}
}
const out = new Map();
for (const [oid, rec] of result) {
out.set(oid, {
// 页面展示用:优先显示「还有效」的那个状态(业务一眼看出这单的进度)
status: rec.alive > 0 ? (rec.statuses.find((s) => s !== IO_VOID_STATUS) || '') : IO_VOID_STATUS,
statuses: rec.statuses,
// 唯一可信的作废判据:有出库单、且一张都没活着
allDeleted: rec.dead > 0 && rec.alive === 0,
count: rec.dead + rec.alive,
});
}
return out;
}
/**
* 各数据源**各自**的最后更新时间,用于判断「这个源还活着吗」。
*
* 🔥 为什么不能只看候选行:候选池本身就是 `send_date IS NULL` 的单,
* 某张表停更后它的候选单 `updateTime` 会集体冻在停更那一刻,看起来「都一样旧」;
* 但若停更表里恰好有几单新改过,`MAX` 就假装新鲜了 —— 必须直接问源表。
*
* 口径:
* · `jst_Orders` → `MAX(updateTime)`(5 分钟一批的增量同步时间)
* · `jst_qmcust_orderlist` → `MAX(local_updated)`(该表没有 updateTime 列)
* · 只扫 30 天窗口(`round.windowStart` 起),不然要全表扫描
* · 任一源查询失败 → 该源记 `lastUpdate:null`、`stale:false`,
* **不谎报停更**(查不到 ≠ 停更),但会在 `error` 里留痕
*
* @param {object} round 轮次(用 windowStart 做扫描下界)
* @param {Date} now 当前时间(已按北京时间取)
* @returns {Promise<Array<{key:string,label:string,lastUpdate:string,lagMinutes:number|null,stale:boolean,error?:string}>>}
*/
async function loadSourceFreshness(round, now) {
const startLit = String(round.windowStart || '').slice(0, 19);
const nowText = formatDateTime(now);
const defs = [
{
key: 'jst_Orders',
label: 'jst_Orders',
sql: `SELECT MAX(updateTime) AS maxUpd FROM rpt.jst_Orders WITH (NOLOCK)
WHERE updateTime >= '${startLit}'`,
},
{
key: 'jst_qmcust_orderlist',
label: 'qmcust',
sql: `SELECT MAX(local_updated) AS maxUpd FROM rpt.jst_qmcust_orderlist WITH (NOLOCK)
WHERE local_updated >= '${startLit}'`,
},
{
// 🔥 2026-10-29 新增:状态镜像表也必须监控。
// 它是「这单取消了吗 / 发出了吗」的唯一权威来源(订单表会停更),
// 当天它停在 11:52,而 13:00 轮的超时判定就建立在这份 11:52 的快照上。
// 不监控它 ⟹ 页面只说「订单表停了」,实际判据也已经过期 1.5 小时。
key: 'jst_order_express_details',
label: '状态镜像表',
// 这张表没有 updateTime 列,用 `updatedAt`(ETL 写入时刻)
sql: `SELECT MAX(updatedAt) AS maxUpd FROM rpt.jst_order_express_details WITH (NOLOCK)
WHERE updatedAt >= '${startLit}'`,
},
{
// 🔥 2026-10-29 新增:两张**销售出库单**表也必须监控。
// 它是「单据作废了吗」的唯一来源(订单表停更、状态表一天只抓几次)。
// 实测当天它俩的 `local_updated` **一起停在 03:10**(停更 11 小时),
// 而业务上午在聚水潭作的废全落在这张表上 —— 页面看到的是 11 小时前的
// `WaitConfirm`(待出库),于是那批单永远「查不出作废」。
// ⚠️ 判断必须用 `local_updated / updateTime`(灌库时刻),
// **不能用 `modified`**(业务字段)—— 没有单据变更时它天然是旧的,
// 拿它判停更会天天误报(这个坑在 `jst_inventoryInfo` 上踩过一次)。
key: 'jst_salesOutboundInfo',
label: '出库单(聚水潭)',
sql: `SELECT MAX(updateTime) AS maxUpd FROM rpt.jst_salesOutboundInfo WITH (NOLOCK)
WHERE updateTime >= '${startLit}'`,
},
{
key: 'jst_qmcust_salesoutbound',
label: '出库单(奇门)',
sql: `SELECT MAX(local_updated) AS maxUpd FROM rpt.jst_qmcust_salesoutbound WITH (NOLOCK)
WHERE local_updated >= '${startLit}'`,
},
];
// 两个源并行查(各自 60s 上限,任一个慢不拖累另一个)
const settled = await Promise.allSettled(defs.map((d) => cloudDatabase.querySlow(
d.sql, {}, { connectRequestTimeoutMs: 120000 },
)));
return defs.map((d, i) => {
const s = settled[i];
if (s.status !== 'fulfilled') {
return {
key: d.key,
label: d.label,
lastUpdate: '',
lagMinutes: null,
stale: false,
error: String((s.reason && s.reason.message) || s.reason || '查询失败').slice(0, 160),
};
}
const rows = s.value || [];
const lastUpdate = formatDateTime(rows[0] && rows[0].maxUpd);
const lagMinutes = lastUpdate ? Math.max(0, diffMinutes(lastUpdate, nowText)) : null;
return {
key: d.key,
label: d.label,
lastUpdate,
lagMinutes,
// 查不到更新时间时**不判停更**(宁可漏报,也不谎报)
stale: lagMinutes != null && lagMinutes > SOURCE_STALE_MINUTES,
};
});
}
function emptySummary() {
return {
@ -389,8 +651,18 @@ function emptySummary() {
voidCount: 0,
// 已剔除的「不考核快递」单量(自提 / 中铁 / 壹米滴答 / 武进安能)
carrierSkipped: 0,
// 已剔除的「其实已发」单量:订单表 send_date 空、状态表 send_time 有值(漏回写)
// 已剔除的「其实已发」单量:状态表 send_time 有值 / order_status_name='已发货'
// / 物流已揽收+ (订单表 send_date 空但聚水潭已经发了)
stateShippedSkipped: 0,
// 已剔除的「订单已取消」单量:状态表 order_status_name='已取消'
// ⚠️ 订单表停更期间这是**唯一**能判出作废的来源(labels 判据会整体失效)
stateVoidSkipped: 0,
// 已剔除的「出库单整体作废」单量:销售出库单 status 全为 Delete
// 🔥 2026-10-29 新增 —— 业务点名「洛宁仓 16 单都是作废订单」,聚水潭的作废落在出库单上
ioVoidSkipped: 0,
// 🔥 超时单里「所在数据源已停更」的单量 —— 这些单的「未发」不可信,可能早已发出。
// 2026-10-28 18:00 轮实测:546 单里 540 单来自停更的 jst_Orders。
sourceStaleUnshipped: 0,
// 不属于 11 主仓的单量(代发仓 / POP 仓 / 仓库表查不到)
unknownWarehouse: 0,
};
@ -473,6 +745,7 @@ async function getShipTimeliness(options = {}) {
heldTotal: 0,
detailDegraded: false,
freshness: null,
dataSources: [],
note: `今日 ${pad2(rounds[0].verifyHour)}:00 首轮核验开始后才展示超时数据`,
};
}
@ -502,25 +775,58 @@ async function getShipTimeliness(options = {}) {
throw err;
}
// ③.5 起算点:批量取审核时间(最后审核时间优先,缺失回退订单创建时间)
// ③.5 状态镜像表:起算点(审核时间)+ 终态(已取消 / 已发货)
// ⚠️ 状态表挂了不阻断页面:全量回退 created,并在 payload 里标降级
let oaConfirmMap = new Map();
let stateInfoMap = new Map();
let oaConfirmDegraded = false;
try {
oaConfirmMap = await loadOaConfirmInfo(stateRows);
stateInfoMap = await loadStateInfo(stateRows);
} catch (e) {
oaConfirmDegraded = true;
console.warn('[WST] 审核时间查询失败,全量回退订单创建时间:', e.message);
console.warn('[WST] 状态镜像表查询失败,全量回退订单创建时间:', e.message);
}
// ③.55 销售出库单状态:判「单据作废」(业务 2026-10-29 点名要求)
// ⚠️ 查不到不阻断页面 —— 判据退化成「不判作废」,由停更告警兜底提示不可信
let ioStatusMap = new Map();
let ioDegraded = false;
try {
ioStatusMap = await loadOrderIoStatus(stateRows);
} catch (e) {
ioDegraded = true;
console.warn('[WST] 销售出库单查询失败,作废判据降级:', e.message);
}
// ③.6 数据源新鲜度:两个订单表**各自独立同步**,必须分源判断停更 ──────────
// 🔥 2026-10-28 18:35 实测:`jst_Orders` 停更在 14:40(4 小时),
// `jst_qmcust_orderlist` 正常到 17:30。那批「未发 546 单」里 540 单来自
// 停更的表 —— 它们的 send_date 全空纯粹是没同步,业务说「基本都发了」是对的。
// 只取候选行的 MAX(updated_at) 会被"碰巧新"的行掩盖,所以直接查源表。
let sourceFreshness = [];
try {
sourceFreshness = await loadSourceFreshness(round, now);
} catch (e) {
// 查不到新鲜度不阻断页面,但要在日志里留痕(页面会退化成"不标注")
console.warn('[WST] 数据源新鲜度查询失败:', e.message);
}
const sourceMap = new Map(sourceFreshness.map((s) => [s.key, s]));
// 被剔除的作废 / 已发单计数(只用于页面说明,不进考核)
let voidCount = 0;
// 因「不考核快递」被跳过的单量(自提 / 中铁 / 壹米滴答 / 武进安能),写进 summary 便于对账
let carrierSkipped = 0;
// 订单表 send_date 为空、但状态表 send_time 有值(漏回写)→ 已发,剔除
let stateShippedSkipped = 0;
// 状态表 `order_status_name='已取消'` → 订单已作废,剔除(订单表停更时唯一可靠来源)
let stateVoidSkipped = 0;
// 出库单全部为 `Delete` → 单据作废,剔除(2026-10-29 新增,业务点名的作废单)
let ioVoidSkipped = 0;
// 仓库表里查不到 / 不属于 11 主仓的单量(代发仓、POP 仓、wms_co_id 为空…)
let unknownWarehouse = 0;
// 超时单里「所在数据源已停更」的数量 —— 这批单的「未发」不可信
let sourceStaleUnshipped = 0;
// 按来源表分开计数(提示里要说「jst_Orders 540 单、qmcust 6 单」,不能只说「这张表」)
const sourceStaleBySrc = {};
// ④ 分桶
const acc = new Map(centerList.map((c) => [c.key, {
@ -559,25 +865,41 @@ async function getShipTimeliness(options = {}) {
// 状态表的 last_oa_confirm_time,不是订单表的 created(10-19 23:44:22)。
// 积压单 created → 审核能差 8~11 天,按 created 算等于把审核积压
// 算到仓库头上(详见文件头 9837824 的证据)。
// 审核时间取不到(实测 599 单里 209 单)→ 回退 created,并标注来源。
//
// 🔥 2026-10-28 下午再纠偏:**状态表的审核时间会严重滞后,必须和订单表
// `modified` 取较晚者**。铁证(9978643,业务给的):
// · qmcust.modified = 2026-10-28 14:52:29
// · 聚水潭页面真实审核时间 = 2026-10-28 14:52:28 ← 秒级吻合
// · 状态表 last_oa_confirm = 2026-10-27 17:08:43 ← 旧值,早了一天
// · 状态表 query_time = 2026-10-28 10:29:11 ← 10:29 后就没再抓过
// 只信状态表 → 这单被当成「10-27 就审核了」,混进 13:00 轮超时(冤枉仓库)。
// 更惨的是**审核时间为空的单**(13:00 轮 65 单里 57 单):回退 created 后,
// 明明是今天 13:40~15:03 才审核的单,被按 10-25~10-27 的下单时间算超时。
//
// ⟹ 口径:起算点 = max(状态表 last_oa_confirm_time, 订单表 modified),
// 两者都没有才回退 created。`modified` 是聚水潭源端的「最后修改时间」,
// 审核动作一定会刷新它;因客服改单/改备注而推后的情况属「放行」方向
// (少报超时,不冤枉仓库),业务已知悉。
const createdAt = formatDateTime(row.created);
const oaInfo = oaConfirmMap.get(Number(row.o_id));
const modifiedAt = formatDateTime(row.modified);
const stateInfo = stateInfoMap.get(Number(row.o_id));
// 状态镜像表里的聚水潭终态(订单表停更时唯一可信的「这单还发不发」)
const stateOrderStatus = stateInfo ? (stateInfo.orderStatus || '') : '';
const stateLogisticStatus = stateInfo ? (stateInfo.logisticStatus || '') : '';
// 销售出库单状态(2026-10-29 新增)—— 判「单据作废」的唯一可靠来源
const ioInfo = ioStatusMap.get(Number(row.o_id)) || null;
const ioStatus = ioInfo ? (ioInfo.status || '') : '';
const ioAllDeleted = Boolean(ioInfo && ioInfo.allDeleted);
// ── ② 已发兜底:状态表说发了,就不再算未发 ─────────────────────────────
// PR #88 换源时记录的是「状态表 send_time 漏回写」这个方向,但**反方向也会漏**:
// 2026-10-28 实测 13:00 轮 144 单里 **6 单**状态表 send_time 有值、且有
// 物流揽收轨迹,而订单表 send_date 仍是 NULL —— 只信订单表就会冤枉仓库。
// ⟹ 口径:**任一方有发货时间即视为已发**,剔除量记 summary.stateShippedSkipped。
// ⚠️ 只认 send_time,**不要**拿 `logistic_time` 当发货时间:它多数是
// 「快递员将上门取件」的预告(实测 9983162 有轨迹但并未收件),会提前放行。
if (oaInfo && oaInfo.sendTime) {
stateShippedSkipped += 1;
continue;
}
const oaConfirmAt = oaInfo ? (oaInfo.last || '') : '';
const benchmarkAt = oaConfirmAt || createdAt;
const benchmarkSource = oaConfirmAt ? 'oa_confirm' : 'created';
const oaConfirmAt = stateInfo ? (stateInfo.last || '') : '';
// 起算点 = 审核时间 / 订单 modified / 下单时间 三者取最大。
// · 取较晚者是为了修「状态表审核时间滞后」(详见上面 9978643 的证据);
// · 把 createdAt 也纳入比较,是因为个别单的 modified 会早于 created(脏数据),
// 起算点绝不该早于下单时刻。
const benchmarkAt = laterOf(laterOf(oaConfirmAt, modifiedAt), createdAt) || createdAt;
let benchmarkSource = 'created';
if (benchmarkAt && benchmarkAt === modifiedAt) benchmarkSource = 'modified';
else if (benchmarkAt && benchmarkAt === oaConfirmAt) benchmarkSource = 'oa_confirm';
const payAt = formatDateTime(row.pay_date);
const statusRaw = String(row.status || '');
@ -586,6 +908,71 @@ async function getShipTimeliness(options = {}) {
if (seenSo.has(dedupeKey)) continue;
seenSo.add(dedupeKey);
// ══ 终态校验(2026-10-29 新增,**必须排在窗口判断和「不计考核」之前**)════
// 🔥 背景:业务第三次报「作废的、已经发货的还在考核之内」。根因不是判定写错,
// 而是**订单两表各自停更**:当天 qmcust 停在 07:25(6 小时),停更之后在
// 聚水潭做的「取消 / 发货」,订单表里完全没反映 —— status 仍是 Delivering、
// send_date 仍是空,于是被当成真超时。13:00 轮 159 单**全部**来自停更的 qmcust。
//
// 状态镜像表虽也停(当天 11:52),但比订单表新鲜 4 小时,`order_status_name`
// 已经是聚水潭的订单终态。实测这 159 单里 11 单 `order_status_name='已取消'`,
// 而这 11 单在订单表 `labels` 里**根本没有**「发货前售后」——
// 原来的 `presaleVoid` 判据(订单表 labels 含关键词)在这批数据上 0 命中。
//
// ⚠️ **判据只用 `order_status_name`**,别用 `aftersale_status_name`:
// · `order_status_name='已取消'` → 订单真的取消了 → 不考核
// · `aftersale_status_name='已作废'` → **售后单被撤销,订单照常发货** → 仍要考核
// (近 2 天 1387 单全是这种,混为一谈会把该考核的单全放跑)
//
// 顺序:**先判取消、再判已发**。发了又被取消的单,两边都不该考核仓库,
// 但归到「作废」比归到「已发」更贴合业务口径(业务对账看的是作废量)。
if (stateOrderStatus === STATE_ORDER_VOID_STATUS) {
voidCount += 1;
stateVoidSkipped += 1;
continue;
}
// ── 作废②:销售出库单整体作废(2026-10-29 新增,业务点名的那批单)──────────
// 🔥 业务原话:「9992097 / 9992098 / 9992924 … 洛宁仓 16 单,这些订单都是作废订单,
// 为啥还在考核之内」,并指明「在聚水潭的**销售出库单**里面找一下这个作废单据」。
//
// 聚水潭的作废落在**出库单**上(`status='Delete'`),而不是订单表的 labels。
// 出库单 `Delete` 的近 7 天样本里,**55 单订单表仍是 `Delivering`** ——
// 订单表和状态表都可能抓不到,只有出库单能判出来。
//
// ⚠️ **必须「该 o_id 下没有任何非 Delete 出库单」才算作废**:
// 拆包 / 重开的单会有多张出库单,删掉旧的那张、新的还在 WaitConfirm —— 照常要发。
// 实测近 7 天 51 个「订单发货中但出库单被删」的单里,7 个挂着 2~8 张全 Delete 的出库单。
// ⚠️ **「没有出库单」绝不能判作废**:近 3 天未发单 82%(1467/1790)压根没出库单。
//
// 🔴 **只对「发货中」生效,异常单/待审核单不碰**(判据放在 here、held 判断之前用
// `statusRaw === ORDER_PENDING_STATUS` 卡住)。原因:实测全库「出库单全 Delete」
// 的候选单里 **127/131 状态表是「异常」**,那批单在聚水潭还挂着待处理,
// 出库单被删更可能是「重新建单」,不是作废 —— 当成作废剔掉会让业务
// 在「不计考核」里也看不到它们,是**丢可见性**,比漏剔更糟。
if (ioAllDeleted && statusRaw === ORDER_PENDING_STATUS) {
voidCount += 1;
ioVoidSkipped += 1;
continue;
}
// ── 已发:三条任一成立即算(状态表比订单表可信得多)────────────────────
// ① `send_time` 有值 —— 订单表 send_date 漏回写时的兜底
// (2026-10-28 实测 144 单里 6 单是这种)
// ② `order_status_name='已发货'` —— 聚水潭订单终态(近 2 天 15.4 万单)
// ③ `logistic_status_name` ∈ 已揽收 / 运输中 / 派送中 / 已签收 / 拒收
// —— 快递已经把货拿走了。`拒收` 也算:仓库的发货动作已完成。
// ⚠️ **`未揽收` / `无物流单` 都不算**:前者只是打了单快递没来取,
// 后者连快递单都没录(当天 39/159 单是这种),都是真未发。
// ⚠️ 也别拿 `logistic_time` 当发货时间 —— 它多数是「快递员将上门取件」的预告。
const shippedByState = (stateInfo && stateInfo.sendTime)
|| stateOrderStatus === STATE_ORDER_SHIPPED_STATUS
|| STATE_LOGISTIC_SHIPPED_STATUSES.includes(stateLogisticStatus);
if (shippedByState) {
stateShippedSkipped += 1;
continue;
}
// ── 本轮核验范围(窗口上界按**起算点**卡)──────────────────────────────
// 13:00 轮:今天 07:00 前审核的单 + 历史未发
// 18:00 轮:今天 16:00 前审核的单 + 历史未发(山东两仓 15:00、河南洛宁 13:00)
@ -601,9 +988,24 @@ async function getShipTimeliness(options = {}) {
state: ORDER_STATE_LABELS[statusRaw] || statusRaw,
statusRaw,
src: String(row.src || ''),
// 该单来自哪张订单表、这张表是否已经停更 ────────────────────────────
// 🔥 停更 ⟹ 停更之后发出的单在这里仍是 send_date 空 ⟹ 被判「未发」,
// 但真实情况很可能是已经发了。所以**不能静默当确认未发**,
// 页面要标出来(2026-10-28 18:00 轮 546 单里 540 单是这种)。
srcLabel: (sourceMap.get(String(row.src || '')) || {}).label || String(row.src || ''),
sourceStale: Boolean((sourceMap.get(String(row.src || '')) || {}).stale),
createdAt,
oaConfirmAt,
payAt,
// 状态镜像表里的聚水潭终态 —— 订单表停更时,页面靠它告诉业务「这单其实取消了/发了」
stateOrderStatus,
stateLogisticStatus,
stateQueryTime: stateInfo ? (stateInfo.queryTime || '') : '',
stateSendTime: stateInfo ? (stateInfo.sendTime || '') : '',
// 销售出库单状态(Delete=作废 / WaitConfirm=待出库 / Confirmed=已出库)
// 业务核对时直接对照聚水潭「销售出库单」页面
ioStatus,
ioCount: ioInfo ? ioInfo.count : 0,
// 起算点(审核时间;缺失回退创建时间)—— 「已等时长」从它算
benchmarkAt,
benchmarkSource,
@ -657,6 +1059,10 @@ async function getShipTimeliness(options = {}) {
const waited = Math.max(0, diffMinutes(benchmarkAt, round.deadline));
bucket.pendingCount += 1;
if (base.sourceStale) {
sourceStaleUnshipped += 1;
sourceStaleBySrc[base.srcLabel] = (sourceStaleBySrc[base.srcLabel] || 0) + 1;
}
const days = Math.floor(waited / 1440);
if (days > bucket.oldestDays) bucket.oldestDays = days;
pendingRows.push({ ...base, waited });
@ -699,6 +1105,19 @@ async function getShipTimeliness(options = {}) {
benchmarkTime: x.benchmarkAt,
benchmarkSource: x.benchmarkSource,
state: x.state,
// 聚水潭侧终态(来自状态镜像表):订单表停更时,这一列才是真的
// 业务核对时看这个 —— 「已取消」本该被剔除,出现在明细里就说明状态表也没抓到
stateOrderStatus: x.stateOrderStatus,
stateLogisticStatus: x.stateLogisticStatus,
stateQueryTime: x.stateQueryTime,
// 销售出库单状态(Delete=作废 / WaitConfirm=待出库 / Confirmed=已出库)
// 🔥 业务在聚水潭「销售出库单」页面看到的作废,就对应这里的 Delete
ioStatus: x.ioStatus,
ioCount: x.ioCount,
// 该单所在订单表是否已停更 —— 前端据此给单打「数据未同步」标记
src: x.src,
srcLabel: x.srcLabel,
sourceStale: x.sourceStale,
// 订单表没有物流轨迹,只能从「有没有运单号」判断仓库是否已打单
logisticStatus: x.logisticId ? '已打单 · 未揽收' : '',
// 运单号 / 快递公司:有运单号说明仓库**已打单**(但还没回传发货时间)。
@ -773,6 +1192,11 @@ async function getShipTimeliness(options = {}) {
summary.voidCount = voidCount;
summary.carrierSkipped = carrierSkipped;
summary.stateShippedSkipped = stateShippedSkipped;
// 由**状态镜像表终态**剔除的作废单量(订单表 labels 判据在停更期会整体失效)
summary.stateVoidSkipped = stateVoidSkipped;
// 由**销售出库单整体 Delete** 剔除的作废单量(业务 2026-10-29 点名的作废单)
summary.ioVoidSkipped = ioVoidSkipped;
summary.sourceStaleUnshipped = sourceStaleUnshipped;
summary.unknownWarehouse = unknownWarehouse;
// 新鲜度:快照时间取自上面主查询的 query_time(不再额外扫一遍 402 万行表)
@ -781,10 +1205,34 @@ async function getShipTimeliness(options = {}) {
// 15:48 之后发的货就永远进不来,页面只能基于旧快照判「未发」。
// 必须把滞后暴露到页面上,否则业务只会以为判定写错。
const snapshotAgeMin = snapshotAt ? diffMinutes(snapshotAt, formatDateTime(now)) : null;
const stale = snapshotAgeMin != null && snapshotAgeMin > STATE_STALE_MINUTES;
// 停更判定要**两个口径取或**:
// ① 候选行的 MAX(updated_at) 太旧(老口径,只能反映"候选池里最新的那条")
// ② 任一订单表自己停更(新口径,直接问源表 —— 候选行会骗人,见 SOURCE_STALE_MINUTES 注释)
const staleSources = sourceFreshness.filter((s) => s.stale);
const stale = (snapshotAgeMin != null && snapshotAgeMin > STATE_STALE_MINUTES)
|| staleSources.length > 0;
// 停更源的一句话描述:「jst_Orders 停止同步于 14:40(已 4.3 小时)」
const staleSrcText = staleSources
.map((s) => `${s.label} 停止同步于 ${String(s.lastUpdate || '').slice(11, 16) || '—'}`
+ `(已 ${Math.round((s.lagMinutes || 0) / 6) / 10} 小时)`)
.join('、');
// 停更源各贡献了多少超时单(540 来自 jst_Orders、6 来自 qmcust 这种要说清,别只写「这张表」)
const staleBySrcText = Object.entries(sourceStaleBySrc)
.map(([k, v]) => `${k} ${v} 单`)
.join('、');
// 🔥 更狠的一条:数据**比本轮核验时刻还早** ⇒ 核验时刻那一刻的真实状态根本没看到。
// 2026-10-27 18:00 轮就是这种情况(状态镜像停在 11:54),推出去的 34 单里混着已发货的。
const coversDeadline = !!snapshotAt && snapshotAt >= round.deadline;
// 🔴 出库单/状态表停更 ⟹ **「这单作废了吗」这件事本身查不出来**(2026-10-29 新增)
// 业务当天点名 9992097 等 9 单「都是作废订单,为啥还在考核之内」:
// 聚水潭里已经作废,但我们库里订单表还是 Delivering、出库单还是 WaitConfirm、
// 状态表还是「发货中」—— 三个来源全停在作废动作**之前**,所以判据再准也判不出来。
// ⟹ 这种情况必须**明说判据失效**,不能让业务以为「系统认定这单没作废」。
const voidJudgeStale = ['jst_order_express_details', 'jst_salesOutboundInfo', 'jst_qmcust_salesoutbound']
.map((k) => sourceMap.get(k))
.filter((s) => s && s.stale);
const freshness = {
stateMaxQuery: snapshotAt,
ageMinutes: snapshotAgeMin,
@ -792,9 +1240,19 @@ async function getShipTimeliness(options = {}) {
coversDeadline,
// 数据源已经换成订单表,文案跟着改(别再写「状态镜像」)
source: 'jst_Orders',
// 作废/取消判据是否可信(false = 出库单或状态表停更,作废单可能没剔干净)
voidJudgeReliable: voidJudgeStale.length === 0,
hint: [
stale
? `订单表最后更新只到 ${String(snapshotAt).slice(11, 16)}(已 ${Math.round(snapshotAgeMin / 60 * 10) / 10} 小时未刷新)。`
// 有源停更就一定要说,哪怕本轮 0 单 —— 「没停更但没单」和「停更了所以看不到单」是两件事
staleSrcText ? `数据源停更:${staleSrcText}。` : '',
sourceStaleUnshipped > 0
? `本轮 ${sourceStaleUnshipped} 单来自停更的数据源(${staleBySrcText}):`
+ '停更之后发出的单在这里仍是「未发货」,这些单很可能已经发货,请先在聚水潭核对同步状态再判超时。'
: '',
voidJudgeStale.length > 0
? `⚠️ ${voidJudgeStale.map((s) => s.label).join('、')} 已停止同步,`
+ '作废单 / 取消单可能判不出来(聚水潭里的作废动作还没同步到本系统),'
+ '下面凡是显示「发货中 · 无物流单」的单,请先在聚水潭「销售出库单」里核对是否已作废。'
: '',
!coversDeadline
? `数据还没覆盖到本轮核验时刻 ${String(round.deadline).slice(11, 16)}:`
@ -828,6 +1286,8 @@ async function getShipTimeliness(options = {}) {
// 审核时间缺失、回退订单创建时间的单量(页面/钉钉需要标出来)
fallbackToCreated: orders.filter((o) => o.benchmarkSource === 'created').length,
fallbackDegraded: oaConfirmDegraded,
// 销售出库单查询失败 ⟹ 作废判据降级(页面据此提示「作废单可能没剔干净」)
ioDegraded: ioDegraded,
// 仓级例外窗口(山东青岗集/山东品牌 15:00、河南洛宁 13:00,仅 18:00 轮)
overrides: windowOverrides,
},
@ -843,6 +1303,8 @@ async function getShipTimeliness(options = {}) {
detailLimit: detailRows.length,
detailDegraded: false,
freshness,
// 两个订单表各自的同步新鲜度(页面据此出红条告警)
dataSources: sourceFreshness,
cached: false,
cacheAgeSec: 0,
note: '',
@ -917,6 +1379,8 @@ async function listShipTimelinessExportRows(query = {}) {
summary: payload.summary || emptySummary(),
excludedCarriers: payload.excludedCarriers || EXCLUDED_CARRIERS,
freshness: payload.freshness || null,
// 导出也要能说明「这批单里有多少来自停更的源」,否则导出的 Excel 脱离页面就没了上下文
dataSources: payload.dataSources || [],
};
}

View File

@ -154,6 +154,10 @@ function stubDb(rows, options = {}) {
if (/jst_returnAndRefundInfo|jst_qmcust_refundlist/u.test(String(sql))) {
return options.interceptRows || [];
}
// 窗口 0 行时的「表级最后灌库时刻」探测
if (/MAX\(\s*e\.query_time\s*\)/iu.test(String(sql))) {
return options.sourceMaxQueryTime === undefined ? [] : [{ max_q: options.sourceMaxQueryTime }];
}
return rows;
};
require.cache[dbPath] = {
@ -672,3 +676,42 @@ test('售后表查询失败时降级:不剔单、不炸页面', async () => {
delete require.cache[require.resolve('../src/services/warehouseLogisticsExceptionRegistry')];
}
});
// ── ⑧ 窗口 0 行:0 单不能被当成「当天没发货 / 全部正常」(2026-11-02)──────
// 起因:11-02 09:00 那批推出「已发货 0 单 / 0 个包裹,异常 0 个包裹」,
// 实况是镜像表 11-01 07:55 之后就没再灌库,11-01 的 12 仓发货记录一条都没进库。
test('窗口 0 行 + 数据源停更 → emptyWindow/sourceStale,hint 明说「数据没进库」', async () => {
const nov2 = new Date(2026, 10, 2, 10, 0, 0); // 2026-11-02 10:00(本机时区)
await withStub(async (svc, calls) => {
const data = await svc.getLogisticsExceptions({ date: '2026-11-02', now: nov2, limit: 100 });
assert.equal(data.summary.shippedOrders, 0);
assert.equal(data.freshness.emptyWindow, true);
assert.equal(data.freshness.sourceLastUpdate, '2026-11-01 07:55:04');
assert.ok(data.freshness.sourceAgeMinutes > 120, `应算出停更小时数,实际 ${data.freshness.sourceAgeMinutes}`);
assert.equal(data.freshness.sourceStale, true);
assert.match(data.freshness.hint, /一条都没有/);
assert.match(data.freshness.hint, /不代表当天没发货/);
// 只在空窗口才付那次全表 MAX(query_time)(实测 13.5s)
assert.equal(calls.sql.filter((s) => /MAX\(\s*e\.query_time\s*\)/iu.test(s)).length, 1);
}, [], { sourceMaxQueryTime: '2026-11-01 07:55:04' });
});
test('窗口 0 行但数据源是新的 → 仍然提示「0 条记录」,不能静默全绿', async () => {
const nov2 = new Date(2026, 10, 2, 10, 0, 0);
await withStub(async (svc) => {
const data = await svc.getLogisticsExceptions({ date: '2026-11-02', now: nov2, limit: 100 });
assert.equal(data.freshness.emptyWindow, true);
assert.equal(data.freshness.sourceStale, false, '表是新的,不该报停更');
assert.match(data.freshness.hint, /0 条发货记录/, '真 0 单也要说清是「库里没有记录」');
assert.match(data.freshness.hint, /数据源本身正常/);
}, [], { sourceMaxQueryTime: '2026-11-02 09:58:00' });
});
test('窗口有行时不做全表探测(省掉 13.5s 的表级 MAX)', async () => {
await withStub(async (svc, calls) => {
const data = await svc.getLogisticsExceptions({ date: '2026-10-21', now: at(21, 10, 0), limit: 100 });
assert.equal(data.freshness.emptyWindow, false);
assert.equal(data.freshness.sourceLastUpdate, '');
assert.equal(calls.sql.filter((s) => /MAX\(\s*e\.query_time\s*\)/iu.test(s)).length, 0);
});
});

View File

@ -495,3 +495,50 @@ test('发文本:超长正文自动截断后仍会发出去(不是直接抛
stub.restore();
}
});
// ── ⑤ 0 单不能用「全部正常」糊过去(2026-11-02)──────────────────────────
// 实况:11-02 09:00 那批推的是「0 单 / 0 个包裹,异常 0 个包裹」,业务以为真没发货,
// 其实是物流镜像表 11-01 07:55 后就没同步。群里绝不能出现「全部正常」这种假绿。
test('数据源停更导致 0 单 → 正文首部醒目告警,且不出现「全部正常」', () => {
const data = sampleData({
rows: [],
summary: {
shippedOrders: 0, packageCount: 0, exceptionOrders: 0,
exceptionPackages: 0, exceptionRate: 0, centerCount: 0, byType: {},
},
exclusions: {},
freshness: {
emptyWindow: true,
sourceLastUpdate: '2026-11-01 07:55:04',
sourceAgeMinutes: 1565,
sourceStale: true,
hint: '11-01 的发货记录在物流镜像表里一条都没有',
},
});
const built = job.buildNotifyText(data, { maxDetailRows: 30 });
assert.match(built.text, /物流数据未同步/);
assert.match(built.text, /镜像表最后更新 2026-11-01 07:55:04/);
assert.match(built.text, /已 26\.1 小时未同步/);
assert.match(built.text, /不代表当天没发货/);
assert.ok(!built.text.includes('全部正常'), '数据没进库时不能说「全部正常」');
// 抬头仍要带「异常」关键词,否则钉钉自定义关键词会拒收
assert.match(built.text, /【仓储物流转运异常】/);
});
test('数据源正常但当天 0 条记录 → 说明是「库里没有记录」,不说「全部正常」也不谎报停更', () => {
const data = sampleData({
rows: [],
summary: {
shippedOrders: 0, packageCount: 0, exceptionOrders: 0,
exceptionPackages: 0, exceptionRate: 0, centerCount: 0, byType: {},
},
exclusions: {},
freshness: { emptyWindow: true, sourceLastUpdate: '2026-11-02 09:58:00', sourceAgeMinutes: 2, sourceStale: false },
});
const built = job.buildNotifyText(data, { maxDetailRows: 30 });
assert.match(built.text, /在物流镜像表里 0 条发货记录/);
assert.match(built.text, /数据源本身正常/);
assert.match(built.text, /请到聚水潭核对/);
assert.ok(!built.text.includes('物流数据未同步'), '表是新的,不能谎报停更');
assert.ok(!built.text.includes('全部正常'), '0 条不能糊成「全部正常」');
});

View File

@ -184,7 +184,7 @@ test('起算点是 orders.created,且只从订单两表取', () => {
});
// ── ④ 服务层分桶(注入假查询,不连库)──
function stubDb(dbPath, scenario = 'default', oaRows = []) {
function stubDb(dbPath, scenario = 'default', oaRows = [], freshnessUpd = '2026-10-20 18:00:00', ioRows = []) {
const WMS = {
CQ: 15038426,
SD_QGJ: 15137523,
@ -281,9 +281,64 @@ function stubDb(dbPath, scenario = 'default', oaRows = []) {
o(26, WMS.CQ, '2026-10-18 12:00:00', { updated_at: '2026-10-20 11:18:27' }), // 2940 分
];
const rows = scenario === 'noon' ? noonRows : defaultRows;
// 「起算点 = max(审核时间, 订单 modified)」专用场景(2026-10-28 下午定版)
// 🔥 为什么必须取较晚者:状态表的 last_oa_confirm_time 会滞后。
// 实测 9978643:状态表写 10-27 17:08,聚水潭真实审核 10-28 14:52,
// 只信状态表 → 把「今天下午才审核的单」算进 13:00 轮,冤枉仓库。
const modifiedRows = [
// 51:created 06:45(7 点前),但 modified 是今天 14:52 → 起算点 14:52 晚于窗口 07:00 → 剔除
o(51, WMS.CQ, '2026-10-20 06:45:00', { modified: '2026-10-20 14:52:29' }),
// 52:历史单 created 10-18,状态表无审核时间,modified 今天 06:00 → 算超时,起算点 06:00
o(52, WMS.CQ, '2026-10-18 12:00:00', { modified: '2026-10-20 06:00:00' }),
// 53:modified 比 created 还早(异常数据)→ 起算点回落到 created
o(53, WMS.CQ, '2026-10-20 05:00:00', { modified: '2026-10-19 23:00:00' }),
];
const calls = { orders: 0, oaConfirm: 0, warehouse: 0, sql: [], params: [] };
// 终态校验专用场景(2026-10-29)
// 🔥 现场:业务第三次报「作废的、已经发货的还在考核之内」。根因是订单两表各自停更,
// 停更之后聚水潭里的「取消 / 发货」订单表看不到,只有状态镜像表能反映。
// 这一组行**订单表侧全部干净**(status=Delivering + send_date 空 + labels 无关键词),
// 全靠状态表终态区分,专门验证「订单表谎报时状态表能救回来」。
const terminalRows = [
o(61, WMS.CQ, '2026-10-20 05:00:00'), // 状态表 已取消 → 剔除(作废)
o(62, WMS.CQ, '2026-10-20 05:10:00'), // 状态表 已发货 → 剔除(已发)
o(63, WMS.CQ, '2026-10-20 05:20:00'), // 物流 已揽收 → 剔除(已发)
o(64, WMS.CQ, '2026-10-20 05:30:00'), // 售后「已作废」+ 订单「发货中」→ **仍要考核**
o(65, WMS.CQ, '2026-10-20 05:40:00'), // 物流 未揽收 → **仍要考核**
o(66, WMS.CQ, '2026-10-20 05:50:00'), // send_time 有值(订单表漏回写)→ 剔除
o(67, WMS.CQ, '2026-10-20 06:00:00'), // 状态表停更,无终态信息 → 按未发算
];
// 出库单作废专用场景(2026-10-29)
// 🔥 现场:业务点名 9992097 等洛宁仓 9 单「都是作废订单,为啥还在考核之内」,
// 并指明「在聚水潭的**销售出库单**里面找这个作废单据」。
// 聚水潭作废落在出库单 `status='Delete'` 上,所以判据必须看出库单。
const ioDbRows = [
// 71:唯一出库单被删 → 单据作废,剔除
{ o_id: 71, io_id: 9001, status: 'Delete' },
// 72:拆包重开:旧单 Delete + 新单 WaitConfirm → **仍要考核**(不能凭一张 Delete 就剔)
{ o_id: 72, io_id: 9002, status: 'Delete' },
{ o_id: 72, io_id: 9003, status: 'WaitConfirm' },
// 73:异常单 + 出库单全删 → **仍进「不计考核」**,不能当作用废丢掉可见性
{ o_id: 73, io_id: 9004, status: 'Delete' },
// 74:压根没有出库单 → 仍要考核(近 3 天 82% 未发单都没有出库单)
// 75:出库单待出库 → 仍要考核(就是洛宁仓那批显示 WaitConfirm 的真积压)
{ o_id: 75, io_id: 9005, status: 'WaitConfirm' },
];
const ioScenarioRows = [
o(71, WMS.HN_LN, '2026-10-20 05:00:00'),
o(72, WMS.HN_LN, '2026-10-20 05:10:00'),
o(73, WMS.HN_LN, '2026-10-20 05:20:00', { status: 'Question' }),
o(74, WMS.HN_LN, '2026-10-20 05:30:00'),
o(75, WMS.HN_LN, '2026-10-20 05:40:00'),
];
const rows = scenario === 'modified' ? modifiedRows
: (scenario === 'noon' ? noonRows
: (scenario === 'terminal' ? terminalRows
: (scenario === 'io' ? ioScenarioRows : defaultRows)));
const calls = { orders: 0, oaConfirm: 0, io: 0, warehouse: 0, freshness: 0, sql: [], params: [] };
const handler = async (sql, params) => {
const text = String(sql);
@ -291,6 +346,25 @@ function stubDb(dbPath, scenario = 'default', oaRows = []) {
calls.warehouse += 1;
return warehouseRows;
}
// 数据源新鲜度探测:`SELECT MAX(updateTime) FROM jst_Orders` /
// `SELECT MAX(local_updated) FROM jst_qmcust_orderlist` /
// `SELECT MAX(updatedAt) FROM jst_order_express_details`(状态镜像表,2026-10-29 新增)/
// `SELECT MAX(updateTime) FROM jst_salesOutboundInfo`、`MAX(local_updated) FROM jst_qmcust_salesoutbound`
// (出库单两表,2026-10-29 新增)。
// 单独记账,**不算订单候选查询** —— 否则「订单两表只允许查一次」的老断言会误伤。
if (/MAX\(updateTime\)/iu.test(text) || /MAX\(local_updated\)/iu.test(text)
|| /MAX\(updatedAt\)/iu.test(text)) {
calls.freshness += 1;
// 默认 18:00(用例 now=18:05 → 滞后 5 分钟 < 60,不触发停更告警);
// 要测停更场景就把 freshnessUpd 传成当天更早的时刻
return [{ maxUpd: freshnessUpd }];
}
// 销售出库单状态(2026-10-29 新增):`SELECT o_id, io_id, status FROM jst_*salesoutbound`
// 默认空 → 服务层「没有出库单就不判作废」,不影响老用例
if (/jst_salesOutboundInfo|jst_qmcust_salesoutbound/u.test(text)) {
calls.io += 1;
return ioRows;
}
// 审核时间查询(状态表):默认返回空 → 服务层全部回退订单创建时间,
// 这样老断言(按创建时间算的分钟数)继续成立;要测审核时间口径就传 oaRows
if (/jst_order_express_details/u.test(text)) {
@ -314,11 +388,11 @@ function stubDb(dbPath, scenario = 'default', oaRows = []) {
return { calls, WMS };
}
function withStubbedService(fn, scenario = 'default', oaRows = []) {
function withStubbedService(fn, scenario = 'default', oaRows = [], freshnessUpd = '2026-10-20 18:00:00', ioRows = []) {
return async () => {
const dbPath = require.resolve('../src/config/cloudDatabase');
const realDb = require.cache[dbPath];
const ctx = stubDb(dbPath, scenario, oaRows);
const ctx = stubDb(dbPath, scenario, oaRows, freshnessUpd, ioRows);
delete require.cache[require.resolve('../src/services/warehouseShipTimelinessService')];
delete require.cache[require.resolve('../src/services/warehouseShipTimelinessRegistry')];
try {
@ -619,3 +693,171 @@ test('导出行为纯函数:缺字段一律给空串,不导出 undefined', (
assert.equal(rows[1].oId, '');
assert.doesNotMatch(JSON.stringify(rows), /undefined|null|NaN/u);
});
test('起算点 = max(审核时间, 订单 modified):状态表滞后时以 modified 为准', withStubbedService(async (svc) => {
// 13:05 → 13:00 轮,窗口上界 07:00
const data = await svc.getShipTimeliness({ now: at(13, 5), limit: 10 });
// 51 的 modified 是今天 14:52,晚于窗口 07:00 → 必须剔除(这就是 9978643 那类单)
assert.ok(!data.orders.some((x) => String(x.oId) === '51'),
'modified 晚于窗口的单不能算进 13:00 轮(状态表滞后会把它冤枉成 7 点前审核)');
// 52:状态表无审核时间,modified 今天 06:00 → 起算点 06:00,不是 created 10-18 12:00
const r52 = data.orders.find((x) => String(x.oId) === '52');
assert.ok(r52, '52 应算超时(modified 06:00 早于窗口 07:00)');
assert.equal(r52.auditTime, '2026-10-20 06:00:00', '起算点取 modified');
assert.equal(r52.benchmarkSource, 'modified', '来源必须是 modified');
assert.equal(r52.createdAt, '2026-10-18 12:00:00', '下单时间照旧展示');
assert.equal(r52.overdueMinutes, 420, '06:00 → 13:00 = 420 分钟(不是按下单时间算的 4380)');
// 53:modified 早于 created → 取较晚者 = created 05:00
const r53 = data.orders.find((x) => String(x.oId) === '53');
assert.ok(r53, '53 应算超时');
assert.equal(r53.auditTime, '2026-10-20 05:00:00', 'modified 比 created 早时不能倒退,取 created');
assert.equal(r53.benchmarkSource, 'created');
}, 'modified'));
test('状态表审核时间比 modified 更晚时,以状态表为准', withStubbedService(async (svc) => {
const data = await svc.getShipTimeliness({ now: at(13, 5), limit: 10 });
const r52 = data.orders.find((x) => String(x.oId) === '52');
assert.ok(r52, '52 应算超时');
assert.equal(r52.auditTime, '2026-10-20 06:30:00', '审核时间 06:30 晚于 modified 06:00,取审核时间');
assert.equal(r52.benchmarkSource, 'oa_confirm');
}, 'modified', [
{ inner_order_id: 52, first_oa_confirm_time: new Date(2026, 9, 20, 6, 30, 0), last_oa_confirm_time: new Date(2026, 9, 20, 6, 30, 0), send_time: null },
]));
test('状态表终态:已取消 / 已发货 / 已揽收的单必须剔除,售后「已作废」不能误剔', async () => {
// 🔥 2026-10-29 现场(业务第三次报同一件事):
// 13:00 轮 159 单**全部**来自停更的 qmcust(停 07:25),订单表里
// status 仍是 Delivering、send_date 仍是空、labels 里**没有**「发货前售后」。
// 而状态镜像表(停 11:52,比订单表新鲜 4 小时)已经把它们标成「已取消」。
// ⟹ 判据必须补状态表终态,否则停更期的取消/发货永远判不出来。
const oa = [
// 已取消 → 作废
{ inner_order_id: 61, order_status_name: '已取消', aftersale_status_name: '已确认', logistic_status_name: '未揽收', last_oa_confirm_time: null, send_time: null },
// 已发货 → 已发
{ inner_order_id: 62, order_status_name: '已发货', aftersale_status_name: '暂无售后', logistic_status_name: '已签收', last_oa_confirm_time: null, send_time: null },
// 订单还「发货中」,但快递已揽收 → 已发
{ inner_order_id: 63, order_status_name: '发货中', aftersale_status_name: '暂无售后', logistic_status_name: '已揽收', last_oa_confirm_time: null, send_time: null },
// ⚠️ 售后「已作废」= 售后单被撤销,订单照常发货 → **仍要考核**
{ inner_order_id: 64, order_status_name: '发货中', aftersale_status_name: '已作废', logistic_status_name: '未揽收', last_oa_confirm_time: null, send_time: null },
// 未揽收 → 仍要考核
{ inner_order_id: 65, order_status_name: '发货中', aftersale_status_name: '暂无售后', logistic_status_name: '未揽收', last_oa_confirm_time: null, send_time: null },
// 订单表 send_date 漏回写,但状态表 send_time 有值 → 已发
{ inner_order_id: 66, order_status_name: '发货中', aftersale_status_name: '暂无售后', logistic_status_name: '未揽收', last_oa_confirm_time: null, send_time: new Date(2026, 9, 20, 12, 0, 0) },
// 状态表没有这单的行(停更/未覆盖)→ 按未发算,不能因为查不到就放行
];
await withStubbedService(async (svc) => {
const data = await svc.getShipTimeliness({ now: at(13, 5), limit: 20 });
const ids = data.orders.map((x) => String(x.oId)).sort();
assert.deepEqual(ids, ['64', '65', '67'], '只该剩「售后已作废 / 未揽收 / 状态表无记录」三单');
assert.equal(data.summary.stateVoidSkipped, 1, '已取消要单独记账(业务对账看这个数)');
assert.equal(data.summary.stateShippedSkipped, 3, '已发货 + 已揽收 + send_time 有值 = 3 单剔为已发');
assert.equal(data.summary.voidCount, 1, '作废量含状态表判出的那一单');
// 明细行要把聚水潭终态透出来,业务核对时能一眼看出「这单其实取消了」
const r64 = data.orders.find((x) => String(x.oId) === '64');
assert.equal(r64.stateOrderStatus, '发货中');
assert.equal(r64.stateLogisticStatus, '未揽收');
}, 'terminal', oa);
});
test('状态表也纳入数据源新鲜度监控', async () => {
// 状态表是「取消了吗 / 发出了吗」的唯一权威来源,它停更了判据就过期了,
// 页面必须一起暴露,不能只报订单表停更。
await withStubbedService(async (svc) => {
const data = await svc.getShipTimeliness({ now: at(13, 5), limit: 10 });
const keys = data.dataSources.map((x) => x.key);
assert.ok(keys.includes('jst_order_express_details'), '状态镜像表要作为独立数据源透出');
// 2026-10-29:加入两张销售出库单表(作废判据的唯一来源,实测一起停更 11 小时)
assert.ok(keys.includes('jst_salesOutboundInfo'), '聚水潭出库单要作为独立数据源透出');
assert.ok(keys.includes('jst_qmcust_salesoutbound'), '奇门出库单要作为独立数据源透出');
assert.equal(data.dataSources.length, 5, '两个订单表 + 状态镜像表 + 两张出库单表');
}, 'terminal');
});
test('出库单整体 Delete = 单据作废,必须剔除;拆包重开 / 无出库单 / 异常单不能误剔', async () => {
// 🔥 2026-10-29 现场:业务点名 9992097 / 9992098 / 9992924 … 洛宁仓 9 单
// 「这些订单都是作废订单,为啥还在考核之内」,并指明
// 「在聚水潭的**销售出库单**里面找一下这个作废单据」。
// 聚水潭的作废落在出库单 status='Delete' 上(订单表 labels 判据在这批单上 0 命中)。
await withStubbedService(async (svc) => {
const data = await svc.getShipTimeliness({ now: at(13, 5), limit: 20 });
// 71 = 唯一出库单被删 → 剔除;73 = 异常单(本就进「不计考核」)
const ids = data.orders.map((x) => String(x.oId)).sort();
assert.deepEqual(ids, ['72', '74', '75'],
'只剩:拆包重开(72) / 无出库单(74) / 出库单待出库(75)');
assert.equal(data.summary.ioVoidSkipped, 1, '出库单作废单独记账');
assert.equal(data.summary.voidCount, 1, '作废量含出库单判出的那一单');
// 🔴 关键反向保护:异常单 + 出库单全删 **不能**被剔成作废,
// 它必须留在「不计考核」里(业务要看到这批待处理的单)
const held = data.heldOrders.map((x) => String(x.oId));
assert.ok(held.includes('73'), '异常单即便出库单被删,也要留在不计考核清单里');
// 明细行要把出库单状态透出来,业务能直接对照聚水潭「销售出库单」页面
const r75 = data.orders.find((x) => String(x.oId) === '75');
assert.equal(r75.ioStatus, 'WaitConfirm', '待出库状态要透出');
const r72 = data.orders.find((x) => String(x.oId) === '72');
assert.equal(r72.ioStatus, 'WaitConfirm', '拆包重开时展示「还活着」的那张');
}, 'io', [], '2026-10-20 18:00:00', [
{ o_id: 71, io_id: 9001, status: 'Delete' },
{ o_id: 72, io_id: 9002, status: 'Delete' },
{ o_id: 72, io_id: 9003, status: 'WaitConfirm' },
{ o_id: 73, io_id: 9004, status: 'Delete' },
{ o_id: 75, io_id: 9005, status: 'WaitConfirm' },
]);
});
test('出库单/状态表停更时,提示要明说「作废判不出来」', async () => {
// 🔥 2026-10-29 13:10 实测:两张出库单表 local_updated 一起停在 03:10(停更 11 小时),
// 业务当天在聚水潭作的废**一条都没同步进来** ——
// 页面必须说清「判据失效」,不能让业务以为「系统认定这单没作废」。
await withStubbedService(async (svc) => {
const data = await svc.getShipTimeliness({ now: at(13, 5), limit: 10 });
assert.equal(data.freshness.voidJudgeReliable, false, '出库单停更 → 作废判据不可信');
assert.match(String(data.freshness.hint), /作废单\/取消单可能判不出来/u,
'提示要明说作废判不出来');
assert.match(String(data.freshness.hint), /销售出库单/u, '要告诉业务去哪儿核对');
}, 'terminal', [], '2026-10-20 10:00:00');
// 反方向:源都正常时不能吓唬人
await withStubbedService(async (svc) => {
const data = await svc.getShipTimeliness({ now: at(13, 5), limit: 10 });
assert.equal(data.freshness.voidJudgeReliable, true, '源正常时判据可信');
assert.doesNotMatch(String(data.freshness.hint), /可能判不出来/u, '不能误报判据失效');
}, 'terminal');
});
test('数据源停更:来自停更表的超时单必须打标,并计入 sourceStaleUnshipped', async () => {
// 🔥 2026-10-28 18:35 现场:`jst_Orders` 停更在 14:40,18:00 轮 546 单里 540 单来自它,
// 业务当场质疑「基本都发了」。页面对这种单**不能静默当确认未发**。
// 用例 now=18:05,源表停在 10:00 → 滞后 8 小时 > 60 分钟阈值
await withStubbedService(async (svc) => {
const data = await svc.getShipTimeliness({ now: at(18, 5), limit: 10 });
assert.ok(data.summary.overdueUnshipped > 0, '前置:默认场景应有超时单');
assert.equal(
data.summary.sourceStaleUnshipped,
data.summary.overdueUnshipped,
'源停更时,全部超时单都要计入「数据未同步」',
);
assert.ok(data.dataSources.length >= 2, '两个订单表的新鲜度都要透出');
assert.ok(data.dataSources.every((x) => x.stale), '两张表都停在 10:00,都算停更');
assert.equal(data.orders[0].sourceStale, true, '明细行要带 sourceStale 标记');
assert.ok(data.orders[0].srcLabel, '明细行要带来源表名,前端才解释得清');
assert.match(String(data.freshness.hint), /停更/u, '页面提示要说明是哪张表停更');
}, 'default', [], '2026-10-20 10:00:00');
// 反方向:源正常时不能误标,否则业务会以为每天都在停更
await withStubbedService(async (svc) => {
const data = await svc.getShipTimeliness({ now: at(18, 5), limit: 10 });
assert.equal(data.summary.sourceStaleUnshipped, 0, '源正常时不能标停更');
assert.ok(data.dataSources.every((x) => !x.stale), '滞后 5 分钟不达阈值');
assert.equal(Boolean(data.orders[0].sourceStale), false, '明细行不带停更标记');
}, 'default');
});

View File

@ -252,8 +252,15 @@ function WarehouseLogisticsException() {
const [activeCenter, setActiveCenter] = useState('');
// 异常类型筛选:为空 = 全部
const [activeType, setActiveType] = useState('');
// 核验日;null = 交给后端按「现在几点」自动判(未到 9 点自动看昨天那批)
const [verifyDate, setVerifyDate] = useState(null);
// 核验日;默认 null = 交给后端按「现在几点」自动判(未到 9 点自动看昨天那批)
// 🔥 钉钉消息里的链接带 `?date=YYYY-MM-DD`(见 buildPageLink),页面必须认这个参数 ——
// 否则群里点进来看到的是「今天这批」,跟消息里说的不是同一批,历史消息会误导人。
const [verifyDate, setVerifyDate] = useState(() => {
const raw = String(new URLSearchParams(window.location.search).get('date') || '').trim();
if (!/^\d{4}-\d{2}-\d{2}$/u.test(raw)) return null;
const parsed = dayjs(raw);
return parsed.isValid() ? parsed : null;
});
// 导出中(导出比列表慢,按钮要转圈,避免重复点)
const [exporting, setExporting] = useState(false);
// 每天定点把异常文本推到钉钉群(「异常通知」)
@ -564,14 +571,16 @@ function WarehouseLogisticsException() {
/>
) : null}
{freshness && (freshness.coversDeadline === false || freshness.stale) ? (
{freshness && (freshness.emptyWindow || freshness.coversDeadline === false || freshness.stale) ? (
<Alert
type={freshness.coversDeadline === false ? 'error' : 'warning'}
type={freshness.emptyWindow || freshness.coversDeadline === false ? 'error' : 'warning'}
showIcon
className="wle-alert"
message={freshness.coversDeadline === false
? '物流快照未覆盖本轮核验时刻,异常量偏大'
: '物流数据可能滞后'}
message={freshness.emptyWindow
? '本批 0 单:物流镜像表里没有当天的发货记录,这个 0 不可当结论'
: (freshness.coversDeadline === false
? '物流快照未覆盖本轮核验时刻,异常量偏大'
: '物流数据可能滞后')}
description={freshness.hint}
/>
) : null}
@ -589,7 +598,11 @@ function WarehouseLogisticsException() {
formatter={(v) => (notStarted ? '—' : number(v))}
/>
<Text type="secondary" className="wle-stat__sub">
共 {notStarted ? '—' : number(summary.packageCount)} 个包裹
{notStarted
? '—'
: (freshness?.emptyWindow
? '数据未同步,见上方红条'
: `共 ${number(summary.packageCount)} 个包裹`)}
</Text>
</Card>
<Card bordered={false} className="wle-stat">

View File

@ -166,7 +166,7 @@ const HELD_COLUMNS = [
},
{
title: (
<Tooltip title="聚水潭「审核时间」(last_oa_confirm_time)。带 * 的表示没取到审核时间,已回退订单创建时间">
<Tooltip title="聚水潭「审核时间」= 状态表 last_oa_confirm_time 与订单表 modified 的较晚者(状态表会滞后,9978643 旧值比真实审核早一天)。两者都没有才回退订单创建时间,标 *">
<span>审核时间</span>
</Tooltip>
),
@ -185,7 +185,26 @@ const HELD_COLUMNS = [
const DETAIL_COLUMNS = [
// 内部单号 = 聚水潭 o_id(系统内部编号,仓管在系统里按它查单)
{ title: '内部单号', dataIndex: 'oId', width: 110 },
{
title: '内部单号',
dataIndex: 'oId',
width: 158,
// 🔥 来自停更订单表的单必须打标(2026-10-28):
// 该表停更之后发出的单,send_date 仍是空 → 被判「未发」,实际很可能已经发了。
// 18:00 轮实测 546 单里 540 单是这种,不标出来业务会以为判定写错。
render: (v, row) => (
<span className="wst-detail__oid">
{v || '—'}
{row?.sourceStale ? (
<Tooltip
title={`这单来自 ${row?.srcLabel || '订单表'},该表已停止同步:停更之后发出的单在这里仍是「未发货」,很可能已经发了。请先在聚水潭核对。`}
>
<Tag bordered={false} color="error" className="wst-detail__stale">未同步</Tag>
</Tooltip>
) : null}
</span>
),
},
// 线上订单号 = 平台 so_id(京东/抖音/天猫等平台单号,客服按它对接客户)
{
title: '线上订单号',
@ -232,10 +251,10 @@ const DETAIL_COLUMNS = [
},
},
{
// 审核时间 = 本页的**考核起算点**(业务 2026-10-28 下午二次定版)
// 取状态表 last_oa_confirm_time;取不到回退订单创建时间并打 `*`
// 审核时间 = 本页的**考核起算点**(业务 2026-10-28 下午三次定版)
// = max(状态表 last_oa_confirm_time, 订单表 modified),都没有才回退创建时间并打 `*`
title: (
<Tooltip title="聚水潭「审核时间」(last_oa_confirm_time),这才是仓库真正接到单的时刻。今天 7:00 前审核的 13:00 核验;截止 16:00 前审核的(含历史未发单)18:00 核验,已等时长也从它算。带 * 的表示没取到审核时间,已回退订单创建时间">
<Tooltip title="聚水潭「审核时间」= 状态表 last_oa_confirm_time 与订单表 modified 的较晚者。状态表会滞后(9978643 状态表是 10-27 17:08,真实审核 10-28 14:52),所以取较晚的那个。今天 7:00 前审核的 13:00 核验;截止 16:00 前审核的(含历史未发单)18:00 核验。带 * 表示两者都没有,回退订单创建时间">
<span>审核时间</span>
</Tooltip>
),
@ -246,7 +265,7 @@ const DETAIL_COLUMNS = [
if (!v) return <span className="wst-detail__fallback">—</span>;
if (row?.benchmarkSource === 'created') {
return (
<Tooltip title="状态表里取不到这个单的审核时间,已回退订单创建时间参与分轮与计时(`*` 为标记)">
<Tooltip title="状态表审核时间和订单表 modified 都取不到,已回退订单创建时间参与分轮与计时(`*` 为标记)">
<span>{v} *</span>
</Tooltip>
);
@ -269,23 +288,70 @@ const DETAIL_COLUMNS = [
// 付款时间 = 客户付款那一刻(并列展示,方便对账)
{ title: '付款时间', dataIndex: 'payTime', width: 152, ellipsis: true, render: (v) => v || '—' },
{
// 发货状态:订单表 status(翻译成中文)
// 发货状态:**优先显示聚水潭终态**(状态镜像表),订单表状态只作对照
// 🔥 2026-10-29:订单两表会各自停更,停更期间聚水潭里已经「已取消 / 已发货」的单,
// 订单表里仍是「发货中」——业务看到的「作废的也在考核里」就是这么来的。
// 状态镜像表比订单表新鲜,`order_status_name` 才是聚水潭的真状态。
title: (
<Tooltip title="订单表 jst_Orders.status 的实时状态。发货中 = 仓库还没发货,即考核对象">
<Tooltip title="优先显示聚水潭订单终态(状态镜像表,订单表停更时只有它靠得住)。⚠ = 与订单表 jst_Orders.status 不一致">
<span>发货状态</span>
</Tooltip>
),
dataIndex: 'state',
width: 104,
render: (v) => (
<Tag bordered={false} color={v === '发货中' ? 'orange' : 'default'}>{v || '—'}</Tag>
),
dataIndex: 'stateOrderStatus',
width: 128,
render: (v, row) => {
const lake = v || '';
const ord = row?.state || '';
const diff = Boolean(lake && ord && lake !== ord);
const text = lake || ord || '—';
const color = text === '已取消' ? 'red' : (text === '发货中' ? 'orange' : 'default');
return (
<Tooltip title={`聚水潭:${lake || '—'}|订单表:${ord || '—'}${diff ? '(不一致,订单表没同步到这个状态)' : ''}`}>
<Tag bordered={false} color={color}>{text}{diff ? ' ⚠' : ''}</Tag>
</Tooltip>
);
},
},
{
title: '物流状态',
dataIndex: 'logisticStatus',
width: 100,
render: (v) => (v ? <Tag bordered={false}>{v}</Tag> : '—'),
// 物流状态:优先用状态表的真实物流节点(未揽收 / 已揽收 / 运输中 / 已签收…),
// 订单表没有物流轨迹,只能靠「有没有运单号」猜「已打单 · 未揽收」
title: (
<Tooltip title="聚水潭物流节点(状态镜像表)。已揽收及之后 = 货已经被快递拿走">
<span>物流状态</span>
</Tooltip>
),
dataIndex: 'stateLogisticStatus',
width: 108,
render: (v, row) => {
const text = v || row?.logisticStatus || '';
if (!text) return '—';
const shipped = ['已揽收', '运输中', '派送中', '已签收', '拒收'].includes(v);
return <Tag bordered={false} color={shipped ? 'green' : 'default'}>{text}</Tag>;
},
},
{
// 销售出库单状态(2026-10-29 新增)
// 🔥 业务点名「这些订单都是作废订单」后挖出来的:聚水潭的作废**落在出库单上**
// (`status='Delete'`),订单表的 labels 判据在那批单上 0 命中。
// 这一列让业务能直接对照聚水潭「销售出库单」页面,不用再问「系统里为什么没有」。
title: (
<Tooltip title="聚水潭「销售出库单」的单据状态。已作废=单据被删(不考核);待出库=已生成单据但没出库;空白=还没建出库单(正常,近八成未发单本来就没有)">
<span>销售出库单</span>
</Tooltip>
),
dataIndex: 'ioStatus',
width: 112,
render: (v) => {
const map = {
Delete: ['已作废', 'red'],
WaitConfirm: ['待出库', 'blue'],
Confirmed: ['已出库', 'green'],
OuterConfirming: ['外部确认中', 'default'],
};
const hit = map[v];
if (!hit) return '—';
return <Tag bordered={false} color={hit[1]}>{hit[0]}</Tag>;
},
},
{
title: (
@ -316,8 +382,31 @@ const EXPORT_COLUMNS = [
{ title: '发货仓', dataIndex: 'warehouseName' },
{ title: '快递公司', dataIndex: 'logisticCompany', exportValue: (v) => v || '未指定' },
{ title: '运单号', dataIndex: 'logisticId', exportValue: (v) => v || '未打单' },
{ title: '物流状态', dataIndex: 'logisticStatus' },
{ title: '物流状态', dataIndex: 'stateLogisticStatus', exportValue: (v, row) => v || row?.logisticStatus || '' },
{ title: '发货状态', dataIndex: 'state' },
// 聚水潭终态与订单表状态分开导出:两者不一致的单,就是「订单表没同步」的证据
{ title: '聚水潭状态', dataIndex: 'stateOrderStatus', exportValue: (v) => v || '—' },
// 销售出库单状态:聚水潭的作废落在这一层(Delete=单据已作废),
// 业务对账时要拿这一列跟聚水潭「销售出库单」页面对
{
title: '销售出库单',
dataIndex: 'ioStatus',
exportValue: (v) => ({
Delete: '已作废',
WaitConfirm: '待出库',
Confirmed: '已出库',
OuterConfirming: '外部确认中',
}[v] || '未建单'),
},
{ title: '状态表抓取时间', dataIndex: 'stateQueryTime', exportValue: (v) => v || '—' },
// 导出也要带上「这单的来源表 + 该表是否停更」,否则 Excel 脱离页面就没有上下文,
// 拿着 540 单「未发」去追仓库,实际人家早就发了。
{ title: '数据源', dataIndex: 'srcLabel', exportValue: (v) => v || '—' },
{
title: '数据源是否停更',
dataIndex: 'sourceStale',
exportValue: (v) => (v ? '是(该单可能已发)' : '否'),
},
{ title: '发货时间', dataIndex: 'sendTime', exportValue: (v) => v || '未发货' },
{
title: '审核时间',
@ -359,9 +448,11 @@ const roundFileText = (roundInfo) => (
* (含 7 点前审核未发出的、含今天之前审核至今未发的历史单;山东两仓 15:00、河南洛宁 13:00);
* 今天之前仍未发的(历史未发)两个轮次都算;
* **到核验时刻未发即超时**,没有「满 24 小时」门槛(业务纠偏点);
* 轮次归属和「已等时长」都按**审核时间**(状态表 last_oa_confirm_time)算 ——
* 业务 2026-10-28 下午二次定版:仓库只有审核后才会接到单,按下单时间算会把审核积压算到仓库头上;
* 审核时间取不到的单回退订单创建时间,页面上带 `*` 标记;
* 轮次归属和「已等时长」都按**审核时间**算 ——
* 业务 2026-10-28 下午三次定版:审核时间 = max(状态表 last_oa_confirm_time, 订单表 modified)。
* 只取状态表会漏 —— 状态表会滞后(9978643 状态表写的是 10-27 17:08,聚水潭真实审核 10-28 14:52,
* 整整早一天),导致「今天下午才审核的单」被算进 13:00 轮,冤枉仓库;
* 两者都没有才回退订单创建时间,页面上带 `*` 标记;
* · **13:00 之前不核验**,直接显示「未到核验时间」,不拿昨天的结果冒充今天;
* · 已出库 / 待出库以订单表 **send_date** 为准(SQL 直接 `send_date IS NULL` 才进候选);
* · 只显示超时未出库(发完的仓显示「—」),点仓库可筛右侧明细。
@ -425,6 +516,11 @@ function WarehouseShipTimeliness() {
const summary = data?.summary || {};
const round = data?.round || null;
const freshness = data?.freshness || null;
// 🔥 超时单里「所在订单表已停更」的数量(2026-10-28 定型):
// 停更⟹停更之后发出的单 send_date 仍为空⟹被判「未发」,但实际很可能已发。
// 18:00 轮实测 546 单里 540 单属于这种,必须显著提示,否则业务会以为判定写错。
const staleUnshipped = Number(summary.sourceStaleUnshipped || 0);
const staleSources = Array.isArray(data?.dataSources) ? data.dataSources.filter((s) => s && s.stale) : [];
// 13:00 之前后端返回 round=null + notStarted=true:此时**不展示任何超时数字**
const notStarted = Boolean(data?.notStarted);
const hasRound = Boolean(round);
@ -666,8 +762,9 @@ function WarehouseShipTimeliness() {
<b>到点还没发就算超时 —— 不设「满 24 小时」门槛</b>(早上 7 点前那份单,13:00 还没走就是超时)。
<b>仓级例外</b>:18:00 轮里 <b>山东青岗集仓 / 山东品牌仓</b> 只看 <b>15:00 前审核</b>的单、
<b>河南洛宁仓</b> 只看 <b>13:00 前审核</b>的单(核验时刻仍是 18:00)。
<b>轮次与「已等时长」都按审核时间算</b>(聚水潭 last_oa_confirm_time:
审核才是仓库接到单的时刻,按下单时间算会把客服审核积压算到仓库头上);
<b>轮次与「已等时长」都按审核时间算</b>(= 状态表 last_oa_confirm_time 与订单表 modified 的较晚者:
审核才是仓库接到单的时刻,按下单时间算会把客服审核积压算到仓库头上;
状态表的审核时间会滞后,所以要和订单 modified 取较晚的那个);
明细并列「审核时间 / 下单时间 / 发货时间」,方便直接和聚水潭对账。
<b>已发 / 未发以订单表 send_date 为准</b>(有值即已发,SQL 侧直接过滤不进候选);
订单表 send_date 没回写、但状态表 send_time 有值的,也按已发剔除(不漏冤仓库)。
@ -727,14 +824,44 @@ function WarehouseShipTimeliness() {
/>
) : null}
{freshness && (freshness.stale || freshness.coversDeadline === false) ? (
{(freshness && (freshness.stale || freshness.coversDeadline === false))
|| staleUnshipped > 0
|| staleSources.length > 0 ? (
<Alert
// 快照没覆盖到核验时刻 → 数字必然偏大,用红色;只是滞后用黄色
type={freshness.coversDeadline === false ? 'error' : 'warning'}
// 快照没覆盖到核验时刻 / 有单来自停更的表 → 数字必然偏大,用红色;只是滞后用黄色
type={staleUnshipped > 0 || freshness?.coversDeadline === false ? 'error' : 'warning'}
showIcon
className="wst-alert"
message={freshness.coversDeadline === false ? '数据未覆盖本轮核验时刻,超时单量偏大' : '发货数据可能滞后'}
description={freshness.hint}
message={
staleUnshipped > 0
? `${number(staleUnshipped)} 单所在订单表已停止同步,这些单很可能已经发货`
: (freshness?.voidJudgeReliable === false
// 🔥 2026-10-29:出库单/状态表停更 ⟹ 作废判据失效。
// 业务当天报「洛宁仓 16 单都是作废单」,但我们三个来源全停在作废动作之前,
// 判据再准也判不出来 —— 必须明说,别让业务以为是系统认定「没作废」。
? '出库单数据源已停止同步,作废单可能判不出来'
: (staleSources.length > 0
// 状态镜像表也算数据源:它停了,判「已取消 / 已发货」的依据就过期了
? '数据源已停止同步(订单表 / 状态镜像表)'
: (freshness?.coversDeadline === false
? '数据未覆盖本轮核验时刻,超时单量偏大'
: '发货数据可能滞后')))
}
description={(
<>
{freshness?.hint}
{staleSources.length ? (
<div className="wst-alert__sources">
{staleSources.map((s) => (
<span key={s.key} className="wst-alert__source">
{s.label}:最后同步 {String(s.lastUpdate || '').slice(11, 19) || '—'}
(已 {Math.round((s.lagMinutes || 0) / 6) / 10} 小时)
</span>
))}
</div>
) : null}
</>
)}
/>
) : null}
@ -751,6 +878,13 @@ function WarehouseShipTimeliness() {
formatter={(v) => (notStarted ? '—' : number(v))}
valueStyle={{ color: (summary.overdueUnshipped || 0) > 0 ? '#cf1322' : undefined }}
/>
{staleUnshipped > 0 ? (
<Tooltip title="这批单来自已停止同步的订单表:停更之后发出的单,在库里 send_date 还是空,会被判成「未发」。先在聚水潭核对,别直接拿去追仓库。">
<div className="wst-stat__warn">
其中 {number(staleUnshipped)} 单数据未同步
</div>
</Tooltip>
) : null}
</Card>
<Card
bordered={false}
@ -1111,11 +1245,18 @@ function WarehouseShipTimeliness() {
<b>今天 7:00 前审核</b>的订单 13:00 核验;<b>截止 16:00 前审核</b>的单 18:00 核验
(含 7 点前审核、13:00 还没发出的,也含今天之前审核至今未发的历史单)。
<b>到点仍未发货即超时</b>(不设「满 24 小时」门槛);
轮次与「已等时长」都按<b>审核时间</b>算(状态表 last_oa_confirm_time,审核才是仓库接到单的时刻;
取不到审核时间的单回退订单创建时间,列上带 <b>*</b>)。
发货 = 订单表 send_date(为空才算未发,但状态表 send_time 有值的也判已发);状态只取「发货中」。
<b>作废单不考核</b>(labels 含「发货前售后」= 客户发货前取消)
{summary.voidCount > 0 ? ` —— 本轮已自动剔除 ${summary.voidCount} 单` : ''};
轮次与「已等时长」都按<b>审核时间</b>算(= 状态表 last_oa_confirm_time 与订单表 modified 的较晚者,
审核才是仓库接到单的时刻;状态表会滞后,故取较晚者)。两者都取不到才回退订单创建时间,列上带 <b>*</b>。
发货 = 订单表 send_date(为空才算未发)。<b>已发货不考核</b>:状态表 send_time 有值、
聚水潭状态「已发货」、或物流已揽收及之后,任一成立即判已发
{summary.stateShippedSkipped > 0 ? ` —— 本轮已剔除 ${summary.stateShippedSkipped} 单` : ''}。
状态只取「发货中」。
<b>作废单不考核</b>:聚水潭状态「已取消」,或订单表 labels 含「发货前售后」
{summary.voidCount > 0
? ` —— 本轮已自动剔除 ${summary.voidCount} 单`
+ `${summary.stateVoidSkipped > 0 ? `(其中 ${summary.stateVoidSkipped} 单靠聚水潭状态判出,订单表当时没同步)` : ''}`
: ''};
⚠️ 售后状态「已作废」<b>不算</b>作废单 —— 那是售后单被撤销、订单照常发货,仍要考核。
<b>{excludedCarrierText}不考核</b>
{summary.carrierSkipped > 0 ? ` —— 本轮已剔除 ${summary.carrierSkipped} 单` : ''};
待审核、订单异常的单归入「不计考核」,避免冤枉仓库。

View File

@ -111,6 +111,45 @@
color: #1677ff;
}
/* 超时卡下面的「其中 N 单数据未同步」—— 订单表停更时的警示小字(2026-10-28) */
.wst-stat__warn {
margin-top: 6px;
font-size: 12px;
line-height: 1.4;
color: #cf1322;
cursor: help;
}
/* 停更告警里逐个源列出「最后同步时间 / 滞后多久」 */
.wst-alert__sources {
margin-top: 6px;
display: flex;
flex-wrap: wrap;
gap: 4px 16px;
}
.wst-alert__source {
font-size: 12px;
color: rgba(0, 0, 0, 0.65);
font-variant-numeric: tabular-nums;
}
/* 明细里的「内部单号 + 未同步标记」 */
.wst-detail__oid {
display: inline-flex;
align-items: center;
gap: 4px;
font-variant-numeric: tabular-nums;
}
.wst-detail__stale {
margin-inline-end: 0;
font-size: 11px;
line-height: 16px;
padding-inline: 5px;
cursor: help;
}
/* ============ 主从两栏 ============ */
.wst-body {
display: flex;