Compare commits

...
6 Commits
2 changed files with 5 additions and 5 deletions
@@ -66,7 +66,7 @@ public sealed class PayfastPaymentConfirmationReceivedEventHandler(IServiceProvi
{ {
OrderId = orderResult.Value.Id, OrderId = orderResult.Value.Id,
PaymentId = paymentResult.Value.Id, PaymentId = paymentResult.Value.Id,
PaymentGatewayReference = payload.PaymentId!, PaymentGatewayReference = payload.MerchantPaymentId!,
Status = LedgerStatuses.Completed, Status = LedgerStatuses.Completed,
CustomerId = orderResult.Value.CustomerId, CustomerId = orderResult.Value.CustomerId,
}, cancellationToken); }, cancellationToken);
@@ -91,7 +91,7 @@ public sealed class PayfastPaymentConfirmationReceivedEventHandler(IServiceProvi
{ {
OrderId = orderResult.Value.Id, OrderId = orderResult.Value.Id,
PaymentId = paymentResult.Value.Id, PaymentId = paymentResult.Value.Id,
PaymentGatewayReference = payload.PaymentId!, PaymentGatewayReference = payload.MerchantPaymentId!,
Status = ledgerStatus, Status = ledgerStatus,
CustomerId = orderResult.Value.CustomerId, CustomerId = orderResult.Value.CustomerId,
}, cancellationToken); }, cancellationToken);
@@ -123,8 +123,7 @@ public sealed class PaymentService(IDbContextFactory<MidrandBooksDbContext> cont
await using var context = await contextFactory.CreateDbContextAsync(cancellationToken); await using var context = await contextFactory.CreateDbContextAsync(cancellationToken);
var exists = await context.Ledger.AnyAsync(l => var exists = await context.Ledger.AnyAsync(l =>
l.OrderId == orderId && l.OrderId == orderId && l.PaymentId == paymentId && l.Status == LedgerStatuses.Completed, cancellationToken);
l.PaymentId == paymentId, cancellationToken);
return Result.Ok(exists); return Result.Ok(exists);
} }
@@ -162,7 +161,8 @@ public sealed class PaymentService(IDbContextFactory<MidrandBooksDbContext> cont
CustomerId = request.CustomerId, CustomerId = request.CustomerId,
OrderId = request.OrderId, OrderId = request.OrderId,
PaymentId = request.PaymentId, PaymentId = request.PaymentId,
Status = request.Status, MerchantPaymentId = request.PaymentGatewayReference,
Status = request.Status,
}); });
return await context.SaveChangesAsync(cancellationToken) > 0 return await context.SaveChangesAsync(cancellationToken) > 0