📁 File Manager Pro
v10.0.3 | PHP: 8.2.31
Server: LiteSpeed
2026-07-01 08:06:23
📂
/ (Root)
/
home
/
orkouolp
/
node_js
/
orkofarms.com
/
api
📍 /home/orkouolp/node_js/orkofarms.com/api
🔄 Refresh
✏️
Editing: saveMilkSale.js
Writable
const firebase = require('../firebase'), con = require('../mysql').con; const logger = require('../log4js').logger; // const MilkSale = require('../models/milkSale.model'); async function saveMilkSale(req, res) { console.log('POST /save-milk-sale'); logger.debug('POST /save-milk-sale'); //logger.debug('Checking for currentUser: '+req.currentUser.toString()); const { currentUser } = req; //console.log('currentUser:', currentUser); //logger.debug('currentUser: '+currentUser.toString()); if(!currentUser) { logger.debug('an error occured, unable to save milk sale'); res.status(400).json({ error: 'an error occured, unable to save milk sale' });; } //logger.debug('Checking for uid in currentUser: '+currentUser.toString()); //logger.debug('uid in currentUser: '+currentUser.uid.toString()); const { colDt, qty, value, amt, due, id } = req.body, { uid } = currentUser; //logger.debug('uid: '+uid.toString()); const saleInfo = { colDt, qty, value, amt, due, user:uid }; //console.log('saleInfo:', saleInfo); //, id //logger.debug('saleInfo: '+saleInfo.toString()); //-------------------------------------------------------------------------------------// const updateSaleData = async (id) => { saleInfo.id = id; let doc = { due: 0 }; const docs = (await firebase.db.collection('settings').get()).docs; //console.log('docs:', docs); if(docs.length>0) doc = docs[0].data(); doc.due = saleInfo.due; const settingsDb = firebase.db.collection('settings'); try { await settingsDb.doc('0').set(doc); console.log('doc:', doc); } catch(error) { console.log(error); } console.log('Returning saleInfo:', saleInfo); res.status(201).json({ message: 'Saved milkSale info.', saleInfo }); }; //-------------------------------------------------------------------------------------// //logger.debug('con: '+con.toString()+', saleInfo: '+saleInfo.toString()); if(con && saleInfo) { if(id && id.length>4) { //Update // MilkSale.findById(id) // .then(async (milkSale) => { console.log("Editing milkSale:", milkSale); // Object.keys(saleInfo).forEach(key => { //console.log("key:", key // if (saleInfo.hasOwnProperty(key)) milkSale[key] = saleInfo[key]; // }); milkSale.save(); //console.log("Successfully updated: sfpHeads", financial.sfpHeads); // updateSaleData(id); // }).catch(err => console.log(err)); logger.debug('SELECT COUNT(*) AS count FROM milk_sales WHERE id='+id); con.query('SELECT COUNT(*) AS count FROM milk_sales WHERE id=?', [id], (err, rows) => { if(err) throw err; console.log('rows:', rows, rows.length); if (rows[0].count < 1) res.send({ message: 'Not found' }); else { con.query('UPDATE milk_sales SET colDt=?, qty=?, value=?, amt=?, due=?, user=?', Object.values(saleInfo), (err, set) => { if(err) throw err; updateSaleData(id.toString()); }); } }); } else { //Insert // MilkSale.create(saleInfo) // .then(milkSale => { //console.log("NEW MilkSale:", milkSale); // updateSaleData(milkSale._id.toString()); // }).catch(err => console.log(err)); //logger.debug('INSERT INTO milk_sales - saleInfo: '+saleInfo.toString()); con.query('INSERT INTO milk_sales SET ?', saleInfo, (err, set) => { logger.debug('Going to check INSERT Error'); if(err) { logger.debug('INSERT ERROR: '+err.toString()); throw err; } //console.log('Last insert ID:', set.insertId); logger.debug('INSERT SET: '+set.toString()); updateSaleData(set.insertId.toString()); }); } } else { logger.debug('Error saving the milk sale'); res.send({ message: 'Error saving the milk sale' }); } // res.status(200).json({saleInfo}); } module.exports = saveMilkSale;
💾 Save Changes
❌ Cancel