From 4a5d2a57460768587bc21ccc7e255a2827e441b6 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=86=AF=E5=87=AF?= <371894675@qq.com>
Date: Thu, 7 Dec 2023 08:55:55 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E4=B8=9A=E5=8A=A11?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/dragon/car/service/rabbit/ListenFaultCode.java    | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/dragon-car-service/src/main/java/com/dragon/car/service/rabbit/ListenFaultCode.java b/dragon-car-service/src/main/java/com/dragon/car/service/rabbit/ListenFaultCode.java
index 246a11e..c3fca96 100644
--- a/dragon-car-service/src/main/java/com/dragon/car/service/rabbit/ListenFaultCode.java
+++ b/dragon-car-service/src/main/java/com/dragon/car/service/rabbit/ListenFaultCode.java
@@ -1,11 +1,13 @@
 package com.dragon.car.service.rabbit;
 
 import com.alibaba.fastjson.JSONObject;
+import com.dragon.car.service.service.FaultService;
 import com.rabbitmq.client.Channel;
 import lombok.extern.log4j.Log4j2;
 import org.springframework.amqp.core.Message;
 import org.springframework.amqp.rabbit.annotation.Queue;
 import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
 import java.io.IOException;
@@ -21,10 +23,14 @@ import java.util.HashMap;
 @Log4j2
 public class ListenFaultCode {
 
+    @Autowired
+    private FaultService faultService;
     @RabbitListener(queuesToDeclare = {@Queue(value = "fault_Dqueue")})
     public void consumerSubscribe(String mesg, Message message, Channel channel) {
-        log.info("收到消息【{}】", JSONObject.parseObject(mesg, HashMap.class));
+        HashMap hashMap = JSONObject.parseObject(mesg, HashMap.class);
+        log.info("收到消息【{}】", hashMap);
         try {
+            faultService.insertFaultRecord(hashMap);
             channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
         } catch (IOException e) {
             throw new RuntimeException(e);