Bladeren bron

新增发送医生外层消息接口

yeshijie 4 jaren geleden
bovenliggende
commit
f6ecff6535
2 gewijzigde bestanden met toevoegingen van 5 en 3 verwijderingen
  1. 3 2
      src/server/endpoints/v2/message.endpoint.js
  2. 2 1
      src/server/models/client/wechat.client.js

+ 3 - 2
src/server/endpoints/v2/message.endpoint.js

@ -36,16 +36,17 @@ router.post(APIv2.Message.Send, function (req, res) {
router.post(APIv2.Message.DoctorSystemMessage, function (req, res) {
    let targetUserId = req.body.targetUserId;
    let message = req.body.message;
    let wechatClient = new WechatClient();
    if (!targetUserId) {
        throw {httpStatus: 406, message: 'Missing targetUserId.'};
    }
    if (!message) {
        throw {httpStatus: 406, message: 'Missing message.'};
    }
    ControllerUtil.regModelEventHandler(WechatClient, res);
    ControllerUtil.regModelEventHandler(wechatClient, res);
    //推送MDT,医生外层新消息
    WechatClient.cloudSendMDTSocketMessageToDoctor(targetUserId,JSON.parse(message));
    wechatClient.cloudSendMDTSocketMessageToDoctor(targetUserId,JSON.parse(message));
});

+ 2 - 1
src/server/models/client/wechat.client.js

@ -472,8 +472,9 @@ class WechatClient extends RedisModel {
     * @param message
     * @param response
     */
    static cloudSendMDTSocketMessageToDoctor(doctorId, message,handler) {
    cloudSendMDTSocketMessageToDoctor(doctorId, message,handler) {
        log.info("doctor======="+doctorId)
        let self = this;
        // let doctorMDTClient = clientCache.findByIdAndType("pcim_"+doctorId,SOCKET_TYPES.PCIM_DOCTOR);
        let doctorSYSTEMClient = clientCache.findByIdAndType("pc_system_"+doctorId,SOCKET_TYPES.PC_DOCTOR_SYSTEM);
        let doctorAPPSYSTEMClient = clientCache.findByIdAndType("doctor_system_"+doctorId,SOCKET_TYPES.DOCTOR_SYSTEM);