#248 - Baixar o pedido do estoque - feature/sp7/#248

Author: jeffreysSharp

src/services/JSE.Catalogo.API/Configuration/MessageBusConfig.cs

@@ -0,0 +1,16 @@
+using JSE.Catalogo.API.Services;
+using JSE.Core.Utils;
+using JSE.MessageBus;
+
+namespace JSE.Catalogo.API.Configuration
+{
+    public static class MessageBusConfig
+    {
+        public static void AddMessageBusConfiguration(this IServiceCollection services,
+            IConfiguration configuration)
+        {
+            services.AddMessageBus(configuration.GetMessageQueueConnection("MessageBus"))
+                .AddHostedService<CatalogoIntegrationHandler>();
+        }
+    }
+}

src/services/JSE.Catalogo.API/JSE.Catalogo.API.csproj

@@ -28,6 +28,7 @@
 
   <ItemGroup>
     <ProjectReference Include="..\..\building blocks\JSE.Core\JSE.Core.csproj" />
+    <ProjectReference Include="..\..\building blocks\JSE.MessageBus\JSE.MessageBus.csproj" />
     <ProjectReference Include="..\..\building blocks\JSE.WebAPI.Core\JSE.WebAPI.Core.csproj" />
     <ProjectReference Include="..\JSE.Identidade.API\JSE.Identidade.API.csproj" />
   </ItemGroup>

src/services/JSE.Catalogo.API/Models/Produto.cs

@@ -5,11 +5,22 @@ namespace JSE.Catalogo.API.Models
     public class Produto : Entity, IAggregateRoot
     {
         public string Nome { get; set; }
-        public string Descricao  { get; set; }
+        public string Descricao { get; set; }
         public bool Ativo { get; set; }
         public decimal Valor { get; set; }
         public DateTime DataCadastro { get; set; }
         public string Imagem { get; set; }
         public int QuantidadeEstoque { get; set; }
+
+        public void RetirarEstoque(int quantidade)
+        {
+            if (QuantidadeEstoque >= quantidade)
+                QuantidadeEstoque -= quantidade;
+        }
+
+        public bool EstaDisponivel(int quantidade)
+        {
+            return Ativo && QuantidadeEstoque >= quantidade;
+        }
     }
 }

src/services/JSE.Catalogo.API/Program.cs

@@ -13,6 +13,7 @@
         .AddUserSecrets(typeof(Program).Assembly).Build();
 
 builder.Services.AddApiConfiguration(configuration);
+builder.Services.AddMessageBusConfiguration(configuration);
 builder.Services.AddJwtConfiguration(configuration);
 builder.Services.AddSwaggerConfiguration();
 builder.Services.AddEndpointsApiExplorer();

src/services/JSE.Catalogo.API/Services/CatalogoIntegrationHandler.cs

@@ -0,0 +1,84 @@
+using JSE.Catalogo.API.Models;
+using JSE.Core.DomainObjects;
+using JSE.Core.Messages.Integration;
+using JSE.MessageBus;
+
+namespace JSE.Catalogo.API.Services
+{
+    public class CatalogoIntegrationHandler : BackgroundService
+    {
+        private readonly IMessageBus _bus;
+        private readonly IServiceProvider _serviceProvider;
+
+        public CatalogoIntegrationHandler(IServiceProvider serviceProvider, IMessageBus bus)
+        {
+            _serviceProvider = serviceProvider;
+            _bus = bus;
+        }
+        protected override Task ExecuteAsync(CancellationToken stoppingToken)
+        {
+            SetSubscribers();
+            return Task.CompletedTask;
+        }
+
+        private void SetSubscribers()
+        {
+            _bus.SubscribeAsync<PedidoAutorizadoIntegrationEvent>("PedidoAutorizado", async request =>
+                await BaixarEstoque(request));
+        }
+
+        private async Task BaixarEstoque(PedidoAutorizadoIntegrationEvent message)
+        {
+            using (var scope = _serviceProvider.CreateScope())
+            {
+                var produtosComEstoque = new List<Produto>();
+                var produtoRepository = scope.ServiceProvider.GetRequiredService<IProdutoRepository>();
+
+                var idsProdutos = string.Join(",", message.Itens.Select(c => c.Key));
+                var produtos = await produtoRepository.ObterProdutosPorId(idsProdutos);
+
+                if (produtos.Count != message.Itens.Count)
+                {
+                    CancelarPedidoSemEstoque(message);
+                    return;
+                }
+
+                foreach (var produto in produtos)
+                {
+                    var quantidadeProduto = message.Itens.FirstOrDefault(p => p.Key == produto.Id).Value;
+                    
+                    if (produto.EstaDisponivel(quantidadeProduto))
+                    {
+                        produto.RetirarEstoque(quantidadeProduto);
+                        produtosComEstoque.Add(produto);
+                    }
+                }
+
+                if (produtosComEstoque.Count != message.Itens.Count)
+                {
+                    CancelarPedidoSemEstoque(message);
+                    return;
+                }
+
+                foreach (var produto in produtosComEstoque)
+                {
+                    produtoRepository.Atualizar(produto);
+                }
+
+                if (!await produtoRepository.UnitOfWork.Commit())
+                {
+                    throw new DomainException($"Problemas ao atualizar estoque do pedido {message.PedidoId}");
+                }
+
+                var pedidoBaixado = new PedidoBaixadoEstoqueIntegrationEvent(message.ClienteId, message.PedidoId);
+                await _bus.PublishAsync(pedidoBaixado);
+            }
+        }
+
+        public async void CancelarPedidoSemEstoque(PedidoAutorizadoIntegrationEvent message)
+        {
+            var pedidoCancelado = new PedidoCanceladoIntegrationEvent(message.ClienteId, message.PedidoId);
+            await _bus.PublishAsync(pedidoCancelado);
+        }
+    }
+}

src/services/JSE.Catalogo.API/appsettings.Development.json

@@ -1,14 +1,19 @@
 {
-  "ConnectionStrings": {
-    "DefaultConnection": "Server=.\\SQLEXPRESS;Database=JeffStoreEnterprise;User Id=sa;Password=Asd123!!;Trusted_Connection=true;MultipleActiveResultSets=true;TrustServerCertificate=True;"
-  },
   "Logging": {
     "LogLevel": {
       "Default": "Information",
       "Microsoft.AspNetCore": "Warning"
     }
   },
 
+  "ConnectionStrings": {
+    "DefaultConnection": "Server=.\\SQLEXPRESS;Database=JeffStoreEnterprise;User Id=sa;Password=Asd123!!;Trusted_Connection=true;MultipleActiveResultSets=true;TrustServerCertificate=True;"
+  },
+
+  "MessageQueueConnection": {
+    "MessageBus": "host=localhost:5672;publisherConfirms=true;timeout=10"
+  },
+
   "AppSettings": {
     "Secret": "F9F52344-59C3-4EAC-90E6-CB47935038BE",
     "ExpirationHours": 2,