optimize: 递归导入逻辑由同步到并行

Author: li-guohao

CHANGELOG.MD

@@ -7,6 +7,7 @@
 ## 优化
 
 - 启动时自动加载alist的token
+- 递归导入逻辑由同步到并行
 
 # 0.12.6
 

src/main/java/run/ikaros/plugin/alist/AListClient.java

@@ -4,7 +4,6 @@
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.DisposableBean;
 import org.springframework.beans.factory.InitializingBean;
-import org.springframework.boot.context.event.ApplicationReadyEvent;
 import org.springframework.context.event.EventListener;
 import org.springframework.http.HttpEntity;
 import org.springframework.http.HttpHeaders;
@@ -93,13 +92,12 @@ private Mono<Void> createAttachmentRecursively(List<String> paths, Long parentId
                 .flatMap(this::saveAListAttachment)
                 .flatMap(aListAttachment -> {
                     if (aListAttachment.getIs_dir()) {
-                        List<String> paths1 = aListAttachment.getPaths();
-                        return createAttachmentRecursively(paths1, aListAttachment.getId())
+                        return Mono.defer(() ->
+                                        createAttachmentRecursively(aListAttachment.getPaths(), aListAttachment.getId()))
                                 .subscribeOn(Schedulers.boundedElastic());
                     } else {
                         return Mono.empty();
                     }
-
                 })
                 .then();
     }
@@ -148,15 +146,15 @@ private Mono<AListAttachment> saveAListAttachment(AListAttachment aListAttachmen
                         aListAttachment.getParentId(), aListAttachment.getName())
                 .filter(exists -> !exists)
                 .flatMap(exists -> attachmentOperate.save(
-                        Attachment.builder()
-                                .parentId(aListAttachment.getParentId())
-                                .name(aListAttachment.getName())
-                                .updateTime(LocalDateTime.now())
-                                .type(type)
-                                .size(aListAttachment.getSize())
-                                .url(aListAttachment.getRaw_url())
-                                .fsPath(getPathByPathArr(aListAttachment.getPaths()))
-                                .build())
+                                Attachment.builder()
+                                        .parentId(aListAttachment.getParentId())
+                                        .name(aListAttachment.getName())
+                                        .updateTime(LocalDateTime.now())
+                                        .type(type)
+                                        .size(aListAttachment.getSize())
+                                        .url(aListAttachment.getRaw_url())
+                                        .fsPath(getPathByPathArr(aListAttachment.getPaths()))
+                                        .build())
                         .doOnSuccess(att -> log.debug("Save attachment[{}] for alist[{}]", att.getName(), att.getFsPath())))
                 .then(attachmentOperate.findByTypeAndParentIdAndName(
                         type, aListAttachment.getParentId(), aListAttachment.getName()