|
@@ -41,7 +41,7 @@ public class RedisTask {
|
|
*/
|
|
*/
|
|
@Scheduled(cron = "0 0 1 * * ?")
|
|
@Scheduled(cron = "0 0 1 * * ?")
|
|
public void synRedisChatToDB() {
|
|
public void synRedisChatToDB() {
|
|
- log.info("执行保存未读消息操作!");
|
|
|
|
|
|
+ log.info("将redis中的聊天缓存,持久到数据库中");
|
|
Set<String> keys = redis.keys("ALLCHATS:*");
|
|
Set<String> keys = redis.keys("ALLCHATS:*");
|
|
for (String key : keys) {
|
|
for (String key : keys) {
|
|
List<ChatMsgEntity> chatList = new ArrayList<>();
|
|
List<ChatMsgEntity> chatList = new ArrayList<>();
|
|
@@ -54,6 +54,7 @@ public class RedisTask {
|
|
entity.setToUser(imMessage.getReceiver());
|
|
entity.setToUser(imMessage.getReceiver());
|
|
entity.setType(imMessage.getType());
|
|
entity.setType(imMessage.getType());
|
|
entity.setSessionid(imMessage.getSessionid());
|
|
entity.setSessionid(imMessage.getSessionid());
|
|
|
|
+ entity.setDura(imMessage.getDura());
|
|
entity.setStatuz(1);
|
|
entity.setStatuz(1);
|
|
entity.setCreateBy(imMessage.getName());
|
|
entity.setCreateBy(imMessage.getName());
|
|
entity.setCreateTime(new Date(imMessage.getTime()).toInstant().atOffset(ZoneOffset.of("+8")).toLocalDateTime());
|
|
entity.setCreateTime(new Date(imMessage.getTime()).toInstant().atOffset(ZoneOffset.of("+8")).toLocalDateTime());
|