From 691f0d4c4836c75fefa1d3b7fba4a72153751dd4 Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期三, 09 七月 2025 13:38:37 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/asrs/task/RealtimeBasMapScheduler.java | 16 +++++++---------
1 files changed, 7 insertions(+), 9 deletions(-)
diff --git a/src/main/java/com/zy/asrs/task/RealtimeBasMapScheduler.java b/src/main/java/com/zy/asrs/task/RealtimeBasMapScheduler.java
index 0f99bc2..55e0d3e 100644
--- a/src/main/java/com/zy/asrs/task/RealtimeBasMapScheduler.java
+++ b/src/main/java/com/zy/asrs/task/RealtimeBasMapScheduler.java
@@ -1,15 +1,18 @@
package com.zy.asrs.task;
import com.alibaba.fastjson.JSON;
+import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.zy.asrs.entity.BasMap;
import com.zy.asrs.service.BasMapService;
import com.zy.common.utils.RedisUtil;
+import com.zy.core.enums.RedisKeyType;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.util.Date;
+import java.util.List;
@Component
@Slf4j
@@ -25,23 +28,18 @@
*/
@Scheduled(cron = "1 * * * * ? ")
private void execute(){
- for (int i = 1; i <= 4; i++) {//鎬诲叡鍥涘眰妤�
- Object data = redisUtil.get("realtimeBasMap_" + i);
+ List<BasMap> basMaps = basMapService.selectList(new EntityWrapper<BasMap>().orderBy("lev", true));
+ for (BasMap basMap : basMaps) {
+ Integer lev = basMap.getLev();
+ Object data = redisUtil.get(RedisKeyType.MAP.key + lev);
if (data == null) {
continue;
}
BasMap redisMap = JSON.parseObject(data.toString(), BasMap.class);
-
- BasMap basMap = basMapService.selectLatestMap(i);
- if (basMap == null) {
- continue;
- }
-
basMap.setLastData(basMap.getData());
basMap.setData(redisMap.getData());
basMap.setUpdateTime(new Date());
-
basMapService.updateById(basMap);//鏇存柊
}
}
--
Gitblit v1.9.1