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 232ebba362c854281dd087edaf2e0044f6292a65..8a8b0f5579b95067cb908801bd591a1cc562354f 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 c77b6aa782697cf9d2ef9033d34cc9878d3dc9a0..f2b58c953dc3b63d536f7a523e155c7b091aab59 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;