From 59689b731b96854035640e1d911ade91221f8fe3 Mon Sep 17 00:00:00 2001
From: xuyang <748613696@qq.com>
Date: Tue, 5 Dec 2023 10:01:14 +0800
Subject: [PATCH] =?UTF-8?q?=E7=AE=97=E6=B3=95=E5=AF=B9=E5=A4=96=E6=8E=A5?=
 =?UTF-8?q?=E5=8F=A3=E6=B7=BB=E5=8A=A0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/njcn/executor/handler/LiteFlowJob.java | 18 ++++++++++++++++++
 .../api/liteflow/LiteFlowFeignClient.java      | 10 ++++++++++
 .../LiteFlowFeignClientFallbackFactory.java    | 12 ++++++++++++
 3 files changed, 40 insertions(+)

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 32d7ac894..958454139 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
@@ -61,4 +61,22 @@ public class LiteFlowJob {
         liteFlowFeignClient.deviceExecutor(baseParam);
     }
 
+    @XxlJob("pmsDimJob")
+    public void pmsDimJob() {
+        BaseParam baseParam = new BaseParam();
+        baseParam.setFullChain(true);
+        baseParam.setRepair(false);
+        baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN));
+        liteFlowFeignClient.pmsDimExecutor(baseParam);
+    }
+
+    @XxlJob("generaTrixJob")
+    public void generaTrixJob() {
+        BaseParam baseParam = new BaseParam();
+        baseParam.setFullChain(true);
+        baseParam.setRepair(false);
+        baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN));
+        liteFlowFeignClient.generaTrixExecutor(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 e94692275..b83423530 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
@@ -1,11 +1,14 @@
 package com.njcn.prepare.harmonic.api.liteflow;
 
 
+import com.njcn.common.pojo.annotation.OperateInfo;
 import com.njcn.common.pojo.constant.ServerInfo;
+import com.njcn.common.pojo.enums.common.LogEnum;
 import com.njcn.prepare.harmonic.api.liteflow.fallback.LiteFlowFeignClientFallbackFactory;
 import com.njcn.prepare.harmonic.pojo.bo.BaseParam;
 import io.swagger.annotations.ApiOperation;
 import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
 
@@ -35,4 +38,11 @@ public interface LiteFlowFeignClient {
     @PostMapping("/deviceExecutor")
     void deviceExecutor(@RequestBody BaseParam baseParam);
 
+    @ApiOperation("pms变电站母线算法执行链")
+    @PostMapping("/pmsdimexecutor")
+    void pmsDimExecutor(@RequestBody BaseParam baseParam);
+
+    @ApiOperation("母线算法执行链(主网测点)")
+    @PostMapping("/generaTrixExecutor")
+    void generaTrixExecutor(@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 86a870ac1..2fcaf6490 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
@@ -45,6 +45,18 @@ public class LiteFlowFeignClientFallbackFactory implements FallbackFactory<LiteF
                 log.error("{}异常，降级处理，异常为：{}", "装置算法执行链:  ", throwable.toString());
                 throw new BusinessException(finalExceptionEnum);
             }
+
+            @Override
+            public void pmsDimExecutor(BaseParam baseParam) {
+                log.error("{}异常，降级处理，异常为：{}", "pms变电站母线算法执行链:  ", throwable.toString());
+                throw new BusinessException(finalExceptionEnum);
+            }
+
+            @Override
+            public void generaTrixExecutor(BaseParam baseParam) {
+                log.error("{}异常，降级处理，异常为：{}", "母线算法执行链(主网测点):  ", throwable.toString());
+                throw new BusinessException(finalExceptionEnum);
+            }
         };
     }
 }