diff --git a/cloud-modules/cloud-modules-data-processing/pom.xml b/cloud-modules/cloud-modules-data-processing/pom.xml index 2810991..e38983c 100644 --- a/cloud-modules/cloud-modules-data-processing/pom.xml +++ b/cloud-modules/cloud-modules-data-processing/pom.xml @@ -23,13 +23,11 @@ com.muyu cloud-common-kafka - 3.6.3 com.muyu cloud-common-caffeine - 3.6.3 @@ -88,46 +86,6 @@ com.muyu cloud-common-datasource - - - - com.muyu - cloud-common-api-doc - - - - - com.muyu - cloud-common-xxl - - - - com.muyu - cloud-common-rabbit - - - - org.bouncycastle - bcpkix-jdk15on - 1.70 - - - - com.muyu - cloud-common-kafka - - - - org.eclipse.paho - org.eclipse.paho.client.mqttv3 - 1.2.2 - - - - com.muyu - cloud-modules-car-gateway - 3.6.3 - ${project.artifactId} diff --git a/cloud-modules/cloud-modules-data-processing/src/main/java/com/muyu/data/processing/rebbit/GoOnlineRabbitConsumer.java b/cloud-modules/cloud-modules-data-processing/src/main/java/com/muyu/data/processing/rebbit/GoOnlineRabbitConsumer.java index f648083..81a841d 100644 --- a/cloud-modules/cloud-modules-data-processing/src/main/java/com/muyu/data/processing/rebbit/GoOnlineRabbitConsumer.java +++ b/cloud-modules/cloud-modules-data-processing/src/main/java/com/muyu/data/processing/rebbit/GoOnlineRabbitConsumer.java @@ -35,14 +35,8 @@ public class GoOnlineRabbitConsumer { public void goOnline(String vin, Message message, Channel channel){ log.info("车辆 {} 上线, 配置信息准备中。。。",vin); try { - // 重复性校验 - Long add = redisTemplate.opsForSet().add(RabbitConstants.GO_ONLINE_QUEUE, message.getMessageProperties().getMessageId()); - if (add>0) { - addCarCache(vin); - log.info("车辆 {} 上线, 消息已确认。。。",vin); - } else { - log.info("车辆 {} 上线, 消息重复消费,已确认。。。",vin); - } + addCarCache(vin); + log.info("车辆 {} 上线, 消息已确认。。。",vin); channel.basicAck(message.getMessageProperties().getDeliveryTag(), false); log.info("车辆 {} 上线, 配置信息已准备完毕。。。",vin); } catch (IOException e) { diff --git a/cloud-modules/cloud-modules-parsing/pom.xml b/cloud-modules/cloud-modules-parsing/pom.xml index 0969c45..8324a5b 100644 --- a/cloud-modules/cloud-modules-parsing/pom.xml +++ b/cloud-modules/cloud-modules-parsing/pom.xml @@ -20,29 +20,6 @@ UTF-8 - - com.muyu - cloud-common-kafka - 3.6.3 - - - - com.muyu - cloud-common-caffeine - 3.6.3 - - - - com.muyu - cloud-common-rabbit - - - - com.muyu - cloud-common-iotdb - 3.6.3 - - com.alibaba.cloud @@ -67,26 +44,51 @@ spring-boot-starter-actuator - - org.springframework.boot - spring-boot-starter-tomcat - - com.mysql mysql-connector-j + + + com.muyu + cloud-common-datasource + + com.muyu cloud-common-datascope + com.muyu - cloud-common-datasource + cloud-common-log + + + + + com.muyu + cloud-common-api-doc + + + + + com.muyu + cloud-common-xxl + + + + com.muyu + cloud-common-rabbit + + + + org.bouncycastle + bcpkix-jdk15on + 1.70