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