Inventario-IT/backend/Controllers/DiscosController.cs

using Dapper;
using Inventario.API.Data;
using Inventario.API.Models;
using Microsoft.AspNetCore.Mvc;

namespace Inventario.API.Controllers
{
  [ApiController]
  [Route("api/[controller]")]
  public class DiscosController : ControllerBase
  {
    private readonly DapperContext _context;

    public DiscosController(DapperContext context)
    {
      _context = context;
    }

    // --- GET /api/discos ---
    [HttpGet]
    public async Task<IActionResult> Consultar()
    {
      var query = "SELECT Id, Mediatype, Size FROM dbo.discos;";
      using (var connection = _context.CreateConnection())
      {
        var discos = await connection.QueryAsync<Disco>(query);
        return Ok(discos);
      }
    }

    // --- GET /api/discos/{id} ---
    [HttpGet("{id}")]
    public async Task<IActionResult> ConsultarDetalle(int id)
    {
      var query = "SELECT Id, Mediatype, Size FROM dbo.discos WHERE Id = @Id;";
      using (var connection = _context.CreateConnection())
      {
        var disco = await connection.QuerySingleOrDefaultAsync<Disco>(query, new { Id = id });
        if (disco == null)
        {
          return NotFound("Disco no encontrado.");
        }
        return Ok(disco);
      }
    }

    // --- POST /api/discos ---
    // Replica la lógica de recibir uno o varios discos y crear solo los que no existen.
    [HttpPost]
    public async Task<IActionResult> Ingresar([FromBody] List<Disco> discos)
    {
      var queryCheck = "SELECT * FROM dbo.discos WHERE Mediatype = @Mediatype AND Size = @Size;";
      var queryInsert = "INSERT INTO dbo.discos (Mediatype, Size) VALUES (@Mediatype, @Size); SELECT CAST(SCOPE_IDENTITY() as int);";

      var resultados = new List<object>();

      using (var connection = _context.CreateConnection())
      {
        foreach (var disco in discos)
        {
          var existente = await connection.QuerySingleOrDefaultAsync<Disco>(queryCheck, new { disco.Mediatype, disco.Size });

          if (existente == null)
          {
            var nuevoId = await connection.ExecuteScalarAsync<int>(queryInsert, new { disco.Mediatype, disco.Size });
            var nuevoDisco = new Disco { Id = nuevoId, Mediatype = disco.Mediatype, Size = disco.Size };
            resultados.Add(new { action = "created", registro = nuevoDisco });
          }
          else
          {
            // Opcional: podrías añadirlo si quieres saber cuáles ya existían
            // resultados.Add(new { action = "exists", registro = existente });
          }
        }
      }
      // Devolvemos HTTP 200 OK con la lista de los discos que se crearon.
      return Ok(resultados);
    }

    // --- PUT /api/discos/{id} ---
    [HttpPut("{id}")]
    public async Task<IActionResult> Actualizar(int id, [FromBody] Disco disco)
    {
      var query = "UPDATE dbo.discos SET Mediatype = @Mediatype, Size = @Size WHERE Id = @Id;";
      using (var connection = _context.CreateConnection())
      {
        var filasAfectadas = await connection.ExecuteAsync(query, new { disco.Mediatype, disco.Size, Id = id });
        if (filasAfectadas == 0)
        {
          return NotFound("Disco no encontrado.");
        }

        var discoActualizado = new Disco { Id = id, Mediatype = disco.Mediatype, Size = disco.Size };
        return Ok(discoActualizado);
      }
    }

    // --- DELETE /api/discos/{id} ---
    [HttpDelete("{id}")]
    public async Task<IActionResult> Borrar(int id)
    {
      var query = "DELETE FROM dbo.discos WHERE Id = @Id;";
      using (var connection = _context.CreateConnection())
      {
        var filasAfectadas = await connection.ExecuteAsync(query, new { Id = id });
        if (filasAfectadas == 0)
        {
          return NotFound("Disco no encontrado.");
        }
        return NoContent();
      }
    }
  }
}