|
@ -27,6 +27,7 @@ const PLATFORMS = require('../../include/commons').PLATFORM;
|
|
|
|
|
|
let configFile = require('../../include/commons').CONFIG_FILE;
|
|
|
let config = require('../../resources/config/' + configFile);
|
|
|
const {SOCKET_TYPES} = require("../../include/commons");
|
|
|
|
|
|
class AppClient extends RedisModel {
|
|
|
constructor() {
|
|
@ -194,13 +195,23 @@ class AppClient extends RedisModel {
|
|
|
if(message.type ==1){
|
|
|
log.info("该消息是系统提醒消息,不做推送,:消息内容"+message.content)
|
|
|
}else{
|
|
|
HlwyyAssistantSDK.request("hz_cloudCare",tipMessage,targetId,message.content,url,params, function (err, res) {
|
|
|
if(err){
|
|
|
log.error(err);
|
|
|
}else {
|
|
|
log.info(res);
|
|
|
if(targetId!=message.sender_id){
|
|
|
let patient_system_Client = clientCache.findByIdAndType("patient_system_"+targetId,SOCKET_TYPES.PATIENT_SYSTEM);
|
|
|
let doctorClient = clientCache.findByIdAndType("doctor_system_"+targetId,SOCKET_TYPES.DOCTOR_SYSTEM);
|
|
|
if(doctorClient||patient_system_Client){
|
|
|
log.info("外壳socket在线不推送targetId:"+targetId+",sender_id"+message.sender_id);
|
|
|
}else{
|
|
|
HlwyyAssistantSDK.request("hz_cloudCare",tipMessage,targetId,message.content,url,params, function (err, res) {
|
|
|
if(err){
|
|
|
log.error(err);
|
|
|
}else {
|
|
|
log.info(res);
|
|
|
}
|
|
|
});
|
|
|
}
|
|
|
});
|
|
|
}else {
|
|
|
log.info("自己不推送targetId:"+targetId+",sender_id"+message.sender_id);
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
}
|