From 033c0aa5121aafd31a7c1437a8d50ace6160ea97 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=B0=91=E5=B9=B4=E6=A2=A6=E4=B8=8E=E7=A0=96?=
 <2847127106@qq.com>
Date: Thu, 10 Oct 2024 10:55:53 +0800
Subject: [PATCH] =?UTF-8?q?fix():=20=E4=BF=AE=E5=A4=8D=E4=BE=9D=E8=B5=96?=
 =?UTF-8?q?=E6=B7=B7=E4=B9=B1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../cloud-modules-data-processing/pom.xml     | 42 -------------
 .../rebbit/GoOnlineRabbitConsumer.java        | 10 +---
 cloud-modules/cloud-modules-parsing/pom.xml   | 60 ++++++++++---------
 3 files changed, 33 insertions(+), 79 deletions(-)

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 @@
         <dependency>
             <groupId>com.muyu</groupId>
             <artifactId>cloud-common-kafka</artifactId>
-            <version>3.6.3</version>
         </dependency>
 
         <dependency>
             <groupId>com.muyu</groupId>
             <artifactId>cloud-common-caffeine</artifactId>
-            <version>3.6.3</version>
         </dependency>
 
         <dependency>
@@ -88,46 +86,6 @@
             <groupId>com.muyu</groupId>
             <artifactId>cloud-common-datasource</artifactId>
         </dependency>
-
-        <!-- 接口模块 -->
-        <dependency>
-            <groupId>com.muyu</groupId>
-            <artifactId>cloud-common-api-doc</artifactId>
-        </dependency>
-
-        <!-- XllJob定时任务 -->
-        <dependency>
-            <groupId>com.muyu</groupId>
-            <artifactId>cloud-common-xxl</artifactId>
-        </dependency>
-
-        <dependency>
-            <groupId>com.muyu</groupId>
-            <artifactId>cloud-common-rabbit</artifactId>
-        </dependency>
-
-        <dependency>
-            <groupId>org.bouncycastle</groupId>
-            <artifactId>bcpkix-jdk15on</artifactId>
-            <version>1.70</version>
-        </dependency>
-        <!--        kafka-->
-        <dependency>
-            <groupId>com.muyu</groupId>
-            <artifactId>cloud-common-kafka</artifactId>
-        </dependency>
-        <!--        mqtt-->
-        <dependency>
-            <groupId>org.eclipse.paho</groupId>
-            <artifactId>org.eclipse.paho.client.mqttv3</artifactId>
-            <version>1.2.2</version>
-        </dependency>
-
-        <dependency>
-            <groupId>com.muyu</groupId>
-            <artifactId>cloud-modules-car-gateway</artifactId>
-            <version>3.6.3</version>
-        </dependency>
     </dependencies>
     <build>
         <finalName>${project.artifactId}</finalName>
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 @@
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
     </properties>
     <dependencies>
-        <dependency>
-            <groupId>com.muyu</groupId>
-            <artifactId>cloud-common-kafka</artifactId>
-            <version>3.6.3</version>
-        </dependency>
-
-        <dependency>
-            <groupId>com.muyu</groupId>
-            <artifactId>cloud-common-caffeine</artifactId>
-            <version>3.6.3</version>
-        </dependency>
-
-        <dependency>
-            <groupId>com.muyu</groupId>
-            <artifactId>cloud-common-rabbit</artifactId>
-        </dependency>
-
-        <dependency>
-            <groupId>com.muyu</groupId>
-            <artifactId>cloud-common-iotdb</artifactId>
-            <version>3.6.3</version>
-        </dependency>
-
         <!-- SpringCloud Alibaba Nacos -->
         <dependency>
             <groupId>com.alibaba.cloud</groupId>
@@ -67,26 +44,51 @@
             <artifactId>spring-boot-starter-actuator</artifactId>
         </dependency>
 
-        <dependency>
-            <groupId>org.springframework.boot</groupId>
-            <artifactId>spring-boot-starter-tomcat</artifactId>
-        </dependency>
-
         <!-- Mysql Connector -->
         <dependency>
             <groupId>com.mysql</groupId>
             <artifactId>mysql-connector-j</artifactId>
         </dependency>
 
+        <!-- MuYu Common DataSource -->
+        <dependency>
+            <groupId>com.muyu</groupId>
+            <artifactId>cloud-common-datasource</artifactId>
+        </dependency>
+
         <!-- MuYu Common DataScope -->
         <dependency>
             <groupId>com.muyu</groupId>
             <artifactId>cloud-common-datascope</artifactId>
         </dependency>
 
+        <!-- MuYu Common Log -->
         <dependency>
             <groupId>com.muyu</groupId>
-            <artifactId>cloud-common-datasource</artifactId>
+            <artifactId>cloud-common-log</artifactId>
+        </dependency>
+
+        <!-- 接口模块 -->
+        <dependency>
+            <groupId>com.muyu</groupId>
+            <artifactId>cloud-common-api-doc</artifactId>
+        </dependency>
+
+        <!-- XllJob定时任务 -->
+        <dependency>
+            <groupId>com.muyu</groupId>
+            <artifactId>cloud-common-xxl</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>com.muyu</groupId>
+            <artifactId>cloud-common-rabbit</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.bouncycastle</groupId>
+            <artifactId>bcpkix-jdk15on</artifactId>
+            <version>1.70</version>
         </dependency>
         <!--        kafka-->
         <dependency>