From 8a1c660cd6ff3bdc881761927d57a3c92b329752 Mon Sep 17 00:00:00 2001 From: marsalva Date: Wed, 14 Jan 2026 08:07:13 +0000 Subject: [PATCH] Actualizar index.js --- index.js | 64 +++++++++++++++++++++++++++++++++++++------------------- 1 file changed, 42 insertions(+), 22 deletions(-) diff --git a/index.js b/index.js index 906e26f..8bd4677 100644 --- a/index.js +++ b/index.js @@ -1,7 +1,6 @@ const { chromium } = require('playwright'); const admin = require('firebase-admin'); - if (!admin.apps.length) { admin.initializeApp({ credential: admin.credential.cert({ @@ -17,8 +16,11 @@ const COLLECTION_PENDIENTES = "multiasistencia_pendientes"; async function runMultiasistencia() { console.log(`\nšŸ•’ [${new Date().toLocaleTimeString()}] Iniciando ciclo...`); - let user, pass; + + // 1. Guardamos la hora de inicio para comparar despuĆ©s + const startRunTime = new Date(); + let user, pass; try { const credSnap = await db.collection("providerCredentials").doc("multiasistencia").get(); if (!credSnap.exists) return console.error("āŒ No hay credenciales."); @@ -70,7 +72,7 @@ async function runMultiasistencia() { while (tieneSiguiente && paginaActual <= 3) { console.log(`šŸ“„ PĆ”gina ${paginaActual}...`); - + const expedientes = await page.evaluate(() => { const links = Array.from(document.querySelectorAll('a[href*="reparacion="]')); return Array.from(new Set(links.map(a => a.href.match(/reparacion=(\d+)/)?.[1]).filter(Boolean))); @@ -90,22 +92,19 @@ async function runMultiasistencia() { for (const ref of expedientes) { const detalleUrl = `https://web.multiasistencia.com/w3multi/repasos1.php?reparacion=${ref}`; - try { await page.goto(detalleUrl, { waitUntil: 'domcontentloaded' }); await page.waitForTimeout(1500); let foundData = false; - for (const frame of page.frames()) { try { const scrapData = await frame.evaluate(() => { const clean = (text) => text ? text.replace(/\s+/g, ' ').trim() : ""; const bodyText = document.body?.innerText || ""; - + if (!bodyText.includes("Nombre Cliente") && !bodyText.includes("Asegurado")) return null; - // Buscar valor por fila: "Etiqueta" | "Valor" const findRowValue = (labels) => { const rows = Array.from(document.querySelectorAll('tr')); for (const tr of rows) { @@ -122,7 +121,6 @@ async function runMultiasistencia() { }; const allCells = Array.from(document.querySelectorAll('td, th')); - const getVertical = (keywords) => { const header = allCells.find(el => keywords.some(k => (el.innerText || "").trim().toUpperCase() === k.toUpperCase())); if (!header) return null; @@ -130,13 +128,11 @@ async function runMultiasistencia() { const row = header.parentElement; const tbody = row.parentElement; let nextRow = row.nextElementSibling; - if (!nextRow && tbody.tagName === 'THEAD') { const table = header.closest('table'); const realBody = table ? table.querySelector('tbody') : null; if (realBody && realBody.rows && realBody.rows[0]) nextRow = realBody.rows[0]; } - if (nextRow && nextRow.cells && nextRow.cells[cellIndex]) { return clean(nextRow.cells[cellIndex].innerText); } @@ -151,16 +147,12 @@ async function runMultiasistencia() { return null; }; - // āœ… DESCRIPTION: "DescripciĆ³n de la ReparaciĆ³n" y cortar antes de la primera fecha dd/mm/yyyy const getDescription = () => { let text = findRowValue(["DescripciĆ³n de la ReparaciĆ³n"]) || getHorizontal(["DescripciĆ³n de la ReparaciĆ³n", "DescripciĆ³n", "DaƱos"]) || ""; - text = clean(text); - - // Cortar en la primera fecha dd/mm/yyyy (da igual si va con parĆ©ntesis o no) const idxDate = text.search(/\b\d{2}\/\d{2}\/\d{4}\b/); if (idxDate !== -1) { text = text.substring(0, idxDate).trim(); @@ -168,10 +160,9 @@ async function runMultiasistencia() { return text; }; - // āœ… multiStatus: guardar el ESTADO tal cual aparece (incluyendo "(27/07/2025 - 13:13)") const getStatus = () => { const st = findRowValue(["Estado", "SituaciĆ³n"]); - if (st) return st; // guardamos todo el texto + if (st) return st; return getHorizontal(["Estado", "SituaciĆ³n"]) || "PENDIENTE"; }; @@ -185,13 +176,11 @@ async function runMultiasistencia() { let rawText = ""; const titleDiv = Array.from(document.querySelectorAll('div.subtitulo')) .find(d => (d.innerText || "").includes("TelĆ©fono del Cliente")); - if (titleDiv) { const table = titleDiv.closest('table') || titleDiv.parentElement.querySelector('table'); if (table) rawText = table.innerText || ""; } if (!rawText) rawText = bodyText; - const match = rawText.match(/[6789]\d{8}/); return match ? match[0] : "Sin telĆ©fono"; }; @@ -228,13 +217,15 @@ async function runMultiasistencia() { if (scrapData && scrapData.clientName) { scrapData.serviceNumber = ref; console.log(`āœ… EXITO ${ref}: ${scrapData.clientName} | Estado: ${scrapData.multiStatus}`); - + await db.collection(COLLECTION_PENDIENTES).doc(ref).set({ ...scrapData, status: "pendiente_validacion", - updatedAt: admin.firestore.FieldValue.serverTimestamp() + updatedAt: admin.firestore.FieldValue.serverTimestamp(), + // 2. AƑADIMOS "VISTO POR ƚLTIMA VEZ" + lastSeenAt: admin.firestore.FieldValue.serverTimestamp() }, { merge: true }); - + foundData = true; break; } @@ -247,7 +238,9 @@ async function runMultiasistencia() { serviceNumber: ref, status: "error_formato", clientName: "ERROR - REVISAR MANUAL", - updatedAt: admin.firestore.FieldValue.serverTimestamp() + updatedAt: admin.firestore.FieldValue.serverTimestamp(), + // TambiĆ©n lo marcamos aquĆ­ para que no se "borre" si da error de lectura pero sigue existiendo + lastSeenAt: admin.firestore.FieldValue.serverTimestamp() }, { merge: true }); } @@ -274,6 +267,33 @@ async function runMultiasistencia() { } } + // 3. LIMPIEZA FINAL (Solo afecta a los que tengan 'lastSeenAt' antiguo) + console.log("šŸ§¹ Verificando servicios que han desaparecido de la web..."); + + // Esta consulta busca documentos que tengan el campo lastSeenAt Y sea viejo. + // Los documentos antiguos sin ese campo serĆ”n ignorados. + const snapshotViejos = await db.collection(COLLECTION_PENDIENTES) + .where('lastSeenAt', '<', startRunTime) + .get(); + + if (!snapshotViejos.empty) { + console.log(`šŸ—‘ļø Se han detectado ${snapshotViejos.size} servicios rastreados que ya no estĆ”n.`); + const batch = db.batch(); + + snapshotViejos.docs.forEach(doc => { + // Opcional: Verificar que no estĆ© ya cerrado para no escribir de mĆ”s + if (doc.data().status !== "cerrado_multiasistencia") { + batch.update(doc.ref, { + status: "cerrado_multiasistencia", + closedAt: admin.firestore.FieldValue.serverTimestamp() + }); + } + }); + + await batch.commit(); + console.log("āœ… Limpieza completada."); + } + } catch (e) { console.error("āŒ Error General:", e.message); } finally {