diff --git a/server.js b/server.js index 096a12e..c68cc7b 100644 --- a/server.js +++ b/server.js @@ -1833,7 +1833,6 @@ 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" }; } @@ -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]); - 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); 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" }; } }