支持自动将下载完成的文件上传至alist

wushuo894 · Nov 13, 2024 · 6e6ae52 · 6e6ae52
1 parent 3eaa5a6
commit 6e6ae52
Showing 1 changed file with 7 additions and 2 deletions.
diff --git a/src/main/java/ani/rss/util/AlistUtil.java b/src/main/java/ani/rss/util/AlistUtil.java
@@ -65,7 +65,12 @@ public static void upload(TorrentsInfo torrentsInfo) {
             filePath += "/" + string;
             String finalFilePath = filePath;
             EXECUTOR.execute(() -> {
-                log.info("上传 {} ==> {}", string, finalFilePath);
+                File file = new File(downloadDir + "/" + string);
+                if (!file.exists()) {
+                    log.error("文件不存在 {}", file);
+                    return;
+                }
+                log.info("上传 {} ==> {}", file, finalFilePath);
                 try {
                     String url = alistHost;
                     if (url.endsWith("/")) {
@@ -78,7 +83,7 @@ public static void upload(TorrentsInfo torrentsInfo) {
                             .header(Header.AUTHORIZATION, alistToken)
                             .header("As-Task", "true")
                             .header("File-Path", URLUtil.encode(finalFilePath))
-                            .form("file", new File(downloadDir + "/" + string))
+                            .form("file", file)
                             .then(res -> {
                                 Assert.isTrue(res.isOk(), "上传失败 {} 状态码:{}", string, res.getStatus());
                                 log.info("已向alist添加上传任务 {}", string);