2. 事件溯源基础：事件溯源原理、事件存储与事件流概念

事件溯源（Event Sourcing）是一种以“事件”为核心的数据持久化与状态重建范式。在供应链控制塔的多系统集成场景中，传统“保存当前快照”的方式无法追溯决策链条，而事件溯源通过记录每一次状态变更的不可变事件，为决策日志移植提供了天然的审计与回放基础。

2.1 事件溯源核心原理

事件溯源将系统的状态变化建模为一系列有序的、不可变的事件。与传统的 CRUD（创建、读取、更新、删除）模型不同，事件溯源不直接存储对象的当前状态，而是存储导致状态变化的所有事件。

2.2 事件存储（Event Store）

事件存储是事件溯源的基础设施，负责持久化事件流并提供高效的追加写入与按序读取能力。在供应链控制塔中，事件存储需要支持高吞吐、低延迟以及跨系统的事件订阅。

• 追加写入（Append-Only）：事件只能追加到流的末尾，不允许更新或删除已有事件。
• 事件版本号：每个事件在流中拥有递增的版本号，用于乐观并发控制和状态重建。
• 快照（Snapshot）：为加速状态重建，可定期保存聚合的快照，重建时从最近快照开始重放后续事件。
• 订阅与投影（Projection）：事件存储支持实时订阅，下游系统通过投影构建物化视图。

// 事件存储追加写入示例（伪代码）
eventStore.appendToStream(
  streamId: "order-2025-001",
  expectedVersion: 3,
  events: [
    {
      eventType: "OrderAllocated",
      data: { warehouseId: "WH-A", carrier: "SF" },
      metadata: { timestamp: 1710000000, userId: "system" }
    }
  ]
);

2.3 事件流（Event Stream）

事件流是同一聚合（Aggregate）或同一业务实体的事件序列。每个事件流由唯一的 streamId 标识，事件按发生顺序排列。在供应链控制塔中，一个订单、一个库存批次、一次运输任务都可以对应一个独立的事件流。

2.4 状态重建与事件回放

事件溯源的核心能力在于“状态重建”：通过重放事件流中的所有事件，可以还原聚合在任何历史时间点的状态。这一机制在决策日志移植中至关重要——当需要审计某个决策的上下文时，只需重建该决策发生时刻的系统状态。

// 状态重建示例：从事件流重建订单状态
function rebuildOrderState(streamId, targetVersion) {
  let state = { status: "pending", warehouse: null, carrier: null };
  const events = eventStore.readStream(streamId, targetVersion);
  
  for (const event of events) {
    switch (event.eventType) {
      case "OrderCreated":
        state.status = "created";
        break;
      case "OrderAllocated":
        state.warehouse = event.data.warehouseId;
        state.status = "allocated";
        break;
      case "InventoryReserved":
        state.status = "reserved";
        break;
      case "OrderShipped":
        state.status = "shipped";
        state.carrier = event.data.carrier;
        break;
    }
  }
  return state;
}

2.5 事件溯源在供应链控制塔中的价值

• 审计完整性：每个决策事件都包含完整的元数据，满足合规审计要求。
• 时间旅行调试：可重建任意历史时刻的系统状态，快速定位决策异常。
• 多系统解耦：事件作为集成契约，各系统只需订阅相关事件流，无需直接调用。
• 决策日志原生适配：事件本身就是决策日志，无需额外设计日志表结构。