错误代码修正，修改引用信息

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

@@ -65,7 +65,7 @@ router.put(APIv2.Sessions.Topics, function (req, res) {
    topic.updateTopic(topicId,jsonValue);
});
router.get(APIv2.Sessions.TopicEnded, function (req, res) {
router.post(APIv2.Sessions.TopicEnded, function (req, res) {
    let data = req.body;
    let endUser = data.end_user;
    let endUserName = data.end_user_name;

src/server/models/sessions/participants.js

@@ -159,7 +159,9 @@ class Participants extends RedisModel {
    updateUser(sessionId, user, role) {
        let participants_role_key = RedisModel.makeRedisKey(REDIS_KEYS.SessionParticipantsRole, sessionId);
        redis.hsetAsync(sessionId, user, role).then(function (res) {
            ParticipantRepo.updateParticipant(sessionId, user, role);
            ParticipantRepo.updateParticipant(sessionId, user, role,function(err,res){
            });
        })
    }

src/server/models/sessions/sessions.js

@@ -502,7 +502,7 @@ class Sessions extends RedisModel {
        message.message_id = messageId;
        let sessionType = 0;
        let name = "";
        participants.existsParticipant(sessionId, message.senderId, function (err, res) {
        participants.existsParticipant(sessionId, message.sender_id, function (err, res) {
            //校验发送成员是都在讨论组
            if (res) {
                redis.hmgetAsync(session_key, ["type", "name"]).then(function (res) {
@@ -514,7 +514,7 @@ class Sessions extends RedisModel {
                    }
                }).then(function (res) {
                    //更新消息相关
                    return messages.saveMessageForRedis(messageId, sessionId, message);
                    return messages.saveMessageToRedis(sessionId,sessionType,messageId, message);
                }).then(function (res) {
                    //更新session的最后一条聊天记录
                    return Messages.updateLastContent(session_key, sessionType, name, message);

src/server/models/sessions/topics.js

@@ -59,7 +59,7 @@ class Topics extends RedisModel {
     * @param topicName 发起议题的名称
     * @param topicId
     * @param users 发起议题的患者{"userId1:role", "userId2:role"}
     * @param messages 发送的消息对象{description:"",title:"",img:"",patient:"",patientName:""}图片多个用逗号隔开
     * @param messages 发送的消息对象{description:"",title:"",img:"",senderId:"",senderName:""}图片多个用逗号隔开
     */
    createTopics(topicName, topicId,sessionId,users, messages) {
        let self = this;
@@ -86,7 +86,7 @@ class Topics extends RedisModel {
                        for(var j in users){
                            pars.push(j+":"+users[j]);
                        }
                        sessions.createSession(sessionId, messages.patientName, SESSION_TYPES.MUC, pars, function (res) {
                        sessions.createSession(sessionId, messages.senderName, SESSION_TYPES.MUC, pars, function (res) {
                            if (res) {
                                callbegin();
                            }
@@ -101,8 +101,8 @@ class Topics extends RedisModel {
         */
        function callbegin() {
            let msg = {};
            msg.sender_id = messages.patient;
            msg.sender_name = messages.patientName;
            msg.sender_id = messages.senderId;
            msg.sender_name = messages.senderName;
            msg.content_type = 6;
            msg.content = "开始咨询"
            msg.timestamp = date;

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

@@ -71,7 +71,9 @@ class MessageRepo {
        ImDb.execQuery({
            "sql": sql,
            "args": [messageId, sessionId, message.sender_id, message.sender_name, message.content_type, message.content, message.timestamp],
            "handler": handler
            "handler": handler||function(err,res){
                log.info(res);
            }
        });
    }
}

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

@@ -34,7 +34,7 @@ class ParticipantRepo {
     * @param sessionId
     * @param handler
     */
    static updateParticipant(sessionId, participant_id, role) {
    static updateParticipant(sessionId, participant_id, role,handler) {
        let sql = "update participants set participant_role = ? where session_id = ? and participant_id = ?";
        ImDb.execQuery({
            "sql": sql,