jobid查询接口;

mhd_bms/src/main/java/com/mhd/bms/application/server/settlementCustomers/SettlementCustomersApplicationService.java

@@ -389,7 +389,7 @@ public class SettlementCustomersApplicationService {
         if (!addOk) {
             throw new RuntimeException("创建夜间定时任务失败");
         }
-        Integer xxlJobId = apiUtil.queryJobIdByDescAndParam(req.getJobDesc(), shipperId);
+        Integer xxlJobId = apiUtil.queryJobIdByDescAndParam(req.getJobDesc(), shipperId,"3");
         if (xxlJobId == null) {
             throw new RuntimeException("定时任务创建成功，但查询jobId失败");
         }
@@ -427,7 +427,7 @@ public class SettlementCustomersApplicationService {
         if (!addOk) {
             throw new RuntimeException("创建夜间定时任务失败");
         }
-        Integer xxlJobId = apiUtil.queryJobIdByDescAndParam(req.getJobDesc(), shipperId);
+        Integer xxlJobId = apiUtil.queryJobIdByDescAndParam(req.getJobDesc(), shipperId,"6");
         if (xxlJobId == null) {
             throw new RuntimeException("定时任务创建成功，但查询jobId失败");
         }

mhd_bms/src/main/java/com/mhd/bms/domain/settlementCustomers/repository/util/XxlJobOpenApiUtil.java

@@ -58,14 +58,16 @@ public class XxlJobOpenApiUtil {
      * @param executorParam 任务参数(业务shipperId)
      * @return jobId，查不到返回null
      */
-    public Integer queryJobIdByDescAndParam(String jobDesc, String executorParam) {
+    public Integer queryJobIdByDescAndParam(String jobDesc, String executorParam,String jobGroup) {
         StringBuilder querySb = new StringBuilder();
         // start length必须
         querySb.append("start=0&length=10");
 
         // jobGroup：为空就不拼接这个参数！！不要 jobGroup=""
         // 你们业务固定jobGroup=3，直接写死3，不用传空
-        querySb.append("&jobGroup=3");
+        if(StrUtil.isNotBlank(jobGroup)){
+            querySb.append("&jobGroup=").append(jobGroup);
+        }
 
         // jobDesc
         if(StrUtil.isNotBlank(jobDesc)){