From b6b84641d704d98b20f35aa5ab211228c6218ce7 Mon Sep 17 00:00:00 2001
From: huangjin <huangjin@lucahealthcare.com>
Date: Fri, 30 Aug 2024 15:21:02 +0800
Subject: [PATCH] =?UTF-8?q?=E5=BC=82=E6=AD=A5=E6=8F=90=E4=BA=A4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../java/com/luca/pilot/service/impl/PlanServiceImpl.java | 7 +++++--
src/test/java/com/luca/pilot/PlanTaskTest.java | 2 +-
2 files changed, 6 insertions(+), 3 deletions(-)
diff --git a/src/main/java/com/luca/pilot/service/impl/PlanServiceImpl.java b/src/main/java/com/luca/pilot/service/impl/PlanServiceImpl.java
index 232ebba..8a8b0f5 100644
--- a/src/main/java/com/luca/pilot/service/impl/PlanServiceImpl.java
+++ b/src/main/java/com/luca/pilot/service/impl/PlanServiceImpl.java
@@ -27,6 +27,7 @@ import javax.annotation.Resource;
import java.time.*;
import java.time.format.DateTimeFormatter;
import java.util.*;
+import java.util.concurrent.CompletableFuture;
import java.util.stream.Collectors;
import java.util.stream.Stream;
@@ -240,8 +241,10 @@ public class PlanServiceImpl implements PlanService {
// 鏄惁绗竴娆″叏閲忔彃鍏�
if (totalPlanModuleCount > 0) {
- bulkOps.execute();
- log.info("bulkOps 鏇存柊鎴栨彃鍏� {} 鏉℃暟鎹�", planMoudles.size());
+ CompletableFuture.runAsync(() -> {
+ bulkOps.execute();
+ log.info("bulkOps 鏇存柊鎴栨彃鍏� {} 鏉℃暟鎹�", planMoudles.size());
+ });
} else {
if (!CollectionUtils.isEmpty(planMoudles)) {
mongoTemplate.insert(planMoudles, PlanModule.class);
diff --git a/src/test/java/com/luca/pilot/PlanTaskTest.java b/src/test/java/com/luca/pilot/PlanTaskTest.java
index c77b6aa..f2b58c9 100644
--- a/src/test/java/com/luca/pilot/PlanTaskTest.java
+++ b/src/test/java/com/luca/pilot/PlanTaskTest.java
@@ -16,7 +16,7 @@ import java.util.List;
@Slf4j
@SpringBootTest
-@ActiveProfiles("uat")
+@ActiveProfiles("hj")
public class PlanTaskTest {
@Autowired
private MongoTemplate mongoTemplate;
--
GitLab