浏览代码

成员替换,创建会话,人员先删除后写入

8 年之前
父节点
当前提交
371b308f0f
共有 2 个文件被更改,包括 3 次插入4 次删除
  1. 2 3
      src/server/models/sessions/sessions.js
  2. 1 1
      src/server/repository/mysql/session.repo.js

+ 2 - 3
src/server/models/sessions/sessions.js

@ -202,7 +202,7 @@ class Sessions extends RedisModel {
            //查找该sessionId是否存在存在则直接返回实例
            SessionRepo.findOne(sessionId, function (err, res) {
                if (res.length > 0) {//已经存在
                        //更新成员
                     //更新成员
                    Participants.saveParticipantsToMysql(sessionId, participantArray, function (err, update) {
                        handler(null, res[0]);
                        return;
@ -591,7 +591,7 @@ class Sessions extends RedisModel {
                        let startMsgScore = res[1];
                        let endMsgScore = res[0];
                        if (startMsgScore == null || endMsgScore == null || startMsgScore == endMsgScore) {
                        if (startMsgScore == null || endMsgScore == null || (startMsgScore == endMsgScore&&isoffset==1)) {
                            handler(null, []);
                            return;
                        }
@ -644,7 +644,6 @@ class Sessions extends RedisModel {
                    if (j == res.length - 1) {
                        ModelUtil.emitOK(self.eventEmitter, {count: count});
                    }
                    continue;
                }
                callback(res, j, res[j]);

+ 1 - 1
src/server/repository/mysql/session.repo.js

@ -36,7 +36,7 @@ class SessionRepo {
     * @param handler
     */
    static findAll(userId, handler) {
        let sql = "select session_id from " + DB_TABLES.Participants + " w where w.participant_id = ? group by w.session_id";
        let sql = "select session_id from " + DB_TABLES.Participants + " w where w.participant_id = ? and participant_role =0  group by w.session_id";
        let sessionSQL = "select id, name, type, create_date, last_sender_id, last_sender_name, last_content_type, last_content, last_message_time from "
            + DB_TABLES.Sessions + " s where s.id in(" + sql + ")";
        ImDb.execQuery({