0xn0l

📂 /home/brightbrai/deploy/routes

✎ EDIT: dataRoutes.js ← BACK

const express = require('express');
const router = express.Router();
const db = require('../db');

// Helper to structure nested data
const structureData = (mainRecords, subRecords, mainIdKey, subIdKey, subArrayName) => {
    const mainMap = new Map();
    mainRecords.forEach(record => {
        record[subArrayName] = [];
        mainMap.set(record[mainIdKey], record);
    });
    subRecords.forEach(subRecord => {
        const mainRecord = mainMap.get(subRecord[subIdKey]);
        if (mainRecord) {
            mainRecord[subArrayName].push(subRecord);
        }
    });
    return Array.from(mainMap.values());
};

// GET all data for initial app load
router.get('/all-data', async (req, res) => {
    try {
        const [opdVisits] = await db.query('SELECT * FROM opd_visits ORDER BY visitDate DESC');
        const [opdFees] = await db.query('SELECT * FROM opd_fees');

const [gynaeAdmissions] = await db.query('SELECT * FROM gynae_admissions ORDER BY admissionDate DESC');
        const [gynaeFees] = await db.query('SELECT * FROM gynae_fees');
        const [gynaePayments] = await db.query('SELECT * FROM gynae_payments');
        const [gynaeMedications] = await db.query('SELECT * FROM gynae_medications');

const [nurseryRecords] = await db.query('SELECT * FROM nursery_records ORDER BY admissionDate DESC');
        const [nurseryFees] = await db.query('SELECT * FROM nursery_fees');
        const [nurseryPayments] = await db.query('SELECT * FROM nursery_payments');

const [expenditures] = await db.query('SELECT * FROM expenditures ORDER BY date DESC');
        const [users] = await db.query('SELECT id, username, role, permissions, securityQuestion FROM users'); // Omit password and answer
        const [doctors] = await db.query('SELECT * FROM doctors');
        const [staffMembers] = await db.query('SELECT * FROM staff_members');
        const [salaryAdvances] = await db.query('SELECT * FROM salary_advances');
        const [salaryPayments] = await db.query('SELECT * FROM salary_payments');
        
        const [settings] = await db.query('SELECT * FROM settings');
        const settingsObj = settings.reduce((acc, setting) => {
            try {
                acc[setting.keyName] = JSON.parse(setting.value);
            } catch (e) {
                acc[setting.keyName] = setting.value;
            }
            return acc;
        }, {});
        
        // Structure nested data
        let structuredOpd = structureData(opdVisits, opdFees, 'id', 'visitId', 'fees');
        
        let structuredGynae = structureData(gynaeAdmissions, gynaeFees, 'id', 'admissionId', 'fees');
        structuredGynae = structureData(structuredGynae, gynaePayments, 'id', 'admissionId', 'payments');
        structuredGynae = structureData(structuredGynae, gynaeMedications, 'id', 'admissionId', 'dischargeMedication');
        
        let structuredNursery = structureData(nurseryRecords, nurseryFees, 'id', 'recordId', 'fees');
        structuredNursery = structureData(structuredNursery, nurseryPayments, 'id', 'recordId', 'payments');
        
        users.forEach(u => u.permissions = JSON.parse(u.permissions));

res.json({
            opdVisits: structuredOpd,
            gynaeAdmissions: structuredGynae,
            nurseryRecords: structuredNursery,
            expenditures,
            users,
            doctors,
            staffMembers,
            salaryAdvances,
            salaryPayments,
            settings: settingsObj
        });
    } catch (err) {
        console.error(err.message);
        res.status(500).send('Server Error');
    }
});

// OPD Routes
router.post('/opd', async (req, res) => {
    const { fees, ...visitData } = req.body;
    const connection = await db.getConnection();
    try {
        await connection.beginTransaction();
        const [result] = await connection.query('INSERT INTO opd_visits SET ?', [visitData]);
        const visitId = result.insertId;
        
        if (fees && fees.length > 0) {
            for (const fee of fees) {
                await connection.query('INSERT INTO opd_fees SET ?', [{ ...fee, visitId }]);
            }
        }
        
        await connection.commit();
        res.json({ msg: 'OPD visit added successfully' });
    } catch (err) {
        await connection.rollback();
        console.error(err.message);
        res.status(500).send('Server Error');
    } finally {
        connection.release();
    }
});

// Gynae Routes
router.post('/gynae', async (req, res) => {
    const { fees, payments, dischargeMedication, ...admissionData } = req.body;
    
    if (admissionData.admissionDate && admissionData.admissionTime) {
        admissionData.admissionDate = `${admissionData.admissionDate} ${admissionData.admissionTime}`;
    }

const connection = await db.getConnection();
    try {
        await connection.beginTransaction();
        const [result] = await connection.query('INSERT INTO gynae_admissions SET ?', [admissionData]);
        const admissionId = result.insertId;

if (fees && fees.length > 0) {
            for (const fee of fees) {
                await connection.query('INSERT INTO gynae_fees SET ?', [{ ...fee, admissionId }]);
            }
        }
        if (payments && payments.length > 0) {
            for (const payment of payments) {
                await connection.query('INSERT INTO gynae_payments SET ?', [{ ...payment, admissionId }]);
            }
        }

await connection.commit();
        res.json({ msg: 'Gynae admission added successfully' });
    } catch (err) {
        await connection.rollback();
        console.error(err.message);
        res.status(500).send('Server Error');
    } finally {
        connection.release();
    }
});

router.put('/gynae/:id', async (req, res) => {
    const { id } = req.params;
    const { fees, payments, dischargeMedication, ...admissionData } = req.body;
    
    if (admissionData.dischargeDate && admissionData.dischargeTime) {
        admissionData.dischargeDate = `${admissionData.dischargeDate} ${admissionData.dischargeTime}`;
        delete admissionData.dischargeTime;
    }

// Nursery Routes
router.post('/nursery', async (req, res) => {
    const { fees, payments, ...recordData } = req.body;
    const connection = await db.getConnection();
    try {
        await connection.beginTransaction();

if (recordData.admissionDate && recordData.admissionTime) {
            recordData.admissionDate = `${recordData.admissionDate} ${recordData.admissionTime}`;
        }
        
        const [result] = await connection.query('INSERT INTO nursery_records SET ?', [recordData]);
        const recordId = result.insertId;

if (fees && fees.length > 0) {
            for (const fee of fees) { 
                await connection.query('INSERT INTO nursery_fees SET ?', [{ ...fee, recordId }]) 
            }
        }
        if (payments && payments.length > 0) {
            for (const payment of payments) { 
                await connection.query('INSERT INTO nursery_payments SET ?', [{ ...payment, recordId }]) 
            }
        }
        await connection.commit();
        res.json({ msg: 'Nursery record added' });
    } catch (err) {
        await connection.rollback();
        console.error(err.message);
        res.status(500).send('Server Error');
    } finally { connection.release(); }
});

0xn0l - 0011000001111000011011100011000001101100