From 564dcbf1c7758f579142a41415247cf87e0d6fd4 Mon Sep 17 00:00:00 2001 From: huangjin <huangjin@lucahealthcare.com> Date: Thu, 5 Sep 2024 12:24:26 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8E=BB=E9=99=A4=E5=BC=82=E6=AD=A5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/main/java/com/luca/pilot/entity/PlanModule.java | 2 +- .../java/com/luca/pilot/service/impl/PlanServiceImpl.java | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/src/main/java/com/luca/pilot/entity/PlanModule.java b/src/main/java/com/luca/pilot/entity/PlanModule.java index 0a939a0..405a747 100644 --- a/src/main/java/com/luca/pilot/entity/PlanModule.java +++ b/src/main/java/com/luca/pilot/entity/PlanModule.java @@ -4,7 +4,7 @@ import lombok.Data; import org.springframework.data.mongodb.core.mapping.Document; @Data -@Document(collection="plan_module") +@Document(collection="plan_module_hj") public class PlanModule { private String key; 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 a756a86..704639a 100644 --- a/src/main/java/com/luca/pilot/service/impl/PlanServiceImpl.java +++ b/src/main/java/com/luca/pilot/service/impl/PlanServiceImpl.java @@ -251,11 +251,11 @@ public class PlanServiceImpl implements PlanService { // 鏄惁绗竴娆″叏閲忔彃鍏� if (totalPlanModuleCount > 0) { - CompletableFuture.runAsync(() -> { +// CompletableFuture.runAsync(() -> { bulkOps.upsert(pairs); bulkOps.execute(); log.info("bulkOps 鏇存柊鎴栨彃鍏� {} 鏉℃暟鎹�", pairs.size()); - }); +// }); } else { if (!CollectionUtils.isEmpty(planMoudles)) { mongoTemplate.insert(planMoudles, PlanModule.class); -- GitLab