|
|
@ -382,7 +382,7 @@ class Sessions extends RedisModel {
|
|
|
|
|
|
// 计算未读消息数
|
|
|
let messagesByTimestampKey = RedisModel.makeRedisKey(REDIS_KEYS.MessagesByTimestamp, sessionId);
|
|
|
redis.zcountAsync(messagesByTimestampKey, lastFetchTime, new Date().getTime())
|
|
|
redis.zcountAsync(messagesByTimestampKey, lastFetchTime+1, new Date().getTime())
|
|
|
.then(function (count) {
|
|
|
if (!otherUserId) otherUserId = userId;
|
|
|
ParticipantRepo.findNameById(otherUserId, function (err, res) {
|
|
|
@ -513,7 +513,7 @@ class Sessions extends RedisModel {
|
|
|
|
|
|
// 计算未读消息数
|
|
|
let messagesByTimestampKey = RedisModel.makeRedisKey(REDIS_KEYS.MessagesByTimestamp, sessionId);
|
|
|
redis.zcountAsync(messagesByTimestampKey, lastFetchTime, new Date().getTime())
|
|
|
redis.zcountAsync(messagesByTimestampKey, lastFetchTime+1, new Date().getTime())
|
|
|
.then(function (count) {
|
|
|
if (!otherUserId) otherUserId = userId;
|
|
|
ParticipantRepo.findNameById(otherUserId, function (err, res) {
|
