From 913c2ef2626a4f5bc750c201eca98daaf6e446b4 Mon Sep 17 00:00:00 2001
From: xy <748613696@qq.com>
Date: Tue, 15 Jul 2025 20:04:35 +0800
Subject: [PATCH] =?UTF-8?q?=E5=BE=AE=E8=B0=83?=
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, 11 insertions(+)

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 bea3828..7aaf32e 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
@@ -318,6 +318,17 @@ public class DataServiceImpl implements IDataService {
                     } else if (Objects.equals(last.getDataType(),1)) {
                         moduleVO.setModuleState(Objects.equals(last.getEventCode(),"Alm_Apf_ModDisConnect") ? "离线" : "运行");
                     }
+                    //如果模块掉线超过30分钟，则续上数据
+                    LocalDateTime givenTime = last.getTime();
+                    LocalDateTime currentTime = LocalDateTime.now();
+                    Duration duration = Duration.between(givenTime, currentTime);
+                    boolean isMoreThan30Minutes = duration.toMinutes() > 30;
+                    if (isMoreThan30Minutes) {
+                        EachModuleVO.HarmonicVo vo = new EachModuleVO.HarmonicVo();
+                        vo.setTime(LocalDateTime.now());
+                        vo.setStateDesc(last.getStateDesc());
+                        vo.setDataType(0);
+                    }
                 }
                 moduleVO.setModOutList(list2);
                 moduleVO.setLoadList(list3);