|
@ -258,8 +258,8 @@ class Participants extends RedisModel {
|
|
ModelUtil.emitOK(self.eventEmitter, {status:200,message: "用户未创建咨询!"});
|
|
ModelUtil.emitOK(self.eventEmitter, {status:200,message: "用户未创建咨询!"});
|
|
return;
|
|
return;
|
|
}else{
|
|
}else{
|
|
|
|
let session = res[0];
|
|
if(oldUserId){
|
|
if(oldUserId){
|
|
let session = res[0];
|
|
|
|
redis.hgetAsync(participantsRoleKey,oldUserId).then(function(role){
|
|
redis.hgetAsync(participantsRoleKey,oldUserId).then(function(role){
|
|
if(!role)role = 0;
|
|
if(!role)role = 0;
|
|
self.addUser(session.id,userId,role,function(err,addResult){
|
|
self.addUser(session.id,userId,role,function(err,addResult){
|
|
@ -280,8 +280,11 @@ class Participants extends RedisModel {
|
|
})
|
|
})
|
|
}else{
|
|
}else{
|
|
self.addUser(session.id,userId,"0",function(err,addResult){
|
|
self.addUser(session.id,userId,"0",function(err,addResult){
|
|
if(err){
|
|
|
|
ModelUtil.emitOK(self.eventEmitter, {status:-1,message: "会话成员添加失败!"});
|
|
|
|
|
|
if(!err){
|
|
|
|
ModelUtil.emitOK(self.eventEmitter, {status:200,message: "成员变更成功!"});
|
|
|
|
return;
|
|
|
|
}else{
|
|
|
|
ModelUtil.emitOK(self.eventEmitter, {status:-1,message: "成员变更失败!"});
|
|
return;
|
|
return;
|
|
}
|
|
}
|
|
});
|
|
});
|