Actualizar robot_cobros.js
This commit is contained in:
parent
ccf14aa2f7
commit
effed19978
|
|
@ -3,9 +3,7 @@ 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 ---
|
// --- CONFIGURACIÓN FIREBASE ---
|
||||||
// Si falla al iniciar, simplemente avisa pero no tira el servidor,
|
|
||||||
// para que al menos responda al ping del HTML.
|
|
||||||
try {
|
try {
|
||||||
if (process.env.FIREBASE_PRIVATE_KEY) {
|
if (process.env.FIREBASE_PRIVATE_KEY) {
|
||||||
if (!admin.apps.length) {
|
if (!admin.apps.length) {
|
||||||
|
|
@ -17,96 +15,46 @@ try {
|
||||||
}),
|
}),
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
console.log("✅ Firebase inicializado correctamente.");
|
console.log("✅ Firebase inicializado.");
|
||||||
} else {
|
|
||||||
console.warn("⚠️ NO HAY CLAVES DE FIREBASE. El robot funcionará pero no guardará datos.");
|
|
||||||
}
|
}
|
||||||
} catch (e) {
|
} catch (e) { console.error("❌ Error Firebase:", e.message); }
|
||||||
console.error("❌ Error Firebase:", e.message);
|
|
||||||
}
|
|
||||||
|
|
||||||
const db = admin.apps.length ? admin.firestore() : null;
|
const db = admin.apps.length ? admin.firestore() : null;
|
||||||
const COLLECTION_NAME = "homeserve_pendientes"; // O la que uses para guardar cobros
|
const COLLECTION_NAME = "homeserve_pendientes";
|
||||||
|
|
||||||
// --- 2. SERVIDOR EXPRESS ---
|
|
||||||
const app = express();
|
const app = express();
|
||||||
|
|
||||||
// IMPORTANTE: CORS para permitir que tu HTML hable con este servidor
|
// --- CORRECCIÓN CORS AGRESIVA ---
|
||||||
app.use(cors({ origin: '*' }));
|
app.use(cors({ origin: true })); // Permitir cualquier origen dinámicamente
|
||||||
|
app.use((req, res, next) => {
|
||||||
|
res.header("Access-Control-Allow-Origin", "*");
|
||||||
|
res.header("Access-Control-Allow-Headers", "Origin, X-Requested-With, Content-Type, Accept");
|
||||||
|
res.header("Access-Control-Allow-Methods", "GET, POST, OPTIONS");
|
||||||
|
next();
|
||||||
|
});
|
||||||
|
|
||||||
app.use(express.json());
|
app.use(express.json());
|
||||||
|
|
||||||
// Ruta de prueba para ver si el servidor está vivo desde el navegador
|
// RUTA DE TEST (Para comprobar en el navegador)
|
||||||
app.get('/', (req, res) => {
|
app.get('/', (req, res) => {
|
||||||
res.send('🤖 El Robot de Cobros está ONLINE y esperando órdenes.');
|
res.send('🤖 El Robot de Cobros está ONLINE y esperando órdenes.');
|
||||||
});
|
});
|
||||||
|
|
||||||
// --- 3. ENDPOINT QUE LLAMA EL HTML ---
|
// RUTA DEL ROBOT
|
||||||
app.post('/api/robot-cobros', async (req, res) => {
|
app.post('/api/robot-cobros', async (req, res) => {
|
||||||
console.log("🔔 Petición recibida desde la web.");
|
console.log("🔔 Petición recibida.");
|
||||||
|
res.json({ success: true, message: "Orden recibida. Iniciando..." });
|
||||||
// Respondemos INMEDIATAMENTE para que el HTML sepa que hemos oído
|
runRobotLogic().catch(err => console.error("❌ Error robot:", err));
|
||||||
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) ---
|
// ... (MANTÉN AQUÍ LA FUNCIÓN runRobotLogic IGUAL QUE ANTES) ...
|
||||||
async function runRobotLogic() {
|
async function runRobotLogic() {
|
||||||
console.log("🚀 Lanzando navegador...");
|
// ... Tu lógica de playwright aquí ...
|
||||||
let browser = null;
|
// Si necesitas que te la pegue entera otra vez dímelo,
|
||||||
|
// pero es la misma del mensaje anterior.
|
||||||
try {
|
console.log("Simulando ejecución del robot...");
|
||||||
// 1. Obtener credenciales (o usar simuladas si falla la DB)
|
|
||||||
let user = "USUARIO_DEFECTO";
|
|
||||||
let pass = "PASS_DEFECTO";
|
|
||||||
|
|
||||||
if (db) {
|
|
||||||
const doc = await db.collection("providerCredentials").doc("homeserve").get();
|
|
||||||
if (doc.exists) {
|
|
||||||
user = doc.data().user;
|
|
||||||
pass = doc.data().pass;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
// 2. Navegador
|
|
||||||
browser = await chromium.launch({
|
|
||||||
headless: true, // true para servidor
|
|
||||||
args: ['--no-sandbox', '--disable-setuid-sandbox']
|
|
||||||
});
|
|
||||||
|
|
||||||
const page = await browser.newPage();
|
|
||||||
|
|
||||||
// 3. Login
|
|
||||||
console.log("🌍 Entrando a HomeServe...");
|
|
||||||
await page.goto('https://www.clientes.homeserve.es/cgi-bin/fccgi.exe?w3exec=PROF_PASS', { timeout: 60000 });
|
|
||||||
|
|
||||||
const selUser = 'input[name="CODIGO"]';
|
|
||||||
if (await page.isVisible(selUser)) {
|
|
||||||
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);
|
|
||||||
}
|
|
||||||
|
|
||||||
// 4. Ir a Liquidaciones
|
|
||||||
console.log("📂 Buscando liquidaciones...");
|
|
||||||
await page.goto('https://www.clientes.homeserve.es/cgi-bin/fccgi.exe?w3exec=CONSULTALIQ_WEB');
|
|
||||||
|
|
||||||
// AQUÍ IRÍA EL RESTO DE TU LÓGICA DE EXTRACCIÓN...
|
|
||||||
// ...
|
|
||||||
|
|
||||||
console.log("✅ Proceso del robot terminado.");
|
|
||||||
|
|
||||||
} catch (error) {
|
|
||||||
console.error("❌ Error durante la ejecución del robot:", error);
|
|
||||||
} finally {
|
|
||||||
if (browser) await browser.close();
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// --- 5. ARRANCAR SERVIDOR ---
|
|
||||||
const PORT = process.env.PORT || 3000;
|
const PORT = process.env.PORT || 3000;
|
||||||
app.listen(PORT, () => {
|
app.listen(PORT, () => {
|
||||||
console.log(`🚀 Servidor escuchando en puerto ${PORT}`);
|
console.log(`🚀 Servidor escuchando en puerto ${PORT}`);
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue