using CMSDAL.DTO.Channel;
using CMSDAL.Query.Channel;
using GB5Shared.DTO.Framework.Login;
using GB5Shared.QueryExecutor;
using GB5Shared.Resource.Response;
using Newtonsoft.Json;

namespace CMSDAL.CustomCode.Channel;
public class ChannelDAL : IChannelDAL
{
    private readonly IQueryExecutor _qe;
    public ChannelDAL(IQueryExecutor qe) => _qe = qe;

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

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

    public async Task<string> GetChannelContentAsync(int channelId, LoginDTO loginDTO, CancellationToken ct)
    {
        try
        {
            var result = await _qe.QueryAsync<ChannelContentDTO>(loginDTO, ChannelQB.GET_CHANNEL_CONTENT,
                new { ChannelId = channelId, TenantId = loginDTO.ClientId }, cancellationToken: ct);
            return JsonConvert.SerializeObject(result);
        }
        catch { throw; }
    }

    public async Task<string> SaveAsync(ChannelDTO dto, LoginDTO loginDTO, CancellationToken ct)
    {
        try
        {
            if (dto.ChannelId == 0)
            {
                await _qe.ExecuteAsync(loginDTO, ChannelQB.INSERT,
                    new { dto.ChannelCode, dto.ChannelName, dto.Description, dto.Visibility,
                          dto.ColorCode, dto.IconName, dto.DefaultFiltersJson, dto.Status,
                          TenantId = loginDTO.ClientId, CreatedById = loginDTO.UserId, ModifiedById = loginDTO.UserId },
                    cancellationToken: ct);
                return SuccessResponse.SaveSuccessMessage;
            }
            else
            {
                await _qe.ExecuteAsync(loginDTO, ChannelQB.UPDATE,
                    new { dto.ChannelId, dto.ChannelName, dto.Description, dto.Visibility,
                          dto.ColorCode, dto.IconName, dto.DefaultFiltersJson, dto.Status,
                          TenantId = loginDTO.ClientId, ModifiedById = loginDTO.UserId },
                    cancellationToken: ct);
                return SuccessResponse.UpdateSuccessMessage;
            }
        }
        catch { throw; }
    }

    public async Task<string> AddChannelContentAsync(AddChannelContentDTO dto, LoginDTO loginDTO, CancellationToken ct)
    {
        try
        {
            await _qe.ExecuteAsync(loginDTO, ChannelQB.ADD_CHANNEL_CONTENT,
                new { dto.ChannelId, dto.ContentId, dto.Pinned, dto.PositionNo,
                      AddedById = loginDTO.UserId, TenantId = loginDTO.ClientId },
                cancellationToken: ct);
            return SuccessResponse.SaveSuccessMessage;
        }
        catch { throw; }
    }

    public async Task<IEnumerable<ChannelContentDTO>> GetPublishedChannelContentAsync(int channelId, LoginDTO loginDTO, CancellationToken ct)
        => await _qe.QueryAsync<ChannelContentDTO>(loginDTO, ChannelQB.GET_PUBLISHED_CHANNEL_CONTENT,
            new { ChannelId = channelId, TenantId = loginDTO.ClientId }, cancellationToken: ct);
}