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

1.部分算法调度任务添加

Browse Source
This commit is contained in:
xuyang
2023-07-27 08:56:28 +08:00
parent 1d6ae663ab
commit 950952f9a2
4 changed files with 107 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

49
pqs-job/job-executor/src/main/java/com/njcn/executor/handler/RMpPassrateJob.java Normal file
View File

@@ -0,0 +1,49 @@
package com.njcn.executor.handler;
import com.njcn.common.pojo.constant.BizParamConstant;
import com.njcn.executor.utils.CommonExecutorUtils;
import com.njcn.prepare.harmonic.api.newalgorithm.RMpPassrateFeignClient;
import com.njcn.prepare.harmonic.api.newalgorithm.ROperatingMonitorFeignClient;
import com.njcn.prepare.harmonic.pojo.param.LineParam;
import com.xxl.job.core.handler.annotation.XxlJob;
import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Component;
import java.time.LocalDateTime;
/**
* 类的介绍：
*
* @author xuyang
* @version 1.0.0
* @createTime 2023/7/26 15:55
*/
@Slf4j
@Component
@RequiredArgsConstructor
public class RMpPassrateJob {
private final RMpPassrateFeignClient rMpPassrateFeignClient;
@XxlJob("rMpPassrateDay")
public void rMpPassrateDay(){
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);
rMpPassrateFeignClient.passRateHandler(lineParam);
}
@XxlJob("rMpPassrateMonth")
public void rMpPassrateMonth(){
log.info(LocalDateTime.now()+"监测点稳态指标合格率_月统计调度开始------------------------");
LineParam lineParam = new LineParam();
lineParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_MONTH));
lineParam.setDataDate(CommonExecutorUtils.prepareTimeDeal(BizParamConstant.STAT_BIZ_MONTH));
lineParam.setDataSource(2);
rMpPassrateFeignClient.passRateHandler(lineParam);
}
}

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

@@ -40,7 +40,6 @@ public class RStatHarmonicJob {
OrgParam orgParam = new OrgParam();
orgParam.setType(Integer.valueOf(BizParamConstant.STAT_BIZ_MONTH));
orgParam.setDataDate(CommonExecutorUtils.prepareTimeDeal(BizParamConstant.STAT_BIZ_MONTH));
System.out.println("orgParam==:" + orgParam);
rStatHarmonicFeignClient.handler(orgParam);
}