From 3915af9b2ab5fcada79b24f2d0fa8e4d0c552379 Mon Sep 17 00:00:00 2001
From: lxu75 <liang.xu.4@volvocars.com>
Date: Mon, 23 Dec 2024 16:00:09 +0800
Subject: [PATCH] =?UTF-8?q?AI=E5=88=86=E6=9E=90=E4=B8=AD=E5=BF=83=E6=9C=8D?=
 =?UTF-8?q?=E5=8A=A1=20=E6=9B=B4=E6=96=B0=E9=85=8D=E7=BD=AE=E6=96=87?=
 =?UTF-8?q?=E4=BB=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 ai-analytic-center-biz/pom.xml                            | 8 +++++++-
 .../center/service/impl/MqMessageRecordServiceImpl.java   | 6 +++---
 .../src/main/resources/application-uat.yml                | 2 +-
 3 files changed, 11 insertions(+), 5 deletions(-)

diff --git a/ai-analytic-center-biz/pom.xml b/ai-analytic-center-biz/pom.xml
index adfa607..d26082a 100644
--- a/ai-analytic-center-biz/pom.xml
+++ b/ai-analytic-center-biz/pom.xml
@@ -126,11 +126,17 @@
 			<artifactId>xxl-job-core</artifactId>
 			<version>2.3.0</version>
 		</dependency>
-		<dependency>
+		<!--<dependency>
 			<groupId>com.clickhouse</groupId>
 			<artifactId>clickhouse-jdbc</artifactId>
 			<version>0.3.2</version>
+		</dependency>-->
+		<dependency>
+			<groupId>ru.yandex.clickhouse</groupId>
+			<artifactId>clickhouse-jdbc</artifactId>
+			<version>0.1.53</version>
 		</dependency>
+
 <!--		<dependency>-->
 <!--			<groupId>com.zaxxer</groupId>-->
 <!--			<artifactId>HikariCP</artifactId>-->
diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/MqMessageRecordServiceImpl.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/MqMessageRecordServiceImpl.java
index 0d5ed89..faee731 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/MqMessageRecordServiceImpl.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/service/impl/MqMessageRecordServiceImpl.java
@@ -35,8 +35,8 @@ import java.util.stream.Collectors;
 @Service
 public class MqMessageRecordServiceImpl extends ServiceImpl<MqMessageRecordMapper, MqMessageRecord> implements MqMessageRecordService {
 
-    @Autowired
-    private AmqpTemplate rabbitTemplate;
+//    @Autowired
+//    private AmqpTemplate rabbitTemplate;
 
     @Autowired
     private DataMaskingRuleService dataMaskingRuleService;
@@ -462,7 +462,7 @@ public class MqMessageRecordServiceImpl extends ServiceImpl<MqMessageRecordMappe
         rabbitMqToData.setSubSinceType(SubSinceTypeEnum.SINCETYPE53.getCode());
         rabbitMqToData.setData(curDiffDefeatCallback);
         String callbackInput = JSONObject.toJSONString(rabbitMqToData);
-        rabbitTemplate.convertAndSend(Constant.rabbitToFormQueue, callbackInput);
+//        rabbitTemplate.convertAndSend(Constant.rabbitToFormQueue, callbackInput);
         log.info("发送回调MQ完成: {}", callbackInput);
     }
 }
diff --git a/ai-analytic-center-biz/src/main/resources/application-uat.yml b/ai-analytic-center-biz/src/main/resources/application-uat.yml
index 6f01f42..781fdd2 100644
--- a/ai-analytic-center-biz/src/main/resources/application-uat.yml
+++ b/ai-analytic-center-biz/src/main/resources/application-uat.yml
@@ -36,7 +36,6 @@ spring:
       validationQuery: SELECT 1 FROM DUAL
       mysql:
         usePingMethod: false
-
   clickhouse-ads-ai:
     minimum-idle: 1
     maximum-pool-size: 80
@@ -47,6 +46,7 @@ spring:
     username: ai_xl
     password: "Xw&-a4Qen;h5bmTz"
     driver-class-name: ru.yandex.clickhouse.ClickHouseDriver
+
 #mybatis 配置
 mybatis:
   mapper-locations: classpath:mapper/**/*.xml