Microservice/pqs
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 1 Wiki Activity

算法对外接口添加

Browse Source
This commit is contained in:
xuyang
2023-12-05 10:01:14 +08:00
parent b96ebcad82
commit 59689b731b
3 changed files with 40 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
pqs-job/job-executor/src/main/java/com/njcn/executor/handler/LiteFlowJob.java
View File

@@ -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);
}
}

10
pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/liteflow/LiteFlowFeignClient.java
View File

@@ -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);
}

12
pqs-prepare/prepare-api/src/main/java/com/njcn/prepare/harmonic/api/liteflow/fallback/LiteFlowFeignClientFallbackFactory.java
View File

@@ -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);
}
};
}
}