fix: fix upload bugs on adding existing files

src/Application/Interfaces/Repositories/IAccountRepository.cs

@@ -7,4 +7,5 @@ public interface IAccountRepository
     Task CreateBulkAsync(List<Account> accounts);
     Task<Account?> GetByIdAsync(long accountId);
     Task<List<Account>> GetAllAccounts();
+    Task<List<long>> GetAllIdsAsync();
 }

src/Application/Interfaces/Repositories/ITransactionRepository.cs

@@ -8,4 +8,5 @@ public interface ITransactionRepository
     Task<List<Transaction>> GetAllTransactions();
     Task<List<Transaction>> GetBySourceAccountId(long accountId);
     Task<List<Transaction>> GetByDestinationAccountId(long accountId);
+    Task<List<long>> GetAllIdsAsync();
 }

src/Application/Services/DomainService/AccountService.cs

@@ -26,7 +26,10 @@ public async Task<Result> AddAccountsFromCsvAsync(string filePath)
             .ToList();
         try
         {
-            await _accountRepository.CreateBulkAsync(accounts);
+            var existingAccountIds = await _accountRepository.GetAllIdsAsync();
+            var newAccounts = accounts.Where(a => !existingAccountIds.Contains(a.AccountId)).ToList();
+
+            await _accountRepository.CreateBulkAsync(newAccounts);
             return Result.Ok();
         }
         catch (Exception ex)

src/Application/Services/DomainService/TransactionService.cs

@@ -27,7 +27,10 @@ public async Task<Result> AddTransactionsFromCsvAsync(string filePath)
 
         try
         {
-            await _transactionRepository.CreateBulkAsync(transactions);
+            var existingTransactionsIds = await _transactionRepository.GetAllIdsAsync();
+            var newTransactions = transactions.Where(t => !existingTransactionsIds.Contains(t.TransactionId)).ToList();
+
+            await _transactionRepository.CreateBulkAsync(newTransactions);
             return Result.Ok();
         }
         catch (Exception ex)

src/Infrastructure/Repositories/AccountRepository.cs

@@ -29,4 +29,11 @@ public async Task<List<Account>> GetAllAccounts()
     {
         return await _dbContext.Accounts.ToListAsync();
     }
+
+    public async Task<List<long>> GetAllIdsAsync()
+    {
+        return await _dbContext.Accounts
+            .Select(a => a.AccountId)
+            .ToListAsync();
+    }
 }

src/Infrastructure/Repositories/TransactionRepository.cs

@@ -37,4 +37,11 @@ public Task<List<Transaction>> GetByDestinationAccountId(long accountId)
             .Where(transaction => transaction.DestinationAccountId == accountId)
             .ToListAsync();
     }
+
+    public async Task<List<long>> GetAllIdsAsync()
+    {
+        return await _dbContext.Transactions
+            .Select(a => a.TransactionId)
+            .ToListAsync();
+    }
 }