From 6c0673b52ed978b046cf6d1c3dd05a8757e243d1 Mon Sep 17 00:00:00 2001 From: lilong Date: Tue, 26 Mar 2024 16:54:00 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20=E8=BF=81=E7=A7=BBxxlJob=E7=9A=84?= =?UTF-8?q?=E4=BD=8D=E7=BD=AE?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../cn/axzo/nanopart/config/XxlJobConfig.java | 0 .../nanopart/server/xxljob/XxlJobConfig.java | 60 ------------------- 2 files changed, 60 deletions(-) create mode 100644 nanopart-server/src/main/java/cn/axzo/nanopart/config/XxlJobConfig.java delete mode 100644 op/op-server/src/main/java/cn/axzo/nanopart/server/xxljob/XxlJobConfig.java 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(); - } - -}