4、数据源接入设计：ERP、WMS、TMS、IoT设备、外部天气/交通API的数据接入规范

供应链控制塔的异常检测能力高度依赖多源异构数据的实时融合。数据源接入规范定义了各系统（ERP、WMS、TMS、IoT设备、外部API）的数据模型、传输协议、频率与质量要求，是构建统一事件层的基础。

4.1 数据源分类与接入协议矩阵

不同数据源在实时性、数据量和安全等级上差异显著，需采用差异化的接入策略。下表汇总了五大类数据源的推荐协议与接入方式：

4.2 数据接入架构与事件流设计

控制塔采用“统一接入层 + 事件总线 + 主题路由”的架构，确保各数据源能够独立扩展、故障隔离。下图展示了数据从源系统到异常检测引擎的完整流动路径：

4.3 各数据源接入规范详解

4.3.1 ERP数据接入规范

ERP系统承载订单、采购单、库存、财务等核心主数据与事务数据。接入规范如下：

• 接入对象：销售订单、采购订单、库存台账、物料主数据。
• 同步策略：首次全量同步后，采用CDC（Debezium + Kafka Connect）捕获增量变更。
• 关键字段：订单号、物料编码、数量、单价、交货日期、状态、最后更新时间。
• 异常检测关注点：订单延迟确认、库存负值、价格异常波动。

// ERP订单事件标准JSON格式示例
{
  "eventType": "ORDER_CREATED",
  "source": "ERP_SAP",
  "timestamp": "2025-03-20T14:30:00Z",
  "payload": {
    "orderId": "SO-20250320-001",
    "materialCode": "MAT-8801",
    "quantity": 500,
    "unit": "pcs",
    "deliveryDate": "2025-03-25",
    "status": "NEW"
  }
}

4.3.2 WMS数据接入规范

WMS提供仓库内实时作业数据，包括收货、上架、拣货、发货、库存移动等事件。

• 接入对象：入库单、出库单、库存快照、库位状态。
• 同步策略：事件驱动推送，WMS每完成一个作业步骤即向控制塔发送事件。
• 关键字段：仓库编码、库位、SKU、批次号、作业类型、操作时间。
• 异常检测关注点：拣货效率下降、库存差异、库位占用异常。

4.3.3 TMS数据接入规范

TMS管理运输计划、在途状态、签收信息等物流数据。

• 接入对象：运输订单、运单状态、GPS轨迹、预计到达时间（ETA）。
• 同步策略：批量同步运输计划，实时推送运单状态变更与GPS坐标。
• 关键字段：运单号、承运商、车牌号、出发地、目的地、当前状态、经纬度。
• 异常检测关注点：运输延迟、路线偏离、长时间停留。

4.3.4 IoT设备数据接入规范

IoT设备包括RFID读写器、温湿度传感器、震动传感器等，数据量最大、实时性要求最高。

• 接入对象：设备ID、读数、时间戳、设备状态。
• 同步策略：MQTT协议持续流式推送，边缘网关聚合后以固定频率（如每5秒）上报。
• 关键字段：设备编码、测量值、单位、采集时间、网关ID。
• 异常检测关注点：温湿度超限、设备离线、数据断流。

// IoT传感器数据Protobuf定义（简化）
message SensorReading {
  string device_id = 1;
  string sensor_type = 2;  // TEMPERATURE, HUMIDITY, VIBRATION
  double value = 3;
  string unit = 4;
  int64 timestamp_unix = 5;
  string gateway_id = 6;
}

4.3.5 外部天气/交通API接入规范

外部API提供环境上下文，用于预测天气导致的物流延迟或交通拥堵。

• 接入对象：天气预报、实时天气、交通拥堵指数、港口作业状态。
• 同步策略：定时轮询（如每30分钟调用一次天气API），Webhook接收港口事件推送。
• 关键字段：地区编码、时间、温度、降水量、风速、拥堵等级。
• 异常检测关注点：极端天气预警、交通拥堵超阈值、港口关闭事件。

4.4 数据质量与异常处理规范

数据质量是异常检测准确性的前提。接入层必须实施以下质量管控措施：

4.5 接入规范实施清单

在部署数据源接入时，请按以下清单逐项确认：

1. 网络连通性：确认各数据源系统与控制塔之间的网络策略（防火墙、VPN、白名单）。
2. 认证授权：配置、OAuth2.0或证书认证，确保传输安全。
3. Schema注册：在Schema Registry中注册各事件类型的Avro/Protobuf Schema，确保向前兼容。
4. 流量压测：模拟峰值流量（如双11大促），验证接入层吞吐量与延迟是否达标。
5. 监控告警：为每个数据源配置接入成功率、延迟、数据量等监控指标，异常时自动告警。
6. 回退机制：当某个数据源持续异常时，自动切换到历史基线数据或降级模式，避免影响全局检测。