Actualizar server.js

server.js

@@ -1872,25 +1872,37 @@ app.get("/public/assignment/:token", async (req, res) => {
         }
 
         if (new Date() > new Date(assign.expires_at)) {
-            // Lo marcamos como expirado si ya pasó el tiempo
             await pool.query("UPDATE assignment_pings SET status = 'expired' WHERE id = $1", [assign.id]);
             return res.json({ ok: false, error: "El tiempo para aceptar este aviso ha caducado." });
         }
 
-        res.json({ ok: true, assignment: assign });
+        // Parsear datos para enviarlos bonitos a la pantalla de aceptar.html
+        const raw = assign.raw_data || {};
+        const serviceData = {
+            "Gremio": raw["Gremio"] || raw.guild_name || "Servicio General",
+            "Expediente": assign.service_ref || raw["Referencia"] || "Sin Ref",
+            "Población": raw["Población"] || raw["POBLACION-PROVINCIA"] || "",
+            "Código Postal": raw["Código Postal"] || "",
+            "Descripción": raw["Descripción"] || raw["DESCRIPCION"] || "Revisar en el lugar."
+        };
+
+        res.json({ ok: true, service: serviceData, debug: { hora_limite_bd: assign.expires_at } });
     } catch (e) {
         console.error("Error al obtener asignación:", e);
         res.status(500).json({ ok: false });
     }
 });
 
-app.post("/public/assignment/:token/accept", async (req, res) => {
+app.post("/public/assignment/respond", async (req, res) => {
     const client = await pool.connect();
     try {
-        const { token } = req.params;
+        const { token, action } = req.body;
+        
+        if (!token || !action) return res.status(400).json({ ok: false, error: "Faltan datos" });
+
         await client.query('BEGIN');
 
-        // 1. Validar ping bloqueando la fila para evitar dobles clicks
+        // 1. Validar ping bloqueando la fila
         const qPing = await client.query("SELECT * FROM assignment_pings WHERE token = $1 AND status = 'pending' FOR UPDATE", [token]);
         if (qPing.rowCount === 0) {
             await client.query('ROLLBACK');
@@ -1899,6 +1911,13 @@ app.post("/public/assignment/:token/accept", async (req, res) => {
         
         const ping = qPing.rows[0];
 
+        if (action === 'reject') {
+            await client.query("UPDATE assignment_pings SET status = 'rejected' WHERE id = $1", [ping.id]);
+            await client.query('COMMIT');
+            return res.json({ ok: true });
+        }
+
+        if (action === 'accept') {
             // 2. Marcar ping como aceptado
             await client.query("UPDATE assignment_pings SET status = 'accepted' WHERE id = $1", [ping.id]);
 
@@ -1927,10 +1946,15 @@ app.post("/public/assignment/:token/accept", async (req, res) => {
             // 6. ¡Magia! Le enviamos un WhatsApp automático al cliente diciendo que ya tiene técnico
             triggerWhatsAppEvent(ownerId, ping.scraped_id, 'wa_evt_assigned').catch(e => console.error(e));
 
-        res.json({ ok: true });
+            return res.json({ ok: true });
+        }
+
+        await client.query('ROLLBACK');
+        res.status(400).json({ ok: false, error: "Acción no válida" });
+
     } catch (e) {
         await client.query('ROLLBACK');
-        console.error("Error aceptando asignación:", e);
+        console.error("Error respondiendo asignación:", e);
         res.status(500).json({ ok: false, error: "Error interno del servidor" });
     } finally {
         client.release();