using System.Data.Common;
using GB5Shared.DTO.Framework.Login;
using GB5Shared.QueryExecutor;
using GB5Shared.ResponseStandard;
using PIEDAL.DTO.Module;
using PIEDAL.Query.Module;

namespace PIEDAL.CustomCode.Module;

public class PIEModuleDAL : IPIEModuleDAL
{
    private readonly IQueryExecutor _QueryExecutor;

    public PIEModuleDAL(IQueryExecutor queryExecutor)
    {
        _QueryExecutor = queryExecutor;
    }

    // ── Reads ─────────────────────────────────────────────────────────────────

    public async Task<PIEModuleDTO?> GetPIEModuleAsync(
        Guid moduleId, LoginDTO login, CancellationToken ct)
        => await _QueryExecutor.QuerySingleAsync<PIEModuleDTO>(
            login, PIEModuleQB.GET_BY_ID,
            new { ModuleId = moduleId },
            cancellationToken: ct).ConfigureAwait(false);

    public async Task<IEnumerable<PIEModuleDependencyDTO>> GetPIEModuleDependenciesAsync(
        Guid moduleId, LoginDTO login, CancellationToken ct)
        => await _QueryExecutor.QueryAsync<PIEModuleDependencyDTO>(
            login, PIEModuleQB.GET_DEPENDENCIES,
            new { ModuleId = moduleId },
            cancellationToken: ct).ConfigureAwait(false)
            ?? Enumerable.Empty<PIEModuleDependencyDTO>();

    public async Task<IEnumerable<PIEModuleDependencyDTO>> GetAllDependenciesForCycleCheckAsync(
        LoginDTO login, CancellationToken ct)
        => await _QueryExecutor.QueryAsync<PIEModuleDependencyDTO>(
            login, PIEModuleQB.GET_ALL_DEPENDENCIES_FOR_CYCLE_CHECK,
            new { },
            cancellationToken: ct).ConfigureAwait(false)
            ?? Enumerable.Empty<PIEModuleDependencyDTO>();

    public async Task<IEnumerable<PIEModuleSelectListDTO>> GetPIEModuleSelectListAsync(
        LoginDTO login, CancellationToken ct)
        => await _QueryExecutor.QueryAsync<PIEModuleSelectListDTO>(
            login, PIEModuleQB.GET_SELECT_LIST,
            new { },
            cancellationToken: ct).ConfigureAwait(false)
            ?? Enumerable.Empty<PIEModuleSelectListDTO>();

    public async Task<PIEKpiDTO?> GetPIEKpiAsync(
        Guid kpiId, LoginDTO login, CancellationToken ct)
        => await _QueryExecutor.QuerySingleAsync<PIEKpiDTO>(
            login, PIEKpiQB.GET_BY_ID,
            new { KpiId = kpiId },
            cancellationToken: ct).ConfigureAwait(false);

    public async Task<IEnumerable<PIEKpiDTO>> GetKpisByModuleAsync(
        Guid moduleId, LoginDTO login, CancellationToken ct)
        => await _QueryExecutor.QueryAsync<PIEKpiDTO>(
            login, PIEKpiQB.GET_BY_MODULE,
            new { ModuleId = moduleId },
            cancellationToken: ct).ConfigureAwait(false)
            ?? Enumerable.Empty<PIEKpiDTO>();

    // ── Module writes ─────────────────────────────────────────────────────────

    public async Task<Result<string>> SavePIEModuleAsync(
        PIEModuleDTO dto, LoginDTO login, DbTransaction tx, CancellationToken ct)
    {
        dto.CreatedBy = login.UserId;
        dto.CreatedAt = DateTime.UtcNow;
        dto.UpdatedBy = login.UserId;
        dto.UpdatedAt = DateTime.UtcNow;

        int rows = await _QueryExecutor.ExecuteAsync(
            login, PIEModuleQB.INSERT, dto, tx,
            cancellationToken: ct).ConfigureAwait(false);

        return rows > 0
            ? Result<string>.Success("PIE module saved.")
            : Result<string>.Failure("Failed to save PIE module.");
    }

    public async Task<Result<string>> UpdatePIEModuleAsync(
        PIEModuleDTO dto, LoginDTO login, DbTransaction tx, CancellationToken ct)
    {
        dto.UpdatedBy = login.UserId;
        dto.UpdatedAt = DateTime.UtcNow;

        int rows = await _QueryExecutor.ExecuteAsync(
            login, PIEModuleQB.UPDATE, dto, tx,
            cancellationToken: ct).ConfigureAwait(false);

        return rows > 0
            ? Result<string>.Success("PIE module updated.")
            : Result<string>.Failure("PIE module not found or not updated.");
    }

    public async Task<Result<string>> SoftDeletePIEModuleAsync(
        Guid moduleId, LoginDTO login, DbTransaction tx, CancellationToken ct)
    {
        var param = new
        {
            ModuleId  = moduleId,
            UpdatedAt = DateTime.UtcNow,
            UpdatedBy = login.UserId
        };

        int rows = await _QueryExecutor.ExecuteAsync(
            login, PIEModuleQB.SOFT_DELETE, param, tx,
            cancellationToken: ct).ConfigureAwait(false);

        return rows > 0
            ? Result<string>.Success("PIE module deleted.")
            : Result<string>.Failure("PIE module not found or already inactive.");
    }

    // ── Dependency writes ─────────────────────────────────────────────────────

    public async Task DeleteModuleDependenciesAsync(
        Guid moduleId, LoginDTO login, DbTransaction tx, CancellationToken ct)
        => await _QueryExecutor.ExecuteAsync(
            login, PIEModuleQB.DELETE_DEPENDENCIES,
            new { ModuleId = moduleId }, tx,
            cancellationToken: ct).ConfigureAwait(false);

    public async Task InsertModuleDependencyAsync(
        PIEModuleDependencyDTO dto, LoginDTO login, DbTransaction tx, CancellationToken ct)
        => await _QueryExecutor.ExecuteAsync(
            login, PIEModuleQB.INSERT_DEPENDENCY, dto, tx,
            cancellationToken: ct).ConfigureAwait(false);

    // ── KPI writes ────────────────────────────────────────────────────────────

    public async Task<Result<string>> SavePIEKpiAsync(
        PIEKpiDTO dto, LoginDTO login, DbTransaction tx, CancellationToken ct)
    {
        dto.CreatedBy = login.UserId;
        dto.CreatedAt = DateTime.UtcNow;
        dto.UpdatedBy = login.UserId;
        dto.UpdatedAt = DateTime.UtcNow;

        int rows = await _QueryExecutor.ExecuteAsync(
            login, PIEKpiQB.INSERT, dto, tx,
            cancellationToken: ct).ConfigureAwait(false);

        return rows > 0
            ? Result<string>.Success("PIE KPI saved.")
            : Result<string>.Failure("Failed to save PIE KPI.");
    }

    public async Task<Result<string>> UpdatePIEKpiAsync(
        PIEKpiDTO dto, LoginDTO login, DbTransaction tx, CancellationToken ct)
    {
        dto.UpdatedBy = login.UserId;
        dto.UpdatedAt = DateTime.UtcNow;

        int rows = await _QueryExecutor.ExecuteAsync(
            login, PIEKpiQB.UPDATE, dto, tx,
            cancellationToken: ct).ConfigureAwait(false);

        return rows > 0
            ? Result<string>.Success("PIE KPI updated.")
            : Result<string>.Failure("PIE KPI not found or not updated.");
    }

    public async Task<Result<string>> SoftDeletePIEKpiAsync(
        Guid kpiId, LoginDTO login, DbTransaction tx, CancellationToken ct)
    {
        var param = new
        {
            KpiId     = kpiId,
            UpdatedAt = DateTime.UtcNow,
            UpdatedBy = login.UserId
        };

        int rows = await _QueryExecutor.ExecuteAsync(
            login, PIEKpiQB.SOFT_DELETE, param, tx,
            cancellationToken: ct).ConfigureAwait(false);

        return rows > 0
            ? Result<string>.Success("PIE KPI deleted.")
            : Result<string>.Failure("PIE KPI not found or already inactive.");
    }
}