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

修改bug

Browse Source
This commit is contained in:
hzj
2025-03-10 11:10:23 +08:00
parent f2e50dd100
commit 9a8742b02c
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
pqs-prepare/prepare-boot/src/main/java/com/njcn/prepare/ExecutionCenter.java
View File

@@ -148,7 +148,7 @@ public class ExecutionCenter extends BaseController {
@ApiOperation("监测点算法执行链(按小时执行的算法)") @ApiOperation("监测点算法执行链(按小时执行的算法)")
@PostMapping("/measurementPointExecutorByHour") @PostMapping("/measurementPointExecutorByHour")
@Async("asyncExecutor") @Async("asyncExecutor")
public void measurementPointExecutorByHour(@RequestBody BaseParam baseParam) { public HttpResult<Boolean> measurementPointExecutorByHour(@RequestBody BaseParam baseParam) {
String methodDescribe = getMethodDescribe("measurementPointExecutorByHour"); String methodDescribe = getMethodDescribe("measurementPointExecutorByHour");
//手动判断参数是否合法, //手动判断参数是否合法,
CalculatedParam calculatedParam = judgeExecuteParam(baseParam); CalculatedParam calculatedParam = judgeExecuteParam(baseParam);
@@ -177,6 +177,7 @@ public class ExecutionCenter extends BaseController {
liteflowResponse = flowExecutor.execute2Resp("measurement_point_hour", calculatedParam); liteflowResponse = flowExecutor.execute2Resp("measurement_point_hour", calculatedParam);
dealResponse(calculatedParam, liteflowResponse, methodDescribe); dealResponse(calculatedParam, liteflowResponse, methodDescribe);
} }
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, true, methodDescribe);
} }
@OperateInfo(info = LogEnum.BUSINESS_COMMON) @OperateInfo(info = LogEnum.BUSINESS_COMMON)
@@ -301,7 +302,7 @@ public class ExecutionCenter extends BaseController {
@ApiOperation("变电站算法执行链") @ApiOperation("变电站算法执行链")
@PostMapping("/substationExecutor") @PostMapping("/substationExecutor")
@Async("asyncExecutor") @Async("asyncExecutor")
public HttpResult<Boolean> substationExecutor(@RequestBody BaseParam baseParam) { public void substationExecutor(@RequestBody BaseParam baseParam) {
String methodDescribe = getMethodDescribe("substationExecutor"); String methodDescribe = getMethodDescribe("substationExecutor");
//手动判断参数是否合法, //手动判断参数是否合法,
CalculatedParam<String> calculatedParam = judgeExecuteParam(baseParam); CalculatedParam<String> calculatedParam = judgeExecuteParam(baseParam);
@@ -342,7 +343,7 @@ public class ExecutionCenter extends BaseController {
liteflowResponse = flowExecutor.execute2Resp("sub_station", calculatedParam); liteflowResponse = flowExecutor.execute2Resp("sub_station", calculatedParam);
dealResponse(calculatedParam, liteflowResponse, methodDescribe); dealResponse(calculatedParam, liteflowResponse, methodDescribe);
} }
return HttpResultUtil.assembleCommonResponseResult(CommonResponseEnum.SUCCESS, true, methodDescribe);
} }
/** /**