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