Actualizar server.js

This commit is contained in:
2026-03-17 13:17:51 +00:00
parent 0741e36a12
commit ceaf824a87

View File

@@ -1975,16 +1975,20 @@ app.post("/providers/scraped", authMiddleware, async (req, res) => {
} }
} }
// 🚨 NUEVO: Detectar si el robot nos avisa de que el expediente está cerrado/archivado en origen
let scraperStatus = svc.status || 'pending';
// GUARDAR EN BD // GUARDAR EN BD
const insertRes = await pool.query(` const insertRes = await pool.query(`
INSERT INTO scraped_services (owner_id, provider, service_ref, raw_data, is_urgent) INSERT INTO scraped_services (owner_id, provider, service_ref, status, raw_data, is_urgent)
VALUES ($1, $2, $3, $4, $5) VALUES ($1, $2, $3, $4, $5, $6)
ON CONFLICT (owner_id, provider, service_ref) ON CONFLICT (owner_id, provider, service_ref)
DO UPDATE SET DO UPDATE SET
status = CASE WHEN EXCLUDED.status = 'archived' THEN 'archived' ELSE scraped_services.status END,
raw_data = scraped_services.raw_data || EXCLUDED.raw_data, raw_data = scraped_services.raw_data || EXCLUDED.raw_data,
is_urgent = scraped_services.is_urgent OR EXCLUDED.is_urgent is_urgent = scraped_services.is_urgent OR EXCLUDED.is_urgent
RETURNING id, automation_status RETURNING id, automation_status
`, [req.user.accountId, provider, ref, JSON.stringify(svc), esUrgente]); `, [req.user.accountId, provider, ref, scraperStatus, JSON.stringify(svc), esUrgente]);
const newSvcId = insertRes.rows[0].id; const newSvcId = insertRes.rows[0].id;
const autoStatus = insertRes.rows[0].automation_status; const autoStatus = insertRes.rows[0].automation_status;