From 1a415e549be00c7794a804509d78fe26f49251ff Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=B0=B7=E6=88=90=E4=BC=9F?= <guchengwei@jsspisoft.com>
Date: Tue, 31 Dec 2024 10:55:14 +0800
Subject: [PATCH] =?UTF-8?q?=E9=93=BE=E8=B7=AF=E5=BF=83=E8=B7=B3=E6=96=B0?=
 =?UTF-8?q?=E5=A2=9Ereal=E5=92=8Cftp=E7=8A=B6=E6=80=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../node/service/impl/SysNodeServiceImpl.java    | 16 ++++++++--------
 1 file changed, 8 insertions(+), 8 deletions(-)

diff --git a/das/src/main/java/com/das/modules/node/service/impl/SysNodeServiceImpl.java b/das/src/main/java/com/das/modules/node/service/impl/SysNodeServiceImpl.java
index a600af96..21a25e32 100644
--- a/das/src/main/java/com/das/modules/node/service/impl/SysNodeServiceImpl.java
+++ b/das/src/main/java/com/das/modules/node/service/impl/SysNodeServiceImpl.java
@@ -82,7 +82,7 @@ public class SysNodeServiceImpl implements SysNodeService {
     SysIotModelServiceMapper iotModelServiceMapper;
 
     @Autowired
-    RedisTemplate<String,Integer> redisTemplate;
+    RedisTemplate<String,Object> redisTemplate;
 
     @Override
     public List<SysNodeVo> querySysNodeList() {
@@ -145,7 +145,7 @@ public class SysNodeServiceImpl implements SysNodeService {
      */
     @Override
     public PageDataInfo<SysCommunicationLinkVo> querySysCommunicationLinkList(SysCommunicationLinkDto sysCommunicationLinkDto) {
-        ValueOperations<String,Integer> ops = redisTemplate.opsForValue();
+        ValueOperations<String,Object> ops = redisTemplate.opsForValue();
         // 初始化分页查询对象
         PageQuery pageQuery = new PageQuery();
         pageQuery.setPageNum(sysCommunicationLinkDto.getPageNum());
@@ -172,16 +172,16 @@ public class SysNodeServiceImpl implements SysNodeService {
             }
 
             // 批量获取在线状态值
-            List<Integer> onlinesStatus = ops.multiGet(onlines);
-            List<Integer> ftpsStatus = ops.multiGet(ftps);
-            List<Integer> realsStatus = ops.multiGet(reals);
+            List<Object> onlinesStatus = ops.multiGet(onlines);
+            List<Object> ftpsStatus = ops.multiGet(ftps);
+            List<Object> realsStatus = ops.multiGet(reals);
 
             // 遍历在线状态值，更新通信链路的在线状态
             for (int i = 0; i < records.size(); i++) {
                 SysCommunicationLinkVo sysCommunicationLinkVo = records.get(i);
-                Integer ostatus = onlinesStatus.get(i);
-                Integer fstatus = ftpsStatus.get(i);
-                Integer rstatus = realsStatus.get(i);
+                Integer ostatus = (Integer) onlinesStatus.get(i);
+                Integer fstatus = (Integer) ftpsStatus.get(i);
+                Integer rstatus = (Integer) realsStatus.get(i);
                 if (ostatus == null) {
                     ostatus = 0;
                 }