From 6708353379f02f54a9decbbdbb6fd68937f7c576 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:08:42 +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

---
 .../SettlementCustomersApplicationService.java              | 4 ++--
 .../repository/util/XxlJobOpenApiUtil.java                  | 6 ++++--
 2 files changed, 6 insertions(+), 4 deletions(-)

diff --git a/mhd_bms/src/main/java/com/mhd/bms/application/server/settlementCustomers/SettlementCustomersApplicationService.java b/mhd_bms/src/main/java/com/mhd/bms/application/server/settlementCustomers/SettlementCustomersApplicationService.java
index 7c0893de5..32bbfa10e 100644
--- a/mhd_bms/src/main/java/com/mhd/bms/application/server/settlementCustomers/SettlementCustomersApplicationService.java
+++ b/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失败");
         }
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 7446ad946..687211894 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
@@ -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)){