|
|
@ -165,6 +165,7 @@ class Participants extends RedisModel {
|
|
|
let participants_key = RedisModel.makeRedisKey(REDIS_KEYS.SessionParticipants, sessionId);
|
|
|
let user_session_key = RedisModel.makeRedisKey(REDIS_KEYS.UserSessions, userId);
|
|
|
let participants_role_key = RedisModel.makeRedisKey(REDIS_KEYS.SessionParticipantsRole, sessionId);
|
|
|
log.info("removeUser------------ ");
|
|
|
// 移除会话中的成员信息,用户的Session信息及MySQL中的记录
|
|
|
redis.multi()
|
|
|
.zrem(participants_key, userId)
|
|
|
@ -176,6 +177,7 @@ class Participants extends RedisModel {
|
|
|
if(handler){
|
|
|
handler(null,true);return;
|
|
|
}
|
|
|
log.info("成员删除成功！ ");
|
|
|
ModelUtil.emitOK(self.eventEmitter, {status:200,message:"成员删除成功！"});
|
|
|
})
|
|
|
.catch(function (err) {
|
|
|
@ -269,7 +271,7 @@ class Participants extends RedisModel {
|
|
|
if(oldUserId){
|
|
|
redis.hgetAsync(participantsRoleKey,oldUserId).then(function(role){
|
|
|
if(!role)role = 0;
|
|
|
self.deleteUserFromMysql(session.id,userId,function(err,addResult){
|
|
|
self.addUser(session.id,userId,role,function(err,addResult){
|
|
|
if(err){
|
|
|
ModelUtil.emitOK(self.eventEmitter, {status:-1,message: "会话成员添加失败！"});
|
|
|
return;
|
shenzaixin