From 13fd6d22bdce84a19b11494ad60263c2d91eeef7 Mon Sep 17 00:00:00 2001 From: qinyulong Date: Thu, 22 Jan 2026 18:39:14 +0800 Subject: [PATCH] =?UTF-8?q?1.=E4=BF=AE=E6=94=B9=E5=AE=9A=E6=97=B6=E4=BB=BB?= =?UTF-8?q?=E5=8A=A1=E6=96=B9=E6=B3=95=EF=BC=8Cpowerjob=E6=96=B9=E5=BC=8F?= =?UTF-8?q?=202.iot=E8=AE=BE=E5=A4=87=E5=90=8C=E6=AD=A5=E6=96=B9=E6=B3=95?= =?UTF-8?q?=EF=BC=8C=E8=AE=A1=E9=87=8F=E8=AE=B0=E5=BD=95=E5=90=8C=E6=AD=A5?= =?UTF-8?q?=E6=96=B9=E6=B3=95=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../device/IotEquipmentProcessor.java | 28 +++++++++++++ .../processor/device/IotFeiBaProcessor.java | 26 ++++++++++++ .../device/IotRecorderProcessor.java | 26 ++++++++++++ .../device/feign/IotEquipmentTaskClient.java | 42 +++++++++++++++++++ .../feign/IotEquipmentTaskClientImpl.java | 39 +++++++++++++++++ 5 files changed, 161 insertions(+) create mode 100644 blade-ops/blade-job/src/main/java/org/springblade/job/processor/device/IotEquipmentProcessor.java create mode 100644 blade-ops/blade-job/src/main/java/org/springblade/job/processor/device/IotFeiBaProcessor.java create mode 100644 blade-ops/blade-job/src/main/java/org/springblade/job/processor/device/IotRecorderProcessor.java create mode 100644 blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/device/feign/IotEquipmentTaskClient.java create mode 100644 blade-service/blade-desk/src/main/java/org/springblade/desk/device/feign/IotEquipmentTaskClientImpl.java diff --git a/blade-ops/blade-job/src/main/java/org/springblade/job/processor/device/IotEquipmentProcessor.java b/blade-ops/blade-job/src/main/java/org/springblade/job/processor/device/IotEquipmentProcessor.java new file mode 100644 index 00000000..a9e006c0 --- /dev/null +++ b/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); + } +} diff --git a/blade-ops/blade-job/src/main/java/org/springblade/job/processor/device/IotFeiBaProcessor.java b/blade-ops/blade-job/src/main/java/org/springblade/job/processor/device/IotFeiBaProcessor.java new file mode 100644 index 00000000..e8f42868 --- /dev/null +++ b/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); + } +} diff --git a/blade-ops/blade-job/src/main/java/org/springblade/job/processor/device/IotRecorderProcessor.java b/blade-ops/blade-job/src/main/java/org/springblade/job/processor/device/IotRecorderProcessor.java new file mode 100644 index 00000000..4999449c --- /dev/null +++ b/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); + } +} diff --git a/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/device/feign/IotEquipmentTaskClient.java b/blade-service-api/blade-desk-api/src/main/java/org/springblade/desk/device/feign/IotEquipmentTaskClient.java new file mode 100644 index 00000000..a7d2c306 --- /dev/null +++ b/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(); + +} diff --git a/blade-service/blade-desk/src/main/java/org/springblade/desk/device/feign/IotEquipmentTaskClientImpl.java b/blade-service/blade-desk/src/main/java/org/springblade/desk/device/feign/IotEquipmentTaskClientImpl.java new file mode 100644 index 00000000..cd28913e --- /dev/null +++ b/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(); + } +}