diff --git a/robot.js b/robot.js index 7090958..521e14b 100644 --- a/robot.js +++ b/robot.js @@ -298,7 +298,7 @@ async function runHomeserve(ownerId, user, pass, gremiosDB) { // 2. Le ponemos el DNI de un Chrome normal en Windows 10 const context = await browser.newContext({ userAgent: 'Mozilla/5.0 (Windows NT 10.0; Win64; x64) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/120.0.0.0 Safari/537.36', - viewport: { width: 1366, height: 768 }, // Tamaño de pantalla típico + viewport: { width: 1366, height: 768 }, hasTouch: false }); @@ -312,10 +312,6 @@ async function runHomeserve(ownerId, user, pass, gremiosDB) { try { console.log("🌍 [HomeServe] Entrando a la web (Modo Sigilo Activado)..."); await gotoWithRetry(page, 'https://www.clientes.homeserve.es/cgi-bin/fccgi.exe?w3exec=PROF_PASS'); -// ... el resto de la función sigue exactamente igual ... - try { - console.log("🌍 [HomeServe] Entrando a la web..."); - await gotoWithRetry(page, 'https://www.clientes.homeserve.es/cgi-bin/fccgi.exe?w3exec=PROF_PASS'); console.log(`🔎 [HomeServe] URL actual: ${page.url()}`); if (await page.isVisible('input[name="CODIGO"]')) { @@ -323,7 +319,6 @@ async function runHomeserve(ownerId, user, pass, gremiosDB) { await page.fill('input[name="CODIGO"]', user); await page.fill('input[type="password"]', pass); - // BUSCAMOS EL BOTÓN Y HACEMOS CLIC EN VEZ DE PULSAR ENTER const botonEntrar = await page.$('input[type="submit"], input[type="button"], button'); if (botonEntrar) { console.log("🖱️ [HomeServe] Haciendo clic en el botón de Entrar..."); @@ -336,7 +331,6 @@ async function runHomeserve(ownerId, user, pass, gremiosDB) { await page.waitForTimeout(5000); console.log(`👀 [HomeServe] URL tras intentar login: ${page.url()}`); - // 🚨 EL LECTOR DE PANTALLA: Si se queda en el login, leemos qué dice el error if (page.url().includes('PROF_PASS')) { console.log("⚠️ [HomeServe] El login falló. Leyendo el texto visible de la web..."); const textoPantalla = await page.evaluate(() => { @@ -356,7 +350,6 @@ async function runHomeserve(ownerId, user, pass, gremiosDB) { await page.waitForTimeout(3000); console.log(`📍 [HomeServe] URL de la lista cargada: ${page.url()}`); - // 🛑 NUEVO: Ahora extraemos la referencia Y LOS ICONOS de la misma pasada const listaConIconos = await page.evaluate(() => { const results = []; const rows = Array.from(document.querySelectorAll('table[bgcolor="#FCF4D6"] tr')); @@ -380,7 +373,6 @@ async function runHomeserve(ownerId, user, pass, gremiosDB) { console.log(`📊 [HomeServe] Total de filas válidas extraídas de la tabla: ${listaConIconos.length}`); - // Sacamos solo los números para la escoba (syncAndArchive) const refs = [...new Set(listaConIconos.map(item => item.ref))]; if (refs.length > 0) { @@ -395,7 +387,7 @@ async function runHomeserve(ownerId, user, pass, gremiosDB) { const scrapData = await page.evaluate(() => { const d = {}; - let isUrgent = "No"; // <-- EMPEZAMOS ASUMIENDO QUE NO ES URGENTE + let isUrgent = "No"; const rows = Array.from(document.querySelectorAll('tr')); rows.forEach(r => { @@ -408,19 +400,16 @@ async function runHomeserve(ownerId, user, pass, gremiosDB) { const inputEl = cells[1].querySelector('textarea'); const txt = inputEl ? inputEl.value : (cells[1].innerText || ""); - // 🔥 DETECTOR DE URGENCIA ANTES DE LIMPIAR 🔥 const txtLower = txt.toLowerCase().normalize("NFD").replace(/[\u0300-\u036f]/g, ""); if (txtLower.includes("atencion presencial urgencias") || txtLower.includes("atencion de la urgencia") || txtLower.includes("urgente")) { - isUrgent = "Sí"; // Si pilla la urgencia, la guarda. + isUrgent = "Sí"; } const cleanDesc = txt.split('\n').filter(line => { const l = line.toUpperCase(); - // Quitamos los filtros destructivos que borraban el "Cambio de estado" return !["ESTADO ASIGNADO", "SMS NO ENVIADO", "CONTACTO CON PROF", "0000"].some(b => l.includes(b)); }).join('\n').trim(); - // Aplicamos el descodificador a la avería - d['Descripción'] = cleanDesc; // Se limpiará luego abajo + d['Descripción'] = cleanDesc; } else if (k.length > 1 && v.length > 0 && !k.includes("MENU")) { d[k] = v; } @@ -434,24 +423,18 @@ async function runHomeserve(ownerId, user, pass, gremiosDB) { d['Compañía'] = "HOME - " + (d['COMPAÑIA'] || "HOMESERVE"); d['Nombre Cliente'] = d['CLIENTE'] || ""; d['Dirección'] = d['DOMICILIO'] || ""; - - // INYECTAMOS LA URGENCIA AL ESTILO MULTIASISTENCIA d['Urgente'] = isUrgent; return d; }); if (scrapData && scrapData['Nombre Cliente']) { - // 🪄 Arreglamos la codificación alienígena de HomeServe EN TODOS LOS CAMPOS IMPORTANTES scrapData['Nombre Cliente'] = arreglarCodificacion(scrapData['Nombre Cliente']); scrapData['Dirección'] = arreglarCodificacion(scrapData['Dirección']); scrapData['Población'] = arreglarCodificacion(scrapData['Población']); scrapData['Descripción'] = arreglarCodificacion(scrapData['Descripción']); - - // 🪄 Arreglamos el formato de "Apellidos, Nombre" (Solo en HomeServe) scrapData['Nombre Cliente'] = arreglarNombre(scrapData['Nombre Cliente']); - // 🛑 NUEVO: Le inyectamos los iconos que cazamos antes en la lista const iconInfo = listaConIconos.find(item => item.ref === ref); if (iconInfo) { scrapData['has_lock'] = iconInfo.hasLock; @@ -465,84 +448,10 @@ async function runHomeserve(ownerId, user, pass, gremiosDB) { await saveServiceToDB(ownerId, 'homeserve', ref, scrapData); } } - } catch (e) { console.error("❌ [HomeServe] Error:", e.message); } - finally { await browser.close(); } -} - -async function syncAndArchive(ownerId, provider, currentWebRefs) { - const client = await pool.connect(); - try { - // 1. Buscamos TODOS los expedientes que están vivos (en el buzón o en el panel) - const { rows: dbServices } = await client.query( - `SELECT id, service_ref, assigned_to, raw_data FROM scraped_services - WHERE owner_id = $1 AND provider = $2 AND status IN ('pending', 'imported')`, - [ownerId, provider] - ); - - // 2. Filtramos cuáles han desaparecido de la web oficial - const missingServices = dbServices.filter(s => !currentWebRefs.includes(s.service_ref)); - const refsToArchive = missingServices.map(s => s.service_ref); - - if (refsToArchive.length > 0) { - // 3. Los archivamos (los quitamos del buzón) - await client.query( - `UPDATE scraped_services - SET status = 'archived' - WHERE owner_id = $1 - AND provider = $2 - AND service_ref = ANY($3)`, - [ownerId, provider, refsToArchive] - ); - - // ======================================================== - // 🛡️ EL ESCUDO ANTI-VIAJES EN BALDE (Para la App del Técnico) - // ======================================================== - // Buscamos el ID del estado "Anulado" de este propietario - const statusQ = await client.query("SELECT id FROM service_statuses WHERE owner_id = $1 AND name ILIKE '%anulado%' LIMIT 1", [ownerId]); - const idAnulado = statusQ.rowCount > 0 ? statusQ.rows[0].id : null; - - if (idAnulado) { - for (const svc of missingServices) { - // Si el expediente estaba asignado a un técnico... - if (svc.assigned_to) { - const raw = svc.raw_data || {}; - const currentStatusId = String(raw.status_operativo || ""); - - // ...y su estado actual no era ya "Anulado" - if (currentStatusId !== String(idAnulado)) { - - // Comprobamos si el técnico ya lo había "Finalizado" (para no pisarle el trabajo hecho) - let isFinal = false; - if (currentStatusId) { - const checkStatusQ = await client.query("SELECT is_final FROM service_statuses WHERE id = $1", [currentStatusId]); - isFinal = checkStatusQ.rowCount > 0 ? checkStatusQ.rows[0].is_final : false; - } - - // Si NO estaba finalizado, procedemos a ANULARLO automáticamente - if (!isFinal) { - raw.status_operativo = idAnulado; - - await client.query("UPDATE scraped_services SET raw_data = $1 WHERE id = $2", [JSON.stringify(raw), svc.id]); - - // Dejamos huella en la trazabilidad para que sepas por qué se anuló - await client.query( - "INSERT INTO scraped_service_logs (scraped_id, user_name, action, details) VALUES ($1, $2, $3, $4)", - [svc.id, "Sistema Robot", "Cancelación Automática", "La compañía ha cancelado/retirado el expediente. Se pasa a estado Anulado para avisar al técnico."] - ); - console.log(`🛡️ [ESCUDO] Expediente ${svc.service_ref} anulado automáticamente (Técnico salvado de viajar en balde).`); - } - } - } - } - } - // ======================================================== - - console.log(`📦 [${provider.toUpperCase()}] Archivados ${refsToArchive.length} expedientes desaparecidos.`); - } - } catch (error) { - console.error(`❌ Error archivando ${provider}:`, error.message); - } finally { - client.release(); + } catch (e) { + console.error("❌ [HomeServe] Error:", e.message); + } finally { + await browser.close(); } }