|
@ -900,15 +900,13 @@ class Sessions extends RedisModel {
|
|
if (handler) return handler(new Error("Unknown session key " + session_key));
|
|
if (handler) return handler(new Error("Unknown session key " + session_key));
|
|
}
|
|
}
|
|
}).then(function (res) {
|
|
}).then(function (res) {
|
|
// 更新消息存储REDIS
|
|
|
|
|
|
// 消息数据双写,并更新用户最后消息获取时间,会话新状态等
|
|
messages.saveMessageToRedis(sessionId, sessionType, messageId, message);
|
|
messages.saveMessageToRedis(sessionId, sessionType, messageId, message);
|
|
//更新消息存储到mysql
|
|
|
|
messages.saveMessageToMysql(sessionId, sessionType, messageId, message);
|
|
messages.saveMessageToMysql(sessionId, sessionType, messageId, message);
|
|
|
|
|
|
// 更新会话最新状态及成员最后一次消息获取时间
|
|
// 更新会话最新状态及成员最后一次消息获取时间
|
|
Sessions.updateParticipantLastFetchTime(sessionId, message.sender_id, message.timestamp.getTime());
|
|
Sessions.updateParticipantLastFetchTime(sessionId, message.sender_id, message.timestamp.getTime());
|
|
//更新最后一条消息
|
|
|
|
Messages.updateLastContent(session_key, sessionType, sessionName, message);
|
|
Messages.updateLastContent(session_key, sessionType, sessionName, message);
|
|
//更新session实体的最后一条消息
|
|
|
|
SessionRepo.updateSessionLastStatus(message.sender_id, message.sender_name, message.timestamp, message.content, message.content_type, sessionId);
|
|
SessionRepo.updateSessionLastStatus(message.sender_id, message.sender_name, message.timestamp, message.content, message.content_type, sessionId);
|
|
|
|
|
|
if (handler) handler(null, messageId);
|
|
if (handler) handler(null, messageId);
|