中山医院MDT修改

src/server/endpoints/v2/doctor.endpoint.js

@@ -0,0 +1,57 @@
/**
 * 独立的发送消息接口
 */
"use strict";
let express = require('express');
let router = express.Router();
let ModelUtil = require('../../util/model.util');
let ObjectUtil = require('../../util/object.util');
let ControllerUtil = require('../../util/controller.util');
let APIv2 = require('../../include/endpoints').APIv2;
let MODEL_EVENTS = require('../../include/commons').MODEL_EVENTS;
let Doctors = require('../../models/doctor/doctors');
let log = require('../../util/log.js');
let uuid = require('uuid')
/**
 * 新增医生
 * 参数：participants:{mobile:'',name:'',sex:'',birthdate:'',avatar:'',hospital_name:'',level:'',idcard:''}
 */
router.post(APIv2.Doctor.AddDoctor, function (req, res) {
    let payload = req.body;
    let testing = ObjectUtil.fieldsCheck(payload, "participants");
    log.info("aaaa:" + payload.participants);
    if (!testing.pass) {
        throw {httpStatus: 406, message: testing.message}
    }
   
    
    let doctors = new Doctors();
    ControllerUtil.regModelEventHandler(doctors, res);
    let participants = JSON.parse(payload.participants);
    let isAllOK = true;
    for (let j in participants) {
        log.info("aaaa:"+j + ":" + participants[j]);
        let participant = participants[j];
        // participant.id = participant.mobile;//用手机号码作为id
        participant.id = uuid.v1();//生成随机UUID
        participant.avatar = '../../../images/d-male.png';
        
        doctors.addDoctor(participant,function (err, result) {
            if(result.status==0){
                isAllOK = false;
            }
        });
    }
    let self = this;
    if(isAllOK){
        res.status(200).json({status: 200, data: {status:1,msg:"保存成功"}});    
    }
    else{
        res.status(200).json({status: 200, data: {status:0,msg:"部分成员添加失败"}});    
    }
    
});
module.exports = router;

src/server/endpoints/v2/session.endpoint.js

@@ -53,15 +53,27 @@ router.post("/", function (req, res) {
    let participantArray = [];
    log.info("participants: "+participants);
    participants = JSON.parse(participants);
    /**
     *MDT 医生数据转换，根据手机号查询医生CODE
     */
    if (payload.hasOwnProperty('videoconferencing') && payload.videoconferencing == 1){
        participants = sessions.conversionAarticipant(participants);
    }
    for (let j in participants) {
        log.info("aaaa:"+j + ":" + participants[j]);
        participantArray.push(j + ":" + participants[j]);
    }
    ControllerUtil.regModelEventHandler(sessions, res);
    console.log(sessionId, sessionName, sessionType, participantArray)
    console.log(sessionId, sessionName, sessionType, participantArray);
    sessions.createSession(sessionId, sessionName, sessionType, participantArray);
    ///是否视频会议的会话
    let videoconferencing = false;

src/server/include/commons.js

@@ -95,6 +95,7 @@ const CONTENT_TYPES = {
    PrescriptionBloodStatus:16,//续方咨询血糖血压咨询消息
    PrescriptionFollowupContent:17,//续方咨询随访问卷消息
    Rehabilitation: 20, //康复计划发送
    VideoAnswerStatus: 29, //视屏请求
    ReservationDoorCardInfo: 2101,//上门服务-预约工单卡片信息
    ChangeDoorCardInfo: 2102,//上门服务-修改工单卡片信息
    ChangeDoorDoctor: 2103,//上门服务-变更工单医生信息

src/server/include/endpoints.js

@@ -74,6 +74,11 @@ const APIv2 = {
    },
    Demo:{
        Base:'/api/v2/demo'
    },
    Doctor: {//szx add ，针对中山医院视频通信
        Base: '/api/v2/doctor',
        AddDoctor: '/addDoctor'                                                  //新增医生
    }
};

src/server/models/client/wechat.client.js

@@ -66,7 +66,9 @@ class WechatClient extends RedisModel {
            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.ChangeDoorPackageItems ||
            message.content_type == CONTENT_TYPES.VideoAnswerStatus
            )) {
            let patientClient = clientCache.findById(targetUserId);
            let pc_patientClient = clientCache.findById("pcpatient_"+targetUserId);
            let doctorClient = clientCache.findByIdAndType(message.sender_id,SOCKET_TYPES.DOCTOR);
@@ -382,6 +384,64 @@ class WechatClient extends RedisModel {
        }
    }
    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,
            });
        }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,
            });
        }else{
            count++;
        }
        if(count==2){
            log.warn("patient is not in the same session or is not online");
        }
    }
    /**
     *
     * 发送微信模板消息给居民

src/server/models/doctor/doctors.js

@@ -0,0 +1,111 @@
/**
 * 医生相关操作。
 *
 * author: shenzaixin
 * since: 12/27/2018
 */
"use strict";
let BaseModel = require('../base.model');
let ImDb = require('../../repository/mysql/db/im.db');
let ParticipantRepo = require('../../repository/mysql/participant.repo');
let DoctorRepo = require('../../repository/mysql/doctor.repo');
let SessionRepo = require('../../repository/mysql/session.repo');
let ModelUtil = require('../../util/model.util');
let ObjectUtil = require("../../util/object.util.js");
let async = require('async');
let log = require('../../util/log');
let configFile = require('../../include/commons').CONFIG_FILE;
let config = require('../../resources/config/' + configFile);
const PLATFORMS = require('../../include/commons').PLATFORM;
class Dortors extends BaseModel {
    constructor() {
        super();
    }
    /**
     * 新增医生信息
     *
     * @param participant
     * @param outCallback
     */
    addDoctor(participant, outCallback) {
        let self = this;
        async.waterfall([
            // 检查是否已存在
            function (callback) {
                let repoProto = DoctorRepo;
                let mobile = participant.mobile;
                repoProto.findByMobile(mobile, function (err, oDoctor) {
                    callback(null, oDoctor);
                });
            },
            // 保存医生信息
            function (oDoctor) {
                let repoProto = DoctorRepo;
                if(oDoctor.length>0){
                    outCallback(null, {status:0,msg:"医生已存在"});
                }
                let id = participant.id;
                let name = participant.name;
                let sex = participant.sex;
                let birthdate = participant.birthdate;
                let avatar = participant.avatar;
                let hospital_name = participant.hospital_name;
                let level = participant.level;
                let idcard = participant.idcard;
                let mobile = participant.mobile;
                repoProto.addDoctor(id,name,mobile,sex,birthdate,avatar,hospital_name,level,idcard, function (err, res) {                        
                    outCallback(null, {status:1,msg:"保存成功"});
                });
            }
        ]);
    }
    /**
     * 用户ID是否属于患者。
     *
     * @param userId
     * @param callback
     */
    static isPatientId(userId, callback) {
        async.waterfall([
                function (callback) {
                    ImDb.execQuery({
                        "sql": "select case when count(*) > 0 then true else false end 'is_patient' from patients where id = ?",
                        "args": [userId],
                        "handler": function (err, res) {
                            if (err) {
                                callback(err, res);
                                return;
                            }
                            callback(null, res);
                        }
                    });
                },
                function (res, callback) {
                    if (res.length === 0) return false;
                    callback(null, res[0].is_patient);
                }
            ],
            function (err, res) {
                if (err) {
                    log.error("User id check failed: ", err);
                    callback(null, false);
                    return;
                }
                callback(null, res !== 0);
            });
    }
}
let Promises = require('bluebird');
Promises.promisifyAll(Dortors.prototype);
module.exports = Dortors;

src/server/models/messages/messages.js

@@ -188,6 +188,9 @@ class Messages extends RedisModel {
                //外网pcim通过socket推送
                WechatClient.sendPcImSocket(targetUserId,message,sessionType);
                //告知居民新消息
                WechatClient.sendSocketMessageToPatient(targetUserId,message,sessionType);
                //redis发布消息
                if(config.pubSubSwitch) {//接收订阅消息处理开关，本地运行和测试库单独运行时防止用户接收消息2次
                    pubSub.publish(config.pubChannel,JSON.stringify(message));

src/server/models/sessions/sessions.js

@@ -8,6 +8,7 @@ let RedisModel = require('./../redis.model.js');
let ModelUtil = require('../../util/model.util');
let Messages = require('../messages/messages');
let Users = require('../user/users');
let DoctorRepo = require('../../repository/mysql/doctor.repo');
let Participants = require('./participants');
let SessionRepo = require('../../repository/mysql/session.repo');
let TopicRepo = require('../../repository/mysql/topics.repo');
@@ -87,6 +88,23 @@ class Sessions extends RedisModel {
        });
    }
    /**
     *MDT 医生数据转换，根据手机号查询医生CODE
     */
    conversionAarticipant(participants) {
        let doctorProto = DoctorRepo;
        for (let j in participants) {
            doctorProto.findByMobile(participants[j][0], function (err, oDoctor) {
                if(oDoctor.length>0){
                    participants[j][0] = oDoctor.id;
                }
            });
        }
        return participants;
    }
    /**
     * 创建会话。REDIS
     * @param sessionId
@@ -436,15 +454,13 @@ class Sessions extends RedisModel {
                        if (!callback) {
                            callback = index, index = 0
                        }
                        log.info("top=.index:" + index);
                        let sessionId = sessionIds[index];
                        log.info("top=.session.id:" + sessionId);
                        let sessionKey = RedisModel.makeRedisKey(REDIS_KEYS.Session, sessionId);
                        log.info("top=.sessionKey:" + sessionKey);
                        log.info("sessionKey:" + sessionKey);
                        let participantsRoleKey = RedisModel.makeRedisKey(REDIS_KEYS.SessionParticipantsRole, sessionId);
                        log.info("top=.participantsRoleKey:" + participantsRoleKey);
                        let sessionParticipantsKey = RedisModel.makeRedisKey(REDIS_KEYS.SessionParticipants, sessionId);
                        log.info("top=.sessionParticipantsKey:" + sessionParticipantsKey);
                        redis.multi()
                            .hgetall(sessionKey)                       // 会话实体
                            .hget(participantsRoleKey, userId)         // 用户在此会话中的角色
@@ -664,7 +680,8 @@ class Sessions extends RedisModel {
                                                type: session.type,
                                                sender_name: session.last_sender_name||"",
                                                unread_count: count,
                                                business_type: session.business_type,
                                                // business_type: session.business_type,
                                                business_type: businessType,
                                                my_role: role,
                                                sender_sex: sex,
                                                sender_birthday: bir,
@@ -2028,6 +2045,7 @@ class Sessions extends RedisModel {
    }
}
// Expose class

src/server/repository/mysql/doctor.repo.js

@@ -19,6 +19,22 @@ class DoctorRepo {
            "handler": handler
        });
    };
    static findByMobile(mobile, handler) {
        ImDb.execQuery({
            "sql": "select id, name, sex, birthdate, photo from doctors where mobile = ? ",
            "args": [mobile],
            "handler": handler
        });
    };
    static addDoctor(id,name,mobile,sex,birthdate,avatar,hospital_name,level,idcard, handler) {
        ImDb.execQuery({
            "sql": "insert into base.base_doctor (id,name,mobile,sex,birthdate,photo,idcard,del) values (?,?,?,?,?,?,?,1)",
            "args": [id,name,mobile,sex,birthdate,avatar,idcard],
            "handler": handler
        });
    };
}
module.exports = DoctorRepo;