Mercados-Web/src/Mercados.Api/Controllers/MercadosController.cs

using Mercados.Core.Entities;
using Mercados.Infrastructure.Persistence.Repositories;
using Microsoft.AspNetCore.Mvc;

namespace Mercados.Api.Controllers
{
    [ApiController]
    [Route("api/[controller]")]
    public class MercadosController : ControllerBase
    {
        private readonly ICotizacionBolsaRepository _bolsaRepo;
        private readonly ICotizacionGranoRepository _granoRepo;
        private readonly ICotizacionGanadoRepository _ganadoRepo;
        private readonly ILogger<MercadosController> _logger;

        // Inyectamos TODOS los repositorios que necesita el controlador.
        public MercadosController(
            ICotizacionBolsaRepository bolsaRepo,
            ICotizacionGranoRepository granoRepo,
            ICotizacionGanadoRepository ganadoRepo,
            ILogger<MercadosController> logger)
        {
            _bolsaRepo = bolsaRepo;
            _granoRepo = granoRepo;
            _ganadoRepo = ganadoRepo;
            _logger = logger;
        }

        // --- Endpoint para Agroganadero ---
        [HttpGet("agroganadero")]
        [ProducesResponseType(typeof(IEnumerable<CotizacionGanado>), StatusCodes.Status200OK)]
        [ProducesResponseType(StatusCodes.Status500InternalServerError)]
        public async Task<IActionResult> GetAgroganadero()
        {
            try
            {
                var data = await _ganadoRepo.ObtenerUltimaTandaAsync();
                return Ok(data);
            }
            catch (Exception ex)
            {
                _logger.LogError(ex, "Error al obtener cotizaciones de agroganadero.");
                return StatusCode(500, "Ocurrió un error interno en el servidor.");
            }
        }

        // --- Endpoint para Granos ---
        [HttpGet("granos")]
        [ProducesResponseType(typeof(IEnumerable<CotizacionGrano>), StatusCodes.Status200OK)]
        [ProducesResponseType(StatusCodes.Status500InternalServerError)]
        public async Task<IActionResult> GetGranos()
        {
            try
            {
                var data = await _granoRepo.ObtenerUltimasAsync();
                return Ok(data);
            }
            catch (Exception ex)
            {
                _logger.LogError(ex, "Error al obtener cotizaciones de granos.");
                return StatusCode(500, "Ocurrió un error interno en el servidor.");
            }
        }

        // --- Endpoints de Bolsa ---
        [HttpGet("bolsa/eeuu")]
        [ProducesResponseType(typeof(IEnumerable<CotizacionBolsa>), StatusCodes.Status200OK)]
        [ProducesResponseType(StatusCodes.Status500InternalServerError)]
        public async Task<IActionResult> GetBolsaUsa()
        {
            try
            {
                var data = await _bolsaRepo.ObtenerUltimasPorMercadoAsync("EEUU");
                return Ok(data);
            }
            catch (Exception ex)
            {
                _logger.LogError(ex, "Error al obtener cotizaciones de bolsa de EEUU.");
                return StatusCode(500, "Ocurrió un error interno en el servidor.");
            }
        }

        [HttpGet("bolsa/local")]
        [ProducesResponseType(typeof(IEnumerable<CotizacionBolsa>), StatusCodes.Status200OK)]
        [ProducesResponseType(StatusCodes.Status500InternalServerError)]
        public async Task<IActionResult> GetBolsaLocal()
        {
            try
            {
                var data = await _bolsaRepo.ObtenerUltimasPorMercadoAsync("Local");
                return Ok(data);
            }
            catch (Exception ex)
            {
                _logger.LogError(ex, "Error al obtener cotizaciones de bolsa local.");
                return StatusCode(500, "Ocurrió un error interno en el servidor.");
            }
        }

        [HttpGet("bolsa/history/{ticker}")]
        [ProducesResponseType(typeof(IEnumerable<CotizacionBolsa>), StatusCodes.Status200OK)]
        [ProducesResponseType(StatusCodes.Status500InternalServerError)]
        public async Task<IActionResult> GetBolsaHistory(string ticker, [FromQuery] string mercado = "Local", [FromQuery] int dias = 30)
        {
            try
            {
                var data = await _bolsaRepo.ObtenerHistorialPorTickerAsync(ticker, mercado, dias);
                return Ok(data);
            }
            catch (Exception ex)
            {
                _logger.LogError(ex, "Error al obtener historial para el ticker {Ticker}.", ticker);
                return StatusCode(500, "Ocurrió un error interno en el servidor.");
            }
        }

        [HttpGet("agroganadero/history")]
        [ProducesResponseType(typeof(IEnumerable<CotizacionGanado>), StatusCodes.Status200OK)]
        [ProducesResponseType(StatusCodes.Status500InternalServerError)]
        public async Task<IActionResult> GetAgroganaderoHistory([FromQuery] string categoria, [FromQuery] string especificaciones, [FromQuery] int dias = 30)
        {
            try
            {
                var data = await _ganadoRepo.ObtenerHistorialAsync(categoria, especificaciones, dias);
                return Ok(data);
            }
            catch (Exception ex)
            {
                _logger.LogError(ex, "Error al obtener historial para la categoría {Categoria}.", categoria);
                return StatusCode(500, "Ocurrió un error interno en el servidor.");
            }
        }

        [HttpGet("granos/history/{nombre}")]
        [ProducesResponseType(typeof(IEnumerable<CotizacionGrano>), StatusCodes.Status200OK)]
        [ProducesResponseType(StatusCodes.Status500InternalServerError)]
        public async Task<IActionResult> GetGranoHistory(string nombre, [FromQuery] int dias = 30)
        {
            try
            {
                var data = await _granoRepo.ObtenerHistorialAsync(nombre, dias);
                return Ok(data);
            }
            catch (Exception ex)
            {
                _logger.LogError(ex, "Error al obtener historial para el grano {Grano}.", nombre);
                return StatusCode(500, "Ocurrió un error interno en el servidor.");
            }
        }
    }
}