refactor: 优化默认buffer大小

Author: zhou-hao

hsweb-commons/hsweb-commons-crud/src/main/java/org/hswebframework/web/crud/service/GenericReactiveTreeSupportCrudService.java

@@ -6,6 +6,8 @@
 
 public abstract class GenericReactiveTreeSupportCrudService<E extends TreeSortSupportEntity<K>, K> implements ReactiveTreeSortEntityService<E, K> {
 
+    private static final int SAVE_BUFFER_SIZE = Integer.getInteger("tree.save.buffer.size", 200);
+
     @Autowired
     private ReactiveRepository<E, K> repository;
 
@@ -14,4 +16,8 @@ public ReactiveRepository<E, K> getRepository() {
         return repository;
     }
 
+    @Override
+    public int getBufferSize() {
+        return SAVE_BUFFER_SIZE;
+    }
 }

hsweb-commons/hsweb-commons-crud/src/main/java/org/hswebframework/web/crud/service/ReactiveTreeSortEntityService.java

@@ -303,7 +303,7 @@ default Mono<SaveResult> save(Publisher<E> entityPublisher) {
             .prepare(Flux.from(entityPublisher))
 //                .doOnNext(e -> e.tryValidate(CreateGroup.class))
             .buffer(getBufferSize())
-            .flatMap(this.getRepository()::save)
+            .concatMap(this.getRepository()::save)
             .reduce(SaveResult::merge);
 
     }