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 18:01:07 +00:00
parent befd31b63c
commit d9edb6452a
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
server.js
View File

@@ -1833,6 +1833,7 @@ 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" };
} }
@@ -1842,7 +1843,7 @@ 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]);
// 🧠 BUSCAMOS EL NOMBRE DEL GREMIO PARA EL WHATSAPP // 🧠 MAGIA AÑADIDA: BUSCAMOS EL NOMBRE DEL GREMIO PARA EL WHATSAPP
let nombreGremio = "URGENCIA"; let nombreGremio = "URGENCIA";
const gQ = await pool.query("SELECT name FROM guilds WHERE id = $1", [guildId]); const gQ = await pool.query("SELECT name FROM guilds WHERE id = $1", [guildId]);
if(gQ.rowCount > 0) nombreGremio = gQ.rows[0].name.toUpperCase(); if(gQ.rowCount > 0) nombreGremio = gQ.rows[0].name.toUpperCase();
@@ -1852,8 +1853,11 @@ async function dispatchToBolsa(serviceId, guildId, cp, accountId, userId) {
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" };
} }
} }