63 lines
2.1 KiB
C#
63 lines
2.1 KiB
C#
using FinancialApi.Application.Commands;
|
|
using FinancialApi.Application.Events;
|
|
using FinancialApi.Application.Interfaces;
|
|
using FinancialApi.Application.Models;
|
|
using FinancialApi.Domain;
|
|
using FinancialApi.Domain.Aggregates;
|
|
using FinancialApi.Domain.Entities;
|
|
using Wolverine.Persistence;
|
|
|
|
namespace FinancialApi.Application.Handlers;
|
|
|
|
public static class ApplyFeeHandler
|
|
{
|
|
public static async Task<FeeContext> LoadAsync(
|
|
ApplyFeeCommand cmd,
|
|
IAccountQuery query, TimeProvider timeProvider)
|
|
{
|
|
var source = await query.FindByIdAsync(cmd.AccountId);
|
|
var dest = await query.FindByIdAsync(99999);
|
|
if (source == null || dest == null)
|
|
{
|
|
throw new InvalidOperationException($"Cannot process transfer. Account(s) not found.");
|
|
}
|
|
|
|
return new FeeContext(source, dest, timeProvider.GetUtcNow());
|
|
}
|
|
|
|
public static (
|
|
IStorageAction<Account> CustomerWrite,
|
|
IStorageAction<Account> RevenueWrite,
|
|
IStorageAction<JournalEntry> JournalWrite,
|
|
FeeAppliedEvent Event
|
|
)
|
|
Handle(
|
|
ApplyFeeCommand cmd,
|
|
FeeContext context
|
|
)
|
|
{
|
|
var updatedSource = context.Source.ApplyPosting(cmd.Amount, EntryType.Debit);
|
|
var updatedRevenue = context.Destination.ApplyPosting(cmd.Amount, EntryType.Credit);
|
|
var serviceFee = 0.5m;
|
|
|
|
var lines = new List<JournalLine>
|
|
{
|
|
new(updatedSource.Id, cmd.Amount, EntryType.Debit),
|
|
new(updatedRevenue.Id, cmd.Amount - serviceFee, EntryType.Credit),
|
|
new(updatedRevenue.Id, serviceFee, EntryType.Credit)
|
|
};
|
|
|
|
var journalEntry = BalancedJournal.Create(Guid.NewGuid(),
|
|
$"Service Fee Applied: {cmd.Amount} to Account {cmd.AccountId}",
|
|
context.TimeStamp, lines);
|
|
|
|
var @event = new FeeAppliedEvent(cmd.AccountId, cmd.Amount);
|
|
|
|
return (
|
|
Storage.Update(updatedSource),
|
|
Storage.Update(updatedRevenue),
|
|
Storage.Insert(journalEntry.Entry),
|
|
@event
|
|
);
|
|
}
|
|
} |