diff --git a/nanopart-server/src/main/java/cn/axzo/nanopart/config/XxlJobConfig.java b/nanopart-server/src/main/java/cn/axzo/nanopart/config/XxlJobConfig.java new file mode 100644 index 00000000..e69de29b diff --git a/op/op-server/src/main/java/cn/axzo/nanopart/server/xxljob/XxlJobConfig.java b/op/op-server/src/main/java/cn/axzo/nanopart/server/xxljob/XxlJobConfig.java deleted file mode 100644 index 161e3a7b..00000000 --- a/op/op-server/src/main/java/cn/axzo/nanopart/server/xxljob/XxlJobConfig.java +++ /dev/null @@ -1,60 +0,0 @@ -package cn.axzo.nanopart.server.xxljob; - -import cn.azxo.framework.common.service.JobParamResolver; -import cn.azxo.framework.common.spring.condition.NonLocalEnvironment; -import com.xxl.job.core.executor.impl.XxlJobSpringExecutor; -import lombok.extern.slf4j.Slf4j; -import org.springframework.beans.factory.annotation.Value; -import org.springframework.context.annotation.Bean; -import org.springframework.context.annotation.Configuration; - -/** - * Xxl Job Config - * - * @author zhaoyong_sh - * @see XxlJobConfig - * @since 2021-05-19 10:26 - */ -@Slf4j -@Configuration -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 int port; - - @Value("${xxl.job.accessToken:}") - private String accessToken; - - @Value("${xxl.job.executor.logPath:}") - private String logPath; - - @Bean - @NonLocalEnvironment - public XxlJobSpringExecutor xxlJobExecutor() { - log.info(">>>>>>>>>>> axzo nanopart op-server service xxl-job 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(7); - return xxlJobSpringExecutor; - } - - @Bean - public JobParamResolver jobParamResolver(){ - return new JobParamResolver(); - } - -}