Actualizar robot.js

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;
-                            d['Descripción'] = cleanDesc; // Se limpiará luego abajo
                         } 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); } 
+    } catch (e) { 
-    finally { await browser.close(); }
+        console.error("❌ [HomeServe] Error:", e.message); 
-}
-
-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();
+        await browser.close(); 
     }
 }