自有合并加入

src/main/java/com/winhc/service/impl/PidToMongoServiceImpl.java

@@ -39,10 +39,8 @@ public class PidToMongoServiceImpl implements PidToMongoService {
         BulkWriteResult bulkWriteResult = null;
         if (ids.size() > 0) {
             //todo 保存临时表,注意替换
-            //MongoCollection<Document> pid = mongoTemplate.getCollection(Base.PID_WAIT_MERGE_V9);
-            MongoCollection<Document> pid = mongoTemplate.getCollection("pid_wait_merge_v9_tmp");
-//            List<Document> documents = messages.stream().map(Document::new).collect(Collectors.toList());
-//            pid.insertMany(documents, new InsertManyOptions().ordered(false));
+            MongoCollection<Document> pid = mongoTemplate.getCollection(Base.PID_WAIT_MERGE_V9);
+//            MongoCollection<Document> pid = mongoTemplate.getCollection("pid_wait_merge_v9_tmp");
             List<WriteModel<Document>> updateDocuments = new ArrayList<>();
             ids.forEach(m -> {
                 Document filterDocument = new Document("_id", m.get("_id"));