From 1bb9ad1cf7af60e52af7ce368a37740f856b2271 Mon Sep 17 00:00:00 2001
From: xy <748613696@qq.com>
Date: Wed, 16 Jul 2025 15:11:48 +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/zlevent/service/impl/CsAlarmServiceImpl.java  | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/iot-analysis/analysis-zl-event/zl-event-boot/src/main/java/com/njcn/zlevent/service/impl/CsAlarmServiceImpl.java b/iot-analysis/analysis-zl-event/zl-event-boot/src/main/java/com/njcn/zlevent/service/impl/CsAlarmServiceImpl.java
index 9b5fc4b..cea4607 100644
--- a/iot-analysis/analysis-zl-event/zl-event-boot/src/main/java/com/njcn/zlevent/service/impl/CsAlarmServiceImpl.java
+++ b/iot-analysis/analysis-zl-event/zl-event-boot/src/main/java/com/njcn/zlevent/service/impl/CsAlarmServiceImpl.java
@@ -98,6 +98,16 @@ public class CsAlarmServiceImpl extends ServiceImpl<CsEventMapper, CsEventPO> im
                         throw new BusinessException(DATA_ERROR);
                     }
                 }
+                //判断是否有重复数据
+                CsEventPO po2 = this.lambdaQuery().eq(CsEventPO::getLineId,lineId)
+                        .eq(CsEventPO::getStartTime,eventTime)
+                        .eq(CsEventPO::getClDid,appEventMessage.getMsg().getClDid())
+                        .eq(CsEventPO::getProcess,po.getProcess())
+                        .eq(CsEventPO::getTag,tag).one();
+                if (po2 != null) {
+                    throw new BusinessException(DATA_ERROR);
+                }
+
                 //事件入库
                 CsEventPO csEvent = new CsEventPO();
                 csEvent.setLineId(lineId);