diff --git a/TransactionProcessor.Settlement.DomainEvents/SettlementAggregateDomainEvents.cs b/TransactionProcessor.Settlement.DomainEvents/SettlementAggregateDomainEvents.cs index d7dba482..2ecc4b20 100644 --- a/TransactionProcessor.Settlement.DomainEvents/SettlementAggregateDomainEvents.cs +++ b/TransactionProcessor.Settlement.DomainEvents/SettlementAggregateDomainEvents.cs @@ -28,7 +28,8 @@ public record MerchantFeeSettledEvent(Guid SettlementId, [ExcludeFromCodeCoverage] public record SettlementCompletedEvent(Guid SettlementId, - Guid EstateId) : DomainEvent(SettlementId, Guid.NewGuid()); + Guid EstateId, + Guid MerchantId) : DomainEvent(SettlementId, Guid.NewGuid()); [ExcludeFromCodeCoverage] public record SettlementCreatedForDateEvent(Guid SettlementId, diff --git a/TransactionProcessor.SettlementAggregates/SettlementAggregate.cs b/TransactionProcessor.SettlementAggregates/SettlementAggregate.cs index d4dade68..87e7c1b0 100644 --- a/TransactionProcessor.SettlementAggregates/SettlementAggregate.cs +++ b/TransactionProcessor.SettlementAggregates/SettlementAggregate.cs @@ -29,7 +29,7 @@ public static void ManuallyComplete(this SettlementAggregate aggregate){ if (aggregate.SettlementComplete) return; - SettlementCompletedEvent pendingSettlementCompletedEvent = new SettlementCompletedEvent(aggregate.AggregateId, aggregate.EstateId); + SettlementCompletedEvent pendingSettlementCompletedEvent = new SettlementCompletedEvent(aggregate.AggregateId, aggregate.EstateId, aggregate.MerchantId); aggregate.ApplyAndAppend(pendingSettlementCompletedEvent); } @@ -58,7 +58,7 @@ public static void MarkFeeAsSettled(this SettlementAggregate aggregate, Guid mer if (aggregate.CalculatedFeesPendingSettlement.Any() == false) { // Settlement is completed - SettlementCompletedEvent pendingSettlementCompletedEvent = new SettlementCompletedEvent(aggregate.AggregateId, aggregate.EstateId); + SettlementCompletedEvent pendingSettlementCompletedEvent = new SettlementCompletedEvent(aggregate.AggregateId, aggregate.EstateId, aggregate.MerchantId); aggregate.ApplyAndAppend(pendingSettlementCompletedEvent); } }