From 7d11f02b28fc5ac72a3816e2ccf4f6b8acfc95cb Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E6=9D=8E=E6=B6=9B?= <a15234804788@163.com>
Date: Sat, 11 Apr 2026 16:57:33 +0800
Subject: [PATCH] =?UTF-8?q?=E7=94=9F=E4=BA=A7=E7=AE=A1=E7=90=86=E4=BF=AE?=
 =?UTF-8?q?=E6=94=B9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../produce/DisTaskingProcessor.java          | 30 +++++++++++++++++++
 .../desk/produce/feign/IDisTaskingClient.java | 29 ++++++++++++++++++
 .../desk/produce/feign/DisTaskingClient.java  | 26 ++++++++++++++++
 .../service/impl/DisTaskingServiceImpl.java   |  3 ++
 4 files changed, 88 insertions(+)
 create mode 100644 blade-ops/blade-job/src/main/java/org/springblade/job/processor/produce/DisTaskingProcessor.java
 create mode 100644 blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/produce/feign/IDisTaskingClient.java
 create mode 100644 blade-service/blade-desk/src/main/java/org/springblade/desk/produce/feign/DisTaskingClient.java

diff --git a/blade-ops/blade-job/src/main/java/org/springblade/job/processor/produce/DisTaskingProcessor.java b/blade-ops/blade-job/src/main/java/org/springblade/job/processor/produce/DisTaskingProcessor.java
new file mode 100644
index 00000000..ae0af977
--- /dev/null
+++ b/blade-ops/blade-job/src/main/java/org/springblade/job/processor/produce/DisTaskingProcessor.java
@@ -0,0 +1,30 @@
+package org.springblade.job.processor.produce;
+
+import jakarta.annotation.Resource;
+import lombok.Data;
+import lombok.extern.slf4j.Slf4j;
+import org.springblade.desk.produce.feign.IDisTaskingClient;
+import org.springframework.stereotype.Component;
+import tech.powerjob.worker.core.processor.ProcessResult;
+import tech.powerjob.worker.core.processor.TaskContext;
+import tech.powerjob.worker.core.processor.sdk.BasicProcessor;
+
+/**
+ * 调度任务同步
+ *
+ * @author litao
+ */
+@Component
+@Data
+@Slf4j
+public class DisTaskingProcessor implements BasicProcessor {
+
+    @Resource
+    private IDisTaskingClient client;
+
+    @Override
+    public ProcessResult process(TaskContext context) throws Exception {
+        log.info("调度任务同步开始");
+        return new ProcessResult(client.syncDisTasking());
+    }
+}
diff --git a/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/produce/feign/IDisTaskingClient.java b/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/produce/feign/IDisTaskingClient.java
new file mode 100644
index 00000000..e371b9a2
--- /dev/null
+++ b/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/produce/feign/IDisTaskingClient.java
@@ -0,0 +1,29 @@
+package org.springblade.desk.produce.feign;
+
+import org.springblade.core.launch.constant.AppConstant;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.GetMapping;
+
+/**
+ * 调度任务同步接口
+ *
+ * @author litao
+ */
+@FeignClient(
+        value = AppConstant.APPLICATION_DESK_NAME
+)
+public interface IDisTaskingClient {
+
+    String API_PREFIX = "/feign/client/disTasking";
+
+    String SYNC_DIS_TASKING = API_PREFIX + "/syncDisTasking";
+
+
+    /**
+     * 调度任务同步接口
+     * @return
+     */
+    @GetMapping(SYNC_DIS_TASKING)
+    boolean syncDisTasking();
+
+}
diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/feign/DisTaskingClient.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/feign/DisTaskingClient.java
new file mode 100644
index 00000000..49b14a2d
--- /dev/null
+++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/feign/DisTaskingClient.java
@@ -0,0 +1,26 @@
+package org.springblade.desk.produce.feign;
+
+import io.swagger.v3.oas.annotations.Hidden;
+import lombok.RequiredArgsConstructor;
+import org.springblade.core.tenant.annotation.NonDS;
+import org.springblade.desk.produce.service.IDisTaskingService;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * Feign 调度任务同步接口
+ *
+ * @author litao
+ */
+@NonDS
+@Hidden()
+@RestController
+@RequiredArgsConstructor
+public class DisTaskingClient implements IDisTaskingClient {
+
+	private final IDisTaskingService disTaskingService;
+
+	@Override
+	public boolean syncDisTasking() {
+		return disTaskingService.syncDisTasking(false);
+	}
+}
diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/service/impl/DisTaskingServiceImpl.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/service/impl/DisTaskingServiceImpl.java
index ee5c89aa..9a434790 100644
--- a/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/service/impl/DisTaskingServiceImpl.java
+++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/produce/service/impl/DisTaskingServiceImpl.java
@@ -165,6 +165,7 @@ public class DisTaskingServiceImpl extends BaseServiceImpl<DisTaskingMapper, Dis
         }
 
         if (CollectionUtils.isEmpty(dsTaskingEntities)) {
+            log.error("没有需要同步的工艺任务分派数据");
             return false;
         }
 
@@ -228,10 +229,12 @@ public class DisTaskingServiceImpl extends BaseServiceImpl<DisTaskingMapper, Dis
             return false;
         }
         boolean saveResult = this.saveBatch(disTaskings);
+        log.info("保存 {} 个工艺任务分派数据", disTaskings.size());
 
         if (saveResult && !CollectionUtils.isEmpty(workOrders)) {
             // 更新工单状态逻辑
             saveResult = workOrderService.update(Wrappers.lambdaUpdate(WorkOrder.class).in(WorkOrder::getId, workOrders).set(WorkOrder::getRunStatus, WorkOrder.RUN_STATUS_CRAFT_CHANGE));
+            log.info("更新 {} 个工单状态为 工艺变更", workOrders.size());
         }
         return saveResult;
     }