using GB5Shared.DTO.Framework.Login;
using GB5Shared.QueryExecutor;
using MMDAL.DTO.MRPRun;
using MMDAL.Query.MRPRun;

namespace MMDAL.CustomCode.MRPRun
{
    public class MRPReportDAL : IMRPReportDAL
    {
        private readonly IQueryExecutor _QueryExecutor;

        public MRPReportDAL(IQueryExecutor queryExecutor)
            => _QueryExecutor = queryExecutor;

        public async Task<PagedResult<MrpRunShortageReportDTO>> GetShortageReport(
            MRPReportCriteriaDTO criteria, LoginDTO loginDTO, CancellationToken ct)
        {
            var (dataSql, countSql, p) = MRPReportQB.BuildShortageReport(criteria);
            return await ExecutePaged<MrpRunShortageReportDTO>(loginDTO, dataSql, countSql, p, ct)
                .ConfigureAwait(false);
        }

        public async Task<PagedResult<MrpRunShortageReportDTO>> GetStageWiseShortageReport(
            MRPReportCriteriaDTO criteria, LoginDTO loginDTO, CancellationToken ct)
        {
            var (dataSql, countSql, p) = MRPReportQB.BuildStageWiseShortageReport(criteria);
            return await ExecutePaged<MrpRunShortageReportDTO>(loginDTO, dataSql, countSql, p, ct)
                .ConfigureAwait(false);
        }

        public async Task<PagedResult<MRPRunDetailReportDTO>> GetMRPWorksheet(
            MRPReportCriteriaDTO criteria, LoginDTO loginDTO, CancellationToken ct)
        {
            var (dataSql, countSql, p) = MRPReportQB.BuildMRPWorksheet(criteria);
            return await ExecutePaged<MRPRunDetailReportDTO>(loginDTO, dataSql, countSql, p, ct)
                .ConfigureAwait(false);
        }

        public async Task<PagedResult<PurchaseRequirementCalculationReportDTO>> GetPurchaseRequirement(
            MRPReportCriteriaDTO criteria, LoginDTO loginDTO, CancellationToken ct)
        {
            var (dataSql, countSql, p) = MRPReportQB.BuildPurchaseRequirement(criteria);
            return await ExecutePaged<PurchaseRequirementCalculationReportDTO>(loginDTO, dataSql, countSql, p, ct)
                .ConfigureAwait(false);
        }

        public async Task<PagedResult<MRPRunScheduleReceiptReportDTO>> GetScheduleReceipt(
            MRPReportCriteriaDTO criteria, LoginDTO loginDTO, CancellationToken ct)
        {
            var (dataSql, countSql, p) = MRPReportQB.BuildScheduleReceipt(criteria);
            return await ExecutePaged<MRPRunScheduleReceiptReportDTO>(loginDTO, dataSql, countSql, p, ct)
                .ConfigureAwait(false);
        }

        public async Task<PagedResult<MRPRunWithActionReportDTO>> GetMRPRunWithActions(
            MRPReportCriteriaDTO criteria, LoginDTO loginDTO, CancellationToken ct)
        {
            var (dataSql, countSql, p) = MRPReportQB.BuildMRPRunWithActions(criteria);
            return await ExecutePaged<MRPRunWithActionReportDTO>(loginDTO, dataSql, countSql, p, ct)
                .ConfigureAwait(false);
        }

        public async Task<PagedResult<MRPWithDimensionDTO>> GetMRPWithDimensionReport(
            MRPReportCriteriaDTO criteria, LoginDTO loginDTO, CancellationToken ct)
        {
            var (dataSql, countSql, p) = MRPReportQB.BuildMRPWithDimension(criteria);
            return await ExecutePaged<MRPWithDimensionDTO>(loginDTO, dataSql, countSql, p, ct)
                .ConfigureAwait(false);
        }

        public async Task<PagedResult<ScopedRunComparisonDTO>> GetScopedRunComparison(
            ScopedRunComparisonCriteriaDTO criteria, LoginDTO loginDTO, CancellationToken ct)
        {
            var (dataSql, countSql, p) = MRPReportQB.BuildScopedRunComparison(criteria, loginDTO);
            return await ExecutePaged<ScopedRunComparisonDTO>(loginDTO, dataSql, countSql, p, ct)
                .ConfigureAwait(false);
        }

        private async Task<PagedResult<T>> ExecutePaged<T>(
            LoginDTO loginDTO, string dataSql, string countSql, Dapper.DynamicParameters p, CancellationToken ct)
        {
            var items = await _QueryExecutor
                .QueryAsync<T>(loginDTO, dataSql, p, cancellationToken: ct)
                .ConfigureAwait(false);

            var total = await _QueryExecutor
                .ExecuteScalarAsync<int>(loginDTO, countSql, p, cancellationToken: ct)
                .ConfigureAwait(false);

            return new PagedResult<T> { Items = items?.ToList() ?? [], TotalCount = total };
        }
    }
}