123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308 |
- /**
- * 用户微信客户端。
- */
- "use strict";
- let RedisClient = require('../../repository/redis/redis.client');
- let RedisModel = require('../redis.model');
- let ObjectUtil = require("../../util/object.util.js");
- let ModelUtil = require('../../util/model.util');
- let WechatSDK = require('../../util/wechat.sdk');
- let PatientRepo = require('../../repository/mysql/patient.repo');
- let TopicRepo = require("../../repository/mysql/topics.repo.js");
- let ParticipantRepo = require("../../repository/mysql/participant.repo");
- let redisConn = RedisClient.redisClient().connection;
- let clientCache = require('../socket.io/client.cache').clientCache();
- let configFile = require('../../include/commons').CONFIG_FILE;
- let config = require('../../resources/config/' + configFile);
- let log = require("../../util/log.js");
- let https = require('https');
- let http = require('http');
- let async = require('async');
- let querystring = require('querystring');
- let HlwyyWechatAssistantSDK = require("../../util/hlwyyWechatAssistant.sdk");
- var reqq = require('request');
- const CONTENT_TYPES = require('../../include/commons').CONTENT_TYPES;
- const SESSION_TYPES = require('../../include/commons').SESSION_TYPES;
- const SOCKET_TYPES = require('../../include/commons').SOCKET_TYPES;
- const REDIS_KEYS = require('../../include/commons').REDIS_KEYS;
- class WechatClient extends RedisModel {
- constructor() {
- super();
- }
- /**
- * 取得用户微信端状态。若Redis中找不到,则从MySQL中查找。
- *
- * @param userId
- * @param handler
- */
- static getWechatStatus(userId, handler) {
- redisConn.hgetallAsync(RedisModel.makeRedisKey(REDIS_KEYS.UserWechatStatus, userId))
- .then(function (status) {
- if (status == null) {
- PatientRepo.findWechatOpenId(userId, handler);
- } else {
- handler(null, {openid: status.openid});
- }
- })
- .catch(function (err) {
- handler(err, null);
- });
- }
- /**
- * 向微信端用户发送消息。若用户微信端在线,通过Web Socket推送给患者,如果不在线则通过微信的模板消息。
- *
- * 只推送文本、图片及语音消息
- *
- * @param targetUserId
- * @param message 消息体
- */
- static sendMessage(targetUserId, targetUserName, message) {
- if (message&&(message.content_type == CONTENT_TYPES.PlainText ||
- message.content_type == CONTENT_TYPES.Image ||
- message.content_type == CONTENT_TYPES.Audio||
- message.content_type == CONTENT_TYPES.PrescriptionBloodStatus ||
- message.content_type == CONTENT_TYPES.PrescriptionFollowupContent ||
- message.content_type == CONTENT_TYPES.ReservationDoorCardInfo ||
- message.content_type == CONTENT_TYPES.ChangeDoorCardInfo ||
- message.content_type == CONTENT_TYPES.ChangeDoorDoctor ||
- message.content_type == CONTENT_TYPES.ChangeDoorPackageItems ||
- message.content_type == CONTENT_TYPES.ReservationDoorCoachCardInfo ||
- message.content_type == CONTENT_TYPES.ChangeDoorCoachCardInfo ||
- message.content_type == CONTENT_TYPES.ChangeDoorCoachDoctor ||
- message.content_type == CONTENT_TYPES.ChangeDoorCoachPackageItems ||
- message.content_type == CONTENT_TYPES.VideoAnswerStatus ||
- message.content_type == CONTENT_TYPES.VideoAnswerAck ||
- message.content_type == CONTENT_TYPES.Screening ||
- message.content_type == CONTENT_TYPES.PrescriptionReject ||
- message.content_type == CONTENT_TYPES.PrescriptionSuggest ||
- message.content_type == CONTENT_TYPES.ConsultSuggest ||
- message.content_type == CONTENT_TYPES.PayMessage||
- message.content_type== CONTENT_TYPES.Article||
- message.content_type==CONTENT_TYPES.surveyMessage||
- message.content_type==CONTENT_TYPES.PersonalCard||
- message.content_type==CONTENT_TYPES.Video||
- message.content_type==CONTENT_TYPES.PrescriptionInfo||
- message.content_type==CONTENT_TYPES.PrescriptionDiagnosis||message.content_type==CONTENT_TYPES.EmergencyAssistanceMessage
- )) {
- let patientClient = clientCache.findById(targetUserId);
- let pc_patientClient = clientCache.findById("pcpatient_"+targetUserId);
- let doctorClient = clientCache.findByIdAndType(message.sender_id,SOCKET_TYPES.DOCTOR);
- 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 || patient_system_Client) {
- if(patientClient){
- log.warn("User's wechat endpoint is online, sending via web socket. User id: ", targetUserId);
- WechatClient.sendViaWebSocket(patientClient.socket, message);
- }
- if(pc_patientClient){
- log.warn("User's pc endpoint is online, sending via web socket. User id: ", targetUserId);
- WechatClient.sendViaWebSocket(pc_patientClient.socket, message);
- }
- if(pc_patient_system_Client){
- log.warn("User's pc systme endpoint is online, sending via web socket. User id: ", targetUserId);
- 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);
- if(patientClient && patientClient.sessionId==doctorClient.sessionId){
- log.error("patient sessionid "+patientClient.sessionId);
- //用户socket在线,推送给用户后,告知医生此消息已读
- WechatClient.updateParticipantLastFetchTime(doctorClient.sessionId, targetUserId, ObjectUtil.timestampToLong(message.timestamp));
- WechatClient.sendReadDoctor(doctorClient.socket, message);
- }
- if(pc_patientClient && pc_patientClient.sessionId==doctorClient.sessionId){
- log.error("pc_patient sessionid "+pc_patientClient.sessionId);
- //用户socket在线,推送给用户后,告知医生此消息已读
- WechatClient.updateParticipantLastFetchTime(doctorClient.sessionId, targetUserId, ObjectUtil.timestampToLong(message.timestamp));
- WechatClient.sendReadDoctor(doctorClient.socket, message);
- }
- }else{
- count++;
- }
- if(pc_doctorClient){
- log.error("pc_doctor sessionid "+pc_doctorClient.sessionId);
- if(patientClient){
- log.error("patient sessionid "+patientClient.sessionId);
- if(patientClient.sessionId==pc_doctorClient.sessionId){
- //用户socket在线,推送给用户后,告知医生此消息已读
- WechatClient.updateParticipantLastFetchTime(pc_doctorClient.sessionId, targetUserId, ObjectUtil.timestampToLong(message.timestamp));
- WechatClient.sendReadDoctor(pc_doctorClient.socket, message);
- }
- }
- if(pc_patientClient){
- log.error("pc_patient sessionid "+pc_patientClient.sessionId);
- if(pc_patientClient.sessionId==pc_doctorClient.sessionId){
- //用户socket在线,推送给用户后,告知医生此消息已读
- WechatClient.updateParticipantLastFetchTime(pc_doctorClient.sessionId, targetUserId, ObjectUtil.timestampToLong(message.timestamp));
- WechatClient.sendReadDoctor(pc_doctorClient.socket, message);
- }
- }
- }else{
- count++;
- }
- if(count==0){
- log.error("doctor client not found");
- }
- } else {
- log.info("User's wechat and pc endpoint is not online, sending via wechat template message. User id: ", targetUserId);
- var isSendWXTem = true;//是否发送微信模板
- if(message.content_type == CONTENT_TYPES.PrescriptionBloodStatus||message.content_type == CONTENT_TYPES.PrescriptionFollowupContent){
- var content = JSON.parse(message.content);
- if(content.isSendWxTemplate){
- message.content = content.text;
- }else {
- isSendWXTem = false;
- }
- }else if (message.content_type==CONTENT_TYPES.Article){
- var content = JSON.parse(message.content);
- message.content = content.title;
- }
- if(isSendWXTem){
- //发送第三方接口的微信模版消息
- WechatClient.sendThirdMessageTemplate(targetUserId, targetUserName, message);
- //发送厦门i健康的微信模版消息
- // WechatClient.sendViaMessageTemplate(targetUserId, targetUserName, message);
- }
- }
- } else if(message.content_type == CONTENT_TYPES.TopicEnd){
- let patientClient = clientCache.findById(targetUserId);
- if(patientClient){//结束咨询的告知患者
- WechatClient.sendViaWebSocket(patientClient.socket, message);
- }
- let pc_patientClient = clientCache.findById("pcpatient_"+targetUserId);
- if(pc_patientClient)//结束咨询的告知患者
- {
- WechatClient.sendViaWebSocket(pc_patientClient.socket, message);
- }
- }
- };
- static sendViaWebSocket(socket, message) {
- 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,
- sender_img : message.sender_img,
- extend:message.extend
- });
- }
- static sendAllRead(doctorId,sessionId){
- let doctorClient = clientCache.findByIdAndType(doctorId,SOCKET_TYPES.DOCTOR);
- let pc_doctorClient = clientCache.findByIdAndType("pc_"+doctorId,SOCKET_TYPES.PC_DOCTOR);
- if(doctorClient){
- if(doctorClient.sessionId==sessionId){
- doctorClient.socket.emit('message',{ read:"all"});
- }else{
- log.warn(" doctor not in the same session ");
- }
- }else{
- if(pc_doctorClient && pc_doctorClient.sessionId == sessionId){
- pc_doctorClient.socket.emit('message',{ read:"all"});
- }else{
- log.warn(doctorId+" target doctor is not online!");
- }
- }
- }
- static sendMucAllRead(doctorId,loginUserId,sessionId){
- let loginClinet = clientCache.findByIdAndType(loginUserId,SOCKET_TYPES.DOCTOR);
- if(loginClinet){
- //muc是医生来获取数据不能更新成已读
- log.warn("type is muc login is doctor not send all read to other doctor!")
- return;
- }
- let doctorClient = clientCache.findByIdAndType(doctorId,SOCKET_TYPES.DOCTOR);
- let pc_doctorClient = clientCache.findByIdAndType("pc_"+doctorId,SOCKET_TYPES.PC_DOCTOR);
- if(doctorClient){
- if(doctorClient.sessionId==sessionId){
- doctorClient.socket.emit('message',{ read:"all"});
- }else{
- log.warn(" doctor not in the same session ");
- }
- }else{
- if(pc_doctorClient && pc_doctorClient.sessionId == sessionId){
- pc_doctorClient.socket.emit('message',{ read:"all"});
- }else{
- log.warn(doctorId+" target doctor is not online!");
- }
- }
- }
- static sendReadDoctor(socket, message) {
- 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,
- read:"one"
- });
- }
- static sendReadDoctorByDoctorId(doctorId, message) {
- if(doctorId==message.sender_id){
- return;
- }
- let doctorClient = clientCache.findByIdAndType(doctorId,SOCKET_TYPES.DOCTOR);
- let pc_doctorClient = clientCache.findByIdAndType("pc_"+doctorId,SOCKET_TYPES.PC_DOCTOR);
- if(!doctorClient&&!pc_doctorClient){
- log.warn("target doctor is not online!");
- return;
- }
- let sendDoctorClient = clientCache.findByIdAndType(message.sender_id,SOCKET_TYPES.DOCTOR);
- if(!sendDoctorClient){
- sendDoctorClient = clientCache.findByIdAndType("pc_"+message.sender_id,SOCKET_TYPES.PC_DOCTOR);
- }
- var count = 0;
- if(doctorClient&&sendDoctorClient&&sendDoctorClient.sessionId==doctorClient.sessionId){
- WechatClient.updateParticipantLastFetchTime(doctorClient.sessionId, doctorId, ObjectUtil.timestampToLong(message.timestamp));
- sendDoctorClient.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,
- read:"one"
- });
- }else{
- count++;
- }
- //发送pc版医生端
- if(pc_doctorClient&&sendDoctorClient&&sendDoctorClient.sessionId==pc_doctorClient.sessionId){
- WechatClient.updateParticipantLastFetchTime(pc_doctorClient.sessionId, doctorId, ObjectUtil.timestampToLong(message.timestamp));
- pc_doctorClient.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,
- read:"one"
- });
- }else{
- count++;
- }
- if(count==2){
- log.warn("doctor is not in the same session or is not online");
- }
- }
- static sendSocketMessageToDoctor(doctorId, message) {
- let doctorClient = clientCache.findByIdAndType(doctorId,SOCKET_TYPES.DOCTOR);
- let pc_doctorClient = clientCache.findByIdAndType("pc_"+doctorId,SOCKET_TYPES.PC_DOCTOR);
- if(!doctorClient&&!pc_doctorClient){
- log.warn("target doctor is not online!");
- return;
- }
- // let sendClient = clientCache.findByIdAndType(message.sender_id,SOCKET_TYPES.DOCTOR);//app医生发送的消息
- // if(!sendClient){//pc医生发送的消息
- // sendClient = clientCache.findByIdAndType("pc_"+message.sender_id,SOCKET_TYPES.PC_DOCTOR);
- // }
- // if(!sendClient){//居民发送的消息
- // sendClient = clientCache.findByIdAndType(message.sender_id,SOCKET_TYPES.PATIENT);
- // }
- var count = 0;
- if(doctorClient&&message.session_id==doctorClient.sessionId){
- WechatClient.updateParticipantLastFetchTime(doctorClient.sessionId, doctorId, ObjectUtil.timestampToLong(message.timestamp));
- doctorClient.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,
- extend:message.extend
- });
- }else{
- count++;
- }
- //发送pc端 - PC端消息不做sessionid的判断,前端自己判断消息归属于哪个会话,自行渲染--20191012-huangwenjie
- // if(pc_doctorClient&&message.session_id==pc_doctorClient.sessionId){
- if(pc_doctorClient){
- WechatClient.updateParticipantLastFetchTime(pc_doctorClient.sessionId, doctorId, ObjectUtil.timestampToLong(message.timestamp));
- pc_doctorClient.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,
- extend:message.extend
- });
- }else{
- count++;
- }
- if(count==2){
- log.warn("doctor is not in the same session or is not online");
- }
- }
- /**
- * 推送MDT,医生外层新消息
- * @param doctorId
- * @param message
- */
- static sendMDTSocketMessageToDoctor(doctorId, message) {
- log.info("doctor======="+doctorId)
- // 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);
- //外层
- if(!doctorSYSTEMClient){
- log.warn("target system doctor is not online!");
- }else{
- doctorSYSTEMClient.socket.emit('message', {
- id: message.id,
- session_id: 'system',
- sender_id: message.sender_id,
- sender_name: message.sender_name,
- content_type: 1,
- content: {"socket_sms_type":4},
- 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
- });
- }
- if(!doctorAPPSYSTEMClient){
- log.warn("target system app doctor is not online!");
- }else{
- doctorAPPSYSTEMClient.socket.emit('message', {
- id: message.id,
- session_id: 'system',
- sender_id: message.sender_id,
- sender_name: message.sender_name,
- content_type: 1,
- content: {"socket_sms_type":4},
- 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
- });
- //新增发送医生外层
- if(message.content_type == CONTENT_TYPES.VideoAnswerStatus ||
- message.content_type == CONTENT_TYPES.VideoAnswerAck){
- 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
- });
- }
- }
- }
- /**
- * 医疗云 医生外层新消息
- * @param doctorId
- * @param message
- * @param response
- */
- 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);
- if(!doctorSYSTEMClient&&!doctorAPPSYSTEMClient){
- log.warn("target system doctor is not online!");
- ModelUtil.emitOK(self.eventEmitter, {status: 1,message:"doctor_not_online"});
- return;
- }
- //外层
- if(!doctorSYSTEMClient){
- log.warn("target system doctor is not online!");
- }else{
- if (message.content_type==CONTENT_TYPES.emergencyAssistance) {
- doctorSYSTEMClient.socket.emit('message', {
- session_id: message.session_id,
- sender_name: message.sender_name,
- content_notice: message.content_notice,
- sender_code: message.sender_code,
- OrderType: message.OrderType, //20紧急救助工单21上门预约工单22安防警报工单
- order_id: message.order_id,
- type: message.content_type,
- extend: message.extend
- });
- }else {
- doctorSYSTEMClient.socket.emit('message', {
- id: message.id,
- session_id: 'system',
- sender_id: message.sender_id,
- sender_name: message.sender_name,
- content_type: 1,
- content: {"socket_sms_type":4},
- 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
- });
- }
- }
- if(!doctorAPPSYSTEMClient){
- log.warn("target system app doctor is not online!");
- }else{
- if (message.content_type+""==CONTENT_TYPES.emergencyAssistance) {
- doctorAPPSYSTEMClient.socket.emit('message', {
- session_id: message.session_id,
- sender_name: message.sender_name,
- content_notice: message.content_notice,
- sender_code: message.sender_code,
- OrderType: message.OrderType,
- order_id: message.order_id,
- type: message.content_type,
- extend: message.extend
- });
- }else {
- doctorAPPSYSTEMClient.socket.emit('message', {
- id: message.id,
- session_id: 'system',
- sender_id: message.sender_id,
- sender_name: message.sender_name,
- content_type: 1,
- content: {"socket_sms_type":4},
- 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
- });
- }
- }
- ModelUtil.emitOK(self.eventEmitter, {status: 200});
- return;
- }
- /**
- * 医疗云 PC管理端发送socket
- * @param doctorId
- * @param message
- * @param response
- */
- CloudCarePcManageMessageToPc(clientType,message,handler) {
- let self = this;
- let CloudCarePcManageClients = clientCache.findByType(clientType);
- if(CloudCarePcManageClients.size==0){
- log.warn("target pcManage is not online!");
- ModelUtil.emitOK(self.eventEmitter, {status: 1,message:"pcManage_not_online"});
- return;
- }else {
- for (let clientKye of CloudCarePcManageClients.keys()){
- let CloudCarePcManageClient = CloudCarePcManageClients.get(clientKye);
- if (CloudCarePcManageClient){
- if (message.content_type==CONTENT_TYPES.emergencyAssistance) {
- CloudCarePcManageClient.socket.emit('message', {
- session_id: message.session_id,
- sender_name: message.sender_name,
- content_notice: message.content_notice,
- OrderStatus:message.OrderStatus,
- sender_code: message.sender_code,
- OrderType: message.OrderType, //20紧急救助工单21上门预约工单22安防警报工单
- order_id: message.order_id,
- type: message.content_type,
- latLon: message.latLon,
- categoryCode: message.categoryCode,
- orgType: message.orgType,
- contactStatus: message.contactStatus,
- serverDesc:message.serverDesc,
- residentialArea:message.residentialArea,
- extend: message.extend
- });
- }
- }
- }
- }
- ModelUtil.emitOK(self.eventEmitter, {status: 200});
- return;
- }
- /**
- * 医疗云 居民端发送socket
- * @param doctorId
- * @param message
- * @param response
- */
- CloudPatientSystemMessage(patient,message,handler) {
- let self = this;
- let patientSYSTEMClient = clientCache.findByIdAndType("patient_system_"+patient,SOCKET_TYPES.PATIENT_SYSTEM);
- if(!patientSYSTEMClient){
- log.warn("target pcManage is not online!");
- ModelUtil.emitOK(self.eventEmitter, {status: 1,message:"pcManage_not_online"});
- return;
- }else {
- if (message.content_type+""==CONTENT_TYPES.BirthdayToPatientAssistance) {//人文关怀(生日祝福)
- patientSYSTEMClient.socket.emit('message', {
- title:message.title,
- code:message.code,
- content: message.content,
- relation_code:message.relation_code,
- type: message.content_type,
- extend: message.extend
- });
- }
- if (message.content_type+""==CONTENT_TYPES.HealthIndexToPatientAssistance) {//体征设备上传
- patientSYSTEMClient.socket.emit('message', {
- title:message.title,
- code:message.code,
- content: message.content,//体征数据
- relation_code:message.relation_code,
- type: message.content_type,
- content_notice:message.content_notice,
- extend: message.extend
- });
- }
- if(message.content_type+""==CONTENT_TYPES.SystemMessagePushAssistance){
- patientSYSTEMClient.socket.emit('message',{
- title:message.title,
- type:message.type,
- content: message.content,
- content_tyep:message.content_type,
- audioUrl: message.audioUrl,
- extend: message.extend
- });
- }
- }
- ModelUtil.emitOK(self.eventEmitter, {status: 200});
- return;
- }
- static sendPcImSocket(targetId, message, sessionType) {
- if (message.content_type == CONTENT_TYPES.PlainText ||
- message.content_type == CONTENT_TYPES.Image ||
- message.content_type == CONTENT_TYPES.Audio||
- message.content_type == CONTENT_TYPES.Video||
- message.content_type == CONTENT_TYPES.GoTo||
- sessionType==SESSION_TYPES.SYSTEM) {
- let pcim_doctorClient = clientCache.findByIdAndType("pcim_"+targetId,SOCKET_TYPES.PCIM_DOCTOR);
- if(pcim_doctorClient) {
- let customData = {
- session_id: message.session_id||'',
- session_type: sessionType,
- from: message.sender_id|| '',
- data: message.content,
- business_type: message.business_type || 1
- };
- pcim_doctorClient.socket.emit('message', {
- session_id: message.session_id||'',
- session_type: sessionType,
- from: message.sender_id|| '',
- data: message.content,
- business_type: message.business_type || 1,
- 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
- });
- }
- }
- }
- /**
- * 发送socket给居民
- * @param patientId
- * @param message
- */
- static sendSocketMessageToPatient(patientId, message) {
- let patientClient = clientCache.findByIdAndType(patientId,SOCKET_TYPES.PATIENT);
- let pc_patientClient = clientCache.findByIdAndType("pcpatient_"+patientId,SOCKET_TYPES.PC_PATIENT);
- if(!patientClient&&!pc_patientClient){
- log.warn("target patient is not online!");
- return;
- }
- // let sendClient = clientCache.findByIdAndType(message.sender_id,SOCKET_TYPES.DOCTOR);//app医生发送的消息
- // if(!sendClient){//pc医生发送的消息
- // sendClient = clientCache.findByIdAndType("pc_"+message.sender_id,SOCKET_TYPES.PC_DOCTOR);
- // }
- // if(!sendClient){//居民发送的消息
- // sendClient = clientCache.findByIdAndType(message.sender_id,SOCKET_TYPES.PATIENT);
- // }
- var count = 0;
- if(patientClient&&message.session_id==patientClient.sessionId){
- WechatClient.updateParticipantLastFetchTime(patientClient.sessionId, patientId, ObjectUtil.timestampToLong(message.timestamp));
- patientClient.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,
- extend:message.extend
- });
- }else{
- count++;
- }
- //发送pc端
- if(pc_patientClient&&message.session_id==pc_patientClient.sessionId){
- WechatClient.updateParticipantLastFetchTime(pc_patientClient.sessionId, patientId, ObjectUtil.timestampToLong(message.timestamp));
- pc_patientClient.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,
- extend:message.extend
- });
- }else{
- count++;
- }
- if(count==2){
- log.warn("patient is not in the same session or is not online");
- }
- }
- //推送居民、居民PC、医生、医生PC外层推送
- static sendSystemSocketMessage(targetUserId, message) {
- //居民外层消息推送
- let patientClient = clientCache.findByIdAndType("patient_system_"+targetUserId,SOCKET_TYPES.PATIENT_SYSTEM);
- let pc_patientClient = clientCache.findByIdAndType("pcpatient_system_"+targetUserId,SOCKET_TYPES.PC_PATIENT_SYSTEM);
- if(!patientClient&&!pc_patientClient){
- log.warn("target patient systemt is not online!");
- // return;
- }
- var patientcount = 0;
- if(patientClient&&message.session_id==patientClient.sessionId){
- WechatClient.updateParticipantLastFetchTime(patientClient.sessionId, targetUserId, ObjectUtil.timestampToLong(message.timestamp));
- patientClient.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,
- extend:message.extend
- });
- }else{
- patientcount++;
- }
- //发送pc端
- if(pc_patientClient&&message.session_id==pc_patientClient.sessionId){
- WechatClient.updateParticipantLastFetchTime(pc_patientClient.sessionId, targetUserId, ObjectUtil.timestampToLong(message.timestamp));
- pc_patientClient.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,
- extend:message.extend
- });
- }else{
- patientcount++;
- }
- if(patientcount==2){
- log.warn("patient system is not in the same session or is not online");
- }
- //医生外层消息推送
- let doctorClient = clientCache.findByIdAndType("doctor_system_"+targetUserId,SOCKET_TYPES.DOCTOR_SYSTEM);
- let pc_doctorClient = clientCache.findByIdAndType("pc_system_"+targetUserId,SOCKET_TYPES.PC_DOCTOR_SYSTEM);
- if(!doctorClient&&!pc_doctorClient){
- log.warn("target doctor system is not online!");
- // return;
- }
- var doctorcount = 0;
- if(doctorClient&&message.session_id==doctorClient.sessionId){
- WechatClient.updateParticipantLastFetchTime(doctorClient.sessionId, targetUserId, ObjectUtil.timestampToLong(message.timestamp));
- doctorClient.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,
- extend:message.extend
- });
- }else{
- doctorcount++;
- }
- //发送pc端 - PC端消息不做sessionid的判断,前端自己判断消息归属于哪个会话,自行渲染--20191012-huangwenjie
- // if(pc_doctorClient&&message.session_id==pc_doctorClient.sessionId){
- if(pc_doctorClient){
- WechatClient.updateParticipantLastFetchTime(pc_doctorClient.sessionId, targetUserId, ObjectUtil.timestampToLong(message.timestamp));
- pc_doctorClient.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,
- extend:message.extend
- });
- }else{
- doctorcount++;
- }
- if(doctorcount==2){
- log.warn("doctor system is not in the same session or is not online");
- }
- }
- //推送托盘消息
- static sendMDTSystemSocketMessage(targetUserId, message) {
- //居民外层消息推送
- let mdtDcotorClient = clientCache.findByIdAndType("pcim_"+targetUserId,SOCKET_TYPES.PCIM_DOCTOR);
- if(!mdtDcotorClient){
- log.warn("target mdt doctor is not online!");
- }
- var mdtDoctorCount = 0;
- if(mdtDcotorClient&&message.session_id==mdtDcotorClient.sessionId){
- WechatClient.updateParticipantLastFetchTime(mdtDcotorClient.sessionId, targetUserId, ObjectUtil.timestampToLong(message.timestamp));
- mdtDcotorClient.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,
- extend:message.extend
- });
- }else{
- mdtDoctorCount++;
- }
- if(mdtDoctorCount==2){
- log.warn("doctor system is not in the same session or is not online");
- }
- }
- /**
- *
- * 发送微信模板消息给居民
- *
- * @param targetUserId
- * @param message
- */
- static sendViaMessageTemplate(targetUserId, targetUserName, message) {
- async.waterfall([
- // 获取微信openid
- function (callback) {
- PatientRepo.findWechatOpenIds(targetUserId, function (err, res) {
- if (err) {
- ModelUtil.logError("Get wechat openid failed", err);
- return;
- }
- var map = new Map();
- res.forEach(function (participant) {
- let openid = participant.openid;
- if (targetUserId==participant.code) {
- if (!openid) {
- ModelUtil.logError("User haven't bound with wechat, user id: " + targetUserId);
- }
- map.set("openid",participant);
- }else {
- if(!map.has(openid)){
- map.set(openid,participant);
- }
- }
- })
- //
- // let openid = result && result.length > 0 ? result[0].openid : null;
- // if (!openid) {
- // ModelUtil.logError("User haven't bound with wechat, user id: " + targetUserId);
- // return;
- // }
- //
- // log.warn("Send via wechat message template, user id: " + targetUserId + ", openid: " + openid);
- callback(null, map);
- });
- },
- // 获取议题信息
- function (map, callback) {
- TopicRepo.findLastTopicStatusAndType(message.session_id, function (err, res) {
- if (err) {
- ModelUtil.logError("Get topic failed", err);
- return;
- }
- if (!res || res.length == 0) {
- ModelUtil.logError("Unable to find session last topic");
- return;
- }
- callback(null, map, message.sender_name, res[0]);
- });
- },
- // 发送消息
- function (map, senderName, topic,callback) {
- let replyContent = message.content;
- switch (Number.parseInt(message.content_type)) {
- case CONTENT_TYPES.Image:
- replyContent = "[图片]";
- break;
- case CONTENT_TYPES.Audio:
- replyContent = "[语音]";
- break;
- default:
- break;
- }
- var patient = map.get("openid");
- map.delete("openid");
- let agent = topic.agent;
- let consultTitle = null;
- let description = null;
- let url = config.wechatConfig.baseUrl;
- switch (topic.type) {
- case 8:
- consultTitle = "续方";
- description = "续方咨询";
- url = url + "/wx/html/yszx/html/prescription-consulting.html";
- case 11:
- consultTitle = "上门服务";
- description = "上门服务咨询";
- url = url + "wx/html/appoint_service/html/appoint-serviceDetail.html";
- default:
- consultTitle = "健康";
- description = topic.description;
- url = url + "/wx/html/yszx/html/consulting-doctor.html";
- }
- if(agent){//代理人发起的议题
- var agentOpenid = "";
- if(map.size>0){
- for(var key of map.keys()){
- var member = map.get(key);
- if(agent == member.code){
- agentOpenid = key;
- var openid = key;
- var first = "您的家人("+patient.name+")的"+consultTitle+"咨询有新的回复";
- // 发送模板消息
- WechatSDK.sendTemplateMessage({
- touser: openid,
- name: member.name,
- patient: member.code,
- template_id: config.wechatConfig.template.consultTemplate,
- url: url + "?openid=" + openid + "&type="+topic.type+"&doctor="+message.sender_id+
- "&consult=" + topic.id + "&toUser=" + member.code + "&toName=" + member.name+"&represented="+patient.code,
- data: {
- first: {value: first, color: "#000000"}
- , remark: {value: "", color: "#000000"}
- , keyword1: {value: description, color: "#000000"}
- , keyword2: {value: replyContent, color: "#000000"}
- , keyword3: {value: senderName, color: "#000000"}
- }
- }, function (err, res) {
- err ? log.error(err) : log.info(res);
- });
- }
- }
- }
- if(patient.openid&&patient.openid!=agentOpenid){
- var first = "您的"+consultTitle+"咨询有新的回复";
- // 发送模板消息
- WechatSDK.sendTemplateMessage({
- touser: patient.openid,
- name: targetUserName,
- patient: targetUserId,
- template_id: config.wechatConfig.template.consultTemplate,
- url: url + "?openid=" + patient.openid +"&type="+topic.type+"&doctor="+message.sender_id+
- "&consult=" + topic.id + "&toUser=" + targetUserId + "&toName=" + targetUserName+"&represented="+patient.code,
- data: {
- first: {value: first, color: "#000000"}
- , remark: {value: "", color: "#000000"}
- , keyword1: {value: description, color: "#000000"}
- , keyword2: {value: replyContent, color: "#000000"}
- , keyword3: {value: senderName, color: "#000000"}
- }
- }, function (err, res) {
- err ? log.error(err) : log.info(res);
- });
- }
- }else {//自己发起的议题
- // 发送模板消息
- if(patient.openid){
- WechatSDK.sendTemplateMessage({
- touser: patient.openid,
- name: targetUserName,
- patient: targetUserId,
- template_id: config.wechatConfig.template.consultTemplate,
- url: url + "?openid=" + patient.openid +"&type="+topic.type+"&doctor="+message.sender_id+
- "&consult=" + topic.id + "&toUser=" + targetUserId + "&toName=" + targetUserName+"&represented="+patient.code,
- data: {
- first: {value: "您的"+consultTitle+"咨询有新的回复", color: "#000000"}
- , remark: {value: "", color: "#000000"}
- , keyword1: {value: description, color: "#000000"}
- , keyword2: {value: replyContent, color: "#000000"}
- , keyword3: {value: senderName, color: "#000000"}
- }
- }, function (err, res) {
- err ? log.error(err) : log.info(res);
- });
- }
- if(map.size>0){
- for(var key of map.keys()){
- if(!patient.openid||key!=patient.openid){
- var member = map.get(key);
- var openid = key;
- var first = "您的家人("+patient.name+")的"+consultTitle+"咨询有新的回复";
- // 发送模板消息
- WechatSDK.sendTemplateMessage({
- touser: openid,
- name: member.name,
- patient: member.code,
- template_id: config.wechatConfig.template.consultTemplate,
- url: url + "?openid=" + openid +"&type="+topic.type+"&doctor="+message.sender_id+
- "&consult=" + topic.id + "&toUser=" + member.code + "&toName=" + member.name+"&represented="+patient.code,
- data: {
- first: {value: first, color: "#000000"}
- , remark: {value: "", color: "#000000"}
- , keyword1: {value: description, color: "#000000"}
- , keyword2: {value: replyContent, color: "#000000"}
- , keyword3: {value: senderName, color: "#000000"}
- }
- }, function (err, res) {
- err ? log.error(err) : log.info(res);
- });
- }
- }
- }
- }
- callback(null, null);
- }
- ],
- function (err, res) {
- if (!err) {
- log.info("Send via wechat template message, DONE!");
- }
- });
- };
- static updateParticipantLastFetchTime(sessionId, userId, score) {
- score = score + 1000;
- let participantsKey = RedisModel.makeRedisKey(REDIS_KEYS.SessionParticipants, sessionId);
- redisConn.zaddAsync(participantsKey, score, userId)
- .then(function (res) {
- ParticipantRepo.updateLastFetchTime(new Date(score), sessionId, userId, function (err, res) {
- if (err) {
- log.error("Update participant last fetch time failed: ", err);
- }
- });
- })
- .catch(function (err) {
- log.error("Update participant last fetch time failed: ", err);
- });
- };
- /**
- * 发送第三方接口的微信模版消息
- * @param targetUserId
- * @param message
- */
- static sendThirdMessageTemplate(targetUserId, targetUserName, message) {
- async.waterfall([
- // 获取微信openid
- function (callback) {
- PatientRepo.findOne(targetUserId, function (err, res) {
- if (err) {
- ModelUtil.logError("Get wechat openid failed", err);
- return;
- }
- var map = new Map();
- res.forEach(function (participant) {
- let openid = participant.openid;
- let idcard = participant.idcard;
- let mobile = participant.mobile;
- let name = participant.name;
- let id = participant.id;
- map.set("openid",openid);
- map.set("idcard",idcard);
- map.set("mobile",mobile);
- map.set("name",name);
- map.set("id",id);
- })
- //
- // let openid = result && result.length > 0 ? result[0].openid : null;
- // if (!openid) {
- // ModelUtil.logError("User haven't bound with wechat, user id: " + targetUserId);
- // return;
- // }
- //
- // log.warn("Send via wechat message template, user id: " + targetUserId + ", openid: " + openid);
- callback(null, map);
- });
- },
- // 获取议题信息
- function (map, callback) {
- TopicRepo.findLastTopicStatusAndType(message.session_id, function (err, res) {
- if (err) {
- ModelUtil.logError("Get topic failed", err);
- return;
- }
- if (!res || res.length == 0) {
- ModelUtil.logError("Unable to find session last topic");
- return;
- }
- callback(null, map, message.sender_name, res[0]);
- });
- },
- // 发送消息
- function (map, senderName, topic,callback) {
- let replyContent = message.content;
- switch (Number.parseInt(message.content_type)) {
- case CONTENT_TYPES.Image:
- replyContent = "[图片]";
- break;
- case CONTENT_TYPES.Audio:
- replyContent = "[语音]";
- break;
- case CONTENT_TYPES.ConsultSuggest:
- var tmpContent = JSON.parse(message.content);
- var arr = [], consultAdvice = "";
- log.error("tmpContent1:"+tmpContent);
- tmpContent.forEach(function (v) {
- if(v.advice_type==1){
- arr.push(v.advice_value);
- } else {
- consultAdvice = v.advice_value;
- }
- });
- log.error("tmpContent2:"+arr);
- replyContent = "参考疾病:"+arr.join("、")+"\r\n"+"咨询建议:"+consultAdvice;
- log.error("replyContent:"+replyContent);
- break;
- default:
- break;
- }
- let consultTitle = null;
- let description = null;
- let url = null;
- switch (topic.type) {
- case 8:
- consultTitle = "续方";
- description = "续方咨询";
- url = url + "/wx/html/yszx/html/prescription-consulting.html";
- case 11:
- consultTitle = "上门服务";
- description = "上门服务咨询";
- url = url + "wx/html/appoint_service/html/appoint-serviceDetail.html";
- default:
- consultTitle = "咨询回复提醒";
- description = topic.description;
- if("xmijk" == config.imClientType.id){
- url = "https://zb.xmtyw.cn/ims-wx/index.html#/chatRoom?type=1&consultCode="+topic.id;
- }else if("zsyy" == config.imClientType.id){
- url = "https://hlwyy.xmzsh.com/ims-wx/index.html#/chatRoom?type=1&consultCode="+topic.id;
- }else if("xm_xzzx_wx" == config.imClientType.id){
- url = "https://ih.xmheart.com/hlwyy/ims-wx/index.html#/chatRoom?type=1&consultCode="+topic.id;
- }else if("sd_tnzyy_wx" == config.imClientType.id){
- url = "https://zyy.jkta.com.cn/ims-wx/index.html#/chatRoom?type=1&consultCode="+topic.id;
- }else if("hz_yyyzh_wx" == config.imClientType.id){
- url = "http://hzijk.cityihealth.com?type=1&consultCode="+topic.id;
- }else{
- }
- }
- log.info("内容类型"+message.content_type);
- log.info("内容"+message.content);
- //1、2、3、18、19、12、34
- // 发送模板消息
- if(map != null && (message.content_type==CONTENT_TYPES.PlainText||
- message.content_type==CONTENT_TYPES.Image||
- message.content_type==CONTENT_TYPES.Audio||
- message.content_type==CONTENT_TYPES.Video||
- message.content_type==CONTENT_TYPES.PersonalCard||
- message.content_type==CONTENT_TYPES.MessageForward||
- message.content_type==CONTENT_TYPES.PrescriptionSuggest||
- message.content_type==CONTENT_TYPES.ConsultSuggest||
- message.content_type==CONTENT_TYPES.Article||
- message.content_type==CONTENT_TYPES.surveyMessage||message.content_type==CONTENT_TYPES.EmergencyAssistanceMessage)){
- log.info("内容类型122:"+message.content_type);
- let userName = map.get("name");
- let idCard = map.get("idcard");
- let phone = map.get("mobile");
- let title = consultTitle;
- let content = "您的咨询有新的回复";
- let contentString = replyContent;
- let topidId = topic.id;
- let sessionId = message.session_id;
- // log.info("推送居民公众号:params:"+params)
- let params = 'senderName='+encodeURIComponent(senderName)+'&userName='+encodeURIComponent(userName)+'&idCard='+idCard
- +"&phone="+phone+'&title='+encodeURIComponent(consultTitle)+'&content='+encodeURIComponent(content)
- +'&contentString='+encodeURIComponent(contentString)+'&url='+encodeURIComponent(url)
- +'&topidId='+encodeURIComponent(topidId)+'&sessionId='+encodeURIComponent(sessionId);
- HlwyyWechatAssistantSDK.request(userName,idCard,phone,title,content,contentString,url,params, function (err, res) {
- // WlyyAssistantSDK.request('admin', '0a5c5258-8863-4b07-a3f9-88c768528ab4', '', 'admin_imei', '/doctor/feldsher/sendDoctorTemplate', param, function (err, res) {
- // WlyySDK.request('admin', '0a5c5258-8863-4b07-a3f9-88c768528ab4', '', 'admin_imei', '/doctor/feldsher/sendDoctorTemplate?' + params, 'GET', function (err, res) {
- if(err){
- log.error(err);
- }else {
- log.info(res);
- }
- });
- }
- callback(null, null);
- }
- ],
- function (err, res) {
- if (!err) {
- log.info("Send via wechat template message, DONE!");
- }
- });
- };
- }
- module.exports = WechatClient;
|