fix(lastleg): isolate shipping node version stream

This commit is contained in:
2026-08-25 13:23:05 +08:00
parent 79eb3efe61
commit 2cfaf8e51b
2 changed files with 5 additions and 2 deletions
@@ -73,8 +73,11 @@ public class LoadingCompletedConsumer {
return countOrders(envelope,payload.containerNo());
}
// The loading-plan and container-shipping events are independent aggregate streams.
// Seeding the shipping version from the loading-plan version makes a valid first node
// (aggregateVersion=0) look stale whenever the loading plan has a higher version.
shippingGates.initialize(payload.containerBookingId(), envelope.tenantId(), "",
payload.containerNo(), envelope.aggregateVersion(), envelope.handoverVersion());
payload.containerNo(), 0, envelope.handoverVersion());
String orderNo = orderNoGenerator.forContainerNo(payload.containerNo());
JsonNode rawOrders = envelope.payload().path("orders");