From 98cf1f3bcf3d270eb029fc3d9c00974fb4cc7992 Mon Sep 17 00:00:00 2001
From: liweidong-hj <liweidong-hj@huafang.com>
Date: Wed, 18 Mar 2026 10:17:19 +0800
Subject: [PATCH] =?UTF-8?q?=E9=85=8D=E7=BD=AE=E5=AE=9A=E6=97=B6=E4=BB=BB?=
 =?UTF-8?q?=E5=8A=A1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../processor/dashboard/TaskingProcessor.java | 29 +++++++++++++++++++
 .../desk/dashboard/feign/IPartClient.java     |  8 ++---
 .../desk/dashboard/feign/PartClient.java      |  4 +--
 3 files changed, 35 insertions(+), 6 deletions(-)
 create mode 100644 blade-ops/blade-job/src/main/java/org/springblade/job/processor/dashboard/TaskingProcessor.java

diff --git a/blade-ops/blade-job/src/main/java/org/springblade/job/processor/dashboard/TaskingProcessor.java b/blade-ops/blade-job/src/main/java/org/springblade/job/processor/dashboard/TaskingProcessor.java
new file mode 100644
index 00000000..c1050349
--- /dev/null
+++ b/blade-ops/blade-job/src/main/java/org/springblade/job/processor/dashboard/TaskingProcessor.java
@@ -0,0 +1,29 @@
+package org.springblade.job.processor.dashboard;
+
+import jakarta.annotation.Resource;
+import lombok.Data;
+import lombok.extern.slf4j.Slf4j;
+import org.springblade.desk.dashboard.feign.IPartClient;
+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 liweidong
+ */
+@Component
+@Data
+@Slf4j
+public class TaskingProcessor implements BasicProcessor {
+
+    @Resource
+    private IPartClient client;
+
+    @Override
+    public ProcessResult process(TaskContext context) throws Exception {
+        client.syncTasking();
+        return new ProcessResult(true);
+    }
+}
diff --git a/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/dashboard/feign/IPartClient.java b/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/dashboard/feign/IPartClient.java
index d82be63f..30cd1bac 100644
--- a/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/dashboard/feign/IPartClient.java
+++ b/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/dashboard/feign/IPartClient.java
@@ -25,7 +25,7 @@ public interface IPartClient {
     String GET_SUB_PART = API_PREFIX + "/getSubPart";
     String BATCH_PARTS = API_PREFIX + "/batchParts";
     String REWORK_TASK = API_PREFIX + "/reworkTask";
-    String SYNC_PART = API_PREFIX + "/syncPart";
+    String SYNC_TASKING = API_PREFIX + "/syncTasking";
 
     /**
      * 获取零件信息
@@ -66,8 +66,8 @@ public interface IPartClient {
     void reworkTask();
 
     /**
-     * 零件同步
+     * 正常任务同步
      */
-    @GetMapping(SYNC_PART)
-    void syncPart();
+    @GetMapping(SYNC_TASKING)
+    void syncTasking();
 }
\ No newline at end of file
diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/dashboard/feign/PartClient.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/dashboard/feign/PartClient.java
index 7426b9b1..3711f56c 100644
--- a/blade-service/blade-desk/src/main/java/org/springblade/desk/dashboard/feign/PartClient.java
+++ b/blade-service/blade-desk/src/main/java/org/springblade/desk/dashboard/feign/PartClient.java
@@ -47,8 +47,8 @@ public class PartClient implements IPartClient {
     }
 
     @Override
-    public void syncPart() {
-        partService.syncPart();
+    public void syncTasking() {
+        taskingService.syncTasking();
     }
 }