using GB5Shared.DTO.Framework.Login;
using GB5Shared.QueryExecutor;
using Microsoft.Extensions.Logging;
using MMDAL.DTO.MMHead;
using MMDAL.Query.MM;

namespace MMDAL.CustomCode.MMDocument
{
    public class MMDocumentDAL : IMMDocumentDAL
    {
        private readonly IQueryExecutor _QueryExecutor;
        private readonly ILogger<MMDocumentDAL> _Logger;

        public MMDocumentDAL(IQueryExecutor queryExecutor, ILogger<MMDocumentDAL> logger)
        {
            _QueryExecutor = queryExecutor;
            _Logger = logger;
        }

        public async Task<List<MMDocumentHeadPrintDTO>> GetMMDocumentHeads(
            MMDocumentFilterDTO filter, LoginDTO login, CancellationToken ct)
        {
            var param = new
            {
                filter.FromDocumentId,
                filter.ToDocumentId,
                filter.BizTransactionTypeId,
                filter.BizTransactionClassId,
                filter.BizTransactionSubClassId,
                filter.OUId,
                filter.PartyId,
                filter.PartyBranchId,
                filter.NumberOfCopy,
                filter.CopyNameTypeId,
                filter.IsOriginalOnly,
            };

            var result = await _QueryExecutor.QueryAsync<MMDocumentHeadPrintDTO>(
                login, MMDocumentQB.GET_MM_DOCUMENT_HEAD, param,
                cancellationToken: ct).ConfigureAwait(false);

            return result.ToList();
        }

        public async Task<List<MMDocumentDetailPrintDTO>> GetMMDocumentDetails(
            int[] documentIds, bool includeB2BFields, LoginDTO login, CancellationToken ct)
        {
            if (documentIds.Length == 0) return [];

            var result = await _QueryExecutor.QueryAsync<MMDocumentDetailPrintDTO>(
                login, MMDocumentQB.GET_MM_DOCUMENT_DETAIL,
                new { DocumentIds = documentIds, IncludeB2BFields = includeB2BFields ? 1 : 0 },
                cancellationToken: ct).ConfigureAwait(false);

            return result.ToList();
        }

        public async Task<List<MMDocumentChargePrintDTO>> GetMMDocumentCharges(
            int[] documentIds, LoginDTO login, CancellationToken ct)
        {
            if (documentIds.Length == 0) return [];

            var result = await _QueryExecutor.QueryAsync<MMDocumentChargePrintDTO>(
                login, MMDocumentQB.GET_MM_DOCUMENT_CHARGES,
                new { DocumentIds = documentIds },
                cancellationToken: ct).ConfigureAwait(false);

            return result.ToList();
        }

        public async Task<List<MMHeadTermsDTO>> GetTermsandConditions(
            int[] documentIds, LoginDTO login, CancellationToken ct)
        {
            if (documentIds.Length == 0) return [];

            var result = await _QueryExecutor.QueryAsync<MMHeadTermsDTO>(
                login, MMDocumentQB.GET_MM_DOCUMENT_TERMS,
                new { DocumentIds = documentIds },
                cancellationToken: ct).ConfigureAwait(false);

            return result.ToList();
        }
        
        public async Task<List<MMDocumentLotDetailPrintDTO>> GetMMDocumentLotDetails(
            int[] documentIds, LoginDTO login, CancellationToken ct)
        {
            if (documentIds.Length == 0) return [];

            var result = await _QueryExecutor.QueryAsync<MMDocumentLotDetailPrintDTO>(
                login, MMDocumentQB.GET_MM_DOCUMENT_LOT_DETAIL,
                new { DocumentIds = documentIds },
                cancellationToken: ct).ConfigureAwait(false);

            return result.ToList();
        }

        public async Task<List<MMDocumentSchedulePrintDTO>> GetMMDocumentSchedules(
            int[] documentIds, LoginDTO login, CancellationToken ct)
        {
            if (documentIds.Length == 0) return [];

            var result = await _QueryExecutor.QueryAsync<MMDocumentSchedulePrintDTO>(
                login, MMDocumentQB.GET_MM_DOCUMENT_SCHEDULES,
                new { DocumentIds = documentIds },
                cancellationToken: ct).ConfigureAwait(false);

            return result.ToList();
        }

        public async Task<List<MMDocumentProcessPrintDTO>> GetMMDocumentProcesses(
            int[] documentIds, LoginDTO login, CancellationToken ct)
        {
            if (documentIds.Length == 0) return [];

            var result = await _QueryExecutor.QueryAsync<MMDocumentProcessPrintDTO>(
                login, MMDocumentQB.GET_MM_DOCUMENT_PROCESSES,
                new { DocumentIds = documentIds },
                cancellationToken: ct).ConfigureAwait(false);

            return result.ToList();
        }

        public async Task<List<MMDocumentParameterPrintDTO>> GetMMDocumentParameters(
            int[] documentIds, LoginDTO login, CancellationToken ct)
        {
            if (documentIds.Length == 0) return [];

            var result = await _QueryExecutor.QueryAsync<MMDocumentParameterPrintDTO>(
                login, MMDocumentQB.GET_MM_DOCUMENT_PARAMETERS,
                new { DocumentIds = documentIds },
                cancellationToken: ct).ConfigureAwait(false);

            return result.ToList();
        }

        public async Task<List<MMDocumentAddonPrintDTO>> GetMMDocumentAddons(
            int[] documentIds, LoginDTO login, CancellationToken ct)
        {
            if (documentIds.Length == 0) return [];

            var result = await _QueryExecutor.QueryAsync<MMDocumentAddonPrintDTO>(
                login, MMDocumentQB.GET_MM_DOCUMENT_ADDONS,
                new { DocumentIds = documentIds },
                cancellationToken: ct).ConfigureAwait(false);

            return result.ToList();
        }

        public async Task<List<MMDocumentPackDetailPrintDTO>> GetMMDocumentPackDetails(
            int[] documentIds, LoginDTO login, CancellationToken ct)
        {
            if (documentIds.Length == 0) return [];

            var result = await _QueryExecutor.QueryAsync<MMDocumentPackDetailPrintDTO>(
                login, MMDocumentQB.GET_MM_DOCUMENT_PACK_DETAILS,
                new { DocumentIds = documentIds },
                cancellationToken: ct).ConfigureAwait(false);

            return result.ToList();
        }

        public async Task<List<MMDocumentItemImagePrintDTO>> GetMMDocumentItemImages(
            int[] itemIds, LoginDTO login, CancellationToken ct)
        {
            if (itemIds.Length == 0) return [];

            var result = await _QueryExecutor.QueryAsync<MMDocumentItemImagePrintDTO>(
                login, MMDocumentQB.GET_MM_DOCUMENT_ITEM_IMAGES,
                new { ItemIds = itemIds },
                cancellationToken: ct).ConfigureAwait(false);

            return result.ToList();
        }

        public async Task<List<MMDocumentVoucherDetailPrintDTO>> GetMMDocumentVoucherDetails(
            int[] documentIds, LoginDTO login, CancellationToken ct)
        {
            if (documentIds.Length == 0) return [];

            var result = await _QueryExecutor.QueryAsync<MMDocumentVoucherDetailPrintDTO>(
                login, MMDocumentQB.GET_MM_DOCUMENT_VOUCHER_DETAILS,
                new { DocumentIds = documentIds },
                cancellationToken: ct).ConfigureAwait(false);

            return result.ToList();
        }

        public async Task<List<MMDocumentBillAllocationPrintDTO>> GetMMDocumentBillAllocations(
            int[] documentIds, LoginDTO login, CancellationToken ct)
        {
            if (documentIds.Length == 0) return [];

            var result = await _QueryExecutor.QueryAsync<MMDocumentBillAllocationPrintDTO>(
                login, MMDocumentQB.GET_MM_DOCUMENT_BILL_ALLOCATIONS,
                new { DocumentIds = documentIds },
                cancellationToken: ct).ConfigureAwait(false);

            return result.ToList();
        }

        public async Task<List<MMDocumentCostCenterAllocationPrintDTO>> GetMMDocumentCostCenterAllocations(
            int[] documentIds, LoginDTO login, CancellationToken ct)
        {
            if (documentIds.Length == 0) return [];

            var result = await _QueryExecutor.QueryAsync<MMDocumentCostCenterAllocationPrintDTO>(
                login, MMDocumentQB.GET_MM_DOCUMENT_COST_CENTER_ALLOCATIONS,
                new { DocumentIds = documentIds },
                cancellationToken: ct).ConfigureAwait(false);

            return result.ToList();
        }

        public async Task<List<MMDocumentItemPartyPrintDTO>> GetMMDocumentItemPartyDocuments(
            int[] documentIds, LoginDTO login, CancellationToken ct)
        {
            if (documentIds.Length == 0) return [];

            var result = await _QueryExecutor.QueryAsync<MMDocumentItemPartyPrintDTO>(
                login, MMDocumentQB.GET_MM_DOCUMENT_ITEM_PARTY,
                new { DocumentIds = documentIds },
                cancellationToken: ct).ConfigureAwait(false);

            return result.ToList();
        }

        public async Task<List<MMDocumentPreDocumentChainDTO>> GetMMDocumentPreDocumentChain(
            int[] documentIds, LoginDTO login, CancellationToken ct)
        {
            if (documentIds.Length == 0) return [];

            var result = await _QueryExecutor.QueryAsync<MMDocumentPreDocumentChainDTO>(
                login, MMDocumentQB.GET_MM_DOCUMENT_PRE_DOCUMENTS,
                new { DocumentIds = documentIds },
                cancellationToken: ct).ConfigureAwait(false);

            return result.ToList();
        }
    }
}