From 3782ac69004b990a5ee23953ad9117e42abba00e Mon Sep 17 00:00:00 2001
From: wr <1754607820@qq.com>
Date: Wed, 6 Mar 2024 17:36:14 +0800
Subject: [PATCH] =?UTF-8?q?1.=E5=8D=95=E4=BD=8D=E5=8F=98=E7=94=B5=E7=AB=99?=
 =?UTF-8?q?=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    |  9 +++++
 .../api/liteflow/LiteFlowFeignClient.java     |  4 ++
 .../LiteFlowFeignClientFallbackFactory.java   |  6 +++
 .../timer/tasks/OrgSubStationTaskRunner.java  | 39 +++++++++++++++++++
 4 files changed, 58 insertions(+)
 create mode 100644 pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/OrgSubStationTaskRunner.java

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 958454139..0f7e518f4 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
@@ -79,4 +79,13 @@ public class LiteFlowJob {
         liteFlowFeignClient.generaTrixExecutor(baseParam);
     }
 
+    @XxlJob("generaTrixJob")
+    public void orgSubStationExecutor() {
+        BaseParam baseParam = new BaseParam();
+        baseParam.setFullChain(true);
+        baseParam.setRepair(false);
+        baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN));
+        liteFlowFeignClient.orgSubStationExecutor(baseParam);
+    }
+
 }
diff --git a/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/liteflow/LiteFlowFeignClient.java b/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/liteflow/LiteFlowFeignClient.java
index 9be22e5ec..e3036e2c7 100644
--- a/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/liteflow/LiteFlowFeignClient.java
+++ b/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/liteflow/LiteFlowFeignClient.java
@@ -47,4 +47,8 @@ public interface LiteFlowFeignClient {
     @ApiOperation("母线算法执行链(主网测点)")
     @PostMapping("/generaTrixExecutor")
     void generaTrixExecutor(@RequestBody BaseParam baseParam);
+
+    @ApiOperation("单位变电站算法执行链")
+    @PostMapping("/orgSubStationExecutor")
+    void orgSubStationExecutor(@RequestBody BaseParam baseParam);
 }
diff --git a/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/liteflow/fallback/LiteFlowFeignClientFallbackFactory.java b/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/liteflow/fallback/LiteFlowFeignClientFallbackFactory.java
index 02ab7a03b..b62129719 100644
--- a/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/liteflow/fallback/LiteFlowFeignClientFallbackFactory.java
+++ b/pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/liteflow/fallback/LiteFlowFeignClientFallbackFactory.java
@@ -63,6 +63,12 @@ public class LiteFlowFeignClientFallbackFactory implements FallbackFactory<LiteF
                 log.error("{}异常，降级处理，异常为：{}", "母线算法执行链(主网测点):  ", throwable.toString());
                 throw new BusinessException(finalExceptionEnum);
             }
+
+            @Override
+            public void orgSubStationExecutor(BaseParam baseParam) {
+                log.error("{}异常，降级处理，异常为：{}", "单位变电站算法执行链:  ", throwable.toString());
+                throw new BusinessException(finalExceptionEnum);
+            }
         };
     }
 }
diff --git a/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/OrgSubStationTaskRunner.java b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/OrgSubStationTaskRunner.java
new file mode 100644
index 000000000..d691e4966
--- /dev/null
+++ b/pqs-system/system-boot/src/main/java/com/njcn/system/timer/tasks/OrgSubStationTaskRunner.java
@@ -0,0 +1,39 @@
+package com.njcn.system.timer.tasks;
+
+import cn.hutool.core.date.DatePattern;
+import cn.hutool.core.date.DateUtil;
+import cn.hutool.core.util.StrUtil;
+import com.njcn.prepare.harmonic.api.liteflow.LiteFlowFeignClient;
+import com.njcn.prepare.harmonic.pojo.bo.BaseParam;
+import com.njcn.system.timer.TimerTaskRunner;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+
+/**
+ * 类的介绍：监测点算法执行链定时任务
+ *
+ * @author xuyang
+ * @version 1.0.0
+ * @createTime 2023/12/6 9:35
+ */
+@Component
+@RequiredArgsConstructor
+public class OrgSubStationTaskRunner implements TimerTaskRunner {
+
+    private final LiteFlowFeignClient liteFlowFeignClient;
+
+    @Override
+    public void action(String date) {
+        BaseParam baseParam = new BaseParam();
+        baseParam.setFullChain(true);
+        baseParam.setRepair(false);
+        if(StrUtil.isBlank(date)){
+            baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN));
+        }else {
+            baseParam.setDataDate(date);
+        }
+        liteFlowFeignClient.orgSubStationExecutor(baseParam);
+    }
+
+
+}