diff --git a/server.js b/server.js index c68cc7b..91db4a1 100644 --- a/server.js +++ b/server.js @@ -1833,6 +1833,7 @@ async function dispatchToBolsa(serviceId, guildId, cp, accountId, userId) { } 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" }; } @@ -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]); - // 🧠 BUSCAMOS EL NOMBRE DEL GREMIO PARA EL WHATSAPP + // 🧠 MAGIA AÑADIDA: 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(); @@ -1852,8 +1853,11 @@ async function dispatchToBolsa(serviceId, guildId, cp, accountId, userId) { sendWhatsAppAuto(worker.phone, msg, `cliente_${accountId}`, false).catch(console.error); 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 }; } catch (e) { + console.error("❌ Error en dispatchToBolsa:", e); return { ok: false, error: "Error interno" }; } }