feat: Controladores con operaciones CRUD completas

backend/Controllers/DiscosController.cs

@@ -0,0 +1,114 @@
+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();
+      }
+    }
+  }
+}