package com.moral.api.config.xxl; import lombok.extern.slf4j.Slf4j; 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.ComponentScan; import org.springframework.context.annotation.Configuration; import com.xxl.job.core.executor.impl.XxlJobSpringExecutor; @Configuration @ComponentScan(basePackages = "com.moral.api.jobHandler") @Slf4j public class XxlJobConfig { @Value("${xxl.job.admin.addresses}") private String adminAddresses; @Value("${xxl.job.executor.appname}") private String appName; @Value("${xxl.job.executor.ip}") private String ip; @Value("${xxl.job.executor.port}") private Integer port; @Value("${xxl.job.accessToken}") private String accessToken; @Value("${xxl.job.executor.logpath}") private String logPath; @Value("${xxl.job.executor.logretentiondays}") private Integer logRetentionDays; @Bean public XxlJobSpringExecutor xxlJobSpringExecutor(){ log.info("xxl jon config init"); XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor(); xxlJobSpringExecutor.setAdminAddresses(adminAddresses); xxlJobSpringExecutor.setAppname(appName); xxlJobSpringExecutor.setIp(ip); xxlJobSpringExecutor.setPort(port); xxlJobSpringExecutor.setAccessToken(accessToken); xxlJobSpringExecutor.setLogPath(logPath); xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays); return xxlJobSpringExecutor; } @Override public String toString() { return "XxlJobConfig{" + "adminAddresses='" + adminAddresses + '\'' + ", appName='" + appName + '\'' + ", ip='" + ip + '\'' + ", port=" + port + ", accessToken='" + accessToken + '\'' + ", logPath='" + logPath + '\'' + ", logRetentionDays=" + logRetentionDays + '}'; } public XxlJobConfig() { } public XxlJobConfig(String adminAddresses, String appName, String ip, Integer port, String accessToken, String logPath, Integer logRetentionDays) { this.adminAddresses = adminAddresses; this.appName = appName; this.ip = ip; this.port = port; this.accessToken = accessToken; this.logPath = logPath; this.logRetentionDays = logRetentionDays; } public String getAdminAddresses() { return adminAddresses; } public void setAdminAddresses(String adminAddresses) { this.adminAddresses = adminAddresses; } public String getAppName() { return appName; } public void setAppName(String appName) { this.appName = appName; } public String getIp() { return ip; } public void setIp(String ip) { this.ip = ip; } public Integer getPort() { return port; } public void setPort(Integer port) { this.port = port; } public String getAccessToken() { return accessToken; } public void setAccessToken(String accessToken) { this.accessToken = accessToken; } public String getLogPath() { return logPath; } public void setLogPath(String logPath) { this.logPath = logPath; } public Integer getLogRetentionDays() { return logRetentionDays; } public void setLogRetentionDays(Integer logRetentionDays) { this.logRetentionDays = logRetentionDays; } }