using BizProcessDAL.DTO;
using BizProcessDAL.Query;
using GB5Shared.DTO.Framework.Login;
using GB5Shared.QueryExecutor;

namespace BizProcessDAL.CustomCode
{
    public class BizProcessDAL : IBizProcessDAL
    {
        private readonly IQueryExecutor _QueryExecutor;

        public BizProcessDAL(IQueryExecutor QueryExecutor)
        {
            _QueryExecutor = QueryExecutor;
        }

        // ── MBIZPROCESS ──────────────────────────────────────────────
        public async Task<BizProcessDTO?> GetProcess(int bizProcessId, LoginDTO login, CancellationToken ct)
            => await _QueryExecutor.QuerySingleAsync<BizProcessDTO>(
                login, BizProcessQB.GET_PROCESS,
                new { BizProcessId = bizProcessId, TenantId = login.ClientId },
                cancellationToken: ct).ConfigureAwait(false);

        public async Task<IEnumerable<dynamic>> GetSelectListProcess(LoginDTO login, CancellationToken ct)
            => await _QueryExecutor.QueryAsync<dynamic>(
                login, BizProcessQB.GET_SELECTLIST_PROCESS,
                new { TenantId = login.ClientId },
                cancellationToken: ct).ConfigureAwait(false);

        public async Task<int> SaveProcess(BizProcessDTO dto, LoginDTO login, CancellationToken ct)
            => await _QueryExecutor.ExecuteAsync(login, BizProcessQB.SAVE_PROCESS, dto, cancellationToken: ct).ConfigureAwait(false);

        public async Task<int> UpdateProcess(BizProcessDTO dto, LoginDTO login, CancellationToken ct)
            => await _QueryExecutor.ExecuteAsync(login, BizProcessQB.UPDATE_PROCESS, dto, cancellationToken: ct).ConfigureAwait(false);

        // ── MBIZPROCESSVARIANT ───────────────────────────────────────
        public async Task<BizProcessVariantDTO?> GetProcessVariant(int bizProcessVariantId, LoginDTO login, CancellationToken ct)
            => await _QueryExecutor.QuerySingleAsync<BizProcessVariantDTO>(
                login, BizProcessQB.GET_PROCESS_VARIANT,
                new { BizProcessVariantId = bizProcessVariantId, TenantId = login.ClientId },
                cancellationToken: ct).ConfigureAwait(false);

        public async Task<IEnumerable<dynamic>> GetSelectListVariant(int bizProcessId, LoginDTO login, CancellationToken ct)
            => await _QueryExecutor.QueryAsync<dynamic>(
                login, BizProcessQB.GET_SELECTLIST_VARIANT,
                new { BizProcessId = bizProcessId, TenantId = login.ClientId },
                cancellationToken: ct).ConfigureAwait(false);

        public async Task<IEnumerable<dynamic>> GetSelectListAllStages(LoginDTO login, CancellationToken ct)
            => await _QueryExecutor.QueryAsync<dynamic>(
                login, BizProcessQB.GET_SELECTLIST_ALL_STAGES,
                new { TenantId = login.ClientId },
                cancellationToken: ct).ConfigureAwait(false);

        public async Task<BizProcessVariantDTO?> GetLatestVariantForProcess(int bizProcessId, LoginDTO login, CancellationToken ct)
            => await _QueryExecutor.QuerySingleAsync<BizProcessVariantDTO>(
                login, BizProcessQB.GET_LATEST_VARIANT_FOR_PROCESS,
                new { BizProcessId = bizProcessId, TenantId = login.ClientId },
                cancellationToken: ct).ConfigureAwait(false);

        public async Task<int> SaveProcessVariant(BizProcessVariantDTO dto, LoginDTO login, CancellationToken ct)
            => await _QueryExecutor.ExecuteAsync(login, BizProcessQB.SAVE_PROCESS_VARIANT, dto, cancellationToken: ct).ConfigureAwait(false);

        public async Task<int> UpdateProcessVariant(BizProcessVariantDTO dto, LoginDTO login, CancellationToken ct)
            => await _QueryExecutor.ExecuteAsync(login, BizProcessQB.UPDATE_PROCESS_VARIANT, dto, cancellationToken: ct).ConfigureAwait(false);

        public async Task<int> PublishProcessVariant(BizProcessVariantDTO dto, LoginDTO login, CancellationToken ct)
            => await _QueryExecutor.ExecuteAsync(login, BizProcessQB.PUBLISH_PROCESS_VARIANT, dto, cancellationToken: ct).ConfigureAwait(false);

        // ── MBIZPROCESSSTAGE ─────────────────────────────────────────
        public async Task<IEnumerable<BizProcessStageDTO>> GetStagesForVariant(int bizProcessVariantId, LoginDTO login, CancellationToken ct)
            => await _QueryExecutor.QueryAsync<BizProcessStageDTO>(
                login, BizProcessQB.GET_STAGES_FOR_VARIANT,
                new { BizProcessVariantId = bizProcessVariantId, TenantId = login.ClientId },
                cancellationToken: ct).ConfigureAwait(false);

        public async Task<BizProcessStageDTO?> GetStage(int bizProcessStageId, LoginDTO login, CancellationToken ct)
            => await _QueryExecutor.QuerySingleAsync<BizProcessStageDTO>(
                login, BizProcessQB.GET_STAGE,
                new { BizProcessStageId = bizProcessStageId, TenantId = login.ClientId },
                cancellationToken: ct).ConfigureAwait(false);

        public async Task<int> SaveStage(BizProcessStageDTO dto, LoginDTO login, CancellationToken ct)
            => await _QueryExecutor.ExecuteAsync(login, BizProcessQB.SAVE_STAGE, dto, cancellationToken: ct).ConfigureAwait(false);

        public async Task<int> UpdateStage(BizProcessStageDTO dto, LoginDTO login, CancellationToken ct)
            => await _QueryExecutor.ExecuteAsync(login, BizProcessQB.UPDATE_STAGE, dto, cancellationToken: ct).ConfigureAwait(false);

        public async Task<int> DeleteStage(int bizProcessStageId, LoginDTO login, CancellationToken ct)
            => await _QueryExecutor.ExecuteAsync(
                login, BizProcessQB.DELETE_STAGE,
                new { BizProcessStageId = bizProcessStageId, TenantId = login.ClientId, ModifiedById = login.UserId, ModifiedOn = DateTime.UtcNow },
                cancellationToken: ct).ConfigureAwait(false);

        // ── MBIZPROCESSSTAGEEDGE ─────────────────────────────────────
        public async Task<IEnumerable<BizProcessStageEdgeDTO>> GetEdgesForVariant(int bizProcessVariantId, LoginDTO login, CancellationToken ct)
            => await _QueryExecutor.QueryAsync<BizProcessStageEdgeDTO>(
                login, BizProcessQB.GET_EDGES_FOR_VARIANT,
                new { BizProcessVariantId = bizProcessVariantId, TenantId = login.ClientId },
                cancellationToken: ct).ConfigureAwait(false);

        public async Task<int> SaveStageEdge(BizProcessStageEdgeDTO dto, LoginDTO login, CancellationToken ct)
            => await _QueryExecutor.ExecuteAsync(login, BizProcessQB.SAVE_STAGE_EDGE, dto, cancellationToken: ct).ConfigureAwait(false);

        public async Task<int> UpdateStageEdge(BizProcessStageEdgeDTO dto, LoginDTO login, CancellationToken ct)
            => await _QueryExecutor.ExecuteAsync(login, BizProcessQB.UPDATE_STAGE_EDGE, dto, cancellationToken: ct).ConfigureAwait(false);

        public async Task<int> DeleteStageEdge(int bizProcessStageEdgeId, LoginDTO login, CancellationToken ct)
            => await _QueryExecutor.ExecuteAsync(
                login, BizProcessQB.DELETE_STAGE_EDGE,
                new { BizProcessStageEdgeId = bizProcessStageEdgeId, TenantId = login.ClientId, ModifiedById = login.UserId, ModifiedOn = DateTime.UtcNow },
                cancellationToken: ct).ConfigureAwait(false);

        // ── MBIZPROCESSFRAMEWORK ─────────────────────────────────────
        public async Task<IEnumerable<dynamic>> GetSelectListFramework(LoginDTO login, CancellationToken ct)
            => await _QueryExecutor.QueryAsync<dynamic>(login, BizProcessQB.GET_SELECTLIST_FRAMEWORK, cancellationToken: ct).ConfigureAwait(false);

        // ── MBIZPROCESSSTAGEANNOTATION ────────────────────────────────
        public async Task<IEnumerable<BizProcessStageAnnotationDTO>> GetAnnotationsForStage(int bizProcessStageId, LoginDTO login, CancellationToken ct)
            => await _QueryExecutor.QueryAsync<BizProcessStageAnnotationDTO>(
                login, BizProcessQB.GET_ANNOTATIONS_FOR_STAGE,
                new { BizProcessStageId = bizProcessStageId, TenantId = login.ClientId },
                cancellationToken: ct).ConfigureAwait(false);

        public async Task<int> SaveStageAnnotation(BizProcessStageAnnotationDTO dto, LoginDTO login, CancellationToken ct)
            => await _QueryExecutor.ExecuteAsync(login, BizProcessQB.SAVE_STAGE_ANNOTATION, dto, cancellationToken: ct).ConfigureAwait(false);

        public async Task<int> UpdateStageAnnotation(BizProcessStageAnnotationDTO dto, LoginDTO login, CancellationToken ct)
            => await _QueryExecutor.ExecuteAsync(login, BizProcessQB.UPDATE_STAGE_ANNOTATION, dto, cancellationToken: ct).ConfigureAwait(false);

        // ── MBIZPROCESSSTAGECOMPETENCYREQUIREMENT ─────────────────────
        public async Task<IEnumerable<BizProcessStageCompetencyRequirementDTO>> GetCompetencyRequirementsForStage(int bizProcessStageId, LoginDTO login, CancellationToken ct)
            => await _QueryExecutor.QueryAsync<BizProcessStageCompetencyRequirementDTO>(
                login, BizProcessQB.GET_COMPETENCY_REQUIREMENTS_FOR_STAGE,
                new { BizProcessStageId = bizProcessStageId, TenantId = login.ClientId },
                cancellationToken: ct).ConfigureAwait(false);

        public async Task<int> SaveCompetencyRequirement(BizProcessStageCompetencyRequirementDTO dto, LoginDTO login, CancellationToken ct)
            => await _QueryExecutor.ExecuteAsync(login, BizProcessQB.SAVE_COMPETENCY_REQUIREMENT, dto, cancellationToken: ct).ConfigureAwait(false);

        public async Task<int> UpdateCompetencyRequirement(BizProcessStageCompetencyRequirementDTO dto, LoginDTO login, CancellationToken ct)
            => await _QueryExecutor.ExecuteAsync(login, BizProcessQB.UPDATE_COMPETENCY_REQUIREMENT, dto, cancellationToken: ct).ConfigureAwait(false);

        // ── MBIZPROCESSROLEDEVPLAN ─────────────────────────────────────
        public async Task<IEnumerable<BizProcessRoleDevPlanDTO>> GetRoleDevPlanForJobRole(int jobRoleId, LoginDTO login, CancellationToken ct)
            => await _QueryExecutor.QueryAsync<BizProcessRoleDevPlanDTO>(
                login, BizProcessQB.GET_ROLEDEVPLAN_FOR_JOBROLE,
                new { JobRoleId = jobRoleId, TenantId = login.ClientId },
                cancellationToken: ct).ConfigureAwait(false);

        public async Task<int> SaveRoleDevPlan(BizProcessRoleDevPlanDTO dto, LoginDTO login, CancellationToken ct)
            => await _QueryExecutor.ExecuteAsync(login, BizProcessQB.SAVE_ROLEDEVPLAN, dto, cancellationToken: ct).ConfigureAwait(false);

        // ── MBIZPROCESSGOVERNANCE ──────────────────────────────────────
        public async Task<IEnumerable<BizProcessGovernanceDTO>> GetGovernanceForProcess(int bizProcessId, LoginDTO login, CancellationToken ct)
            => await _QueryExecutor.QueryAsync<BizProcessGovernanceDTO>(
                login, BizProcessQB.GET_GOVERNANCE_FOR_PROCESS,
                new { BizProcessId = bizProcessId, TenantId = login.ClientId },
                cancellationToken: ct).ConfigureAwait(false);

        public async Task<int> SaveGovernance(BizProcessGovernanceDTO dto, LoginDTO login, CancellationToken ct)
            => await _QueryExecutor.ExecuteAsync(login, BizProcessQB.SAVE_GOVERNANCE, dto, cancellationToken: ct).ConfigureAwait(false);

        // ── MBIZPROCESSVARIANTMETRIC ─────────────────────────────────────
        public async Task<IEnumerable<BizProcessVariantMetricDTO>> GetMetricsForVariant(int bizProcessVariantId, LoginDTO login, CancellationToken ct)
            => await _QueryExecutor.QueryAsync<BizProcessVariantMetricDTO>(
                login, BizProcessQB.GET_METRICS_FOR_VARIANT,
                new { BizProcessVariantId = bizProcessVariantId, TenantId = login.ClientId },
                cancellationToken: ct).ConfigureAwait(false);

        public async Task<int> SaveVariantMetric(BizProcessVariantMetricDTO dto, LoginDTO login, CancellationToken ct)
            => await _QueryExecutor.ExecuteAsync(login, BizProcessQB.SAVE_VARIANT_METRIC, dto, cancellationToken: ct).ConfigureAwait(false);
    }
}