fix: ensure download service starts normal after reboot

Author: shinonomeow

backend/src/module/core/aiocore.py

@@ -5,8 +5,7 @@
 
 from module.utils.events import event_bus
 
-from .task_manager import TaskManager
-
+from .task_manager import TaskManager 
 logger = logging.getLogger(__name__)
 
 
@@ -71,6 +70,8 @@ async def _register_tasks(self) -> None:
                     interval=config["interval"],
                 )
                 logger.debug(f"[AsyncCore] 注册任务: {config['name']}")
+            else:
+                logger.debug(f"[AsyncCore] 跳过未启用的任务: {config['name']}")
 
     async def _register_event_handlers(self) -> None:
         """注册事件处理器"""
@@ -121,6 +122,7 @@ async def stop(self) -> None:
         if not self._running:
             return
 
+        self._initialized = False
         logger.info("[AsyncCore] 开始停止应用...")
         self._running = False
 

backend/src/module/core/renamer_service.py

@@ -15,18 +15,24 @@ class RenamerService(BaseService):
 
     def __init__(self):
         super().__init__()
-        self._renamer: Renamer | None = None
+        self._renamer: Renamer = Renamer()
+        self.enable = settings.bangumi_manage.enable
 
     async def _setup(self) -> None:
         """初始化重命名器"""
         self._renamer = Renamer()
 
+    async def initialize(self) -> None:
+        await super().initialize()
+        self.enable = settings.bangumi_manage.enable
+
+
     def get_task_config(self) -> dict[str, Any]:
         """获取重命名任务配置"""
         return {
             "name": "renamer_check",
             "interval": 600,  # 转换为秒
-            "enabled": settings.bangumi_manage.enable,
+            "enabled": self.enable,
         }
 
     async def execute(self) -> None:

backend/src/module/core/services.py

@@ -130,7 +130,6 @@ def get_task_config(self) -> dict[str, Any]:
         return {
             "name": "download_process",
             "interval": 10,
-            "max_retries": 5,
             "enabled": True,
         }
 

backend/src/module/core/task_manager.py

@@ -22,7 +22,6 @@ class TaskInfo:
     task: asyncio.Task[Any] | None = None
     last_run: float | None = None
     error_count: int = 0
-    max_retries: int = 3
     metadata: dict[str, Any] = field(default_factory=dict)
 
 
@@ -33,12 +32,11 @@ def __init__(self):
         self._shutdown_event: asyncio.Event = asyncio.Event()
 
     async def register_task(
-        self, name: str, coro_func: Callable, interval: int, max_retries: int = 3
+        self, name: str, coro_func: Callable, interval: int
     ) -> None:
         """注册任务"""
         self._tasks[name] = TaskInfo(
             name=name,
-            max_retries=max_retries,
             metadata={"coro_func": coro_func, "interval": interval},
         )
         logger.info(f"[TaskManager] 已注册任务: {name}")

backend/src/module/core/task_queue.py

@@ -149,11 +149,9 @@ async def torrent_info(self, hash: str) -> TorrentDownloadInfo | None:
                 url=QB_API_URL["properties"],
                 params=data,
             )
-            print(reps.json())
             reps.raise_for_status()
             logger.debug(f"[qbittorrent] Torrent info: {hash}")
             reps = reps.json()
-            # print(reps)
             logger.debug(
                 f"[qbittorrent] Torrent info: {reps['eta']=}, {reps['save_path']=}, {reps['completion_date']=}"
             )