库存一致性排查手册

本手册用于处理“页面有库存但下单/出库失败”“业务单完成但库存未变”“库存流水与实时库存不一致”“盘点和报表库存不一致”等问题。

库存不是一个数字，而是一组带站点、商品、仓库、货位、货位类型、时间和业务来源的事实。排查时必须同时看业务单、128 分片库存流水、实时库存单表、历史归档、盘点差异、缓存/索引和预警；任何只改单表的修复都可能让另一个视图继续错误。

1. 业务目标

• 从 sid + invId/skuId + 仓库 + 货位 找到该库存维度的完整事实。
• 明确业务单、库存流水和实时库存之间的写入顺序与事务边界。
• 区分库存过程事实、当前结果、查询缓存、预警结果和报表快照。
• 用数量方向和 transType 判断每条流水应增加还是减少库存。
• 识别分表错误、重复写入、漏写流水、漏改实时库存、归档漏查和维度串仓。
• 解释负库存是否被允许，以及为什么快准商品与第三方商品走不同分支。
• 修复前保存可回滚证据，修复后完成业务、流水、实时、缓存、报表五层验收。

2. 先建立库存事实模型

flowchart LR
    DOC["业务单据"] --> LEDGER["库存流水\n过程事实"]
    DOC --> RT["实时库存\n当前结果"]
    LEDGER --> ARCHIVE["历史归档"]
    RT --> QUERY["列表/可售查询"]
    LEDGER --> REPORT["报表/成本"]
    RT --> WARN["库存预警"]
    RT --> CACHE["ES/缓存展示"]
    DOC --> CHECK["盘点单"]
    CHECK --> LEDGER
    CHECK --> RT

2.1 五类数据的职责

2.2 不能用一个数字代替全部口径

同一 invId 可能同时存在：

• 多个仓库 location_id。
• 多个货位 location_area_id。
• 普通品、不良品、微仓、微仓退货等 area_type。
• 快准中心商品和服务站自建第三方商品。
• 正常库存、业务锁定量、活动锁定量和在途量。
• 当前月流水与历史归档流水。

3. 适用现象与首查方向

4. 排查前事实卡

环境：
异常时间范围：
sid：
invId：
skuId / 商品编码：
商品归属 sid（快准中心=1 或服务站自建）：
仓库 locationId：
货位 locationAreaId：
area_type：
业务单类型/单号/主键：
transType：
页面展示库存：
交易校验库存：
预期变化量：
实际实时变化量：
是否涉及锁定量/在途量/活动量：
是否跨月：

缺少 sid、invId、仓库或时间点时，不要直接开始修数据。

5. 三套分表规则必须分开

5.1 库存流水：128 分片

库存流水物理表 = t_scm_inventory_0_{sid % 128}

InventorySubModel::setSid() 和 getInventorySubTable() 已确认使用这一规则。

5.2 实时库存：当前为单表

t_scm_inventory_real_time

InventoryRealTimeModel 所有读写直接使用 SCM_INVENTORY_REAL_TIME，当前代码没有追加 sid % 128。sid 是表内租户字段，不是表名后缀。

5.3 盘点明细：10 分片

盘点明细物理表 = t_scm_inventory_check_info{sid 最后一位}

代码既有 sid % 10，也有 substr($sid, -1)，结果等价。

5.4 表定位字典

flowchart TB
    SID["sid"] --> M128["sid % 128"]
    SID --> M10["sid % 10"]
    SID --> COL["单表 sid 字段"]
    M128 --> LEDGER["inventory_0_n"]
    M10 --> CHECK["inventory_check_infon"]
    COL --> RT["inventory_real_time"]
    COL --> WARN["inventory_warning"]

5.5 常见误查

• 对实时库存追加 _0_{sid%128}，得到不存在或错误表。
• 只查旧 t_scm_inventory，漏掉新 128 分片流水。
• 跨月只查当前分片，不查历史归档。
• 盘点明细写成下划线后缀，实际常量直接拼个位数。
• 用 skuId 查流水但业务记录只稳定保存 invId，或反过来。

6. 核心入口、Service 和模型

rg -n "function save|function changeInventoryQty|function delete" application/Services/Storage/InventorySer.php
rg -n "increaseQty|decrementQty|FOR UPDATE" application/models/bs/InventoryRealTimeModel.php
rg -n "SCM_INVENTORY.'_0_'|SCM_INVENTORY_SUB_NUM" application/models/bs/InventorySubModel.php application/config/tables.php

7. 库存写入真实顺序

7.1 InventorySer::save()

对每一行库存变化，代码按以下顺序执行：

1. 如果传入旧业务单 iid，先调用 delete(iid, billType) 反向恢复旧流水。
2. 构建新的库存流水数组。
3. qty != 0 时调用 changeInventoryQty() 修改实时库存。
4. 所有行处理完成后，批量写入 128 分片库存流水。
5. 旧 InventoryModel->save() 已被注释，当前写新分片。

sequenceDiagram
    participant B as 业务Service
    participant I as InventorySer
    participant R as 实时库存单表
    participant L as 128分片流水
    B->>I: save(inventory, iid, billType)
    alt 编辑旧单
        I->>L: 查旧有效流水
        I->>R: 按 -old.qty 反向恢复
        I->>L: 旧流水 isDelete=1
    end
    loop 每一行
        I->>R: changeInventoryQty(qty)
    end
    I->>L: insert_batch 新流水

7.2 事务风险

InventorySer::save() 本身没有显式开启事务，依赖外层业务 Service 的事务。如果外层没有事务：

• 实时库存可能已逐行修改。
• 最后的流水批量插入可能失败。
• 多行处理中间失败时，前几行可能已生效。

所以排查“实时变了但流水没有”时，要确认调用方是否在同一个数据库连接和事务中调用。

7.3 删除/编辑的反向语义

InventorySer::delete()：

查旧有效流水 -> 对每行执行 0 - old.qty -> 旧流水软删

例如旧销售出库 qty = -2，删除时变化量为 +2，实时库存恢复；旧采购入库 qty = +5，删除时变化量为 -5。

8. 实时库存并发模型

8.1 增加库存

increaseQty()：

1. 按 sid + invId + locationId + locationAreaId 执行 SELECT ... FOR UPDATE。
2. 已有行则 qty = qty + change。
3. 无行则插入新记录，包含 skuId 和 areaType。

8.2 扣减库存

decrementQty() 同样先 FOR UPDATE，然后根据 minus 参数选择：

-- minus = true：允许扣成负数
update ... set qty = qty - :qty where id = :id;

-- minus = false：不允许负数
update ... set qty = qty - :qty where id = :id and qty >= :qty;

受影响行数小于等于 0 时，库存 Service 抛出“库存不足，出库失败”。

8.3 首次并发插入风险

两个事务同时发现该维度不存在时，都可能尝试插入。是否能防止重复行依赖线上唯一索引。建议唯一键至少覆盖：

sid + inv_id + location_id + location_area_id

sku_id/area_type 是否属于唯一键需以生产 DDL 和业务维度确认。

flowchart TD
    A["库存变化"] --> Q["FOR UPDATE 查精确维度"]
    Q --> E{"记录存在?"}
    E -->|是| U["加/减 qty"]
    E -->|否且增加| I["INSERT 新行"]
    E -->|否且扣减| F["返回失败"]
    U --> R{"扣减且禁止负库存?"}
    R -->|是| C["WHERE qty >= change"]
    R -->|否| N["允许负数"]

9. 负库存控制分支

9.1 先区分商品归属

GoodsModel->getGoodsBaseByInvId(invId) 返回商品归属站点：

• good.sid == 1：快准中心商品。
• 其他：服务站自建第三方商品。

9.2 当前静态代码分支

配置方法名与 minus 的最终效果容易凭直觉读反，排查时应以实际传参和 SQL 条件为准。

9.3 负库存不一定是脏数据

先确认：

• 商品属于快准还是第三方。
• 当前站点是否在对应控制名单。
• 负数来自正常业务扣减、盘亏、货位调整还是历史修复。
• 页面是否聚合了其他正库存货位。
• 业务是否允许暂时负库存后再入库冲回。

10. 库存维度与查询口径

10.1 精确维度

sid + inv_id + location_id + location_area_id

这是实时更新行锁使用的维度。

10.2 常见聚合层级

10.3 已确认查询差异

• getInventoryByStoreId(..., isNotBadArea=true) 增加 area_type = 0。
• getStorageQty() 只包含普通、微仓、微仓退货三类货位。
• getQtyByInvIdsWithSid(..., isBad=false) 会查不良品货位 ID 并排除。
• 有些列表只判断任一行 qty > 0，有些按 sum(qty) > 0。

flowchart LR
    ROW["实时库存行"] --> EXACT["精确货位库存"]
    ROW --> STORAGE["仓库聚合"]
    ROW --> GOODS["商品聚合"]
    STORAGE --> SALEABLE["减锁定/排除不良品"]
    GOODS --> DISPLAY["ES/列表展示"]
    SALEABLE --> TRADE["加购/出库校验"]

“列表有库存、交易失败”的本质通常是 DISPLAY 与 TRADE 使用了不同聚合条件。

11. 交易类型与数量方向

11.1 增加库存

11.2 减少库存

11.3 编码冲突

170502 同时出现在销售订单和货位调整入注释中。仅凭 transType 无法唯一解释业务，必须联合：

billType + transType + billNo/iid + 来源表

12. 一单到底排查流程

flowchart TD
    A["拿到业务单号"] --> B["确认 sid/invId/仓库货位"]
    B --> C["查业务主明细是否成功"]
    C --> D["计算 sid%128 查库存流水"]
    D --> E{"流水存在且方向正确?"}
    E -->|否| E1["业务到库存Service断点"]
    E -->|是| F["查实时库存精确维度"]
    F --> G{"变化量一致?"}
    G -->|否| G1["事务/重复/漏更新"]
    G -->|是| H["查缓存和交易查询口径"]
    H --> I["查预警/报表/下游"]

12.1 业务单据

先证明业务动作是否真的提交：

• 采购入库：采购入库主明细和原采购/出库数量。
• 销售出库：64 分片 150601 主明细，状态小于 6。
• 销售退货：64 分片 150602 主明细。
• 采购退货：采购退货单和出库事实。
• 调拨：调出、调入两端和运输状态。
• 盘点：盘点主单、10 分片明细、盘盈/盘亏流水。
• 套包：主物料和子物料必须成对变化。

12.2 库存流水

-- :inv_suffix = sid % 128
select id, iid, sid, billNo, billType, transType, transTypeName,
       invId, skuId, locationId, locationAreaId,
       qty, price, amount, createTime, isDelete
from t_scm_inventory_0_:inv_suffix
where sid = :sid
  and (billNo = :bill_no or iid = :business_id)
order by createTime, id;

12.3 实时库存

select id, sid, inv_id, sku_id, location_id, location_area_id,
       area_type, qty
from t_scm_inventory_real_time
where sid = :sid and inv_id = :inv_id
order by location_id, location_area_id, id;

12.4 精确比较

对于一次业务变化：

期望实时变化量 = 同维度本次有效库存流水 qty 之和

不要直接用“当前实时库存 = 当前月流水总和”，因为还存在期初、历史归档和跨月余额。

13. 跨月与历史归档

13.1 正确守恒式

在某一时间截面：

当前库存
= 期初/历史结转
+ 历史有效入出库流水
+ 当期有效入出库流水

13.2 跨月误差来源

• 只查 t_scm_inventory_0_n 当前活跃数据，漏历史归档。
• 归档过程中重复复制或漏复制。
• 归档后旧表数据未按相同 isDelete 口径处理。
• 报表按业务日期，实时库存按实际提交时间。
• 跨月撤销业务单，反向流水落当前月但原流水在历史表。

13.3 安全对账方式

优先选择一个已知正确的期初截面，再累计之后所有有效变化；不要在不知道归档策略时直接全量 sum(qty)。

14. 流水与实时不一致分类

flowchart TD
    A["发现差异"] --> B{"业务单真实吗?"}
    B -->|否| C["处理业务单/反向业务"]
    B -->|是| D{"流水正确?"}
    D -->|否| E["补/撤销流水"]
    D -->|是| F{"实时正确?"}
    F -->|否| G["按有效流水重建精确维度"]
    F -->|是| H{"页面/报表仍错?"}
    H -->|页面| I["刷新缓存/索引"]
    H -->|报表| J["查同步/归档口径"]

15. 删除、编辑和重复操作

15.1 编辑库存业务

正确语义通常是：

反向旧流水 -> 软删旧流水 -> 应用新数量 -> 写新流水

InventorySer::save($inventory, $iid, $billType) 会在 iid 非空时先删除旧库存事实。

15.2 billType/transType 匹配风险

删除查旧流水使用：

iid + billType + 可选 transType + isDelete=0

任一字段与原保存值不一致都会查不到旧流水，导致编辑时新库存叠加到旧库存之上。

15.3 重复提交检查

select iid, billType, transType, invId, locationId, locationAreaId,
       qty, count(*) as cnt
from t_scm_inventory_0_:inv_suffix
where sid = :sid and isDelete = 0
group by iid, billType, transType, invId, locationId, locationAreaId, qty
having count(*) > 1;

多行同维度可能是合法拆行，必须结合业务明细 ID、时间和单号判断，不能见 cnt > 1 就删除。

16. 盘点一致性

16.1 盘点数据链

sequenceDiagram
    participant P as PDA/GPDA
    participant C as 盘点主单
    participant D as 10分片盘点明细
    participant I as 库存Service
    participant R as 实时库存
    P->>C: 创建盘点批次
    P->>D: 保存 sysQty/checkQty
    D->>D: diff = checkQty - sysQty
    alt diff > 0
        D->>I: 盘盈 150701
    else diff < 0
        D->>I: 盘亏 150801
    end
    I->>R: 应用差异

16.2 盘点排查

1. 查盘点主单状态、盘点时间和仓库范围。
2. 计算 sid 个位数，查正确盘点明细表。
3. 对比 sysQty、checkQty 和 diff。
4. 查差异是否生成盘盈/盘亏业务事实。
5. 查 128 分片流水是否有对应正/负数量。
6. 查实时库存是否应用差异。
7. 确认盘点期间是否仍允许其他出入库，避免时间截面漂移。

16.3 盘点 SQL

select *
from t_scm_inventory_check
where sid = :sid and id = :check_id;

select PDDId, sid, invId, skuId, locationId, locationAreaId,
       sysQty, checkQty, checkQty - sysQty as diff, checkType
from t_scm_inventory_check_info:check_suffix
where sid = :sid and PDDId = :check_id
order by invId, locationAreaId;

17. 套包、拆包和组包

17.1 数量方向

17.2 守恒检查

套包不一定是简单 1:1，需要按 BOM 数量：

成品变化量 * BOM单位用量 = 每个子件应变化量

金额和成本也可能按不同规则分摊，数量正确不代表成本正确。

flowchart LR
    P["成品包"] -->|"拆包 -1"| OUT["191101"]
    OUT -->|"BOM比例 +N"| C["子件 191102"]
    C -->|"组包 -N"| IN["191201"]
    IN -->|"+1"| P2["成品 191202"]

18. 货位调整和调拨

18.1 货位调整

同一商品总库存理论上不变：

原货位 170501 负数量 + 新货位 170502 正数量 = 0

InventorySer 不为这两类交易写最近出入库 Redis 时间，避免把内部搬位误算成真实进销。

18.2 站内/站间调拨

• 调出端减少库存。
• 调入端在确认入库后增加库存。
• 在途期间两端实时库存之和可能暂时减少，需联合调拨状态理解。
• 撤销调出要反向恢复原仓货位。
• 站间调拨还涉及两个 sid，不能在一个站点维度内强行守恒。

19. 库存预警不是实时库存

19.1 inventory_event 用途

库存业务完成后，多个 Service 调用 MqSer::sendInventoryEvent()，消息包含：

{
  "inventoryData": [{"invId": 30001}],
  "iid": 0,
  "billType": "",
  "transType": null,
  "sid": 10001,
  "po_order_id": 0
}

该消息消费方不会再次修改实时库存，主要用于确定受影响商品并重算库存预警。

19.2 受影响商品来源

• inventoryData[*].invId。
• 删除业务单时，从已软删 128 分片流水按 iid/billType/transType 找 invId。
• 采购在途变化时，从采购明细按 po_order_id 找 invId。

19.3 预警公式

warning_num = 实时可用库存 qty + 在途 waitQty - 下限 lowQty
suggest_num = 上限 highQty - 实时可用库存 qty - 在途 waitQty

页面将 warning_num < 0 视为需要预警。

flowchart LR
    EVENT["inventory_event"] --> IDS["收集 invIds"]
    IDS --> EXT["读取 highQty/lowQty"]
    EXT --> STATUS["仅正常/暂供商品"]
    STATUS --> RT["实时库存\n排除不良品"]
    STATUS --> WAY["采购在途 waitQty"]
    RT --> CALC["warning/suggest"]
    WAY --> CALC
    CALC --> UPSERT["inventory_warning"]

19.4 预警异常

20. Redis、ES 与页面库存

20.1 最近出入库时间

每次非货位调整库存变化后，InventorySer 更新 Redis Hash：

key: GOODS_INVENTORY_CHANGE_TIME + sid
field: invId
value: {"in":"时间", "out":"时间"}

它是时间辅助信息，不保存库存数量，不应拿来修复实时库存。

20.2 ES/物料缓存

• 商品列表可能走 MaterielCacheStationEsSer。
• 销售出库后会异步/容错更新近期销售数量字段。
• ES 更新失败只记录日志，不一定回滚业务出库。
• 列表中的库存或销售量可能短暂滞后。

20.3 判断原则

交易校验：以业务库实时库存和业务规则为准。
页面展示：可能来自聚合、缓存或索引。
缓存错误：重建缓存，不改业务库存。

21. 常用只读 SQL

21.1 实时库存精确维度

select id, sid, inv_id, sku_id, location_id, location_area_id,
       area_type, qty
from t_scm_inventory_real_time
where sid = :sid
  and inv_id = :inv_id
  and location_id = :location_id
  and location_area_id = :location_area_id;

21.2 商品全仓汇总

select inv_id, sum(qty) as total_qty,
       sum(case when area_type = 0 then qty else 0 end) as normal_qty
from t_scm_inventory_real_time
where sid = :sid and inv_id in (:inv_ids)
group by inv_id;

21.3 重复实时行

select sid, inv_id, location_id, location_area_id,
       count(*) as cnt, sum(qty) as qty_sum
from t_scm_inventory_real_time
group by sid, inv_id, location_id, location_area_id
having count(*) > 1;

21.4 业务单流水

select iid, billNo, billType, transType, invId, skuId,
       locationId, locationAreaId, qty, amount, createTime, isDelete
from t_scm_inventory_0_:inv_suffix
where sid = :sid and (iid = :iid or billNo = :bill_no)
order by createTime, id;

21.5 软删前后

select iid, billType, transType, invId, locationId, locationAreaId,
       isDelete, sum(qty) as qty
from t_scm_inventory_0_:inv_suffix
where sid = :sid and iid = :iid
group by iid, billType, transType, invId, locationId, locationAreaId, isDelete;

21.6 预警

select sid, inv_id, sku_id, warning_num, suggest_num
from t_scm_inventory_warning
where sid = :sid and inv_id in (:inv_ids);

22. 按现象执行的 SOP

22.1 列表有库存但出库失败

1. 确认列表使用 skuId 还是 invId。
2. 查列表展示值来自 ES、实时表还是聚合接口。
3. 查交易使用的具体仓库和货位。
4. 排除不良品/特殊货位。
5. 减去锁定量、活动量或其他占用。
6. 确认站点负库存分支。
7. 查请求时间是否有并发扣减。

22.2 入库成功但实时库存未增加

1. 查业务入库主明细已提交。
2. 查 128 分片是否有正数量流水。
3. 查实时精确货位行。
4. 查业务 Service 是否调用 InventorySer。
5. 查事务是否回滚或用了不同连接。
6. 查是否入到另一仓库/货位。

22.3 流水有、实时少

1. 按精确维度汇总异常时间段流水。
2. 找一个可信期初截面。
3. 排除软删流水。
4. 查重复反向删除或重复扣减。
5. 查实时表重复行和唯一索引。
6. 评审按有效流水重建该维度。

22.4 实时有、流水少

1. 查旧库存表和历史归档。
2. 查期初库存 180001。
3. 查是否手工/脚本直接改实时表。
4. 查 InventorySer::save() 批量流水插入异常。
5. 查调用方有无外层事务。
6. 根据真实业务决定补流水或反向恢复实时。

22.5 删除业务单后数量不对

1. 查原流水的 iid/billType/transType。
2. 查旧流水是否 isDelete=1。
3. 查反向变化是否作用于同仓同货位。
4. 查删除调用传入的 billType 是否一致。
5. 查业务单是否其实不允许删除而应撤销。

22.6 报表与实时不一致

1. 固定同一截止时间。
2. 确认报表按业务日期还是创建时间。
3. 查当前流水和历史归档是否都进入。
4. 查 DWD/Hologres 同步时间和失败任务。
5. 确认报表是否排除不良品、撤销和软删。
6. 分开数量差异和成本金额差异。

23. 修复决策

flowchart TD
    A["库存差异"] --> B["保存业务单/流水/实时快照"]
    B --> C{"业务单是否真实?"}
    C -->|否| D["撤销/反向业务单"]
    C -->|是| E{"流水是否完整?"}
    E -->|否| F["通过领域接口补业务流水"]
    E -->|是| G{"实时是否等于可信截面+流水?"}
    G -->|否| H["单维度重建实时结果"]
    G -->|是| I["刷新缓存/预警/报表"]
    D --> J["五层验收"]
    F --> J
    H --> J
    I --> J

23.1 修复优先级

1. 原业务撤销、退货、反向入出库。
2. 已有 InventorySer 领域接口。
3. 单业务单、单商品、单货位补偿脚本。
4. 只在确认过程事实完整时重建实时库存。
5. 最后才直接 SQL，必须带断言、备份、行数和回滚。

23.2 不应做

• 只把实时库存改成页面期望值。
• 删除原库存流水。
• 用缓存值覆盖业务库。
• 忽略历史归档直接汇总当月。
• 把所有负库存都归零。
• 不区分仓库货位按 invId 全站修改。

24. 修复后五层验收

24.1 业务层

• [ ] 原业务单状态和数量正确。
• [ ] 撤销/反向业务有审计记录。
• [ ] 不会再次被定时任务重放。

24.2 流水层

• [ ] 128 分片流水完整。
• [ ] 正负方向与 transType 一致。
• [ ] 旧流水软删和新流水关系清楚。
• [ ] 无无法解释的重复行。

24.3 实时层

• [ ] 精确仓库货位数量正确。
• [ ] 商品/仓库聚合结果正确。
• [ ] 不良品和特殊货位口径正确。
• [ ] 并发出库仍受负库存规则保护。

24.4 派生层

• [ ] inventory_event 重算预警。
• [ ] ES/物料缓存刷新。
• [ ] 最近出入库时间符合业务。
• [ ] 报表在同步后与口径一致。

24.5 回归层

• [ ] 同商品再次采购入库。
• [ ] 同商品再次销售出库。
• [ ] 销退/采退、盘点和调拨。
• [ ] 套包拆组和活动库存。

25. 完整回归矩阵

25.1 正向库存

• [ ] 快准采购入库。
• [ ] 第三方商品入库。
• [ ] 销售退货入库。
• [ ] 其他入库、盘盈、期初。
• [ ] 调拨入库、货位调整入。

25.2 负向库存

• [ ] 普通销售出库。
• [ ] 采购退货出库。
• [ ] 其他出库、盘亏。
• [ ] 调拨出库、货位调整出。
• [ ] 快准/第三方不同负库存配置。

25.3 编辑撤销

• [ ] 编辑业务单先反向旧流水再写新流水。
• [ ] 删除/撤销恢复实时库存。
• [ ] 重复请求幂等。
• [ ] 中间异常同事务回滚。

25.4 特殊场景

• [ ] 普通品和不良品。
• [ ] 多仓库、多货位、微仓。
• [ ] 套包拆包/组包守恒。
• [ ] 盘点期间并发出入库。
• [ ] 跨月撤销和历史归档。
• [ ] 秒杀指定仓、锁定量和已用量。

26. 监控建议

27. 已确认与待确认

27.1 静态代码已确认

• 新库存流水表按 t_scm_inventory_0_{sid%128}。
• 实时库存当前是单表 t_scm_inventory_real_time。
• 盘点明细按 sid 个位数 10 分片。
• InventorySer::save() 先逐行改实时库存，再批量写流水。
• InventorySer 自身不显式开事务，依赖调用方外层事务。
• 编辑/删除通过反向旧流水数量恢复实时库存，并软删旧流水。
• 实时库存增加和扣减都先按精确维度 FOR UPDATE。
• minus=true 允许负数，minus=false 使用 qty >= change 限制。
• 快准商品和第三方商品的负库存配置分支不同。
• 非货位调整会在 Redis 记录最近入/出库时间。
• inventory_event 重算库存预警，不直接修改实时库存。
• 预警公式包含实时库存、采购在途和上下限。
• 当前旧库存表保存调用已注释，新流水是主写路径。

27.2 环境待确认

• 实时库存线上唯一索引定义。
• 128 分片建表完整性、索引和数据量分布。
• 当月流水到 th_scm_inventory 的归档任务、时间和幂等。
• 历史旧表与新分片的迁移/双写边界。
• 各业务入口是否都使用同一数据库连接和外层事务。
• 快准/第三方负库存配置的业务命名和当前站点名单。
• ES/Mongo/Redis 库存字段刷新 SLA。
• inventory_event 的 binding、重试、死信和积压监控。
• 盘点期间是否冻结出入库及时间截面算法。
• 报表从业务库、历史表还是 DWD/Hologres 取数。

28. 证据来源

29. 一页式执行结论

先固定 sid、invId、仓库、货位和时间截面。
库存流水查 t_scm_inventory_0_{sid%128}；实时库存查单表；盘点明细查 sid 个位数分片。
先证明业务单，再看流水，最后验证实时结果；缓存和报表是派生层。
正数增加、负数减少，但 transType 170502 有语义冲突，必须联合 billType。
列表库存与交易库存可能因仓库、货位、不良品、锁定量不同而不同。
实时先改、流水后批量插入，外层事务缺失会产生部分成功风险。
负库存是否允许要按商品归属和站点配置分支判断。
修复优先做反向业务或领域补偿，不能只改实时库存。
修复后验收业务、流水、实时、缓存预警和报表。

请求-日志-数据变更追踪卡

多入口请求链路

日志证据矩阵

| 链路段 | 日志来源 | 可检索锚点 | 成功信号 | 失败信号 | 与下一段关联方式 | | --- | --- | --- | --- | --- | --- | --- | | 调用方 | 采购/销售/盘点 Service 日志 | request_id、业务单、SKU、transType | 调用 InventorySer 且业务 commit | 业务失败但库存有变、参数方向错误 | 单号查库存主单 | | 流水写入 | InventorySer/InventorySubModel | 库存主单、业务单、分片键 | 主单和全部明细 insert | 分片漏写、批量插入部分失败 | 主单 PK 查分片明细 | | 实时更新 | InventoryRealTimeModel | 四维键、影响行数、deadlock | qty 按符号改变 | update 0、重复扣加、负库存限制 | 四维键与流水净额对账 | | MQ/缓存预警 | MqSer/Cache/Warning | 业务单、routing key、库存键 | 消费 ACK，缓存/预警追平 | DB 正确但派生层旧 | 同一库存键比较数据时间 |

环节数据变更台账

子模块追踪：inventory-write-check 库存写入与实时量排查

子模块追踪：inventory-negative-check 负库存控制排查

子模块追踪：inventory-archive-check 分片、跨月与历史归档排查

子模块追踪：inventory-repeat-check 删除、编辑与重复操作排查

子模块追踪：inventory-stocktake-check 盘点一致性排查

子模块追踪：inventory-package-check 套包、拆包与组包排查

子模块追踪：inventory-transfer-check 货位调整与调拨排查

子模块追踪：inventory-warning-check 库存预警排查

子模块追踪：inventory-cache-check Redis、ES 与页面库存排查