Actualizar server.js
This commit is contained in:
255
server.js
255
server.js
@@ -225,6 +225,17 @@ async function autoUpdateDB() {
|
||||
comment TEXT,
|
||||
created_at TIMESTAMP DEFAULT NOW()
|
||||
);
|
||||
|
||||
-- NUEVO: TABLA PARA AUTOMATISMOS [AÑADIDO]
|
||||
CREATE TABLE IF NOT EXISTS assignment_pings (
|
||||
id SERIAL PRIMARY KEY,
|
||||
scraped_id INT REFERENCES scraped_services(id) ON DELETE CASCADE,
|
||||
user_id INT REFERENCES users(id) ON DELETE CASCADE,
|
||||
token TEXT UNIQUE NOT NULL,
|
||||
status TEXT DEFAULT 'pending',
|
||||
expires_at TIMESTAMP NOT NULL,
|
||||
created_at TIMESTAMP DEFAULT NOW()
|
||||
);
|
||||
`);
|
||||
|
||||
// PARCHE DE ACTUALIZACIÓN
|
||||
@@ -238,12 +249,14 @@ async function autoUpdateDB() {
|
||||
IF NOT EXISTS (SELECT 1 FROM information_schema.columns WHERE table_name='users' AND column_name='plan_tier') THEN ALTER TABLE users ADD COLUMN plan_tier TEXT DEFAULT 'free'; END IF;
|
||||
IF NOT EXISTS (SELECT 1 FROM information_schema.columns WHERE table_name='users' AND column_name='company_slug') THEN ALTER TABLE users ADD COLUMN company_slug TEXT UNIQUE; END IF;
|
||||
IF NOT EXISTS (SELECT 1 FROM information_schema.columns WHERE table_name='users' AND column_name='zones') THEN ALTER TABLE users ADD COLUMN zones JSONB DEFAULT '[]'; END IF;
|
||||
-- NUEVO: Columna de estado para Baja Temporal
|
||||
IF NOT EXISTS (SELECT 1 FROM information_schema.columns WHERE table_name='users' AND column_name='status') THEN ALTER TABLE users ADD COLUMN status TEXT DEFAULT 'active'; END IF;
|
||||
|
||||
IF NOT EXISTS (SELECT 1 FROM information_schema.columns WHERE table_name='services' AND column_name='provider_data') THEN ALTER TABLE services ADD COLUMN provider_data JSONB DEFAULT '{}'; END IF;
|
||||
IF NOT EXISTS (SELECT 1 FROM information_schema.columns WHERE table_name='services' AND column_name='import_source') THEN ALTER TABLE services ADD COLUMN import_source TEXT; END IF;
|
||||
|
||||
-- NUEVO: Estado de automatismo [AÑADIDO]
|
||||
IF NOT EXISTS (SELECT 1 FROM information_schema.columns WHERE table_name='scraped_services' AND column_name='automation_status') THEN ALTER TABLE scraped_services ADD COLUMN automation_status TEXT DEFAULT 'manual'; END IF;
|
||||
|
||||
BEGIN ALTER TABLE users DROP CONSTRAINT IF EXISTS users_phone_key; EXCEPTION WHEN OTHERS THEN NULL; END;
|
||||
BEGIN ALTER TABLE users DROP CONSTRAINT IF EXISTS users_email_key; EXCEPTION WHEN OTHERS THEN NULL; END;
|
||||
END $$;
|
||||
@@ -281,6 +294,17 @@ async function sendWhatsAppCode(phone, code) {
|
||||
} catch (e) { console.error("Error envío WA:", e.message); }
|
||||
}
|
||||
|
||||
// NUEVA FUNCIÓN PARA MENSAJES DE AUTOMATISMOS [AÑADIDO]
|
||||
async function sendWhatsAppAuto(phone, text) {
|
||||
if (!EVOLUTION_BASE_URL || !EVOLUTION_API_KEY || !EVOLUTION_INSTANCE) return;
|
||||
try {
|
||||
await fetch(`${EVOLUTION_BASE_URL.replace(/\/$/, "")}/message/sendText/${EVOLUTION_INSTANCE}`, {
|
||||
method: "POST", headers: { "Content-Type": "application/json", "apikey": EVOLUTION_API_KEY },
|
||||
body: JSON.stringify({ number: phone.replace("+", ""), text })
|
||||
});
|
||||
} catch (e) {}
|
||||
}
|
||||
|
||||
async function ensureInstance(instanceName) {
|
||||
if (!EVOLUTION_BASE_URL || !EVOLUTION_API_KEY) throw new Error("Faltan variables EVOLUTION");
|
||||
const baseUrl = EVOLUTION_BASE_URL.replace(/\/$/, "");
|
||||
@@ -345,10 +369,8 @@ app.post("/providers/credentials", authMiddleware, async (req, res) => {
|
||||
} catch (e) { res.status(500).json({ ok: false }); }
|
||||
});
|
||||
|
||||
// RUTA CORREGIDA: Ahora entrega todos los servicios para que el filtro del panel funcione
|
||||
app.get("/providers/scraped", authMiddleware, async (req, res) => {
|
||||
try {
|
||||
// Eliminado el filtro status='pending' para permitir ver archivados
|
||||
const q = await pool.query(
|
||||
"SELECT * FROM scraped_services WHERE owner_id=$1 ORDER BY created_at DESC",
|
||||
[req.user.accountId]
|
||||
@@ -360,14 +382,12 @@ app.get("/providers/scraped", authMiddleware, async (req, res) => {
|
||||
}
|
||||
});
|
||||
|
||||
// 📥 IMPORTACIÓN CON ASIGNACIÓN AUTOMÁTICA POR CP
|
||||
app.post("/providers/import/:id", authMiddleware, async (req, res) => {
|
||||
const client = await pool.connect();
|
||||
try {
|
||||
const scrapedId = req.params.id;
|
||||
await client.query('BEGIN');
|
||||
|
||||
// 1. Obtener los datos crudos del robot
|
||||
const scrapedQ = await client.query(
|
||||
"SELECT * FROM scraped_services WHERE id=$1 AND owner_id=$2",
|
||||
[scrapedId, req.user.accountId]
|
||||
@@ -378,7 +398,6 @@ app.post("/providers/import/:id", authMiddleware, async (req, res) => {
|
||||
const provider = scrapedQ.rows[0].provider;
|
||||
const ref = scrapedQ.rows[0].service_ref;
|
||||
|
||||
// 2. Obtener tus reglas de mapeo
|
||||
const mappingQ = await client.query(
|
||||
"SELECT original_key, target_key FROM variable_mappings WHERE owner_id=$1 AND provider=$2 AND is_ignored=FALSE",
|
||||
[req.user.accountId, provider]
|
||||
@@ -391,11 +410,10 @@ app.post("/providers/import/:id", authMiddleware, async (req, res) => {
|
||||
}
|
||||
});
|
||||
|
||||
// 3. Buscar/Crear Cliente
|
||||
const phone = cleanData.phone || cleanData.phone2 || "";
|
||||
const name = cleanData.clientName || "Cliente Importado";
|
||||
const address = cleanData.address || "";
|
||||
const cpExpediente = cleanData.cp || ""; // Extraemos Código Postal
|
||||
const cpExpediente = cleanData.cp || "";
|
||||
|
||||
const phoneClean = normalizePhone(phone);
|
||||
let clientId = null;
|
||||
@@ -411,10 +429,8 @@ app.post("/providers/import/:id", authMiddleware, async (req, res) => {
|
||||
clientId = newC.rows[0].id;
|
||||
}
|
||||
|
||||
// --- 🚀 LÓGICA DE ASIGNACIÓN AUTOMÁTICA POR CP ---
|
||||
let autoAssignedTo = null;
|
||||
if (cpExpediente) {
|
||||
// Buscamos un operario que esté ACTIVO y que tenga este CP en sus zones
|
||||
const workerQ = await client.query(`
|
||||
SELECT id FROM users
|
||||
WHERE owner_id = $1
|
||||
@@ -429,7 +445,6 @@ app.post("/providers/import/:id", authMiddleware, async (req, res) => {
|
||||
}
|
||||
}
|
||||
|
||||
// 5. Insertar el Servicio Final
|
||||
const statusQ = await client.query("SELECT id FROM service_statuses WHERE owner_id=$1 AND is_default=TRUE LIMIT 1", [req.user.accountId]);
|
||||
|
||||
const insertSvc = await client.query(`
|
||||
@@ -451,10 +466,9 @@ app.post("/providers/import/:id", authMiddleware, async (req, res) => {
|
||||
provider,
|
||||
JSON.stringify(cleanData),
|
||||
cleanData.fecha_cita || 'NOW()',
|
||||
autoAssignedTo // Asignación automática
|
||||
autoAssignedTo
|
||||
]);
|
||||
|
||||
// 6. Marcar como importado
|
||||
await client.query("UPDATE scraped_services SET status='imported' WHERE id=$1", [scrapedId]);
|
||||
|
||||
await client.query('COMMIT');
|
||||
@@ -468,116 +482,65 @@ app.post("/providers/import/:id", authMiddleware, async (req, res) => {
|
||||
}
|
||||
});
|
||||
|
||||
// NUEVA RUTA CORREGIDA PARA GUARDAR GREMIO Y OPERARIO
|
||||
app.put('/providers/scraped/:id', authMiddleware, async (req, res) => {
|
||||
const { id } = req.params;
|
||||
const {
|
||||
name, phone, address, cp, description,
|
||||
guild_id, assigned_to, internal_notes, client_notes, is_urgent
|
||||
} = req.body;
|
||||
|
||||
// NUEVA RUTA PARA INICIAR AUTOMATISMO [AÑADIDO]
|
||||
app.post("/providers/automate/:id", authMiddleware, async (req, res) => {
|
||||
try {
|
||||
const current = await pool.query(
|
||||
'SELECT raw_data FROM scraped_services WHERE id = $1 AND owner_id = $2',
|
||||
[id, req.user.accountId]
|
||||
);
|
||||
const { id } = req.params;
|
||||
const { guild_id, cp } = req.body;
|
||||
const workersQ = await pool.query(`
|
||||
SELECT u.id, u.full_name, u.phone FROM users u
|
||||
JOIN user_guilds ug ON u.id = ug.user_id
|
||||
WHERE u.owner_id = $1 AND u.role = 'operario' AND u.status = 'active'
|
||||
AND ug.guild_id = $2 AND u.zones @> $3::jsonb
|
||||
`, [req.user.accountId, guild_id, JSON.stringify([{ cps: cp.toString() }])]);
|
||||
|
||||
if (current.rows.length === 0) {
|
||||
return res.status(404).json({ error: 'Expediente no encontrado' });
|
||||
}
|
||||
if (workersQ.rowCount === 0) return res.status(404).json({ ok: false, error: "No hay operarios disponibles" });
|
||||
|
||||
// MEZCLAMOS LOS DATOS: Guardamos los campos nuevos dentro de raw_data
|
||||
const updatedRawData = {
|
||||
...current.rows[0].raw_data,
|
||||
"Nombre Cliente": name,
|
||||
"Teléfono": phone,
|
||||
"Dirección": address,
|
||||
"Código Postal": cp,
|
||||
"Descripción": description,
|
||||
"Urgente": is_urgent ? "Sí" : "No",
|
||||
// IMPORTANTE: Guardamos estos para que al recargar aparezcan
|
||||
"guild_id": guild_id,
|
||||
"assigned_to": assigned_to,
|
||||
"internal_notes": internal_notes,
|
||||
"client_notes": client_notes
|
||||
};
|
||||
await pool.query("UPDATE scraped_services SET automation_status = 'in_progress' WHERE id = $1", [id]);
|
||||
const worker = workersQ.rows[Math.floor(Math.random() * workersQ.rows.length)];
|
||||
const token = Math.random().toString(36).substring(2, 15);
|
||||
const expiresAt = new Date(Date.now() + 5 * 60 * 1000);
|
||||
|
||||
await pool.query(
|
||||
`UPDATE scraped_services
|
||||
SET raw_data = $1,
|
||||
status = 'pending'
|
||||
WHERE id = $2 AND owner_id = $3`,
|
||||
[JSON.stringify(updatedRawData), id, req.user.accountId]
|
||||
);
|
||||
await pool.query(`INSERT INTO assignment_pings (scraped_id, user_id, token, expires_at) VALUES ($1, $2, $3, $4)`, [id, worker.id, token, expiresAt]);
|
||||
const link = `https://tuweb.com/aceptar.html?t=${token}`;
|
||||
await sendWhatsAppAuto(worker.phone, `🛠️ *NUEVO SERVICIO*\nCP: ${cp}\n🔗 ${link}`);
|
||||
|
||||
res.json({ ok: true, message: 'Borrador actualizado correctamente' });
|
||||
} catch (error) {
|
||||
console.error('Error al actualizar borrador:', error);
|
||||
res.status(500).json({ error: 'Error interno del servidor' });
|
||||
}
|
||||
res.json({ ok: true, message: "Automatismo iniciado" });
|
||||
} catch (e) { res.status(500).json({ ok: false }); }
|
||||
});
|
||||
|
||||
// ==========================================
|
||||
// 🗺️ MAPEADOR (VERSIÓN LIMPIA: SOLO EL ÚLTIMO SERVICIO)
|
||||
// ==========================================
|
||||
// RUTA PARA GUARDAR GREMIO Y OPERARIO
|
||||
app.put('/providers/scraped/:id', authMiddleware, async (req, res) => {
|
||||
const { id } = req.params;
|
||||
const { name, phone, address, cp, description, guild_id, assigned_to, internal_notes, client_notes, is_urgent } = req.body;
|
||||
try {
|
||||
const current = await pool.query('SELECT raw_data FROM scraped_services WHERE id = $1 AND owner_id = $2', [id, req.user.accountId]);
|
||||
if (current.rows.length === 0) return res.status(404).json({ error: 'No encontrado' });
|
||||
const updatedRawData = { ...current.rows[0].raw_data, "Nombre Cliente": name, "Teléfono": phone, "Dirección": address, "Código Postal": cp, "Descripción": description, "Urgente": is_urgent ? "Sí" : "No", "guild_id": guild_id, "assigned_to": assigned_to, "internal_notes": internal_notes, "client_notes": client_notes };
|
||||
await pool.query(`UPDATE scraped_services SET raw_data = $1, status = 'pending' WHERE id = $2 AND owner_id = $3`, [JSON.stringify(updatedRawData), id, req.user.accountId]);
|
||||
res.json({ ok: true });
|
||||
} catch (error) { res.status(500).json({ error: 'Error' }); }
|
||||
});
|
||||
|
||||
// MAPEADOR
|
||||
app.get("/discovery/keys/:provider", authMiddleware, async (req, res) => {
|
||||
try {
|
||||
const { provider } = req.params;
|
||||
|
||||
// Buscamos solo el último servicio para que la lista sea corta y real
|
||||
const rawServices = await pool.query(
|
||||
"SELECT raw_data FROM scraped_services WHERE owner_id=$1 AND provider=$2 ORDER BY id DESC LIMIT 1",
|
||||
[req.user.accountId, provider]
|
||||
);
|
||||
|
||||
const mappings = await pool.query(
|
||||
"SELECT original_key, target_key, is_ignored FROM variable_mappings WHERE owner_id=$1 AND provider=$2",
|
||||
[req.user.accountId, provider]
|
||||
);
|
||||
|
||||
const mapDict = {};
|
||||
mappings.rows.forEach(m => {
|
||||
mapDict[m.original_key] = m;
|
||||
});
|
||||
|
||||
const discoverySet = new Set();
|
||||
const samples = {};
|
||||
|
||||
rawServices.rows.forEach(row => {
|
||||
const data = row.raw_data;
|
||||
if (data && typeof data === 'object') {
|
||||
Object.keys(data).forEach(k => {
|
||||
discoverySet.add(k);
|
||||
if (!samples[k]) samples[k] = data[k];
|
||||
});
|
||||
}
|
||||
});
|
||||
|
||||
const result = Array.from(discoverySet).map(key => ({
|
||||
original: key,
|
||||
sample: samples[key] || "(Vacío)",
|
||||
mappedTo: mapDict[key]?.target_key || "",
|
||||
ignored: mapDict[key]?.is_ignored || false
|
||||
})).sort((a, b) => a.original.localeCompare(b.original));
|
||||
|
||||
const rawServices = await pool.query("SELECT raw_data FROM scraped_services WHERE owner_id=$1 AND provider=$2 ORDER BY id DESC LIMIT 1", [req.user.accountId, provider]);
|
||||
const mappings = await pool.query("SELECT original_key, target_key, is_ignored FROM variable_mappings WHERE owner_id=$1 AND provider=$2", [req.user.accountId, provider]);
|
||||
const mapDict = {}; mappings.rows.forEach(m => { mapDict[m.original_key] = m; });
|
||||
const discoverySet = new Set(); const samples = {};
|
||||
rawServices.rows.forEach(row => { const data = row.raw_data; if (data && typeof data === 'object') { Object.keys(data).forEach(k => { discoverySet.add(k); if (!samples[k]) samples[k] = data[k]; }); } });
|
||||
const result = Array.from(discoverySet).map(key => ({ original: key, sample: samples[key] || "(Vacío)", mappedTo: mapDict[key]?.target_key || "", ignored: mapDict[key]?.is_ignored || false })).sort((a, b) => a.original.localeCompare(b.original));
|
||||
res.json({ ok: true, keys: result });
|
||||
|
||||
} catch (e) {
|
||||
res.status(500).json({ ok: false, error: e.message });
|
||||
}
|
||||
} catch (e) { res.status(500).json({ ok: false }); }
|
||||
});
|
||||
|
||||
// RUTA NUEVA: Entrega todos los mapeos guardados por el usuario
|
||||
app.get("/discovery/mappings", authMiddleware, async (req, res) => {
|
||||
try {
|
||||
const q = await pool.query(
|
||||
"SELECT provider, original_key, target_key FROM variable_mappings WHERE owner_id = $1",
|
||||
[req.user.accountId]
|
||||
);
|
||||
const q = await pool.query("SELECT provider, original_key, target_key FROM variable_mappings WHERE owner_id = $1", [req.user.accountId]);
|
||||
res.json(q.rows);
|
||||
} catch (e) {
|
||||
res.status(500).json({ ok: false, error: e.message });
|
||||
}
|
||||
} catch (e) { res.status(500).json({ ok: false }); }
|
||||
});
|
||||
|
||||
app.post("/discovery/save", authMiddleware, async (req, res) => {
|
||||
@@ -586,26 +549,14 @@ app.post("/discovery/save", authMiddleware, async (req, res) => {
|
||||
const { provider, mappings } = req.body;
|
||||
await client.query('BEGIN');
|
||||
for (const m of mappings) {
|
||||
await client.query(`
|
||||
INSERT INTO variable_mappings (owner_id, provider, original_key, target_key, is_ignored)
|
||||
VALUES ($1, $2, $3, $4, $5)
|
||||
ON CONFLICT (owner_id, provider, original_key)
|
||||
DO UPDATE SET target_key = EXCLUDED.target_key, is_ignored = EXCLUDED.is_ignored
|
||||
`, [req.user.accountId, provider, m.original, m.target, m.ignored]);
|
||||
await client.query(`INSERT INTO variable_mappings (owner_id, provider, original_key, target_key, is_ignored) VALUES ($1, $2, $3, $4, $5) ON CONFLICT (owner_id, provider, original_key) DO UPDATE SET target_key = EXCLUDED.target_key, is_ignored = EXCLUDED.is_ignored`, [req.user.accountId, provider, m.original, m.target, m.ignored]);
|
||||
}
|
||||
await client.query('COMMIT');
|
||||
res.json({ ok: true });
|
||||
} catch (e) {
|
||||
await client.query('ROLLBACK');
|
||||
res.status(500).json({ ok: false, error: e.message });
|
||||
} finally {
|
||||
client.release();
|
||||
}
|
||||
} catch (e) { await client.query('ROLLBACK'); res.status(500).json({ ok: false }); } finally { client.release(); }
|
||||
});
|
||||
|
||||
// =========================
|
||||
// 👥 GESTIÓN DE CLIENTES
|
||||
// =========================
|
||||
// CLIENTES
|
||||
app.get("/clients", authMiddleware, async (req, res) => {
|
||||
try {
|
||||
const { search } = req.query;
|
||||
@@ -645,12 +596,12 @@ app.put("/clients/:id", authMiddleware, async (req, res) => {
|
||||
} catch (e) { res.status(500).json({ ok: false }); }
|
||||
});
|
||||
|
||||
// GESTIÓN DE ESTADOS Y SERVICIOS BÁSICOS
|
||||
// ESTADOS
|
||||
app.get("/statuses", authMiddleware, async (req, res) => { try { let q = await pool.query("SELECT * FROM service_statuses WHERE owner_id=$1 ORDER BY id ASC", [req.user.accountId]); if (q.rowCount === 0) { const defaults = [{name:'Pendiente',c:'gray',d:true,f:false},{name:'En Proceso',c:'blue',d:false,f:false},{name:'Terminado',c:'green',d:false,f:true},{name:'Cancelado',c:'red',d:false,f:true}]; for (const s of defaults) await pool.query("INSERT INTO service_statuses (owner_id,name,color,is_default,is_final) VALUES ($1,$2,$3,$4,$5)", [req.user.accountId,s.name,s.c,s.d,s.f]); q = await pool.query("SELECT * FROM service_statuses WHERE owner_id=$1 ORDER BY id ASC", [req.user.accountId]); } res.json({ ok: true, statuses: q.rows }); } catch (e) { res.status(500).json({ ok: false }); } });
|
||||
app.post("/statuses", authMiddleware, async (req, res) => { try { const { name, color } = req.body; await pool.query("INSERT INTO service_statuses (owner_id, name, color) VALUES ($1, $2, $3)", [req.user.accountId, name, color || 'gray']); res.json({ ok: true }); } catch(e) { res.status(500).json({ ok: false }); } });
|
||||
app.delete("/statuses/:id", authMiddleware, async (req, res) => { const client = await pool.connect(); try { const statusId = req.params.id; const check = await client.query("SELECT COUNT(*) FROM services WHERE status_id = $1 AND owner_id = $2", [statusId, req.user.accountId]); if (parseInt(check.rows[0].count) > 0) return res.status(400).json({ ok: false, error: "En uso" }); await client.query("DELETE FROM service_statuses WHERE id=$1 AND owner_id=$2", [statusId, req.user.accountId]); res.json({ ok: true }); } catch(e) { res.status(500).json({ ok: false }); } finally { client.release(); } });
|
||||
|
||||
// RESTO DE ENDPOINTS
|
||||
// RESTO
|
||||
app.get("/clients/search", authMiddleware, async (req, res) => { try { const { phone } = req.query; const p = normalizePhone(phone); if(!p) return res.json({ok:true,client:null}); const q = await pool.query("SELECT * FROM clients WHERE phone=$1 AND owner_id=$2 LIMIT 1", [p, req.user.accountId]); res.json({ ok: true, client: q.rows[0] || null }); } catch (e) { res.status(500).json({ ok: false }); } });
|
||||
app.get("/companies", authMiddleware, async (req, res) => { try { const q = await pool.query("SELECT * FROM companies WHERE owner_id=$1 ORDER BY name ASC", [req.user.accountId]); res.json({ ok: true, companies: q.rows }); } catch (e) { res.status(500).json({ ok: false }); } });
|
||||
app.post("/companies", authMiddleware, async (req, res) => { try { const { name } = req.body; await pool.query("INSERT INTO companies (name, owner_id) VALUES ($1, $2)", [name, req.user.accountId]); res.json({ ok: true }); } catch (e) { res.status(500).json({ ok: false }); } });
|
||||
@@ -662,7 +613,7 @@ app.delete("/zones/:id", authMiddleware, async (req, res) => { try { await pool.
|
||||
app.get("/zones/:id/operators", authMiddleware, async (req, res) => { try { const q = await pool.query("SELECT user_id FROM user_zones WHERE zone_id=$1", [req.params.id]); res.json({ ok: true, assignedIds: q.rows.map(r=>r.user_id) }); } catch (e) { res.status(500).json({ ok: false }); } });
|
||||
app.post("/zones/:id/assign", authMiddleware, async (req, res) => { const client = await pool.connect(); try { const { operator_ids } = req.body; await client.query('BEGIN'); await client.query("DELETE FROM user_zones WHERE zone_id=$1", [req.params.id]); if(operator_ids) for(const uid of operator_ids) await client.query("INSERT INTO user_zones (user_id, zone_id) VALUES ($1, $2)", [uid, req.params.id]); await client.query('COMMIT'); res.json({ok:true}); } catch(e){ await client.query('ROLLBACK'); res.status(500).json({ok:false}); } finally { client.release(); } });
|
||||
|
||||
// BUSCADOR GEOGRÁFICO MEJORADO (Ignora tildes automáticamente)
|
||||
// GEO
|
||||
app.get("/api/geo/municipios/:provincia", authMiddleware, async (req, res) => {
|
||||
try {
|
||||
let { provincia } = req.params;
|
||||
@@ -672,33 +623,28 @@ app.get("/api/geo/municipios/:provincia", authMiddleware, async (req, res) => {
|
||||
} catch (e) { res.status(500).json({ ok: false }); }
|
||||
});
|
||||
|
||||
// NUEVO: Endpoint para activar/desactivar operario (Baja Temporal)
|
||||
// STATUS USUARIO
|
||||
app.patch("/admin/users/:id/status", authMiddleware, async (req, res) => {
|
||||
try {
|
||||
const { status } = req.body; // 'active' o 'inactive'
|
||||
await pool.query("UPDATE users SET status = $1 WHERE id = $2 AND owner_id = $3",
|
||||
[status, req.params.id, req.user.accountId]);
|
||||
const { status } = req.body;
|
||||
await pool.query("UPDATE users SET status = $1 WHERE id = $2 AND owner_id = $3", [status, req.params.id, req.user.accountId]);
|
||||
res.json({ ok: true });
|
||||
} catch (e) {
|
||||
res.status(500).json({ ok: false });
|
||||
}
|
||||
} catch (e) { res.status(500).json({ ok: false }); }
|
||||
});
|
||||
|
||||
// ACTUALIZACIÓN DE SELECT PARA INCLUIR STATUS
|
||||
app.get("/admin/users", authMiddleware, async (req, res) => { try { const q = await pool.query(`SELECT u.id, u.full_name, u.email, u.phone, u.role, u.zones, u.status, COALESCE(json_agg(g.id) FILTER (WHERE g.id IS NOT NULL), '[]') as guilds FROM users u LEFT JOIN user_guilds ug ON u.id=ug.user_id LEFT JOIN guilds g ON ug.guild_id=g.id WHERE u.owner_id=$1 GROUP BY u.id ORDER BY u.id DESC`, [req.user.accountId]); res.json({ ok: true, users: q.rows }); } catch (e) { res.status(500).json({ ok: false }); } });
|
||||
|
||||
app.post("/admin/users", authMiddleware, async (req, res) => { const client = await pool.connect(); try { const { fullName, email, password, role, guilds, phone, zones } = req.body; if (!email || !password || !fullName || !phone) return res.status(400).json({ ok: false }); const p = normalizePhone(phone); const hash = await bcrypt.hash(password, 10); const check = await client.query("SELECT id FROM users WHERE (phone=$1 OR email=$2) AND owner_id=$3", [p, email, req.user.accountId]); if (check.rowCount > 0) return res.status(400).json({ ok: false, error: "Duplicado" }); await client.query('BEGIN'); const insert = await client.query("INSERT INTO users (full_name, email, password_hash, role, phone, is_verified, owner_id, zones, status) VALUES ($1, $2, $3, $4, $5, TRUE, $6, $7, 'active') RETURNING id", [fullName, email, hash, role || 'operario', p, req.user.accountId, JSON.stringify(zones || [])]); const uid = insert.rows[0].id; if (guilds) for (const gid of guilds) await client.query("INSERT INTO user_guilds (user_id, guild_id) VALUES ($1, $2)", [uid, gid]); await client.query('COMMIT'); res.json({ ok: true }); } catch (e) { await client.query('ROLLBACK'); res.status(500).json({ ok: false }); } finally { client.release(); } });
|
||||
app.put("/admin/users/:id", authMiddleware, async (req, res) => { const client = await pool.connect(); try { const userId = req.params.id; const { fullName, email, phone, role, guilds, password, zones } = req.body; const p = normalizePhone(phone); await client.query('BEGIN'); if(password) { const hash = await bcrypt.hash(password, 10); await client.query("UPDATE users SET full_name=$1, email=$2, phone=$3, role=$4, password_hash=$5, zones=$6 WHERE id=$7", [fullName, email, p, role, hash, JSON.stringify(zones || []), userId]); } else { await client.query("UPDATE users SET full_name=$1, email=$2, phone=$3, role=$4, zones=$5 WHERE id=$6", [fullName, email, p, role, JSON.stringify(zones || []), userId]); } if (guilds && Array.isArray(guilds)) { await client.query("DELETE FROM user_guilds WHERE user_id=$1", [userId]); for (const gid of guilds) await client.query("INSERT INTO user_guilds (user_id, guild_id) VALUES ($1, $2)", [userId, gid]); } await client.query('COMMIT'); res.json({ ok: true }); } catch (e) { await client.query('ROLLBACK'); res.status(500).json({ ok: false }); } finally { client.release(); } });
|
||||
app.delete("/admin/users/:id", authMiddleware, async (req, res) => { try { await pool.query("DELETE FROM users WHERE id=$1 AND owner_id=$2", [req.params.id, req.user.accountId]); res.json({ ok: true }); } catch (e) { res.status(500).json({ ok: false }); } });
|
||||
|
||||
// GESTIÓN DE SUBDOMINIO (EMPRESA)
|
||||
// CONFIG
|
||||
app.get("/config/company", authMiddleware, async (req, res) => { try { const q = await pool.query("SELECT company_slug, full_name, plan_tier FROM users WHERE id=$1", [req.user.accountId]); res.json({ ok: true, slug: q.rows[0]?.company_slug, name: q.rows[0]?.full_name, plan: q.rows[0]?.plan_tier }); } catch (e) { res.status(500).json({ ok: false }); } });
|
||||
app.post("/config/company", authMiddleware, async (req, res) => { const client = await pool.connect(); try { const { slug } = req.body; if (!slug || slug.length < 3) return res.status(400).json({ ok: false, error: "Mínimo 3 caracteres" }); const cleanSlug = slug.toLowerCase().replace(/[^a-z0-9-]/g, ""); if (cleanSlug !== slug) return res.status(400).json({ ok: false, error: "Carácteres inválidos" }); const check = await client.query("SELECT id FROM users WHERE company_slug=$1 AND id != $2", [cleanSlug, req.user.accountId]); if (check.rowCount > 0) return res.status(400).json({ ok: false, error: "Nombre en uso" }); await client.query("UPDATE users SET company_slug=$1 WHERE id=$2", [cleanSlug, req.user.accountId]); res.json({ ok: true, fullUrl: `https://${cleanSlug}.integrarepara.es` }); } catch (e) { res.status(500).json({ ok: false }); } finally { client.release(); } });
|
||||
|
||||
// SERVICIOS
|
||||
app.get("/guilds", authMiddleware, async (req, res) => { try { const q = await pool.query("SELECT * FROM guilds WHERE owner_id=$1 ORDER BY name ASC", [req.user.accountId]); res.json({ ok: true, guilds: q.rows }); } catch (e) { res.status(500).json({ ok: false }); } });
|
||||
app.post("/guilds", authMiddleware, async (req, res) => { try { const { name } = req.body; await pool.query("INSERT INTO guilds (name, owner_id) VALUES ($1, $2)", [name, req.user.accountId]); res.json({ ok: true }); } catch (e) { res.status(500).json({ ok: false }); } });
|
||||
app.delete("/guilds/:id", authMiddleware, async (req, res) => { try { await pool.query("DELETE FROM guilds WHERE id=$1 AND owner_id=$2", [req.params.id, req.user.accountId]); res.json({ ok: true }); } catch (e) { res.status(500).json({ ok: false }); } });
|
||||
|
||||
app.get("/services", authMiddleware, async (req, res) => { try { const q = await pool.query(`SELECT s.*, st.name as status_name, st.color as status_color, c.name as company_name, g.name as guild_name, u.full_name as assigned_name FROM services s LEFT JOIN service_statuses st ON s.status_id = st.id LEFT JOIN companies c ON s.company_id = c.id LEFT JOIN guilds g ON s.guild_id = g.id LEFT JOIN users u ON s.assigned_to = u.id WHERE s.owner_id=$1 ORDER BY s.created_at DESC`, [req.user.accountId]); res.json({ ok: true, services: q.rows }); } catch (e) { res.status(500).json({ ok: false }); } });
|
||||
app.get("/services/:id", authMiddleware, async (req, res) => { try { const q = await pool.query(`SELECT * FROM services WHERE id=$1 AND owner_id=$2`, [req.params.id, req.user.accountId]); res.json({ ok: true, service: q.rows[0] }); } catch (e) { res.status(500).json({ ok: false }); } });
|
||||
app.get("/services/:id/logs", authMiddleware, async (req, res) => { try { const q = await pool.query(`SELECT l.*, u.full_name as user_name, s2.name as new_status, s2.color as new_color FROM service_logs l LEFT JOIN users u ON l.user_id=u.id LEFT JOIN service_statuses s2 ON l.new_status_id=s2.id WHERE l.service_id=$1 ORDER BY l.created_at DESC`, [req.params.id]); res.json({ ok: true, logs: q.rows }); } catch (e) { res.status(500).json({ ok: false }); } });
|
||||
@@ -707,5 +653,42 @@ app.post("/services", authMiddleware, async (req, res) => { const client = await
|
||||
app.put("/services/:id", authMiddleware, async (req, res) => { const client = await pool.connect(); try { const { name, address, email, description, scheduled_date, scheduled_time, duration, is_urgent, is_company, company_id, company_ref, internal_notes, client_notes, guild_id, assigned_to } = req.body; await client.query('BEGIN'); await client.query(`UPDATE services SET contact_name=$1, address=$2, email=$3, description=$4, scheduled_date=$5, scheduled_time=$6, duration_minutes=$7, is_urgent=$8, is_company=$9, company_id=$10, company_ref=$11, internal_notes=$12, client_notes=$13, guild_id=$14, assigned_to=$15 WHERE id=$16 AND owner_id=$17`, [name, address, email, description, scheduled_date, scheduled_time, (duration || 30), (is_urgent || false), (is_company || false), (company_id || null), company_ref, internal_notes, client_notes, (guild_id || null), (assigned_to || null), req.params.id, req.user.accountId]); await client.query("INSERT INTO service_logs (service_id, user_id, new_status_id, comment) VALUES ($1, $2, (SELECT status_id FROM services WHERE id=$1), 'Datos editados')", [req.params.id, req.user.sub]); await client.query('COMMIT'); res.json({ ok: true }); } catch (e) { await client.query('ROLLBACK'); res.status(500).json({ ok: false }); } finally { client.release(); } });
|
||||
app.delete("/services/:id", authMiddleware, async (req, res) => { try { await pool.query("DELETE FROM services WHERE id=$1 AND owner_id=$2", [req.params.id, req.user.accountId]); res.json({ ok: true }); } catch (e) { res.status(500).json({ ok: false }); } });
|
||||
|
||||
// ==========================================
|
||||
// 🕒 EL RELOJ DEL SISTEMA (Ejecutar cada minuto) [AÑADIDO]
|
||||
// ==========================================
|
||||
setInterval(async () => {
|
||||
try {
|
||||
const expiredPings = await pool.query(`
|
||||
SELECT ap.id, ap.scraped_id, ap.user_id, s.owner_id, s.raw_data
|
||||
FROM assignment_pings ap
|
||||
JOIN scraped_services s ON ap.scraped_id = s.id
|
||||
WHERE ap.status = 'pending' AND ap.expires_at < NOW()
|
||||
AND s.automation_status = 'in_progress'
|
||||
`);
|
||||
|
||||
for (const ping of expiredPings.rows) {
|
||||
await pool.query("UPDATE assignment_pings SET status = 'expired' WHERE id = $1", [ping.id]);
|
||||
const nextWorkerQ = await pool.query(`
|
||||
SELECT u.id, u.phone, u.full_name
|
||||
FROM users u
|
||||
JOIN user_guilds ug ON u.id = ug.user_id
|
||||
WHERE u.owner_id = $1 AND u.status = 'active'
|
||||
AND u.id NOT IN (SELECT user_id FROM assignment_pings WHERE scraped_id = $2)
|
||||
LIMIT 1
|
||||
`, [ping.owner_id, ping.scraped_id]);
|
||||
|
||||
if (nextWorkerQ.rowCount > 0) {
|
||||
const nextW = nextWorkerQ.rows[0];
|
||||
const newToken = Math.random().toString(36).substring(2, 15);
|
||||
const expiresAt = new Date(Date.now() + 5 * 60 * 1000);
|
||||
await pool.query(`INSERT INTO assignment_pings (scraped_id, user_id, token, expires_at) VALUES ($1, $2, $3, $4)`, [ping.scraped_id, nextW.id, newToken, expiresAt]);
|
||||
await sendWhatsAppAuto(nextW.phone, `🛠️ *SERVICIO DISPONIBLE*\nEl anterior compañero no respondió. Es tu turno:\n🔗 https://tuweb.com/aceptar.html?t=${newToken}`);
|
||||
} else {
|
||||
await pool.query("UPDATE scraped_services SET automation_status = 'failed' WHERE id = $1", [ping.scraped_id]);
|
||||
}
|
||||
}
|
||||
} catch (e) { console.error("Reloj:", e); }
|
||||
}, 60000);
|
||||
|
||||
const port = process.env.PORT || 3000;
|
||||
autoUpdateDB().then(() => { app.listen(port, "0.0.0.0", () => console.log(`🚀 Server OK en puerto ${port}`)); });
|
||||
Reference in New Issue
Block a user