From e5d1a73e2a2a186f3f3d1e0df6a33dbc735829c2 Mon Sep 17 00:00:00 2001
From: zren25 <zhen.ren.2@volvocars.com>
Date: Thu, 13 Mar 2025 16:31:19 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0xxjob=E9=85=8D=E7=BD=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 ai-analytic-center-biz/pom.xml                |  6 ++
 .../analytic/center/config/XxlJobConfig.java  | 60 +++++++++++++++++++
 2 files changed, 66 insertions(+)
 create mode 100644 ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/config/XxlJobConfig.java

diff --git a/ai-analytic-center-biz/pom.xml b/ai-analytic-center-biz/pom.xml
index 79353d4..a5713bf 100644
--- a/ai-analytic-center-biz/pom.xml
+++ b/ai-analytic-center-biz/pom.xml
@@ -209,6 +209,12 @@
 		</dependency>
 
 
+		<dependency>
+			<groupId>com.xuxueli</groupId>
+			<artifactId>xxl-job-core</artifactId>
+			<version>2.3.0</version>
+		</dependency>
+
 	</dependencies>
 
 	<build>
diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/config/XxlJobConfig.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/config/XxlJobConfig.java
new file mode 100644
index 0000000..5dc6dbc
--- /dev/null
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/config/XxlJobConfig.java
@@ -0,0 +1,60 @@
+package com.volvo.ai.analytic.center.config;
+
+import com.xxl.job.core.executor.impl.XxlJobSpringExecutor;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * @author liuyazhou
+ * @version 1.0.0
+ * @ClassName XxlJobConfig.java
+ * @Description TODO
+ * @createTime 2022年08月09日 17:05:00
+ */
+@Configuration
+public class XxlJobConfig {
+
+    private static final Logger logger = LoggerFactory.getLogger(XxlJobConfig.class);
+
+    @Value("${xxl.job.admin.addresses}")
+    private String adminAddresses;
+    @Value("${xxl.job.accessToken}")
+    private String accessToken;
+
+    @Value("${xxl.job.executor.appName}")
+    private String appname;
+
+    @Value("${xxl.job.executor.address}")
+    private String address;
+
+    @Value("${xxl.job.executor.ip}")
+    private String ip;
+
+    @Value("${xxl.job.executor.port}")
+    private int port;
+
+    @Value("${xxl.job.executor.logPath}")
+    private String logPath;
+
+    @Value("${xxl.job.executor.logRetentionDays}")
+    private int logRetentionDays;
+
+    @Bean
+    public XxlJobSpringExecutor xxlJobExecutor() {
+        logger.info(">>>>>>>>>>> xxl-job config init.");
+        XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor();
+        xxlJobSpringExecutor.setAdminAddresses(adminAddresses);
+        xxlJobSpringExecutor.setAppname(appname);
+        xxlJobSpringExecutor.setAddress(address);
+        xxlJobSpringExecutor.setIp(ip);
+        xxlJobSpringExecutor.setPort(port);
+        xxlJobSpringExecutor.setAccessToken(accessToken);
+        xxlJobSpringExecutor.setLogPath(logPath);
+        xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays);
+        return xxlJobSpringExecutor;
+    }
+
+}