|
|
@ -109,7 +109,7 @@ class Patient extends BaseModel {
|
|
|
* @param message
|
|
|
*/
|
|
|
sendConsultWechatReplyTempMsg(message) {
|
|
|
// 推送微信模板消息
|
|
|
// 查询居民openid
|
|
|
patientRepo.getPatientOpenid(message.to, function (err, result) {
|
|
|
if (err) {
|
|
|
modelUtil.emitDbError(self.eventEmitter, "get patient openid failed", err);
|
|
|
@ -119,6 +119,7 @@ class Patient extends BaseModel {
|
|
|
var openid = result && result.length > 0 ? result[0].openid : "";
|
|
|
|
|
|
if (openid) {
|
|
|
// 查询医生信息
|
|
|
doctorRepo.getDoctorInfo(message.from, function (err, result) {
|
|
|
if (err) {
|
|
|
modelUtil.emitDbError(self.eventEmitter, "get doctor info failed", err);
|
|
|
@ -127,7 +128,7 @@ class Patient extends BaseModel {
|
|
|
|
|
|
if (result && result.length > 0) {
|
|
|
var name = result[0].name;
|
|
|
|
|
|
// 查询医生与居民对应的咨询信息
|
|
|
patientRepo.getPatientDoctorConsult(message.to, message.from, function (err, result) {
|
|
|
if (err) {
|
|
|
modelUtil.emitDbError(self.eventEmitter, "get patient and doctor consult info failed", err);
|
|
|
@ -163,7 +164,7 @@ class Patient extends BaseModel {
|
|
|
break;
|
|
|
}
|
|
|
|
|
|
|
|
|
// 模板消息数据
|
|
|
var msg = {
|
|
|
touser: openid,
|
|
|
template_id: config.wechatConfig.template.consultTemplate,
|
|
|
@ -178,6 +179,7 @@ class Patient extends BaseModel {
|
|
|
}
|
|
|
};
|
|
|
|
|
|
// 发送模板消息
|
|
|
wechatUtil.sendWxTemplateMessage(msg);
|
|
|
}
|
|
|
});
|
lyr