|
@ -142,12 +142,25 @@ class Sessions extends RedisModel {
|
|
|
redis.zrangebyscoreAsync(message_time_key, restimestamp, (new Date().getTime())).then(function (messagetimelist) {
|
|
|
res.sessionId = session;
|
|
|
res.message = messagetimelist.length;
|
|
|
callback(res, j, _len);
|
|
|
callrole(res, j, _len,session);
|
|
|
}).catch(function (err) {
|
|
|
throw err;
|
|
|
})
|
|
|
}
|
|
|
|
|
|
/**
|
|
|
* 用户角色
|
|
|
* @param res要返回的JSON
|
|
|
* @param j 第N调数据
|
|
|
* @param _len 总数据长度
|
|
|
*/
|
|
|
function callrole(res, j, _len,session){
|
|
|
let participants_role_key = _super(RedisKeys.ParticipantsRole, session);
|
|
|
redis.hgetAsync(participants_role_key, userId).then(function(role){
|
|
|
res.role=role;
|
|
|
callback(res, j, _len);
|
|
|
})
|
|
|
}
|
|
|
/**
|
|
|
* 列表封装完毕后由此回调返回数据界面
|
|
|
* @param res
|