Actualizar robot.js
This commit is contained in:
116
robot.js
116
robot.js
@@ -42,10 +42,10 @@ async function main() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// ==========================================
|
// ==========================================
|
||||||
// 🏥 MULTIASISTENCIA V7 (EXTRACCIÓN POR PATRONES DE TEXTO)
|
// 🏥 MULTIASISTENCIA V8 (LÓGICA BASADA EN FRAMES)
|
||||||
// ==========================================
|
// ==========================================
|
||||||
async function runMultiasistencia(ownerId, user, pass) {
|
async function runMultiasistencia(ownerId, user, pass) {
|
||||||
const browser = await chromium.launch({ headless: HEADLESS, args: ['--no-sandbox'] });
|
const browser = await chromium.launch({ headless: true, args: ['--no-sandbox'] });
|
||||||
const context = await browser.newContext();
|
const context = await browser.newContext();
|
||||||
const page = await context.newPage();
|
const page = await context.newPage();
|
||||||
|
|
||||||
@@ -53,78 +53,84 @@ async function runMultiasistencia(ownerId, user, pass) {
|
|||||||
console.log("🌍 [Multi] Accediendo...");
|
console.log("🌍 [Multi] Accediendo...");
|
||||||
await page.goto('https://web.multiasistencia.com/w3multi/acceso.php', { timeout: 60000 });
|
await page.goto('https://web.multiasistencia.com/w3multi/acceso.php', { timeout: 60000 });
|
||||||
|
|
||||||
const userInput = await page.$('input[name="usuario"]') || await page.$('input[type="text"]');
|
await page.fill('input[name="usuario"]', user);
|
||||||
if(userInput) {
|
await page.fill('input[type="password"]', pass);
|
||||||
await userInput.fill(user);
|
await page.click('input[type="submit"]');
|
||||||
await page.fill('input[type="password"]', pass);
|
await page.waitForTimeout(4000);
|
||||||
await page.click('input[type="submit"]');
|
|
||||||
await page.waitForTimeout(5000);
|
|
||||||
}
|
|
||||||
|
|
||||||
await page.goto('https://web.multiasistencia.com/w3multi/frepasos_new.php?refresh=1', { waitUntil: 'domcontentloaded' });
|
// Forzar recarga de listado
|
||||||
|
await page.goto('https://web.multiasistencia.com/w3multi/frepasos_new.php?refresh=1');
|
||||||
|
await page.waitForTimeout(2000);
|
||||||
|
|
||||||
const expedientes = await page.evaluate(() => {
|
const expedientes = await page.evaluate(() => {
|
||||||
const links = Array.from(document.querySelectorAll('a[href*="reparacion="]'));
|
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)));
|
return Array.from(new Set(links.map(a => a.href.match(/reparacion=(\d+)/)?.[1]).filter(Boolean)));
|
||||||
});
|
});
|
||||||
|
|
||||||
console.log(`🔍 [Multi] Procesando ${expedientes.length} expedientes.`);
|
console.log(`🔍 [Multi] ${expedientes.length} expedientes encontrados.`);
|
||||||
|
|
||||||
for (const ref of expedientes) {
|
for (const ref of expedientes) {
|
||||||
await page.goto(`https://web.multiasistencia.com/w3multi/repasos1.php?reparacion=${ref}`, { waitUntil: 'domcontentloaded' });
|
await page.goto(`https://web.multiasistencia.com/w3multi/repasos1.php?reparacion=${ref}`, { waitUntil: 'domcontentloaded' });
|
||||||
|
await page.waitForTimeout(1500);
|
||||||
|
|
||||||
const fullData = await page.evaluate(() => {
|
let scrapData = null;
|
||||||
const text = document.body.innerText;
|
|
||||||
const data = {};
|
|
||||||
|
|
||||||
// Función para extraer texto entre dos palabras clave
|
// RECORREMOS LOS FRAMES (La clave del éxito)
|
||||||
const extract = (start, end) => {
|
for (const frame of page.frames()) {
|
||||||
const regex = new RegExp(`${start}\\s*:?\\s*([\\s\\S]*?)(?=${end}|$)`, 'i');
|
try {
|
||||||
const match = text.match(regex);
|
scrapData = await frame.evaluate(() => {
|
||||||
return match ? match[1].trim() : null;
|
const clean = (t) => t ? t.replace(/\s+/g, ' ').trim() : "";
|
||||||
};
|
const body = document.body?.innerText || "";
|
||||||
|
|
||||||
// CAPTURA POR BLOQUES DE TEXTO (IGNORANDO TABLAS)
|
// Si este frame no tiene datos de cliente, lo saltamos
|
||||||
data['Número Reparación'] = extract('Número Reparación', 'Número de Póliza');
|
if (!body.includes("Nombre Cliente") && !body.includes("Asegurado")) return null;
|
||||||
data['Número de Póliza'] = extract('Número de Póliza', 'Nombre Cliente');
|
|
||||||
data['Nombre Cliente'] = extract('Nombre Cliente', 'Dirección');
|
|
||||||
data['Dirección'] = extract('Dirección', 'Baremo');
|
|
||||||
data['Distrito Postal'] = extract('Distrito Postal', 'Más información');
|
|
||||||
data['Procedencia'] = extract('Procedencia', 'Forma de pago');
|
|
||||||
data['Descripción'] = extract('Descripción de la Reparación', 'Urgente');
|
|
||||||
data['Tramitador'] = extract('Tramitador', 'Teléfono del Cliente');
|
|
||||||
data['Urgente'] = extract('Urgente', 'Fecha realización');
|
|
||||||
data['Fecha realización'] = extract('Fecha realización', 'Estado');
|
|
||||||
|
|
||||||
// Teléfonos (Regex de 9 dígitos limpia)
|
const allCells = Array.from(document.querySelectorAll('td, th, b'));
|
||||||
const phones = text.match(/[6789]\d{8}/g);
|
|
||||||
if (phones) data['phone_fixed'] = [...new Set(phones)].join(' / ');
|
|
||||||
|
|
||||||
// Limpieza final: si el valor capturado contiene el nombre de otra etiqueta, está mal
|
// Lógica de búsqueda horizontal (Etiqueta -> Valor al lado)
|
||||||
const labels = ["Número Reparación", "Dirección", "Nombre Cliente", "Urgente", "Estado"];
|
const getH = (keys) => {
|
||||||
Object.keys(data).forEach(k => {
|
const header = allCells.find(el => keys.some(k => el.innerText.toUpperCase().includes(k.toUpperCase())));
|
||||||
if (data[k]) {
|
return header && header.nextElementSibling ? clean(header.nextElementSibling.innerText) : null;
|
||||||
// Cortamos si se nos ha colado la siguiente etiqueta
|
};
|
||||||
labels.forEach(l => {
|
|
||||||
if (data[k].includes(l)) data[k] = data[k].split(l)[0].trim();
|
|
||||||
});
|
|
||||||
// Quitamos saltos de línea molestos
|
|
||||||
data[k] = data[k].replace(/\n/g, ' ').replace(/\s+/g, ' ');
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
return data;
|
// Lógica de búsqueda vertical (Etiqueta -> Valor abajo)
|
||||||
});
|
const getV = (keys) => {
|
||||||
|
const header = allCells.find(el => keys.some(k => el.innerText.trim().toUpperCase() === k.toUpperCase()));
|
||||||
|
if (!header) return null;
|
||||||
|
const idx = header.cellIndex;
|
||||||
|
const nextRow = header.parentElement.nextElementSibling;
|
||||||
|
return nextRow && nextRow.cells[idx] ? clean(nextRow.cells[idx].innerText) : null;
|
||||||
|
};
|
||||||
|
|
||||||
if (fullData && Object.keys(fullData).length > 2) {
|
// Recolectamos todo con nombres estables para el mapeador
|
||||||
await saveServiceToDB(ownerId, 'multiasistencia', ref, fullData);
|
const data = {};
|
||||||
|
data['Expediente'] = getH(["Número Reparación", "Expediente"]) || "";
|
||||||
|
data['Nombre Cliente'] = getV(["Nombre Cliente", "Asegurado"]) || "";
|
||||||
|
data['Dirección'] = getV(["Dirección", "Domicilio"]) || "";
|
||||||
|
data['Población_CP'] = getV(["Distrito Postal", "C.P"]) || "";
|
||||||
|
data['Compañía'] = getH(["Procedencia", "Compañía"]) || "";
|
||||||
|
data['Descripción'] = getH(["Descripción de la Reparación", "Descripción"]) || "";
|
||||||
|
data['Urgente'] = getH(["Urgente"]) || "No";
|
||||||
|
data['Fecha Cita'] = getH(["Fecha realización"]) || "";
|
||||||
|
data['Tramitador'] = getH(["Tramitador"]) || "";
|
||||||
|
|
||||||
|
// Teléfono (Busca patrón de 9 dígitos)
|
||||||
|
const phoneMatch = body.match(/[6789]\d{8}/);
|
||||||
|
data['Teléfono'] = phoneMatch ? phoneMatch[0] : "";
|
||||||
|
|
||||||
|
return data;
|
||||||
|
});
|
||||||
|
|
||||||
|
if (scrapData && scrapData['Nombre Cliente']) break; // Si ya encontramos los datos, salimos del bucle de frames
|
||||||
|
} catch (e) { continue; }
|
||||||
|
}
|
||||||
|
|
||||||
|
if (scrapData && scrapData['Nombre Cliente']) {
|
||||||
|
await saveServiceToDB(ownerId, 'multiasistencia', ref, scrapData);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
} catch (e) {
|
} catch (e) { console.error("❌ Error Multi:", e.message); }
|
||||||
console.error("❌ [Multi] Error Crítico:", e.message);
|
finally { await browser.close(); }
|
||||||
} finally {
|
|
||||||
await browser.close();
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// ... (Mantén el resto del archivo igual)
|
// ... (Mantén el resto del archivo igual)
|
||||||
|
|||||||
Reference in New Issue
Block a user