From 366d97e8d267bb25351dab87794dc4cd8f94d06c Mon Sep 17 00:00:00 2001
From: lijiayao <13831655+xiao-yao-charge-forward@user.noreply.gitee.com>
Date: Mon, 8 Apr 2024 10:02:19 +0800
Subject: [PATCH] =?UTF-8?q?feat:=20=E7=94=B5=E5=AD=90=E5=9B=B4=E6=A0=8F?=
 =?UTF-8?q?=E6=8A=A5=E8=AD=A6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../analyze/msg/model/ModelsKafkaMessage.java | 21 +++++++++----------
 1 file changed, 10 insertions(+), 11 deletions(-)

diff --git a/couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/model/ModelsKafkaMessage.java b/couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/model/ModelsKafkaMessage.java
index defe82b..c9bb4b5 100644
--- a/couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/model/ModelsKafkaMessage.java
+++ b/couplet-modules/couplet-analyze/couplet-analyze-msg/src/main/java/com/couplet/analyze/msg/model/ModelsKafkaMessage.java
@@ -9,7 +9,6 @@ import lombok.extern.slf4j.Slf4j;
 import org.apache.kafka.clients.consumer.ConsumerConfig;
 import org.apache.kafka.clients.consumer.ConsumerRecords;
 import org.apache.kafka.clients.consumer.KafkaConsumer;
-import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
@@ -43,8 +42,8 @@ public class ModelsKafkaMessage {
             add("stored-event");
         }
     };
-    @Autowired
-    private RabbitTemplate rabbitTemplate;
+//    @Autowired
+//    private RabbitTemplate rabbitTemplate;
 
     /**
      * 消费者配置
@@ -75,15 +74,15 @@ public class ModelsKafkaMessage {
                     List<CoupletMsgData> coupletMsgDataList = sendMsg(str);
                     for (CoupletMsgData msgData : coupletMsgDataList) {
                         log.info("解析到车辆数据：{}", msgData);
-//                        for (String string : strings) {
-//                            IncidentService incidentService = SpringUtils.getBean(string);
-//                            incidentService.incident(msgData);
-//                        }
+                        for (String string : strings) {
+                            IncidentService incidentService = SpringUtils.getBean(string);
+                            incidentService.incident(msgData);
+                        }
                         //发送消息
-                        rabbitTemplate.convertAndSend("couplet-code-queue",msgData,message -> {
-                            message.getMessageProperties().setMessageId(UUID.randomUUID().toString());
-                            return message;
-                        });
+//                        rabbitTemplate.convertAndSend("couplet-code-queue",msgData,message -> {
+//                            message.getMessageProperties().setMessageId(UUID.randomUUID().toString());
+//                            return message;
+//                        });
 
                         try {
                             sleep(100);