From 1e006812895f48bda9b5a0e206d5a62eb034e345 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=8E=8B=E5=A5=8E=E5=85=B4?= <2220574228@qq.com> Date: Wed, 26 Aug 2026 17:28:50 +0800 Subject: [PATCH] =?UTF-8?q?=E6=81=A2=E5=A4=8D=20xxl-job?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../stockInOrder/StockInOrderApi.java | 48 +++++------ .../java/com/mhd/wms/util/XxlJobConfig.java | 82 +++++++++---------- mhd_wms/src/main/resources/bootstrap.yml | 42 +++++----- 3 files changed, 86 insertions(+), 86 deletions(-) diff --git a/mhd_wms/src/main/java/com/mhd/wms/interfaces/facadeApi/stockInOrder/StockInOrderApi.java b/mhd_wms/src/main/java/com/mhd/wms/interfaces/facadeApi/stockInOrder/StockInOrderApi.java index 81871c182..795e9782e 100644 --- a/mhd_wms/src/main/java/com/mhd/wms/interfaces/facadeApi/stockInOrder/StockInOrderApi.java +++ b/mhd_wms/src/main/java/com/mhd/wms/interfaces/facadeApi/stockInOrder/StockInOrderApi.java @@ -53,8 +53,8 @@ public class StockInOrderApi extends BaseController { private StockInOrderAssembler stockInOrderAssembler; @Resource private StockOutOrderAssembler stockOutOrderAssembler; - @Autowired - private XxlJobServiceFeign xxlJobServiceFeign; +// @Autowired +// private XxlJobServiceFeign xxlJobServiceFeign; /** * 分页查询入库单列表 @@ -353,32 +353,32 @@ public class StockInOrderApi extends BaseController { return stockInOrderApplicationService.batchSignature(dto); } - @GetMapping("/xxlopenfeign") - public AjaxResult xxlopenfeign(@RequestParam String param) { - R> mapR = xxlJobServiceFeign.openFeignTest(param); - return AjaxResult.success(mapR); - } +// @GetMapping("/xxlopenfeign") +// public AjaxResult xxlopenfeign(@RequestParam String param) { +// R> mapR = xxlJobServiceFeign.openFeignTest(param); +// return AjaxResult.success(mapR); +// } /** * 1. 简单任务示例（Bean模式） * 这里的 demoJobHandler 必须和调度中心配置一致 */ - @XxlJob("demoJobHandler") - public void demoJobHandler() { - // 获取任务参数 - String param = XxlJobHelper.getJobParam(); - logger.info("XXL-JOB 开始执行，参数：{}", param); - - try { - // ========== 你的业务逻辑 ========== - logger.info("执行若依微服务定时任务..."); - - // 设置任务执行结果 - XxlJobHelper.handleSuccess("执行成功"); - } catch (Exception e) { - logger.error("XXL-JOB 执行失败", e); - XxlJobHelper.handleFail("执行失败：" + e.getMessage()); - } - } +// @XxlJob("demoJobHandler") +// public void demoJobHandler() { +// // 获取任务参数 +// String param = XxlJobHelper.getJobParam(); +// logger.info("XXL-JOB 开始执行，参数：{}", param); +// +// try { +// // ========== 你的业务逻辑 ========== +// logger.info("执行若依微服务定时任务..."); +// +// // 设置任务执行结果 +// XxlJobHelper.handleSuccess("执行成功"); +// } catch (Exception e) { +// logger.error("XXL-JOB 执行失败", e); +// XxlJobHelper.handleFail("执行失败：" + e.getMessage()); +// } +// } } \ No newline at end of file diff --git a/mhd_wms/src/main/java/com/mhd/wms/util/XxlJobConfig.java b/mhd_wms/src/main/java/com/mhd/wms/util/XxlJobConfig.java index 9627d0e7b..e17d38a46 100644 --- a/mhd_wms/src/main/java/com/mhd/wms/util/XxlJobConfig.java +++ b/mhd_wms/src/main/java/com/mhd/wms/util/XxlJobConfig.java @@ -9,46 +9,46 @@ import org.springframework.context.annotation.Configuration; /** * XXL-JOB 配置类 */ -@Configuration +//@Configuration public class XxlJobConfig { - private Logger logger = LoggerFactory.getLogger(XxlJobConfig.class); - - @Value("${xxl.job.admin.addresses}") - private String adminAddresses; - - @Value("${xxl.job.accessToken}") - private String accessToken; - - @Value("${xxl.job.executor.appname}") - private String appname; - - @Value("${xxl.job.executor.address}") - private String address; - - @Value("${xxl.job.executor.ip}") - private String ip; - - @Value("${xxl.job.executor.port}") - private int port; - - @Value("${xxl.job.executor.logpath}") - private String logPath; - - @Value("${xxl.job.executor.logretentiondays}") - private int logRetentionDays; - - @Bean - public XxlJobSpringExecutor xxlJobExecutor() { - logger.info(">>>>>>>>>>> xxl-job config init."); - XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor(); - xxlJobSpringExecutor.setAdminAddresses(adminAddresses); - xxlJobSpringExecutor.setAppname(appname); - xxlJobSpringExecutor.setAddress(address); - xxlJobSpringExecutor.setIp(ip); - xxlJobSpringExecutor.setPort(port); - xxlJobSpringExecutor.setAccessToken(accessToken); - xxlJobSpringExecutor.setLogPath(logPath); - xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays); - return xxlJobSpringExecutor; - } +// private Logger logger = LoggerFactory.getLogger(XxlJobConfig.class); +// +// @Value("${xxl.job.admin.addresses}") +// private String adminAddresses; +// +// @Value("${xxl.job.accessToken}") +// private String accessToken; +// +// @Value("${xxl.job.executor.appname}") +// private String appname; +// +// @Value("${xxl.job.executor.address}") +// private String address; +// +// @Value("${xxl.job.executor.ip}") +// private String ip; +// +// @Value("${xxl.job.executor.port}") +// private int port; +// +// @Value("${xxl.job.executor.logpath}") +// private String logPath; +// +// @Value("${xxl.job.executor.logretentiondays}") +// private int logRetentionDays; +// +// @Bean +// public XxlJobSpringExecutor xxlJobExecutor() { +// logger.info(">>>>>>>>>>> xxl-job config init."); +// XxlJobSpringExecutor xxlJobSpringExecutor = new XxlJobSpringExecutor(); +// xxlJobSpringExecutor.setAdminAddresses(adminAddresses); +// xxlJobSpringExecutor.setAppname(appname); +// xxlJobSpringExecutor.setAddress(address); +// xxlJobSpringExecutor.setIp(ip); +// xxlJobSpringExecutor.setPort(port); +// xxlJobSpringExecutor.setAccessToken(accessToken); +// xxlJobSpringExecutor.setLogPath(logPath); +// xxlJobSpringExecutor.setLogRetentionDays(logRetentionDays); +// return xxlJobSpringExecutor; +// } } \ No newline at end of file diff --git a/mhd_wms/src/main/resources/bootstrap.yml b/mhd_wms/src/main/resources/bootstrap.yml index 503393ad1..b99fb0b27 100644 --- a/mhd_wms/src/main/resources/bootstrap.yml +++ b/mhd_wms/src/main/resources/bootstrap.yml @@ -36,24 +36,24 @@ spring: shared-configs: - application-${spring.profiles.active}.${spring.cloud.nacos.config.file-extension} # XXL-JOB 配置 -xxl: - job: - # 调度中心地址（填你部署的地址） - admin: - addresses: http://192.168.1.6:8020/xxl-job-admin - # 执行器配置 - executor: - # 执行器名称（自定义，后面调度中心要用到） - appname: wms-service-executor - # 执行器注册地址，默认0表示自动获取 - address: - # 执行器IP，默认空自动获取 - ip: - # 执行器端口号（每个微服务不能重复，建议9997/9998/9999） - port: 9997 - # 执行器日志存放路径 - logpath: /data/applogs/xxl-job/jobhandler - # 日志保留天数 - logretentiondays: 30 - # 调度中心通讯令牌（默认空，安全可设置） - accessToken: default_token \ No newline at end of file +#xxl: +# job: +# # 调度中心地址（填你部署的地址） +# admin: +# addresses: http://192.168.1.6:8020/xxl-job-admin +# # 执行器配置 +# executor: +# # 执行器名称（自定义，后面调度中心要用到） +# appname: wms-service-executor +# # 执行器注册地址，默认0表示自动获取 +# address: +# # 执行器IP，默认空自动获取 +# ip: +# # 执行器端口号（每个微服务不能重复，建议9997/9998/9999） +# port: 9997 +# # 执行器日志存放路径 +# logpath: /data/applogs/xxl-job/jobhandler +# # 日志保留天数 +# logretentiondays: 30 +# # 调度中心通讯令牌（默认空，安全可设置） +# accessToken: default_token \ No newline at end of file