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

namespace CMSDAL.CustomCode.ContentContainer;
public class ContentContainerDAL : IContentContainerDAL
{
    private readonly IQueryExecutor _qe;
    public ContentContainerDAL(IQueryExecutor qe) => _qe = qe;

    public async Task<string> GetByContentAsync(int contentId, LoginDTO loginDTO, CancellationToken ct)
    {
        try
        {
            var result = await _qe.QueryAsync<ContentContainerDTO>(loginDTO, ContentContainerQB.GET_BY_CONTENT,
                new { ContentId = contentId, TenantId = loginDTO.ClientId }, cancellationToken: ct);
            return JsonConvert.SerializeObject(result);
        }
        catch { throw; }
    }

    public async Task<string> SaveAsync(ContentContainerDTO dto, LoginDTO loginDTO, CancellationToken ct)
    {
        try
        {
            if (dto.ContentContainerId == 0)
            {
                int newContentContainerId = await _qe.ExecuteIdentityAsync(loginDTO, ContentContainerQB.INSERT,
                    new { dto.ContentId, dto.ContainerTypeId, dto.PositionNo, dto.ContainerLabel,
                          dto.CssClassJson, TenantId = loginDTO.ClientId,
                          CreatedById = loginDTO.UserId, ModifiedById = loginDTO.UserId });
                dto.ContentContainerId = newContentContainerId;
                return SuccessResponse.SaveSuccessMessage;
            }
            else
            {
                await _qe.ExecuteAsync(loginDTO, ContentContainerQB.UPDATE_POSITION,
                    new { dto.ContentContainerId, dto.PositionNo, TenantId = loginDTO.ClientId, ModifiedById = loginDTO.UserId },
                    cancellationToken: ct);
                return SuccessResponse.UpdateSuccessMessage;
            }
        }
        catch { throw; }
    }

    public async Task<string> ReorderAsync(int contentContainerId, short positionNo, LoginDTO loginDTO, CancellationToken ct)
    {
        try
        {
            await _qe.ExecuteAsync(loginDTO, ContentContainerQB.UPDATE_POSITION,
                new { ContentContainerId = contentContainerId, PositionNo = positionNo,
                      TenantId = loginDTO.ClientId, ModifiedById = loginDTO.UserId },
                cancellationToken: ct);
            return SuccessResponse.UpdateSuccessMessage;
        }
        catch { throw; }
    }

    public async Task<string> DeleteAsync(int contentContainerId, LoginDTO loginDTO, CancellationToken ct)
    {
        try
        {
            await _qe.ExecuteAsync(loginDTO, ContentContainerQB.SOFT_DELETE,
                new { ContentContainerId = contentContainerId, TenantId = loginDTO.ClientId, ModifiedById = loginDTO.UserId },
                cancellationToken: ct);
            return SuccessResponse.DeleteSuccessMessage;
        }
        catch { throw; }
    }

    public async Task<int?> GetContentTenantIdAsync(int contentId, LoginDTO loginDTO, CancellationToken ct)
    {
        try
        {
            var result = await _qe.QueryAsync<int?>(loginDTO, ContentContainerQB.GET_CONTENT_TENANT,
                new { ContentId = contentId }, cancellationToken: ct);
            return result.FirstOrDefault();
        }
        catch { throw; }
    }
}