From 04364a9fa351a8f8aa31aa179d9f907b804430f1 Mon Sep 17 00:00:00 2001 From: Stuart Ferguson Date: Tue, 19 Dec 2023 09:27:44 +0000 Subject: [PATCH] Add merchant id to settlement completed event --- .../SettlementAggregateDomainEvents.cs | 3 ++- .../SettlementAggregate.cs | 4 ++-- 2 files changed, 4 insertions(+), 3 deletions(-) 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); } }