|
@ -566,7 +566,7 @@ class Sessions extends RedisModel {
|
|
|
* @param endMsgId 必选。会话中的结束消息ID
|
|
|
* @param page 必选。页码
|
|
|
* @param size 必选。页面大小
|
|
|
* @param handler 必选。回调
|
|
|
* @param handler 必选。回调 如果是根据结束消息获取是否有新消息返回时正序的数据
|
|
|
*/
|
|
|
getMessagesByPage(sessionId, userId, startMsgId, endMsgId, page, size, isoffset, handler) {
|
|
|
let messagesTimestampKey = RedisModel.makeRedisKey(REDIS_KEYS.MessagesByTimestamp, sessionId);
|
|
@ -597,7 +597,6 @@ class Sessions extends RedisModel {
|
|
|
return;
|
|
|
}
|
|
|
if(endMsgScore>startMsgScore){
|
|
|
console.error("endMsgScore>startMsgScore");
|
|
|
redis.zrangebyscoreAsync(messagesTimestampKey, startMsgScore, endMsgScore, "limit", offset, count)
|
|
|
.then(function (res) {
|
|
|
if (res.length == 0) {
|
|
@ -617,7 +616,6 @@ class Sessions extends RedisModel {
|
|
|
handler(err, false);
|
|
|
})
|
|
|
}else{
|
|
|
console.error(3);
|
|
|
// 从消息时间表中过滤出要获取的消息ID列表,倒序取出消息
|
|
|
redis.zrevrangebyscoreAsync(messagesTimestampKey, startMsgScore, endMsgScore, "limit", offset, count)
|
|
|
.then(function (res) {
|
|
@ -634,7 +632,6 @@ class Sessions extends RedisModel {
|
|
|
})
|
|
|
.catch(function (err) {
|
|
|
logger.error("Get message by page failed: ", err);
|
|
|
|
|
|
handler(err, false);
|
|
|
})
|
|
|
}
|