|
@ -11,7 +11,7 @@ let ControllerUtil = require('../../util/controller.util');
|
|
|
let APIv2 = require('../../include/endpoints').APIv2;
|
|
|
let MODEL_EVENTS = require('../../include/commons').MODEL_EVENTS;
|
|
|
let Messages = require('../../models/messages/messages');
|
|
|
|
|
|
let WechatClient = require("../../models/client/wechat.client.js");
|
|
|
/**
|
|
|
* 发送消息
|
|
|
*/
|
|
@ -30,6 +30,24 @@ router.post(APIv2.Message.Send, function (req, res) {
|
|
|
messages.sendMessage(payload);
|
|
|
});
|
|
|
|
|
|
/**
|
|
|
* 发送医生外层socket消息
|
|
|
*/
|
|
|
router.post(APIv2.Message.DoctorSystemMessage, function (req, res) {
|
|
|
let targetUserId = req.body.targetUserId;
|
|
|
let message = req.body.message;
|
|
|
if (!targetUserId) {
|
|
|
throw {httpStatus: 406, message: 'Missing targetUserId.'};
|
|
|
}
|
|
|
if (!message) {
|
|
|
throw {httpStatus: 406, message: 'Missing message.'};
|
|
|
}
|
|
|
ControllerUtil.regModelEventHandler(wechatClient, res);
|
|
|
|
|
|
//推送MDT,医生外层新消息
|
|
|
WechatClient.sendMDTSocketMessageToDoctor(targetUserId,JSON.parse(message));
|
|
|
});
|
|
|
|
|
|
router.get(APIv2.Message.DataMessage, function (req, res) {
|
|
|
let sessionId = req.query.sessionId;
|
|
|
let messages = new Messages();
|