using GB5Shared.DTO.Framework.Login;
using GB5Shared.QueryExecutor;
using QMSDAL.DTO;
using QMSDAL.Query.ChecklistAnalytics;

namespace QMSDAL.CustomCode.ChecklistAnalytics
{
    public class ChecklistAnalyticsDAL : IChecklistAnalyticsDAL
    {
        private readonly IQueryExecutor _QueryExecutor;

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

        // ── KPI summary ───────────────────────────────────────────────────────

        public async Task<ChecklistKpiDTO> GetKpiAsync(LoginDTO login, CancellationToken ct = default)
        {
            try
            {
                var result = await _QueryExecutor
                    .QuerySingleAsync<ChecklistKpiDTO>(
                        login, ChecklistAnalyticsQB.GET_KPI)
                    .ConfigureAwait(false);

                return result ?? new ChecklistKpiDTO();
            }
            catch (Exception)
            {
                throw;
            }
        }

        // ── Daily trend ───────────────────────────────────────────────────────

        public async Task<IEnumerable<ChecklistTrendDTO>> GetTrendAsync(
            int days, LoginDTO login, CancellationToken ct = default)
        {
            try
            {
                var param  = new { Days = days };
                var result = await _QueryExecutor
                    .QueryAsync<ChecklistTrendDTO>(
                        login, ChecklistAnalyticsQB.GET_TREND, param, cancellationToken: ct)
                    .ConfigureAwait(false);

                return result ?? Enumerable.Empty<ChecklistTrendDTO>();
            }
            catch (Exception)
            {
                throw;
            }
        }

        // ── Timing phase breakdown ────────────────────────────────────────────

        public async Task<IEnumerable<ChecklistTimingDTO>> GetTimingBreakdownAsync(
            LoginDTO login, CancellationToken ct = default)
        {
            try
            {
                var result = await _QueryExecutor
                    .QueryAsync<ChecklistTimingDTO>(
                        login, ChecklistAnalyticsQB.GET_TIMING_BREAKDOWN, cancellationToken: ct)
                    .ConfigureAwait(false);

                return result ?? Enumerable.Empty<ChecklistTimingDTO>();
            }
            catch (Exception)
            {
                throw;
            }
        }

        // ── Top failing items ─────────────────────────────────────────────────

        public async Task<IEnumerable<ChecklistTopFailureDTO>> GetTopFailuresAsync(
            int days, LoginDTO login, CancellationToken ct = default)
        {
            try
            {
                var param  = new { Days = days };
                var result = await _QueryExecutor
                    .QueryAsync<ChecklistTopFailureDTO>(
                        login, ChecklistAnalyticsQB.GET_TOP_FAILURES, param, cancellationToken: ct)
                    .ConfigureAwait(false);

                return result ?? Enumerable.Empty<ChecklistTopFailureDTO>();
            }
            catch (Exception)
            {
                throw;
            }
        }
    }
}