using GB5Shared.DTO.Framework.Criteria;
using GB5Shared.DTO.Framework.Login;
using GB5Shared.QueryExecutor;
using GB5Shared.Resource.Response;
using GB5Shared.Validation;
using Newtonsoft.Json;
using WiDAL.DTOs;
using WiDAL.Query.Wi;

namespace WiDAL.CustomCode.WiSubProcess;

public class WiSubProcessDAL : IWiSubProcessDAL
{
    private readonly IQueryExecutor _qe; private readonly IValidation _Validation;

    public WiSubProcessDAL(IQueryExecutor qe, IValidation validation)
    {
        _qe = qe;
        _Validation = validation;
    }

    public async Task<string> GetWiSubProcessList(int first, int max, LoginDTO loginDTO)
    {
        var result = await _qe.QueryAsync<WiSubProcessDTO>(
            loginDTO, WiSubProcessQB.GET_LIST_WISUBPROCESS,
            new { firstnumber = first, maxresult = max, TenantId = loginDTO.ClientId })
            .ConfigureAwait(false);
        return JsonConvert.SerializeObject(result);
    }
    

    public async Task<string> GetById(int wiSubProcessId, LoginDTO login, CancellationToken ct)
    {
        var result = await _qe.QuerySingleAsync<WiSubProcessDTO>(login, WiSubProcessQB.GET_BY_ID,
            new { WiSubProcessId = wiSubProcessId, TenantId = login.ClientId });
        return JsonConvert.SerializeObject(result);
    }

    public async Task<int> Save(WiSubProcessDTO dto, bool isNew, LoginDTO login, CancellationToken ct)
    {
        try
        {
            string sql = isNew
                ? WiSubProcessQB.INSERT
                : WiSubProcessQB.UPDATE;

            var rows = await _qe.ExecuteAsync(login, sql, dto);

            if (rows == 0)
            {
                throw new Exception(isNew
                    ? "Insert failed!"
                    : "Update failed! No matching record.");
            }

            return dto.WiSubProcessId;
        }
        catch (Exception ex)
        {
            string error = await _Validation.HandleException(ex,
                isNew ? ErrorResponse.SaveErrorMessage : ErrorResponse.UpdateErrorMessage);

            throw new Exception(error);
        }
    }
    public async Task<string> GetSelectListWiSubProcess(CriteriaDTO criteriaDTO, LoginDTO login, CancellationToken ct)
    {
        var result = await _qe.QueryAsync<dynamic>(
            login, WiSubProcessQB.GET_SELECTLIST_WISUBPROCESS);
        return JsonConvert.SerializeObject(result);
    }
    public async Task<string> DeleteWiSubProcess(int WiSubProcessId, LoginDTO loginDTO)
    {
        try
        {
            string sql = WiSubProcessQB.DELETE_WISUBPROCESS;

            var parameter = new { wiSubProcessId = WiSubProcessId };

            var result = await _qe.ExecuteAsync(loginDTO, sql, parameter);

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