From 40588c6cd4efbb95612056ad492ee5b2dc624b09 Mon Sep 17 00:00:00 2001
From: xy <748613696@qq.com>
Date: Fri, 11 Jul 2025 13:27:40 +0800
Subject: [PATCH] =?UTF-8?q?APF=E6=A8=A1=E5=9D=97=E8=AF=A2=E9=97=AE?=
 =?UTF-8?q?=E9=80=BB=E8=BE=91=E8=B0=83=E6=95=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../njcn/csharmonic/service/impl/DataServiceImpl.java | 11 ++++++++++-
 1 file changed, 10 insertions(+), 1 deletion(-)

diff --git a/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/DataServiceImpl.java b/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/DataServiceImpl.java
index 0af297e..dfa7714 100644
--- a/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/DataServiceImpl.java
+++ b/cs-harmonic/cs-harmonic-boot/src/main/java/com/njcn/csharmonic/service/impl/DataServiceImpl.java
@@ -348,7 +348,16 @@ public class DataServiceImpl implements IDataService {
                     Double value = Double.parseDouble(redisUtilObjectByKey.toString());
                     moduleVO.setModuleState(channelState(value));
                 } else {
-                    moduleVO.setModuleState("离线");
+                    //再询问一次
+                    publisher.send("/Pfm/DevCmd/" + version + "/" + nDid, new Gson().toJson(dto), 1, false);
+                    Thread.sleep(800);
+                    Object redisUtilObjectByKey2 = redisUtil.getObjectByKey("ApfRtData:" + mid);
+                    if (ObjectUtil.isNotNull(redisUtilObjectByKey2)) {
+                        Double value = Double.parseDouble(redisUtilObjectByKey2.toString());
+                        moduleVO.setModuleState(channelState(value));
+                    } else {
+                        moduleVO.setModuleState("离线");
+                    }
                 }
                 mid = mid + 1;
                 if (mid > 10000) {