using GB5Shared.DTO.Framework.Criteria;
using GB5Shared.DTO.Framework.Login;
using GB5Shared.QueryExecutor;
using Newtonsoft.Json;
using TMSDAL.DTO.TxSkillUpgrade;
using TMSDAL.Query.TxSkillUpgrade;

namespace TMSDAL.CustomCode.TxSkillUpgrade
{
    public class TxSkillUpgradeDAL : ITxSkillUpgradeDAL
    {
        private readonly IQueryExecutor _QueryExecutor;

        public TxSkillUpgradeDAL(IQueryExecutor QueryExecutor)
        {
            _QueryExecutor = QueryExecutor;
        }

        public async Task<string> GetTxSkillUpgrade(int txSkillUpgradeId, LoginDTO loginDTO, CancellationToken ct)
        {
            try
            {
                var result = await _QueryExecutor.QuerySingleAsync<TxSkillUpgradeDTO>(
                    loginDTO, TxSkillUpgradeQB.GET_TXSKILLUPGRADE,
                    new { txskillupgradeid = txSkillUpgradeId, tenantid = loginDTO.ClientId },
                    cancellationToken: ct).ConfigureAwait(false);
                return JsonConvert.SerializeObject(result);
            }
            catch (Exception) { throw; }
        }

        public async Task<string> GetTxSkillUpgradeList(int upgradeStatus, LoginDTO loginDTO, CancellationToken ct)
        {
            try
            {
                var result = await _QueryExecutor.QueryAsync<TxSkillUpgradeDTO>(
                    loginDTO, TxSkillUpgradeQB.GET_TXSKILLUPGRADE_LIST,
                    new { upgradestatus = upgradeStatus, tenantid = loginDTO.ClientId },
                    cancellationToken: ct).ConfigureAwait(false);
                return JsonConvert.SerializeObject(result);
            }
            catch (Exception) { throw; }
        }

        public async Task<int> SaveTxSkillUpgrade(TxSkillUpgradeDTO dto, LoginDTO loginDTO, CancellationToken ct)
        {
            try
            {
                return await _QueryExecutor.ExecuteAsync(
                    loginDTO, TxSkillUpgradeQB.SAVE_TXSKILLUPGRADE, dto,
                    cancellationToken: ct).ConfigureAwait(false);
            }
            catch (Exception) { throw; }
        }

        public async Task<string> GetSelectListTxSkillUpgrade(CriteriaDTO criteriaDTO, LoginDTO loginDTO, CancellationToken ct)
        {
            try
            {
                var result = await _QueryExecutor.QueryWithCriteriaAsync<TxSkillUpgradeSelectDTO>(
                    loginDTO, TxSkillUpgradeQB.GET_SELECTLIST_TXSKILLUPGRADE,
                    new { TenantId = loginDTO.ClientId }, criteriaDTO, ct).ConfigureAwait(false);
                return JsonConvert.SerializeObject(result);
            }
            catch (Exception) { throw; }
        }

        public async Task<int> UpdateTxSkillUpgrade(TxSkillUpgradeDTO dto, LoginDTO loginDTO, CancellationToken ct)
        {
            try
            {
                return await _QueryExecutor.ExecuteAsync(
                    loginDTO, TxSkillUpgradeQB.UPDATE_TXSKILLUPGRADE, dto,
                    cancellationToken: ct).ConfigureAwait(false);
            }
            catch (Exception) { throw; }
        }

        public async Task<int> DeleteTxSkillUpgrade(int txSkillUpgradeId, LoginDTO loginDTO, CancellationToken ct)
        {
            try
            {
                return await _QueryExecutor.ExecuteAsync(
                    loginDTO, TxSkillUpgradeQB.DELETE_TXSKILLUPGRADE,
                    new { TxSkillUpgradeId = txSkillUpgradeId, TenantId = loginDTO.ClientId },
                    cancellationToken: ct).ConfigureAwait(false);
            }
            catch (Exception) { throw; }
        }

        public async Task<int> ReviewTxSkillUpgrade(TxSkillUpgradeDTO dto, LoginDTO loginDTO, CancellationToken ct)
        {
            try
            {
                return await _QueryExecutor.ExecuteAsync(
                    loginDTO, TxSkillUpgradeQB.REVIEW_TXSKILLUPGRADE, dto,
                    cancellationToken: ct).ConfigureAwait(false);
            }
            catch (Exception) { throw; }
        }

        public async Task<int> GetEmployeeIdForUpgrade(int txSkillUpgradeId, LoginDTO loginDTO, CancellationToken ct)
        {
            try
            {
                return await _QueryExecutor.QuerySingleAsync<int>(
                    loginDTO, TxSkillUpgradeQB.GET_TXSKILLUPGRADE_EMPLOYEEID,
                    new { txskillupgradeid = txSkillUpgradeId, tenantid = loginDTO.ClientId },
                    cancellationToken: ct).ConfigureAwait(false);
            }
            catch (Exception) { throw; }
        }

        public async Task<int> GetEmployeeIdByEnrollment(int enrollmentId, LoginDTO loginDTO, CancellationToken ct)
        {
            try
            {
                return await _QueryExecutor.QuerySingleAsync<int>(
                    loginDTO, TxSkillUpgradeQB.GET_EMPLOYEEID_BY_ENROLLMENT,
                    new { enrollmentid = enrollmentId, tenantid = loginDTO.ClientId },
                    cancellationToken: ct).ConfigureAwait(false);
            }
            catch (Exception) { throw; }
        }
    }
}