创建条目的时候添加个标签

ikaros-dev · Oct 19, 2024 · 485b750 · 485b750
1 parent 75281bb
commit 485b750
Show file tree

Hide file tree

Showing 4 changed files with 20 additions and 3 deletions.
diff --git a/CHANGELOG.MD b/CHANGELOG.MD
@@ -1,4 +1,8 @@
 
+# 17.1.6
+
+- 创建条目的时候添加个标签
+
 # 17.1.5
 
 - 移除日志

diff --git a/gradle.properties b/gradle.properties
@@ -1,3 +1,3 @@
 group=run.ikaros.plugin
 description=A mikan plugin for ikaros.
-version=17.1.5
+version=17.1.6
diff --git a/src/main/java/run/ikaros/plugin/mikan/MikanSubHandler.java b/src/main/java/run/ikaros/plugin/mikan/MikanSubHandler.java
@@ -104,7 +104,6 @@ public Mono<Void> parseMikanSubRssAndAddToQbittorrent() {
                 .doOnNext(mikanRssItem ->
                         log.debug("start for each mikan rss item list for item title: {}",
                                 mikanRssItem.getTitle()))
-                .parallel()
                 .flatMap(mikanRssItem -> {
                     String mikanRssItemTitle = mikanRssItem.getTitle();
                     qbittorrentClient.addTorrentFromUrl(mikanRssItem.getTorrentUrl(),
@@ -161,6 +160,7 @@ public Mono<Void> parseMikanSubRssAndAddToQbittorrent() {
                     return subjectOperate.syncByPlatform(null, SubjectSyncPlatform.BGM_TV,
                             bgmTvSubjectId);
                 })
+                .flatMap(this::saveSubjectFromTag)
                 .doOnError(throwable -> log.error("parse mikan sub rss item fail.", throwable))
                 .doOnComplete(() -> {
                     // 如果新添加的种子文件状态是缺失文件，则需要再恢复下
@@ -190,6 +190,18 @@ private Mono<Subject> matchingSingleFile(Subject subject, String fileName, Long
                 .then(Mono.just(subject));
     }
 
+    private synchronized Mono<Subject> saveSubjectFromTag(Subject subject) {
+        final String tagName = "from:" + MikanPlugin.NAME;
+        return tagOperate.create(Tag.builder()
+                .createTime(LocalDateTime.now())
+                .type(TagType.SUBJECT)
+                .masterId(subject.getId())
+                .name(tagName)
+                .userId(-1L)
+                .build())
+                .map(tag -> subject);
+    }
+
     public Mono<Void> importQbittorrentFilesAndAddSubject() {
         return Mono.just(qbittorrentClient)
                 .doOnNext(qc ->
@@ -211,6 +223,7 @@ public Mono<Void> importQbittorrentFilesAndAddSubject() {
                         .filter(StringUtils::hasText)
                         .flatMap(bgmTvSubjectId -> subjectOperate.syncByPlatform(null,
                                         SubjectSyncPlatform.BGM_TV, bgmTvSubjectId)
+                                .flatMap(this::saveSubjectFromTag)
                                 .flatMap(subject -> {
                                     String contentPath = torrentInfo.getContentPath();
                                     File torrentFile = new File(contentPath);

diff --git a/src/main/resources/plugin.yaml b/src/main/resources/plugin.yaml
@@ -4,7 +4,7 @@ name: PluginMikan
 # plugin entry class that extends BasePlugin
 clazz: run.ikaros.plugin.mikan.MikanPlugin
 # plugin 'version' is a valid semantic version string (see semver.org).
-version: 17.1.5
+version: 17.1.6
 requires: ">=0.17.4"
 author:
   name: Ikaros OSS Team