|
|
@ -152,10 +152,12 @@ class Users extends RedisModel {
|
|
|
}
|
|
|
|
|
|
sessions.forEach(function (session) {
|
|
|
console.error("out:"+session.id);
|
|
|
redisConn.zscore(REDIS_KEYS.Sessions, session.id, function (err, res) {
|
|
|
console.error("int:"+session.id+" res:"+res);
|
|
|
if (res != null) return; // 已经缓存过的会话不再缓存
|
|
|
|
|
|
(function (sessionId, userId) {
|
|
|
console.error("int_two:"+sessionId);
|
|
|
let business_type = session.business_type;
|
|
|
if (!session.business_type && session.type == SESSION_TYPE.MUC) {
|
|
|
business_type = 2
|
|
|
@ -168,11 +170,11 @@ class Users extends RedisModel {
|
|
|
"name", session.name,
|
|
|
"type", session.type,
|
|
|
"business_type", business_type,
|
|
|
"last_sender_id", session.last_sender_id == null ? "" : session.last_sender_id,
|
|
|
"last_sender_name", session.last_sender_name == null ? "" : session.last_sender_name,
|
|
|
"last_content_type", session.last_content_type == null ? "" : session.last_content_type,
|
|
|
"last_content", session.last_content == null ? "" : session.last_content,
|
|
|
"last_message_time", session.last_message_time == null ? "" : session.last_message_time,
|
|
|
"last_sender_id", session.last_sender_id||"",
|
|
|
"last_sender_name", session.last_sender_name||"",
|
|
|
"last_content_type", session.last_content_type||"",
|
|
|
"last_content", session.last_content||"",
|
|
|
"last_message_time", session.last_message_time||"",
|
|
|
"create_date", ObjectUtil.timestampToLong(session.create_date),
|
|
|
"status",session.status==null?0:session.status
|
|
|
];
|
|
|
@ -197,7 +199,7 @@ class Users extends RedisModel {
|
|
|
participants.forEach(function (participant) {
|
|
|
let participantId = participant.id;
|
|
|
let participantRole = participant.role;
|
|
|
let score = ObjectUtil.timestampToLong(participant.last_fetch_time);
|
|
|
let score = ObjectUtil.timestampToLong(participant.last_fetch_time||(new Date()));
|
|
|
|
|
|
multi = multi.zadd(sessionParticipantsKey, score, participantId)
|
|
|
.hset(sessionParticipantsRoleKey, participantId, participantRole);
|
