事件溯源：订单拣选系统的数量控制与状态重建问题

一、从源头避免错误事件生成 #

事件溯源中，事件是已发生的事实，不能在状态重建的事件处理逻辑中过滤事件（这会导致状态不一致）。正确的控制应该放在命令处理层——也就是触发事件的前置环节：

在处理拣选命令（比如ProcessPickCommand）时，先校验拣选数量是否超过请求数量，拒绝非法命令或自动修正后再生成事件：

// 命令处理逻辑，生成OrderPrepared事件前做校验
public void handle(ProcessPickCommand command) {
    OrderLine orderLine = getOrderLine(command.getOrderLineId());
    int requestedQty = orderLine.getRequestedQuantity();
    int pickedQty = command.getPickedQuantity();

    // 校验逻辑：禁止超拣
    if (pickedQty > requestedQty) {
        // 可选方案1：抛出异常拒绝非法拣选请求
        throw new IllegalArgumentException("拣选数量不能超过订单请求数量");
        // 可选方案2：自动将拣选量修正为最大允许值，继续生成事件
        // pickedQty = requestedQty;
    }

    // 生成合法的OrderPrepared事件并持久化
    apply(new OrderPrepared(orderLine.withPickedQuantity(pickedQty)));
}

二、修复已有错误事件并重建正确状态 #

对于已经生成的错误OrderPrepared事件（拣选量超请求量），不能直接修改已存储的事件（事件不可变是事件溯源的核心原则），需通过补偿事件修正状态：

步骤1：定义补偿事件 #

新增OrderPickCorrected事件，用于修正错误的拣选数量：

public class OrderPickCorrected {
    private final OrderLine correctedOrderLine;

    public OrderPickCorrected(OrderLine correctedOrderLine) {
        this.correctedOrderLine = correctedOrderLine;
    }

    public OrderLine getData() {
        return correctedOrderLine;
    }
}

步骤2：识别并生成补偿事件 #

遍历所有订单的事件流，找出包含pickedQuantity > requestedQuantity的OrderPrepared事件的订单，为每个订单生成OrderPickCorrected事件（其中pickedQuantity设为对应订单的requestedQuantity），并将补偿事件追加到该订单的事件流末尾。

步骤3：修改聚合的事件处理逻辑 #

在聚合中新增补偿事件的处理方法，同时保留原OrderPrepared事件的处理（必须保留所有已发生的事实）：

// 原OrderPrepared事件处理：保留所有事实，即使是错误的
handle(OrderPrepared event) {
    OrderLine orderLine = event.getData();
    this.pickedQuantity = orderLine.getPickedQuantity();
}

// 新增补偿事件处理：修正错误状态
handle(OrderPickCorrected event) {
    OrderLine correctedLine = event.getData();
    this.pickedQuantity = correctedLine.getPickedQuantity();
}

步骤4：重建所有受影响订单的状态 #

对所有包含错误事件的订单，重新重放其完整事件流（原事件+补偿事件），聚合会先应用错误的拣选数量，再通过补偿事件修正为正确值，最终得到一致的正确状态。

为什么你之前的调整会有问题 #

你在OrderPrepared事件处理中过滤错误事件的做法，违背了事件溯源“记录所有已发生事实”的核心原则：

• 重放事件时跳过错误事件，会导致聚合状态与真实业务流程脱节
• 如果后续有依赖该错误状态的其他事件（比如订单发货事件），重放时会出现状态不一致的问题

内容的提问来源于stack exchange，提问作者user2530251