using Dapper;
using GestionIntegral.Api.Models.Suscripciones;
using System.Data;
using System.Text;

namespace GestionIntegral.Api.Data.Repositories.Suscripciones
{
    public class PromocionRepository : IPromocionRepository
    {
        private readonly DbConnectionFactory _connectionFactory;
        private readonly ILogger<PromocionRepository> _logger;

        public PromocionRepository(DbConnectionFactory factory, ILogger<PromocionRepository> logger)
        {
            _connectionFactory = factory;
            _logger = logger;
        }

        public async Task<IEnumerable<Promocion>> GetAllAsync(bool soloActivas)
        {
            var sql = new StringBuilder("SELECT * FROM dbo.susc_Promociones");
            if(soloActivas)
            {
                sql.Append(" WHERE Activa = 1");
            }
            sql.Append(" ORDER BY FechaInicio DESC;");

            using var connection = _connectionFactory.CreateConnection();
            return await connection.QueryAsync<Promocion>(sql.ToString());
        }

        public async Task<Promocion?> GetByIdAsync(int id)
        {
            const string sql = "SELECT * FROM dbo.susc_Promociones WHERE IdPromocion = @Id;";
            using var connection = _connectionFactory.CreateConnection();
            return await connection.QuerySingleOrDefaultAsync<Promocion>(sql, new { Id = id });
        }

        public async Task<Promocion?> CreateAsync(Promocion nuevaPromocion, IDbTransaction transaction)
        {
            const string sql = @"
                INSERT INTO dbo.susc_Promociones (Descripcion, TipoPromocion, Valor, FechaInicio, FechaFin, Activa, IdUsuarioAlta, FechaAlta)
                OUTPUT INSERTED.*
                VALUES (@Descripcion, @TipoPromocion, @Valor, @FechaInicio, @FechaFin, @Activa, @IdUsuarioAlta, GETDATE());";

            if (transaction?.Connection == null)
            {
                throw new ArgumentNullException(nameof(transaction.Connection), "La conexión de la transacción no puede ser nula.");
            }

            return await transaction.Connection.QuerySingleAsync<Promocion>(sql, nuevaPromocion, transaction);
        }

        public async Task<bool> UpdateAsync(Promocion promocion, IDbTransaction transaction)
        {
            const string sql = @"
                UPDATE dbo.susc_Promociones SET
                    Descripcion = @Descripcion,
                    TipoPromocion = @TipoPromocion,
                    Valor = @Valor,
                    FechaInicio = @FechaInicio,
                    FechaFin = @FechaFin,
                    Activa = @Activa
                WHERE IdPromocion = @IdPromocion;";

            if (transaction?.Connection == null)
            {
                throw new ArgumentNullException(nameof(transaction.Connection), "La conexión de la transacción no puede ser nula.");
            }

            var rows = await transaction.Connection.ExecuteAsync(sql, promocion, transaction);
            return rows == 1;
        }

        public async Task<IEnumerable<Promocion>> GetPromocionesActivasParaSuscripcion(int idSuscripcion, DateTime fechaPeriodo, IDbTransaction transaction)
        {
            const string sql = @"
                SELECT p.* FROM dbo.susc_Promociones p
                JOIN dbo.susc_SuscripcionPromociones sp ON p.IdPromocion = sp.IdPromocion
                WHERE sp.IdSuscripcion = @IdSuscripcion
                  AND p.Activa = 1
                  AND p.FechaInicio <= @FechaPeriodo
                  AND (p.FechaFin IS NULL OR p.FechaFin >= @FechaPeriodo);";

            if (transaction?.Connection == null)
            {
                throw new ArgumentNullException(nameof(transaction.Connection), "La conexión de la transacción no puede ser nula.");
            }

            return await transaction.Connection.QueryAsync<Promocion>(sql, new { IdSuscripcion = idSuscripcion, FechaPeriodo = fechaPeriodo }, transaction);
        }
    }
}