feature produtos mais vendidos

Mensageria/Domain/Interfaces/IConfiguracaoParceiroRepository.cs

@@ -0,0 +1,6 @@
+namespace Mensageria.Domain.Interfaces;
+
+public interface IConfiguracaoParceiroRepository
+{
+    Task<string> GetConnectionStringParceiroAsync(string referer);
+}

Mensageria/Domain/Interfaces/IProdutosMaisVendidosRepository.cs

@@ -0,0 +1,10 @@
+using Domain.Pkg.Entities;
+
+namespace Mensageria.Domain.Interfaces;
+
+public interface IProdutosMaisVendidosRepository
+{
+    Task AddRangeAsync(IList<ProdutosMaisVendidos> produtosMaisVendidos, string referer);
+    Task UpdateRangeAsync(IList<ProdutosMaisVendidos> produtosMaisVendidos, string referer);
+    Task<IList<ProdutosMaisVendidos>> GetProdutosMaisVendidosAsync(IList<Guid> produtosIds, string referer);
+}

Mensageria/Dtos/ProdutosMaisVendidos/AddOrUpdateProdutosMaisVendidosDto.cs

@@ -0,0 +1,7 @@
+namespace Mensageria.Dtos.ProdutosMaisVendidos;
+
+public class AddOrUpdateProdutosMaisVendidosDto
+{
+    public Guid ProdutoId { get; set; }
+    public decimal QuantidadeProdutos { get; set; }
+}

Mensageria/Infra/Context/OpenAdmContext.cs

@@ -0,0 +1,11 @@
+using Domain.Pkg.Entities;
+using Microsoft.EntityFrameworkCore;
+
+namespace Mensageria.Infra.Context;
+
+public class OpenAdmContext(DbContextOptions<OpenAdmContext> options)
+    : DbContext(options)
+{
+    public DbSet<Parceiro> Parceiros { get; set; }
+    public DbSet<ConfiguracaoParceiro> ConfiguracoesParceiro { get; set; }
+}

Mensageria/Infra/Context/ParceiroContext.cs

@@ -0,0 +1,25 @@
+using Domain.Pkg.Entities;
+using Microsoft.EntityFrameworkCore;
+
+namespace Mensageria.Infra.Context;
+
+public class ParceiroContext(DbContextOptions options)
+    : DbContext(options)
+{
+    public DbSet<Banner> Banners { get; set; }
+    public DbSet<Funcionario> Funcionarios { get; set; }
+    public DbSet<Categoria> Categorias { get; set; }
+    public DbSet<Peso> Pesos { get; set; }
+    public DbSet<Tamanho> Tamanhos { get; set; }
+    public DbSet<Produto> Produtos { get; set; }
+    public DbSet<PesosProdutos> PesosProdutos { get; set; }
+    public DbSet<TamanhosProdutos> TamanhosProdutos { get; set; }
+    public DbSet<Usuario> Usuarios { get; set; }
+    public DbSet<Pedido> Pedidos { get; set; }
+    public DbSet<ItensPedido> ItensPedidos { get; set; }
+    public DbSet<TabelaDePreco> TabelaDePreco { get; set; }
+    public DbSet<ItensTabelaDePreco> ItensTabelaDePreco { get; set; }
+    public DbSet<ProdutosMaisVendidos> ProdutosMaisVendidos { get; set; }
+    public DbSet<ConfiguracaoDeEmail> ConfiguracoesDeEmail { get; set; }
+    public DbSet<ConfiguracoesDePedido> ConfiguracoesDePedidos { get; set; }
+}

Mensageria/Infra/Factories/FactoryParceiroContext.cs

@@ -0,0 +1,27 @@
+using Mensageria.Domain.Interfaces;
+using Mensageria.Infra.Context;
+using Mensageria.Infra.Interfaces;
+using Microsoft.EntityFrameworkCore;
+
+namespace Mensageria.Infra.Factories;
+
+public class FactoryParceiroContext : IFactoryParceiroContext
+{
+    private readonly IConfiguracaoParceiroRepository _configuracaoParceiroRepository;
+
+    public FactoryParceiroContext(IConfiguracaoParceiroRepository configuracaoParceiroRepository)
+    {
+        _configuracaoParceiroRepository = configuracaoParceiroRepository;
+    }
+
+    public async Task<ParceiroContext> CreateParceiroContextAsync(string referer)
+    {
+        var connectionString = await _configuracaoParceiroRepository.GetConnectionStringParceiroAsync(referer);
+
+        var optionsBuilderParceiro = new DbContextOptionsBuilder<ParceiroContext>();
+
+        optionsBuilderParceiro.UseNpgsql(connectionString);
+
+        return new ParceiroContext(optionsBuilderParceiro.Options);
+    }
+}

Mensageria/Infra/Interfaces/IFactoryParceiroContext.cs

@@ -0,0 +1,8 @@
+using Mensageria.Infra.Context;
+
+namespace Mensageria.Infra.Interfaces;
+
+public interface IFactoryParceiroContext
+{
+    Task<ParceiroContext> CreateParceiroContextAsync(string referer);
+}

Mensageria/Infra/Repositories/ConfiguracaoParceiroRepository.cs

@@ -0,0 +1,26 @@
+using Mensageria.Domain.Interfaces;
+using Mensageria.Infra.Context;
+using Microsoft.EntityFrameworkCore;
+
+namespace Mensageria.Infra.Repositories;
+
+public class ConfiguracaoParceiroRepository : IConfiguracaoParceiroRepository
+{
+    private readonly OpenAdmContext _openAdmContext;
+
+    public ConfiguracaoParceiroRepository(OpenAdmContext openAdmContext)
+    {
+        _openAdmContext = openAdmContext;
+    }
+
+    public async Task<string> GetConnectionStringParceiroAsync(string referer)
+    {
+        return await _openAdmContext
+            .ConfiguracoesParceiro
+            .AsNoTracking()
+            .Where(x => x.DominioSiteAdm == referer || x.DominioSiteEcommerce == referer)
+            .Select(x => x.ConexaoDb)
+            .FirstOrDefaultAsync()
+             ?? throw new Exception("Conexão do parceiro não foi localizada!");
+    }
+}