From 59e48ffed5302b82fc9c66fb9048d05d75789b89 Mon Sep 17 00:00:00 2001
From: xuyang <748613696@qq.com>
Date: Fri, 17 Nov 2023 08:54:07 +0800
Subject: [PATCH] =?UTF-8?q?=E7=AE=97=E6=B3=95=E5=85=A5=E5=8F=A3=E6=B7=BB?=
 =?UTF-8?q?=E5=8A=A0=E5=BC=82=E6=AD=A5=E6=B3=A8=E8=A7=A3,=E9=98=B2?=
 =?UTF-8?q?=E6=AD=A2xxl=E6=97=A5=E5=BF=97=E6=98=BE=E7=A4=BA=E5=A4=B1?=
 =?UTF-8?q?=E8=B4=A5,=E5=AE=9E=E9=99=85=E7=AE=97=E6=B3=95=E6=89=A7?=
 =?UTF-8?q?=E8=A1=8C=E6=88=90=E5=8A=9F=E7=9A=84=E9=97=AE=E9=A2=98?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../src/main/java/com/njcn/prepare/ExecutionCenter.java       | 4 ++++
 1 file changed, 4 insertions(+)

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