90 lines
2.9 KiB
JavaScript
90 lines
2.9 KiB
JavaScript
require('dotenv').config(); // Carga las contraseñas del archivo .env
|
|
const express = require('express');
|
|
const cors = require('cors');
|
|
const { Client } = require('pg');
|
|
|
|
const app = express();
|
|
|
|
// --- MIDDLEWARES (Configuración) ---
|
|
app.use(express.json()); // Permite leer datos JSON
|
|
app.use(cors()); // ¡VITAL! Permite que tu Web (React) se conecte
|
|
|
|
// --- CONFIGURACIÓN DE LA BASE DE DATOS ---
|
|
const dbConfig = {
|
|
host: process.env.DB_HOST,
|
|
user: process.env.DB_USER,
|
|
password: process.env.DB_PASS,
|
|
database: process.env.DB_NAME,
|
|
port: 5432,
|
|
};
|
|
|
|
// --- RUTAS (Los "Botones" de tu servidor) ---
|
|
|
|
// 1. Ruta de prueba (Health Check)
|
|
app.get('/', (req, res) => {
|
|
res.send('<h1>🤖 Servidor Integrarepara: ONLINE</h1><p>Sistema funcionando correctamente.</p>');
|
|
});
|
|
|
|
// 2. EL BUZÓN (POST): Recibe trabajos de los Robots
|
|
app.post('/api/nuevo-servicio', async (req, res) => {
|
|
const { empresa_id, nombre_cliente, direccion, descripcion, origen } = req.body;
|
|
|
|
console.log("📩 Recibido nuevo parte de trabajo...");
|
|
console.log(` Cliente: ${nombre_cliente}`);
|
|
|
|
const client = new Client(dbConfig);
|
|
try {
|
|
await client.connect();
|
|
|
|
// Insertamos en la base de datos
|
|
const query = `
|
|
INSERT INTO servicios (empresa_id, nombre_cliente, direccion, descripcion, origen, estado)
|
|
VALUES ($1, $2, $3, $4, $5, 'PENDIENTE')
|
|
RETURNING id;
|
|
`;
|
|
const values = [empresa_id, nombre_cliente, direccion, descripcion, origen || 'MANUAL'];
|
|
|
|
const resultado = await client.query(query, values);
|
|
|
|
console.log(`✅ Parte guardado con ID: ${resultado.rows[0].id}`);
|
|
|
|
res.status(201).json({
|
|
mensaje: 'Servicio creado correctamente',
|
|
id_servicio: resultado.rows[0].id
|
|
});
|
|
|
|
} catch (err) {
|
|
console.error("❌ Error guardando el parte:", err);
|
|
res.status(500).json({ error: 'Error interno de base de datos' });
|
|
} finally {
|
|
await client.end();
|
|
}
|
|
});
|
|
|
|
// 3. LA ANTENA (GET): Envía la lista a tu Web (React)
|
|
app.get('/api/servicios', async (req, res) => {
|
|
const client = new Client(dbConfig);
|
|
try {
|
|
await client.connect();
|
|
|
|
console.log("📡 La web solicita datos actualizados...");
|
|
|
|
// Pedimos los últimos 50 servicios
|
|
const resultado = await client.query('SELECT * FROM servicios ORDER BY fecha_entrada DESC LIMIT 50');
|
|
|
|
res.json(resultado.rows); // Enviamos JSON a la web
|
|
|
|
} catch (err) {
|
|
console.error("❌ Error al leer servicios:", err);
|
|
res.status(500).json({ error: 'Error al obtener servicios' });
|
|
} finally {
|
|
await client.end();
|
|
}
|
|
});
|
|
|
|
// --- ARRANCAR EL MOTOR ---
|
|
const PORT = process.env.PORT || 3000;
|
|
app.listen(PORT, () => {
|
|
console.log(`\n🚀 SERVIDOR INTEGRAREPARA ARRANCADO`);
|
|
console.log(`📡 Escuchando en: http://localhost:${PORT}`);
|
|
}); |