表结构与业务表字典

1. 文档目标

本文不是 application/config/tables.php 的机械复制，而是 DGJ2.0 的数据导航手册。它要回答：

1. 一个业务现象应该先查哪张主表；
2. 主表、明细表、数量过程表、库存流水、支付表怎样关联；
3. 知道 sid 后怎样算出真实分表；
4. id、iid、srcOrderId、srcOrderEntryId、billNo、srcOrderNo 分别表达什么；
5. 哪些表是业务事实、过程事实、当前结果、配置或日志；
6. 表中金额、数量、状态和软删除字段怎样解释；
7. 改一张公共表时需要回归哪些上下游。

适用场景：

• 新人理解 DGJ 的数据模型；
• 按采购单、销售单、出库单、活动单、渠道单排查；
• 核对库存、付款、报表和业务页面差异；
• 新增字段、索引、分表或迁移脚本前做影响评估；
• 编写补偿任务、数据修复 SQL 或只读巡检；
• 识别“代码常量表”和“实际运行物理表”不一致的问题。

字段说明来自当前模型查询、写入代码和 tables.php，不等同于目标环境的完整 DDL。字段类型、默认值、索引、唯一键和字符集必须用对应环境的 SHOW CREATE TABLE 或 information_schema 再确认。

2. 数据地图总览

flowchart LR
    BASE["基础资料\n商品 / 客户 / 仓库 / 货位"]
    PO["采购域\n采购主明细 / 发货 / 入库 / 退货"]
    SA["销售域\n销售主明细 / 出库 / 销退"]
    INV["库存域\n业务流水 / 实时结果 / 盘点"]
    FIN["财务域\n收付款 / 账户 / 核销"]
    ACT["活动域\n普通活动 / 赠品 / 秒杀"]
    CH["渠道域\n订单 / 售后 / 签收"]
    MOVE["移动与微仓\nE站 / 补货 / 退货 / 对账"]
    ROBOT["机器人与报价\n会话 / 规则 / 报价单"]
    SYS["系统域\n账号 / 权限 / 菜单 / 配置"]
    OUT["外部系统\n订单中心 / 支付 / OA / 配送"]
    REPORT["报表与同步\nDWD / Hologres / MQ"]

    BASE --> PO
    BASE --> SA
    BASE --> INV
    ACT --> PO
    ACT --> SA
    CH --> SA
    MOVE --> SA
    ROBOT --> SA
    PO --> INV
    SA --> INV
    PO --> FIN
    SA --> FIN
    SYS --> BASE
    OUT --> PO
    OUT --> SA
    OUT --> FIN
    PO --> REPORT
    SA --> REPORT
    INV --> REPORT
    FIN --> REPORT

2.1 五类表必须分开理解

不能只凭当前结果反推完整过程，也不能只凭一条流水断言当前结果正确。

3. tables.php 的使用边界

当前 application/config/tables.php 静态统计结果：

3.1 已发现的配置重复和别名

3.2 常量名不是实际分表名

SCM_PO_ORDER_INFO 的值是前缀 t_scm_po_order_info。真正查询时，模型会拼接：

t_scm_po_order_info_{sid % 32}

因此下面的 SQL 通常是错的：

SELECT * FROM t_scm_po_order_info WHERE billNo = 'CG...';

必须先拿到 sid，再算分片。

4. 分表规则总表

4.1 分片计算示例

假设 sid = 1017：

flowchart TD
    INPUT["输入业务单号"] --> SID{"是否已知 sid"}
    SID -->|否| MAIN["先查未分片入口表、日志或来源系统"]
    SID -->|是| TYPE{"业务对象"}
    TYPE -->|采购明细| M32["sid % 32"]
    TYPE -->|销售单| M16["sid % 16"]
    TYPE -->|销售出库| M64["sid % 64"]
    TYPE -->|库存流水| M128["sid % 128"]
    M32 --> TABLE["拼出真实物理表"]
    M16 --> TABLE
    M64 --> TABLE
    M128 --> TABLE
    TABLE --> VERIFY["查询时同时过滤 sid 与 isDelete"]

4.2 分片查询的硬规则

1. 不能在不知道 sid 时猜分表；
2. 即使已经落到正确分表，仍要带 sid 条件；
3. 主表和明细表可能使用不同分片规则；
4. 部分老代码保留未分片 oldTable，不能默认新老表同时写；
5. 跨服务站查询不能只查一个分片；
6. 数据修复必须先输出计算出的物理表名供复核；
7. 生产 SQL 不能把用户输入直接拼进表名或条件。

5. 通用关系键字典

5.1 主明细与来源关系图

erDiagram
    PO_ORDER ||--o{ PO_ORDER_INFO : "id = iid"
    PO_ORDER ||--o{ PO_INFO_QTY : "id = po_order_id"
    PO_ORDER_INFO ||--o{ PO_OUT_INFO : "id = srcOrderEntryId"
    PO_ORDER ||--o{ PU_INVOICE : "id = srcOrderId"
    PO_ORDER_INFO ||--o{ PU_INVOICE_INFO : "id = srcOrderEntryId"
    SA_ORDER ||--o{ SA_ORDER_INFO : "id = iid"
    SA_ORDER ||--o{ SA_INVOICE : "id = srcOrderId"
    SA_ORDER_INFO ||--o{ SA_INVOICE_INFO : "id = srcOrderEntryId"
    PAYMENT ||--o{ PAYMENT_INFO : "id = iid"

关系来自代码约定，不代表数据库实际存在外键约束。DGJ 老系统大量关系由应用维护，必须警惕孤儿明细。

6. 字段口径和单位

6.1 金额

6.2 数量

采购数量过程的理想守恒关系要结合业务分支验证：

原采购数量
= 待发 + 配送中 + 已入库 + 待退货 + 已完成退货 + 已关闭

代码中的退货流转会在字段间搬运数量，不能直接把所有字段无条件相加。专项公式以第 14、16 篇为准。

7. 基础资料域

7.1 商品、价格和物料关系

7.2 客户、供应商、门店

7.3 仓库与货位

erDiagram
    BS_GOODS ||--o{ BS_GOODS_STO : "商品仓配置"
    BS_GOODS ||--o{ INVENTORY_RT : "invId / skuId"
    BS_STORAGE ||--o{ BS_AREA_REL : "仓库关系"
    BS_AREA ||--o{ BS_AREA_REL : "area_id"
    BS_STORAGE ||--o{ INVENTORY_RT : "location_id"
    BS_AREA ||--o{ INVENTORY_RT : "location_area_id"
    BS_CONTACT ||--o{ BS_CONTACT_CONFIG : "contact_id"
    BS_CONTACT ||--o{ BS_CONTACT_ADDR : "contactId"
    BS_STORE ||--o{ SA_ORDER : "storeId"

8. 采购域

8.1 核心表字典

8.2 采购数据链

flowchart LR
    ORDER["采购主单\nt_scm_po_order"]
    INFO["采购明细\n32 分片"]
    QTY["数量过程\nt_scm_po_order_info_qty"]
    PAY["支付拆分\nt_scm_po_order_payinfo"]
    OUT["采购发货\n32 分片"]
    IN["采购入库主明细\n主表 + 32 分片"]
    INV["库存流水 + 实时库存"]
    CLOSE["关闭/退货/物流"]

    ORDER -->|"id=iid"| INFO
    ORDER -->|"id=po_order_id"| QTY
    ORDER --> PAY
    INFO -->|"id=srcOrderEntryId"| OUT
    INFO -->|"id=srcOrderEntryId"| IN
    OUT --> QTY
    IN --> QTY
    IN --> INV
    ORDER --> CLOSE
    CLOSE --> QTY

8.3 PoOrderInfoQtyModel 的字段搬运

9. 销售、出库和配送域

9.1 核心表字典

9.2 销售到库存和财务

flowchart LR
    SA["销售主单\n16 分片"] --> SI["销售明细\n16 分片"]
    SA --> OUT["销售出库主单\n64 分片"]
    SI --> OI["销售出库明细\n64 分片"]
    OUT --> DEL["三方配送单"]
    DEL --> REL["出库配送关系"]
    OI --> INV["库存流水\n150601/150602"]
    INV --> RT["实时库存"]
    OUT --> PI["收付款明细"]
    PI --> PM["收付款主单"]
    OUT --> SYNC["dgj_notify 下游同步"]

9.3 不能混淆的三组状态

10. 库存域

10.1 核心表字典

10.2 流水和实时库存的写入关系

sequenceDiagram
    participant B as 业务 Service
    participant I as InventorySer
    participant L as 128 分片库存流水
    participant R as 实时库存
    participant C as 动态成本/缓存/MQ

    B->>I: save(单据与商品仓位变化)
    I->>L: 插入过程流水
    I->>R: qty = qty + changeQty
    I->>C: 更新成本或发送库存事件
    Note over L,R: 两类事实都成功才表示库存链路完整

InventoryRealTimeModel::changeQty() 使用 INSERT ... ON DUPLICATE KEY UPDATE qty = qty + VALUES(qty)。这意味着目标环境必须存在能唯一定位“站点 + 商品 + 仓库 + 货位 + 区域类型”的唯一约束，否则可能产生重复结果行。唯一索引需用 DDL 实证确认。

10.3 库存方向

11. 财务域

11.1 核心表字典

11.2 一次采购支付的落表顺序

sequenceDiagram
    participant MQ as paycenter_notify
    participant C as PayCenterNotify
    participant PO as 采购/预订单
    participant PM as Payment 32分片
    participant PI as PaymentInfo 32分片
    participant AC as Account 流水
    participant PP as PoOrderPayInfo

    MQ->>C: paycenter_pay_result
    C->>PO: 校验来源和当前状态
    C->>PM: 写付款主单
    C->>PI: 写账户/来源明细
    C->>AC: 写账户变化
    C->>PP: 保存支付拆分
    C->>PO: 推进支付状态和时间

财务排查至少要同时核对五处：业务主单、付款主单、付款明细、账户流水、采购支付扩展。只存在其中一张表不能证明完整落账。

12. 活动、赠品与秒杀域

12.1 普通活动和赠品

12.2 秒杀

erDiagram
    FLASH_ACTIVITY ||--o{ FLASH_ACTIVITY_GOODS : activity_id
    FLASH_ACTIVITY ||--o{ FLASH_ACTIVITY_STATION_SCOPE : activity_id
    FLASH_ACTIVITY_GOODS ||--o{ FLASH_CART : activity_goods_id
    FLASH_ACTIVITY ||--o{ FLASH_ORDER : activity_id
    FLASH_ORDER ||--o{ FLASH_ORDER_DETAIL : order_id
    FLASH_ORDER ||--o| PO_ORDER : "采购来源关系"

秒杀库存不是 t_scm_inventory_real_time 的同义词。它至少涉及：物理可用库存、活动总量、锁定量、使用量、单站限购和购物车有效性。

13. 渠道与大客户域

flowchart LR
    EXT["DCD / FC / CZG"] --> CO["CHANNEL_ORDER"]
    CO --> CI["CHANNEL_ORDER_INFO"]
    CO --> SA["销售主明细 16 分片"]
    SA --> OUT["销售出库 64 分片"]
    OUT --> SIGN["CHANNEL_ORDER_SIGN_DETAIL"]
    CO --> AF["CHANNEL_AFTERSALE"]
    AF --> AI["CHANNEL_AFTERSALE_INFO"]
    AI --> RET["销售退货/退款"]

渠道状态使用字符串，不能按采购/销售数字枚举解释。CHS、CHR 是渠道单号前缀，180601/180602 是业务交易类型，两者也不能互换。

14. 移动商城、微仓和对账单

14.1 移动商城与微仓

14.2 新旧对账单

新旧对账表并存时不能把数据简单 UNION 后求和，必须先确认是否是迁移、双写、按日期切换还是不同业务入口。

15. 报价、机器人与 AI 域

会话表、预会话表和消息记录表不是同一生命周期。排查“机器人回复了但没有报价单”时要按“入站消息 -> 会话/预会话 -> 意图/搜索日志 -> 报价申请 -> 报价主明细 -> 销售单”逐层查。

16. 系统、权限和终端域

权限可见性通常是资源、菜单、用户、数据权限、站点版本、OPS 规则和白名单共同计算的结果，不能只改 t_sys_menu。

17. 其他仓储和专项单据索引

18. 从单号开始的查询路径

18.1 采购单号

flowchart TD
    N["采购单号 / 外部来源单号"] --> P["t_scm_po_order"]
    P --> S["取得 sid、id、状态、来源类型"]
    S --> I["采购明细 sid%32"]
    S --> Q["数量状态表"]
    S --> O["发货明细 sid%32"]
    S --> U["入库主表 + 明细 sid%32"]
    S --> F["付款 sid%32 + payinfo"]
    U --> V["库存流水 sid%128 + 实时库存"]

18.2 销售或出库单号

flowchart TD
    N["销售单 / 出库单 / 来源单号"] --> S16["销售主单 sid%16"]
    S16 --> I16["销售明细 sid%16"]
    S16 --> O64["出库主单 sid%64"]
    O64 --> I64["出库明细 sid%64"]
    O64 --> D["配送关系和三方配送单"]
    O64 --> P32["收款主明细 sid%32"]
    I64 --> V128["库存流水 sid%128"]
    V128 --> RT["实时库存"]

19. 可直接复用的只读 SQL

以下 SQL 只作为结构模板。执行前替换站点和单号，确认库名、字段名及权限；生产默认只读。

19.1 计算分片

SET @sid = 1017;
SELECT
    @sid % 16  AS sa_order_shard,
    @sid % 32  AS po_payment_shard,
    @sid % 64  AS sa_invoice_shard,
    @sid % 128 AS inventory_shard,
    @sid % 10  AS inventory_check_shard;

19.2 采购主单和明细

SET @sid = 1017;
SET @bill_no = 'CG_REPLACE_ME';

SELECT id, sid, billNo, billStatus, orderType, srcOrderType,
       srcOrderId, srcOrderNo, payment, totalQty, totalAmount,
       createTime, modifyTime, isDelete
FROM t_scm_po_order
WHERE sid = @sid AND billNo = @bill_no;

-- @sid % 32 = 25 时：
SELECT id, iid, billNo, invId, skuId, qty, price, amount,
       srcOrderEntryId, srcOrderId, srcOrderNo, isGift, isDelete
FROM t_scm_po_order_info_25
WHERE sid = @sid AND billNo = @bill_no;

19.3 采购数量过程

SELECT po_order_id, bill_no, sku_id, is_gift, qty,
       wait_out_qty, going_out_qty, sign_qty, in_qty,
       going_refund_qty, finish_refund_qty, close_qty
FROM t_scm_po_order_info_qty
WHERE po_order_id = :po_order_id;

检查负数和明显超量：

SELECT *
FROM t_scm_po_order_info_qty
WHERE po_order_id = :po_order_id
  AND (
      wait_out_qty < 0 OR going_out_qty < 0 OR in_qty < 0 OR
      going_refund_qty < 0 OR finish_refund_qty < 0 OR close_qty < 0
  );

19.4 销售与出库

-- @sid % 16 = 9
SELECT id, sid, billNo, buId, sourceType, billStatus, payType,
       srcOrderId, srcOrderNo, totalAmount, createTime, isDelete
FROM t_scm_sa_order_9
WHERE sid = @sid AND billNo = :sa_bill_no;

SELECT id, iid, billNo, invId, skuId, qty, price, amount,
       srcOrderEntryId, srcOrderId, srcOrderNo, isDelete
FROM t_scm_sa_order_info_9
WHERE sid = @sid AND iid = :sa_order_id;

-- @sid % 64 = 57
SELECT id, sid, billNo, billStatus, transType, srcOrderId,
       srcOrderNo, totalQty, totalAmount, amount, hxStateCode, isDelete
FROM t_scm_sa_invoice_0_57
WHERE sid = @sid AND (billNo = :invoice_no OR srcOrderNo = :sa_bill_no);

19.5 库存流水与实时库存

-- @sid % 128 = 121
SELECT id, sid, billNo, transType, invId, skuId,
       locationId, locationAreaId, qty, createTime, isDelete
FROM t_scm_inventory_0_121
WHERE sid = @sid
  AND skuId = :sku_id
  AND createTime >= :start_time
ORDER BY id;

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 sku_id = :sku_id
ORDER BY location_id, location_area_id, area_type;

19.6 收付款

-- @sid % 32 = 25
SELECT id, sid, billNo, billType, transType, buId,
       totalAmount, billStatus, srcOrderId, srcOrderNo,
       createTime, isDelete
FROM t_scm_payment_25
WHERE sid = @sid
  AND (billNo = :payment_no OR srcOrderNo = :source_order_no);

SELECT id, iid, sid, billNo, transType, amount, diffAmount,
       accId, wayId, stlId, stlNo, buId, isDelete
FROM t_scm_payment_info_25
WHERE sid = @sid AND iid = :payment_id;

19.7 孤儿明细巡检

-- 示例：销售主明细使用同一 16 分片。
SELECT i.id, i.iid, i.billNo
FROM t_scm_sa_order_info_9 i
LEFT JOIN t_scm_sa_order_9 o ON o.id = i.iid
WHERE i.sid = @sid
  AND i.isDelete = 0
  AND o.id IS NULL
LIMIT 100;

20. 代码检索命令

20.1 从表常量找读写方

rg -n "SCM_PO_ORDER_INFO|SCM_PO_ORDER_INFO_QTY" application
rg -n "SCM_SA_ORDER_INFO|SCM_SA_INVOICE_INFO" application
rg -n "SCM_INVENTORY_REAL_TIME|SCM_INVENTORY_SUB_NUM" application
rg -n "SCM_PAYMENT|SCM_PAYMENT_INFO|SCM_ACCOUNT" application

20.2 找动态表名

rg -n "sid.*%|%.*SUB_NUM|_0_.*sid|setSid\(" application/models application/Services application/service

20.3 找关系字段

rg -n "srcOrderId|srcOrderEntryId|srcOrderNo|sourceType|srcOrderType" application/Services application/service application/models

20.4 找写操作

rg -n "insert_batch|->insert\(|->update\(|ON DUPLICATE KEY" application/models application/Services application/service

21. 常见故障与数据表现

22. 数据修复前的安全门槛

1. 明确环境、库、sid、单号和真实分表；
2. 先保存只读查询结果和受影响行数；
3. 画出主表、明细、过程表、流水和当前结果的关系；
4. 明确哪个表是源事实，不能用结果表反向覆盖源事实；
5. 确认是否有 MQ、缓存、DWD、搜索索引和外部系统需要同步；
6. 设计幂等条件，重复执行不能重复加减数量或金额；
7. 小范围事务执行，检查影响行数；
8. 修复后按业务页面、SQL、日志和下游四层验证；
9. 保留回滚 SQL，但不要把回滚理解成无条件反向加减；
10. 将原因、SQL、验证证据沉淀到第 47 篇数据修复治理文档。

flowchart TD
    FOUND["发现数据差异"] --> READ["只读取证：主明细/流水/日志"]
    READ --> SOURCE{"确定源事实了吗"}
    SOURCE -->|否| STOP["停止写库，继续核对"]
    SOURCE -->|是| PLAN["修复方案 + 幂等 + 回滚 + 影响面"]
    PLAN --> REVIEW["双人复核表名、sid、行数"]
    REVIEW --> EXEC["事务执行"]
    EXEC --> VERIFY["业务库 + 页面 + MQ + 报表验证"]
    VERIFY --> DOC["记录证据与长期修复"]

23. 表结构变更风险矩阵

24. 回归清单

24.1 分表

• 用 sid 分别覆盖 16、32、64、128 的不同余数；
• 新增、查询、更新、软删都落到相同分片；
• 主单和明细按各自规则正确联查；
• 跨站点任务不会只处理当前登录站点；
• 旧表兼容读取不会造成重复数据。

24.2 采购

• 普通采购、退货、预订单、秒杀转采购、赠品采购；
• 待发、在途、入库、关闭、退货数量守恒；
• 采购发货和入库来源行能追到原明细；
• 在线支付拆分与采购金额一致；
• 主单、明细、数量状态和日志同步。

24.3 销售

• 销售创建、部分出库、全部出库、关闭和销退；
• 销售明细与出库明细逐行关联；
• 活动、报价和渠道来源关系不丢；
• 三方配送关系可追溯；
• 收款、核销、欠款和出库状态独立正确。

24.4 库存

• 采购入库、销售出库、销售退货、采购退货；
• 其他出入库、盘盈盘亏、站内/站间调拨；
• 流水和实时库存同事务或具备补偿；
• 普通仓位和不良品仓位分开；
• 月末归档后当前月与历史查询连续。

24.5 财务、活动和外部链路

• 付款主明细、账户、业务单金额单位一致；
• 重复支付消息不会重复落账；
• 秒杀锁量、使用、释放和采购关系完整；
• 渠道订单、签收、售后到 DGJ 单据可双向追溯；
• MQ、缓存、搜索和 DWD 不因字段变更失效。

25. 代码证据索引

26. 仍需环境确认

1. 核心表完整 SHOW CREATE TABLE，尤其字段类型、默认值和唯一索引；
2. 各环境是否都已经完成采购、销售、出库、付款和库存分表迁移；
3. oldTable 的真实读写范围及历史数据截止日期；
4. 账户表的实际分片规则和新旧月表切换方式；
5. 库存实时表的唯一键是否覆盖 area_type；
6. 盘点明细真实表名的分隔符和路由实现；
7. V2 对账单 64 分片的真实后缀规则；
8. 当前月流水转 th_* 历史表的任务、时间点和失败补偿；
9. DWD 从业务表抽取的增量键、删除同步和延迟 SLA；
10. 表结构变更是否有统一在线 DDL、灰度和回滚规范；
11. 重复常量与物理表别名是否可以安全收敛；
12. 是否存在未写入 tables.php、仅在 Model 中硬编码的生产业务表。

这些环境证据确认后，应把 DDL 摘要、索引和实际路由回填本文；本文不会把静态代码推断伪装成生产数据库事实。

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

多入口请求链路

日志证据矩阵

环节数据变更台账

子模块级独立追踪

子模块追踪：base-tables 基础资料域表

子模块追踪：purchase-tables 采购域表

子模块追踪：sale-tables 销售与出库域表

子模块追踪：inventory-tables 库存域表与分片

子模块追踪：finance-tables 财务域表

子模块追踪：activity-tables 活动与秒杀域表

子模块追踪：channel-tables 渠道与大客户域表

子模块追踪：move-tables 移动商城、微仓与对账域表

子模块追踪：system-tables 系统、权限、机器人与专项表