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