#240 - Solicitar processamento de pagamento - feature/sp7/#240

Author: jeffreysSharp

src/building blocks/JSE.Core/Messages/Integration/PedidoIniciadoIntegrationEvent.cs

@@ -0,0 +1,15 @@
+namespace JSE.Core.Messages.Integration
+{
+    public class PedidoIniciadoIntegrationEvent : IntegrationEvent
+    {
+        public Guid ClienteId { get; set; }
+        public Guid PedidoId { get; set; }
+        public int TipoPagamento { get; set; }
+        public decimal Valor { get; set; }
+        public string NomeCartao { get; set; }
+        public string NumeroCartao { get; set; }
+        public string MesAnoVencimento { get; set; }
+        public string CVV { get; set; }
+
+    }
+}

src/services/JSE.Pedido.API/Application/Commands/PedidoCommandHandler.cs

@@ -1,7 +1,8 @@
 using FluentValidation.Results;
 using JSE.Core.Messages;
+using JSE.Core.Messages.Integration;
+using JSE.MessageBus;
 using JSE.Pedido_API.Application.Events;
-using JSE.Pedidos.API.Application.Commands;
 using JSE.Pedidos.API.Application.DTO;
 using JSE.Pedidos.Domain;
 using JSE.Pedidos.Domain.Pedidos;
@@ -15,12 +16,15 @@ public class PedidoCommandHandler : CommandHandler,
     {
         private readonly IPedidoRepository _pedidoRepository;
         private readonly IVoucherRepository _voucherRepository;
+        private readonly IMessageBus _bus;
 
-        public PedidoCommandHandler(IVoucherRepository voucherRepository, 
-                                    IPedidoRepository pedidoRepository)
+        public PedidoCommandHandler(IVoucherRepository voucherRepository,
+                                    IPedidoRepository pedidoRepository,
+                                    IMessageBus bus)
         {
             _voucherRepository = voucherRepository;
             _pedidoRepository = pedidoRepository;
+            _bus = bus;
         }
 
         public async Task<ValidationResult> Handle(AdicionarPedidoCommand message, CancellationToken cancellationToken)
@@ -38,7 +42,7 @@ public async Task<ValidationResult> Handle(AdicionarPedidoCommand message, Cance
             if (!ValidarPedido(pedido)) return ValidationResult;
 
             // Processar pagamento
-            if (!ProcessarPagamento(pedido)) return ValidationResult;
+            if (! await ProcessarPagamento(pedido, message)) return ValidationResult;
 
             // Se pagamento tudo ok!
             pedido.AutorizarPedido();
@@ -123,8 +127,29 @@ private bool ValidarPedido(Pedido pedido)
             return true;
         }
 
-        public bool ProcessarPagamento(Pedido pedido)
+        public async Task<bool> ProcessarPagamento(Pedido pedido, AdicionarPedidoCommand message)
         {
+            var pedidoIniciado = new PedidoIniciadoIntegrationEvent
+            {
+                PedidoId = pedido.Id,
+                ClienteId = pedido.ClienteId,
+                Valor = pedido.ValorTotal,
+                TipoPagamento = 1, // Fixo, alterar se tiver mais tipos
+                NomeCartao = message.NomeCartao,
+                MesAnoVencimento = message.ExpiracaoCartao,
+                CVV = message.CvvCartao
+            };
+
+            var result = await _bus
+                .RequestAsync<PedidoIniciadoIntegrationEvent, ResponseMessage>(pedidoIniciado);
+
+            if (result.ValidationResult.IsValid) return true;
+
+            foreach (var erro in result.ValidationResult.Errors)
+            {
+                AddError(erro.ErrorMessage);
+            }
+
             return true;
         }
     }