From 712390328c81688b8e938648dc4476fd365b4104 Mon Sep 17 00:00:00 2001
From: wushuo <wushuo894@outlook.com>
Date: Thu, 16 Jan 2025 22:38:39 +0800
Subject: [PATCH] =?UTF-8?q?=E6=94=AF=E6=8C=81=E8=AE=BE=E7=BD=AERSS?=
 =?UTF-8?q?=E8=B6=85=E6=97=B6=E6=97=B6=E9=97=B4?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 UPDATE.md                                  | 6 +-----
 pom.xml                                    | 2 +-
 src/main/java/ani/rss/entity/Config.java   | 5 +++++
 src/main/java/ani/rss/util/AniUtil.java    | 1 +
 src/main/java/ani/rss/util/ConfigUtil.java | 1 +
 src/main/java/ani/rss/util/ItemsUtil.java  | 5 ++++-
 ui/src/config/Basic.vue                    | 8 ++++++++
 7 files changed, 21 insertions(+), 7 deletions(-)

diff --git a/UPDATE.md b/UPDATE.md
index b3ae318d..6c6456d8 100644
--- a/UPDATE.md
+++ b/UPDATE.md
@@ -1,5 +1 @@
-PWA主题色跟随系统主题
-
-close #143
-
-bgm点格子前先判断状态，防止刷屏 #142 @EzraRT
\ No newline at end of file
+支持设置RSS超时时间
diff --git a/pom.xml b/pom.xml
index 10defffd..991bec17 100644
--- a/pom.xml
+++ b/pom.xml
@@ -6,7 +6,7 @@
 
     <groupId>ani.rss</groupId>
     <artifactId>ani-rss</artifactId>
-    <version>1.1.220</version>
+    <version>1.1.221</version>
 
     <properties>
         <maven.compiler.source>11</maven.compiler.source>
diff --git a/src/main/java/ani/rss/entity/Config.java b/src/main/java/ani/rss/entity/Config.java
index fcaaaf7c..427f6399 100644
--- a/src/main/java/ani/rss/entity/Config.java
+++ b/src/main/java/ani/rss/entity/Config.java
@@ -108,6 +108,11 @@ public class Config implements Serializable {
      */
     private Boolean rss;
 
+    /**
+     * rss 超时时间 秒
+     */
+    private Integer rssTimeout;
+
     /**
      * 文件已下载自动跳过
      */
diff --git a/src/main/java/ani/rss/util/AniUtil.java b/src/main/java/ani/rss/util/AniUtil.java
index 19288a36..12b314ee 100644
--- a/src/main/java/ani/rss/util/AniUtil.java
+++ b/src/main/java/ani/rss/util/AniUtil.java
@@ -267,6 +267,7 @@ public static Ani getAni(String url, String text, String type, String bgmUrl) {
         }
 
         String s = HttpReq.get(url, true)
+                .timeout(config.getRssTimeout() * 1000)
                 .thenFunction(HttpResponse::body);
         List<Item> items = ItemsUtil.getItems(ani, s, new Item());
         if (items.size() == 1) {
diff --git a/src/main/java/ani/rss/util/ConfigUtil.java b/src/main/java/ani/rss/util/ConfigUtil.java
index 4cdf6d87..cc6052f4 100644
--- a/src/main/java/ani/rss/util/ConfigUtil.java
+++ b/src/main/java/ani/rss/util/ConfigUtil.java
@@ -33,6 +33,7 @@ public class ConfigUtil {
                 .setGcSleep(10)
                 .setRename(true)
                 .setRss(true)
+                .setRssTimeout(6)
                 .setWatchErrorTorrent(true)
                 .setDelayedDownload(0)
                 .setFileExist(false)
diff --git a/src/main/java/ani/rss/util/ItemsUtil.java b/src/main/java/ani/rss/util/ItemsUtil.java
index 43ca88a8..2a14a505 100644
--- a/src/main/java/ani/rss/util/ItemsUtil.java
+++ b/src/main/java/ani/rss/util/ItemsUtil.java
@@ -43,7 +43,10 @@ public static synchronized List<Item> getItems(Ani ani) {
 
         List<Item> items = new ArrayList<>();
 
+        Config config = ConfigUtil.CONFIG;
+
         String s = HttpReq.get(url, true)
+                .timeout(config.getRssTimeout() * 1000)
                 .thenFunction(HttpResponse::body);
         String subgroup = StrUtil.blankToDefault(ani.getSubgroup(), "未知字幕组");
         items.addAll(ItemsUtil.getItems(ani, s, new Item().setSubgroup(subgroup))
@@ -51,7 +54,6 @@ public static synchronized List<Item> getItems(Ani ani) {
                 .peek(item -> item.setMaster(true))
                 .collect(Collectors.toList()));
 
-        Config config = ConfigUtil.CONFIG;
         if (!config.getBackRss()) {
             return items;
         }
@@ -60,6 +62,7 @@ public static synchronized List<Item> getItems(Ani ani) {
         for (Ani.BackRss rss : backRss) {
             ThreadUtil.sleep(1000);
             s = HttpReq.get(rss.getUrl(), true)
+                    .timeout(config.getRssTimeout() * 1000)
                     .thenFunction(HttpResponse::body);
             subgroup = StrUtil.blankToDefault(rss.getLabel(), "未知字幕组");
             Ani clone = ObjUtil.clone(ani);
diff --git a/ui/src/config/Basic.vue b/ui/src/config/Basic.vue
index f954b6ea..a7c85014 100644
--- a/ui/src/config/Basic.vue
+++ b/ui/src/config/Basic.vue
@@ -135,6 +135,14 @@
               </template>
             </el-input-number>
           </el-form-item>
+          <el-form-item label="RSS超时">
+            <el-input-number v-model:model-value="props.config['rssTimeout']"
+                             :min="6" :max="60">
+              <template #suffix>
+                <span>秒</span>
+              </template>
+            </el-input-number>
+          </el-form-item>
           <el-form-item label="自动跳过">
             <div style="width: 100%">
               <el-switch v-model:model-value="props.config.fileExist" :disabled="!config.rename"/>