1.修改定时任务方法，powerjob方式

2.iot设备同步方法，计量记录同步方法修改

blade-ops/blade-job/src/main/java/org/springblade/job/processor/device/IotEquipmentProcessor.java

@@ -0,0 +1,28 @@
+package org.springblade.job.processor.device;
+
+import jakarta.annotation.Resource;
+import lombok.extern.slf4j.Slf4j;
+import org.springblade.desk.device.feign.IotEquipmentTaskClient;
+import org.springblade.desk.quality.feign.ILquidTankTaskClient;
+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;
+import tech.powerjob.worker.log.OmsLogger;
+
+/**
+ * 同步设备数据任务
+ */
+@Component
+@Slf4j
+public class IotEquipmentProcessor implements BasicProcessor {
+
+    @Resource
+    private IotEquipmentTaskClient iotEquipmentTaskClient;
+
+    @Override
+    public ProcessResult process(TaskContext context) throws Exception {
+        iotEquipmentTaskClient.synchronizeEquipmentTask();
+        return new ProcessResult(true);
+    }
+}

blade-ops/blade-job/src/main/java/org/springblade/job/processor/device/IotFeiBaProcessor.java

@@ -0,0 +1,26 @@
+package org.springblade.job.processor.device;
+
+import jakarta.annotation.Resource;
+import lombok.extern.slf4j.Slf4j;
+import org.springblade.desk.device.feign.IotEquipmentTaskClient;
+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;
+
+/**
+ * 同步飞靶数据任务
+ */
+@Component
+@Slf4j
+public class IotFeiBaProcessor implements BasicProcessor {
+
+    @Resource
+    private IotEquipmentTaskClient iotEquipmentTaskClient;
+
+    @Override
+    public ProcessResult process(TaskContext context) throws Exception {
+        iotEquipmentTaskClient.synchronizeFeibaTask();
+        return new ProcessResult(true);
+    }
+}

blade-ops/blade-job/src/main/java/org/springblade/job/processor/device/IotRecorderProcessor.java

@@ -0,0 +1,26 @@
+package org.springblade.job.processor.device;
+
+import jakarta.annotation.Resource;
+import lombok.extern.slf4j.Slf4j;
+import org.springblade.desk.device.feign.IotEquipmentTaskClient;
+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;
+
+/**
+ * 同步记录仪记录数据任务
+ */
+@Component
+@Slf4j
+public class IotRecorderProcessor implements BasicProcessor {
+
+    @Resource
+    private IotEquipmentTaskClient iotEquipmentTaskClient;
+
+    @Override
+    public ProcessResult process(TaskContext context) throws Exception {
+        iotEquipmentTaskClient.synchronizeRecorderTask();
+        return new ProcessResult(true);
+    }
+}

blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/device/feign/IotEquipmentTaskClient.java

@@ -0,0 +1,42 @@
+package org.springblade.desk.device.feign;
+
+import org.springblade.core.launch.constant.AppConstant;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.GetMapping;
+
+@FeignClient(
+        value = AppConstant.APPLICATION_DESK_NAME
+)
+/**
+ * 同步IOT设备相关信息
+ */
+public interface IotEquipmentTaskClient {
+
+    String API_PREFIX = "/feign/device/iot-task";
+
+    String SYNCHRONIZE_EQUIPMENT_TASK = API_PREFIX + "/synchronize-equipment-task";
+
+    String SYNCHRONIZE_FEIBA_TASK = API_PREFIX + "/synchronize-feiba-task";
+
+    String SYNCHRONIZE_RECORDER_TASK = API_PREFIX + "/synchronize-recorder-task";
+
+
+    /**
+     * 同步设备数据
+     */
+    @GetMapping(SYNCHRONIZE_EQUIPMENT_TASK)
+    void synchronizeEquipmentTask();
+
+    /**
+     * 同步飞靶数据
+     */
+    @GetMapping(SYNCHRONIZE_FEIBA_TASK)
+    void synchronizeFeibaTask();
+
+    /**
+     * 同步记录仪记录数据
+     */
+    @GetMapping(SYNCHRONIZE_RECORDER_TASK)
+    void synchronizeRecorderTask();
+
+}

blade-service/blade-desk/src/main/java/org/springblade/desk/device/feign/IotEquipmentTaskClientImpl.java

@@ -0,0 +1,39 @@
+package org.springblade.desk.device.feign;
+
+import io.swagger.v3.oas.annotations.Hidden;
+import jakarta.annotation.Resource;
+import org.springblade.desk.device.service.IEquipmentService;
+import org.springblade.desk.device.service.IFeiBaSetService;
+import org.springblade.desk.device.service.IRecorderService;
+import org.springblade.desk.quality.feign.IIotThicknessClient;
+import org.springblade.desk.quality.service.IotThicknessService2;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@Hidden
+public class IotEquipmentTaskClientImpl implements IotEquipmentTaskClient {
+
+    @Resource
+    private IEquipmentService equipmentService;
+
+    @Resource
+    private IFeiBaSetService feiBaSetService;
+
+    @Resource
+    private IRecorderService recorderService;
+
+    @Override
+    public void synchronizeEquipmentTask() {
+        equipmentService.regularlyUpdated();
+    }
+
+    @Override
+    public void synchronizeFeibaTask() {
+        feiBaSetService.regularlyUpdated();
+    }
+
+    @Override
+    public void synchronizeRecorderTask() {
+        recorderService.regularlyUpdated();
+    }
+}