From fb32c2021a5dcd22638da94d5af2d0190a7080cc Mon Sep 17 00:00:00 2001
From: hzj <826100833@qq.com>
Date: Mon, 20 Jul 2026 10:24:12 +0800
Subject: [PATCH] =?UTF-8?q?=E5=8C=97=E4=BA=AC=E6=89=8B=E5=8A=A8=E5=8F=91?=
 =?UTF-8?q?=E9=80=81=E7=9F=AD=E4=BF=A1=E9=9C=80=E6=B1=82?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../dataTransmit/DataSynchronization.java     | 10 +++++++
 .../event/transientes/job/CleanEventJob.java  | 28 +++++++++++++++++++
 .../service/CleanEventService.java            |  2 +-
 3 files changed, 39 insertions(+), 1 deletion(-)
 create mode 100644 event_smart/src/main/java/com/njcn/product/event/transientes/job/CleanEventJob.java

diff --git a/event_smart/src/main/java/com/njcn/product/event/dataTransmit/DataSynchronization.java b/event_smart/src/main/java/com/njcn/product/event/dataTransmit/DataSynchronization.java
index cad1e43..320857a 100644
--- a/event_smart/src/main/java/com/njcn/product/event/dataTransmit/DataSynchronization.java
+++ b/event_smart/src/main/java/com/njcn/product/event/dataTransmit/DataSynchronization.java
@@ -281,6 +281,9 @@ public class DataSynchronization {
             Map<Integer, PqLinedetail> lineDetailMap = pqLinedetails.stream().collect(Collectors.toMap(PqLinedetail::getLineIndex, Function.identity()));
 
             eventIds.forEach(temp->{
+                if(!pqsEventdetailMap.containsKey(temp)){
+                    return;
+                }
                 PqsEventdetail pqsEventdetail = pqsEventdetailMap.get(temp);
 
                 if(pqsEventDetailStatusPOMap.containsKey(temp)){
@@ -542,6 +545,13 @@ public class DataSynchronization {
 
     public static void main(String[] args) {
         double a =3.00;
+        List<String> collect = Stream.of("1", "2", "3").collect(Collectors.toList());
+        collect.forEach(temp->{
+            if(temp.equals("1")){
+                return;
+            }
+            System.out.println(temp);
+        });
         System.out.println(a/1000);
     }
 
diff --git a/event_smart/src/main/java/com/njcn/product/event/transientes/job/CleanEventJob.java b/event_smart/src/main/java/com/njcn/product/event/transientes/job/CleanEventJob.java
new file mode 100644
index 0000000..977f3a4
--- /dev/null
+++ b/event_smart/src/main/java/com/njcn/product/event/transientes/job/CleanEventJob.java
@@ -0,0 +1,28 @@
+package com.njcn.product.event.transientes.job;
+
+import com.njcn.product.event.transientes.service.CleanEventService;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.scheduling.annotation.EnableScheduling;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+/**
+ * Description:
+ * Date: 2026/07/01  上午 10:41【需求】:定时清理电压暂降98%-90%范围内的暂态事件及文件默认为1个月
+ *
+ * @author clam
+ * @version V1.0.0
+ */
+@Component
+@EnableScheduling
+@RequiredArgsConstructor
+@Slf4j
+public class CleanEventJob {
+    private final CleanEventService cleanEventService;
+    @Scheduled(cron = "0 0 2 * * ?")
+    public void cleanup() {
+        cleanEventService.cleanup();
+    }
+}
diff --git a/event_smart/src/main/java/com/njcn/product/event/transientes/service/CleanEventService.java b/event_smart/src/main/java/com/njcn/product/event/transientes/service/CleanEventService.java
index 5e50107..5454f36 100644
--- a/event_smart/src/main/java/com/njcn/product/event/transientes/service/CleanEventService.java
+++ b/event_smart/src/main/java/com/njcn/product/event/transientes/service/CleanEventService.java
@@ -8,5 +8,5 @@ package com.njcn.product.event.transientes.service;
  * @version V1.0.0
  */
 public interface CleanEventService {
-     void cleanup();
+    void cleanup();
 }