using AmpDAL.Query.ApiCapability;
using AMPDAL.DTO.ApiCapability;
using GB5Shared.DTO.Framework.Criteria;
using GB5Shared.DTO.Framework.Login;
using GB5Shared.QueryExecutor;

namespace AmpDAL.CustomCode.ApiCapability;

public class ApiCapabilityDAL(IQueryExecutor _qe) : IApiCapabilityDAL
{
    public async Task<ApiCapabilityDTO?> GetCapabilityAsync(long ApiCapabilityId, int tenantId, LoginDTO login, CancellationToken ct)
        => await _qe.QuerySingleAsync<ApiCapabilityDTO>(
            login,
            ApiCapabilityQB.GET_CAPABILITY,
            new { ApiCapabilityId = ApiCapabilityId, TenantId = tenantId }).ConfigureAwait(false);

    public async Task<List<ApiCapabilityDTO>> GetCapabilityListAsync(CriteriaDTO criteriaDTO, LoginDTO login, CancellationToken ct)
    {
        var result = await _qe.QueryAsync<ApiCapabilityDTO>(
            login,
            ApiCapabilityQB.GET_CAPABILITY_LIST,
            new { TenantId = login.ClientId }).ConfigureAwait(false);
        return result.ToList();
    }

    public async Task<long> SaveCapabilityAsync(ApiCapabilitySaveDTO dto, LoginDTO login, CancellationToken ct)
    => await _qe.ExecuteScalarAsync<long>(
        login,
        ApiCapabilityQB.SAVE_CAPABILITY,
        new
        {
            dto.ApiCapabilityId,   // Primary key for the row
            dto.TenantId,
            dto.ApiId,
            dto.ApiDomainId,
            dto.CapabilityName,
            dto.Description,
            dto.Remarks,
            dto.SortOrder,
            dto.Status,
            dto.Version,
            dto.SourceType,
            dto.CreatedById,
            dto.ModifiedById,
        }).ConfigureAwait(false);

    public async Task<long> UpdateCapabilityAsync(ApiCapabilitySaveDTO dto, LoginDTO login, CancellationToken ct)
    {
        // Ensure ModifiedById is set
        dto.ModifiedById = login.UserId;

        return await _qe.ExecuteScalarAsync<long>(
            login,
            ApiCapabilityQB.UPDATE_CAPABILITY,
            new
            {
                dto.ApiCapabilityId,   // Primary key for the row
                dto.TenantId,
                dto.ApiId,
                dto.ApiDomainId,
                dto.CapabilityName,
                dto.Description,
                dto.Remarks,
                dto.SortOrder,
                dto.Status,
                dto.Version,
                dto.SourceType,
                dto.ModifiedById,
            }).ConfigureAwait(false);
    }
    public async Task<int> SaveCapabilityLinkAsync(SaveApiCapabilityLinkDTO dto, LoginDTO login, CancellationToken ct)
    {
        return await _qe.ExecuteScalarAsync<int>(
            login,
            ApiCapabilityQB.SAVE_CAPABILITY_LINK,
            dto
        ).ConfigureAwait(false);
    }

    public async Task<int> UpdateCapabilityLinkAsync(SaveApiCapabilityLinkDTO dto, LoginDTO login, CancellationToken ct)
    {
        return await _qe.ExecuteScalarAsync<int>(
            login,
            ApiCapabilityQB.UPDATE_CAPABILITY_LINK,
            dto
        ).ConfigureAwait(false);
    }

    public async Task<List<ApiCapabilityDTO>> GetCapabilitySelectListAsync(CriteriaDTO criteriaDTO, LoginDTO login, CancellationToken ct)
    {
        var result = await _qe.QueryAsync<ApiCapabilityDTO>(
            login,
            ApiCapabilityQB.GET_CAPABILITY_SELECT_LIST,
            new { TenantId = login.ClientId }).ConfigureAwait(false);
        return result.ToList();
    }

    public async Task<List<ApiCapabilityDTO>> GetPagedCapabilityList(int firstNumber, int maxResult, LoginDTO login, CancellationToken ct)
    {
        var result = await _qe.QueryAsync<ApiCapabilityDTO>(
            login,
            ApiCapabilityQB.GET_CAPABILITY_LIST_PAGED,
            new { TenantId = login.ClientId, FirstNumber = firstNumber, MaxResult = maxResult }).ConfigureAwait(false);
        return result.ToList();
    }

    public async Task<int> DeleteById(int apiCapabilityId, LoginDTO login, CancellationToken ct)
        => await _qe.ExecuteAsync(
            login,
            ApiCapabilityQB.DELETE_CAPABILITY,
            new { ApiCapabilityId = apiCapabilityId, TenantId = login.ClientId }).ConfigureAwait(false);
}