From 8881063209a7df5db4bb55d2f6cb2081164b2711 Mon Sep 17 00:00:00 2001 From: xuyang <748613696@qq.com> Date: Wed, 3 Jan 2024 13:34:52 +0800 Subject: [PATCH] =?UTF-8?q?=E9=83=A8=E7=BD=B2=E6=B2=BB=E7=90=86=E7=B3=BB?= =?UTF-8?q?=E7=BB=9F=E6=A8=A1=E5=9D=97=E9=83=A8=E5=88=86=E4=BB=A3=E7=A0=81?= =?UTF-8?q?=E5=B1=8F=E8=94=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../system/timer/tasks/DeviceTaskRunner.java | 64 ++--- .../timer/tasks/GeneraTrixTaskRunner.java | 64 ++--- .../timer/tasks/MeasurementTaskRunner.java | 64 ++--- .../timer/tasks/MonitorSendTaskRunner.java | 90 +++---- .../tasks/MonitorUserSendTaskRunner.java | 60 ++--- .../system/timer/tasks/OrgTaskRunner.java | 64 ++--- .../system/timer/tasks/PmsDimTaskRunner.java | 64 ++--- .../timer/tasks/PmsMonitorSendTaskRunner.java | 64 ++--- ...PmsStatisticsSpecialMonitorTaskRunner.java | 226 +++++++++--------- .../timer/tasks/RMpEmissionTaskRunner.java | 226 +++++++++--------- .../timer/tasks/RMpInfluenceTaskRunner.java | 226 +++++++++--------- .../tasks/StatisticReportTaskRunner.java | 64 ++--- .../timer/tasks/SubstationTaskRunner.java | 64 ++--- .../timer/tasks/UploadGwTaskRunner.java | 64 ++--- ...pecialAnalysisIndexOverviewTaskRunner.java | 226 +++++++++--------- 15 files changed, 815 insertions(+), 815 deletions(-) diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/DeviceTaskRunner.java b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/DeviceTaskRunner.java index 12ce7090d..081e345ac 100644 --- a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/DeviceTaskRunner.java +++ b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/DeviceTaskRunner.java @@ -1,32 +1,32 @@ -package com.njcn.system.timer.tasks; - -import cn.hutool.core.date.DatePattern; -import cn.hutool.core.date.DateUtil; -import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient; -import com.njcn.prepare.harmonic.pojo.bo.BaseParam; -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 DeviceTaskRunner implements TimerTaskRunner { - - private final LiteFlowFeignClient liteFlowFeignClient; - - @Override - public void action() { - BaseParam baseParam = new BaseParam(); - baseParam.setFullChain(true); - baseParam.setRepair(false); - baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN)); - liteFlowFeignClient.deviceExecutor(baseParam); - } -} +//package com.njcn.system.timer.tasks; +// +//import cn.hutool.core.date.DatePattern; +//import cn.hutool.core.date.DateUtil; +//import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient; +//import com.njcn.prepare.harmonic.pojo.bo.BaseParam; +//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 DeviceTaskRunner implements TimerTaskRunner { +// +// private final LiteFlowFeignClient liteFlowFeignClient; +// +// @Override +// public void action() { +// BaseParam baseParam = new BaseParam(); +// baseParam.setFullChain(true); +// baseParam.setRepair(false); +// baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN)); +// liteFlowFeignClient.deviceExecutor(baseParam); +// } +//} diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/GeneraTrixTaskRunner.java b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/GeneraTrixTaskRunner.java index d29e1da06..03263b0e6 100644 --- a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/GeneraTrixTaskRunner.java +++ b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/GeneraTrixTaskRunner.java @@ -1,32 +1,32 @@ -package com.njcn.system.timer.tasks; - -import cn.hutool.core.date.DatePattern; -import cn.hutool.core.date.DateUtil; -import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient; -import com.njcn.prepare.harmonic.pojo.bo.BaseParam; -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 GeneraTrixTaskRunner implements TimerTaskRunner { - - private final LiteFlowFeignClient liteFlowFeignClient; - - @Override - public void action() { - BaseParam baseParam = new BaseParam(); - baseParam.setFullChain(true); - baseParam.setRepair(false); - baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN)); - liteFlowFeignClient.generaTrixExecutor(baseParam); - } -} +//package com.njcn.system.timer.tasks; +// +//import cn.hutool.core.date.DatePattern; +//import cn.hutool.core.date.DateUtil; +//import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient; +//import com.njcn.prepare.harmonic.pojo.bo.BaseParam; +//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 GeneraTrixTaskRunner implements TimerTaskRunner { +// +// private final LiteFlowFeignClient liteFlowFeignClient; +// +// @Override +// public void action() { +// BaseParam baseParam = new BaseParam(); +// baseParam.setFullChain(true); +// baseParam.setRepair(false); +// baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN)); +// liteFlowFeignClient.generaTrixExecutor(baseParam); +// } +//} 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 8ab887a42..2f844f68c 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,32 +1,32 @@ -package com.njcn.system.timer.tasks; - -import cn.hutool.core.date.DatePattern; -import cn.hutool.core.date.DateUtil; -import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient; -import com.njcn.prepare.harmonic.pojo.bo.BaseParam; -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; - - @Override - public void action() { - BaseParam baseParam = new BaseParam(); - baseParam.setFullChain(true); - baseParam.setRepair(false); - baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN)); - liteFlowFeignClient.measurementPointExecutor(baseParam); - } -} +//package com.njcn.system.timer.tasks; +// +//import cn.hutool.core.date.DatePattern; +//import cn.hutool.core.date.DateUtil; +//import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient; +//import com.njcn.prepare.harmonic.pojo.bo.BaseParam; +//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; +// +// @Override +// public void action() { +// BaseParam baseParam = new BaseParam(); +// baseParam.setFullChain(true); +// baseParam.setRepair(false); +// baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN)); +// liteFlowFeignClient.measurementPointExecutor(baseParam); +// } +//} diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/MonitorSendTaskRunner.java b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/MonitorSendTaskRunner.java index 9022489d2..c57692193 100644 --- a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/MonitorSendTaskRunner.java +++ b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/MonitorSendTaskRunner.java @@ -1,45 +1,45 @@ -package com.njcn.system.timer.tasks; - -import com.njcn.device.pms.api.MonitorSendClient; -import com.njcn.device.pms.pojo.param.MonitorParam; -import com.njcn.system.service.SysDicTreePOService; -import com.njcn.system.timer.TimerTaskRunner; -import lombok.RequiredArgsConstructor; -import org.springframework.stereotype.Component; - - -/** - * - */ -@Component -@RequiredArgsConstructor -public class MonitorSendTaskRunner implements TimerTaskRunner { - - private final MonitorSendClient monitorSendClient; - private final SysDicTreePOService sysDicTreePOService; - - - @Override - public void action() { - //风电场 - MonitorParam.Info param = new MonitorParam.Info(); - param.setObjType(sysDicTreePOService.queryByCode("1401").getId()); - param.setFiy(true); - monitorSendClient.windSend(param); - //光伏电站 - MonitorParam.Info param1 = new MonitorParam.Info(); - param1.setObjType(sysDicTreePOService.queryByCode("1402").getId()); - param1.setFiy(true); - monitorSendClient.windSend(param1); - //牵引站 - MonitorParam.Info param3 = new MonitorParam.Info(); - param3.setObjType(sysDicTreePOService.queryByCode("1300").getId()); - param3.setFiy(true); - monitorSendClient.windSend(param3); - //干扰用户 - MonitorParam.Info param4 = new MonitorParam.Info(); - param4.setObjType(sysDicTreePOService.queryByCode("2300").getId()); - param4.setFiy(true); - monitorSendClient.windSend(param4); - } -} +//package com.njcn.system.timer.tasks; +// +//import com.njcn.device.pms.api.MonitorSendClient; +//import com.njcn.device.pms.pojo.param.MonitorParam; +//import com.njcn.system.service.SysDicTreePOService; +//import com.njcn.system.timer.TimerTaskRunner; +//import lombok.RequiredArgsConstructor; +//import org.springframework.stereotype.Component; +// +// +///** +// * +// */ +//@Component +//@RequiredArgsConstructor +//public class MonitorSendTaskRunner implements TimerTaskRunner { +// +// private final MonitorSendClient monitorSendClient; +// private final SysDicTreePOService sysDicTreePOService; +// +// +// @Override +// public void action() { +// //风电场 +// MonitorParam.Info param = new MonitorParam.Info(); +// param.setObjType(sysDicTreePOService.queryByCode("1401").getId()); +// param.setFiy(true); +// monitorSendClient.windSend(param); +// //光伏电站 +// MonitorParam.Info param1 = new MonitorParam.Info(); +// param1.setObjType(sysDicTreePOService.queryByCode("1402").getId()); +// param1.setFiy(true); +// monitorSendClient.windSend(param1); +// //牵引站 +// MonitorParam.Info param3 = new MonitorParam.Info(); +// param3.setObjType(sysDicTreePOService.queryByCode("1300").getId()); +// param3.setFiy(true); +// monitorSendClient.windSend(param3); +// //干扰用户 +// MonitorParam.Info param4 = new MonitorParam.Info(); +// param4.setObjType(sysDicTreePOService.queryByCode("2300").getId()); +// param4.setFiy(true); +// monitorSendClient.windSend(param4); +// } +//} diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/MonitorUserSendTaskRunner.java b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/MonitorUserSendTaskRunner.java index 1f7d84b97..b4a8d56ac 100644 --- a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/MonitorUserSendTaskRunner.java +++ b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/MonitorUserSendTaskRunner.java @@ -1,30 +1,30 @@ -package com.njcn.system.timer.tasks; - -import com.njcn.device.pms.api.MonitorSendClient; -import com.njcn.device.pms.pojo.param.MonitorParam; -import com.njcn.system.service.SysDicTreePOService; -import com.njcn.system.timer.TimerTaskRunner; -import lombok.RequiredArgsConstructor; -import org.springframework.stereotype.Component; - - -/** - * - */ -@Component -@RequiredArgsConstructor -public class MonitorUserSendTaskRunner implements TimerTaskRunner { - - private final MonitorSendClient monitorSendClient; - private final SysDicTreePOService sysDicTreePOService; - - - @Override - public void action() { - //重要或敏感用户 - MonitorParam.Info param2 = new MonitorParam.Info(); - param2.setObjType(sysDicTreePOService.queryByCode("2400").getId()); - param2.setFiy(true); - monitorSendClient.windSend(param2); - } -} +//package com.njcn.system.timer.tasks; +// +//import com.njcn.device.pms.api.MonitorSendClient; +//import com.njcn.device.pms.pojo.param.MonitorParam; +//import com.njcn.system.service.SysDicTreePOService; +//import com.njcn.system.timer.TimerTaskRunner; +//import lombok.RequiredArgsConstructor; +//import org.springframework.stereotype.Component; +// +// +///** +// * +// */ +//@Component +//@RequiredArgsConstructor +//public class MonitorUserSendTaskRunner implements TimerTaskRunner { +// +// private final MonitorSendClient monitorSendClient; +// private final SysDicTreePOService sysDicTreePOService; +// +// +// @Override +// public void action() { +// //重要或敏感用户 +// MonitorParam.Info param2 = new MonitorParam.Info(); +// param2.setObjType(sysDicTreePOService.queryByCode("2400").getId()); +// param2.setFiy(true); +// monitorSendClient.windSend(param2); +// } +//} diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/OrgTaskRunner.java b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/OrgTaskRunner.java index 1480c9396..8d7275838 100644 --- a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/OrgTaskRunner.java +++ b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/OrgTaskRunner.java @@ -1,32 +1,32 @@ -package com.njcn.system.timer.tasks; - -import cn.hutool.core.date.DatePattern; -import cn.hutool.core.date.DateUtil; -import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient; -import com.njcn.prepare.harmonic.pojo.bo.BaseParam; -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 OrgTaskRunner implements TimerTaskRunner { - - private final LiteFlowFeignClient liteFlowFeignClient; - - @Override - public void action() { - BaseParam baseParam = new BaseParam(); - baseParam.setFullChain(true); - baseParam.setRepair(false); - baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN)); - liteFlowFeignClient.orgPointExecutor(baseParam); - } -} +//package com.njcn.system.timer.tasks; +// +//import cn.hutool.core.date.DatePattern; +//import cn.hutool.core.date.DateUtil; +//import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient; +//import com.njcn.prepare.harmonic.pojo.bo.BaseParam; +//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 OrgTaskRunner implements TimerTaskRunner { +// +// private final LiteFlowFeignClient liteFlowFeignClient; +// +// @Override +// public void action() { +// BaseParam baseParam = new BaseParam(); +// baseParam.setFullChain(true); +// baseParam.setRepair(false); +// baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN)); +// liteFlowFeignClient.orgPointExecutor(baseParam); +// } +//} diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/PmsDimTaskRunner.java b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/PmsDimTaskRunner.java index 18e4813e1..9b0b6cfac 100644 --- a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/PmsDimTaskRunner.java +++ b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/PmsDimTaskRunner.java @@ -1,32 +1,32 @@ -package com.njcn.system.timer.tasks; - -import cn.hutool.core.date.DatePattern; -import cn.hutool.core.date.DateUtil; -import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient; -import com.njcn.prepare.harmonic.pojo.bo.BaseParam; -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 PmsDimTaskRunner implements TimerTaskRunner { - - private final LiteFlowFeignClient liteFlowFeignClient; - - @Override - public void action() { - BaseParam baseParam = new BaseParam(); - baseParam.setFullChain(true); - baseParam.setRepair(false); - baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN)); - liteFlowFeignClient.pmsDimExecutor(baseParam); - } -} +//package com.njcn.system.timer.tasks; +// +//import cn.hutool.core.date.DatePattern; +//import cn.hutool.core.date.DateUtil; +//import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient; +//import com.njcn.prepare.harmonic.pojo.bo.BaseParam; +//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 PmsDimTaskRunner implements TimerTaskRunner { +// +// private final LiteFlowFeignClient liteFlowFeignClient; +// +// @Override +// public void action() { +// BaseParam baseParam = new BaseParam(); +// baseParam.setFullChain(true); +// baseParam.setRepair(false); +// baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN)); +// liteFlowFeignClient.pmsDimExecutor(baseParam); +// } +//} diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/PmsMonitorSendTaskRunner.java b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/PmsMonitorSendTaskRunner.java index 8a140f32f..e0ee88a33 100644 --- a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/PmsMonitorSendTaskRunner.java +++ b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/PmsMonitorSendTaskRunner.java @@ -1,32 +1,32 @@ -package com.njcn.system.timer.tasks; - -import com.njcn.device.pms.api.GwMonitorPushFeignClient; -import com.njcn.device.pms.api.MonitorSendClient; -import com.njcn.device.pms.pojo.param.MonitorParam; -import com.njcn.system.service.SysDicTreePOService; -import com.njcn.system.timer.TimerTaskRunner; -import lombok.RequiredArgsConstructor; -import org.springframework.stereotype.Component; - -import java.util.ArrayList; - - -/** - * - */ -@Component -@RequiredArgsConstructor -public class PmsMonitorSendTaskRunner implements TimerTaskRunner { - - private final GwMonitorPushFeignClient gwMonitorPushFeignClient; - - - @Override - public void action() { - - gwMonitorPushFeignClient.timeTaskPushMonitor(new ArrayList<>()); - - gwMonitorPushFeignClient.pushMonitorOverLimit(new ArrayList<>()); - - } -} +//package com.njcn.system.timer.tasks; +// +//import com.njcn.device.pms.api.GwMonitorPushFeignClient; +//import com.njcn.device.pms.api.MonitorSendClient; +//import com.njcn.device.pms.pojo.param.MonitorParam; +//import com.njcn.system.service.SysDicTreePOService; +//import com.njcn.system.timer.TimerTaskRunner; +//import lombok.RequiredArgsConstructor; +//import org.springframework.stereotype.Component; +// +//import java.util.ArrayList; +// +// +///** +// * +// */ +//@Component +//@RequiredArgsConstructor +//public class PmsMonitorSendTaskRunner implements TimerTaskRunner { +// +// private final GwMonitorPushFeignClient gwMonitorPushFeignClient; +// +// +// @Override +// public void action() { +// +// gwMonitorPushFeignClient.timeTaskPushMonitor(new ArrayList<>()); +// +// gwMonitorPushFeignClient.pushMonitorOverLimit(new ArrayList<>()); +// +// } +//} diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/PmsStatisticsSpecialMonitorTaskRunner.java b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/PmsStatisticsSpecialMonitorTaskRunner.java index 71c95135b..e33949b99 100644 --- a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/PmsStatisticsSpecialMonitorTaskRunner.java +++ b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/PmsStatisticsSpecialMonitorTaskRunner.java @@ -1,113 +1,113 @@ -package com.njcn.system.timer.tasks; - -import cn.hutool.core.date.DateUtil; -import cn.hutool.core.util.StrUtil; -import com.njcn.common.pojo.constant.BizParamConstant; -import com.njcn.prepare.harmonic.api.newalgorithm.PmsStatisticsSpecialMonitorFeignClient; -import com.njcn.prepare.harmonic.pojo.param.LineParam; -import com.njcn.system.timer.TimerTaskRunner; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; -import org.springframework.stereotype.Component; - -import java.text.SimpleDateFormat; -import java.time.LocalDateTime; -import java.util.Calendar; -import java.util.Date; -import java.util.Objects; - -/** - * 类的介绍：专项分析-台账统计定时任务 - * - * @author xuyang - * @version 1.0.0 - * @createTime 2023/12/08 11:23 - */ -@Component -@RequiredArgsConstructor -@Slf4j -public class PmsStatisticsSpecialMonitorTaskRunner implements TimerTaskRunner { - - private final PmsStatisticsSpecialMonitorFeignClient pmsStatisticsSpecialMonitorFeignClient; - - @Override - public void action() { - log.info(LocalDateTime.now()+"专项分析-台账统计调度开始"); - LineParam lineParam = new LineParam(); - lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_MONTH)); - lineParam.setDataDate(this.prepareTimeDeal(BizParamConstant.STAT_BIZ_MONTH)); - this.commDefineDate(BizParamConstant.STAT_BIZ_MONTH,lineParam); - pmsStatisticsSpecialMonitorFeignClient.pmsStatisticsSpecialMonitorHandler(lineParam); - } - - public String prepareTimeDeal(String command) { - if (StrUtil.isBlank(command)) { - log.error(LocalDateTime.now() + "xxl调度任务参数未设置"); - return null; - } - SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); - Calendar calendar = Calendar.getInstance(); - if (Objects.equals(BizParamConstant.STAT_BIZ_DAY, command)) { - calendar.add(Calendar.DAY_OF_MONTH, -1); - } else if (Objects.equals(BizParamConstant.STAT_BIZ_MONTH, command)) { - calendar.set(Calendar.DAY_OF_MONTH, 1); - } else if (Objects.equals(BizParamConstant.STAT_BIZ_QUARTER, command)) { - int nowMonth = calendar.get(Calendar.MONTH); - calendar.set(Calendar.MONTH, nowMonth - (nowMonth % 3)); - calendar.set(Calendar.DAY_OF_MONTH, 1); - calendar.set(Calendar.HOUR_OF_DAY, 0); - calendar.set(Calendar.MINUTE, 0); - calendar.set(Calendar.SECOND, 0); - calendar.set(Calendar.MILLISECOND, 0); - } else if (Objects.equals(BizParamConstant.STAT_BIZ_YEAR, command)) { - calendar.set(Calendar.DAY_OF_YEAR, 1); - } - log.info("job调度时间:" + sdf.format(calendar.getTime())); - return sdf.format(calendar.getTime()); - } - - /** - * 根据xxl-job的参数，生成一个任务的起始时间和结束时间 - * - * @author cdf - * @date 2023/9/20 - */ - public void commDefineDate(String command, LineParam lineParam) { - SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); - String begin; - String end; - Calendar calendar = Calendar.getInstance(); - calendar.add(Calendar.DAY_OF_MONTH, -1); - Date temDate = calendar.getTime(); - switch (command) { - case BizParamConstant.STAT_BIZ_DAY: - begin = sdf.format(DateUtil.beginOfDay(temDate)); - end = sdf.format(DateUtil.endOfDay(temDate)); - break; - case BizParamConstant.STAT_BIZ_WEEK: - begin = sdf.format(DateUtil.beginOfWeek(temDate)); - end = sdf.format(DateUtil.endOfWeek(temDate)); - break; - case BizParamConstant.STAT_BIZ_MONTH: - begin = sdf.format(DateUtil.beginOfMonth(temDate)); - end = sdf.format(DateUtil.endOfMonth(temDate)); - break; - case BizParamConstant.STAT_BIZ_QUARTER: - begin = sdf.format(DateUtil.beginOfQuarter(temDate)); - end = sdf.format(DateUtil.endOfQuarter(temDate)); - break; - case BizParamConstant.STAT_BIZ_YEAR: - begin = sdf.format(DateUtil.beginOfYear(temDate)); - end = sdf.format(DateUtil.endOfYear(temDate)); - break; - default: - begin = sdf.format(DateUtil.beginOfDay(temDate)); - end = sdf.format(DateUtil.endOfDay(temDate)); - break; - } - lineParam.setBeginTime(begin); - lineParam.setEndTime(end); - lineParam.setDataDate(begin.substring(0, 10)); - } - -} +//package com.njcn.system.timer.tasks; +// +//import cn.hutool.core.date.DateUtil; +//import cn.hutool.core.util.StrUtil; +//import com.njcn.common.pojo.constant.BizParamConstant; +//import com.njcn.prepare.harmonic.api.newalgorithm.PmsStatisticsSpecialMonitorFeignClient; +//import com.njcn.prepare.harmonic.pojo.param.LineParam; +//import com.njcn.system.timer.TimerTaskRunner; +//import lombok.RequiredArgsConstructor; +//import lombok.extern.slf4j.Slf4j; +//import org.springframework.stereotype.Component; +// +//import java.text.SimpleDateFormat; +//import java.time.LocalDateTime; +//import java.util.Calendar; +//import java.util.Date; +//import java.util.Objects; +// +///** +// * 类的介绍：专项分析-台账统计定时任务 +// * +// * @author xuyang +// * @version 1.0.0 +// * @createTime 2023/12/08 11:23 +// */ +//@Component +//@RequiredArgsConstructor +//@Slf4j +//public class PmsStatisticsSpecialMonitorTaskRunner implements TimerTaskRunner { +// +// private final PmsStatisticsSpecialMonitorFeignClient pmsStatisticsSpecialMonitorFeignClient; +// +// @Override +// public void action() { +// log.info(LocalDateTime.now()+"专项分析-台账统计调度开始"); +// LineParam lineParam = new LineParam(); +// lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_MONTH)); +// lineParam.setDataDate(this.prepareTimeDeal(BizParamConstant.STAT_BIZ_MONTH)); +// this.commDefineDate(BizParamConstant.STAT_BIZ_MONTH,lineParam); +// pmsStatisticsSpecialMonitorFeignClient.pmsStatisticsSpecialMonitorHandler(lineParam); +// } +// +// public String prepareTimeDeal(String command) { +// if (StrUtil.isBlank(command)) { +// log.error(LocalDateTime.now() + "xxl调度任务参数未设置"); +// return null; +// } +// SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); +// Calendar calendar = Calendar.getInstance(); +// if (Objects.equals(BizParamConstant.STAT_BIZ_DAY, command)) { +// calendar.add(Calendar.DAY_OF_MONTH, -1); +// } else if (Objects.equals(BizParamConstant.STAT_BIZ_MONTH, command)) { +// calendar.set(Calendar.DAY_OF_MONTH, 1); +// } else if (Objects.equals(BizParamConstant.STAT_BIZ_QUARTER, command)) { +// int nowMonth = calendar.get(Calendar.MONTH); +// calendar.set(Calendar.MONTH, nowMonth - (nowMonth % 3)); +// calendar.set(Calendar.DAY_OF_MONTH, 1); +// calendar.set(Calendar.HOUR_OF_DAY, 0); +// calendar.set(Calendar.MINUTE, 0); +// calendar.set(Calendar.SECOND, 0); +// calendar.set(Calendar.MILLISECOND, 0); +// } else if (Objects.equals(BizParamConstant.STAT_BIZ_YEAR, command)) { +// calendar.set(Calendar.DAY_OF_YEAR, 1); +// } +// log.info("job调度时间:" + sdf.format(calendar.getTime())); +// return sdf.format(calendar.getTime()); +// } +// +// /** +// * 根据xxl-job的参数，生成一个任务的起始时间和结束时间 +// * +// * @author cdf +// * @date 2023/9/20 +// */ +// public void commDefineDate(String command, LineParam lineParam) { +// SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); +// String begin; +// String end; +// Calendar calendar = Calendar.getInstance(); +// calendar.add(Calendar.DAY_OF_MONTH, -1); +// Date temDate = calendar.getTime(); +// switch (command) { +// case BizParamConstant.STAT_BIZ_DAY: +// begin = sdf.format(DateUtil.beginOfDay(temDate)); +// end = sdf.format(DateUtil.endOfDay(temDate)); +// break; +// case BizParamConstant.STAT_BIZ_WEEK: +// begin = sdf.format(DateUtil.beginOfWeek(temDate)); +// end = sdf.format(DateUtil.endOfWeek(temDate)); +// break; +// case BizParamConstant.STAT_BIZ_MONTH: +// begin = sdf.format(DateUtil.beginOfMonth(temDate)); +// end = sdf.format(DateUtil.endOfMonth(temDate)); +// break; +// case BizParamConstant.STAT_BIZ_QUARTER: +// begin = sdf.format(DateUtil.beginOfQuarter(temDate)); +// end = sdf.format(DateUtil.endOfQuarter(temDate)); +// break; +// case BizParamConstant.STAT_BIZ_YEAR: +// begin = sdf.format(DateUtil.beginOfYear(temDate)); +// end = sdf.format(DateUtil.endOfYear(temDate)); +// break; +// default: +// begin = sdf.format(DateUtil.beginOfDay(temDate)); +// end = sdf.format(DateUtil.endOfDay(temDate)); +// break; +// } +// lineParam.setBeginTime(begin); +// lineParam.setEndTime(end); +// lineParam.setDataDate(begin.substring(0, 10)); +// } +// +//} diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/RMpEmissionTaskRunner.java b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/RMpEmissionTaskRunner.java index 2eb98d7b1..41450380c 100644 --- a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/RMpEmissionTaskRunner.java +++ b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/RMpEmissionTaskRunner.java @@ -1,113 +1,113 @@ -package com.njcn.system.timer.tasks; - -import cn.hutool.core.date.DateUtil; -import cn.hutool.core.util.StrUtil; -import com.njcn.common.pojo.constant.BizParamConstant; -import com.njcn.prepare.harmonic.api.newalgorithm.RMpEmissionFeignClient; -import com.njcn.prepare.harmonic.pojo.param.LineParam; -import com.njcn.system.timer.TimerTaskRunner; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; -import org.springframework.stereotype.Component; - -import java.text.SimpleDateFormat; -import java.time.LocalDateTime; -import java.util.Calendar; -import java.util.Date; -import java.util.Objects; - -/** - * 类的介绍：发射特性定时任务 - * - * @author xuyang - * @version 1.0.0 - * @createTime 2023/12/20 13:55 - */ -@Component -@RequiredArgsConstructor -@Slf4j -public class RMpEmissionTaskRunner implements TimerTaskRunner { - - private final RMpEmissionFeignClient rMpEmissionFeignClient; - - @Override - public void action() { - log.info(LocalDateTime.now()+"发射特性调度开始"); - LineParam lineParam = new LineParam(); - lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_MONTH)); - lineParam.setDataDate(this.prepareTimeDeal(BizParamConstant.STAT_BIZ_MONTH)); - this.commDefineDate(BizParamConstant.STAT_BIZ_MONTH,lineParam); - rMpEmissionFeignClient.rMpEmissionMHandler(lineParam); - } - - public String prepareTimeDeal(String command) { - if (StrUtil.isBlank(command)) { - log.error(LocalDateTime.now() + "xxl调度任务参数未设置"); - return null; - } - SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); - Calendar calendar = Calendar.getInstance(); - if (Objects.equals(BizParamConstant.STAT_BIZ_DAY, command)) { - calendar.add(Calendar.DAY_OF_MONTH, -1); - } else if (Objects.equals(BizParamConstant.STAT_BIZ_MONTH, command)) { - calendar.set(Calendar.DAY_OF_MONTH, 1); - } else if (Objects.equals(BizParamConstant.STAT_BIZ_QUARTER, command)) { - int nowMonth = calendar.get(Calendar.MONTH); - calendar.set(Calendar.MONTH, nowMonth - (nowMonth % 3)); - calendar.set(Calendar.DAY_OF_MONTH, 1); - calendar.set(Calendar.HOUR_OF_DAY, 0); - calendar.set(Calendar.MINUTE, 0); - calendar.set(Calendar.SECOND, 0); - calendar.set(Calendar.MILLISECOND, 0); - } else if (Objects.equals(BizParamConstant.STAT_BIZ_YEAR, command)) { - calendar.set(Calendar.DAY_OF_YEAR, 1); - } - log.info("job调度时间:" + sdf.format(calendar.getTime())); - return sdf.format(calendar.getTime()); - } - - /** - * 根据xxl-job的参数，生成一个任务的起始时间和结束时间 - * - * @author cdf - * @date 2023/9/20 - */ - public void commDefineDate(String command, LineParam lineParam) { - SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); - String begin; - String end; - Calendar calendar = Calendar.getInstance(); - calendar.add(Calendar.DAY_OF_MONTH, -1); - Date temDate = calendar.getTime(); - switch (command) { - case BizParamConstant.STAT_BIZ_DAY: - begin = sdf.format(DateUtil.beginOfDay(temDate)); - end = sdf.format(DateUtil.endOfDay(temDate)); - break; - case BizParamConstant.STAT_BIZ_WEEK: - begin = sdf.format(DateUtil.beginOfWeek(temDate)); - end = sdf.format(DateUtil.endOfWeek(temDate)); - break; - case BizParamConstant.STAT_BIZ_MONTH: - begin = sdf.format(DateUtil.beginOfMonth(temDate)); - end = sdf.format(DateUtil.endOfMonth(temDate)); - break; - case BizParamConstant.STAT_BIZ_QUARTER: - begin = sdf.format(DateUtil.beginOfQuarter(temDate)); - end = sdf.format(DateUtil.endOfQuarter(temDate)); - break; - case BizParamConstant.STAT_BIZ_YEAR: - begin = sdf.format(DateUtil.beginOfYear(temDate)); - end = sdf.format(DateUtil.endOfYear(temDate)); - break; - default: - begin = sdf.format(DateUtil.beginOfDay(temDate)); - end = sdf.format(DateUtil.endOfDay(temDate)); - break; - } - lineParam.setBeginTime(begin); - lineParam.setEndTime(end); - lineParam.setDataDate(begin.substring(0, 10)); - } - -} +//package com.njcn.system.timer.tasks; +// +//import cn.hutool.core.date.DateUtil; +//import cn.hutool.core.util.StrUtil; +//import com.njcn.common.pojo.constant.BizParamConstant; +//import com.njcn.prepare.harmonic.api.newalgorithm.RMpEmissionFeignClient; +//import com.njcn.prepare.harmonic.pojo.param.LineParam; +//import com.njcn.system.timer.TimerTaskRunner; +//import lombok.RequiredArgsConstructor; +//import lombok.extern.slf4j.Slf4j; +//import org.springframework.stereotype.Component; +// +//import java.text.SimpleDateFormat; +//import java.time.LocalDateTime; +//import java.util.Calendar; +//import java.util.Date; +//import java.util.Objects; +// +///** +// * 类的介绍：发射特性定时任务 +// * +// * @author xuyang +// * @version 1.0.0 +// * @createTime 2023/12/20 13:55 +// */ +//@Component +//@RequiredArgsConstructor +//@Slf4j +//public class RMpEmissionTaskRunner implements TimerTaskRunner { +// +// private final RMpEmissionFeignClient rMpEmissionFeignClient; +// +// @Override +// public void action() { +// log.info(LocalDateTime.now()+"发射特性调度开始"); +// LineParam lineParam = new LineParam(); +// lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_MONTH)); +// lineParam.setDataDate(this.prepareTimeDeal(BizParamConstant.STAT_BIZ_MONTH)); +// this.commDefineDate(BizParamConstant.STAT_BIZ_MONTH,lineParam); +// rMpEmissionFeignClient.rMpEmissionMHandler(lineParam); +// } +// +// public String prepareTimeDeal(String command) { +// if (StrUtil.isBlank(command)) { +// log.error(LocalDateTime.now() + "xxl调度任务参数未设置"); +// return null; +// } +// SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); +// Calendar calendar = Calendar.getInstance(); +// if (Objects.equals(BizParamConstant.STAT_BIZ_DAY, command)) { +// calendar.add(Calendar.DAY_OF_MONTH, -1); +// } else if (Objects.equals(BizParamConstant.STAT_BIZ_MONTH, command)) { +// calendar.set(Calendar.DAY_OF_MONTH, 1); +// } else if (Objects.equals(BizParamConstant.STAT_BIZ_QUARTER, command)) { +// int nowMonth = calendar.get(Calendar.MONTH); +// calendar.set(Calendar.MONTH, nowMonth - (nowMonth % 3)); +// calendar.set(Calendar.DAY_OF_MONTH, 1); +// calendar.set(Calendar.HOUR_OF_DAY, 0); +// calendar.set(Calendar.MINUTE, 0); +// calendar.set(Calendar.SECOND, 0); +// calendar.set(Calendar.MILLISECOND, 0); +// } else if (Objects.equals(BizParamConstant.STAT_BIZ_YEAR, command)) { +// calendar.set(Calendar.DAY_OF_YEAR, 1); +// } +// log.info("job调度时间:" + sdf.format(calendar.getTime())); +// return sdf.format(calendar.getTime()); +// } +// +// /** +// * 根据xxl-job的参数，生成一个任务的起始时间和结束时间 +// * +// * @author cdf +// * @date 2023/9/20 +// */ +// public void commDefineDate(String command, LineParam lineParam) { +// SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); +// String begin; +// String end; +// Calendar calendar = Calendar.getInstance(); +// calendar.add(Calendar.DAY_OF_MONTH, -1); +// Date temDate = calendar.getTime(); +// switch (command) { +// case BizParamConstant.STAT_BIZ_DAY: +// begin = sdf.format(DateUtil.beginOfDay(temDate)); +// end = sdf.format(DateUtil.endOfDay(temDate)); +// break; +// case BizParamConstant.STAT_BIZ_WEEK: +// begin = sdf.format(DateUtil.beginOfWeek(temDate)); +// end = sdf.format(DateUtil.endOfWeek(temDate)); +// break; +// case BizParamConstant.STAT_BIZ_MONTH: +// begin = sdf.format(DateUtil.beginOfMonth(temDate)); +// end = sdf.format(DateUtil.endOfMonth(temDate)); +// break; +// case BizParamConstant.STAT_BIZ_QUARTER: +// begin = sdf.format(DateUtil.beginOfQuarter(temDate)); +// end = sdf.format(DateUtil.endOfQuarter(temDate)); +// break; +// case BizParamConstant.STAT_BIZ_YEAR: +// begin = sdf.format(DateUtil.beginOfYear(temDate)); +// end = sdf.format(DateUtil.endOfYear(temDate)); +// break; +// default: +// begin = sdf.format(DateUtil.beginOfDay(temDate)); +// end = sdf.format(DateUtil.endOfDay(temDate)); +// break; +// } +// lineParam.setBeginTime(begin); +// lineParam.setEndTime(end); +// lineParam.setDataDate(begin.substring(0, 10)); +// } +// +//} diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/RMpInfluenceTaskRunner.java b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/RMpInfluenceTaskRunner.java index 0220bffd7..d83f1f368 100644 --- a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/RMpInfluenceTaskRunner.java +++ b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/RMpInfluenceTaskRunner.java @@ -1,113 +1,113 @@ -package com.njcn.system.timer.tasks; - -import cn.hutool.core.date.DateUtil; -import cn.hutool.core.util.StrUtil; -import com.njcn.common.pojo.constant.BizParamConstant; -import com.njcn.prepare.harmonic.api.newalgorithm.RMpInfluenceFeignClient; -import com.njcn.prepare.harmonic.pojo.param.LineParam; -import com.njcn.system.timer.TimerTaskRunner; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; -import org.springframework.stereotype.Component; - -import java.text.SimpleDateFormat; -import java.time.LocalDateTime; -import java.util.Calendar; -import java.util.Date; -import java.util.Objects; - -/** - * 类的介绍： - * - * @author xuyang - * @version 1.0.0 - * @createTime 2023/12/20 14:12 - */ -@Component -@RequiredArgsConstructor -@Slf4j -public class RMpInfluenceTaskRunner implements TimerTaskRunner { - - private final RMpInfluenceFeignClient rMpInfluenceFeignClient; - - @Override - public void action() { - log.info(LocalDateTime.now()+"影响特性调度开始"); - LineParam lineParam = new LineParam(); - lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_MONTH)); - lineParam.setDataDate(this.prepareTimeDeal(BizParamConstant.STAT_BIZ_MONTH)); - this.commDefineDate(BizParamConstant.STAT_BIZ_MONTH,lineParam); - rMpInfluenceFeignClient.rMpInfluenceMHandler(lineParam); - } - - public String prepareTimeDeal(String command) { - if (StrUtil.isBlank(command)) { - log.error(LocalDateTime.now() + "xxl调度任务参数未设置"); - return null; - } - SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); - Calendar calendar = Calendar.getInstance(); - if (Objects.equals(BizParamConstant.STAT_BIZ_DAY, command)) { - calendar.add(Calendar.DAY_OF_MONTH, -1); - } else if (Objects.equals(BizParamConstant.STAT_BIZ_MONTH, command)) { - calendar.set(Calendar.DAY_OF_MONTH, 1); - } else if (Objects.equals(BizParamConstant.STAT_BIZ_QUARTER, command)) { - int nowMonth = calendar.get(Calendar.MONTH); - calendar.set(Calendar.MONTH, nowMonth - (nowMonth % 3)); - calendar.set(Calendar.DAY_OF_MONTH, 1); - calendar.set(Calendar.HOUR_OF_DAY, 0); - calendar.set(Calendar.MINUTE, 0); - calendar.set(Calendar.SECOND, 0); - calendar.set(Calendar.MILLISECOND, 0); - } else if (Objects.equals(BizParamConstant.STAT_BIZ_YEAR, command)) { - calendar.set(Calendar.DAY_OF_YEAR, 1); - } - log.info("job调度时间:" + sdf.format(calendar.getTime())); - return sdf.format(calendar.getTime()); - } - - /** - * 根据xxl-job的参数，生成一个任务的起始时间和结束时间 - * - * @author cdf - * @date 2023/9/20 - */ - public void commDefineDate(String command, LineParam lineParam) { - SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); - String begin; - String end; - Calendar calendar = Calendar.getInstance(); - calendar.add(Calendar.DAY_OF_MONTH, -1); - Date temDate = calendar.getTime(); - switch (command) { - case BizParamConstant.STAT_BIZ_DAY: - begin = sdf.format(DateUtil.beginOfDay(temDate)); - end = sdf.format(DateUtil.endOfDay(temDate)); - break; - case BizParamConstant.STAT_BIZ_WEEK: - begin = sdf.format(DateUtil.beginOfWeek(temDate)); - end = sdf.format(DateUtil.endOfWeek(temDate)); - break; - case BizParamConstant.STAT_BIZ_MONTH: - begin = sdf.format(DateUtil.beginOfMonth(temDate)); - end = sdf.format(DateUtil.endOfMonth(temDate)); - break; - case BizParamConstant.STAT_BIZ_QUARTER: - begin = sdf.format(DateUtil.beginOfQuarter(temDate)); - end = sdf.format(DateUtil.endOfQuarter(temDate)); - break; - case BizParamConstant.STAT_BIZ_YEAR: - begin = sdf.format(DateUtil.beginOfYear(temDate)); - end = sdf.format(DateUtil.endOfYear(temDate)); - break; - default: - begin = sdf.format(DateUtil.beginOfDay(temDate)); - end = sdf.format(DateUtil.endOfDay(temDate)); - break; - } - lineParam.setBeginTime(begin); - lineParam.setEndTime(end); - lineParam.setDataDate(begin.substring(0, 10)); - } - -} +//package com.njcn.system.timer.tasks; +// +//import cn.hutool.core.date.DateUtil; +//import cn.hutool.core.util.StrUtil; +//import com.njcn.common.pojo.constant.BizParamConstant; +//import com.njcn.prepare.harmonic.api.newalgorithm.RMpInfluenceFeignClient; +//import com.njcn.prepare.harmonic.pojo.param.LineParam; +//import com.njcn.system.timer.TimerTaskRunner; +//import lombok.RequiredArgsConstructor; +//import lombok.extern.slf4j.Slf4j; +//import org.springframework.stereotype.Component; +// +//import java.text.SimpleDateFormat; +//import java.time.LocalDateTime; +//import java.util.Calendar; +//import java.util.Date; +//import java.util.Objects; +// +///** +// * 类的介绍： +// * +// * @author xuyang +// * @version 1.0.0 +// * @createTime 2023/12/20 14:12 +// */ +//@Component +//@RequiredArgsConstructor +//@Slf4j +//public class RMpInfluenceTaskRunner implements TimerTaskRunner { +// +// private final RMpInfluenceFeignClient rMpInfluenceFeignClient; +// +// @Override +// public void action() { +// log.info(LocalDateTime.now()+"影响特性调度开始"); +// LineParam lineParam = new LineParam(); +// lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_MONTH)); +// lineParam.setDataDate(this.prepareTimeDeal(BizParamConstant.STAT_BIZ_MONTH)); +// this.commDefineDate(BizParamConstant.STAT_BIZ_MONTH,lineParam); +// rMpInfluenceFeignClient.rMpInfluenceMHandler(lineParam); +// } +// +// public String prepareTimeDeal(String command) { +// if (StrUtil.isBlank(command)) { +// log.error(LocalDateTime.now() + "xxl调度任务参数未设置"); +// return null; +// } +// SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); +// Calendar calendar = Calendar.getInstance(); +// if (Objects.equals(BizParamConstant.STAT_BIZ_DAY, command)) { +// calendar.add(Calendar.DAY_OF_MONTH, -1); +// } else if (Objects.equals(BizParamConstant.STAT_BIZ_MONTH, command)) { +// calendar.set(Calendar.DAY_OF_MONTH, 1); +// } else if (Objects.equals(BizParamConstant.STAT_BIZ_QUARTER, command)) { +// int nowMonth = calendar.get(Calendar.MONTH); +// calendar.set(Calendar.MONTH, nowMonth - (nowMonth % 3)); +// calendar.set(Calendar.DAY_OF_MONTH, 1); +// calendar.set(Calendar.HOUR_OF_DAY, 0); +// calendar.set(Calendar.MINUTE, 0); +// calendar.set(Calendar.SECOND, 0); +// calendar.set(Calendar.MILLISECOND, 0); +// } else if (Objects.equals(BizParamConstant.STAT_BIZ_YEAR, command)) { +// calendar.set(Calendar.DAY_OF_YEAR, 1); +// } +// log.info("job调度时间:" + sdf.format(calendar.getTime())); +// return sdf.format(calendar.getTime()); +// } +// +// /** +// * 根据xxl-job的参数，生成一个任务的起始时间和结束时间 +// * +// * @author cdf +// * @date 2023/9/20 +// */ +// public void commDefineDate(String command, LineParam lineParam) { +// SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); +// String begin; +// String end; +// Calendar calendar = Calendar.getInstance(); +// calendar.add(Calendar.DAY_OF_MONTH, -1); +// Date temDate = calendar.getTime(); +// switch (command) { +// case BizParamConstant.STAT_BIZ_DAY: +// begin = sdf.format(DateUtil.beginOfDay(temDate)); +// end = sdf.format(DateUtil.endOfDay(temDate)); +// break; +// case BizParamConstant.STAT_BIZ_WEEK: +// begin = sdf.format(DateUtil.beginOfWeek(temDate)); +// end = sdf.format(DateUtil.endOfWeek(temDate)); +// break; +// case BizParamConstant.STAT_BIZ_MONTH: +// begin = sdf.format(DateUtil.beginOfMonth(temDate)); +// end = sdf.format(DateUtil.endOfMonth(temDate)); +// break; +// case BizParamConstant.STAT_BIZ_QUARTER: +// begin = sdf.format(DateUtil.beginOfQuarter(temDate)); +// end = sdf.format(DateUtil.endOfQuarter(temDate)); +// break; +// case BizParamConstant.STAT_BIZ_YEAR: +// begin = sdf.format(DateUtil.beginOfYear(temDate)); +// end = sdf.format(DateUtil.endOfYear(temDate)); +// break; +// default: +// begin = sdf.format(DateUtil.beginOfDay(temDate)); +// end = sdf.format(DateUtil.endOfDay(temDate)); +// break; +// } +// lineParam.setBeginTime(begin); +// lineParam.setEndTime(end); +// lineParam.setDataDate(begin.substring(0, 10)); +// } +// +//} diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/StatisticReportTaskRunner.java b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/StatisticReportTaskRunner.java index c9e05ad70..a0ae8b3f4 100644 --- a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/StatisticReportTaskRunner.java +++ b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/StatisticReportTaskRunner.java @@ -1,32 +1,32 @@ -package com.njcn.system.timer.tasks; - -import com.njcn.process.api.SupvStatisticReportMFeignClient; -import com.njcn.system.timer.TimerTaskRunner; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; -import org.springframework.stereotype.Component; - -import java.time.LocalDate; -import java.time.LocalDateTime; -import java.time.format.DateTimeFormatter; - -/** - * 类的介绍：第二技术监督月上送报告统计-定时任务 - * - * @author xuyang - * @version 1.0.0 - * @createTime 2023/12/08 11:35 - */ -@Component -@RequiredArgsConstructor -@Slf4j -public class StatisticReportTaskRunner implements TimerTaskRunner { - private final SupvStatisticReportMFeignClient supvStatisticReportMFeignClient; - - @Override - public void action() { - log.info(LocalDateTime.now()+"技术监督计划问题月报统计调用成功"); - LocalDate yesterday = LocalDate.now().plusDays(-1); - supvStatisticReportMFeignClient.statisticReport(yesterday.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))); - } -} +//package com.njcn.system.timer.tasks; +// +//import com.njcn.process.api.SupvStatisticReportMFeignClient; +//import com.njcn.system.timer.TimerTaskRunner; +//import lombok.RequiredArgsConstructor; +//import lombok.extern.slf4j.Slf4j; +//import org.springframework.stereotype.Component; +// +//import java.time.LocalDate; +//import java.time.LocalDateTime; +//import java.time.format.DateTimeFormatter; +// +///** +// * 类的介绍：第二技术监督月上送报告统计-定时任务 +// * +// * @author xuyang +// * @version 1.0.0 +// * @createTime 2023/12/08 11:35 +// */ +//@Component +//@RequiredArgsConstructor +//@Slf4j +//public class StatisticReportTaskRunner implements TimerTaskRunner { +// private final SupvStatisticReportMFeignClient supvStatisticReportMFeignClient; +// +// @Override +// public void action() { +// log.info(LocalDateTime.now()+"技术监督计划问题月报统计调用成功"); +// LocalDate yesterday = LocalDate.now().plusDays(-1); +// supvStatisticReportMFeignClient.statisticReport(yesterday.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))); +// } +//} 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 0979defd2..270e1a549 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,32 +1,32 @@ -package com.njcn.system.timer.tasks; - -import cn.hutool.core.date.DatePattern; -import cn.hutool.core.date.DateUtil; -import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient; -import com.njcn.prepare.harmonic.pojo.bo.BaseParam; -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 LiteFlowFeignClient liteFlowFeignClient; - - @Override - public void action() { - BaseParam baseParam = new BaseParam(); - baseParam.setFullChain(true); - baseParam.setRepair(false); - baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN)); - liteFlowFeignClient.substationExecutor(baseParam); - } -} +//package com.njcn.system.timer.tasks; +// +//import cn.hutool.core.date.DatePattern; +//import cn.hutool.core.date.DateUtil; +//import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient; +//import com.njcn.prepare.harmonic.pojo.bo.BaseParam; +//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 LiteFlowFeignClient liteFlowFeignClient; +// +// @Override +// public void action() { +// BaseParam baseParam = new BaseParam(); +// baseParam.setFullChain(true); +// baseParam.setRepair(false); +// baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN)); +// liteFlowFeignClient.substationExecutor(baseParam); +// } +//} diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/UploadGwTaskRunner.java b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/UploadGwTaskRunner.java index 0ebb82eab..79afa7b25 100644 --- a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/UploadGwTaskRunner.java +++ b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/UploadGwTaskRunner.java @@ -1,32 +1,32 @@ -package com.njcn.system.timer.tasks; - -import cn.hutool.core.date.DatePattern; -import cn.hutool.core.date.DateUtil; -import com.njcn.harmonic.api.UploadGwDataFeignClient; -import com.njcn.harmonic.pojo.param.UploadParam; -import com.njcn.system.timer.TimerTaskRunner; -import lombok.RequiredArgsConstructor; -import org.springframework.stereotype.Component; - -/** - * 类的介绍：国网数据每日上送定时任务 - * - * @author xuyang - * @version 1.0.0 - * @createTime 2023/12/15 13:45 - */ -@Component -@RequiredArgsConstructor -public class UploadGwTaskRunner implements TimerTaskRunner { - - private final UploadGwDataFeignClient uploadGwDataFeignClient; - - @Override - public void action() { - UploadParam param = new UploadParam(); - param.setTime(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN)); - uploadGwDataFeignClient.uploadPointStatisticalData(param); - uploadGwDataFeignClient.uploadSubstationStatisticalData(param); - uploadGwDataFeignClient.uploadEvaluationData(param); - } -} +//package com.njcn.system.timer.tasks; +// +//import cn.hutool.core.date.DatePattern; +//import cn.hutool.core.date.DateUtil; +//import com.njcn.harmonic.api.UploadGwDataFeignClient; +//import com.njcn.harmonic.pojo.param.UploadParam; +//import com.njcn.system.timer.TimerTaskRunner; +//import lombok.RequiredArgsConstructor; +//import org.springframework.stereotype.Component; +// +///** +// * 类的介绍：国网数据每日上送定时任务 +// * +// * @author xuyang +// * @version 1.0.0 +// * @createTime 2023/12/15 13:45 +// */ +//@Component +//@RequiredArgsConstructor +//public class UploadGwTaskRunner implements TimerTaskRunner { +// +// private final UploadGwDataFeignClient uploadGwDataFeignClient; +// +// @Override +// public void action() { +// UploadParam param = new UploadParam(); +// param.setTime(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN)); +// uploadGwDataFeignClient.uploadPointStatisticalData(param); +// uploadGwDataFeignClient.uploadSubstationStatisticalData(param); +// uploadGwDataFeignClient.uploadEvaluationData(param); +// } +//} diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/specialAnalysisIndexOverviewTaskRunner.java b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/specialAnalysisIndexOverviewTaskRunner.java index f51749985..11c54218c 100644 --- a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/specialAnalysisIndexOverviewTaskRunner.java +++ b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/specialAnalysisIndexOverviewTaskRunner.java @@ -1,113 +1,113 @@ -package com.njcn.system.timer.tasks; - -import cn.hutool.core.date.DateUtil; -import cn.hutool.core.util.StrUtil; -import com.njcn.common.pojo.constant.BizParamConstant; -import com.njcn.prepare.harmonic.api.specialanalysis.SpecialAnalysisFeignClient; -import com.njcn.prepare.harmonic.pojo.param.LineParam; -import com.njcn.system.timer.TimerTaskRunner; -import lombok.RequiredArgsConstructor; -import lombok.extern.slf4j.Slf4j; -import org.springframework.stereotype.Component; - -import java.text.SimpleDateFormat; -import java.time.LocalDateTime; -import java.util.Calendar; -import java.util.Date; -import java.util.Objects; - -/** - * 类的介绍： - * - * @author xuyang - * @version 1.0.0 - * @createTime 2023/12/20 14:15 - */ -@Component -@RequiredArgsConstructor -@Slf4j -public class specialAnalysisIndexOverviewTaskRunner implements TimerTaskRunner { - - private final SpecialAnalysisFeignClient specialAnalysisFeignClient; - - @Override - public void action() { - log.info(LocalDateTime.now()+"专项分析-指标总览开始执行"); - LineParam lineParam = new LineParam(); - lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_MONTH)); - lineParam.setDataDate(this.prepareTimeDeal(BizParamConstant.STAT_BIZ_MONTH)); - this.commDefineDate(BizParamConstant.STAT_BIZ_MONTH,lineParam); - specialAnalysisFeignClient.hanlder(lineParam); - } - - public String prepareTimeDeal(String command) { - if (StrUtil.isBlank(command)) { - log.error(LocalDateTime.now() + "xxl调度任务参数未设置"); - return null; - } - SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); - Calendar calendar = Calendar.getInstance(); - if (Objects.equals(BizParamConstant.STAT_BIZ_DAY, command)) { - calendar.add(Calendar.DAY_OF_MONTH, -1); - } else if (Objects.equals(BizParamConstant.STAT_BIZ_MONTH, command)) { - calendar.set(Calendar.DAY_OF_MONTH, 1); - } else if (Objects.equals(BizParamConstant.STAT_BIZ_QUARTER, command)) { - int nowMonth = calendar.get(Calendar.MONTH); - calendar.set(Calendar.MONTH, nowMonth - (nowMonth % 3)); - calendar.set(Calendar.DAY_OF_MONTH, 1); - calendar.set(Calendar.HOUR_OF_DAY, 0); - calendar.set(Calendar.MINUTE, 0); - calendar.set(Calendar.SECOND, 0); - calendar.set(Calendar.MILLISECOND, 0); - } else if (Objects.equals(BizParamConstant.STAT_BIZ_YEAR, command)) { - calendar.set(Calendar.DAY_OF_YEAR, 1); - } - log.info("job调度时间:" + sdf.format(calendar.getTime())); - return sdf.format(calendar.getTime()); - } - - /** - * 根据xxl-job的参数，生成一个任务的起始时间和结束时间 - * - * @author cdf - * @date 2023/9/20 - */ - public void commDefineDate(String command, LineParam lineParam) { - SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); - String begin; - String end; - Calendar calendar = Calendar.getInstance(); - calendar.add(Calendar.DAY_OF_MONTH, -1); - Date temDate = calendar.getTime(); - switch (command) { - case BizParamConstant.STAT_BIZ_DAY: - begin = sdf.format(DateUtil.beginOfDay(temDate)); - end = sdf.format(DateUtil.endOfDay(temDate)); - break; - case BizParamConstant.STAT_BIZ_WEEK: - begin = sdf.format(DateUtil.beginOfWeek(temDate)); - end = sdf.format(DateUtil.endOfWeek(temDate)); - break; - case BizParamConstant.STAT_BIZ_MONTH: - begin = sdf.format(DateUtil.beginOfMonth(temDate)); - end = sdf.format(DateUtil.endOfMonth(temDate)); - break; - case BizParamConstant.STAT_BIZ_QUARTER: - begin = sdf.format(DateUtil.beginOfQuarter(temDate)); - end = sdf.format(DateUtil.endOfQuarter(temDate)); - break; - case BizParamConstant.STAT_BIZ_YEAR: - begin = sdf.format(DateUtil.beginOfYear(temDate)); - end = sdf.format(DateUtil.endOfYear(temDate)); - break; - default: - begin = sdf.format(DateUtil.beginOfDay(temDate)); - end = sdf.format(DateUtil.endOfDay(temDate)); - break; - } - lineParam.setBeginTime(begin); - lineParam.setEndTime(end); - lineParam.setDataDate(begin.substring(0, 10)); - } - -} +//package com.njcn.system.timer.tasks; +// +//import cn.hutool.core.date.DateUtil; +//import cn.hutool.core.util.StrUtil; +//import com.njcn.common.pojo.constant.BizParamConstant; +//import com.njcn.prepare.harmonic.api.specialanalysis.SpecialAnalysisFeignClient; +//import com.njcn.prepare.harmonic.pojo.param.LineParam; +//import com.njcn.system.timer.TimerTaskRunner; +//import lombok.RequiredArgsConstructor; +//import lombok.extern.slf4j.Slf4j; +//import org.springframework.stereotype.Component; +// +//import java.text.SimpleDateFormat; +//import java.time.LocalDateTime; +//import java.util.Calendar; +//import java.util.Date; +//import java.util.Objects; +// +///** +// * 类的介绍： +// * +// * @author xuyang +// * @version 1.0.0 +// * @createTime 2023/12/20 14:15 +// */ +//@Component +//@RequiredArgsConstructor +//@Slf4j +//public class specialAnalysisIndexOverviewTaskRunner implements TimerTaskRunner { +// +// private final SpecialAnalysisFeignClient specialAnalysisFeignClient; +// +// @Override +// public void action() { +// log.info(LocalDateTime.now()+"专项分析-指标总览开始执行"); +// LineParam lineParam = new LineParam(); +// lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_MONTH)); +// lineParam.setDataDate(this.prepareTimeDeal(BizParamConstant.STAT_BIZ_MONTH)); +// this.commDefineDate(BizParamConstant.STAT_BIZ_MONTH,lineParam); +// specialAnalysisFeignClient.hanlder(lineParam); +// } +// +// public String prepareTimeDeal(String command) { +// if (StrUtil.isBlank(command)) { +// log.error(LocalDateTime.now() + "xxl调度任务参数未设置"); +// return null; +// } +// SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); +// Calendar calendar = Calendar.getInstance(); +// if (Objects.equals(BizParamConstant.STAT_BIZ_DAY, command)) { +// calendar.add(Calendar.DAY_OF_MONTH, -1); +// } else if (Objects.equals(BizParamConstant.STAT_BIZ_MONTH, command)) { +// calendar.set(Calendar.DAY_OF_MONTH, 1); +// } else if (Objects.equals(BizParamConstant.STAT_BIZ_QUARTER, command)) { +// int nowMonth = calendar.get(Calendar.MONTH); +// calendar.set(Calendar.MONTH, nowMonth - (nowMonth % 3)); +// calendar.set(Calendar.DAY_OF_MONTH, 1); +// calendar.set(Calendar.HOUR_OF_DAY, 0); +// calendar.set(Calendar.MINUTE, 0); +// calendar.set(Calendar.SECOND, 0); +// calendar.set(Calendar.MILLISECOND, 0); +// } else if (Objects.equals(BizParamConstant.STAT_BIZ_YEAR, command)) { +// calendar.set(Calendar.DAY_OF_YEAR, 1); +// } +// log.info("job调度时间:" + sdf.format(calendar.getTime())); +// return sdf.format(calendar.getTime()); +// } +// +// /** +// * 根据xxl-job的参数，生成一个任务的起始时间和结束时间 +// * +// * @author cdf +// * @date 2023/9/20 +// */ +// public void commDefineDate(String command, LineParam lineParam) { +// SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); +// String begin; +// String end; +// Calendar calendar = Calendar.getInstance(); +// calendar.add(Calendar.DAY_OF_MONTH, -1); +// Date temDate = calendar.getTime(); +// switch (command) { +// case BizParamConstant.STAT_BIZ_DAY: +// begin = sdf.format(DateUtil.beginOfDay(temDate)); +// end = sdf.format(DateUtil.endOfDay(temDate)); +// break; +// case BizParamConstant.STAT_BIZ_WEEK: +// begin = sdf.format(DateUtil.beginOfWeek(temDate)); +// end = sdf.format(DateUtil.endOfWeek(temDate)); +// break; +// case BizParamConstant.STAT_BIZ_MONTH: +// begin = sdf.format(DateUtil.beginOfMonth(temDate)); +// end = sdf.format(DateUtil.endOfMonth(temDate)); +// break; +// case BizParamConstant.STAT_BIZ_QUARTER: +// begin = sdf.format(DateUtil.beginOfQuarter(temDate)); +// end = sdf.format(DateUtil.endOfQuarter(temDate)); +// break; +// case BizParamConstant.STAT_BIZ_YEAR: +// begin = sdf.format(DateUtil.beginOfYear(temDate)); +// end = sdf.format(DateUtil.endOfYear(temDate)); +// break; +// default: +// begin = sdf.format(DateUtil.beginOfDay(temDate)); +// end = sdf.format(DateUtil.endOfDay(temDate)); +// break; +// } +// lineParam.setBeginTime(begin); +// lineParam.setEndTime(end); +// lineParam.setDataDate(begin.substring(0, 10)); +// } +// +//}