fix: 合并冲突

Author: linyuan0213

app/downloader/client/qbittorrent.py

@@ -76,7 +76,7 @@ def __login_qbittorrent(self):
                                         username=self.username,
                                         password=self.password,
                                         VERIFY_WEBUI_CERTIFICATE=False,
-                                        REQUESTS_ARGS={'timeout': (10, 30)})
+                                        REQUESTS_ARGS={'timeout': (15, 60)})
             try:
                 qbt.auth_log_in()
                 self.ver = qbt.app_version()
@@ -580,7 +580,7 @@ def get_download_dirs(self):
             return []
         ret_dirs = []
         try:
-            categories = self.qbc.torrents_categories(requests_args={'timeout': (5, 10)}) or {}
+            categories = self.qbc.torrents_categories(requests_args={'timeout': (10, 30)}) or {}
         except Exception as err:
             ExceptionUtils.exception_traceback(err)
             return []

app/downloader/client/transmission.py

@@ -74,7 +74,7 @@ def __login_transmission(self):
                                           port=self.port,
                                           username=self.username,
                                           password=self.password,
-                                          timeout=30)
+                                          timeout=60)
             return trt
         except Exception as err:
             ExceptionUtils.exception_traceback(err)
@@ -482,7 +482,7 @@ def get_download_dirs(self):
         if not self.trc:
             return []
         try:
-            return [self.trc.get_session(timeout=10).download_dir]
+            return [self.trc.get_session(timeout=30).download_dir]
         except Exception as err:
             ExceptionUtils.exception_traceback(err)
             return []

app/media/meta/customization.py

@@ -24,11 +24,13 @@ def match(self, title=None):
         if not self.customization:
             return ""
         customization_re = re.compile(r"%s" % self.customization)
-        # 处理重复多次的情况，保留先后顺序
-        unique_customization = []
+        # 处理重复多次的情况，保留先后顺序（按添加自定义占位符的顺序）
+        unique_customization = {}
         for item in re.findall(customization_re, title):
-            if item not in unique_customization:
-                unique_customization.append(item)
+            for i in range(len(item)):
+                if item[i] and unique_customization.get(item[i]) is None:
+                    unique_customization[item[i]] = i
+        unique_customization = list(dict(sorted(unique_customization.items(), key=lambda x: x[1])).keys())
         separator = self.custom_separator or "@"
         return separator.join(unique_customization)
 

app/plugins/modules/_autosignin/hdchina.py

@@ -37,19 +37,37 @@ def signin(self, site_info: dict):
         ua = site_info.get("ua")
         proxy = Config().get_proxies() if site_info.get("proxy") else None
 
+        # 尝试解决瓷器cookie每天签到后过期,只保留hdchina=部分
+        cookie = ""
+        # 按照分号进行字符串拆分
+        sub_strs = site_cookie.split(";")
+        # 遍历每个子字符串
+        for sub_str in sub_strs:
+            if "hdchina=" in sub_str:
+                # 如果子字符串包含"hdchina="，则保留该子字符串
+                cookie += sub_str + ";"
+
+        if "hdchina=" not in cookie:
+            self.error(f"签到失败，cookie失效")
+            return False, f'【{site}】签到失败，cookie失效'
+
+        site_cookie = cookie
         # 获取页面html
         html_res = RequestUtils(cookies=site_cookie,
                                 headers=ua,
                                 proxies=proxy
-                                ).get_res(url="https://hdchina.org/")
+                                ).get_res(url="https://hdchina.org/index.php")
         if not html_res or html_res.status_code != 200:
             self.error(f"签到失败，请检查站点连通性")
             return False, f'【{site}】签到失败，请检查站点连通性'
 
-        if "login.php" in html_res.text:
+        if "login.php" in html_res.text or "阻断页面" in html_res.text:
             self.error(f"签到失败，cookie失效")
             return False, f'【{site}】签到失败，cookie失效'
 
+        # 获取新返回的cookie进行签到
+        site_cookie = ';'.join(['{}={}'.format(k, v) for k, v in html_res.cookies.get_dict().items()])
+
         # 判断是否已签到
         html_res.encoding = "utf-8"
         sign_status = self.sign_in_result(html_res=html_res.text,

app/plugins/modules/_autosignin/pterclub.py

@@ -45,6 +45,7 @@ def signin(self, site_info: dict):
             return False, f'【{site}】签到失败，请检查cookie是否失效'
 
         sign_dict = json.loads(sign_res.text)
+        self.debug(f"签到接口返回参数 {sign_dict}")
         if sign_dict['status'] == 1:
             # {"status":"1","data":" (签到已成功300)","message":"<p>这是您的第<b>237</b>次签到，
             # 已连续签到<b>237</b>天。</p><p>本次签到获得<b>300</b>克猫粮。</p>"}

app/plugins/modules/_autosignin/u2.py

@@ -1,5 +1,6 @@
 import random
 import re
+import datetime
 
 from lxml import etree
 
@@ -45,6 +46,12 @@ def signin(self, site_info: dict):
         ua = site_info.get("ua")
         proxy = Config().get_proxies() if site_info.get("proxy") else None
 
+        now = datetime.datetime.now()
+        # 判断当前时间是否小于9点
+        if now.hour < 9:
+            self.error(f"签到失败，9点前不签到")
+            return False, f'【{site}】签到失败，9点前不签到'
+        
         # 获取页面html
         html_res = RequestUtils(cookies=site_cookie,
                                 headers=ua,

app/plugins/modules/autobackup.py

@@ -228,10 +228,12 @@ def __backup(self):
 
         # 发送通知
         if self._notify:
+            next_run_time = self._scheduler.get_jobs()[0].next_run_time.strftime('%Y-%m-%d %H:%M:%S')
             self.send_message(title="【自动备份任务完成】",
                               text=f"创建备份{'成功' if zip_file else '失败'}\n"
                                    f"清理备份数量 {del_cnt}\n"
-                                   f"剩余备份数量 {bk_cnt - del_cnt}")
+                                   f"剩余备份数量 {bk_cnt - del_cnt} \n"
+                                   f"下次备份时间: {next_run_time}")
 
     def stop_service(self):
         """

app/plugins/modules/autosignin.py

@@ -336,11 +336,14 @@ def sign_in(self, event=None):
 
             # 发送通知
             if self._notify:
+                next_run_time = self._scheduler.get_jobs()[0].next_run_time.strftime('%Y-%m-%d %H:%M:%S')
                 # 签到汇总信息
                 self.send_message(title="【自动签到任务完成】",
                                   text=f"本次签到数量: {len(sign_sites)} \n"
                                        f"命中重试数量: {len(retry_sites) if self._retry_keyword else 0} \n"
+                                       f"强制签到数量: {len(self._special_sites)} \n"
                                        f"下次签到数量: {len(set(retry_sites + self._special_sites))} \n"
+                                       f"下次签到时间: {next_run_time} \n"
                                        f"详见签到消息")
         else:
             self.error("站点签到任务失败！")

app/plugins/modules/customization.py

@@ -55,7 +55,7 @@ def get_fields():
                         {
                             'title': '自定义分隔符',
                             'required': "",
-                            'tooltip': '当匹配到多个结果时，使用此分隔符进行分隔，留空使用@；如名称中识别出A和B，分隔符为@，则结果为A@B',
+                            'tooltip': '当匹配到多个结果时，使用此分隔符进行分隔，留空使用@；如名称中识别出A和B，分隔符为@，则结果为A@B，按添加自定义占位符的顺序',
                             'type': 'text',
                             'content': [
                                 {
@@ -77,15 +77,12 @@ def init_config(self, config=None):
             customization = config.get('customization')
             custom_separator = config.get('separator')
             if customization:
-                if customization.startswith(';'):
-                    customization = customization[1:]
-                if customization.endswith(';'):
-                    customization = customization[:-1]
-                customization = customization.replace(";", "|").replace("\n", "|")
+                customization = customization.replace("\n", ";").strip(";").split(";")
+                customization = "|".join([f"({item})" for item in customization])
                 if customization:
                     self.info("自定义占位符已加载")
                     if custom_separator:
-                        self.info(f"自定义分隔符{custom_separator}已加载")
+                        self.info(f"自定义分隔符 {custom_separator} 已加载")
                     self._customization_matcher.update_custom(customization, custom_separator)
                     self._customization = customization
                     self._custom_separator = custom_separator

app/plugins/modules/customreleasegroups.py

@@ -86,7 +86,7 @@ def init_config(self, config=None):
                 if custom_release_groups:
                     self.info("自定义制作组/字幕组已加载")
                 if custom_separator:
-                    self.info(f"自定义分隔符{custom_separator}已加载")
+                    self.info(f"自定义分隔符 {custom_separator} 已加载")
                 self._release_groups_matcher.update_custom(custom_release_groups, custom_separator)
                 self._custom_release_groups = custom_release_groups
                 self._custom_separator = custom_separator