PK!A7��nvar sql = require("mysql"); var pool = require("../db"); const opts = { errorEventName: "error", logDirectory: "logs", fileNamePattern: "log-.log", dateFormat: "YYYY-MM-DD", }; const log = require("simple-node-logger").createRollingFileLogger(opts); module.exports = { getConnectionDB: function (startDate, endDate) { return new Promise((resolve, reject) => { let data = [startDate, endDate]; let query = "select id,name, type, url, status,username,password,post_data,created_at,host,port from connections where date(created_at) BETWEEN ? and ? order by id desc"; pool.query(query, data, (err, results, fields) => { try { if (err) { log.info("[PLANS], [MODEL], [getPlansDB], [error], [" + err + "]"); throw err; } else { var numRows = results.length; if (numRows > 0) { return resolve(results); } else { return resolve(false); } } } catch (err) { log.info("[PLANS], [MODEL], [getPlansDB], [error], [" + err + "]"); return reject(err); } }); }); }, getConnections: function (startDate, endDate) { return new Promise((resolve, reject) => { let data = [startDate, endDate]; let query = "select id,name, type, url, status,username,password,post_data,created_at from connections order by id desc"; pool.query(query, data, (err, results, fields) => { try { if (err) { log.info("[PLANS], [MODEL], [getPlansDB], [error], [" + err + "]"); throw err; } else { var numRows = results.length; if (numRows > 0) { return resolve(results); } else { return resolve([]); } } } catch (err) { log.info("[PLANS], [MODEL], [getPlansDB], [error], [" + err + "]"); return reject(err); } }); }); }, getConnctionByName: function (newName) { return new Promise((resolve, reject) => { let data = [newName]; let query = "select * from connections where name=? order by id desc"; pool.query(query, data, (err, results, fields) => { try { if (err) { log.info("[PLANS], [MODEL], [getPlansDB], [error], [" + err + "]"); throw err; } else { var numRows = results.length; if (numRows > 0) { return resolve(results); } else { return resolve(false); } } } catch (err) { log.info("[PLANS], [MODEL], [getPlansDB], [error], [" + err + "]"); return reject(err); } }); }); }, addConnectionForGet: function (newName, method, userName, password, url) { return new Promise((resolve, reject) => { let query = "insert into connections (name, type, username, password,url, created_at, updated_at) values(?, ?, ?, ?, ?, now(), now());"; let data = [newName, method, userName, password, url]; pool.query(query, data, (err, results, fields) => { try { if (err) { throw err; } else { return resolve(results.insertId); } } catch (err) { log.info(`[CONTACT], [MODEL], [addConnectionForGet], [error], [${err}]`); reject(err); } }); }); }, addConnectionForSmpp: function (newName, method, userName, password, host, port, adminport, smsboxport) { return new Promise((resolve, reject) => { let query = "insert into connections (name, type, username, password,host, port, smsbox_port, admin_port, created_at, updated_at) values(?, ?, ?, ?, ?, ?,?,?,now(), now());"; let data = [newName, method, userName, password, host, port, smsboxport, adminport]; pool.query(query, data, (err, results, fields) => { try { if (err) { throw err; } else { return resolve(results.insertId); } } catch (err) { log.info(`[CONTACT], [MODEL], [addConnectionForSmpp], [error], [${err}]`); reject(err); } }); }); }, updateStatus: function (status, id) { return new Promise((resolve, reject) => { const query = "update connections set status=? where id=? "; let data = [status, id]; pool.query(query, data, (err, results, fields) => { try { if (err) { throw err; } else { return resolve(results.insertId); } } catch (err) { log.info(`[CONTACT], [MODEL], [addContact], [error], [${err}]`); reject(err); } }); }); }, getConnectionbyid: function (operator) { return new Promise((resolve, reject) => { let data = [operator]; let query = "select * from connections where id=? "; pool.query(query, data, (err, results, fields) => { try { if (err) { log.info("[PLANS], [MODEL], [getPlansDB], [error], [" + err + "]"); throw err; } else { var numRows = results.length; if (numRows > 0) { return resolve(results[0]); } else { return resolve(false); } } } catch (err) { log.info("[PLANS], [MODEL], [getPlansDB], [error], [" + err + "]"); return reject(err); } }); }); }, getActiveConnections: function () { return new Promise((resolve, reject) => { let query = "select id,name from connections where status=1 order by id desc"; pool.query(query, (err, results, fields) => { try { if (err) { log.info("[CONNECTIONS], [MODEL], [getActiveConnections], [error], [" + err + "]"); throw err; } else { var numRows = results.length; if (numRows > 0) { return resolve(results); } else { return resolve([]); } } } catch (err) { log.info("[PLANS], [CONNECTIONS], [getActiveConnections], [error], [" + err + "]"); return reject(err); } }); }); }, };