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-02-21 11:08:59 +00:00
parent 7f69ef1c0a
commit bfc661d21d
1 changed files with 15 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
server.js
View File

@@ -973,11 +973,11 @@ app.get("/services/active", authMiddleware, async (req, res) => {
} catch (e) { res.status(500).json({ ok: false }); } } catch (e) { res.status(500).json({ ok: false }); }
}); });
// AÑADIDO: Ruta para fijar la cita o el estado operativo (REGLA ESTRICTA)
app.put("/services/set-appointment/:id", authMiddleware, async (req, res) => { app.put("/services/set-appointment/:id", authMiddleware, async (req, res) => {
try { try {
const { id } = req.params; const { id } = req.params;
let { date, time, status_operativo, ...extra } = req.body; // let en status_operativo para poder cambiarlo // OJO: status_operativo con 'let' para que la IA pueda cambiarlo
let { date, time, status_operativo, ...extra } = req.body;
const current = await pool.query('SELECT raw_data FROM scraped_services WHERE id = $1 AND owner_id = $2', [id, req.user.accountId]); const current = await pool.query('SELECT raw_data FROM scraped_services WHERE id = $1 AND owner_id = $2', [id, req.user.accountId]);
if (current.rowCount === 0) return res.status(404).json({ ok: false, error: 'No encontrado' }); if (current.rowCount === 0) return res.status(404).json({ ok: false, error: 'No encontrado' });
@@ -986,31 +986,34 @@ app.put("/services/set-appointment/:id", authMiddleware, async (req, res) => {
const oldTime = current.rows[0].raw_data.scheduled_time || ""; const oldTime = current.rows[0].raw_data.scheduled_time || "";
const newDate = date || ""; const newDate = date || "";
const newTime = time || ""; const newTime = time || "";
const statusQ = await pool.query("SELECT name FROM service_statuses WHERE id=$1", [status_operativo]); const statusQ = await pool.query("SELECT name FROM service_statuses WHERE id=$1", [status_operativo]);
const stName = statusQ.rows[0]?.name.toLowerCase() || ""; const stName = statusQ.rows[0]?.name.toLowerCase() || "";
// --- REGLA: ASIGNADO -> WA -> ESPERANDO AL CLIENTE --- // --- REGLA ESTRICTA: ASIGNADO -> WA -> ESPERANDO AL CLIENTE ---
if (stName.includes('asignado')) { if (stName.includes('asignado')) {
const waEnviadoExito = await triggerWhatsAppEvent(req.user.accountId, id, 'wa_evt_assigned'); const waEnviadoExito = await triggerWhatsAppEvent(req.user.accountId, id, 'wa_evt_assigned');
if (waEnviadoExito) { if (waEnviadoExito) {
// Si el WA se envía correctamente, forzamos el estado a "Esperando al Cliente" // Si el WA se envía correctamente, forzamos el salto a "Esperando al Cliente"
const estadoEsperando = await pool.query("SELECT id FROM service_statuses WHERE owner_id=$1 AND name='Esperando al Cliente' LIMIT 1", [req.user.accountId]); const estadoEsperando = await pool.query("SELECT id FROM service_statuses WHERE owner_id=$1 AND name='Esperando al Cliente' LIMIT 1", [req.user.accountId]);
if(estadoEsperando.rowCount > 0) status_operativo = estadoEsperando.rows[0].id; if (estadoEsperando.rowCount > 0) {
status_operativo = estadoEsperando.rows[0].id;
}
} }
} else if (stName.includes('citado') && newDate !== "") { } else if (stName.includes('citado') && newDate !== "") {
if (oldDate === "") triggerWhatsAppEvent(req.user.accountId, id, 'wa_evt_date'); if (oldDate === "") await triggerWhatsAppEvent(req.user.accountId, id, 'wa_evt_date');
else if (oldDate !== newDate || oldTime !== newTime) triggerWhatsAppEvent(req.user.accountId, id, 'wa_evt_update'); else if (oldDate !== newDate || oldTime !== newTime) await triggerWhatsAppEvent(req.user.accountId, id, 'wa_evt_update');
} else if (stName.includes('camino')) { } else if (stName.includes('camino')) {
triggerWhatsAppEvent(req.user.accountId, id, 'wa_evt_onway'); await triggerWhatsAppEvent(req.user.accountId, id, 'wa_evt_onway');
} else if (stName.includes('finalizado') || stName.includes('terminado')) { } else if (stName.includes('finalizado') || stName.includes('terminado')) {
triggerWhatsAppEvent(req.user.accountId, id, 'wa_evt_survey'); await triggerWhatsAppEvent(req.user.accountId, id, 'wa_evt_survey');
} }
// Guardamos el estado definitivo (sea el que arrastró, o el forzado a "Esperando") // Finalmente, guardamos (con el estado original, o con el estado "Esperando" si el WA llegó)
const updatedRawData = { ...current.rows[0].raw_data, ...extra, "scheduled_date": newDate, "scheduled_time": newTime, "status_operativo": status_operativo }; const updatedRawData = { ...current.rows[0].raw_data, ...extra, "scheduled_date": newDate, "scheduled_time": newTime, "status_operativo": status_operativo };
await pool.query('UPDATE scraped_services SET raw_data = $1 WHERE id = $2 AND owner_id = $3', [JSON.stringify(updatedRawData), id, req.user.accountId]);
await pool.query('UPDATE scraped_services SET raw_data = $1 WHERE id = $2 AND owner_id = $3', [JSON.stringify(updatedRawData), id, req.user.accountId]);
res.json({ ok: true }); res.json({ ok: true });
} catch (e) { } catch (e) {
console.error("Error agendando cita:", e); console.error("Error agendando cita:", e);