diff --git a/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmAberrationRateJob.java b/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmAberrationRateJob.java index fd08e3044..a6a4ee6f8 100644 --- a/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmAberrationRateJob.java +++ b/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmAberrationRateJob.java @@ -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); } diff --git a/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmComprehensiveAssessJob.java b/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmComprehensiveAssessJob.java index 90e22f8c9..a1eb2b3b3 100644 --- a/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmComprehensiveAssessJob.java +++ b/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmComprehensiveAssessJob.java @@ -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); } } diff --git a/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmKpiAssessJob.java b/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmKpiAssessJob.java index eed9ff188..9dcce23cf 100644 --- a/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmKpiAssessJob.java +++ b/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmKpiAssessJob.java @@ -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); } } diff --git a/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmOnlineRateJob.java b/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmOnlineRateJob.java index bf31ac379..31820c295 100644 --- a/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmOnlineRateJob.java +++ b/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmOnlineRateJob.java @@ -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); } diff --git a/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/RMpEventDetailJob.java b/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/RMpEventDetailJob.java index 3896e62de..af6624e22 100644 --- a/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/RMpEventDetailJob.java +++ b/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/RMpEventDetailJob.java @@ -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); }