4. 数据源梳理：ERP、WMS、TMS、IoT 与外部 API

通知链路的起点是数据。供应链控制塔需要从多个异构系统实时或准实时地采集事件数据，才能驱动后续的规则判断与通知分发。本章对五大类核心数据源进行结构化梳理，明确每类数据源的关键事件、采集方式与数据质量要求。

4.1 数据源全景概览

下表从系统定位、典型事件、数据格式与采集频率四个维度，对五大数据源进行横向对比：

4.2 ERP 数据源

ERP 是供应链控制塔的“主脑”，提供订单主数据、库存状态与财务凭证。关键事件包括：

• 订单创建/变更： 触发“订单确认”通知，包含客户、物料、数量、交期。
• 发货过账（GI）： 触发“已发货”通知，包含物流单号、承运商。
• 库存转移： 触发“库存调拨”通知，用于内部补货场景。
• 发票核销： 触发“财务对账”通知，用于 B2B 客户。

ERP 数据采集通常采用 IDoc（Intermediate Document） 或 RFC（Remote Function Call） 接口。以下是一个简化的 IDoc 监听配置示例：

// 基于 SAP PI/PO 的 IDoc 监听配置片段
{
  "idocType": "ORDERS05",
  "messageType": "ORDER",
  "receiverPort": "CONTROL_TOWER_HTTP",
  "filter": {
    "segment": "E1EDK01",
    "field": "BSART",
    "value": "ZOR"  // 标准销售订单
  },
  "callbackUrl": "https://ctower.example.com/api/v1/events/erp"
}

4.3 WMS 数据源

WMS 提供仓库作业的实时状态，是“已拣货”、“已打包”、“已装车”等通知的源头。核心事件：

• 收货确认： 触发“入库完成”通知，用于采购方。
• 拣货完成： 触发“准备发货”通知，用于内部运营。
• 装车扫描： 触发“已发运”通知，包含实际发运时间。
• 库存调整： 触发“库存差异”告警，用于异常处理。

WMS 数据通常通过 消息队列 或 Webhook 推送至控制塔。以下是一个 WMS 出库事件的 JSON 示例：

{
  "eventType": "PICKING_COMPLETE",
  "timestamp": "2025-03-21T14:30:00Z",
  "warehouse": "WH-SH-01",
  "orderId": "SO-20250321-001",
  "items": [
    {
      "sku": "SKU-A100",
      "qty": 50,
      "location": "A-12-03"
    }
  ],
  "carrier": "SF_EXPRESS",
  "trackingNo": "SF1234567890"
}

4.4 TMS 数据源

TMS 管理运输执行过程，提供在途可见性。关键事件：

• 发车事件： 触发“运输开始”通知。
• 到达事件： 触发“已到达/目的地”通知。
• 异常停留： 触发“运输延迟”告警。
• 电子围栏进出： 触发“车辆接近”通知，用于预约收货。

TMS 数据采集建议采用 轮询 + Webhook 双通道 模式，确保数据不丢失。

4.5 IoT 设备数据源

IoT 设备提供物理世界的实时感知数据，是冷链、危险品等场景的必备数据源。典型设备与事件：

IoT 数据通常通过 MQTT Broker 接入控制塔，数据格式为轻量级 JSON 或二进制 Protobuf。

4.6 外部 API 数据源

外部 API 为控制塔提供环境上下文，增强通知的预见性。常见外部数据源：

• 天气 API： 获取台风、暴雨、暴雪预警，触发“运输风险”通知。
• 交通 API： 获取实时路况与拥堵指数，触发“预计延迟”通知。
• 海关 API： 获取清关状态（放行/查验），触发“清关完成”通知。
• 供应商 API： 获取供应商发货确认与 ASN，触发“采购在途”通知。

4.7 数据源集成架构

下图展示了控制塔与五大数据源之间的逻辑集成关系，以及事件数据在通知链路中的流转路径：

4.8 数据质量与治理要点

数据源接入后，必须建立数据质量监控机制，否则通知链路将产生大量误报或漏报。关键治理指标：