Microservice/pqs
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

2

Browse Source
This commit is contained in:
xuyang
2024-01-04 14:42:22 +08:00
parent fde344c710
commit 6a32c44fb6
15 changed files with 815 additions and 815 deletions
Download Patch File Download Diff File Expand all files Collapse all files

64
pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/DeviceTaskRunner.java
View File

@@ -1,32 +1,32 @@
//package com.njcn.system.timer.tasks; package com.njcn.system.timer.tasks;
//
//import cn.hutool.core.date.DatePattern; import cn.hutool.core.date.DatePattern;
//import cn.hutool.core.date.DateUtil; import cn.hutool.core.date.DateUtil;
//import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient; import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient;
//import com.njcn.prepare.harmonic.pojo.bo.BaseParam; import com.njcn.prepare.harmonic.pojo.bo.BaseParam;
//import com.njcn.system.timer.TimerTaskRunner; import com.njcn.system.timer.TimerTaskRunner;
//import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
//import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
//
///** /**
// * 类的介绍：装置算法执行链定时任务 * 类的介绍：装置算法执行链定时任务
// * *
// * @author xuyang * @author xuyang
// * @version 1.0.0 * @version 1.0.0
// * @createTime 2023/12/6 9:35 * @createTime 2023/12/6 9:35
// */ */
//@Component @Component
//@RequiredArgsConstructor @RequiredArgsConstructor
//public class DeviceTaskRunner implements TimerTaskRunner { public class DeviceTaskRunner implements TimerTaskRunner {
//
// private final LiteFlowFeignClient liteFlowFeignClient; private final LiteFlowFeignClient liteFlowFeignClient;
//
// @Override @Override
// public void action() { public void action() {
// BaseParam baseParam = new BaseParam(); BaseParam baseParam = new BaseParam();
// baseParam.setFullChain(true); baseParam.setFullChain(true);
// baseParam.setRepair(false); baseParam.setRepair(false);
// baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN)); baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN));
// liteFlowFeignClient.deviceExecutor(baseParam); liteFlowFeignClient.deviceExecutor(baseParam);
// } }
//} }

64
pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/GeneraTrixTaskRunner.java
View File

@@ -1,32 +1,32 @@
//package com.njcn.system.timer.tasks; package com.njcn.system.timer.tasks;
//
//import cn.hutool.core.date.DatePattern; import cn.hutool.core.date.DatePattern;
//import cn.hutool.core.date.DateUtil; import cn.hutool.core.date.DateUtil;
//import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient; import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient;
//import com.njcn.prepare.harmonic.pojo.bo.BaseParam; import com.njcn.prepare.harmonic.pojo.bo.BaseParam;
//import com.njcn.system.timer.TimerTaskRunner; import com.njcn.system.timer.TimerTaskRunner;
//import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
//import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
//
///** /**
// * 类的介绍：母线算法执行链定时任务 * 类的介绍：母线算法执行链定时任务
// * *
// * @author xuyang * @author xuyang
// * @version 1.0.0 * @version 1.0.0
// * @createTime 2023/12/6 9:35 * @createTime 2023/12/6 9:35
// */ */
//@Component @Component
//@RequiredArgsConstructor @RequiredArgsConstructor
//public class GeneraTrixTaskRunner implements TimerTaskRunner { public class GeneraTrixTaskRunner implements TimerTaskRunner {
//
// private final LiteFlowFeignClient liteFlowFeignClient; private final LiteFlowFeignClient liteFlowFeignClient;
//
// @Override @Override
// public void action() { public void action() {
// BaseParam baseParam = new BaseParam(); BaseParam baseParam = new BaseParam();
// baseParam.setFullChain(true); baseParam.setFullChain(true);
// baseParam.setRepair(false); baseParam.setRepair(false);
// baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN)); baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN));
// liteFlowFeignClient.generaTrixExecutor(baseParam); liteFlowFeignClient.generaTrixExecutor(baseParam);
// } }
//} }

64
pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/MeasurementTaskRunner.java
View File

@@ -1,32 +1,32 @@
//package com.njcn.system.timer.tasks; package com.njcn.system.timer.tasks;
//
//import cn.hutool.core.date.DatePattern; import cn.hutool.core.date.DatePattern;
//import cn.hutool.core.date.DateUtil; import cn.hutool.core.date.DateUtil;
//import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient; import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient;
//import com.njcn.prepare.harmonic.pojo.bo.BaseParam; import com.njcn.prepare.harmonic.pojo.bo.BaseParam;
//import com.njcn.system.timer.TimerTaskRunner; import com.njcn.system.timer.TimerTaskRunner;
//import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
//import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
//
///** /**
// * 类的介绍：监测点算法执行链定时任务 * 类的介绍：监测点算法执行链定时任务
// * *
// * @author xuyang * @author xuyang
// * @version 1.0.0 * @version 1.0.0
// * @createTime 2023/12/6 9:35 * @createTime 2023/12/6 9:35
// */ */
//@Component @Component
//@RequiredArgsConstructor @RequiredArgsConstructor
//public class MeasurementTaskRunner implements TimerTaskRunner { public class MeasurementTaskRunner implements TimerTaskRunner {
//
// private final LiteFlowFeignClient liteFlowFeignClient; private final LiteFlowFeignClient liteFlowFeignClient;
//
// @Override @Override
// public void action() { public void action() {
// BaseParam baseParam = new BaseParam(); BaseParam baseParam = new BaseParam();
// baseParam.setFullChain(true); baseParam.setFullChain(true);
// baseParam.setRepair(false); baseParam.setRepair(false);
// baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN)); baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN));
// liteFlowFeignClient.measurementPointExecutor(baseParam); liteFlowFeignClient.measurementPointExecutor(baseParam);
// } }
//} }

90
pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/MonitorSendTaskRunner.java
View File

@@ -1,45 +1,45 @@
//package com.njcn.system.timer.tasks; package com.njcn.system.timer.tasks;
//
//import com.njcn.device.pms.api.MonitorSendClient; import com.njcn.device.pms.api.MonitorSendClient;
//import com.njcn.device.pms.pojo.param.MonitorParam; import com.njcn.device.pms.pojo.param.MonitorParam;
//import com.njcn.system.service.SysDicTreePOService; import com.njcn.system.service.SysDicTreePOService;
//import com.njcn.system.timer.TimerTaskRunner; import com.njcn.system.timer.TimerTaskRunner;
//import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
//import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
//
//
///** /**
// * *
// */ */
//@Component @Component
//@RequiredArgsConstructor @RequiredArgsConstructor
//public class MonitorSendTaskRunner implements TimerTaskRunner { public class MonitorSendTaskRunner implements TimerTaskRunner {
//
// private final MonitorSendClient monitorSendClient; private final MonitorSendClient monitorSendClient;
// private final SysDicTreePOService sysDicTreePOService; private final SysDicTreePOService sysDicTreePOService;
//
//
// @Override @Override
// public void action() { public void action() {
// //风电场 //风电场
// MonitorParam.Info param = new MonitorParam.Info(); MonitorParam.Info param = new MonitorParam.Info();
// param.setObjType(sysDicTreePOService.queryByCode("1401").getId()); param.setObjType(sysDicTreePOService.queryByCode("1401").getId());
// param.setFiy(true); param.setFiy(true);
// monitorSendClient.windSend(param); monitorSendClient.windSend(param);
// //光伏电站 //光伏电站
// MonitorParam.Info param1 = new MonitorParam.Info(); MonitorParam.Info param1 = new MonitorParam.Info();
// param1.setObjType(sysDicTreePOService.queryByCode("1402").getId()); param1.setObjType(sysDicTreePOService.queryByCode("1402").getId());
// param1.setFiy(true); param1.setFiy(true);
// monitorSendClient.windSend(param1); monitorSendClient.windSend(param1);
// //牵引站 //牵引站
// MonitorParam.Info param3 = new MonitorParam.Info(); MonitorParam.Info param3 = new MonitorParam.Info();
// param3.setObjType(sysDicTreePOService.queryByCode("1300").getId()); param3.setObjType(sysDicTreePOService.queryByCode("1300").getId());
// param3.setFiy(true); param3.setFiy(true);
// monitorSendClient.windSend(param3); monitorSendClient.windSend(param3);
// //干扰用户 //干扰用户
// MonitorParam.Info param4 = new MonitorParam.Info(); MonitorParam.Info param4 = new MonitorParam.Info();
// param4.setObjType(sysDicTreePOService.queryByCode("2300").getId()); param4.setObjType(sysDicTreePOService.queryByCode("2300").getId());
// param4.setFiy(true); param4.setFiy(true);
// monitorSendClient.windSend(param4); monitorSendClient.windSend(param4);
// } }
//} }

60
pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/MonitorUserSendTaskRunner.java
View File

@@ -1,30 +1,30 @@
//package com.njcn.system.timer.tasks; package com.njcn.system.timer.tasks;
//
//import com.njcn.device.pms.api.MonitorSendClient; import com.njcn.device.pms.api.MonitorSendClient;
//import com.njcn.device.pms.pojo.param.MonitorParam; import com.njcn.device.pms.pojo.param.MonitorParam;
//import com.njcn.system.service.SysDicTreePOService; import com.njcn.system.service.SysDicTreePOService;
//import com.njcn.system.timer.TimerTaskRunner; import com.njcn.system.timer.TimerTaskRunner;
//import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
//import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
//
//
///** /**
// * *
// */ */
//@Component @Component
//@RequiredArgsConstructor @RequiredArgsConstructor
//public class MonitorUserSendTaskRunner implements TimerTaskRunner { public class MonitorUserSendTaskRunner implements TimerTaskRunner {
//
// private final MonitorSendClient monitorSendClient; private final MonitorSendClient monitorSendClient;
// private final SysDicTreePOService sysDicTreePOService; private final SysDicTreePOService sysDicTreePOService;
//
//
// @Override @Override
// public void action() { public void action() {
// //重要或敏感用户 //重要或敏感用户
// MonitorParam.Info param2 = new MonitorParam.Info(); MonitorParam.Info param2 = new MonitorParam.Info();
// param2.setObjType(sysDicTreePOService.queryByCode("2400").getId()); param2.setObjType(sysDicTreePOService.queryByCode("2400").getId());
// param2.setFiy(true); param2.setFiy(true);
// monitorSendClient.windSend(param2); monitorSendClient.windSend(param2);
// } }
//} }

64
pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/OrgTaskRunner.java
View File

@@ -1,32 +1,32 @@
//package com.njcn.system.timer.tasks; package com.njcn.system.timer.tasks;
//
//import cn.hutool.core.date.DatePattern; import cn.hutool.core.date.DatePattern;
//import cn.hutool.core.date.DateUtil; import cn.hutool.core.date.DateUtil;
//import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient; import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient;
//import com.njcn.prepare.harmonic.pojo.bo.BaseParam; import com.njcn.prepare.harmonic.pojo.bo.BaseParam;
//import com.njcn.system.timer.TimerTaskRunner; import com.njcn.system.timer.TimerTaskRunner;
//import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
//import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
//
///** /**
// * 类的介绍：单位监测点算法执行链定时任务 * 类的介绍：单位监测点算法执行链定时任务
// * *
// * @author xuyang * @author xuyang
// * @version 1.0.0 * @version 1.0.0
// * @createTime 2023/12/6 9:35 * @createTime 2023/12/6 9:35
// */ */
//@Component @Component
//@RequiredArgsConstructor @RequiredArgsConstructor
//public class OrgTaskRunner implements TimerTaskRunner { public class OrgTaskRunner implements TimerTaskRunner {
//
// private final LiteFlowFeignClient liteFlowFeignClient; private final LiteFlowFeignClient liteFlowFeignClient;
//
// @Override @Override
// public void action() { public void action() {
// BaseParam baseParam = new BaseParam(); BaseParam baseParam = new BaseParam();
// baseParam.setFullChain(true); baseParam.setFullChain(true);
// baseParam.setRepair(false); baseParam.setRepair(false);
// baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN)); baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN));
// liteFlowFeignClient.orgPointExecutor(baseParam); liteFlowFeignClient.orgPointExecutor(baseParam);
// } }
//} }

64
pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/PmsDimTaskRunner.java
View File

@@ -1,32 +1,32 @@
//package com.njcn.system.timer.tasks; package com.njcn.system.timer.tasks;
//
//import cn.hutool.core.date.DatePattern; import cn.hutool.core.date.DatePattern;
//import cn.hutool.core.date.DateUtil; import cn.hutool.core.date.DateUtil;
//import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient; import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient;
//import com.njcn.prepare.harmonic.pojo.bo.BaseParam; import com.njcn.prepare.harmonic.pojo.bo.BaseParam;
//import com.njcn.system.timer.TimerTaskRunner; import com.njcn.system.timer.TimerTaskRunner;
//import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
//import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
//
///** /**
// * 类的介绍：变电站母线算法执行链定时任务 * 类的介绍：变电站母线算法执行链定时任务
// * *
// * @author xuyang * @author xuyang
// * @version 1.0.0 * @version 1.0.0
// * @createTime 2023/12/6 9:35 * @createTime 2023/12/6 9:35
// */ */
//@Component @Component
//@RequiredArgsConstructor @RequiredArgsConstructor
//public class PmsDimTaskRunner implements TimerTaskRunner { public class PmsDimTaskRunner implements TimerTaskRunner {
//
// private final LiteFlowFeignClient liteFlowFeignClient; private final LiteFlowFeignClient liteFlowFeignClient;
//
// @Override @Override
// public void action() { public void action() {
// BaseParam baseParam = new BaseParam(); BaseParam baseParam = new BaseParam();
// baseParam.setFullChain(true); baseParam.setFullChain(true);
// baseParam.setRepair(false); baseParam.setRepair(false);
// baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN)); baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN));
// liteFlowFeignClient.pmsDimExecutor(baseParam); liteFlowFeignClient.pmsDimExecutor(baseParam);
// } }
//} }

64
pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/PmsMonitorSendTaskRunner.java
View File

@@ -1,32 +1,32 @@
//package com.njcn.system.timer.tasks; package com.njcn.system.timer.tasks;
//
//import com.njcn.device.pms.api.GwMonitorPushFeignClient; import com.njcn.device.pms.api.GwMonitorPushFeignClient;
//import com.njcn.device.pms.api.MonitorSendClient; import com.njcn.device.pms.api.MonitorSendClient;
//import com.njcn.device.pms.pojo.param.MonitorParam; import com.njcn.device.pms.pojo.param.MonitorParam;
//import com.njcn.system.service.SysDicTreePOService; import com.njcn.system.service.SysDicTreePOService;
//import com.njcn.system.timer.TimerTaskRunner; import com.njcn.system.timer.TimerTaskRunner;
//import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
//import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
//
//import java.util.ArrayList; import java.util.ArrayList;
//
//
///** /**
// * *
// */ */
//@Component @Component
//@RequiredArgsConstructor @RequiredArgsConstructor
//public class PmsMonitorSendTaskRunner implements TimerTaskRunner { public class PmsMonitorSendTaskRunner implements TimerTaskRunner {
//
// private final GwMonitorPushFeignClient gwMonitorPushFeignClient; private final GwMonitorPushFeignClient gwMonitorPushFeignClient;
//
//
// @Override @Override
// public void action() { public void action() {
//
// gwMonitorPushFeignClient.timeTaskPushMonitor(new ArrayList<>()); gwMonitorPushFeignClient.timeTaskPushMonitor(new ArrayList<>());
//
// gwMonitorPushFeignClient.pushMonitorOverLimit(new ArrayList<>()); gwMonitorPushFeignClient.pushMonitorOverLimit(new ArrayList<>());
//
// } }
//} }

226
pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/PmsStatisticsSpecialMonitorTaskRunner.java
View File

@@ -1,113 +1,113 @@
//package com.njcn.system.timer.tasks; package com.njcn.system.timer.tasks;
//
//import cn.hutool.core.date.DateUtil; import cn.hutool.core.date.DateUtil;
//import cn.hutool.core.util.StrUtil; import cn.hutool.core.util.StrUtil;
//import com.njcn.common.pojo.constant.BizParamConstant; import com.njcn.common.pojo.constant.BizParamConstant;
//import com.njcn.prepare.harmonic.api.newalgorithm.PmsStatisticsSpecialMonitorFeignClient; import com.njcn.prepare.harmonic.api.newalgorithm.PmsStatisticsSpecialMonitorFeignClient;
//import com.njcn.prepare.harmonic.pojo.param.LineParam; import com.njcn.prepare.harmonic.pojo.param.LineParam;
//import com.njcn.system.timer.TimerTaskRunner; import com.njcn.system.timer.TimerTaskRunner;
//import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
//import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
//import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
//
//import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
//import java.time.LocalDateTime; import java.time.LocalDateTime;
//import java.util.Calendar; import java.util.Calendar;
//import java.util.Date; import java.util.Date;
//import java.util.Objects; import java.util.Objects;
//
///** /**
// * 类的介绍：专项分析-台账统计定时任务 * 类的介绍：专项分析-台账统计定时任务
// * *
// * @author xuyang * @author xuyang
// * @version 1.0.0 * @version 1.0.0
// * @createTime 2023/12/08 11:23 * @createTime 2023/12/08 11:23
// */ */
//@Component @Component
//@RequiredArgsConstructor @RequiredArgsConstructor
//@Slf4j @Slf4j
//public class PmsStatisticsSpecialMonitorTaskRunner implements TimerTaskRunner { public class PmsStatisticsSpecialMonitorTaskRunner implements TimerTaskRunner {
//
// private final PmsStatisticsSpecialMonitorFeignClient pmsStatisticsSpecialMonitorFeignClient; private final PmsStatisticsSpecialMonitorFeignClient pmsStatisticsSpecialMonitorFeignClient;
//
// @Override @Override
// public void action() { public void action() {
// log.info(LocalDateTime.now()+"专项分析-台账统计调度开始"); log.info(LocalDateTime.now()+"专项分析-台账统计调度开始");
// LineParam lineParam = new LineParam(); LineParam lineParam = new LineParam();
// lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_MONTH)); lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_MONTH));
// lineParam.setDataDate(this.prepareTimeDeal(BizParamConstant.STAT_BIZ_MONTH)); lineParam.setDataDate(this.prepareTimeDeal(BizParamConstant.STAT_BIZ_MONTH));
// this.commDefineDate(BizParamConstant.STAT_BIZ_MONTH,lineParam); this.commDefineDate(BizParamConstant.STAT_BIZ_MONTH,lineParam);
// pmsStatisticsSpecialMonitorFeignClient.pmsStatisticsSpecialMonitorHandler(lineParam); pmsStatisticsSpecialMonitorFeignClient.pmsStatisticsSpecialMonitorHandler(lineParam);
// } }
//
// public String prepareTimeDeal(String command) { public String prepareTimeDeal(String command) {
// if (StrUtil.isBlank(command)) { if (StrUtil.isBlank(command)) {
// log.error(LocalDateTime.now() + "xxl调度任务参数未设置"); log.error(LocalDateTime.now() + "xxl调度任务参数未设置");
// return null; return null;
// } }
// SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
// Calendar calendar = Calendar.getInstance(); Calendar calendar = Calendar.getInstance();
// if (Objects.equals(BizParamConstant.STAT_BIZ_DAY, command)) { if (Objects.equals(BizParamConstant.STAT_BIZ_DAY, command)) {
// calendar.add(Calendar.DAY_OF_MONTH, -1); calendar.add(Calendar.DAY_OF_MONTH, -1);
// } else if (Objects.equals(BizParamConstant.STAT_BIZ_MONTH, command)) { } else if (Objects.equals(BizParamConstant.STAT_BIZ_MONTH, command)) {
// calendar.set(Calendar.DAY_OF_MONTH, 1); calendar.set(Calendar.DAY_OF_MONTH, 1);
// } else if (Objects.equals(BizParamConstant.STAT_BIZ_QUARTER, command)) { } else if (Objects.equals(BizParamConstant.STAT_BIZ_QUARTER, command)) {
// int nowMonth = calendar.get(Calendar.MONTH); int nowMonth = calendar.get(Calendar.MONTH);
// calendar.set(Calendar.MONTH, nowMonth - (nowMonth % 3)); calendar.set(Calendar.MONTH, nowMonth - (nowMonth % 3));
// calendar.set(Calendar.DAY_OF_MONTH, 1); calendar.set(Calendar.DAY_OF_MONTH, 1);
// calendar.set(Calendar.HOUR_OF_DAY, 0); calendar.set(Calendar.HOUR_OF_DAY, 0);
// calendar.set(Calendar.MINUTE, 0); calendar.set(Calendar.MINUTE, 0);
// calendar.set(Calendar.SECOND, 0); calendar.set(Calendar.SECOND, 0);
// calendar.set(Calendar.MILLISECOND, 0); calendar.set(Calendar.MILLISECOND, 0);
// } else if (Objects.equals(BizParamConstant.STAT_BIZ_YEAR, command)) { } else if (Objects.equals(BizParamConstant.STAT_BIZ_YEAR, command)) {
// calendar.set(Calendar.DAY_OF_YEAR, 1); calendar.set(Calendar.DAY_OF_YEAR, 1);
// } }
// log.info("job调度时间:" + sdf.format(calendar.getTime())); log.info("job调度时间:" + sdf.format(calendar.getTime()));
// return sdf.format(calendar.getTime()); return sdf.format(calendar.getTime());
// } }
//
// /** /**
// * 根据xxl-job的参数，生成一个任务的起始时间和结束时间 * 根据xxl-job的参数，生成一个任务的起始时间和结束时间
// * *
// * @author cdf * @author cdf
// * @date 2023/9/20 * @date 2023/9/20
// */ */
// public void commDefineDate(String command, LineParam lineParam) { public void commDefineDate(String command, LineParam lineParam) {
// SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
// String begin; String begin;
// String end; String end;
// Calendar calendar = Calendar.getInstance(); Calendar calendar = Calendar.getInstance();
// calendar.add(Calendar.DAY_OF_MONTH, -1); calendar.add(Calendar.DAY_OF_MONTH, -1);
// Date temDate = calendar.getTime(); Date temDate = calendar.getTime();
// switch (command) { switch (command) {
// case BizParamConstant.STAT_BIZ_DAY: case BizParamConstant.STAT_BIZ_DAY:
// begin = sdf.format(DateUtil.beginOfDay(temDate)); begin = sdf.format(DateUtil.beginOfDay(temDate));
// end = sdf.format(DateUtil.endOfDay(temDate)); end = sdf.format(DateUtil.endOfDay(temDate));
// break; break;
// case BizParamConstant.STAT_BIZ_WEEK: case BizParamConstant.STAT_BIZ_WEEK:
// begin = sdf.format(DateUtil.beginOfWeek(temDate)); begin = sdf.format(DateUtil.beginOfWeek(temDate));
// end = sdf.format(DateUtil.endOfWeek(temDate)); end = sdf.format(DateUtil.endOfWeek(temDate));
// break; break;
// case BizParamConstant.STAT_BIZ_MONTH: case BizParamConstant.STAT_BIZ_MONTH:
// begin = sdf.format(DateUtil.beginOfMonth(temDate)); begin = sdf.format(DateUtil.beginOfMonth(temDate));
// end = sdf.format(DateUtil.endOfMonth(temDate)); end = sdf.format(DateUtil.endOfMonth(temDate));
// break; break;
// case BizParamConstant.STAT_BIZ_QUARTER: case BizParamConstant.STAT_BIZ_QUARTER:
// begin = sdf.format(DateUtil.beginOfQuarter(temDate)); begin = sdf.format(DateUtil.beginOfQuarter(temDate));
// end = sdf.format(DateUtil.endOfQuarter(temDate)); end = sdf.format(DateUtil.endOfQuarter(temDate));
// break; break;
// case BizParamConstant.STAT_BIZ_YEAR: case BizParamConstant.STAT_BIZ_YEAR:
// begin = sdf.format(DateUtil.beginOfYear(temDate)); begin = sdf.format(DateUtil.beginOfYear(temDate));
// end = sdf.format(DateUtil.endOfYear(temDate)); end = sdf.format(DateUtil.endOfYear(temDate));
// break; break;
// default: default:
// begin = sdf.format(DateUtil.beginOfDay(temDate)); begin = sdf.format(DateUtil.beginOfDay(temDate));
// end = sdf.format(DateUtil.endOfDay(temDate)); end = sdf.format(DateUtil.endOfDay(temDate));
// break; break;
// } }
// lineParam.setBeginTime(begin); lineParam.setBeginTime(begin);
// lineParam.setEndTime(end); lineParam.setEndTime(end);
// lineParam.setDataDate(begin.substring(0, 10)); lineParam.setDataDate(begin.substring(0, 10));
// } }
//
//} }

226
pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/RMpEmissionTaskRunner.java
View File

@@ -1,113 +1,113 @@
//package com.njcn.system.timer.tasks; package com.njcn.system.timer.tasks;
//
//import cn.hutool.core.date.DateUtil; import cn.hutool.core.date.DateUtil;
//import cn.hutool.core.util.StrUtil; import cn.hutool.core.util.StrUtil;
//import com.njcn.common.pojo.constant.BizParamConstant; import com.njcn.common.pojo.constant.BizParamConstant;
//import com.njcn.prepare.harmonic.api.newalgorithm.RMpEmissionFeignClient; import com.njcn.prepare.harmonic.api.newalgorithm.RMpEmissionFeignClient;
//import com.njcn.prepare.harmonic.pojo.param.LineParam; import com.njcn.prepare.harmonic.pojo.param.LineParam;
//import com.njcn.system.timer.TimerTaskRunner; import com.njcn.system.timer.TimerTaskRunner;
//import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
//import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
//import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
//
//import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
//import java.time.LocalDateTime; import java.time.LocalDateTime;
//import java.util.Calendar; import java.util.Calendar;
//import java.util.Date; import java.util.Date;
//import java.util.Objects; import java.util.Objects;
//
///** /**
// * 类的介绍：发射特性定时任务 * 类的介绍：发射特性定时任务
// * *
// * @author xuyang * @author xuyang
// * @version 1.0.0 * @version 1.0.0
// * @createTime 2023/12/20 13:55 * @createTime 2023/12/20 13:55
// */ */
//@Component @Component
//@RequiredArgsConstructor @RequiredArgsConstructor
//@Slf4j @Slf4j
//public class RMpEmissionTaskRunner implements TimerTaskRunner { public class RMpEmissionTaskRunner implements TimerTaskRunner {
//
// private final RMpEmissionFeignClient rMpEmissionFeignClient; private final RMpEmissionFeignClient rMpEmissionFeignClient;
//
// @Override @Override
// public void action() { public void action() {
// log.info(LocalDateTime.now()+"发射特性调度开始"); log.info(LocalDateTime.now()+"发射特性调度开始");
// LineParam lineParam = new LineParam(); LineParam lineParam = new LineParam();
// lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_MONTH)); lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_MONTH));
// lineParam.setDataDate(this.prepareTimeDeal(BizParamConstant.STAT_BIZ_MONTH)); lineParam.setDataDate(this.prepareTimeDeal(BizParamConstant.STAT_BIZ_MONTH));
// this.commDefineDate(BizParamConstant.STAT_BIZ_MONTH,lineParam); this.commDefineDate(BizParamConstant.STAT_BIZ_MONTH,lineParam);
// rMpEmissionFeignClient.rMpEmissionMHandler(lineParam); rMpEmissionFeignClient.rMpEmissionMHandler(lineParam);
// } }
//
// public String prepareTimeDeal(String command) { public String prepareTimeDeal(String command) {
// if (StrUtil.isBlank(command)) { if (StrUtil.isBlank(command)) {
// log.error(LocalDateTime.now() + "xxl调度任务参数未设置"); log.error(LocalDateTime.now() + "xxl调度任务参数未设置");
// return null; return null;
// } }
// SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
// Calendar calendar = Calendar.getInstance(); Calendar calendar = Calendar.getInstance();
// if (Objects.equals(BizParamConstant.STAT_BIZ_DAY, command)) { if (Objects.equals(BizParamConstant.STAT_BIZ_DAY, command)) {
// calendar.add(Calendar.DAY_OF_MONTH, -1); calendar.add(Calendar.DAY_OF_MONTH, -1);
// } else if (Objects.equals(BizParamConstant.STAT_BIZ_MONTH, command)) { } else if (Objects.equals(BizParamConstant.STAT_BIZ_MONTH, command)) {
// calendar.set(Calendar.DAY_OF_MONTH, 1); calendar.set(Calendar.DAY_OF_MONTH, 1);
// } else if (Objects.equals(BizParamConstant.STAT_BIZ_QUARTER, command)) { } else if (Objects.equals(BizParamConstant.STAT_BIZ_QUARTER, command)) {
// int nowMonth = calendar.get(Calendar.MONTH); int nowMonth = calendar.get(Calendar.MONTH);
// calendar.set(Calendar.MONTH, nowMonth - (nowMonth % 3)); calendar.set(Calendar.MONTH, nowMonth - (nowMonth % 3));
// calendar.set(Calendar.DAY_OF_MONTH, 1); calendar.set(Calendar.DAY_OF_MONTH, 1);
// calendar.set(Calendar.HOUR_OF_DAY, 0); calendar.set(Calendar.HOUR_OF_DAY, 0);
// calendar.set(Calendar.MINUTE, 0); calendar.set(Calendar.MINUTE, 0);
// calendar.set(Calendar.SECOND, 0); calendar.set(Calendar.SECOND, 0);
// calendar.set(Calendar.MILLISECOND, 0); calendar.set(Calendar.MILLISECOND, 0);
// } else if (Objects.equals(BizParamConstant.STAT_BIZ_YEAR, command)) { } else if (Objects.equals(BizParamConstant.STAT_BIZ_YEAR, command)) {
// calendar.set(Calendar.DAY_OF_YEAR, 1); calendar.set(Calendar.DAY_OF_YEAR, 1);
// } }
// log.info("job调度时间:" + sdf.format(calendar.getTime())); log.info("job调度时间:" + sdf.format(calendar.getTime()));
// return sdf.format(calendar.getTime()); return sdf.format(calendar.getTime());
// } }
//
// /** /**
// * 根据xxl-job的参数，生成一个任务的起始时间和结束时间 * 根据xxl-job的参数，生成一个任务的起始时间和结束时间
// * *
// * @author cdf * @author cdf
// * @date 2023/9/20 * @date 2023/9/20
// */ */
// public void commDefineDate(String command, LineParam lineParam) { public void commDefineDate(String command, LineParam lineParam) {
// SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
// String begin; String begin;
// String end; String end;
// Calendar calendar = Calendar.getInstance(); Calendar calendar = Calendar.getInstance();
// calendar.add(Calendar.DAY_OF_MONTH, -1); calendar.add(Calendar.DAY_OF_MONTH, -1);
// Date temDate = calendar.getTime(); Date temDate = calendar.getTime();
// switch (command) { switch (command) {
// case BizParamConstant.STAT_BIZ_DAY: case BizParamConstant.STAT_BIZ_DAY:
// begin = sdf.format(DateUtil.beginOfDay(temDate)); begin = sdf.format(DateUtil.beginOfDay(temDate));
// end = sdf.format(DateUtil.endOfDay(temDate)); end = sdf.format(DateUtil.endOfDay(temDate));
// break; break;
// case BizParamConstant.STAT_BIZ_WEEK: case BizParamConstant.STAT_BIZ_WEEK:
// begin = sdf.format(DateUtil.beginOfWeek(temDate)); begin = sdf.format(DateUtil.beginOfWeek(temDate));
// end = sdf.format(DateUtil.endOfWeek(temDate)); end = sdf.format(DateUtil.endOfWeek(temDate));
// break; break;
// case BizParamConstant.STAT_BIZ_MONTH: case BizParamConstant.STAT_BIZ_MONTH:
// begin = sdf.format(DateUtil.beginOfMonth(temDate)); begin = sdf.format(DateUtil.beginOfMonth(temDate));
// end = sdf.format(DateUtil.endOfMonth(temDate)); end = sdf.format(DateUtil.endOfMonth(temDate));
// break; break;
// case BizParamConstant.STAT_BIZ_QUARTER: case BizParamConstant.STAT_BIZ_QUARTER:
// begin = sdf.format(DateUtil.beginOfQuarter(temDate)); begin = sdf.format(DateUtil.beginOfQuarter(temDate));
// end = sdf.format(DateUtil.endOfQuarter(temDate)); end = sdf.format(DateUtil.endOfQuarter(temDate));
// break; break;
// case BizParamConstant.STAT_BIZ_YEAR: case BizParamConstant.STAT_BIZ_YEAR:
// begin = sdf.format(DateUtil.beginOfYear(temDate)); begin = sdf.format(DateUtil.beginOfYear(temDate));
// end = sdf.format(DateUtil.endOfYear(temDate)); end = sdf.format(DateUtil.endOfYear(temDate));
// break; break;
// default: default:
// begin = sdf.format(DateUtil.beginOfDay(temDate)); begin = sdf.format(DateUtil.beginOfDay(temDate));
// end = sdf.format(DateUtil.endOfDay(temDate)); end = sdf.format(DateUtil.endOfDay(temDate));
// break; break;
// } }
// lineParam.setBeginTime(begin); lineParam.setBeginTime(begin);
// lineParam.setEndTime(end); lineParam.setEndTime(end);
// lineParam.setDataDate(begin.substring(0, 10)); lineParam.setDataDate(begin.substring(0, 10));
// } }
//
//} }

226
pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/RMpInfluenceTaskRunner.java
View File

@@ -1,113 +1,113 @@
//package com.njcn.system.timer.tasks; package com.njcn.system.timer.tasks;
//
//import cn.hutool.core.date.DateUtil; import cn.hutool.core.date.DateUtil;
//import cn.hutool.core.util.StrUtil; import cn.hutool.core.util.StrUtil;
//import com.njcn.common.pojo.constant.BizParamConstant; import com.njcn.common.pojo.constant.BizParamConstant;
//import com.njcn.prepare.harmonic.api.newalgorithm.RMpInfluenceFeignClient; import com.njcn.prepare.harmonic.api.newalgorithm.RMpInfluenceFeignClient;
//import com.njcn.prepare.harmonic.pojo.param.LineParam; import com.njcn.prepare.harmonic.pojo.param.LineParam;
//import com.njcn.system.timer.TimerTaskRunner; import com.njcn.system.timer.TimerTaskRunner;
//import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
//import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
//import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
//
//import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
//import java.time.LocalDateTime; import java.time.LocalDateTime;
//import java.util.Calendar; import java.util.Calendar;
//import java.util.Date; import java.util.Date;
//import java.util.Objects; import java.util.Objects;
//
///** /**
// * 类的介绍： * 类的介绍：
// * *
// * @author xuyang * @author xuyang
// * @version 1.0.0 * @version 1.0.0
// * @createTime 2023/12/20 14:12 * @createTime 2023/12/20 14:12
// */ */
//@Component @Component
//@RequiredArgsConstructor @RequiredArgsConstructor
//@Slf4j @Slf4j
//public class RMpInfluenceTaskRunner implements TimerTaskRunner { public class RMpInfluenceTaskRunner implements TimerTaskRunner {
//
// private final RMpInfluenceFeignClient rMpInfluenceFeignClient; private final RMpInfluenceFeignClient rMpInfluenceFeignClient;
//
// @Override @Override
// public void action() { public void action() {
// log.info(LocalDateTime.now()+"影响特性调度开始"); log.info(LocalDateTime.now()+"影响特性调度开始");
// LineParam lineParam = new LineParam(); LineParam lineParam = new LineParam();
// lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_MONTH)); lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_MONTH));
// lineParam.setDataDate(this.prepareTimeDeal(BizParamConstant.STAT_BIZ_MONTH)); lineParam.setDataDate(this.prepareTimeDeal(BizParamConstant.STAT_BIZ_MONTH));
// this.commDefineDate(BizParamConstant.STAT_BIZ_MONTH,lineParam); this.commDefineDate(BizParamConstant.STAT_BIZ_MONTH,lineParam);
// rMpInfluenceFeignClient.rMpInfluenceMHandler(lineParam); rMpInfluenceFeignClient.rMpInfluenceMHandler(lineParam);
// } }
//
// public String prepareTimeDeal(String command) { public String prepareTimeDeal(String command) {
// if (StrUtil.isBlank(command)) { if (StrUtil.isBlank(command)) {
// log.error(LocalDateTime.now() + "xxl调度任务参数未设置"); log.error(LocalDateTime.now() + "xxl调度任务参数未设置");
// return null; return null;
// } }
// SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
// Calendar calendar = Calendar.getInstance(); Calendar calendar = Calendar.getInstance();
// if (Objects.equals(BizParamConstant.STAT_BIZ_DAY, command)) { if (Objects.equals(BizParamConstant.STAT_BIZ_DAY, command)) {
// calendar.add(Calendar.DAY_OF_MONTH, -1); calendar.add(Calendar.DAY_OF_MONTH, -1);
// } else if (Objects.equals(BizParamConstant.STAT_BIZ_MONTH, command)) { } else if (Objects.equals(BizParamConstant.STAT_BIZ_MONTH, command)) {
// calendar.set(Calendar.DAY_OF_MONTH, 1); calendar.set(Calendar.DAY_OF_MONTH, 1);
// } else if (Objects.equals(BizParamConstant.STAT_BIZ_QUARTER, command)) { } else if (Objects.equals(BizParamConstant.STAT_BIZ_QUARTER, command)) {
// int nowMonth = calendar.get(Calendar.MONTH); int nowMonth = calendar.get(Calendar.MONTH);
// calendar.set(Calendar.MONTH, nowMonth - (nowMonth % 3)); calendar.set(Calendar.MONTH, nowMonth - (nowMonth % 3));
// calendar.set(Calendar.DAY_OF_MONTH, 1); calendar.set(Calendar.DAY_OF_MONTH, 1);
// calendar.set(Calendar.HOUR_OF_DAY, 0); calendar.set(Calendar.HOUR_OF_DAY, 0);
// calendar.set(Calendar.MINUTE, 0); calendar.set(Calendar.MINUTE, 0);
// calendar.set(Calendar.SECOND, 0); calendar.set(Calendar.SECOND, 0);
// calendar.set(Calendar.MILLISECOND, 0); calendar.set(Calendar.MILLISECOND, 0);
// } else if (Objects.equals(BizParamConstant.STAT_BIZ_YEAR, command)) { } else if (Objects.equals(BizParamConstant.STAT_BIZ_YEAR, command)) {
// calendar.set(Calendar.DAY_OF_YEAR, 1); calendar.set(Calendar.DAY_OF_YEAR, 1);
// } }
// log.info("job调度时间:" + sdf.format(calendar.getTime())); log.info("job调度时间:" + sdf.format(calendar.getTime()));
// return sdf.format(calendar.getTime()); return sdf.format(calendar.getTime());
// } }
//
// /** /**
// * 根据xxl-job的参数，生成一个任务的起始时间和结束时间 * 根据xxl-job的参数，生成一个任务的起始时间和结束时间
// * *
// * @author cdf * @author cdf
// * @date 2023/9/20 * @date 2023/9/20
// */ */
// public void commDefineDate(String command, LineParam lineParam) { public void commDefineDate(String command, LineParam lineParam) {
// SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
// String begin; String begin;
// String end; String end;
// Calendar calendar = Calendar.getInstance(); Calendar calendar = Calendar.getInstance();
// calendar.add(Calendar.DAY_OF_MONTH, -1); calendar.add(Calendar.DAY_OF_MONTH, -1);
// Date temDate = calendar.getTime(); Date temDate = calendar.getTime();
// switch (command) { switch (command) {
// case BizParamConstant.STAT_BIZ_DAY: case BizParamConstant.STAT_BIZ_DAY:
// begin = sdf.format(DateUtil.beginOfDay(temDate)); begin = sdf.format(DateUtil.beginOfDay(temDate));
// end = sdf.format(DateUtil.endOfDay(temDate)); end = sdf.format(DateUtil.endOfDay(temDate));
// break; break;
// case BizParamConstant.STAT_BIZ_WEEK: case BizParamConstant.STAT_BIZ_WEEK:
// begin = sdf.format(DateUtil.beginOfWeek(temDate)); begin = sdf.format(DateUtil.beginOfWeek(temDate));
// end = sdf.format(DateUtil.endOfWeek(temDate)); end = sdf.format(DateUtil.endOfWeek(temDate));
// break; break;
// case BizParamConstant.STAT_BIZ_MONTH: case BizParamConstant.STAT_BIZ_MONTH:
// begin = sdf.format(DateUtil.beginOfMonth(temDate)); begin = sdf.format(DateUtil.beginOfMonth(temDate));
// end = sdf.format(DateUtil.endOfMonth(temDate)); end = sdf.format(DateUtil.endOfMonth(temDate));
// break; break;
// case BizParamConstant.STAT_BIZ_QUARTER: case BizParamConstant.STAT_BIZ_QUARTER:
// begin = sdf.format(DateUtil.beginOfQuarter(temDate)); begin = sdf.format(DateUtil.beginOfQuarter(temDate));
// end = sdf.format(DateUtil.endOfQuarter(temDate)); end = sdf.format(DateUtil.endOfQuarter(temDate));
// break; break;
// case BizParamConstant.STAT_BIZ_YEAR: case BizParamConstant.STAT_BIZ_YEAR:
// begin = sdf.format(DateUtil.beginOfYear(temDate)); begin = sdf.format(DateUtil.beginOfYear(temDate));
// end = sdf.format(DateUtil.endOfYear(temDate)); end = sdf.format(DateUtil.endOfYear(temDate));
// break; break;
// default: default:
// begin = sdf.format(DateUtil.beginOfDay(temDate)); begin = sdf.format(DateUtil.beginOfDay(temDate));
// end = sdf.format(DateUtil.endOfDay(temDate)); end = sdf.format(DateUtil.endOfDay(temDate));
// break; break;
// } }
// lineParam.setBeginTime(begin); lineParam.setBeginTime(begin);
// lineParam.setEndTime(end); lineParam.setEndTime(end);
// lineParam.setDataDate(begin.substring(0, 10)); lineParam.setDataDate(begin.substring(0, 10));
// } }
//
//} }

64
pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/StatisticReportTaskRunner.java
View File

@@ -1,32 +1,32 @@
//package com.njcn.system.timer.tasks; package com.njcn.system.timer.tasks;
//
//import com.njcn.process.api.SupvStatisticReportMFeignClient; import com.njcn.process.api.SupvStatisticReportMFeignClient;
//import com.njcn.system.timer.TimerTaskRunner; import com.njcn.system.timer.TimerTaskRunner;
//import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
//import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
//import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
//
//import java.time.LocalDate; import java.time.LocalDate;
//import java.time.LocalDateTime; import java.time.LocalDateTime;
//import java.time.format.DateTimeFormatter; import java.time.format.DateTimeFormatter;
//
///** /**
// * 类的介绍：第二技术监督月上送报告统计-定时任务 * 类的介绍：第二技术监督月上送报告统计-定时任务
// * *
// * @author xuyang * @author xuyang
// * @version 1.0.0 * @version 1.0.0
// * @createTime 2023/12/08 11:35 * @createTime 2023/12/08 11:35
// */ */
//@Component @Component
//@RequiredArgsConstructor @RequiredArgsConstructor
//@Slf4j @Slf4j
//public class StatisticReportTaskRunner implements TimerTaskRunner { public class StatisticReportTaskRunner implements TimerTaskRunner {
// private final SupvStatisticReportMFeignClient supvStatisticReportMFeignClient; private final SupvStatisticReportMFeignClient supvStatisticReportMFeignClient;
//
// @Override @Override
// public void action() { public void action() {
// log.info(LocalDateTime.now()+"技术监督计划问题月报统计调用成功"); log.info(LocalDateTime.now()+"技术监督计划问题月报统计调用成功");
// LocalDate yesterday = LocalDate.now().plusDays(-1); LocalDate yesterday = LocalDate.now().plusDays(-1);
// supvStatisticReportMFeignClient.statisticReport(yesterday.format(DateTimeFormatter.ofPattern("yyyy-MM-dd"))); supvStatisticReportMFeignClient.statisticReport(yesterday.format(DateTimeFormatter.ofPattern("yyyy-MM-dd")));
// } }
//} }

64
pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/SubstationTaskRunner.java
View File

@@ -1,32 +1,32 @@
//package com.njcn.system.timer.tasks; package com.njcn.system.timer.tasks;
//
//import cn.hutool.core.date.DatePattern; import cn.hutool.core.date.DatePattern;
//import cn.hutool.core.date.DateUtil; import cn.hutool.core.date.DateUtil;
//import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient; import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient;
//import com.njcn.prepare.harmonic.pojo.bo.BaseParam; import com.njcn.prepare.harmonic.pojo.bo.BaseParam;
//import com.njcn.system.timer.TimerTaskRunner; import com.njcn.system.timer.TimerTaskRunner;
//import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
//import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
//
///** /**
// * 类的介绍：变电站算法执行链定时任务 * 类的介绍：变电站算法执行链定时任务
// * *
// * @author xuyang * @author xuyang
// * @version 1.0.0 * @version 1.0.0
// * @createTime 2023/12/6 9:35 * @createTime 2023/12/6 9:35
// */ */
//@Component @Component
//@RequiredArgsConstructor @RequiredArgsConstructor
//public class SubstationTaskRunner implements TimerTaskRunner { public class SubstationTaskRunner implements TimerTaskRunner {
//
// private final LiteFlowFeignClient liteFlowFeignClient; private final LiteFlowFeignClient liteFlowFeignClient;
//
// @Override @Override
// public void action() { public void action() {
// BaseParam baseParam = new BaseParam(); BaseParam baseParam = new BaseParam();
// baseParam.setFullChain(true); baseParam.setFullChain(true);
// baseParam.setRepair(false); baseParam.setRepair(false);
// baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN)); baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN));
// liteFlowFeignClient.substationExecutor(baseParam); liteFlowFeignClient.substationExecutor(baseParam);
// } }
//} }

64
pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/UploadGwTaskRunner.java
View File

@@ -1,32 +1,32 @@
//package com.njcn.system.timer.tasks; package com.njcn.system.timer.tasks;
//
//import cn.hutool.core.date.DatePattern; import cn.hutool.core.date.DatePattern;
//import cn.hutool.core.date.DateUtil; import cn.hutool.core.date.DateUtil;
//import com.njcn.harmonic.api.UploadGwDataFeignClient; import com.njcn.harmonic.api.UploadGwDataFeignClient;
//import com.njcn.harmonic.pojo.param.UploadParam; import com.njcn.harmonic.pojo.param.UploadParam;
//import com.njcn.system.timer.TimerTaskRunner; import com.njcn.system.timer.TimerTaskRunner;
//import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
//import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
//
///** /**
// * 类的介绍：国网数据每日上送定时任务 * 类的介绍：国网数据每日上送定时任务
// * *
// * @author xuyang * @author xuyang
// * @version 1.0.0 * @version 1.0.0
// * @createTime 2023/12/15 13:45 * @createTime 2023/12/15 13:45
// */ */
//@Component @Component
//@RequiredArgsConstructor @RequiredArgsConstructor
//public class UploadGwTaskRunner implements TimerTaskRunner { public class UploadGwTaskRunner implements TimerTaskRunner {
//
// private final UploadGwDataFeignClient uploadGwDataFeignClient; private final UploadGwDataFeignClient uploadGwDataFeignClient;
//
// @Override @Override
// public void action() { public void action() {
// UploadParam param = new UploadParam(); UploadParam param = new UploadParam();
// param.setTime(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN)); param.setTime(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN));
// uploadGwDataFeignClient.uploadPointStatisticalData(param); uploadGwDataFeignClient.uploadPointStatisticalData(param);
// uploadGwDataFeignClient.uploadSubstationStatisticalData(param); uploadGwDataFeignClient.uploadSubstationStatisticalData(param);
// uploadGwDataFeignClient.uploadEvaluationData(param); uploadGwDataFeignClient.uploadEvaluationData(param);
// } }
//} }

226
pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/specialAnalysisIndexOverviewTaskRunner.java
View File

@@ -1,113 +1,113 @@
//package com.njcn.system.timer.tasks; package com.njcn.system.timer.tasks;
//
//import cn.hutool.core.date.DateUtil; import cn.hutool.core.date.DateUtil;
//import cn.hutool.core.util.StrUtil; import cn.hutool.core.util.StrUtil;
//import com.njcn.common.pojo.constant.BizParamConstant; import com.njcn.common.pojo.constant.BizParamConstant;
//import com.njcn.prepare.harmonic.api.specialanalysis.SpecialAnalysisFeignClient; import com.njcn.prepare.harmonic.api.specialanalysis.SpecialAnalysisFeignClient;
//import com.njcn.prepare.harmonic.pojo.param.LineParam; import com.njcn.prepare.harmonic.pojo.param.LineParam;
//import com.njcn.system.timer.TimerTaskRunner; import com.njcn.system.timer.TimerTaskRunner;
//import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
//import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
//import org.springframework.stereotype.Component; import org.springframework.stereotype.Component;
//
//import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
//import java.time.LocalDateTime; import java.time.LocalDateTime;
//import java.util.Calendar; import java.util.Calendar;
//import java.util.Date; import java.util.Date;
//import java.util.Objects; import java.util.Objects;
//
///** /**
// * 类的介绍： * 类的介绍：
// * *
// * @author xuyang * @author xuyang
// * @version 1.0.0 * @version 1.0.0
// * @createTime 2023/12/20 14:15 * @createTime 2023/12/20 14:15
// */ */
//@Component @Component
//@RequiredArgsConstructor @RequiredArgsConstructor
//@Slf4j @Slf4j
//public class specialAnalysisIndexOverviewTaskRunner implements TimerTaskRunner { public class specialAnalysisIndexOverviewTaskRunner implements TimerTaskRunner {
//
// private final SpecialAnalysisFeignClient specialAnalysisFeignClient; private final SpecialAnalysisFeignClient specialAnalysisFeignClient;
//
// @Override @Override
// public void action() { public void action() {
// log.info(LocalDateTime.now()+"专项分析-指标总览开始执行"); log.info(LocalDateTime.now()+"专项分析-指标总览开始执行");
// LineParam lineParam = new LineParam(); LineParam lineParam = new LineParam();
// lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_MONTH)); lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_MONTH));
// lineParam.setDataDate(this.prepareTimeDeal(BizParamConstant.STAT_BIZ_MONTH)); lineParam.setDataDate(this.prepareTimeDeal(BizParamConstant.STAT_BIZ_MONTH));
// this.commDefineDate(BizParamConstant.STAT_BIZ_MONTH,lineParam); this.commDefineDate(BizParamConstant.STAT_BIZ_MONTH,lineParam);
// specialAnalysisFeignClient.hanlder(lineParam); specialAnalysisFeignClient.hanlder(lineParam);
// } }
//
// public String prepareTimeDeal(String command) { public String prepareTimeDeal(String command) {
// if (StrUtil.isBlank(command)) { if (StrUtil.isBlank(command)) {
// log.error(LocalDateTime.now() + "xxl调度任务参数未设置"); log.error(LocalDateTime.now() + "xxl调度任务参数未设置");
// return null; return null;
// } }
// SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
// Calendar calendar = Calendar.getInstance(); Calendar calendar = Calendar.getInstance();
// if (Objects.equals(BizParamConstant.STAT_BIZ_DAY, command)) { if (Objects.equals(BizParamConstant.STAT_BIZ_DAY, command)) {
// calendar.add(Calendar.DAY_OF_MONTH, -1); calendar.add(Calendar.DAY_OF_MONTH, -1);
// } else if (Objects.equals(BizParamConstant.STAT_BIZ_MONTH, command)) { } else if (Objects.equals(BizParamConstant.STAT_BIZ_MONTH, command)) {
// calendar.set(Calendar.DAY_OF_MONTH, 1); calendar.set(Calendar.DAY_OF_MONTH, 1);
// } else if (Objects.equals(BizParamConstant.STAT_BIZ_QUARTER, command)) { } else if (Objects.equals(BizParamConstant.STAT_BIZ_QUARTER, command)) {
// int nowMonth = calendar.get(Calendar.MONTH); int nowMonth = calendar.get(Calendar.MONTH);
// calendar.set(Calendar.MONTH, nowMonth - (nowMonth % 3)); calendar.set(Calendar.MONTH, nowMonth - (nowMonth % 3));
// calendar.set(Calendar.DAY_OF_MONTH, 1); calendar.set(Calendar.DAY_OF_MONTH, 1);
// calendar.set(Calendar.HOUR_OF_DAY, 0); calendar.set(Calendar.HOUR_OF_DAY, 0);
// calendar.set(Calendar.MINUTE, 0); calendar.set(Calendar.MINUTE, 0);
// calendar.set(Calendar.SECOND, 0); calendar.set(Calendar.SECOND, 0);
// calendar.set(Calendar.MILLISECOND, 0); calendar.set(Calendar.MILLISECOND, 0);
// } else if (Objects.equals(BizParamConstant.STAT_BIZ_YEAR, command)) { } else if (Objects.equals(BizParamConstant.STAT_BIZ_YEAR, command)) {
// calendar.set(Calendar.DAY_OF_YEAR, 1); calendar.set(Calendar.DAY_OF_YEAR, 1);
// } }
// log.info("job调度时间:" + sdf.format(calendar.getTime())); log.info("job调度时间:" + sdf.format(calendar.getTime()));
// return sdf.format(calendar.getTime()); return sdf.format(calendar.getTime());
// } }
//
// /** /**
// * 根据xxl-job的参数，生成一个任务的起始时间和结束时间 * 根据xxl-job的参数，生成一个任务的起始时间和结束时间
// * *
// * @author cdf * @author cdf
// * @date 2023/9/20 * @date 2023/9/20
// */ */
// public void commDefineDate(String command, LineParam lineParam) { public void commDefineDate(String command, LineParam lineParam) {
// SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
// String begin; String begin;
// String end; String end;
// Calendar calendar = Calendar.getInstance(); Calendar calendar = Calendar.getInstance();
// calendar.add(Calendar.DAY_OF_MONTH, -1); calendar.add(Calendar.DAY_OF_MONTH, -1);
// Date temDate = calendar.getTime(); Date temDate = calendar.getTime();
// switch (command) { switch (command) {
// case BizParamConstant.STAT_BIZ_DAY: case BizParamConstant.STAT_BIZ_DAY:
// begin = sdf.format(DateUtil.beginOfDay(temDate)); begin = sdf.format(DateUtil.beginOfDay(temDate));
// end = sdf.format(DateUtil.endOfDay(temDate)); end = sdf.format(DateUtil.endOfDay(temDate));
// break; break;
// case BizParamConstant.STAT_BIZ_WEEK: case BizParamConstant.STAT_BIZ_WEEK:
// begin = sdf.format(DateUtil.beginOfWeek(temDate)); begin = sdf.format(DateUtil.beginOfWeek(temDate));
// end = sdf.format(DateUtil.endOfWeek(temDate)); end = sdf.format(DateUtil.endOfWeek(temDate));
// break; break;
// case BizParamConstant.STAT_BIZ_MONTH: case BizParamConstant.STAT_BIZ_MONTH:
// begin = sdf.format(DateUtil.beginOfMonth(temDate)); begin = sdf.format(DateUtil.beginOfMonth(temDate));
// end = sdf.format(DateUtil.endOfMonth(temDate)); end = sdf.format(DateUtil.endOfMonth(temDate));
// break; break;
// case BizParamConstant.STAT_BIZ_QUARTER: case BizParamConstant.STAT_BIZ_QUARTER:
// begin = sdf.format(DateUtil.beginOfQuarter(temDate)); begin = sdf.format(DateUtil.beginOfQuarter(temDate));
// end = sdf.format(DateUtil.endOfQuarter(temDate)); end = sdf.format(DateUtil.endOfQuarter(temDate));
// break; break;
// case BizParamConstant.STAT_BIZ_YEAR: case BizParamConstant.STAT_BIZ_YEAR:
// begin = sdf.format(DateUtil.beginOfYear(temDate)); begin = sdf.format(DateUtil.beginOfYear(temDate));
// end = sdf.format(DateUtil.endOfYear(temDate)); end = sdf.format(DateUtil.endOfYear(temDate));
// break; break;
// default: default:
// begin = sdf.format(DateUtil.beginOfDay(temDate)); begin = sdf.format(DateUtil.beginOfDay(temDate));
// end = sdf.format(DateUtil.endOfDay(temDate)); end = sdf.format(DateUtil.endOfDay(temDate));
// break; break;
// } }
// lineParam.setBeginTime(begin); lineParam.setBeginTime(begin);
// lineParam.setEndTime(end); lineParam.setEndTime(end);
// lineParam.setDataDate(begin.substring(0, 10)); lineParam.setDataDate(begin.substring(0, 10));
// } }
//
//} }