Merge 78581b15a7 into 6f9b009194

README.md

@@ -8,7 +8,7 @@
 
 对于一些持续更新的资源，隔段时间去转存十分麻烦。
 
-定期执行本脚本自动转存、文件名整理，配合 [SmartStrm](https://github.com/Cp0204/SmartStrm) / [OpenList](https://github.com/OpenListTeam/OpenList) , Emby 可达到自动追更的效果。🥳
+定期执行本脚本自动转存、文件名整理，配合 OpenList, SmartStrm, Emby 可达到自动追更的效果。🥳
 
 
 [![wiki][wiki-image]][wiki-url] [![github releases][gitHub-releases-image]][github-url] [![docker pulls][docker-pulls-image]][docker-url] [![docker image size][docker-image-size-image]][docker-url]
@@ -29,7 +29,7 @@
 > ⛔️⛔️⛔️ 注意！资源不会每时每刻更新，**严禁设定过高的定时运行频率！** 以免账号风控和给夸克服务器造成不必要的压力。雪山崩塌，每一片雪花都有责任！
 
 > [!NOTE]
-> 开发者≠客服，开源免费≠帮你解决使用问题；本项目 Wiki 已经相对完善，遇到问题请先翻阅 Issues 和 Wiki ，请勿盲目发问。
+> 开发者≠客服，开源免费≠帮你解决使用问题；本项目Wiki和已经相对完善，遇到问题请先翻阅 Issues 和 Wiki ，请勿盲目发问。
 
 ## 功能
 
@@ -107,11 +107,10 @@ services:
 
 管理地址：http://yourhost:5005
 
-| 环境变量         | 默认       | 备注                                     |
+| 环境变量         | 默认       | 备注     |
-| ---------------- | ---------- | ---------------------------------------- |
+| ---------------- | ---------- | -------- |
-| `WEBUI_USERNAME` | `admin`    | 管理账号                                 |
+| `WEBUI_USERNAME` | `admin`    | 管理账号 |
-| `WEBUI_PASSWORD` | `admin123` | 管理密码                                 |
+| `WEBUI_PASSWORD` | `admin123` | 管理密码 |
-| `PORT`           | `5005`     | 管理后台端口                             |
 | `PLUGIN_FLAGS`   |            | 插件标志，如 `-emby,-aria2` 禁用某些插件 |
 
 #### 一键更新
@@ -129,17 +128,23 @@ docker run --rm -v /var/run/docker.sock:/var/run/docker.sock containrrr/watchtow
 
 </details>
 
+### 青龙部署
+
+程序也支持以青龙定时任务的方式运行，但该方式无法使用 WebUI 管理任务，需手动修改配置文件。
+
+青龙部署说明已转移到 Wiki ：[青龙部署教程](https://github.com/Cp0204/quark-auto-save/wiki/部署教程#青龙部署)
+
 ## 使用说明
 
 ### 正则处理示例
 
-| pattern                                | replace                 | 效果                                                                   |
+| pattern                                | replace      | 效果                                                                   |
-| -------------------------------------- | ----------------------- | ---------------------------------------------------------------------- |
+| -------------------------------------- | ------------ | ---------------------------------------------------------------------- |
-| `.*`                                   |                         | 无脑转存所有文件，不整理                                               |
+| `.*`                                   |              | 无脑转存所有文件，不整理                                               |
-| `\.mp4$`                               |                         | 转存所有 `.mp4` 后缀的文件                                             |
+| `\.mp4$`                               |              | 转存所有 `.mp4` 后缀的文件                                             |
-| `^【电影TT】花好月圆(\d+)\.(mp4\|mkv)` | `\1.\2`                 | 【电影TT】花好月圆01.mp4 → 01.mp4<br>【电影TT】花好月圆02.mkv → 02.mkv |
+| `^【电影TT】花好月圆(\d+)\.(mp4\|mkv)` | `\1.\2`      | 【电影TT】花好月圆01.mp4 → 01.mp4<br>【电影TT】花好月圆02.mkv → 02.mkv |
-| `^(\d+)\.mp4`                          | `S02E\1.mp4`            | 01.mp4 → S02E01.mp4<br>02.mp4 → S02E02.mp4                             |
+| `^(\d+)\.mp4`                          | `S02E\1.mp4` | 01.mp4 → S02E01.mp4<br>02.mp4 → S02E02.mp4                             |
-| `$TV`                                  |                         | [魔法匹配](#魔法匹配)剧集文件                                          |
+| `$TV`                                  |              | [魔法匹配](#魔法匹配)剧集文件                                          |
 | `^(\d+)\.mp4`                          | `{TASKNAME}.S02E\1.mp4` | 01.mp4 → 任务名.S02E01.mp4                                             |
 
 更多正则使用说明：[正则处理教程](https://github.com/Cp0204/quark-auto-save/wiki/正则处理教程)

app/sdk/cloudsaver.py

@@ -1,6 +1,6 @@
+from datetime import datetime, timedelta
 import re
 import requests
-from sdk.common import iso_to_cst
 
 
 class CloudSaver:
@@ -128,7 +128,8 @@ class CloudSaver:
                         # 统一发布时间格式
                         pubdate = item.get("pubDate", "")
                         if pubdate:
-                            pubdate = iso_to_cst(pubdate)
+                            utc_tm = datetime.fromisoformat(pubdate)
+                            pubdate = (utc_tm + timedelta(hours=8)).strftime("%Y-%m-%d %H:%M:%S")
                         # 链接去重
                         if link.get("link") not in link_array:
                             link_array.append(link.get("link"))
@@ -139,7 +140,8 @@ class CloudSaver:
                                     "content": content,
                                     "datetime": pubdate,
                                     "tags": item.get("tags", []),
-                                    "channel": item.get("channelId", ""),
+                                    "channel": item.get("channel", ""),
+                                    "channel_id": item.get("channelId", ""),
                                     "source": "CloudSaver"
                                 }
                             )

app/sdk/common.py

@@ -1,15 +0,0 @@
-from datetime import datetime, timezone, timedelta
-
-
-def iso_to_cst(iso_time_str: str) -> str:
-    """将 ISO 格式的时间字符串转换为 CST(China Standard Time) 时间并格式化为 %Y-%m-%d %H:%M:%S 格式
-
-    Args:
-        iso_time_str (str): ISO 格式时间字符串
-
-    Returns:
-        str: CST(China Standard Time) 时间字符串
-    """
-    dt = datetime.fromisoformat(iso_time_str)
-    dt_cst = dt.astimezone(timezone(timedelta(hours=8)))
-    return dt_cst.strftime("%Y-%m-%d %H:%M:%S") if dt_cst.year >= 1970 else ""

app/sdk/pansou.py

@@ -1,9 +1,8 @@
 import re
+from datetime import datetime, timedelta
 
 import requests
 
-from sdk.common import iso_to_cst
-
 
 class PanSou:
     """
@@ -56,12 +55,13 @@ class PanSou:
         )
         format_results = []
         link_array = []
-        for item in search_results:
+        for channel in search_results:
-            url = item.get("url", "")
+            url = channel.get("url", "")
-            note = item.get("note", "")
+            note = channel.get("note", "")
-            tm = item.get("datetime", "")
+            tm = channel.get("datetime", "")
             if tm:
-                tm = iso_to_cst(tm)
+                utc_tm = datetime.strptime(tm, "%Y-%m-%dT%H:%M:%SZ")
+                tm = (utc_tm + timedelta(hours=8)).strftime("%Y-%m-%d %H:%M:%S")
 
             match = re.search(pattern, note)
             if match:
@@ -74,11 +74,10 @@ class PanSou:
             if url != "" and url not in link_array:
                 link_array.append(url)
                 format_results.append({
-                    "shareurl": url,
                     "taskname": title,
                     "content": content,
+                    "shareurl": url,
                     "datetime": tm,
-                    "channel": item.get("source", ""),
                     "source": "PanSou"
                 })
 

app/templates/index.html

@@ -303,7 +303,6 @@
                               <a :href="suggestion.shareurl" target="_blank" @click.stop>{{ suggestion.shareurl }}</a>
                             </small>
                             <span class="badge bg-transparent border border-success text-success">{{ suggestion.source || "网络公开" }}</span>
-                            <span class="badge bg-transparent border border-info text-info">{{ suggestion.channel }}</span>
                             <span v-if="suggestion.datetime" class="badge bg-transparent border border-dark text-dark">{{ suggestion.datetime }}</span>
                           </div>
                         </div>

plugins/smartstrm.py

@@ -7,6 +7,7 @@ class Smartstrm:
         "strmtask": "",  # SmartStrm 任务名，支持多个如 `tv,movie`
         "xlist_path_fix": "",  # 路径映射， SmartStrm 任务使用 quark 驱动时无须填写；使用 openlist 驱动时需填写 `/storage_mount_path:/quark_root_dir` ，例如把夸克根目录挂载在 OpenList 的 /quark 下，则填写 `/quark:/` ；以及 SmartStrm 会使 OpenList 强制刷新目录，无需再用 alist 插件刷新。
     }
+    default_task_config = {}
     is_active = False
 
     def __init__(self, **kwargs):
@@ -46,12 +47,16 @@ class Smartstrm:
                 json=payload,
                 timeout=5,
             )
-            response = response.json()
+            # 检查响应状态
-            if response.get("success"):
+            if response.status_code == 200:
-                print(
+                response = response.json()
-                    f"SmartStrm 触发任务: [{response['task']['name']}] {response['task']['storage_path']} 成功✅"
+                if response.get("success"):
-                )
+                    print(
+                        f"SmartStrm 触发任务: [{response['task']['name']}] {response['task']['storage_path']} 成功✅"
+                    )
+                else:
+                    print(f"SmartStrm 触发任务: {response['message']}")
             else:
-                print(f"SmartStrm 触发任务: {response['message']}")
+                print(f"SmartStrm 触发任务: {response.status_code}")
         except Exception as e:
-            print(f"SmartStrm 触发任务：出错 {str(e)}")
+            print(f"SmartStrm 触发任务：出错 {e}")