kafka推送 毫米波雷达 护栏碰撞

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;

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