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

预处理兼容pq/pms处理

Browse Source
This commit is contained in:
雨木c
2023-09-21 16:41:54 +08:00
parent 2d3d21504b
commit 4a4f1b56ba
4 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmIntegrityJob.java
View File

@@ -42,6 +42,7 @@ public class HarmIntegrityJob {
lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_DAY)); lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_DAY));
lineParam.setDataDate(CommonExecutorUtils.prepareTimeDeal(BizParamConstant.STAT_BIZ_DAY)); lineParam.setDataDate(CommonExecutorUtils.prepareTimeDeal(BizParamConstant.STAT_BIZ_DAY));
lineParam.setDataSource(2); lineParam.setDataSource(2);
CommonExecutorUtils.commDefineDate(BizParamConstant.STAT_BIZ_DAY,lineParam);
integrityFeignClient.dataIntegrity(lineParam); integrityFeignClient.dataIntegrity(lineParam);
} }

2
pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmLimitRateJob.java
View File

@@ -48,6 +48,8 @@ public class HarmLimitRateJob {
lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_DAY)); lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_DAY));
lineParam.setDataDate(CommonExecutorUtils.prepareTimeDeal(BizParamConstant.STAT_BIZ_DAY)); lineParam.setDataDate(CommonExecutorUtils.prepareTimeDeal(BizParamConstant.STAT_BIZ_DAY));
lineParam.setDataSource(2); lineParam.setDataSource(2);
CommonExecutorUtils.commDefineDate(BizParamConstant.STAT_BIZ_DAY,lineParam);
limitrateFeignClient.limitRate(lineParam); limitrateFeignClient.limitRate(lineParam);
} }

2
pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmLimitTargetJob.java
View File

@@ -43,6 +43,8 @@ public class HarmLimitTargetJob {
lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_DAY)); lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_DAY));
lineParam.setDataDate(CommonExecutorUtils.prepareTimeDeal(BizParamConstant.STAT_BIZ_DAY)); lineParam.setDataDate(CommonExecutorUtils.prepareTimeDeal(BizParamConstant.STAT_BIZ_DAY));
lineParam.setDataSource(2); lineParam.setDataSource(2);
CommonExecutorUtils.commDefineDate(BizParamConstant.STAT_BIZ_DAY,lineParam);
limitTargetFeignClient.limitTargetData(lineParam); limitTargetFeignClient.limitTargetData(lineParam);
} }

2
pqs-job/job-executor/src/main/java/com/njcn/executor/handler/HarmPollutionJob.java
View File

@@ -40,6 +40,8 @@ public class HarmPollutionJob {
//测试数据部署时注释 //测试数据部署时注释
//date = "2022-10-21"; //date = "2022-10-21";
lineParam.setDataDate(date); lineParam.setDataDate(date);
CommonExecutorUtils.commDefineDate(command,lineParam);
pollutionFeignClient.processPollutionData(lineParam); pollutionFeignClient.processPollutionData(lineParam);
} }