using Application.Common.CQS.Queries; using Application.Common.Extensions; using AutoMapper; using Domain.Entities; using FluentValidation; using MediatR; using Microsoft.EntityFrameworkCore; namespace Application.Features.TransferOutManager.Queries; public class GetTransferOutSingleProfile : Profile { public GetTransferOutSingleProfile() { } } public class GetTransferOutSingleResult { public TransferOut? Data { get; init; } public List? TransactionList { get; init; } } public class GetTransferOutSingleRequest : IRequest { public string? Id { get; init; } } public class GetTransferOutSingleValidator : AbstractValidator { public GetTransferOutSingleValidator() { RuleFor(x => x.Id).NotEmpty(); } } public class GetTransferOutSingleHandler : IRequestHandler { private readonly IQueryContext _context; public GetTransferOutSingleHandler( IQueryContext context ) { _context = context; } public async Task Handle(GetTransferOutSingleRequest request, CancellationToken cancellationToken) { var queryData = _context .TransferOut .AsNoTracking() .Include(x => x.WarehouseFrom) .Include(x => x.WarehouseTo) .Where(x => x.Id == request.Id) .AsQueryable(); var data = await queryData.SingleOrDefaultAsync(cancellationToken); var queryTransactionList = _context .InventoryTransaction .AsNoTracking() .ApplyIsDeletedFilter(false) .Include(x => x.Product) .Include(x => x.Warehouse) .Include(x => x.WarehouseFrom) .Include(x => x.WarehouseTo) .Where(x => x.ModuleId == request.Id && x.ModuleName == nameof(TransferOut)) .AsQueryable(); var transactionList = await queryTransactionList.ToListAsync(cancellationToken); return new GetTransferOutSingleResult { Data = data, TransactionList = transactionList }; } }