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

Actualizar server.js

Browse Source
This commit is contained in:
marsalva
2026-02-15 23:28:31 +00:00
parent ac0a56e42f
commit bfde817cba
1 changed files with 36 additions and 30 deletions
Download Patch File Download Diff File Expand all files Collapse all files

66
server.js
View File

@@ -88,12 +88,12 @@ async function autoUpdateDB() {
created_at TIMESTAMP DEFAULT NOW()
);
// Añade esto dentro del DO $$ BEGIN de autoUpdateDB
IF NOT EXISTS (SELECT 1 FROM information_schema.columns WHERE table_name='scraped_services' AND column_name='assigned_to') THEN
ALTER TABLE scraped_services ADD COLUMN assigned_to INT REFERENCES users(id);
END IF;
-- CONFIGURACIÓN NEGOCIO
CREATE TABLE IF NOT EXISTS guilds (
id SERIAL PRIMARY KEY,
owner_id INT REFERENCES users(id) ON DELETE CASCADE,
name TEXT NOT NULL,
created_at TIMESTAMP DEFAULT NOW()
);
CREATE TABLE IF NOT EXISTS user_guilds (
user_id INT REFERENCES users(id) ON DELETE CASCADE,
@@ -228,15 +228,6 @@ END IF;
created_at TIMESTAMP DEFAULT NOW()
);
// Así debe quedar ese bloque dentro de autoUpdateDB:
await client.query(`
DO $$ BEGIN
-- AÑADE ESTA LÍNEA AQUÍ DENTRO:
IF NOT EXISTS (SELECT 1 FROM information_schema.columns WHERE table_name='scraped_services' AND column_name='assigned_to') THEN ALTER TABLE scraped_services ADD COLUMN assigned_to INT REFERENCES users(id); END IF;
IF NOT EXISTS (SELECT 1 FROM information_schema.columns WHERE table_name='services' AND column_name='client_id') THEN ...
`);
-- TABLA PARA ASIGNACIÓN AUTOMÁTICA
CREATE TABLE IF NOT EXISTS assignment_pings (
id SERIAL PRIMARY KEY,
@@ -252,6 +243,11 @@ await client.query(`
// PARCHE DE ACTUALIZACIÓN
await client.query(`
DO $$ BEGIN
-- AÑADIDO: Columna física de operario para el panel operativo
IF NOT EXISTS (SELECT 1 FROM information_schema.columns WHERE table_name='scraped_services' AND column_name='assigned_to') THEN
ALTER TABLE scraped_services ADD COLUMN assigned_to INT REFERENCES users(id);
END IF;
IF NOT EXISTS (SELECT 1 FROM information_schema.columns WHERE table_name='services' AND column_name='client_id') THEN ALTER TABLE services ADD COLUMN client_id INT REFERENCES clients(id) ON DELETE SET NULL; END IF;
IF NOT EXISTS (SELECT 1 FROM information_schema.columns WHERE table_name='services' AND column_name='status_id') THEN ALTER TABLE services ADD COLUMN status_id INT REFERENCES service_statuses(id) ON DELETE SET NULL; END IF;
IF NOT EXISTS (SELECT 1 FROM information_schema.columns WHERE table_name='services' AND column_name='contact_phone') THEN ALTER TABLE services ADD COLUMN contact_phone TEXT; END IF;
@@ -353,7 +349,6 @@ app.post("/public/assignment/respond", async (req, res) => {
const { token, action } = req.body;
await client.query('BEGIN');
// 1. Buscamos el ping para saber qué operario y qué servicio es
const q = await client.query(
"SELECT * FROM assignment_pings WHERE token = $1 AND status = 'pending' AND expires_at > NOW()",
[token]
@@ -363,20 +358,17 @@ app.post("/public/assignment/respond", async (req, res) => {
const ping = q.rows[0];
if (action === 'accept') {
// Marcamos el ping como aceptado
await client.query("UPDATE assignment_pings SET status = 'accepted' WHERE id = $1", [ping.id]);
// ACCIÓN CLAVE: Actualizamos el servicio con el operario asignado
// Guardamos el user_id en el JSON raw_data para que el panel lo lea correctamente
// Sustituye el UPDATE dentro de action === 'accept'
await client.query(`
UPDATE scraped_services
SET status = 'imported',
automation_status = 'completed',
assigned_to = $1,
raw_data = raw_data || jsonb_build_object('assigned_to', $1)
WHERE id = $2
`, [ping.user_id, ping.scraped_id]);
// AÑADIDO: Guardar ID de operario en columna física y JSON
await client.query(`
UPDATE scraped_services
SET status = 'imported',
automation_status = 'completed',
assigned_to = $1,
raw_data = raw_data || jsonb_build_object('assigned_to', $1)
WHERE id = $2
`, [ping.user_id, ping.scraped_id]);
} else {
await client.query("UPDATE assignment_pings SET status = 'rejected', expires_at = NOW() WHERE id = $1", [ping.id]);
@@ -622,7 +614,7 @@ app.get("/discovery/keys/:provider", authMiddleware, async (req, res) => {
} catch (e) { res.status(500).json({ ok: false }); }
});
// Ruta para obtener servicios aceptados con datos de operarios y gremios
// AÑADIDO: Ruta para el Panel Operativo (Asignados vs Citados)
app.get("/services/active", authMiddleware, async (req, res) => {
try {
const q = await pool.query(`
@@ -644,7 +636,7 @@ app.get("/services/active", authMiddleware, async (req, res) => {
} catch (e) { res.status(500).json({ ok: false }); }
});
// Ruta para fijar la cita (Mueve el servicio de la izquierda a la derecha)
// AÑADIDO: Ruta para fijar la cita o el estado operativo
app.put("/services/set-appointment/:id", authMiddleware, async (req, res) => {
try {
const { id } = req.params;
@@ -658,6 +650,20 @@ app.put("/services/set-appointment/:id", authMiddleware, async (req, res) => {
} catch (e) { res.status(500).json({ ok: false }); }
});
// AÑADIDO: Ruta para alta de expedientes manuales (Cola o Directo)
app.post("/services/manual-high", authMiddleware, async (req, res) => {
try {
const { phone, name, address, description, guild_id, assigned_to, mode } = req.body;
const serviceRef = "MAN-" + Date.now().toString().slice(-6);
const rawData = { "Nombre Cliente": name, "Teléfono": phone, "Dirección": address, "Descripción": description, "guild_id": guild_id };
await pool.query(`
INSERT INTO scraped_services (owner_id, provider, service_ref, raw_data, status, automation_status, assigned_to)
VALUES ($1, 'MANUAL', $2, $3, 'pending', $4, $5)
`, [req.user.accountId, serviceRef, JSON.stringify(rawData), mode === 'auto' ? 'manual' : 'completed', mode === 'manual' ? assigned_to : null]);
res.json({ ok: true });
} catch (e) { res.status(500).json({ ok: false }); }
});
app.get("/discovery/mappings", authMiddleware, async (req, res) => {
try {