From 813fcf1b55352ad51ea6fc89d7e9080c34f9568d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=99=A8=E5=93=80?= <2076029107@qq.com> Date: Tue, 8 Oct 2024 12:12:57 +0800 Subject: [PATCH] =?UTF-8?q?feat:()=20=E8=A7=A3=E5=86=B3=E5=90=88=E5=B9=B6?= =?UTF-8?q?=E5=86=B2=E7=AA=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../consumer/KafkaConsumerService.java | 19 +------------------ .../consumer/OnLineMonitoringConsumer.java | 4 ---- 2 files changed, 1 insertion(+), 22 deletions(-) diff --git a/cloud-modules/cloud-modules-processing/src/main/java/com/muyu/processing/consumer/KafkaConsumerService.java b/cloud-modules/cloud-modules-processing/src/main/java/com/muyu/processing/consumer/KafkaConsumerService.java index 578db9d..496e254 100644 --- a/cloud-modules/cloud-modules-processing/src/main/java/com/muyu/processing/consumer/KafkaConsumerService.java +++ b/cloud-modules/cloud-modules-processing/src/main/java/com/muyu/processing/consumer/KafkaConsumerService.java @@ -4,12 +4,6 @@ import cn.hutool.core.thread.ThreadUtil; import com.alibaba.fastjson.JSON; import com.alibaba.fastjson.JSONObject; import com.alibaba.nacos.shaded.com.google.common.collect.Lists; -import com.muyu.common.core.utils.html.EscapeUtil; -import com.muyu.domain.Fence; -import com.muyu.domain.Vehicle; -import com.muyu.domain.WarnRule; -import com.muyu.domain.WarnStrategy; -import com.muyu.domain.resp.VehicleManageResp; import com.muyu.processing.basic.EventPublisher; import com.muyu.processing.utils.CacheUtil; import lombok.extern.log4j.Log4j2; @@ -83,18 +77,7 @@ public class KafkaConsumerService implements InitializingBean { log.info("从Kafka中消费的原始数据: " + originalMsg); //把消费数据转换为JSON对象 JSONObject jsonObject = JSON.parseObject(originalMsg); - // 获取VIN码 - String vin = (String) jsonObject.get("vin"); - log.info("vin码为: {}",vin); - // 获取本地缓存中的数据 -// Map map = (Map) cacheUtil.get(vin); -// log.info("map: {}",map); -// Fence fence = (Fence) map.get("fence"); -// Object breakdown = map.get("breakdown"); -// Vehicle vehicle = (Vehicle) map.get("vehicle"); -// WarnRule warnRule = (WarnRule) map.get("warnRule"); -// WarnStrategy warnStrategy = (WarnStrategy) map.get("warnStrategy"); -// VehicleManageResp vehicleManageResp = (VehicleManageResp) map.get("vehicleManageResp"); + // 发布事件 eventPublisher.eventPublish(jsonObject); } diff --git a/cloud-modules/cloud-modules-processing/src/main/java/com/muyu/processing/consumer/OnLineMonitoringConsumer.java b/cloud-modules/cloud-modules-processing/src/main/java/com/muyu/processing/consumer/OnLineMonitoringConsumer.java index 19a9b6c..1dd079f 100644 --- a/cloud-modules/cloud-modules-processing/src/main/java/com/muyu/processing/consumer/OnLineMonitoringConsumer.java +++ b/cloud-modules/cloud-modules-processing/src/main/java/com/muyu/processing/consumer/OnLineMonitoringConsumer.java @@ -3,12 +3,10 @@ package com.muyu.processing.consumer; import com.muyu.domain.Fence; import com.muyu.domain.Vehicle; import com.muyu.domain.WarnRule; -import com.muyu.domain.WarnStrategy; import com.muyu.domain.resp.VehicleManageResp; import com.muyu.domain.resp.WarnRuleResp; import com.muyu.enterprise.cache.*; import com.muyu.processing.utils.CacheUtil; -import com.rabbitmq.client.Channel; import lombok.extern.log4j.Log4j2; import org.springframework.amqp.rabbit.annotation.Exchange; import org.springframework.amqp.rabbit.annotation.Queue; @@ -89,6 +87,4 @@ public class OnLineMonitoringConsumer { log.info("vin码为: {}, 数据为: {}, 已完成本地缓存",vin,map); } - } - }