|
@ -50,19 +50,39 @@ class WechatSDK {
|
|
|
let wechatEcho = JSON.parse(data);
|
|
|
if (wechatEcho && wechatEcho.errcode === 0) {
|
|
|
log.info("Send wechat template message successfully: " + messageJSON);
|
|
|
WechatTokenRepo.saveLog(message.touser,message.patient, message.name,messageJSON,data,1, new Date(), function (err, result) {
|
|
|
if (err) {
|
|
|
log.error("save push log failed: " + err.message);
|
|
|
}
|
|
|
});
|
|
|
handler(null, wechatEcho);
|
|
|
} else {
|
|
|
WechatTokenRepo.saveLog(message.touser,message.patient, message.name,messageJSON,data,0, new Date(), function (err, result) {
|
|
|
if (err) {
|
|
|
log.error("save push log failed: " + err.message);
|
|
|
}
|
|
|
});
|
|
|
log.error("Send wechat template message failed: " + messageJSON);
|
|
|
handler(wechatEcho, null);
|
|
|
}
|
|
|
});
|
|
|
|
|
|
res.on('error', function (err) {
|
|
|
WechatTokenRepo.saveLog(message.touser,message.patient, message.name,messageJSON,err.message,1, new Date(), function (err, result) {
|
|
|
if (err) {
|
|
|
log.error("save push log failed: " + err.message);
|
|
|
}
|
|
|
});
|
|
|
log.error('Send wechat template message failed: ' + err.message);
|
|
|
handler(err, null);
|
|
|
});
|
|
|
})
|
|
|
.on('error', (e) => {
|
|
|
WechatTokenRepo.saveLog(message.touser,message.patient, message.name,messageJSON,e.message,1, new Date(), function (err, result) {
|
|
|
if (err) {
|
|
|
log.error("save push log failed: " + err.message);
|
|
|
}
|
|
|
});
|
|
|
log.error("Send wechat template message failed:" + e.message);
|
|
|
handler(e, null);
|
|
|
});
|