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

xxlJob定时任务

Browse Source
This commit is contained in:
xuyang
2023-11-15 18:23:11 +08:00
parent 1ec64da829
commit 68ef4b63dd
1 changed files with 19 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
pqs-job/job-executor/src/main/java/com/njcn/executor/handler/LiteFlowJob.java
View File

@@ -1,10 +1,11 @@
package com.njcn.executor.handler; package com.njcn.executor.handler;
import cn.hutool.core.util.StrUtil; import cn.hutool.core.date.DatePattern;
import com.njcn.energy.pojo.api.EleAirStrategyFeignClient; import cn.hutool.core.date.DateTime;
import cn.hutool.core.date.DateUtil;
import cn.hutool.core.date.LocalDateTimeUtil;
import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient; import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient;
import com.njcn.web.pojo.param.BaseParam; import com.njcn.prepare.harmonic.pojo.bo.BaseParam;
import com.xxl.job.core.context.XxlJobHelper;
import com.xxl.job.core.handler.annotation.XxlJob; import com.xxl.job.core.handler.annotation.XxlJob;
import lombok.AllArgsConstructor; import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
@@ -27,20 +28,28 @@ public class LiteFlowJob {
@XxlJob("measurementPointJob") @XxlJob("measurementPointJob")
public void measurementPointJob() { public void measurementPointJob() {
BaseParam baseParam = new BaseParam(); BaseParam baseParam = new BaseParam();
baseParam.setFullChain(true);
baseParam.setRepair(false);
baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN));
liteFlowFeignClient.measurementPointExecutor(baseParam);
} }
@XxlJob("orgJob") @XxlJob("orgJob")
public void orgJob() { public void orgJob() {
BaseParam baseParam = new BaseParam();
baseParam.setFullChain(true);
baseParam.setRepair(false);
baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN));
liteFlowFeignClient.orgPointExecutor(baseParam);
} }
@XxlJob("substationJob") @XxlJob("substationJob")
public void substationJob() { public void substationJob() {
BaseParam baseParam = new BaseParam();
baseParam.setFullChain(true);
baseParam.setRepair(false);
baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN));
liteFlowFeignClient.substationExecutor(baseParam);
} }
} }