using CMSDAL.DTO.ContentContainerType;
using CMSDAL.Query.ContentContainerType;
using GB5Shared.DTO.Framework.Login;
using GB5Shared.QueryExecutor;
using GB5Shared.Resource.Response;
using Newtonsoft.Json;
using System.Linq;

namespace CMSDAL.CustomCode.ContentContainerType;
public class ContentContainerTypeDAL : IContentContainerTypeDAL
{
    private readonly IQueryExecutor _qe;
    public ContentContainerTypeDAL(IQueryExecutor qe) => _qe = qe;

    public async Task<string> GetListAsync(LoginDTO loginDTO, CancellationToken ct)
    {
        try
        {
            var result = await _qe.QueryAsync<ContentContainerTypeDTO>(loginDTO, ContentContainerTypeQB.GET_LIST,
                new { TenantId = loginDTO.ClientId }, cancellationToken: ct);
            return JsonConvert.SerializeObject(result);
        }
        catch { throw; }
    }

    public async Task<string> GetByIdAsync(int containerTypeId, LoginDTO loginDTO, CancellationToken ct)
    {
        try
        {
            var result = await _qe.QuerySingleAsync<ContentContainerTypeDTO>(loginDTO, ContentContainerTypeQB.GET_BY_ID,
                new { ContainerTypeId = containerTypeId, TenantId = loginDTO.ClientId }, cancellationToken: ct);
            return JsonConvert.SerializeObject(result);
        }
        catch { throw; }
    }

    public async Task<string> GetByCodeAsync(string containerTypeCode, LoginDTO loginDTO, CancellationToken ct)
    {
        try
        {
            var result = await _qe.QueryAsync<ContentContainerTypeDTO>(loginDTO, ContentContainerTypeQB.GET_BY_CODE,
                new { ContainerTypeCode = containerTypeCode, TenantId = loginDTO.ClientId }, cancellationToken: ct);
            return JsonConvert.SerializeObject(result.FirstOrDefault());
        }
        catch { throw; }
    }

    public async Task<string> GetSelectListAsync(LoginDTO loginDTO, CancellationToken ct)
    {
        try
        {
            var result = await _qe.QueryAsync<ContentContainerTypePickListDTO>(loginDTO, ContentContainerTypeQB.GET_SELECT_LIST,
                new { TenantId = loginDTO.ClientId }, cancellationToken: ct);
            return JsonConvert.SerializeObject(result);
        }
        catch { throw; }
    }

    public async Task<string> SaveAsync(ContentContainerTypeDTO dto, LoginDTO loginDTO, CancellationToken ct)
    {
        try
        {
            if (dto.ContainerTypeId == 0)
            {
                await _qe.ExecuteAsync(loginDTO, ContentContainerTypeQB.INSERT,
                    new { dto.ContainerTypeCode, dto.ContainerTypeName, dto.ZoneDefinitionsJson,
                          dto.Status, TenantId = loginDTO.ClientId,
                          CreatedById = loginDTO.UserId, ModifiedById = loginDTO.UserId },
                    cancellationToken: ct);
                return SuccessResponse.SaveSuccessMessage;
            }
            else
            {
                await _qe.ExecuteAsync(loginDTO, ContentContainerTypeQB.UPDATE,
                    new { dto.ContainerTypeId, dto.ContainerTypeName, dto.ZoneDefinitionsJson,
                          dto.Status, TenantId = loginDTO.ClientId, ModifiedById = loginDTO.UserId },
                    cancellationToken: ct);
                return SuccessResponse.UpdateSuccessMessage;
            }
        }
        catch { throw; }
    }
}