📁 File Manager Pro
v10.0.3 | PHP: 8.2.31
Server: LiteSpeed
2026-06-29 08:21:58
📂
/ (Root)
/
home
/
orkouolp
/
node_js
/
orkofarms.com
/
controller
📍 /home/orkouolp/node_js/orkofarms.com/controller
🔄 Refresh
✏️
Editing: cow.controller.js
Writable
const con = require('../mysql').con, logger = require('../log4js').logger; const cowController = {}; cowController.getCows = async (req, res) => { let query = {}; console.log('GET /get-cows'); logger.debug('GET /get-cows'); return con.query('SELECT * FROM cows', async (err, rows) => { if(err) { logger.debug('Database Connection Error: ')+err.toString(); throw err; } logger.debug('Database Connection active for getting cows! rows: '+rows.toString()); // let due = 0; //console.log('rows:', rows); // const docs = (await firebase.db.collection('settings').get()).docs; //console.log('docs:', docs); // if(docs.length>0) due = docs[0].data().due; logger.debug('sending cows...'); res.send({ cows: rows }); }); } //---------------------------------------------------------------------------------------------------------// cowController.saveCow = async (req, res) => { console.log("POST /save-cow"); logger.debug('POST /save-cow'); const { currentUser } = req; //console.log('currentUser:', currentUser); if(!currentUser) { logger.debug('an error occured, unable to save cow'); res.status(400).json({ error: 'an error occured, unable to save cow' }); } let { tagNo, purchDt, bodyWt, age, insurance, id } = req.body, { uid } = currentUser; const cowInfo = { tagNo, purchDt, bodyWt, age, insurance, user:uid }; console.log('cowInfo:', cowInfo); //-------------------------------------------------------------------------------------// const updateCowData = async (id) => { cowInfo.id = id; let doc = { due: 0 }; console.log('Returning cowInfo:', cowInfo); res.status(201).json({ message: 'Saved cow info.', cowInfo }); }; //-------------------------------------------------------------------------------------// if(con && cowInfo) { if(!id) { //Find cow by tagNo con.query('SELECT id FROM cows WHERE tagNo=?', [tagNo], (err, rows) => { if(!err && rows && rows.length>0) id = rows[0].id; }); } if(id) { //Update con.query('SELECT COUNT(*) AS count FROM cows WHERE id=?', [id], (err, rows) => { if(err) throw err; console.log('rows:', rows, rows.length); if (rows[0].count < 1) res.status(200).json({message:'Error updating cow info'}); else { con.query('UPDATE cows SET tagNo=?, purchDt=?, bodyWt=?, age=?, insurance=?, user=?', Object.values(cowInfo), (err, set) => { if(err) throw err; updateCowData(id.toString()); }); } }); } else { //Insert con.query('INSERT INTO cows SET ?', cowInfo, (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()); updateCowData(set.insertId.toString()); }); } } //-------------------------------------------------------------------------------------// } //---------------------------------------------------------------------------------------------------------// module.exports = cowController;
💾 Save Changes
❌ Cancel