|
@ -515,7 +515,7 @@ class Sessions extends RedisModel {
|
|
}
|
|
}
|
|
}).then(function (res) {
|
|
}).then(function (res) {
|
|
//更新消息相关
|
|
//更新消息相关
|
|
return messages.saveMessageToRedis(sessionId,sessionType,messageId, message);
|
|
|
|
|
|
return messages.saveMessageToRedis(sessionId, sessionType, messageId, message);
|
|
}).then(function (res) {
|
|
}).then(function (res) {
|
|
//更新session的最后一条聊天记录
|
|
//更新session的最后一条聊天记录
|
|
return Messages.updateLastContent(session_key, sessionType, name, message);
|
|
return Messages.updateLastContent(session_key, sessionType, name, message);
|
|
@ -587,6 +587,23 @@ class Sessions extends RedisModel {
|
|
});
|
|
});
|
|
})
|
|
})
|
|
}
|
|
}
|
|
|
|
|
|
|
|
/**
|
|
|
|
* 更新会话参与者的最后消息获取时间。
|
|
|
|
*
|
|
|
|
* @param sessionId
|
|
|
|
* @param userId
|
|
|
|
*/
|
|
|
|
static updateParticipantLastFetchTime(sessionId, userId) {
|
|
|
|
let participantsKey = RedisModel.makeRedisKey(REDIS_KEYS.SessionParticipants, sessionId);
|
|
|
|
redis.zaddAsync(participantsKey, new Date().getTime(), userId)
|
|
|
|
.then(function (res) {
|
|
|
|
console.log(res);
|
|
|
|
})
|
|
|
|
.catch(function (res) {
|
|
|
|
throw res;
|
|
|
|
});
|
|
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
// Expose class
|
|
// Expose class
|