配置定时任务

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);
+    }
+}

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();
 }

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();
     }
 }