From ca8bd65148e9b2770f110b2f8bb7c8ded4a20145 Mon Sep 17 00:00:00 2001 From: xinzirun Date: Mon, 7 Oct 2024 09:01:57 +0800 Subject: [PATCH] =?UTF-8?q?fix():=20=E4=BC=98=E5=8C=96=E6=97=B6=E9=97=B4?= =?UTF-8?q?=E5=A4=84=E7=90=86=E6=B5=81=E7=A8=8B=EF=BC=8C=E4=BF=AE=E5=A4=8D?= =?UTF-8?q?bug?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../enterprise/domain/{FaultrRule.java => FaultRule.java} | 2 +- cloud-modules/cloud-modules-event-process/pom.xml | 6 ++++++ .../muyu/event/process/consumer/GoOfflineConsumer.java | 6 ++++-- .../com/muyu/event/process/consumer/VehicleConsumer.java | 4 ++-- ...ataListener.java => IoTDBInsertDataEventListener.java} | 8 +++++++- 5 files changed, 20 insertions(+), 6 deletions(-) rename cloud-modules/cloud-modules-enterprise/cloud-modules-enterprise-common/src/main/java/com/muyu/enterprise/domain/{FaultrRule.java => FaultRule.java} (96%) rename cloud-modules/cloud-modules-event-process/src/main/java/com/muyu/event/process/listener/{IoTDBInsertDataListener.java => IoTDBInsertDataEventListener.java} (85%) 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 @@ com.muyu cloud-common-rabbit + + + + com.muyu + cloud-modules-enterprise-cache + \ 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 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 { +public class IoTDBInsertDataEventListener implements BasicEventListener { /** * IoTDB业务层 @@ -36,6 +41,7 @@ public class IoTDBInsertDataListener implements BasicEventListener { */ @Override public void onEvent(BasicEvent event) { + log.info("触发向IoTDB插入数据事件监听器……"); JSONObject data = JSONObject.parseObject(event.getData()); List keyList = extractKeys(data); List valueList = extractValues(data);