kafka推送事件（AI）数据

zc-business/src/main/java/com/zc/business/message/device/handler/DeviceMessageHandler.java

@@ -8,6 +8,8 @@ import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.google.gson.Gson;
 import com.ruoyi.common.core.redis.RedisCache;
+import com.ruoyi.common.utils.SecurityUtils;
+import com.ruoyi.common.utils.spring.SpringUtils;
 import com.zc.business.constant.RedisKeyConstants;
 import com.zc.business.domain.DcDevice;
 import com.zc.business.domain.DcMeteorologicalDetectorData;
@@ -18,6 +20,7 @@ import com.zc.business.message.device.subscribe.KafkaTopicProducer;
 import com.zc.business.service.*;
 import com.zc.common.core.websocket.WebSocketService;
 import com.zc.common.core.websocket.constant.WebSocketEvent;
+import org.apache.catalina.security.SecurityUtil;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -64,8 +67,7 @@ public class DeviceMessageHandler {
 
     @Autowired
     private IDcMeteorologicalDetectorDataService meteorologicalDetectorDataService;
-    @Resource
-    private KafkaTopicProducer kafkaTopicProducer;
+
 
 
     /**
@@ -359,6 +361,7 @@ public class DeviceMessageHandler {
         combinedData.put("address", otherConfig);*/
             dcWarning.setOtherConfig(otherConfig.toString());
             //异常天气等级 过滤
+            KafkaTopicProducer kafkaTopicProducer = SpringUtils.getBean(KafkaTopicProducer.class);
             if (data.getInteger("warningType") == VISIBILITY_LEVEL) {
                 int WarningLevel = data.getInteger("visibilityLevel");
                 if (WarningLevel != UniversalEnum.ZERO.getNumber()) {