diff --git a/cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-common/src/main/java/com/muyu/enterprise/domain/FaultrRule.java b/cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-common/src/main/java/com/muyu/enterprise/domain/FaultRule.java
similarity index 96%
rename from cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-common/src/main/java/com/muyu/enterprise/domain/FaultrRule.java
rename to cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-common/src/main/java/com/muyu/enterprise/domain/FaultRule.java
index 8d0cb89..d7387d7 100644
--- a/cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-common/src/main/java/com/muyu/enterprise/domain/FaultrRule.java
+++ b/cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-common/src/main/java/com/muyu/enterprise/domain/FaultRule.java
@@ -21,7 +21,7 @@ import lombok.experimental.SuperBuilder;
 @TableName(value = "fault_rule",autoResultMap = true)
 @EqualsAndHashCode(callSuper = true)
 @Tag(name = "故障规则")
-public class FaultrRule extends BaseEntity {
+public class FaultRule extends BaseEntity {
     /**
      * 故障规则ID
      */
diff --git a/cloud-modules/cloud-modules-event-process/pom.xml b/cloud-modules/cloud-modules-event-process/pom.xml
index 14b3a3c..b9e8451 100644
--- a/cloud-modules/cloud-modules-event-process/pom.xml
+++ b/cloud-modules/cloud-modules-event-process/pom.xml
@@ -93,5 +93,11 @@
             <groupId>com.muyu</groupId>
             <artifactId>cloud-common-rabbit</artifactId>
         </dependency>
+
+        <!-- 企业缓存模块 -->
+        <dependency>
+            <groupId>com.muyu</groupId>
+            <artifactId>cloud-modules-enterprise-cache</artifactId>
+        </dependency>
     </dependencies>
 </project>
\ No newline at end of file
diff --git a/cloud-modules/cloud-modules-event-process/src/main/java/com/muyu/event/process/consumer/GoOfflineConsumer.java b/cloud-modules/cloud-modules-event-process/src/main/java/com/muyu/event/process/consumer/GoOfflineConsumer.java
index 7c66491..773b91e 100644
--- a/cloud-modules/cloud-modules-event-process/src/main/java/com/muyu/event/process/consumer/GoOfflineConsumer.java
+++ b/cloud-modules/cloud-modules-event-process/src/main/java/com/muyu/event/process/consumer/GoOfflineConsumer.java
@@ -7,6 +7,7 @@ import org.springframework.amqp.rabbit.annotation.Exchange;
 import org.springframework.amqp.rabbit.annotation.Queue;
 import org.springframework.amqp.rabbit.annotation.QueueBinding;
 import org.springframework.amqp.rabbit.annotation.RabbitListener;
+import org.springframework.stereotype.Component;
 
 /**
  * @Author: zi run
@@ -14,11 +15,12 @@ import org.springframework.amqp.rabbit.annotation.RabbitListener;
  * @Description 车辆下线消费者
  */
 @Slf4j
+@Component
 @RequiredArgsConstructor
 public class GoOfflineConsumer {
 
     /**
-     * 缓存工具
+     * 存储字符串类型数据缓存工具
      */
     private final CacheUtil<String> cacheUtil;
 
@@ -34,7 +36,7 @@ public class GoOfflineConsumer {
             )
     )
     public void offline(String vin) {
-        log.info("清除缓存，车辆vin: {}", vin);
+        log.info("车辆vin码：{}，该车辆已下线", vin);
         cacheUtil.remove(vin);
     }
 }
diff --git a/cloud-modules/cloud-modules-event-process/src/main/java/com/muyu/event/process/consumer/VehicleConsumer.java b/cloud-modules/cloud-modules-event-process/src/main/java/com/muyu/event/process/consumer/VehicleConsumer.java
index 89eaf89..070a118 100644
--- a/cloud-modules/cloud-modules-event-process/src/main/java/com/muyu/event/process/consumer/VehicleConsumer.java
+++ b/cloud-modules/cloud-modules-event-process/src/main/java/com/muyu/event/process/consumer/VehicleConsumer.java
@@ -2,7 +2,7 @@ package com.muyu.event.process.consumer;
 
 import com.muyu.common.core.constant.KafkaConstants;
 import com.muyu.event.process.basic.EventPublisher;
-import com.muyu.event.process.event.IoTDBInsertDataEvent;
+import com.muyu.event.process.event.DataProcessEvent;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.kafka.clients.consumer.ConsumerRecord;
@@ -73,7 +73,7 @@ public class VehicleConsumer implements ApplicationRunner, ApplicationListener<C
         String message = consumerRecord.value();
         log.info("接收到车辆报文数据，内容：{}", message);
         log.info("------------------------------------------------");
-        eventPublisher.publish(new IoTDBInsertDataEvent(this, message));
+        eventPublisher.publish(new DataProcessEvent(this, message));
     }
 
     /**
diff --git a/cloud-modules/cloud-modules-event-process/src/main/java/com/muyu/event/process/listener/IoTDBInsertDataListener.java b/cloud-modules/cloud-modules-event-process/src/main/java/com/muyu/event/process/listener/IoTDBInsertDataEventListener.java
similarity index 85%
rename from cloud-modules/cloud-modules-event-process/src/main/java/com/muyu/event/process/listener/IoTDBInsertDataListener.java
rename to cloud-modules/cloud-modules-event-process/src/main/java/com/muyu/event/process/listener/IoTDBInsertDataEventListener.java
index 3e9a2a7..3bab49e 100644
--- a/cloud-modules/cloud-modules-event-process/src/main/java/com/muyu/event/process/listener/IoTDBInsertDataListener.java
+++ b/cloud-modules/cloud-modules-event-process/src/main/java/com/muyu/event/process/listener/IoTDBInsertDataEventListener.java
@@ -5,6 +5,10 @@ import com.muyu.event.process.basic.BasicEvent;
 import com.muyu.event.process.basic.BasicEventListener;
 import com.muyu.event.process.iotdb.service.IoTDBService;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.context.annotation.Primary;
 import org.springframework.stereotype.Component;
 
 import java.util.List;
@@ -15,9 +19,10 @@ import java.util.stream.Collectors;
  * @Date 2024/9/29 22:12
  * @Description 向IoTDB插入数据事件监听器
  */
+@Slf4j
 @Component
 @RequiredArgsConstructor
-public class IoTDBInsertDataListener implements BasicEventListener<String> {
+public class IoTDBInsertDataEventListener implements BasicEventListener<String> {
 
     /**
      * IoTDB业务层
@@ -36,6 +41,7 @@ public class IoTDBInsertDataListener implements BasicEventListener<String> {
      */
     @Override
     public void onEvent(BasicEvent<String> event) {
+        log.info("触发向IoTDB插入数据事件监听器……");
         JSONObject data = JSONObject.parseObject(event.getData());
         List<String> keyList = extractKeys(data);
         List<String> valueList = extractValues(data);