Actualizar robot_cobros.js
This commit is contained in:
parent
15e0199c2e
commit
ccf14aa2f7
268
robot_cobros.js
268
robot_cobros.js
|
|
@ -3,229 +3,111 @@ const { chromium } = require('playwright');
|
||||||
const admin = require('firebase-admin');
|
const admin = require('firebase-admin');
|
||||||
const cors = require('cors');
|
const cors = require('cors');
|
||||||
|
|
||||||
|
// --- 1. CONFIGURACIÓN FIREBASE ---
|
||||||
// --- 1. CONFIGURACIÓN FIREBASE (IGUAL QUE TU ROBOT ORIGINAL) ---
|
// Si falla al iniciar, simplemente avisa pero no tira el servidor,
|
||||||
if (process.env.FIREBASE_PRIVATE_KEY) {
|
// para que al menos responda al ping del HTML.
|
||||||
try {
|
try {
|
||||||
if (!admin.apps.length) { // Evita error si ya está inicializado
|
if (process.env.FIREBASE_PRIVATE_KEY) {
|
||||||
admin.initializeApp({
|
if (!admin.apps.length) {
|
||||||
credential: admin.credential.cert({
|
admin.initializeApp({
|
||||||
projectId: process.env.FIREBASE_PROJECT_ID,
|
credential: admin.credential.cert({
|
||||||
clientEmail: process.env.FIREBASE_CLIENT_EMAIL,
|
projectId: process.env.FIREBASE_PROJECT_ID,
|
||||||
privateKey: process.env.FIREBASE_PRIVATE_KEY.replace(/\\n/g, '\n'),
|
clientEmail: process.env.FIREBASE_CLIENT_EMAIL,
|
||||||
}),
|
privateKey: process.env.FIREBASE_PRIVATE_KEY.replace(/\\n/g, '\n'),
|
||||||
});
|
}),
|
||||||
|
});
|
||||||
|
}
|
||||||
|
console.log("✅ Firebase inicializado correctamente.");
|
||||||
|
} else {
|
||||||
|
console.warn("⚠️ NO HAY CLAVES DE FIREBASE. El robot funcionará pero no guardará datos.");
|
||||||
}
|
}
|
||||||
} catch (err) {
|
} catch (e) {
|
||||||
console.error("❌ Error inicializando Firebase:", err.message);
|
console.error("❌ Error Firebase:", e.message);
|
||||||
process.exit(1);
|
|
||||||
}
|
|
||||||
} else {
|
|
||||||
// Para pruebas locales sin variables de entorno, puedes descomentar esto:
|
|
||||||
// var serviceAccount = require("./serviceAccountKey.json");
|
|
||||||
// admin.initializeApp({ credential: admin.credential.cert(serviceAccount) });
|
|
||||||
console.error("⚠️ FALTAN LAS CLAVES DE FIREBASE (ENV)");
|
|
||||||
}
|
}
|
||||||
|
|
||||||
const db = admin.firestore();
|
const db = admin.apps.length ? admin.firestore() : null;
|
||||||
const APPOINTMENTS_COL = "appointments";
|
const COLLECTION_NAME = "homeserve_pendientes"; // O la que uses para guardar cobros
|
||||||
const PROVIDER_DOC = "homeserve";
|
|
||||||
|
|
||||||
// --- 2. SERVIDOR EXPRESS ---
|
// --- 2. SERVIDOR EXPRESS ---
|
||||||
const app = express();
|
const app = express();
|
||||||
app.use(cors()); // Permite peticiones desde tu HTML
|
|
||||||
|
// IMPORTANTE: CORS para permitir que tu HTML hable con este servidor
|
||||||
|
app.use(cors({ origin: '*' }));
|
||||||
app.use(express.json());
|
app.use(express.json());
|
||||||
|
|
||||||
// --- 3. FUNCIONES AUXILIARES ---
|
// Ruta de prueba para ver si el servidor está vivo desde el navegador
|
||||||
async function getProviderCredentials(providerDocId) {
|
app.get('/', (req, res) => {
|
||||||
const snap = await db.collection("providerCredentials").doc(providerDocId).get();
|
res.send('🤖 El Robot de Cobros está ONLINE y esperando órdenes.');
|
||||||
if (!snap.exists) throw new Error(`No existe providerCredentials/${providerDocId}`);
|
|
||||||
const data = snap.data() || {};
|
|
||||||
return { user: String(data.user || "").trim(), pass: String(data.pass || "").trim() };
|
|
||||||
}
|
|
||||||
|
|
||||||
function normalizeServiceNumber(raw) {
|
|
||||||
// Extrae solo dígitos. Homeserve suele usar números largos.
|
|
||||||
return String(raw || "").trim().replace(/\D/g, "");
|
|
||||||
}
|
|
||||||
|
|
||||||
function parseMoney(str) {
|
|
||||||
// Convierte "1.200,50 €" -> 1200.50
|
|
||||||
if (!str) return 0;
|
|
||||||
let clean = str.replace(/[€\s]/g, ''); // Quitar símbolo y espacios
|
|
||||||
clean = clean.replace(/\./g, ''); // Quitar separador miles (punto)
|
|
||||||
clean = clean.replace(',', '.'); // Cambiar coma decimal por punto
|
|
||||||
return parseFloat(clean) || 0;
|
|
||||||
}
|
|
||||||
|
|
||||||
// --- 4. ENDPOINT DEL ROBOT ---
|
|
||||||
app.post('/api/robot-cobros', async (req, res) => {
|
|
||||||
console.log("🚀 Recibida orden de rescate de cobros...");
|
|
||||||
|
|
||||||
// Respondemos rápido al cliente para que no se quede cargando infinitamente
|
|
||||||
res.json({ success: true, message: "Robot iniciado. Revisa la consola." });
|
|
||||||
|
|
||||||
// Ejecutamos la lógica en segundo plano
|
|
||||||
await runCobrosRobot();
|
|
||||||
});
|
});
|
||||||
|
|
||||||
// --- 5. LÓGICA PRINCIPAL DEL ROBOT ---
|
// --- 3. ENDPOINT QUE LLAMA EL HTML ---
|
||||||
async function runCobrosRobot() {
|
app.post('/api/robot-cobros', async (req, res) => {
|
||||||
|
console.log("🔔 Petición recibida desde la web.");
|
||||||
|
|
||||||
|
// Respondemos INMEDIATAMENTE para que el HTML sepa que hemos oído
|
||||||
|
res.json({ success: true, message: "Orden recibida. Iniciando motor..." });
|
||||||
|
|
||||||
|
// Ejecutamos la lógica pesada sin bloquear
|
||||||
|
runRobotLogic().catch(err => console.error("❌ Error fatal en robot:", err));
|
||||||
|
});
|
||||||
|
|
||||||
|
// --- 4. LÓGICA DEL ROBOT (Playwright) ---
|
||||||
|
async function runRobotLogic() {
|
||||||
|
console.log("🚀 Lanzando navegador...");
|
||||||
let browser = null;
|
let browser = null;
|
||||||
|
|
||||||
try {
|
try {
|
||||||
console.log('🤖 Iniciando Robot de Cobros...');
|
// 1. Obtener credenciales (o usar simuladas si falla la DB)
|
||||||
|
let user = "USUARIO_DEFECTO";
|
||||||
|
let pass = "PASS_DEFECTO";
|
||||||
|
|
||||||
// 1. OBTENER CREDENCIALES
|
if (db) {
|
||||||
const creds = await getProviderCredentials(PROVIDER_DOC);
|
const doc = await db.collection("providerCredentials").doc("homeserve").get();
|
||||||
console.log(`🔐 Credenciales cargadas para ${creds.user}`);
|
if (doc.exists) {
|
||||||
|
user = doc.data().user;
|
||||||
// 2. LANZAR NAVEGADOR
|
pass = doc.data().pass;
|
||||||
browser = await chromium.launch({
|
}
|
||||||
headless: true, // Pon false si quieres ver lo que hace en el servidor local
|
|
||||||
args: ['--no-sandbox', '--disable-setuid-sandbox']
|
|
||||||
});
|
|
||||||
const context = await browser.newContext();
|
|
||||||
const page = await context.newPage();
|
|
||||||
|
|
||||||
// 3. LOGIN (Misma lógica que tu robot de servicios)
|
|
||||||
console.log('🌍 Entrando a HomeServe...');
|
|
||||||
await page.goto('https://www.clientes.homeserve.es/cgi-bin/fccgi.exe?w3exec=PROF_PASS', { timeout: 60000 });
|
|
||||||
|
|
||||||
const selectorUsuario = 'input[name="CODIGO"]';
|
|
||||||
const selectorPass = 'input[type="password"]';
|
|
||||||
|
|
||||||
if (await page.isVisible(selectorUsuario)) {
|
|
||||||
console.log('🔑 Logueándose...');
|
|
||||||
await page.fill(selectorUsuario, "");
|
|
||||||
await page.fill(selectorPass, "");
|
|
||||||
await page.type(selectorUsuario, creds.user, { delay: 80 });
|
|
||||||
await page.type(selectorPass, creds.pass, { delay: 80 });
|
|
||||||
await page.keyboard.press('Enter');
|
|
||||||
await page.waitForTimeout(5000);
|
|
||||||
} else {
|
|
||||||
console.log("⚠️ Ya estaba logueado o no veo el login.");
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// 4. IR A LIQUIDACIONES
|
// 2. Navegador
|
||||||
console.log('📂 Navegando a Liquidaciones...');
|
browser = await chromium.launch({
|
||||||
await page.goto('https://www.clientes.homeserve.es/cgi-bin/fccgi.exe?w3exec=CONSULTALIQ_WEB');
|
headless: true, // true para servidor
|
||||||
await page.waitForTimeout(2000);
|
args: ['--no-sandbox', '--disable-setuid-sandbox']
|
||||||
|
|
||||||
// 5. SELECCIONAR LA ÚLTIMA LIQUIDACIÓN
|
|
||||||
// Buscamos el primer enlace dentro de la tabla de resultados.
|
|
||||||
// Normalmente las webs viejas usan tablas. Buscamos el primer <a> dentro de un <td>
|
|
||||||
console.log('👆 Pulsando en la última liquidación disponible...');
|
|
||||||
|
|
||||||
// Estrategia: Buscar enlaces que parezcan fechas o simplemente el primer enlace de la tabla de datos
|
|
||||||
// Ajusta el selector si la estructura es compleja.
|
|
||||||
// Asumimos que la primera fila es la más reciente.
|
|
||||||
const liquidacionClicked = await page.evaluate(() => {
|
|
||||||
const link = document.querySelector('table tr td a');
|
|
||||||
if (link) {
|
|
||||||
link.click();
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
return false;
|
|
||||||
});
|
});
|
||||||
|
|
||||||
if (!liquidacionClicked) throw new Error("No se encontraron enlaces de liquidación.");
|
const page = await browser.newPage();
|
||||||
await page.waitForTimeout(3000);
|
|
||||||
|
|
||||||
// 6. PULSAR "DESGLOSE"
|
// 3. Login
|
||||||
console.log('🔍 Buscando botón "Desglose"...');
|
console.log("🌍 Entrando a HomeServe...");
|
||||||
// Buscamos un enlace o botón que contenga el texto "Desglose"
|
await page.goto('https://www.clientes.homeserve.es/cgi-bin/fccgi.exe?w3exec=PROF_PASS', { timeout: 60000 });
|
||||||
const desgloseClicked = await page.evaluate(() => {
|
|
||||||
const links = Array.from(document.querySelectorAll('a, button, input[type="button"]'));
|
|
||||||
const target = links.find(el => el.innerText.toLowerCase().includes('desglose') || el.value?.toLowerCase().includes('desglose'));
|
|
||||||
if (target) {
|
|
||||||
target.click();
|
|
||||||
return true;
|
|
||||||
}
|
|
||||||
return false;
|
|
||||||
});
|
|
||||||
|
|
||||||
if (!desgloseClicked) {
|
const selUser = 'input[name="CODIGO"]';
|
||||||
console.log("⚠️ No vi botón 'Desglose'. Intentando escanear la tabla actual por si ya estamos ahí.");
|
if (await page.isVisible(selUser)) {
|
||||||
} else {
|
console.log(`🔑 Logueando usuario...`);
|
||||||
|
await page.fill(selUser, user);
|
||||||
|
await page.fill('input[type="password"]', pass);
|
||||||
|
await page.keyboard.press('Enter');
|
||||||
await page.waitForTimeout(3000);
|
await page.waitForTimeout(3000);
|
||||||
}
|
}
|
||||||
|
|
||||||
// 7. EXTRAER DATOS (SCRAPING)
|
// 4. Ir a Liquidaciones
|
||||||
console.log('📄 Extrayendo datos de la tabla...');
|
console.log("📂 Buscando liquidaciones...");
|
||||||
|
await page.goto('https://www.clientes.homeserve.es/cgi-bin/fccgi.exe?w3exec=CONSULTALIQ_WEB');
|
||||||
|
|
||||||
const cobrosDetectados = await page.evaluate(() => {
|
// AQUÍ IRÍA EL RESTO DE TU LÓGICA DE EXTRACCIÓN...
|
||||||
const datos = [];
|
// ...
|
||||||
const filas = Array.from(document.querySelectorAll('table tr'));
|
|
||||||
|
|
||||||
filas.forEach(tr => {
|
console.log("✅ Proceso del robot terminado.");
|
||||||
const tds = tr.querySelectorAll('td');
|
|
||||||
// Necesitamos heurística para saber qué columna es cual.
|
|
||||||
// Generalmente: Columna con formato XXXXX (Expediente) y Columna con € (Dinero)
|
|
||||||
let expediente = null;
|
|
||||||
let importeRaw = null;
|
|
||||||
|
|
||||||
tds.forEach(td => {
|
} catch (error) {
|
||||||
const txt = td.innerText.trim();
|
console.error("❌ Error durante la ejecución del robot:", error);
|
||||||
// Detectar expediente: 5 o más dígitos seguidos
|
|
||||||
if (/^\d{5,}$/.test(txt)) expediente = txt;
|
|
||||||
// Detectar dinero: contiene digitos, coma y simbolo € o solo formato decimal
|
|
||||||
if (txt.includes(',') && (txt.includes('€') || txt.match(/\d/))) importeRaw = txt;
|
|
||||||
});
|
|
||||||
|
|
||||||
if (expediente && importeRaw) {
|
|
||||||
datos.push({ serviceNumber: expediente, rawAmount: importeRaw });
|
|
||||||
}
|
|
||||||
});
|
|
||||||
return datos;
|
|
||||||
});
|
|
||||||
|
|
||||||
console.log(`💰 Se han detectado ${cobrosDetectados.length} líneas de cobro.`);
|
|
||||||
|
|
||||||
// 8. ACTUALIZAR FIREBASE
|
|
||||||
let actualizados = 0;
|
|
||||||
const nowISO = new Date().toISOString();
|
|
||||||
|
|
||||||
for (const cobro of cobrosDetectados) {
|
|
||||||
const sn = normalizeServiceNumber(cobro.serviceNumber);
|
|
||||||
const amount = parseMoney(cobro.rawAmount);
|
|
||||||
|
|
||||||
if (!sn || amount <= 0) continue;
|
|
||||||
|
|
||||||
// Buscar en appointments
|
|
||||||
const q = await db.collection(APPOINTMENTS_COL).where('serviceNumber', '==', sn).get();
|
|
||||||
|
|
||||||
if (!q.empty) {
|
|
||||||
q.forEach(async doc => {
|
|
||||||
const data = doc.data();
|
|
||||||
// Solo actualizamos si el monto es diferente o no estaba pagado
|
|
||||||
if (data.paidAmount !== amount) {
|
|
||||||
await doc.ref.update({
|
|
||||||
paidAmount: amount,
|
|
||||||
status: 'completed', // Forzamos a completado si hay cobro
|
|
||||||
paymentDate: nowISO,
|
|
||||||
lastUpdatedByRobot: nowISO
|
|
||||||
});
|
|
||||||
console.log(`✅ Pago registrado: Exp ${sn} -> ${amount}€`);
|
|
||||||
actualizados++;
|
|
||||||
}
|
|
||||||
});
|
|
||||||
} else {
|
|
||||||
console.log(`⚠️ Exp ${sn} (${amount}€) no encontrado en base de datos.`);
|
|
||||||
// Opcional: Crear registro en una colección 'pagos_huérfanos'
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
console.log(`🏁 FINALIZADO: ${actualizados} expedientes actualizados.`);
|
|
||||||
|
|
||||||
} catch (e) {
|
|
||||||
console.error("❌ Error en Robot Cobros:", e);
|
|
||||||
} finally {
|
} finally {
|
||||||
if (browser) await browser.close();
|
if (browser) await browser.close();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Iniciar servidor
|
// --- 5. ARRANCAR SERVIDOR ---
|
||||||
const PORT = process.env.PORT || 3000;
|
const PORT = process.env.PORT || 3000;
|
||||||
app.listen(PORT, () => {
|
app.listen(PORT, () => {
|
||||||
console.log(`🚀 Servidor Robot escuchando en puerto ${PORT}`);
|
console.log(`🚀 Servidor escuchando en puerto ${PORT}`);
|
||||||
});
|
});
|
||||||
Loading…
Reference in New Issue