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

算法入口添加异步注解,防止xxl日志显示失败,实际算法执行成功的问题

Browse Source
This commit is contained in:
xuyang
2023-11-17 08:54:07 +08:00
parent 9e779d5ed5
commit 59e48ffed5
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -28,6 +28,7 @@ import io.swagger.annotations.ApiOperation;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.collections.CollectionUtils; import org.apache.commons.collections.CollectionUtils;
import org.springframework.scheduling.annotation.Async;
import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMapping;
@@ -110,6 +111,7 @@ public class ExecutionCenter extends BaseController {
@OperateInfo(info = LogEnum.BUSINESS_COMMON) @OperateInfo(info = LogEnum.BUSINESS_COMMON)
@ApiOperation("监测点算法执行链") @ApiOperation("监测点算法执行链")
@PostMapping("/measurementPointExecutor") @PostMapping("/measurementPointExecutor")
@Async("asyncExecutor")
public void measurementPointExecutor(@RequestBody BaseParam baseParam) { public void measurementPointExecutor(@RequestBody BaseParam baseParam) {
String methodDescribe = getMethodDescribe("measurementPointExecutor"); String methodDescribe = getMethodDescribe("measurementPointExecutor");
//手动判断参数是否合法, //手动判断参数是否合法,
@@ -144,6 +146,7 @@ public class ExecutionCenter extends BaseController {
@OperateInfo(info = LogEnum.BUSINESS_COMMON) @OperateInfo(info = LogEnum.BUSINESS_COMMON)
@ApiOperation("单位监测点算法执行链") @ApiOperation("单位监测点算法执行链")
@PostMapping("/orgPointExecutor") @PostMapping("/orgPointExecutor")
@Async("asyncExecutor")
public void orgPointExecutor(@RequestBody BaseParam baseParam) { public void orgPointExecutor(@RequestBody BaseParam baseParam) {
String methodDescribe = getMethodDescribe("OrgPointExecutor"); String methodDescribe = getMethodDescribe("OrgPointExecutor");
//手动判断参数是否合法, //手动判断参数是否合法,
@@ -182,6 +185,7 @@ public class ExecutionCenter extends BaseController {
@OperateInfo(info = LogEnum.BUSINESS_COMMON) @OperateInfo(info = LogEnum.BUSINESS_COMMON)
@ApiOperation("变电站算法执行链") @ApiOperation("变电站算法执行链")
@PostMapping("/substationExecutor") @PostMapping("/substationExecutor")
@Async("asyncExecutor")
public void substationExecutor(@RequestBody BaseParam baseParam) { public void substationExecutor(@RequestBody BaseParam baseParam) {
String methodDescribe = getMethodDescribe("substationExecutor"); String methodDescribe = getMethodDescribe("substationExecutor");
//手动判断参数是否合法, //手动判断参数是否合法,