From 4a4f1b56ba3ee36177aa2d31c2f346dd5de37d80 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=9B=A8=E6=9C=A8c?= <857448963@qq.com>
Date: Thu, 21 Sep 2023 16:41:54 +0800
Subject: [PATCH] =?UTF-8?q?=E9=A2=84=E5=A4=84=E7=90=86=E5=85=BC=E5=AE=B9pq?=
 =?UTF-8?q?/pms=E5=A4=84=E7=90=86?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../main/java/com/njcn/executor/handler/HarmIntegrityJob.java   | 1 +
 .../main/java/com/njcn/executor/handler/HarmLimitRateJob.java   | 2 ++
 .../main/java/com/njcn/executor/handler/HarmLimitTargetJob.java | 2 ++
 .../main/java/com/njcn/executor/handler/HarmPollutionJob.java   | 2 ++
 4 files changed, 7 insertions(+)

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