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

1

Browse Source
This commit is contained in:
xuyang
2024-01-04 14:40:39 +08:00
parent 98a52ab626
commit fde344c710
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;
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);
// }
//}

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;
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);
// }
//}

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;
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);
// }
//}

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;
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);
// }
//}

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;
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);
// }
//}

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;
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);
// }
//}

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;
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);
// }
//}

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

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;
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));
// }
//
//}

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;
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));
// }
//
//}

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;
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));
// }
//
//}

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;
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")));
// }
//}

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;
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);
// }
//}

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;
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);
// }
//}

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;
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));
// }
//
//}