marsalva/api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Actualizar worker-homeserve.js

Browse Source
This commit is contained in:
marsalva
2026-03-09 08:16:12 +00:00
parent fa7386d96c
commit 13d83d19f5
1 changed files with 126 additions and 174 deletions
Download Patch File Download Diff File Expand all files Collapse all files

288
worker-homeserve.js
View File

@@ -1,4 +1,4 @@
// worker-homeserve.js (Versión Definitiva PostgreSQL - MULTI-EMPRESA SAAS)
// worker-homeserve.js (Versión SaaS Ultra-Eficaz con Logs Reforzados)
import { chromium } from 'playwright';
import pg from 'pg';
@@ -10,241 +10,193 @@ const CONFIG = {
LOGIN_URL: 'https://www.clientes.homeserve.es/cgi-bin/fccgi.exe?w3exec=PROF_PASS',
BASE_CGI: 'https://www.clientes.homeserve.es/cgi-bin/fccgi.exe',
NAV_TIMEOUT: 60000,
POLL_INTERVAL_MS: 5000 // Cada 5 segundos mira si hay trabajo en la pizarra
POLL_INTERVAL_MS: 5000
};
if (!CONFIG.DATABASE_URL) {
console.error("❌ ERROR FATAL: Falta la variable de entorno DATABASE_URL");
process.exit(1);
}
// Conexión a la Base de Datos
const pool = new Pool({ connectionString: CONFIG.DATABASE_URL, ssl: false });
// --- UTILS ---
const sleep = (ms) => new Promise((r) => setTimeout(r, ms));
// --- HELPERS ---
function checkWeekend(dateStr) {
if (!dateStr) return;
const parts = dateStr.split('/');
if (parts.length !== 3) return;
const day = parseInt(parts[0], 10);
const month = parseInt(parts[1], 10) - 1;
const year = parseInt(parts[2], 10);
const d = new Date(year, month, day);
const dayOfWeek = d.getDay();
if (dayOfWeek === 0 || dayOfWeek === 6) {
throw new Error(`⛔ ERROR: La fecha ${dateStr} es fin de semana (Sáb/Dom). No permitido por HomeServe.`);
const d = new Date(parseInt(parts[2]), parseInt(parts[1]) - 1, parseInt(parts[0]));
if (d.getDay() === 0 || d.getDay() === 6) {
throw new Error(`⛔ ERROR: La fecha ${dateStr} es fin de semana.`);
}
}
// --- DESENCRIPTAR CREDENCIALES (MULTI-EMPRESA) ---
async function getHomeServeCreds(ownerId) {
const q = await pool.query(
"SELECT username, password_hash FROM provider_credentials WHERE provider = 'homeserve' AND status = 'active' AND owner_id = $1 LIMIT 1",
[ownerId]
);
if (q.rowCount === 0) {
throw new Error(`No hay credenciales activas de HomeServe para la empresa/dueño ID: ${ownerId}.`);
}
const user = q.rows[0].username;
// Convierte el Base64 a texto normal
const pass = Buffer.from(q.rows[0].password_hash, 'base64').toString('utf-8');
return { user, pass };
}
// --- PLAYWRIGHT HELPERS ---
async function withBrowser(fn) {
const browser = await chromium.launch({ headless: true, args: ['--no-sandbox', '--disable-setuid-sandbox'] });
const context = await browser.newContext();
const page = await context.newPage();
try { return await fn(page); } finally { await browser.close().catch(() => {}); }
if (q.rowCount === 0) throw new Error(`Sin credenciales para empresa ID: ${ownerId}`);
return {
user: q.rows[0].username,
pass: Buffer.from(q.rows[0].password_hash, 'base64').toString('utf-8')
};
}
async function findLocatorInFrames(page, selector) {
for (const fr of page.frames()) {
const loc = fr.locator(selector);
try { if (await loc.count()) return { frame: fr, locator: loc }; } catch (_) {}
}
return null;
// Primero buscamos en la página principal
const mainLoc = page.locator(selector);
if (await mainLoc.count() > 0) return mainLoc.first();
// Si no está, buscamos dentro de cada frame (HomeServe usa muchos frames)
for (const frame of page.frames()) {
const frameLoc = frame.locator(selector);
try {
if (await frameLoc.count() > 0) return frameLoc.first();
} catch (e) {}
}
return null;
}
async function clickFirstThatExists(page, selectors) {
for (const sel of selectors) {
const hit = await findLocatorInFrames(page, sel);
if (hit) { await hit.locator.first().click(); return sel; }
}
return null;
}
async function fillFirstThatExists(page, selectors, value) {
for (const sel of selectors) {
const hit = await findLocatorInFrames(page, sel);
if (hit) { await hit.locator.first().fill(String(value)); return sel; }
}
return null;
}
// --- INYECCIÓN EN HOMESERVE ---
// --- PROCESO PRINCIPAL ---
async function loginAndProcess(page, creds, jobData) {
console.log(`>>> 1. Login en HomeServe con usuario: ${creds.user}`);
console.log(` [1] Intentando Login (${creds.user})...`);
if (jobData.appointment_date) checkWeekend(jobData.appointment_date);
if (jobData.appointment_date) checkWeekend(jobData.appointment_date);
if (!jobData.observation || jobData.observation.trim().length === 0) {
throw new Error('⛔ ERROR: El campo Observaciones es obligatorio para HomeServe.');
}
// Manejo de diálogos (Alertas de la web que bloquean el proceso)
page.on('dialog', async dialog => {
console.log(` [DIALOG] Mensaje detectado: ${dialog.message()}`);
await dialog.accept();
});
await page.goto(CONFIG.LOGIN_URL, { waitUntil: 'domcontentloaded', timeout: CONFIG.NAV_TIMEOUT });
await page.waitForTimeout(1000);
await page.goto(CONFIG.LOGIN_URL, { waitUntil: 'networkidle', timeout: CONFIG.NAV_TIMEOUT });
await fillFirstThatExists(page, ['input[name="w3user"]', 'input[type="text"]'], creds.user);
await fillFirstThatExists(page, ['input[name="w3clau"]', 'input[type="password"]'], creds.pass);
const userInp = await findLocatorInFrames(page, 'input[name="w3user"]');
const passInp = await findLocatorInFrames(page, 'input[name="w3clau"]');
await page.keyboard.press('Enter');
await page.waitForTimeout(3000);
if (!userInp || !passInp) throw new Error("No se cargó el formulario de login.");
const loginFail = await findLocatorInFrames(page, 'input[type="password"]');
if (loginFail) throw new Error(`Login fallido en HomeServe para el usuario ${creds.user}. Revise las credenciales.`);
await userInp.fill(creds.user);
await passInp.fill(creds.pass);
await page.keyboard.press('Enter');
console.log(`>>> 2. Login OK. Navegando al expediente ${jobData.service_number}...`);
await page.waitForTimeout(3000);
const serviceUrl = `${CONFIG.BASE_CGI}?w3exec=ver_servicioencurso&Servicio=${jobData.service_number}&Pag=1`;
await page.goto(serviceUrl, { waitUntil: 'domcontentloaded', timeout: CONFIG.NAV_TIMEOUT });
await page.waitForTimeout(1500);
// Verificar si seguimos en login
if (await page.locator('input[type="password"]').count() > 0) {
throw new Error("Credenciales rechazadas por HomeServe.");
}
const changeBtn = await clickFirstThatExists(page, ['input[name="repaso"]']);
if (!changeBtn) {
throw new Error(`No veo el botón 'repaso'. ¿El siniestro ${jobData.service_number} existe y está abierto?`);
}
console.log(` [2] Login OK. Buscando expediente: ${jobData.service_number}...`);
const serviceUrl = `${CONFIG.BASE_CGI}?w3exec=ver_servicioencurso&Servicio=${jobData.service_number}&Pag=1`;
await page.goto(serviceUrl, { waitUntil: 'domcontentloaded' });
console.log('>>> 3. Accediendo al formulario. Rellenando datos...');
await page.waitForLoadState('domcontentloaded');
await page.waitForTimeout(1000);
const repasBtn = await findLocatorInFrames(page, 'input[name="repaso"]');
if (!repasBtn) throw new Error("No se encuentra el siniestro o no permite 'repaso'.");
await repasBtn.click();
// 🔴 MAGIA: DICCIONARIO TRADUCTOR DE ESTADOS
const HOMESERVE_MAP = {
'CITADO': '307',
'ESPERA': '303',
'TERMINADO': '345',
'ANULADO': '352'
};
console.log(' [3] Rellenando formulario de cambio de estado...');
await page.waitForTimeout(2000);
let targetCode = jobData.new_status.toUpperCase();
if (HOMESERVE_MAP[targetCode]) {
targetCode = HOMESERVE_MAP[targetCode];
}
// Selección de Estado
const targetCode = jobData.new_status;
const statusOk = await page.evaluate((code) => {
const sel = document.querySelector('select[name="ESTADO"]');
if (!sel) return false;
// Buscamos por valor (código 307, 348...) o por texto parcial
for (let opt of sel.options) {
if (opt.value == code || opt.text.includes(code)) {
sel.value = opt.value;
sel.dispatchEvent(new Event('change', { bubbles: true }));
return true;
}
}
return false;
}, targetCode);
const statusOk = await page.evaluate((code) => {
const select = document.querySelector('select[name="ESTADO"]');
if (!select) return false;
for (const opt of select.options) {
if (opt.value == code || opt.text.toUpperCase().includes(code.toUpperCase())) {
select.value = opt.value;
return true;
}
}
return false;
}, targetCode);
if (!statusOk) throw new Error(`Estado '${targetCode}' no disponible en la web.`);
if (!statusOk) throw new Error(`No encontré el estado '${jobData.new_status}' (Buscando código interno: ${targetCode}) en el desplegable de HomeServe.`);
// Fecha Siguiente Acción
if (jobData.appointment_date) {
const dateInp = await findLocatorInFrames(page, 'input[name="FECSIG"]');
if (dateInp) await dateInp.fill(jobData.appointment_date);
}
if (jobData.appointment_date) {
const dateFilled = await fillFirstThatExists(page, ['input[name="FECSIG"]'], jobData.appointment_date);
if (!dateFilled) console.warn('⚠️ No encontré el recuadro para la fecha.');
}
// Observaciones
const obsInp = await findLocatorInFrames(page, 'textarea[name="Observaciones"]');
if (!obsInp) throw new Error("Campo observaciones no encontrado.");
await obsInp.fill(jobData.observation);
const obsFilled = await fillFirstThatExists(page, ['textarea[name="Observaciones"]'], jobData.observation);
if (!obsFilled) throw new Error('No encontré el recuadro de Observaciones en la web de HomeServe.');
// Informar Cliente
if (jobData.inform_client) {
const check = await findLocatorInFrames(page, 'input[name="INFORMO"]');
if (check && !(await check.isChecked())) await check.check();
}
if (jobData.inform_client) {
const informCheck = await findLocatorInFrames(page, 'input[name="INFORMO"]');
if (informCheck && !(await informCheck.locator.first().isChecked())) {
await informCheck.locator.first().check();
}
}
console.log(' [4] Ejecutando CLIC DE GUARDADO FINAL...');
const btnGuardar = await findLocatorInFrames(page, 'input[name="BTNCAMBIAESTADO"]');
if (!btnGuardar) throw new Error("Botón GUARDAR no encontrado.");
console.log('>>> 4. Guardando cambios en HomeServe...');
// Clic con reintento y espera de red
await Promise.all([
page.waitForLoadState('networkidle').catch(() => {}),
btnGuardar.click()
]);
const saveBtnLocator = page.locator('input[name="BTNCAMBIAESTADO"]');
// Verificación de éxito
await page.waitForTimeout(3000);
const feedback = await page.evaluate(() => {
// Buscamos textos rojos o negritas que indiquen el resultado
const el = document.querySelector('font[color="#FF0000"], .Estilo4, b, .mensaje');
return el ? el.innerText : "";
});
if (await saveBtnLocator.count() === 0) {
throw new Error('No encuentro el botón para guardar los cambios en HomeServe.');
}
console.log(` [RESULTADO] Web dice: "${feedback.trim() || 'Sin mensaje visible'}"`);
// Esperamos a que la página navegue DESPUÉS de hacer clic (El Clic Seguro)
await Promise.all([
page.waitForNavigation({ waitUntil: 'domcontentloaded', timeout: CONFIG.NAV_TIMEOUT }),
saveBtnLocator.first().click()
]);
const esExito = feedback.toUpperCase().includes('EXITO') ||
feedback.toUpperCase().includes('ÉXITO') ||
feedback.toUpperCase().includes('MODIFICADO') ||
feedback.toUpperCase().includes('ACTUALIZADO');
// 🔴 LECTURA INTELIGENTE DEL RESULTADO (Evita los falsos errores rojos)
const alertText = await page.locator('font[color="#FF0000"], .Estilo4').first().textContent().catch(() => null);
if (alertText && alertText.trim().length > 0) {
const textUpper = alertText.toUpperCase();
if (!textUpper.includes('EXITO') && !textUpper.includes('ÉXITO')) {
throw new Error(`HomeServe devolvió un error: ${alertText.trim()}`);
} else {
console.log(`>>> Confirmación positiva de HomeServe: ${alertText.trim()}`);
}
}
if (!esExito && feedback.length > 0) {
throw new Error(`HomeServe denegó el cambio: ${feedback}`);
}
await page.waitForTimeout(2000);
return { success: true };
return { success: true };
}
// --- EL CEREBRO: LECTURA DE LA COLA EN POSTGRESQL ---
// --- BUCLE DE COLA ---
async function pollQueue() {
try {
const res = await pool.query(`
UPDATE robot_queue
SET status = 'RUNNING', updated_at = NOW()
WHERE id = (
SELECT id FROM robot_queue
WHERE status = 'PENDING' AND provider = 'homeserve'
ORDER BY created_at ASC
FOR UPDATE SKIP LOCKED
LIMIT 1
)
UPDATE robot_queue SET status = 'RUNNING', updated_at = NOW()
WHERE id = (SELECT id FROM robot_queue WHERE status = 'PENDING' AND provider = 'homeserve' ORDER BY created_at ASC FOR UPDATE SKIP LOCKED LIMIT 1)
RETURNING *;
`);
if (res.rowCount > 0) {
const job = res.rows[0];
console.log(`\n========================================`);
console.log(`🤖 TRABAJO #${job.id} | Empresa ID: ${job.owner_id}`);
console.log(`📋 Siniestro: ${job.service_number} -> Cambiar a: ${job.new_status}`);
console.log(`========================================`);
console.log(`\n🚀 TRABAJO #${job.id} | Exp: ${job.service_number} | Accion: ${job.new_status}`);
const browser = await chromium.launch({ headless: true, args: ['--no-sandbox'] });
const page = await browser.newPage();
try {
const creds = await getHomeServeCreds(job.owner_id);
await withBrowser(async (page) => {
await loginAndProcess(page, creds, job);
});
await loginAndProcess(page, creds, job);
await pool.query("UPDATE robot_queue SET status = 'DONE', updated_at = NOW() WHERE id = $1", [job.id]);
console.log(`✅ TRABAJO #${job.id} COMPLETADO CON ÉXITO.\n`);
console.log(`✅ COMPLETADO #${job.id}`);
} catch (err) {
console.error(`❌ ERROR EN TRABAJO #${job.id}:`, err.message);
console.error(`❌ ERROR #${job.id}:`, err.message);
await pool.query("UPDATE robot_queue SET status = 'FAILED', error_msg = $1, updated_at = NOW() WHERE id = $2", [err.message, job.id]);
} finally {
await browser.close();
setTimeout(pollQueue, 1000);
}
setTimeout(pollQueue, 1000);
} else {
setTimeout(pollQueue, CONFIG.POLL_INTERVAL_MS);
}
} catch (e) {
console.error("Error crítico en el bucle del robot:", e.message);
console.error("Error en bucle:", e.message);
setTimeout(pollQueue, CONFIG.POLL_INTERVAL_MS);
}
}
// --- INICIO ---
console.log("🚀 Robot HomeServe (Multi-Empresa SaaS) Iniciado.");
console.log("📡 Conectado a PostgreSQL. Esperando peticiones en la cola...");
console.log("📡 Robot HomeServe SaaS Online...");
pollQueue();