4. 控制塔架构：供应链控制塔的参考架构、事件驱动架构（EDA）与微服务集成模式

供应链控制塔并非单一系统，而是一套由事件驱动架构（EDA）与微服务组合而成的集成平台。其核心目标是将分散在 ERP、WMS、TMS、MES 中的业务事件实时汇聚、关联并触发决策日志的持久化与适配。本节从参考架构、EDA 事件流、微服务集成模式三个维度展开。

4.1 供应链控制塔参考架构

控制塔采用分层解耦设计，自下而上分为五层：

4.2 事件驱动架构（EDA）在控制塔中的落地

EDA 是控制塔的神经中枢。所有业务变更（订单创建、库存调整、物流状态更新）均以不可变事件形式发布到事件总线，下游微服务通过订阅消费事件，实现松耦合与最终一致性。

4.2.1 核心事件类型

• 业务事件：由源系统直接产生，如 OrderCreated、ShipmentDelayed。
• 决策事件：由控制塔规则引擎生成，如 AllocationDecisionMade、ReplenishmentTriggered。
• 日志事件：决策日志的持久化与适配事件，如 DecisionLogAppended、LogSchemaMigrated。

4.2.2 事件溯源与决策日志的关系

事件溯源（Event Sourcing）将决策日志视为事件流的投影。每次决策产生一条决策日志事件，追加到事件存储中；日志适配器通过重放事件流重建任意时刻的决策状态。

4.3 微服务集成模式

控制塔的微服务集成遵循三种核心模式，确保决策日志在不同服务间正确传递与适配：

4.3.1 事件通知模式示例

当库存服务触发补货决策时，发布 ReplenishmentDecisionMade 事件：

{
  "eventType": "ReplenishmentDecisionMade",
  "decisionId": "dec-20250321-001",
  "ruleVersion": "v2.3.1",
  "input": {
    "sku": "WH-1001",
    "currentStock": 15,
    "reorderPoint": 20
  },
  "output": {
    "action": "CREATE_PO",
    "quantity": 50,
    "supplierId": "SUP-045"
  },
  "timestamp": "2025-03-21T10:30:00Z"
}

4.3.2 CQRS 与决策日志投影

在 CQRS 模式下，决策日志的写入与查询分离：

• 命令侧：规则引擎生成决策日志事件，追加到事件存储。
• 查询侧：投影订阅器消费事件，构建针对不同目标系统的日志视图（如 JSON 格式、Avro 格式、关系表格式）。
• 适配器：日志移植时，只需新增一个投影订阅器，将事件流转换为目标系统所需的日志格式，无需修改命令侧逻辑。

4.3.3 Saga 编排中的决策日志链

跨服务 Saga 事务（如订单→库存→物流）会产生决策日志链：

1. 订单服务发布 OrderCreated 事件，生成决策日志 LOG-001。
2. 库存服务消费后执行分配，生成 LOG-002，并关联 LOG-001 的 decisionId。
3. 物流服务消费后执行调度，生成 LOG-003，关联 LOG-002。
4. 若某一步失败，补偿服务根据日志链反向生成补偿日志，确保审计完整性。