diff --git a/server.js b/server.js index 679e474..f58a65a 100644 --- a/server.js +++ b/server.js @@ -384,52 +384,59 @@ async function requirePlan(req, res, next, feature) { app.get("/public/portal/:token", async (req, res) => { try { const { token } = req.params; - - // 1. Buscamos al cliente por su token mágico - const qClient = await pool.query("SELECT * FROM clients WHERE portal_token = $1", [token]); + const serviceIdParam = req.query.service; // Extraemos el ID si lo mandan + + // 1. Buscamos al cliente por su token + const qClient = await pool.query("SELECT * FROM clients WHERE portal_token = $1 LIMIT 1", [token]); if (qClient.rowCount === 0) return res.status(404).json({ ok: false, error: "Enlace no válido" }); const client = qClient.rows[0]; const ownerId = client.owner_id; - const clientId = client.id; // 2. Buscamos los datos de la empresa para personalizar el portal - const qConfig = await pool.query("SELECT full_name, company_logo, portal_settings FROM users WHERE id = $1", [ownerId]); - const userData = qConfig.rows[0] || {}; - + const qConfig = await pool.query("SELECT full_name, company_logo FROM users WHERE id = $1", [ownerId]); const company = { - name: userData.full_name || "IntegraRepara", - logo: userData.company_logo || null + name: qConfig.rows[0]?.full_name || "IntegraRepara", + logo: qConfig.rows[0]?.company_logo || null }; - // 3. TELÉFONO SEGURO E ID SEGURO (Esto evita el Error 500 y el fallo de enlace) - let cleanPhoneToMatch = String(client.phone || "").replace(/\D/g, "").slice(-9); - if (cleanPhoneToMatch.length < 8) cleanPhoneToMatch = "NO_VALIDO_123"; // Seguridad + // 3. OBTENER SERVICIOS (Lógica blindada anti-crashes) + let qServices; - // Si hay ID en el enlace lo usamos, si no, mandamos un "0" para que no explote la DB - const requestedServiceId = req.query.service ? String(req.query.service) : "0"; - - const qServices = await pool.query(` - SELECT - s.id, s.service_ref, s.is_urgent, s.raw_data, s.created_at, s.client_id, - st.name as real_status_name, - st.is_final as is_status_final, - u.full_name as worker_name, - u.phone as worker_phone - FROM scraped_services s - LEFT JOIN users u ON u.id = s.assigned_to - LEFT JOIN service_statuses st ON st.id::text = (s.raw_data->>'status_operativo')::text - WHERE s.owner_id = $1 - AND s.provider != 'SYSTEM_BLOCK' - AND ( - s.id::text = $4 - OR s.client_id = $2 - OR (s.client_id IS NULL AND REPLACE(s.raw_data->>'Teléfono', ' ', '') LIKE $3) - OR (s.client_id IS NULL AND REPLACE(s.raw_data->>'TELEFONO', ' ', '') LIKE $3) - OR (s.client_id IS NULL AND REPLACE(s.raw_data->>'TELEFONOS', ' ', '') LIKE $3) - ) - ORDER BY s.created_at DESC - `, [ownerId, clientId, `%${cleanPhoneToMatch}%`, requestedServiceId]); + // Si nos pasan un ID de servicio en la URL, sacamos ESE servicio exacto + if (serviceIdParam && serviceIdParam !== "undefined" && serviceIdParam !== "null") { + qServices = await pool.query(` + SELECT s.id, s.service_ref, s.is_urgent, s.raw_data, s.created_at, s.client_id, + st.name as real_status_name, st.is_final as is_status_final, + u.full_name as worker_name, u.phone as worker_phone + FROM scraped_services s + LEFT JOIN users u ON u.id = s.assigned_to + LEFT JOIN service_statuses st ON st.id::text = (s.raw_data->>'status_operativo')::text + WHERE s.id = $1 AND s.owner_id = $2 + `, [parseInt(serviceIdParam), ownerId]); + } + // Si no hay ID en la URL, sacamos todos los del cliente usando su teléfono + else { + let phoneMatch = String(client.phone || "").replace(/\D/g, "").slice(-9); + if (phoneMatch.length < 8) phoneMatch = "NO_VALIDO_123"; + + qServices = await pool.query(` + SELECT s.id, s.service_ref, s.is_urgent, s.raw_data, s.created_at, s.client_id, + st.name as real_status_name, st.is_final as is_status_final, + u.full_name as worker_name, u.phone as worker_phone + FROM scraped_services s + LEFT JOIN users u ON u.id = s.assigned_to + LEFT JOIN service_statuses st ON st.id::text = (s.raw_data->>'status_operativo')::text + WHERE s.owner_id = $1 AND s.provider != 'SYSTEM_BLOCK' + AND ( + s.client_id = $2 + OR REPLACE(s.raw_data->>'Teléfono', ' ', '') LIKE $3 + OR REPLACE(s.raw_data->>'TELEFONO', ' ', '') LIKE $3 + OR REPLACE(s.raw_data->>'TELEFONOS', ' ', '') LIKE $3 + ) + ORDER BY s.created_at DESC + `, [ownerId, client.id, `%${phoneMatch}%`]); + } const formattedServices = qServices.rows.map(s => { return { @@ -449,7 +456,7 @@ app.get("/public/portal/:token", async (req, res) => { res.json({ ok: true, client: { name: client.full_name }, company, services: formattedServices }); } catch (e) { - console.error("🔥 ERROR EN PORTAL:", e); + console.error("🔥 ERROR EN PORTAL:", e.message); res.status(500).json({ ok: false, error: "Error interno" }); } });