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