using GB5Shared.Signatory.DTO;
using GB5Shared.Signatory.Query;
using GB5Shared.DTO.Framework.Criteria;
using GB5Shared.DTO.Framework.Login;
using GB5Shared.QueryExecutor;
using GB5Shared.Resource.Response;
using GB5Shared.Validation;
using Newtonsoft.Json;

namespace GB5Shared.Signatory
{
    public class SignatoryDAL : ISignatoryDAL
    {
        private readonly IQueryExecutor _QueryExecutor;
        private readonly IValidation _Validation;

        public SignatoryDAL(IQueryExecutor QueryExecutor, IValidation Validation)
        {
            _QueryExecutor = QueryExecutor;
            _Validation = Validation;
        }

        public async Task<string> GetSignatory(int signatoryId, LoginDTO loginDTO, CancellationToken ct)
        {
            try
            {
                var result = await _QueryExecutor.QuerySingleAsync<SignatoryDTO>(
                    loginDTO, SignatoryQB.GET_SIGNATORY,
                    new { signatoryid = signatoryId, tenantid = loginDTO.ClientId },
                    cancellationToken: ct).ConfigureAwait(false);
                return JsonConvert.SerializeObject(result);
            }
            catch (Exception)
            {
                throw;
            }
        }

        public async Task<string> GetActiveSignatoryByModule(int moduleId, LoginDTO loginDTO, CancellationToken ct)
        {
            try
            {
                var result = await _QueryExecutor.QueryAsync<SignatoryDTO>(
                    loginDTO, SignatoryQB.GET_ACTIVE_SIGNATORY_BY_MODULE,
                    new { moduleid = moduleId, tenantid = loginDTO.ClientId },
                    cancellationToken: ct).ConfigureAwait(false);
                return JsonConvert.SerializeObject(result.FirstOrDefault());
            }
            catch (Exception)
            {
                throw;
            }
        }

        public async Task<string> GetSelectListSignatory(CriteriaDTO criteriaDTO, LoginDTO loginDTO, CancellationToken ct)
        {
            try
            {
                var result = await _QueryExecutor.QueryAsync<SignatoryPicklistDTO>(
                    loginDTO, SignatoryQB.GET_SELECTLIST_SIGNATORY,
                    new { tenantid = loginDTO.ClientId },
                    cancellationToken: ct).ConfigureAwait(false);
                return JsonConvert.SerializeObject(result);
            }
            catch (Exception)
            {
                throw;
            }
        }

        public async Task<int> SaveSignatory(SignatoryDTO signatoryDTO, LoginDTO loginDTO, CancellationToken ct)
        {
            try
            {
                return await _QueryExecutor.ExecuteAsync(
                    loginDTO, SignatoryQB.SAVE_SIGNATORY, signatoryDTO,
                    cancellationToken: ct).ConfigureAwait(false);
            }
            catch (Exception ex)
            {
                string error = await _Validation.HandleException(ex, ErrorResponse.SaveErrorMessage);
                throw new Exception(error);
            }
        }

        public async Task<int> UpdateSignatory(SignatoryDTO signatoryDTO, LoginDTO loginDTO, CancellationToken ct)
        {
            try
            {
                return await _QueryExecutor.ExecuteAsync(
                    loginDTO, SignatoryQB.UPDATE_SIGNATORY, signatoryDTO,
                    cancellationToken: ct).ConfigureAwait(false);
            }
            catch (Exception ex)
            {
                string error = await _Validation.HandleException(ex, ErrorResponse.UpdateErrorMessage);
                throw new Exception(error);
            }
        }

        public async Task<string> DeleteSignatory(int signatoryId, LoginDTO loginDTO, CancellationToken ct)
        {
            try
            {
                var result = await _QueryExecutor.ExecuteAsync(
                    loginDTO, SignatoryQB.DELETE_SIGNATORY,
                    new { signatoryid = signatoryId, tenantid = loginDTO.ClientId },
                    cancellationToken: ct).ConfigureAwait(false);

                return result > 0 ? SuccessResponse.DeleteSuccessMessage : ErrorResponse.DeleteNotFoundMessage;
            }
            catch (Exception ex)
            {
                string error = await _Validation.HandleException(ex, ErrorResponse.DeleteErrorMessage);
                throw new Exception(error);
            }
        }
    }
}