var JPush = require("jpush-async").JPushAsync
|
var client = JPush.buildClient('4d8537a365e460b36ee67582', 'aa157259813574ee87a17fbb')
|
module.exports = {
|
pushAll(msg) {
|
return new Promise((resolve, reject) => {
|
client.push().setPlatform(JPush.ALL)
|
.setAudience(JPush.ALL)
|
.setMessage(msg)
|
.send()
|
.then(function (result) {
|
resolve(result)
|
}).catch(function (err) {
|
reject(err);
|
});
|
})
|
},
|
/**
|
* 命令下发接口
|
* @param {String} alias 设备号，逗号分割
|
* @param {String} msg "scan","record","reboot"
|
* @param {JSON} extra 相应的命令参数
|
*/
|
pushWithAlias(rids, msg, extra) {
|
return new Promise((resolve, reject) => {
|
client.push().setPlatform('android')
|
.setAudience(JPush.registration_id(rids))
|
.setMessage('title', msg, 'string', extra)
|
.send()
|
.then(function (result) {
|
// let sql = 'INSERT INTO t_fm_jpush(msg_id,android_id,msg,send_time) VALUES '
|
// if (typeof alias=="object") {
|
// sql += `('${result.msg_id}','${alias[0]}','${msg}',NOW())`
|
// for (let i = 1; i < alias.length; i++) {
|
// const element = alias[i];
|
// sql += `,('${result.msg_id}','${alias[i]}','${msg}',NOW())`
|
// }
|
// } else {
|
// sql += `('${result.msg_id}','${alias}','${msg}',NOW())`
|
// }
|
//mysql_db.query(sql);
|
resolve(result)
|
}).catch(function (err) {
|
reject(err);
|
});
|
})
|
}
|
}
|
