AI分析中心服务 更新配置文件

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>-->

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);
     }
 }

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