CHIEFSOFT\ameye
79 lines
2.9 KiB
JavaScript
79 lines
2.9 KiB
JavaScript
'use strict';
|
|
|
|
const request = require('request');
|
|
const db = require('../app/db')
|
|
const logger = require('../app/logger');
|
|
|
|
var members_action = {
|
|
refreshActions: function (req, res, next) {
|
|
logger.info(req.query);
|
|
|
|
let Qstring = "SELECT id,uid,updated from members ORDER BY updated ASC LIMIT 2";
|
|
logger.info( Qstring );
|
|
db.query(Qstring, function (err, result) {
|
|
try {
|
|
if (err) throw err;
|
|
|
|
if (result.rowCount > 0 ){
|
|
result.rows.map( (rw)=>{
|
|
console.log(rw);
|
|
console.log(rw["uid"]);
|
|
|
|
const updateQuery = "UPDATE members SET updated =now() WHERE uid::text='"+rw["uid"]+"'"
|
|
db.query(updateQuery, (err, res) => {
|
|
if (err) {
|
|
logger.info(err.stack)
|
|
} else {
|
|
logger.info(res.rows[0])
|
|
}
|
|
})
|
|
|
|
const insertQuery = 'INSERT INTO members_actions(member_id, member_uid, action_label,action_name,status_description,status ) VALUES($1, $2, $3, $4, $5, $6)'
|
|
|
|
var Querydata2 = {
|
|
"members_id":rw["id"],
|
|
"members_uid": rw["uid"],
|
|
"action_label": 'Systems Status Checks ',
|
|
"action_name": 'system_status_checks',
|
|
"status_description": 'processing',
|
|
"status": 0
|
|
};
|
|
|
|
var Querydata = [
|
|
rw["id"],
|
|
rw["uid"],
|
|
'Systems Status Checks ',
|
|
'system_status_checks',
|
|
'processing',
|
|
0
|
|
];
|
|
|
|
logger.info(Querydata);
|
|
db.query(insertQuery, Querydata, (err, res) => {
|
|
if (err) {
|
|
console.log(err.stack)
|
|
} else {
|
|
console.log(res.rows[0])
|
|
}
|
|
})
|
|
})
|
|
}
|
|
|
|
let resultItem ={
|
|
"result": result.rows,
|
|
"total_record": result.rowCount
|
|
}
|
|
// logger.info(result);
|
|
next(null, resultItem); // pass control to the next handler
|
|
} catch (e) {
|
|
next(e.message, null); // pass control to the next handler
|
|
}
|
|
});
|
|
|
|
},
|
|
updateSelection: async function (){
|
|
logger.info("Ameye-Called -The-Function")
|
|
}
|
|
};
|
|
module.exports = members_action;
|