diff --git a/dragon-car-common/src/main/java/com/dragon/car/domain/req/FaultRecordReq.java b/dragon-car-common/src/main/java/com/dragon/car/domain/req/FaultRecordReq.java
new file mode 100644
index 0000000..14518e1
--- /dev/null
+++ b/dragon-car-common/src/main/java/com/dragon/car/domain/req/FaultRecordReq.java
@@ -0,0 +1,21 @@
+package com.dragon.car.domain.req;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ * @author 冯凯
+ * @version 1.0
+ * @description:
+ * @date 2023/12/7 9:37
+ */
+@Data
+@Builder
+@AllArgsConstructor
+@NoArgsConstructor
+public class FaultRecordReq {
+
+    private String faultCode;
+}
diff --git a/dragon-car-service/src/main/java/com/dragon/car/service/mapper/FaultMapper.java b/dragon-car-service/src/main/java/com/dragon/car/service/mapper/FaultMapper.java
index fdb8902..1cf4a98 100644
--- a/dragon-car-service/src/main/java/com/dragon/car/service/mapper/FaultMapper.java
+++ b/dragon-car-service/src/main/java/com/dragon/car/service/mapper/FaultMapper.java
@@ -5,8 +5,6 @@ import com.dragon.car.domain.FaultCode;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
 
-import java.util.Date;
-
 /**
  * @author zhn
  * 故障映射
@@ -14,5 +12,5 @@ import java.util.Date;
 @Mapper
 public interface FaultMapper extends BaseMapper<FaultCode> {
 
-    void insertFaultRecord(@Param("vin") String vin, @Param("faultCode") String faultCode, @Param("startTime") Date startTime);
+    void insertFaultRecord(@Param("vin") String vin, @Param("faultCode") String faultCode, @Param("startTime") String startTime);
 }
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 c3fca96..de34895 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
@@ -11,6 +11,9 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 
 import java.io.IOException;
+import java.text.ParseException;
+import java.text.SimpleDateFormat;
+import java.util.Date;
 import java.util.HashMap;
 
 /**
@@ -25,9 +28,13 @@ public class ListenFaultCode {
 
     @Autowired
     private FaultService faultService;
+
     @RabbitListener(queuesToDeclare = {@Queue(value = "fault_Dqueue")})
     public void consumerSubscribe(String mesg, Message message, Channel channel) {
         HashMap hashMap = JSONObject.parseObject(mesg, HashMap.class);
+        String string = (String) hashMap.get("startTime");
+        faultService.insertFaultRecord(hashMap);
+
         log.info("收到消息【{}】", hashMap);
         try {
             faultService.insertFaultRecord(hashMap);
@@ -36,4 +43,6 @@ public class ListenFaultCode {
             throw new RuntimeException(e);
         }
     }
+
+
 }
diff --git a/dragon-car-service/src/main/java/com/dragon/car/service/service/impl/FaultServiceImpl.java b/dragon-car-service/src/main/java/com/dragon/car/service/service/impl/FaultServiceImpl.java
index 6a5036e..3cc9643 100644
--- a/dragon-car-service/src/main/java/com/dragon/car/service/service/impl/FaultServiceImpl.java
+++ b/dragon-car-service/src/main/java/com/dragon/car/service/service/impl/FaultServiceImpl.java
@@ -125,13 +125,6 @@ public class FaultServiceImpl implements FaultService {
 		} catch (ParseException e) {
 			throw new RuntimeException(e);
 		}
-	faultMapper.insertFaultRecord(map.get("vin"),map.get("faultCode"),startTime);
-	}
-
-	public static void main(String[] args) throws ParseException {
-		String time="2021-09-23 10:00:00";
-		SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
-		Date parse = format.parse(time);
-		System.out.println(parse);
+	faultMapper.insertFaultRecord(map.get("vin"),map.get("faultCode"),s);
 	}
 }