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

namespace CMSDAL.CustomCode.Campaign;
public class CampaignDAL : ICampaignDAL
{
    private readonly IQueryExecutor _qe;
    public CampaignDAL(IQueryExecutor qe) => _qe = qe;

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

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

    public async Task<string> GetAssignmentsAsync(int campaignId, LoginDTO loginDTO, CancellationToken ct)
    {
        try
        {
            var result = await _qe.QueryAsync<AssignmentDTO>(loginDTO, CampaignQB.GET_ASSIGNMENTS,
                new { CampaignId = campaignId, TenantId = loginDTO.ClientId }, cancellationToken: ct);
            return JsonConvert.SerializeObject(result);
        }
        catch { throw; }
    }

    public async Task<string> SaveAsync(CampaignDTO dto, LoginDTO loginDTO, CancellationToken ct)
    {
        try
        {
            if (dto.CampaignId == 0)
            {
                await _qe.ExecuteAsync(loginDTO, CampaignQB.INSERT,
                    new { dto.CampaignCode, dto.CampaignName, dto.CampaignType, dto.Status,
                          dto.AudienceJson, dto.ScheduledOn,
                          TenantId = loginDTO.ClientId, CreatedById = loginDTO.UserId, ModifiedById = loginDTO.UserId },
                    cancellationToken: ct);
                return SuccessResponse.SaveSuccessMessage;
            }
            else
            {
                await _qe.ExecuteAsync(loginDTO, CampaignQB.UPDATE,
                    new { dto.CampaignId, dto.CampaignName, dto.Status, dto.AudienceJson, dto.ScheduledOn,
                          TenantId = loginDTO.ClientId, ModifiedById = loginDTO.UserId },
                    cancellationToken: ct);
                return SuccessResponse.UpdateSuccessMessage;
            }
        }
        catch { throw; }
    }

    public async Task<string> InsertAssignmentAsync(int campaignId, int employeeId, int? contentId, int? learningPathId, DateTime? dueOn, LoginDTO loginDTO, CancellationToken ct)
    {
        try
        {
            await _qe.ExecuteAsync(loginDTO, CampaignQB.INSERT_ASSIGNMENT,
                new { CampaignId = campaignId, ContentId = contentId, LearningPathId = learningPathId,
                      EmployeeId = employeeId, DueOn = dueOn, TenantId = loginDTO.ClientId },
                cancellationToken: ct);
            return SuccessResponse.SaveSuccessMessage;
        }
        catch { throw; }
    }

    public async Task<string> UpdateAssignmentStatusAsync(int assignmentId, byte status, LoginDTO loginDTO, CancellationToken ct)
    {
        await _qe.ExecuteAsync(loginDTO, CampaignQB.UPDATE_ASSIGNMENT_STATUS,
            new { AssignmentId = assignmentId, Status = status, TenantId = loginDTO.ClientId },
            cancellationToken: ct).ConfigureAwait(false);
        return SuccessResponse.UpdateSuccessMessage;
    }
}