|
@ -95,9 +95,10 @@ class WechatClient extends RedisModel {
|
|
|
let pc_doctorClient = clientCache.findByIdAndType("pc_"+message.sender_id,SOCKET_TYPES.PC_DOCTOR);
|
|
|
|
|
|
let pc_patient_system_Client = clientCache.findByIdAndType("pcpatient_system_"+targetUserId,SOCKET_TYPES.PC_PATIENT_SYSTEM);
|
|
|
let patient_system_Client = clientCache.findByIdAndType("patient_system_"+targetUserId,SOCKET_TYPES.PATIENT_SYSTEM);
|
|
|
|
|
|
var count = 0;
|
|
|
if (patientClient || pc_patientClient || pc_patient_system_Client) {
|
|
|
if (patientClient || pc_patientClient || pc_patient_system_Client || patient_system_Client) {
|
|
|
|
|
|
if(patientClient){
|
|
|
log.warn("User's wechat endpoint is online, sending via web socket. User id: ", targetUserId);
|
|
@ -114,6 +115,11 @@ class WechatClient extends RedisModel {
|
|
|
WechatClient.sendViaWebSocket(pc_patient_system_Client.socket, message);
|
|
|
}
|
|
|
|
|
|
if(patient_system_Client){
|
|
|
log.warn("User's systme endpoint is online, sending via web socket. User id: ", targetUserId);
|
|
|
WechatClient.sendViaWebSocket(patient_system_Client.socket, message);
|
|
|
}
|
|
|
|
|
|
if(doctorClient && (patientClient || pc_patientClient) ){
|
|
|
log.error("doctor sessionid "+doctorClient.sessionId);
|
|
|
|
|
@ -445,6 +451,25 @@ class WechatClient extends RedisModel {
|
|
|
patient_sex:message.patient_sex,
|
|
|
extend:message.extend
|
|
|
});
|
|
|
|
|
|
//新增发送医生外层
|
|
|
if(message.content_type == CONTENT_TYPES.VideoAnswerStatus){
|
|
|
doctorAPPSYSTEMClient.socket.emit('message', {
|
|
|
id: message.id,
|
|
|
session_id: message.session_id,
|
|
|
sender_id: message.sender_id,
|
|
|
sender_name: message.sender_name,
|
|
|
content_type: message.content_type,
|
|
|
content: message.content,
|
|
|
timestamp: ObjectUtil.timestampToLong(message.timestamp),
|
|
|
type: message.content_type, // legacy support
|
|
|
name: message.sender_name,
|
|
|
patient_name:message.patient_name,
|
|
|
patient_age:message.patient_age,
|
|
|
patient_sex:message.patient_sex,
|
|
|
extend:message.extend
|
|
|
});
|
|
|
}
|
|
|
}
|
|
|
|
|
|
|