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();
 }