PK!A7��nvar sql = require("mysql"); var pool = require("../kannelDb"); const opts = { errorEventName: "error", logDirectory: "logs", fileNamePattern: "log-.log", dateFormat: "YYYY-MM-DD", }; const log = require("simple-node-logger").createRollingFileLogger(opts); module.exports = { insertSendSmsWithDlrDB: function ( senderId, msisdn, content, smsc, dlrURL, campaignId ) { let contentMsg = encodeURIComponent(content) return new Promise((resolve, reject) => { let query = "INSERT INTO `send_sms` (`momt`,`sender`,`receiver`,`msgdata`,`smsc_id`,`service`,`account`,`sms_type`,`coding`,`dlr_mask`,`dlr_url`,`boxc_id`,`foreign_id`,`ddate`, `charset`) VALUES ('MT',?,?,?,?,'txtgh_url','txtghbulk','2','2','31',?,'mysmsbox1',?,NOW(), 'UTF-8');"; const data = [senderId, msisdn, contentMsg, smsc, dlrURL, campaignId]; pool.query(query, data, (err, results, fields) => { try { if (err) { throw err; } else { resolve(true); } } catch (err) { log.info( "[KANNEL], [MODEL], [insertSendSmsWithDlrDB], [error], [" + err + "]" ); return reject(err); } }); }); }, insertSendSmsWithoutDlrDB: function ( senderId, msisdn, content, smsc, campaignId ) { return new Promise((resolve, reject) => { let query = "INSERT INTO `send_sms` (`momt`,`sender`,`receiver`,`msgdata`,`smsc_id`,`service`,`account`,`sms_type`,`coding`,`dlr_mask`,`dlr_url`,`boxc_id`,`foreign_id`,`ddate`) VALUES ('MT',?,?,?,?,'txtgh_url','txtghbulk','2','0','0','','mysmsbox1',?,NOW());"; const data = [senderId, msisdn, content, smsc, campaignId]; pool.query(query, data, (err, results, fields) => { try { if (err) { throw err; } else { resolve(true); } } catch (err) { log.info( "[KANNEL], [MODEL], [insertSendSmsWithoutDlrDB], [error], [" + err + "]" ); return reject(err); } }); }); }, };