diff --git a/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmIntegrityJob.java b/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmIntegrityJob.java index 768433b8b..5dd1d06e4 100644 --- a/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmIntegrityJob.java +++ b/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmIntegrityJob.java @@ -42,6 +42,7 @@ public class HarmIntegrityJob { lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_DAY)); lineParam.setDataDate(CommonExecutorUtils.prepareTimeDeal(BizParamConstant.STAT_BIZ_DAY)); lineParam.setDataSource(2); + CommonExecutorUtils.commDefineDate(BizParamConstant.STAT_BIZ_DAY,lineParam); integrityFeignClient.dataIntegrity(lineParam); } diff --git a/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmLimitRateJob.java b/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmLimitRateJob.java index 1035b3746..6584171dd 100644 --- a/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmLimitRateJob.java +++ b/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmLimitRateJob.java @@ -48,6 +48,8 @@ public class HarmLimitRateJob { lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_DAY)); lineParam.setDataDate(CommonExecutorUtils.prepareTimeDeal(BizParamConstant.STAT_BIZ_DAY)); lineParam.setDataSource(2); + CommonExecutorUtils.commDefineDate(BizParamConstant.STAT_BIZ_DAY,lineParam); + limitrateFeignClient.limitRate(lineParam); } diff --git a/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmLimitTargetJob.java b/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmLimitTargetJob.java index 96662db4f..dc665d5cc 100644 --- a/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmLimitTargetJob.java +++ b/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmLimitTargetJob.java @@ -43,6 +43,8 @@ public class HarmLimitTargetJob { lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_DAY)); lineParam.setDataDate(CommonExecutorUtils.prepareTimeDeal(BizParamConstant.STAT_BIZ_DAY)); lineParam.setDataSource(2); + CommonExecutorUtils.commDefineDate(BizParamConstant.STAT_BIZ_DAY,lineParam); + limitTargetFeignClient.limitTargetData(lineParam); } diff --git a/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmPollutionJob.java b/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmPollutionJob.java index 9f4d302b8..94ed6d470 100644 --- a/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmPollutionJob.java +++ b/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmPollutionJob.java @@ -40,6 +40,8 @@ public class HarmPollutionJob { //测试数据部署时注释 //date = "2022-10-21"; lineParam.setDataDate(date); + CommonExecutorUtils.commDefineDate(command,lineParam); + pollutionFeignClient.processPollutionData(lineParam); }