marsalva/api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Actualizar server.js

Browse Source
This commit is contained in:
marsalva
2026-03-15 17:59:51 +00:00
parent 8b0f5e03d7
commit befd31b63c
1 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
server.js
View File

@@ -1833,7 +1833,6 @@ async function dispatchToBolsa(serviceId, guildId, cp, accountId, userId) {
} }
if (workersQ.rowCount === 0) { if (workersQ.rowCount === 0) {
console.log(`⚠️ [AUTO-DISPATCH] No hay operarios activos para el gremio ${guildId}.`);
return { ok: false, error: "No hay operarios disponibles para este gremio" }; return { ok: false, error: "No hay operarios disponibles para este gremio" };
} }
@@ -1843,15 +1842,18 @@ async function dispatchToBolsa(serviceId, guildId, cp, accountId, userId) {
await pool.query(`INSERT INTO assignment_pings (scraped_id, user_id, token, expires_at) VALUES ($1, $2, $3, CURRENT_TIMESTAMP + INTERVAL '5 minutes')`, [serviceId, worker.id, token]); await pool.query(`INSERT INTO assignment_pings (scraped_id, user_id, token, expires_at) VALUES ($1, $2, $3, CURRENT_TIMESTAMP + INTERVAL '5 minutes')`, [serviceId, worker.id, token]);
const msg = `🚨 *NUEVA URGENCIA DISPONIBLE*\n📍 Zona: ${(cp && cp !== "00000") ? cp : "Asignada"}\n🔗 https://web.integrarepara.es/aceptar.html?t=${token}`; // 🧠 BUSCAMOS EL NOMBRE DEL GREMIO PARA EL WHATSAPP
let nombreGremio = "URGENCIA";
const gQ = await pool.query("SELECT name FROM guilds WHERE id = $1", [guildId]);
if(gQ.rowCount > 0) nombreGremio = gQ.rows[0].name.toUpperCase();
const msg = `🚨 *NUEVO AVISO: ${nombreGremio}*\n📍 Código Postal: ${(cp && cp !== "00000") ? cp : "Zona Asignada"}\n\nTienes un aviso urgente pendiente. Entra aquí para ver la avería y aceptarlo antes de que caduque el turno:\n🔗 https://web.integrarepara.es/aceptar.html?t=${token}`;
sendWhatsAppAuto(worker.phone, msg, `cliente_${accountId}`, false).catch(console.error); sendWhatsAppAuto(worker.phone, msg, `cliente_${accountId}`, false).catch(console.error);
await registrarMovimiento(serviceId, userId, "Bolsa Automática", `Notificación enviada a: ${worker.full_name}`); await registrarMovimiento(serviceId, userId, "Bolsa Automática", `Notificación enviada a: ${worker.full_name}`);
console.log(`✅ [AUTO-DISPATCH] Urgencia enviada con éxito a ${worker.full_name}`);
return { ok: true }; return { ok: true };
} catch (e) { } catch (e) {
console.error("❌ Error en dispatchToBolsa:", e);
return { ok: false, error: "Error interno" }; return { ok: false, error: "Error interno" };
} }
} }