From 7b60549deb5ccc97a0b8021e17b92434c194286f Mon Sep 17 00:00:00 2001 From: xuyang <748613696@qq.com> Date: Wed, 3 Jan 2024 13:40:01 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BB=A3=E7=A0=81=E6=81=A2=E5=A4=8D?= 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 081e345ac..12ce7090d 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 03263b0e6..d29e1da06 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 2f844f68c..8ab887a42 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 c57692193..9022489d2 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 b4a8d56ac..1f7d84b97 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 8d7275838..1480c9396 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 9b0b6cfac..18e4813e1 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 e0ee88a33..8a140f32f 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 e33949b99..71c95135b 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 41450380c..2eb98d7b1 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 d83f1f368..0220bffd7 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 a0ae8b3f4..c9e05ad70 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 270e1a549..0979defd2 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 79afa7b25..0ebb82eab 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 11c54218c..f51749985 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)); + } + +}