diff --git a/src/main/java/com/luca/pilot/entity/PlanModule.java b/src/main/java/com/luca/pilot/entity/PlanModule.java index 0a939a00b40e53e41da5cb9503ae262fa4618a74..405a747ab75d9026b2fe2b86272b3d824c0c5d60 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 a756a8686bd8cb4f7587e6a08658ee19e426cd8d..704639a3ae79b673f21b32c7cd939b24c3960e70 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);