From 317653fed5f46488f7901a55c056492a6ae9b44c Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E7=8E=8B=E5=85=B4=E7=90=B3?= <1911390090@qq.com>
Date: Tue, 8 Apr 2025 10:48:45 +0800
Subject: [PATCH] =?UTF-8?q?kafka=E6=8E=A8=E9=80=81=20=E6=AF=AB=E7=B1=B3?=
 =?UTF-8?q?=E6=B3=A2=E9=9B=B7=E8=BE=BE=20=20=E6=8A=A4=E6=A0=8F=E7=A2=B0?=
 =?UTF-8?q?=E6=92=9E?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/com/zc/business/enums/KafkEnum.java |  4 ++++
 .../message/device/handler/DeviceMessageHandler.java  | 11 +++++++++++
 2 files changed, 15 insertions(+)

diff --git a/zc-business/src/main/java/com/zc/business/enums/KafkEnum.java b/zc-business/src/main/java/com/zc/business/enums/KafkEnum.java
index 90d6f9be..7198ba4e 100644
--- a/zc-business/src/main/java/com/zc/business/enums/KafkEnum.java
+++ b/zc-business/src/main/java/com/zc/business/enums/KafkEnum.java
@@ -12,6 +12,10 @@ public enum KafkEnum {
     deviceStatus("deviceState"),
     // 视频AI
     videoAI("eventAi"),
+  //毫米波雷达
+  millimeterWaveRadar("millimeterWaveRadar"),
+  //护栏
+  guardrailCollision("guardrailCollision"),
     //交通
     surveyStation("surveyStation");
     private final String value;
diff --git a/zc-business/src/main/java/com/zc/business/message/device/handler/DeviceMessageHandler.java b/zc-business/src/main/java/com/zc/business/message/device/handler/DeviceMessageHandler.java
index 5a47c9c6..65279717 100644
--- a/zc-business/src/main/java/com/zc/business/message/device/handler/DeviceMessageHandler.java
+++ b/zc-business/src/main/java/com/zc/business/message/device/handler/DeviceMessageHandler.java
@@ -230,6 +230,12 @@ public class DeviceMessageHandler {
             dcWarning.setRemark(formattedDate + UniversalEnum.BLANK_SPACE.getValue() + stakeMark + UniversalEnum.BLANK_SPACE.getValue() + directio + UniversalEnum.BLANK_SPACE.getValue() + UniversalEnum.TAKE_PLACE.getValue() + eventName + UniversalEnum.INCIDENT.getValue());
             dcWarning.setOtherConfig(event.toJSONString());
             dcWarningService.insertDcWarning(dcWarning);
+
+            //kafka消息推送 毫米波雷达
+            Gson gson = new Gson();
+            String jsonString = gson.toJson(dcWarning);
+            kafkaTopicProducer.KafkaTopicProducer(jsonString, KafkEnum.millimeterWaveRadar.value());
+
         } else if (Objects.equals(eventTopic, UniversalEnum.TIME_RANGE.getValue())) {
             //    交通统计
 
@@ -595,6 +601,11 @@ public class DeviceMessageHandler {
             dcWarning.setWarningTitle("护栏碰撞在20" + timeOfFireAlarming + direction + UniversalEnum.TAKE_PLACE.getValue() + eventType + UniversalEnum.INCIDENT.getValue());
             dcWarning.setOtherConfig(dataJsonObject.toJSONString());
             dcWarningService.insertDcWarning(dcWarning);
+            //kafka消息推送 护栏碰撞
+            Gson gson = new Gson();
+            String jsonString = gson.toJson(dcWarning);
+            kafkaTopicProducer.KafkaTopicProducer(jsonString, KafkEnum.guardrailCollision.value());
+
         }
     }