#179 - Camada de infraestrutura de pedido

Author: jeffreysSharp

src/services/JSE.Pedido.Infra/Data/Mappings/PedidoItemMapping.cs

@@ -0,0 +1,24 @@
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Metadata.Builders;
+using JSE.Pedidos.Domain.Pedidos;
+
+namespace JSE.Pedidos.Infra.Data.Mappings
+{
+    public class PedidoItemMapping : IEntityTypeConfiguration<PedidoItem>
+    {
+        public void Configure(EntityTypeBuilder<PedidoItem> builder)
+        {
+            builder.HasKey(c => c.Id);
+
+            builder.Property(c => c.ProdutoNome)
+                .IsRequired()
+                .HasColumnType("varchar(250)");
+
+            // 1 : N => Pedido : Pagamento
+            builder.HasOne(c => c.Pedido)
+                .WithMany(c => c.PedidoItems);
+
+            builder.ToTable("PedidoItems");
+        }
+    }
+}

src/services/JSE.Pedido.Infra/Data/Mappings/PedidoMapping.cs

@@ -0,0 +1,48 @@
+using Microsoft.EntityFrameworkCore;
+using Microsoft.EntityFrameworkCore.Metadata.Builders;
+using JSE.Pedidos.Domain.Pedidos;
+
+namespace JSE.Pedidos.Infra.Data.Mappings
+{
+    public class PedidoMapping : IEntityTypeConfiguration<Pedido>
+    {
+        public void Configure(EntityTypeBuilder<Pedido> builder)
+        {
+            builder.HasKey(c => c.Id);
+
+            builder.OwnsOne(p => p.Endereco, e =>
+            {
+                e.Property(pe => pe.Logradouro)
+                    .HasColumnName("Logradouro");
+
+                e.Property(pe => pe.Numero)
+                    .HasColumnName("Numero");
+
+                e.Property(pe => pe.Complemento)
+                    .HasColumnName("Complemento");
+
+                e.Property(pe => pe.Bairro)
+                    .HasColumnName("Bairro");
+
+                e.Property(pe => pe.Cep)
+                    .HasColumnName("Cep");
+
+                e.Property(pe => pe.Cidade)
+                    .HasColumnName("Cidade");
+
+                e.Property(pe => pe.Estado)
+                    .HasColumnName("Estado");
+            });
+
+            builder.Property(c => c.Codigo)
+                .HasDefaultValueSql("NEXT VALUE FOR MinhaSequencia");
+
+            // 1 : N => Pedido : PedidoItems
+            builder.HasMany(c => c.PedidoItems)
+                .WithOne(c => c.Pedido)
+                .HasForeignKey(c => c.PedidoId);
+
+            builder.ToTable("Pedidos");
+        }
+    }
+}

src/services/JSE.Pedido.Infra/Data/PedidosContext.cs

@@ -3,6 +3,7 @@
 using JSE.Core.DomainObjects;
 using JSE.Core.Mediator;
 using JSE.Core.Messages;
+using JSE.Pedidos.Domain.Pedidos;
 using JSE.Pedidos.Domain.Vouchers;
 using Microsoft.EntityFrameworkCore;
 
@@ -18,6 +19,8 @@ public PedidosContext(DbContextOptions<PedidosContext> options, IMediatorHandler
             _mediatorHandler = mediatorHandler;
         }
 
+        public DbSet<Pedido> Pedidos { get; set; }
+        public DbSet<PedidoItem> PedidoItems { get; set; }
         public DbSet<Voucher> Vouchers { get; set; }
 
         protected override void OnModelCreating(ModelBuilder modelBuilder)

src/services/JSE.Pedido.Infra/Data/Repository/PedidoRepository.cs

@@ -0,0 +1,62 @@
+using JSE.Core.Data;
+using JSE.Pedidos.Domain.Pedidos;
+using Microsoft.EntityFrameworkCore;
+using System.Data.Common;
+
+namespace JSE.Pedidos.Infra.Data.Repository
+{
+    public class PedidoRepository : IPedidoRepository
+    {
+        private readonly PedidosContext _context;
+
+        public PedidoRepository(PedidosContext context)
+        {
+            _context = context;
+        }
+
+        public IUnitOfWork UnitOfWork => _context;
+
+        public DbConnection ObterConexao() => _context.Database.GetDbConnection();
+
+        public async Task<Pedido> ObterPorId(Guid id)
+        {
+            return await _context.Pedidos.FindAsync(id);
+        }
+
+        public async Task<IEnumerable<Pedido>> ObterListaPorClienteId(Guid clienteId)
+        {
+            return await _context.Pedidos
+                .Include(p => p.PedidoItems)
+                .AsNoTracking()
+                .Where(p => p.ClienteId == clienteId)
+                .ToListAsync();
+        }
+
+        public void Adicionar(Pedido pedido)
+        {
+            _context.Pedidos.Add(pedido);
+        }
+
+        public void Atualizar(Pedido pedido)
+        {
+            _context.Pedidos.Update(pedido);
+        }
+
+
+        public async Task<PedidoItem> ObterItemPorId(Guid id)
+        {
+            return await _context.PedidoItems.FindAsync(id);
+        }
+
+        public async Task<PedidoItem> ObterItemPorPedido(Guid pedidoId, Guid produtoId)
+        {
+            return await _context.PedidoItems
+                .FirstOrDefaultAsync(p => p.ProdutoId == produtoId && p.PedidoId == pedidoId);
+        }
+
+        public void Dispose()
+        {
+            _context.Dispose();
+        }
+    }
+}