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