From 695cb6d76b838b1e4cb161bae335faa948dca12a Mon Sep 17 00:00:00 2001
From: 疯狂的狮子li <15040126243@163.com>
Date: 星期三, 27 十月 2021 13:16:19 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/dev' into satoken
---
ruoyi-job/src/main/java/com/ruoyi/job/config/XxlJobConfig.java | 48 ++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 48 insertions(+), 0 deletions(-)
diff --git a/ruoyi-job/src/main/java/com/ruoyi/job/config/XxlJobConfig.java b/ruoyi-job/src/main/java/com/ruoyi/job/config/XxlJobConfig.java
new file mode 100644
index 0000000..2df063e
--- /dev/null
+++ b/ruoyi-job/src/main/java/com/ruoyi/job/config/XxlJobConfig.java
@@ -0,0 +1,48 @@
+package com.ruoyi.job.config;
+
+import com.ruoyi.job.config.properties.XxlJobProperties;
+import com.xxl.job.core.executor.impl.XxlJobSpringExecutor;
+import com.yomahub.tlog.springboot.lifecircle.TLogXxljobEnhanceInit;
+import lombok.AllArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * xxl-job config
+ *
+ * @author Lion Li
+ */
+@Slf4j
+@Configuration
+@EnableConfigurationProperties(XxlJobProperties.class)
+@AllArgsConstructor
+@ConditionalOnProperty(prefix = "xxl.job", name = "enabled", havingValue = "true")
+public class XxlJobConfig {
+
+ private final XxlJobProperties xxlJobProperties;
+
+ @Bean
+ public XxlJobSpringExecutor xxlJobExecutor() {
+ log.info(">>>>>>>>>>> xxl-job config init.");
+ XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor();
+ xxlJobSpringExecutor.setAdminAddresses(xxlJobProperties.getAdminAddresses());
+ xxlJobSpringExecutor.setAccessToken(xxlJobProperties.getAccessToken());
+ XxlJobProperties.Executor executor = xxlJobProperties.getExecutor();
+ xxlJobSpringExecutor.setAppname(executor.getAppname());
+ xxlJobSpringExecutor.setAddress(executor.getAddress());
+ xxlJobSpringExecutor.setIp(executor.getIp());
+ xxlJobSpringExecutor.setPort(executor.getPort());
+ xxlJobSpringExecutor.setLogPath(executor.getLogPath());
+ xxlJobSpringExecutor.setLogRetentionDays(executor.getLogRetentionDays());
+ return xxlJobSpringExecutor;
+ }
+
+ @Bean
+ public TLogXxljobEnhanceInit tLogXxljobEnhanceInit(){
+ return new TLogXxljobEnhanceInit();
+ }
+
+}
\ No newline at end of file
--
Gitblit v1.9.3