From 68ef4b63dde546d24a4b414a9387482d5d1b72ca Mon Sep 17 00:00:00 2001
From: xuyang <748613696@qq.com>
Date: Wed, 15 Nov 2023 18:23:11 +0800
Subject: [PATCH] =?UTF-8?q?xxlJob=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../njcn/executor/handler/LiteFlowJob.java    | 29 ++++++++++++-------
 1 file changed, 19 insertions(+), 10 deletions(-)

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