diff --git a/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/LiteFlowJob.java b/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/LiteFlowJob.java index 53f8c21d9..e794255b5 100644 --- a/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/LiteFlowJob.java +++ b/pqs-job/job-executor/src/main/java/com/njcn/executor/handler/LiteFlowJob.java @@ -1,10 +1,11 @@ package com.njcn.executor.handler; -import cn.hutool.core.util.StrUtil; -import com.njcn.energy.pojo.api.EleAirStrategyFeignClient; +import cn.hutool.core.date.DatePattern; +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.web.pojo.param.BaseParam; -import com.xxl.job.core.context.XxlJobHelper; +import com.njcn.prepare.harmonic.pojo.bo.BaseParam; import com.xxl.job.core.handler.annotation.XxlJob; import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; @@ -27,20 +28,28 @@ public class LiteFlowJob { @XxlJob("measurementPointJob") public void measurementPointJob() { BaseParam baseParam = new BaseParam(); - - - - + baseParam.setFullChain(true); + baseParam.setRepair(false); + baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN)); + liteFlowFeignClient.measurementPointExecutor(baseParam); } @XxlJob("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") 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); } }