From 20d11dc9b2fb086b595b7f1d1c3b14ba26a7db03 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=8E=8B=E5=A5=8E=E5=85=B4?= <2220574228@qq.com> Date: Sat, 5 Sep 2026 19:00:02 +0800 Subject: [PATCH] =?UTF-8?q?jobid=E6=9F=A5=E8=AF=A2=E6=8E=A5=E5=8F=A3;?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../repository/util/XxlJobOpenApiUtil.java | 26 +++++++++++++++---- 1 file changed, 21 insertions(+), 5 deletions(-) diff --git a/mhd_bms/src/main/java/com/mhd/bms/domain/settlementCustomers/repository/util/XxlJobOpenApiUtil.java b/mhd_bms/src/main/java/com/mhd/bms/domain/settlementCustomers/repository/util/XxlJobOpenApiUtil.java index cc30bc577..7446ad946 100644 --- a/mhd_bms/src/main/java/com/mhd/bms/domain/settlementCustomers/repository/util/XxlJobOpenApiUtil.java +++ b/mhd_bms/src/main/java/com/mhd/bms/domain/settlementCustomers/repository/util/XxlJobOpenApiUtil.java @@ -59,14 +59,29 @@ public class XxlJobOpenApiUtil { * @return jobId,查不到返回null */ public Integer queryJobIdByDescAndParam(String jobDesc, String executorParam) { - String query = "jobGroup=&jobDesc="+cn.hutool.core.net.URLEncodeUtil.encode(jobDesc) - +"&executorHandler=&executorParam="+cn.hutool.core.net.URLEncodeUtil.encode(executorParam) - +"&triggerStatus=-1&start=0&length=10"; + StringBuilder querySb = new StringBuilder(); + // start length必须 + querySb.append("start=0&length=10"); - String url = adminUrl + "/jobinfo/pageList?" + query; + // jobGroup:为空就不拼接这个参数!!不要 jobGroup="" + // 你们业务固定jobGroup=3,直接写死3,不用传空 + querySb.append("&jobGroup=3"); + + // jobDesc + if(StrUtil.isNotBlank(jobDesc)){ + querySb.append("&jobDesc=").append(cn.hutool.core.net.URLEncodeUtil.encode(jobDesc)); + } + // executorParam + if(StrUtil.isNotBlank(executorParam)){ + querySb.append("&executorParam=").append(cn.hutool.core.net.URLEncodeUtil.encode(executorParam)); + } + // executorHandler为空,直接不携带 + // triggerStatus=-1 + querySb.append("&triggerStatus=-1"); + + String url = adminUrl + "/jobinfo/pageList?" + querySb; log.info("[XxlJob] pageList请求url:{}",url); try { - // 重点:1. header名称是Cookie;2. 改用get请求 HttpResponse response = HttpRequest.get(url) .header("Authorization", cookie) .execute(); @@ -102,6 +117,7 @@ public class XxlJobOpenApiUtil { + /** * 暂停任务 POST /jobinfo/pause * @param jobId xxl任务id