|
@ -579,7 +579,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);
|
|
@ -620,8 +620,8 @@ class Sessions extends RedisModel {
|
|
|
handler(null, []);
|
|
|
return;
|
|
|
}
|
|
|
|
|
|
redis.hmgetAsync(messagesKey, res).then(function (messages) {
|
|
|
messages.reverse();
|
|
|
handler(null, messages);
|
|
|
}).then(function () {
|
|
|
Sessions.updateParticipantLastFetchTime(sessionId, userId, new Date().getTime());
|