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 eeeb59a6e8ae2f1cd8fa8214502b9e9fbe4c05ff..3b15ec72f75302091a4634d7069d1593af607625 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)) {