From 5c7de80d32707e2d1b1c56222700a6a309cc3e3f 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:23:38 +0800
Subject: [PATCH] =?UTF-8?q?kafka=E6=8E=A8=E9=80=81=20=E4=BA=A4=E8=B0=83?=
 =?UTF-8?q?=E6=95=B0=E6=8D=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

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

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 49481bce..90d6f9be 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
@@ -11,7 +11,9 @@ public enum KafkEnum {
     //设备状态
     deviceStatus("deviceState"),
     // 视频AI
-    videoAI("eventAi");
+    videoAI("eventAi"),
+    //交通
+    surveyStation("surveyStation");
     private final String value;
 
     KafkEnum(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 d23e9c69..5a47c9c6 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
@@ -509,6 +509,9 @@ public class DeviceMessageHandler {
      * @param msg 设备消息
      */
     private void oneStopDeviceMessageHandle(JSONObject msg) {
+        //kafka消息推送
+        kafkaTopicProducer.KafkaTopicProducer(msg.toJSONString(), KafkEnum.surveyStation.value());
+
         dcTrafficSectionDataService.processRealtimeOneStopMessage(msg);
     }