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

调度模块调整

Browse Source
This commit is contained in:
雨木c
2023-09-28 09:17:33 +08:00
parent ae3ff91328
commit d327814ade
5 changed files with 15 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmAberrationRateJob.java
View File

@@ -32,8 +32,9 @@ public class HarmAberrationRateJob {
lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_DAY));
String date = CommonExecutorUtils.prepareTimeDeal(BizParamConstant.STAT_BIZ_DAY);
//date = "2022-10-26";
lineParam.setDataDate(date);
lineParam.setDataSource(1);
//lineParam.setDataDate(date);
//lineParam.setDataSource(1);
CommonExecutorUtils.commDefineDate(BizParamConstant.STAT_BIZ_DAY,lineParam);
distortionRateFeignClient.harmonicThdDay(lineParam);
}

5
pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmComprehensiveAssessJob.java
View File

@@ -40,8 +40,9 @@ public class HarmComprehensiveAssessJob {
public void comprehensiveAssessHandlerToMysql(){
LineParam lineParam = new LineParam();
lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_DAY));
lineParam.setDataDate(CommonExecutorUtils.prepareTimeDeal(BizParamConstant.STAT_BIZ_DAY));
lineParam.setDataSource(2);
//lineParam.setDataDate(CommonExecutorUtils.prepareTimeDeal(BizParamConstant.STAT_BIZ_DAY));
//lineParam.setDataSource(2);
CommonExecutorUtils.commDefineDate(BizParamConstant.STAT_BIZ_DAY,lineParam);
harmonicGeneralFeignClient.generalDataToMysql(lineParam);
}
}

5
pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmKpiAssessJob.java
View File

@@ -41,8 +41,9 @@ public class HarmKpiAssessJob {
public void kpiAssessHandlerToMysql(){
LineParam lineParam = new LineParam();
lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_DAY));
lineParam.setDataDate(CommonExecutorUtils.prepareTimeDeal(BizParamConstant.STAT_BIZ_DAY));
lineParam.setDataSource(2);
//lineParam.setDataDate(CommonExecutorUtils.prepareTimeDeal(BizParamConstant.STAT_BIZ_DAY));
//lineParam.setDataSource(2);
CommonExecutorUtils.commDefineDate(BizParamConstant.STAT_BIZ_DAY,lineParam);
harmonicMetricFeignClient.metricDataToMysql(lineParam);
}
}

5
pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmOnlineRateJob.java
View File

@@ -36,8 +36,9 @@ public class HarmOnlineRateJob {
public void harmOnlineRateJobToMysql(){
LineParam lineParam = new LineParam();
lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_DAY));
lineParam.setDataDate(CommonExecutorUtils.prepareTimeDeal(BizParamConstant.STAT_BIZ_DAY));
lineParam.setDataSource(2);
//lineParam.setDataDate(CommonExecutorUtils.prepareTimeDeal(BizParamConstant.STAT_BIZ_DAY));
//lineParam.setDataSource(2);
CommonExecutorUtils.commDefineDate(BizParamConstant.STAT_BIZ_DAY,lineParam);
onlineRateFeignClient.onlineRateData(lineParam);
}

5
pqs-job/job-executor/src/main/java/com/njcn/executor/handler/RMpEventDetailJob.java
View File

@@ -31,8 +31,9 @@ public class RMpEventDetailJob {
log.info(LocalDateTime.now()+"监测点暂态指标处理调度开始------------------------");
LineParam lineParam = new LineParam();
lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_DAY));
lineParam.setDataDate(CommonExecutorUtils.prepareTimeDeal(BizParamConstant.STAT_BIZ_DAY));
lineParam.setDataSource(2);
//lineParam.setDataDate(CommonExecutorUtils.prepareTimeDeal(BizParamConstant.STAT_BIZ_DAY));
//lineParam.setDataSource(2);
CommonExecutorUtils.commDefineDate(BizParamConstant.STAT_BIZ_DAY,lineParam);
rMpEventDetailFeignClient.eventdetailHandler(lineParam);
}