feat(ReadData): Read CSV Data format (#9)

Co-authored-by: AmirReza <[email protected]>

AnalysisData/AnalysisData/AnalysisData.csproj

@@ -7,6 +7,7 @@
     </PropertyGroup>
 
     <ItemGroup>
+        <PackageReference Include="CsvHelper" Version="33.0.1" />
         <PackageReference Include="JWT" Version="10.1.1" />
         <PackageReference Include="Microsoft.AspNetCore.Authentication.JwtBearer" Version="8.0.7" />
         <PackageReference Include="Microsoft.AspNetCore.OpenApi" Version="8.0.7" />

AnalysisData/AnalysisData/Controllers/UploadDataController.cs

@@ -0,0 +1,46 @@
+using AnalysisData.DataProcessService;
+using Microsoft.AspNetCore.Authorization;
+using Microsoft.AspNetCore.Mvc;
+
+namespace AnalysisData.Controllers;
+
+[ApiController]
+[Authorize(Roles = "admin")]
+[Route("api/[controller]")]
+public class DataController : ControllerBase
+{
+    private readonly IDataProcessor _dataProcessor;
+
+    public DataController(IDataProcessor dataProcessor)
+    {
+        _dataProcessor = dataProcessor;
+    }
+
+    [HttpPost("upload/account")]
+    public async Task<IActionResult> UploadAccountFile(IFormFile file)
+    {
+        if (file == null || file.Length == 0)
+        {
+            return BadRequest("File is empty or not provided.");
+        }
+
+        var stream = file.OpenReadStream();
+        await _dataProcessor.ProcessDataAsync(stream, "account");
+
+        return Ok("Account data processed successfully.");
+    }
+
+    [HttpPost("upload/transaction")]
+    public async Task<IActionResult> UploadTransactionFile(IFormFile file)
+    {
+        if (file == null || file.Length == 0)
+        {
+            return BadRequest("File is empty or not provided.");
+        }
+
+        var stream = file.OpenReadStream();
+        await _dataProcessor.ProcessDataAsync(stream, "transaction");
+
+        return Ok("Transaction data processed successfully.");
+    }
+}

AnalysisData/AnalysisData/Data/ApplicationDbContext.cs

@@ -1,4 +1,5 @@
-using Microsoft.EntityFrameworkCore;
+using AnalysisData.DataManage.Model;
+using Microsoft.EntityFrameworkCore;
 
 namespace AnalysisData.Data;
 
@@ -10,5 +11,6 @@ public ApplicationDbContext(DbContextOptions<ApplicationDbContext> options)
     }
     public DbSet<User> Users { get; set; }
     public DbSet<Role> Roles { get; set; }
-
+    public DbSet<Account> Accounts { get; set; }
+    public DbSet<Transaction> Transactions { get; set; }
 }

AnalysisData/AnalysisData/DataManage/Model/Account.cs

@@ -0,0 +1,15 @@
+namespace AnalysisData.DataManage.Model;
+
+public class Account
+{
+    public string AccountID { get; set; }
+    public string CardID { get; set; }
+    public string IBAN { get; set; }
+    public string AccountType { get; set; }
+    public string BranchTelephone { get; set; }
+    public string BranchAdress { get; set; }
+    public string BranchName { get; set; }
+    public string OwnerName { get; set; }
+    public string OwnerLastName { get; set; }
+    public string OwnerID { get; set; }
+}

AnalysisData/AnalysisData/DataManage/Model/Trancsaction.cs

@@ -0,0 +1,21 @@
+using AnalysisData.DataProcessService;
+using CsvHelper.Configuration.Attributes;
+
+namespace AnalysisData.DataManage.Model;
+
+public class Transaction
+{
+    [Name("SourceAcount")]
+    public string SourceAccount { get; set; }
+
+    [Name("DestiantionAccount")]
+    public string DestinationAccount { get; set; }
+
+    public decimal Amount { get; set; }
+
+    public string Date { get; set; }
+
+    public string TransactionID { get; set; }
+
+    public string Type { get; set; }
+}

AnalysisData/AnalysisData/DataProcessService/DataReadProcessor.cs

@@ -0,0 +1,41 @@
+using CsvHelper;
+using System.Globalization;
+using AnalysisData.DataManage.Model;
+using AnalysisData.Repository.AccountRepository.Abstraction;
+using AnalysisData.Repository.TrancsactionRepository.Abstraction;
+using CsvHelper.Configuration;
+
+namespace AnalysisData.DataProcessService;
+
+public class DataReadProcessor : IDataProcessor
+{
+    private readonly IAccountRepository _accountRepository;
+    private readonly ITransactionRepository _transactionRepository;
+
+    public DataReadProcessor(IAccountRepository accountRepository, ITransactionRepository transactionRepository)
+    {
+        _accountRepository = accountRepository;
+        _transactionRepository = transactionRepository;
+    }
+
+    public async Task ProcessDataAsync(Stream fileStream, string fileType)
+    {
+        var reader = new StreamReader(fileStream);
+        var csv = new CsvReader(reader, new CsvHelper.Configuration.CsvConfiguration(CultureInfo.InvariantCulture));
+
+        if (fileType == "account")
+        {
+            var accounts = csv.GetRecords<Account>().ToList();
+            await _accountRepository.AddAccountsAsync(accounts);
+        }
+        else if (fileType == "transaction")
+        {
+            var transactions = csv.GetRecords<Transaction>().ToList();
+            await _transactionRepository.AddTransactionsAsync(transactions);
+        }
+        else
+        {
+            throw new ArgumentException("Invalid file type");
+        }
+    }
+}

AnalysisData/AnalysisData/DataProcessService/IDataProcessor.cs

@@ -0,0 +1,6 @@
+namespace AnalysisData.DataProcessService;
+
+public interface IDataProcessor
+{
+    Task ProcessDataAsync(Stream fileStream, string fileType);
+}