using Application.Common.Repositories; using Application.Features.InventoryTransactionManager; using Domain.Entities; using Domain.Enums; using FluentValidation; using MediatR; namespace Application.Features.StockCountManager.Commands; public class DeleteStockCountResult { public StockCount? Data { get; set; } } public class DeleteStockCountRequest : IRequest { public string? Id { get; init; } public string? DeletedById { get; init; } } public class DeleteStockCountValidator : AbstractValidator { public DeleteStockCountValidator() { RuleFor(x => x.Id).NotEmpty(); } } public class DeleteStockCountHandler : IRequestHandler { private readonly ICommandRepository _repository; private readonly IUnitOfWork _unitOfWork; private readonly InventoryTransactionService _inventoryTransactionService; public DeleteStockCountHandler( ICommandRepository repository, IUnitOfWork unitOfWork, InventoryTransactionService inventoryTransactionService ) { _repository = repository; _unitOfWork = unitOfWork; _inventoryTransactionService = inventoryTransactionService; } public async Task Handle(DeleteStockCountRequest request, CancellationToken cancellationToken) { var entity = await _repository.GetAsync(request.Id ?? string.Empty, cancellationToken); if (entity == null) { throw new Exception($"Entity not found: {request.Id}"); } entity.UpdatedById = request.DeletedById; _repository.Delete(entity); await _unitOfWork.SaveAsync(cancellationToken); await _inventoryTransactionService.PropagateParentUpdate( entity.Id, nameof(StockCount), entity.CountDate, (InventoryTransactionStatus?)entity.Status, entity.IsDeleted, entity.UpdatedById, null, cancellationToken ); return new DeleteStockCountResult { Data = entity }; } }