From 0ff4f2fa3b0c2f6af5b0aba5eb77f2702422a7e4 Mon Sep 17 00:00:00 2001
From: huangjin <huangjin@lucahealthcare.com>
Date: Mon, 2 Sep 2024 12:20:20 +0800
Subject: [PATCH] =?UTF-8?q?=E5=8D=95=E6=AC=A1=E6=89=A7=E8=A1=8C?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../com/luca/pilot/service/impl/PlanServiceImpl.java | 10 ++++++----
1 file changed, 6 insertions(+), 4 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 eeeb59a..3b15ec7 100644
--- a/src/main/java/com/luca/pilot/service/impl/PlanServiceImpl.java
+++ b/src/main/java/com/luca/pilot/service/impl/PlanServiceImpl.java
@@ -76,7 +76,7 @@ public class PlanServiceImpl implements PlanService {
long totalPlanModuleCount = mongoTemplate.count(new Query(), PlanModule.class);
- BulkOperations bulkOps = mongoTemplate.bulkOps(BulkOperations.BulkMode.UNORDERED, PlanModule.class);
+// BulkOperations bulkOps = mongoTemplate.bulkOps(BulkOperations.BulkMode.UNORDERED, PlanModule.class);
for (int i = 0; i < skip; i++) {
countQuery.skip(i * 10000L);
@@ -232,7 +232,9 @@ public class PlanServiceImpl implements PlanService {
if (totalPlanModuleCount > 0) {
Query upsertQuery = new Query(where("key").is(planMoudle.getKey()));
Update update = buildUpdate(planMoudle);
- bulkOps.upsert(upsertQuery, update);
+// bulkOps.upsert(upsertQuery, update);
+ mongoTemplate.upsert(upsertQuery, update, PlanModule.class);
+ log.info("mongoTemplate upsert 1 鏉℃暟鎹�");
}
planMoudles.add(planMoudle);
}
@@ -242,8 +244,8 @@ public class PlanServiceImpl implements PlanService {
// 鏄惁绗竴娆″叏閲忔彃鍏�
if (totalPlanModuleCount > 0) {
// CompletableFuture.runAsync(() -> {
- bulkOps.execute();
- log.info("bulkOps 鏇存柊鎴栨彃鍏� {} 鏉℃暟鎹�", planMoudles.size());
+// bulkOps.execute();
+// log.info("bulkOps 鏇存柊鎴栨彃鍏� {} 鏉℃暟鎹�", planMoudles.size());
// });
} else {
if (!CollectionUtils.isEmpty(planMoudles)) {
--
GitLab