假设我们有股票。此库存应保留产品 ID 和可用数量。该库存的用户可以频繁更新(InitAvailableQuantityCommand)可用数量。如果某些产品已售出,我们的系统将收到已售出事件(DecreaseAvailableQuantityCommand),并且已售出产品的可用数量应该减少。
它适用于下面的聚合,直到一件事,如果我再次尝试使用 InitAvailableQuantityCommand 重新初始化库存,该事件将被忽略并引发错误
已插入序列 [0] 处的聚合 [3333] 事件”
我试图达到的目标如下:
- InitAvailableQuantityCommand (productId = 1, 数量 = 10)
- DecreaseAvailableQuantityCommand(productId = 1,数量 = 1)
- DecreaseAvailableQuantityCommand(productId = 1,数量 = 1)
- 现在我们还有 8 种可用产品。
- 并且此时用户将使用 productId 1 的 20 个可用产品重新初始化库存。用户将发送一个新的 InitAvailableQuantityCommand (productId = 1, quantity = 20),此时它失败并且不起作用。
我错了什么?
谢谢。
@NoArgsConstructor
@Aggregate
@Data
public class AvailableQuantityAggregate {
private String partnerId;
private String productId;
@AggregateIdentifier
private String productVariationId;
private int quantity;
@CommandHandler
public AvailableQuantityAggregate(InitAvailableQuantityCommand cmd) {
final ApplyMore apply = AggregateLifecycle.apply(AvailableQuantityInitializedEvent.builder()
.partnerId(cmd.getPartnerId())
.productId(cmd.getProductId())
.productVariationId(cmd.getProductVariationId())
.quantity(cmd.getQuantity())
.build());
}
@CommandHandler
public void handle(DecreaseAvailableQuantityCommand cmd) {
AggregateLifecycle.apply(AvailableQuantityDecreasedEvent.builder()
.productVariationId(cmd.getProductVariationId())
.quantity(cmd.getQuantity())
.build());
}
@EventSourcingHandler
protected void on(AvailableQuantityInitializedEvent event) {
this.productVariationId = event.getProductVariationId();
this.partnerId = event.getPartnerId();
this.productId = event.getProductId();
this.quantity = event.getQuantity();
}
@EventSourcingHandler
protected void on(AvailableQuantityDecreasedEvent event) {
this.quantity = this.quantity-event.getQuantity();
}
}