added payment commands

Author: suxrobGM

src/Core/Logistics.Application.Tenant/Commands/Payment/CreatePayment/CreatePaymentCommand.cs

@@ -0,0 +1,12 @@
+using Logistics.Shared.Enums;
+using MediatR;
+
+namespace Logistics.Application.Tenant.Commands;
+
+public class CreatePaymentCommand : IRequest<ResponseResult>
+{
+    public PaymentMethod Method { get; set; }
+    public decimal Amount { get; set; }
+    public PaymentFor PaymentFor { get; set; }
+    public string? Comment { get; set; }
+}

src/Core/Logistics.Application.Tenant/Commands/Payment/CreatePayment/CreatePaymentHandler.cs

@@ -0,0 +1,27 @@
+namespace Logistics.Application.Tenant.Commands;
+
+internal sealed class CreatePaymentHandler : RequestHandler<CreatePaymentCommand, ResponseResult>
+{
+    private readonly ITenantRepository _tenantRepository;
+
+    public CreatePaymentHandler(ITenantRepository tenantRepository)
+    {
+        _tenantRepository = tenantRepository;
+    }
+
+    protected override async Task<ResponseResult> HandleValidated(
+        CreatePaymentCommand req, CancellationToken cancellationToken)
+    {
+        var payment = new Payment
+        {
+            Amount = req.Amount,
+            Method = req.Method,
+            PaymentFor = req.PaymentFor,
+            Comment = req.Comment
+        };
+        
+        await _tenantRepository.AddAsync(payment);
+        await _tenantRepository.UnitOfWork.CommitAsync();
+        return ResponseResult.CreateSuccess();
+    }
+}

src/Core/Logistics.Application.Tenant/Commands/Payment/CreatePayment/CreatePaymentValidator.cs

@@ -0,0 +1,11 @@
+using FluentValidation;
+
+namespace Logistics.Application.Tenant.Commands;
+
+internal sealed class CreatePaymentValidator : AbstractValidator<CreatePaymentCommand>
+{
+    public CreatePaymentValidator()
+    {
+        RuleFor(i => i.Amount).GreaterThan(0M);
+    }
+}

src/Core/Logistics.Application.Tenant/Commands/Payment/DeletePayment/DeletePaymentCommand.cs

@@ -0,0 +1,8 @@
+using MediatR;
+
+namespace Logistics.Application.Tenant.Commands;
+
+public class DeletePaymentCommand : IRequest<ResponseResult>
+{
+    public string Id { get; set; } = default!;
+}

src/Core/Logistics.Application.Tenant/Commands/Payment/DeletePayment/DeletePaymentHandler.cs

@@ -0,0 +1,24 @@
+namespace Logistics.Application.Tenant.Commands;
+
+internal sealed class DeletePaymentHandler : RequestHandler<DeletePaymentCommand, ResponseResult>
+{
+    private readonly ITenantRepository _tenantRepository;
+
+    public DeletePaymentHandler(ITenantRepository tenantRepository)
+    {
+        _tenantRepository = tenantRepository;
+    }
+
+    protected override async Task<ResponseResult> HandleValidated(
+        DeletePaymentCommand req, CancellationToken cancellationToken)
+    {
+        var payment = await _tenantRepository.GetAsync<Payment>(req.Id);
+
+        if (payment is null)
+            return ResponseResult.CreateError($"Could not find a payment with ID {req.Id}");
+        
+        _tenantRepository.Delete(payment);
+        await _tenantRepository.UnitOfWork.CommitAsync();
+        return ResponseResult.CreateSuccess();
+    }
+}

src/Core/Logistics.Application.Tenant/Commands/Payment/DeletePayment/DeletePaymentValidator.cs

@@ -0,0 +1,11 @@
+using FluentValidation;
+
+namespace Logistics.Application.Tenant.Commands;
+
+internal sealed class DeletePaymentValidator : AbstractValidator<DeletePaymentCommand>
+{
+    public DeletePaymentValidator()
+    {
+        RuleFor(i => i.Id).NotEmpty();
+    }
+}

src/Core/Logistics.Application.Tenant/Commands/Payment/UpdatePayment/UpdatePaymentCommand.cs

@@ -0,0 +1,14 @@
+using Logistics.Shared.Enums;
+using MediatR;
+
+namespace Logistics.Application.Tenant.Commands;
+
+public class UpdatePaymentCommand : IRequest<ResponseResult>
+{
+    public string Id { get; set; } = default!;
+    public PaymentMethod? Method { get; set; }
+    public decimal? Amount { get; set; }
+    public PaymentStatus? Status { get; set; }
+    public PaymentFor? PaymentFor { get; set; }
+    public string? Comment { get; set; }
+}

src/Core/Logistics.Application.Tenant/Commands/Payment/UpdatePayment/UpdatePaymentHandler.cs

@@ -0,0 +1,45 @@
+namespace Logistics.Application.Tenant.Commands;
+
+internal sealed class UpdatePaymentHandler : RequestHandler<UpdatePaymentCommand, ResponseResult>
+{
+    private readonly ITenantRepository _tenantRepository;
+
+    public UpdatePaymentHandler(ITenantRepository tenantRepository)
+    {
+        _tenantRepository = tenantRepository;
+    }
+
+    protected override async Task<ResponseResult> HandleValidated(
+        UpdatePaymentCommand req, CancellationToken cancellationToken)
+    {
+        var payment = await _tenantRepository.GetAsync<Payment>(req.Id);
+
+        if (payment is null)
+            return ResponseResult.CreateError($"Could not find a payment with ID '{req.Id}'");
+
+        if (req.PaymentFor.HasValue && payment.PaymentFor != req.PaymentFor)
+        {
+            payment.PaymentFor = req.PaymentFor.Value;
+        }
+        if (req.Method.HasValue && payment.Method != req.Method)
+        {
+            payment.Method = req.Method.Value;
+        }
+        if (req.Status.HasValue && payment.Status != req.Status)
+        {
+            payment.SetStatus(req.Status.Value);
+        }
+        if (req.Amount.HasValue && payment.Amount != req.Amount)
+        {
+            payment.Amount = req.Amount.Value;
+        }
+        if (!string.IsNullOrEmpty(req.Comment) && payment.Comment != req.Comment)
+        {
+            payment.Comment = req.Comment;
+        }
+        
+        _tenantRepository.Update(payment);
+        await _tenantRepository.UnitOfWork.CommitAsync();
+        return ResponseResult.CreateSuccess();
+    }
+}

src/Core/Logistics.Application.Tenant/Commands/Payment/UpdatePayment/UpdatePaymentValidator.cs

@@ -0,0 +1,11 @@
+using FluentValidation;
+
+namespace Logistics.Application.Tenant.Commands;
+
+internal sealed class UpdatePaymentValidator : AbstractValidator<UpdatePaymentCommand>
+{
+    public UpdatePaymentValidator()
+    {
+        RuleFor(i => i.Id).NotEmpty();
+    }
+}

src/Core/Logistics.Domain/Entities/Payment.cs

@@ -12,4 +12,14 @@ public class Payment : Entity, ITenantEntity
     public PaymentStatus Status { get; set; }
     public PaymentFor PaymentFor { get; set; }
     public string? Comment { get; set; }
+
+    public void SetStatus(PaymentStatus status)
+    {
+        if (status == PaymentStatus.Paid)
+        {
+            PaymentDate = DateTime.UtcNow;
+        }
+
+        Status = status;
+    }
 }

src/Server/Logistics.API/Controllers/PaymentsController.cs

@@ -45,7 +45,7 @@ public async Task<IActionResult> GetList([FromQuery] GetPaymentsQuery query)
     [ProducesResponseType(typeof(ResponseResult), StatusCodes.Status200OK)]
     [ProducesResponseType(typeof(ResponseResult), StatusCodes.Status400BadRequest)]
     [Authorize(Policy = Permissions.Payments.Create)]
-    public async Task<IActionResult> Create([FromBody] CreateCustomerCommand request)
+    public async Task<IActionResult> Create([FromBody] CreatePaymentCommand request)
     {
         var result = await _mediator.Send(request);
 
@@ -59,7 +59,7 @@ public async Task<IActionResult> Create([FromBody] CreateCustomerCommand request
     [ProducesResponseType(typeof(ResponseResult), StatusCodes.Status200OK)]
     [ProducesResponseType(typeof(ResponseResult), StatusCodes.Status400BadRequest)]
     [Authorize(Policy = Permissions.Payments.Edit)]
-    public async Task<IActionResult> Update(string id, [FromBody] UpdateCustomerCommand request)
+    public async Task<IActionResult> Update(string id, [FromBody] UpdatePaymentCommand request)
     {
         request.Id = id;
         var result = await _mediator.Send(request);

src/Server/Logistics.API/Extensions/ApplicationExtensions.cs

@@ -3,7 +3,6 @@
 using Logistics.API.Hubs;
 using Logistics.API.Middlewares;
 using Logistics.API.Services;
-using Logistics.Application.Core;
 using Logistics.Application.Tenant.Services;
 using Logistics.Infrastructure.EF;
 using Microsoft.AspNetCore.Mvc.Authorization;

src/Server/Logistics.API/Middlewares/ExceptionHandlingMiddleware.cs

@@ -1,7 +1,5 @@
-using System;
-using System.Text;
+using System.Text;
 using System.Text.Json;
-using Azure;
 using FluentValidation;
 
 namespace Logistics.API.Middlewares;
@@ -81,4 +79,4 @@ public static IApplicationBuilder UseCustomExceptionHandler(this IApplicationBui
     {
         return builder.UseMiddleware<ExceptionHandlingMiddleware>();
     } 
-}
+}