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