From 4388a215e23b109d43133dddce16e4fda1837344 Mon Sep 17 00:00:00 2001
From: xuyang <748613696@qq.com>
Date: Thu, 30 Nov 2023 15:57:32 +0800
Subject: [PATCH] =?UTF-8?q?=E7=AE=97=E6=B3=95=E8=B0=83=E5=BA=A6=E4=BB=BB?=
 =?UTF-8?q?=E5=8A=A1=E6=B7=BB=E5=8A=A0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../main/java/com/njcn/executor/handler/LiteFlowJob.java | 9 +++++++++
 .../harmonic/api/liteflow/LiteFlowFeignClient.java       | 4 ++++
 .../fallback/LiteFlowFeignClientFallbackFactory.java     | 6 ++++++
 3 files changed, 19 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 e794255b5..e1ac76fad 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
@@ -52,4 +52,13 @@ public class LiteFlowJob {
         liteFlowFeignClient.substationExecutor(baseParam);
     }
 
+    @XxlJob("deviceJob")
+    public void deviceJob() {
+        BaseParam baseParam = new BaseParam();
+        baseParam.setFullChain(true);
+        baseParam.setRepair(false);
+        baseParam.setDataDate(DateUtil.yesterday().toString(DatePattern.NORM_DATE_PATTERN));
+        liteFlowFeignClient.substationExecutor(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 bca4ca5bc..e94692275 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
@@ -31,4 +31,8 @@ public interface LiteFlowFeignClient {
     @PostMapping("/substationExecutor")
     void substationExecutor(@RequestBody BaseParam baseParam);
 
+    @ApiOperation("装置算法执行链")
+    @PostMapping("/deviceExecutor")
+    void deviceExecutor(@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 4562caede..86a870ac1 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
@@ -39,6 +39,12 @@ public class LiteFlowFeignClientFallbackFactory implements FallbackFactory<LiteF
                 log.error("{}异常，降级处理，异常为：{}", "变电站算法执行链:  ", throwable.toString());
                 throw new BusinessException(finalExceptionEnum);
             }
+
+            @Override
+            public void deviceExecutor(BaseParam baseParam) {
+                log.error("{}异常，降级处理，异常为：{}", "装置算法执行链:  ", throwable.toString());
+                throw new BusinessException(finalExceptionEnum);
+            }
         };
     }
 }