feat: зависимости многие ко многим

TheBank/BankDatabase/BankDbContext.cs

@@ -67,6 +67,14 @@ internal class BankDbContext(IConfigurationDatabase configurationDatabase) : DbC
             .WithOne(x => x.Clerk)
             .HasForeignKey(x => x.ClerkId)
             .OnDelete(DeleteBehavior.Restrict);
+
+        modelBuilder.Entity<DepositCurrency>().HasKey(x => new { x.DepositId, x.CurrencyId });
+
+        modelBuilder.Entity<ClientCreditProgram>().HasKey(x => new { x.ClientId, x.CreditProgramId });
+
+        modelBuilder.Entity<DepositClient>().HasKey(x => new { x.DepositId, x.ClientId });
+
+        modelBuilder.Entity<CreditProgramCurrency>().HasKey(x => new { x.CreditProgramId, x.CurrencyId });
     }
 
     public DbSet<Clerk> Clerks { get; set; }
@@ -84,4 +92,12 @@ internal class BankDbContext(IConfigurationDatabase configurationDatabase) : DbC
     public DbSet<Replenishment> Replenishments { get; set; }
     
     public DbSet<Storekeeper> Storekeepers { get; set; }
+
+    public DbSet<DepositCurrency> DepositCurrencies { get; set; }
+
+    public DbSet<ClientCreditProgram> CreditProgramClients { get; set; }
+
+    public DbSet<DepositClient> DepositClients { get; set; }
+
+    public DbSet<CreditProgramCurrency> CurrencyCreditPrograms { get; set; }
 }

TheBank/BankDatabase/Implementations/DepositStorageContract.cs

@@ -0,0 +1,151 @@
+using AutoMapper;
+using BankContracts.DataModels;
+using BankContracts.Exceptions;
+using BankContracts.StorageContracts;
+using BankDatabase.Models;
+using Microsoft.EntityFrameworkCore;
+using Npgsql;
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace BankDatabase.Implementations;
+
+internal class DepositStorageContract : IDepositStorageContract
+{
+    private readonly BankDbContext _dbContext;
+    private readonly Mapper _mapper;
+
+    public DepositStorageContract(BankDbContext dbContext)
+    {
+        _dbContext = dbContext;
+        var config = new MapperConfiguration(cfg =>
+        {
+            cfg.CreateMap<Clerk, ClerkDataModel>();
+            cfg.CreateMap<Deposit, DepositDataModel>();
+            cfg.CreateMap<DepositDataModel, Deposit>();
+            cfg.CreateMap<Replenishment, ReplenishmentDataModel>();
+        });
+        _mapper = new Mapper(config);
+    }
+    public List<DepositDataModel> GetList(string? clerkId = null)
+    {
+        try
+        {
+            var query = _dbContext.Deposits.Include(x => x.Clerk).AsQueryable();
+            if (clerkId is not null)
+            {
+                query = query.Where(x => x.ClerkId == clerkId);
+            }
+            return [.. query.Select(x => _mapper.Map<DepositDataModel>(x))];
+        }
+        catch (Exception ex)
+        {
+            _dbContext.ChangeTracker.Clear();
+            throw new StorageException(ex.Message);
+        }
+    }
+
+    public DepositDataModel? GetElementById(string id)
+    {
+        try
+        {
+            return _mapper.Map<DepositDataModel>(_dbContext.Deposits.FirstOrDefault(x => x.Id == id));
+        }
+        catch (Exception ex)
+        {
+            _dbContext.ChangeTracker.Clear();
+            throw new StorageException(ex.Message);
+        }
+    }
+
+    public DepositDataModel? GetElementByInterestRate(float interestRate)
+    {
+        try
+        {
+            return _mapper.Map<DepositDataModel>(_dbContext.Deposits.Include(x => x.Clerk).FirstOrDefault(x => x.InterestRate == interestRate));
+        }
+        catch (Exception ex)
+        {
+            _dbContext.ChangeTracker.Clear();
+            throw new StorageException(ex.Message);
+        }
+    }
+
+    public void AddElement(DepositDataModel depositDataModel)
+    {
+        try
+        {
+            _dbContext.Deposits.Add(_mapper.Map<Deposit>(depositDataModel));
+            _dbContext.SaveChanges();
+        }
+        catch (InvalidOperationException ex) when (ex.TargetSite?.Name == "ThrowIdentityConflict")
+        {
+            _dbContext.ChangeTracker.Clear();
+            throw new ElementExistsException($"Id {depositDataModel.Id }");
+        }
+        catch (DbUpdateException ex) when (ex.InnerException is PostgresException { ConstraintName: "IX_Deposits_InterestRate" })
+        {
+            _dbContext.ChangeTracker.Clear();
+            throw new ElementExistsException($"InterestRate {depositDataModel.InterestRate}");
+        }
+        catch (Exception ex)
+        {
+            _dbContext.ChangeTracker.Clear();
+            throw new StorageException(ex.Message);
+        }
+    }
+
+    public void UpdElement(DepositDataModel depositDataModel)
+    {
+        try
+        {
+            var transaction = _dbContext.Database.BeginTransaction();
+            try
+            {
+                var element = GetDepositById(depositDataModel.Id) ?? throw new ElementNotFoundException(depositDataModel.Id);
+
+                if (depositDataModel.Currencies != null)
+                {
+                    if (element.DepositCurrencies != null || element.DepositCurrencies?.Count >= 0)
+                    {
+                        _dbContext.DepositCurrencies.RemoveRange(element.DepositCurrencies);
+                    }
+
+                    element.Components = _mapper.Map<List<ShipComponents>>(shipDataModel.Components);
+                }
+                _dbContext.SaveChanges();
+                transaction.Commit();
+            }
+            catch
+            {
+                transaction.Rollback();
+                throw;
+            }
+        }
+        catch (ElementNotFoundException)
+        {
+            _dbContext.ChangeTracker.Clear();
+            throw;
+        }
+        catch (DbUpdateException ex) when (ex.InnerException is PostgresException { ConstraintName: "IX_Ships_Name" })
+        {
+            _dbContext.ChangeTracker.Clear();
+            throw new ElementExistsException("Name", shipDataModel.Name);
+        }
+        catch (Exception ex) when (ex is ElementDeletedException || ex is ElementNotFoundException)
+        {
+            _dbContext.ChangeTracker.Clear();
+            throw;
+        }
+        catch (Exception ex)
+        {
+            _dbContext.ChangeTracker.Clear();
+            throw new StorageException(ex);
+        }
+    }
+
+    private Deposit? GetDepositById(string id) => _dbContext.Deposits.FirstOrDefault(x => x.Id == id);
+}