push

yd-csf-service/src/main/java/com/yd/csf/service/config/XxlJobConfig.java

+package com.yd.csf.service.config;
+
+import com.xxl.job.core.executor.impl.XxlJobSpringExecutor;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Slf4j
+@Configuration
+@ConditionalOnClass(XxlJobSpringExecutor.class)
+public class XxlJobConfig {
+    
+    @Value("${xxl.job.admin.addresses:http://139.224.145.34:8686/xxl-job-admin}")
+    private String adminAddresses;
+
+    @Value("${xxl.job.executor.appname:csf-executor}")
+    private String appname;
+
+    @Value("${xxl.job.executor.port:9999}")
+    private int port;
+
+    @Value("${xxl.job.accessToken:default_token}")
+    private String accessToken;
+
+    @Bean
+    public XxlJobSpringExecutor xxlJobExecutor() {
+        log.info(">>>>>>>>>>> xxl-job config init. appname: {}, port: {}, accessToken: {}",
+                appname, port, StringUtils.isNotBlank(accessToken) ? "已配置" : "未配置");
+
+        XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor();
+        xxlJobSpringExecutor.setAdminAddresses(adminAddresses);
+        xxlJobSpringExecutor.setAppname(appname);
+        xxlJobSpringExecutor.setPort(port);
+        // 设置accessToken
+        xxlJobSpringExecutor.setAccessToken(accessToken);
+        xxlJobSpringExecutor.setLogRetentionDays(30);
+
+        return xxlJobSpringExecutor;
+    }
+}
\ No newline at end of file