jobid查询接口;

This commit is contained in:
王奎兴
2026-09-05 19:00:02 +08:00
parent fa7db5df0c
commit 20d11dc9b2
@@ -59,14 +59,29 @@ public class XxlJobOpenApiUtil {
* @return jobId,查不到返回null * @return jobId,查不到返回null
*/ */
public Integer queryJobIdByDescAndParam(String jobDesc, String executorParam) { public Integer queryJobIdByDescAndParam(String jobDesc, String executorParam) {
String query = "jobGroup=&jobDesc="+cn.hutool.core.net.URLEncodeUtil.encode(jobDesc) StringBuilder querySb = new StringBuilder();
+"&executorHandler=&executorParam="+cn.hutool.core.net.URLEncodeUtil.encode(executorParam) // start length必须
+"&triggerStatus=-1&start=0&length=10"; 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); log.info("[XxlJob] pageList请求url:{}",url);
try { try {
// 重点:1. header名称是Cookie2. 改用get请求
HttpResponse response = HttpRequest.get(url) HttpResponse response = HttpRequest.get(url)
.header("Authorization", cookie) .header("Authorization", cookie)
.execute(); .execute();
@@ -102,6 +117,7 @@ public class XxlJobOpenApiUtil {
/** /**
* 暂停任务 POST /jobinfo/pause * 暂停任务 POST /jobinfo/pause
* @param jobId xxl任务id * @param jobId xxl任务id