Add store KYC document management

Distribution/Features/Store/Kyc/IStoreKycDocumentRepository.cs

@@ -0,0 +1,7 @@
+namespace Distribution.Features.Store.Kyc;
+
+public interface IStoreKycDocumentRepository
+{
+    Task<List<Models.StoreKycDocument>> GetByStoreIdAsync(Guid storeId);
+    Task AddAsync(Models.StoreKycDocument entity);
+}

Distribution/Features/Store/Kyc/StoreKycDocumentController.cs

@@ -0,0 +1,26 @@
+using Microsoft.AspNetCore.Authorization;
+using Microsoft.AspNetCore.Mvc;
+
+namespace Distribution.Features.Store.Kyc;
+
+[ApiController]
+[Route("api/stores/{storeId:guid}/kyc-documents")]
+[Authorize]
+public class StoreKycDocumentController(StoreKycDocumentService service) : ControllerBase
+{
+    [HttpGet]
+    [Authorize(Policy = "stores.view")]
+    public async Task<IActionResult> GetByStoreId(Guid storeId)
+    {
+        var result = await service.GetByStoreIdAsync(storeId);
+        return result is null ? NotFound() : Ok(result);
+    }
+
+    [HttpPost]
+    [Authorize(Policy = "stores.update")]
+    public async Task<IActionResult> Upload(Guid storeId, [FromForm] string documentType, [FromForm] IFormFile file, CancellationToken ct)
+    {
+        var result = await service.UploadAsync(storeId, new UploadKycDocumentRequest(documentType, file), ct);
+        return result is null ? NotFound() : Ok(result);
+    }
+}

Distribution/Features/Store/Kyc/StoreKycDocumentDTOs.cs

@@ -0,0 +1,5 @@
+namespace Distribution.Features.Store.Kyc;
+
+public record UploadKycDocumentRequest(string DocumentType, IFormFile File);
+
+public record StoreKycDocumentResponse(Guid Id, Guid StoreId, string DocumentType, string FileReference, DateTime UploadedAt);

Distribution/Features/Store/Kyc/StoreKycDocumentRepository.cs

@@ -0,0 +1,13 @@
+using Distribution.Data;
+using Microsoft.EntityFrameworkCore;
+
+namespace Distribution.Features.Store.Kyc;
+
+public class StoreKycDocumentRepository(AppDBContext context) : IStoreKycDocumentRepository
+{
+    public async Task<List<Models.StoreKycDocument>> GetByStoreIdAsync(Guid storeId) =>
+        await context.StoreKycDocuments.Where(d => d.FK_StoreId == storeId && d.IsActive).ToListAsync();
+
+    public async Task AddAsync(Models.StoreKycDocument entity) =>
+        await context.StoreKycDocuments.AddAsync(entity);
+}

Distribution/Features/Store/Kyc/StoreKycDocumentService.cs

@@ -0,0 +1,71 @@
+using Distribution.Infra.Authorization;
+using Distribution.Infra.UoW;
+
+namespace Distribution.Features.Store.Kyc;
+
+public class StoreKycDocumentService(
+    IStoreKycDocumentRepository repo,
+    IStoreRepository storeRepo,
+    IUnitOfWork uow,
+    ICurrentUserService currentUser,
+    IScopeAccessService scopeAccess,
+    IWebHostEnvironment env)
+{
+    private const int GlobalScopeRoleLevel = 50;
+
+    private bool HasGlobalScope => currentUser.RoleLevel >= GlobalScopeRoleLevel;
+
+    private async Task<bool> HasStoreScopeAsync(Guid storeId)
+    {
+        if (HasGlobalScope || currentUser.UserId is null) return HasGlobalScope;
+        return await scopeAccess.HasStoreScopeAsync(currentUser.UserId.Value, storeId);
+    }
+
+    private static StoreKycDocumentResponse ToResponse(Models.StoreKycDocument d) =>
+        new(d.Id, d.FK_StoreId, d.DocumentType, d.FileReference, d.UploadedAt);
+
+    public async Task<List<StoreKycDocumentResponse>?> GetByStoreIdAsync(Guid storeId)
+    {
+        if (!await HasStoreScopeAsync(storeId)) return null;
+        var docs = await repo.GetByStoreIdAsync(storeId);
+        return docs.Select(ToResponse).ToList();
+    }
+
+    public async Task<StoreKycDocumentResponse?> UploadAsync(Guid storeId, UploadKycDocumentRequest request, CancellationToken ct = default)
+    {
+        var store = await storeRepo.GetByIdAsync(storeId);
+        if (store is null || !store.IsActive) return null;
+        if (!await HasStoreScopeAsync(storeId)) return null;
+
+        var uploadsRoot = Path.Combine(env.ContentRootPath, "wwwroot", "uploads", "kyc", storeId.ToString());
+        Directory.CreateDirectory(uploadsRoot);
+        var fileName = $"{Guid.NewGuid()}{Path.GetExtension(request.File.FileName)}";
+        var filePath = Path.Combine(uploadsRoot, fileName);
+        await using (var stream = new FileStream(filePath, FileMode.Create))
+        {
+            await request.File.CopyToAsync(stream, ct);
+        }
+        var fileReference = $"uploads/kyc/{storeId}/{fileName}";
+
+        var doc = new Models.StoreKycDocument
+        {
+            FK_StoreId = storeId,
+            DocumentType = request.DocumentType,
+            FileReference = fileReference,
+            UploadedAt = DateTime.Now
+        };
+
+        await uow.BeginAsync(ct);
+        try
+        {
+            await repo.AddAsync(doc);
+            await uow.CommitAsync(ct);
+        }
+        catch
+        {
+            await uow.RollbackAsync(ct);
+            throw;
+        }
+        return ToResponse(doc);
+    }
+}

Distribution/Program.cs

@@ -9,6 +9,7 @@ using Distribution.Features.Region;
 using Distribution.Features.Role;
 using Distribution.Features.Route;
 using Distribution.Features.Store;
+using Distribution.Features.Store.Kyc;
 using Distribution.Features.Sync;
 using Distribution.Features.Uom;
 using Distribution.Features.User;
@@ -46,6 +47,7 @@ builder.Services.AddScoped<IBrandRepository, BrandRepository>();
 builder.Services.AddScoped<IUomRepository, UomRepository>();
 builder.Services.AddScoped<IItemRepository, ItemRepository>();
 builder.Services.AddScoped<IStockRepository, StockRepository>();
+builder.Services.AddScoped<IStoreKycDocumentRepository, StoreKycDocumentRepository>();
 
 builder.Services.AddScoped<RegionService>();
 builder.Services.AddScoped<RouteService>();
@@ -62,6 +64,7 @@ builder.Services.AddScoped<UomService>();
 builder.Services.AddScoped<ItemService>();
 builder.Services.AddScoped<SyncService>();
 builder.Services.AddScoped<StockService>();
+builder.Services.AddScoped<StoreKycDocumentService>();
 
 builder.Services.AddHttpContextAccessor();
 builder.Services.AddScoped<ICurrentUserService, CurrentUserService>();