using AccountsDAL.DTO.ETDS;
using AccountsDAL.Query.ETDS;
using GB5Shared.DTO.Framework.Login;
using GB5Shared.QueryExecutor;
using System.Data.Common;

namespace AccountsDAL.CustomCode.ETDS
{
    public class EtdsDAL : IEtdsDAL
    {
        private readonly IQueryExecutor _queryExecutor;

        public EtdsDAL(IQueryExecutor queryExecutor)
        {
            _queryExecutor = queryExecutor;
        }

        public async Task<List<int>> GetTDSReturnIdsForUndo(int ouId, int periodId, string fileType, string formNumber, string periodType, LoginDTO loginDTO)
        {
            var rows = await _queryExecutor
                .QueryAsync<int>(loginDTO, EtdsQB.GET_TDS_RETURN_IDS_FOR_UNDO,
                    new { OUId = ouId, PeriodId = periodId, FileType = fileType, FormNumber = formNumber, PeriodType = periodType })
                .ConfigureAwait(false);
            return rows.ToList();
        }

        public async Task UndoPostingTDSReturnForm(List<int> tdsReturnIds, LoginDTO loginDTO, DbTransaction tx)
        {
            var param = new { TDSReturnIds = tdsReturnIds };

            await _queryExecutor.ExecuteAsync(loginDTO, EtdsQB.DELETE_TDS_SECTION6A, param, tx).ConfigureAwait(false);
            await _queryExecutor.ExecuteAsync(loginDTO, EtdsQB.DELETE_TDS_SECTION16, param, tx).ConfigureAwait(false);
            await _queryExecutor.ExecuteAsync(loginDTO, EtdsQB.DELETE_TDS_SALARY_DETAIL, param, tx).ConfigureAwait(false);
            await _queryExecutor.ExecuteAsync(loginDTO, EtdsQB.DELETE_TDS_RETURN_EMPLOYEE, param, tx).ConfigureAwait(false);
            await _queryExecutor.ExecuteAsync(loginDTO, EtdsQB.DELETE_TDS_RETURN_CHALLAN, param, tx).ConfigureAwait(false);
            await _queryExecutor.ExecuteAsync(loginDTO, EtdsQB.DELETE_TDS_RETURN_BATCH, param, tx).ConfigureAwait(false);
            await _queryExecutor.ExecuteAsync(loginDTO, EtdsQB.DELETE_TDS_RETURN, param, tx).ConfigureAwait(false);
        }

        // ── Form24Q123 / GetTDSReturnForm ────────────────────────────────────

        public async Task<TDSReturnDTO?> GetTDSReturn(int tdsReturnId, LoginDTO loginDTO)
        {
            var rows = await _queryExecutor
                .QueryAsync<TDSReturnDTO>(loginDTO, EtdsQB.GET_ETDS_FORM_TDSRETURN, new { TDSReturnId = tdsReturnId })
                .ConfigureAwait(false);
            return rows.FirstOrDefault();
        }

        public async Task<List<TDSRetrunBatchDTO>> GetTDSReturnBatch(int tdsReturnId, LoginDTO loginDTO)
        {
            var rows = await _queryExecutor
                .QueryAsync<TDSRetrunBatchDTO>(loginDTO, EtdsQB.GET_ETDS_FORM_TDSRETURN_BATCH, new { TDSReturnId = tdsReturnId })
                .ConfigureAwait(false);
            return rows.ToList();
        }

        public async Task<List<TDSReturnChallanDTO>> GetTDSReturnChallan(int tdsReturnId, LoginDTO loginDTO)
        {
            var rows = await _queryExecutor
                .QueryAsync<TDSReturnChallanDTO>(loginDTO, EtdsQB.GET_ETDS_FORM_TDSRETURN_CHALLAN, new { TDSReturnId = tdsReturnId })
                .ConfigureAwait(false);
            return rows.ToList();
        }

        public async Task<List<TDSReturnEmployeeDTO>> GetTDSReturnEmployee(int tdsReturnId, LoginDTO loginDTO)
        {
            var rows = await _queryExecutor
                .QueryAsync<TDSReturnEmployeeDTO>(loginDTO, EtdsQB.GET_ETDS_FORM_TDSRETURN_EMPLOYEE, new { TDSReturnId = tdsReturnId })
                .ConfigureAwait(false);
            return rows.ToList();
        }

        public async Task<List<TDSSalaryDetailDTO>> GetTDSSalaryDetail(int tdsReturnId, LoginDTO loginDTO)
        {
            var rows = await _queryExecutor
                .QueryAsync<TDSSalaryDetailDTO>(loginDTO, EtdsQB.GET_ETDS_FORM_TDSSALARY_DETAIL, new { TDSReturnId = tdsReturnId })
                .ConfigureAwait(false);
            return rows.ToList();
        }

        public async Task<List<TDSSection16DTO>> GetTDSSection16(int tdsReturnId, LoginDTO loginDTO)
        {
            var rows = await _queryExecutor
                .QueryAsync<TDSSection16DTO>(loginDTO, EtdsQB.GET_ETDS_FORM_TDSSECTION16_DETAIL, new { TDSReturnId = tdsReturnId })
                .ConfigureAwait(false);
            return rows.ToList();
        }

        public async Task<List<TDSSection6ADTO>> GetTDSSection6A(int tdsReturnId, LoginDTO loginDTO)
        {
            var rows = await _queryExecutor
                .QueryAsync<TDSSection6ADTO>(loginDTO, EtdsQB.GET_ETDS_FORM_TDSSECTION6A_DETAIL, new { TDSReturnId = tdsReturnId })
                .ConfigureAwait(false);
            return rows.ToList();
        }
    }
}