From abdb8559194207a34a529242b1e9238d00b60b02 Mon Sep 17 00:00:00 2001 From: cdf <857448963@qq.com> Date: Thu, 23 Apr 2026 15:11:07 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B3=A8=E9=87=8Aprepareboot=E6=A8=A1=E5=9D=97?= =?UTF-8?q?=E6=97=A0=E7=94=A8=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../timer/tasks/MeasurementTaskRunner.java | 81 +++++++++---------- .../timer/tasks/SubstationTaskRunner.java | 75 +++++++++-------- 2 files changed, 76 insertions(+), 80 deletions(-) diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/MeasurementTaskRunner.java b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/MeasurementTaskRunner.java index b6b5e3acb..946e804a9 100644 --- a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/MeasurementTaskRunner.java +++ b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/MeasurementTaskRunner.java @@ -1,42 +1,39 @@ -//package com.njcn.system.timer.tasks; -// -//import cn.hutool.core.date.DatePattern; -//import cn.hutool.core.date.DateUtil; -//import cn.hutool.core.util.StrUtil; -//import com.njcn.algorithm.pojo.bo.BaseParam; -//import com.njcn.algorithm.pojo.liteflow.LiteFlowAlgorithmFeignClient; -//import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient; -//import com.njcn.system.timer.TimerTaskRunner; -//import lombok.RequiredArgsConstructor; -//import org.springframework.stereotype.Component; -// -///** -// * 类的介绍：监测点算法执行链定时任务 -// * -// * @author xuyang -// * @version 1.0.0 -// * @createTime 2023/12/6 9:35 -// */ -//@Component -//@RequiredArgsConstructor -//public class MeasurementTaskRunner implements TimerTaskRunner { -// -// private final LiteFlowFeignClient liteFlowFeignClient; -// -// private final LiteFlowAlgorithmFeignClient liteFlowAlgorithmFeignClient; -// -// @Override -// public void action(String date) { -// BaseParam baseParam = new BaseParam(); -// baseParam.setFullChain(true); -// baseParam.setRepair(false); -// if(StrUtil.isBlank(date)){ -// baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN)); -// }else { -// baseParam.setDataDate(date); -// } -// liteFlowAlgorithmFeignClient.measurementPointExecutor(baseParam); -// } -// -// -//} +package com.njcn.system.timer.tasks; + +import cn.hutool.core.date.DatePattern; +import cn.hutool.core.date.DateUtil; +import cn.hutool.core.util.StrUtil; +import com.njcn.algorithm.pojo.bo.BaseParam; +import com.njcn.algorithm.pojo.liteflow.LiteFlowAlgorithmFeignClient; +import com.njcn.system.timer.TimerTaskRunner; +import lombok.RequiredArgsConstructor; +import org.springframework.stereotype.Component; + +/** + * 类的介绍：监测点算法执行链定时任务 + * + * @author xuyang + * @version 1.0.0 + * @createTime 2023/12/6 9:35 + */ +@Component +@RequiredArgsConstructor +public class MeasurementTaskRunner implements TimerTaskRunner { + + private final LiteFlowAlgorithmFeignClient liteFlowAlgorithmFeignClient; + + @Override + public void action(String date) { + BaseParam baseParam = new BaseParam(); + baseParam.setFullChain(true); + baseParam.setRepair(false); + if(StrUtil.isBlank(date)){ + baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN)); + }else { + baseParam.setDataDate(date); + } + liteFlowAlgorithmFeignClient.measurementPointExecutor(baseParam); + } + + +} diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/SubstationTaskRunner.java b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/SubstationTaskRunner.java index fff92f070..8217272fc 100644 --- a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/SubstationTaskRunner.java +++ b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/SubstationTaskRunner.java @@ -1,38 +1,37 @@ -//package com.njcn.system.timer.tasks; -// -//import cn.hutool.core.date.DatePattern; -//import cn.hutool.core.date.DateUtil; -//import cn.hutool.core.util.StrUtil; -//import com.njcn.algorithm.pojo.bo.BaseParam; -//import com.njcn.algorithm.pojo.liteflow.LiteFlowAlgorithmFeignClient; -//import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient; -// -//import com.njcn.system.timer.TimerTaskRunner; -//import lombok.RequiredArgsConstructor; -//import org.springframework.stereotype.Component; -// -///** -// * 类的介绍：变电站算法执行链定时任务 -// * -// * @author xuyang -// * @version 1.0.0 -// * @createTime 2023/12/6 9:35 -// */ -//@Component -//@RequiredArgsConstructor -//public class SubstationTaskRunner implements TimerTaskRunner { -// -// private final LiteFlowAlgorithmFeignClient liteFlowFeignClient; -// @Override -// public void action(String date) { -// BaseParam baseParam = new BaseParam(); -// baseParam.setFullChain(true); -// baseParam.setRepair(false); -// if(StrUtil.isBlank(date)){ -// baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN)); -// }else { -// baseParam.setDataDate(date); -// } -// liteFlowFeignClient.substationExecutor(baseParam); -// } -//} +package com.njcn.system.timer.tasks; + +import cn.hutool.core.date.DatePattern; +import cn.hutool.core.date.DateUtil; +import cn.hutool.core.util.StrUtil; +import com.njcn.algorithm.pojo.bo.BaseParam; +import com.njcn.algorithm.pojo.liteflow.LiteFlowAlgorithmFeignClient; + +import com.njcn.system.timer.TimerTaskRunner; +import lombok.RequiredArgsConstructor; +import org.springframework.stereotype.Component; + +/** + * 类的介绍：变电站算法执行链定时任务 + * + * @author xuyang + * @version 1.0.0 + * @createTime 2023/12/6 9:35 + */ +@Component +@RequiredArgsConstructor +public class SubstationTaskRunner implements TimerTaskRunner { + + private final LiteFlowAlgorithmFeignClient liteFlowFeignClient; + @Override + public void action(String date) { + BaseParam baseParam = new BaseParam(); + baseParam.setFullChain(true); + baseParam.setRepair(false); + if(StrUtil.isBlank(date)){ + baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN)); + }else { + baseParam.setDataDate(date); + } + liteFlowFeignClient.substationExecutor(baseParam); + } +}