发起和结束咨询的消息由系统发出，发送者ID记录操作人！

src/server/models/sessions/participants.js

@@ -101,12 +101,13 @@ class Participants extends RedisModel {
        participantsArray.forEach(function (item) {
            let tokens = item.split(":");
            userSessions[RedisModel.makeRedisKey(REDIS_KEYS.UserSessions, tokens[0])] = [createDate.getTime(), sessionId];
            sessionParticipants.push(createDate.getTime());
            sessionParticipants.push(tokens[0]);
            sessionParticipantsRoles.push(tokens[0], tokens[1]);
            if(tokens[1]!=2){
                userSessions[RedisModel.makeRedisKey(REDIS_KEYS.UserSessions, tokens[0])] = [createDate.getTime(), sessionId];
                sessionParticipants.push(createDate.getTime());
                sessionParticipants.push(tokens[0]);
                sessionParticipantsRoles.push(tokens[0], tokens[1]);
            }
        });
        // 向会话成员、会话成员角色集合中添加数据
        let sessionParticipantsKey = RedisModel.makeRedisKey(REDIS_KEYS.SessionParticipants, sessionId);
        let sessionParticipantsRoleKey = RedisModel.makeRedisKey(REDIS_KEYS.SessionParticipantsRole, sessionId);

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

@@ -211,13 +211,12 @@ class ParticipantRepo {
        let sql = "INSERT INTO " + DB_TABLES.Participants + " (session_id,participant_id,participant_role) VALUES ";
        let args = [];
        for (let j in users) {
            sql += "(?,?,?)";
            let tokens = users[j].split(":");
            if(tokens.length > 1&&tokens[1]==2)continue;
            sql += "(?,?,?)";
            args.push(sessionId);
            args.push(tokens[0]);
            args.push(tokens.length > 1 ? tokens[1] : '0');
            if (j != users.length - 1) sql += ", ";
        }