From d327814ade97122a3f51ae8bdfc06b5555e85700 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=9B=A8=E6=9C=A8c?= <857448963@qq.com> Date: Thu, 28 Sep 2023 09:17:33 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E5=BA=A6=E6=A8=A1=E5=9D=97=E8=B0=83?= =?UTF-8?q?=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/njcn/executor/handler/HarmAberrationRateJob.java | 5 +++-- .../njcn/executor/handler/HarmComprehensiveAssessJob.java | 5 +++-- .../java/com/njcn/executor/handler/HarmKpiAssessJob.java | 5 +++-- .../java/com/njcn/executor/handler/HarmOnlineRateJob.java | 5 +++-- .../java/com/njcn/executor/handler/RMpEventDetailJob.java | 5 +++-- 5 files changed, 15 insertions(+), 10 deletions(-) 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); }