fix 按对象名称组织代码文件

app/api/endpoints/history.py

@@ -1,4 +1,3 @@
-import json
 from typing import List, Any
 
 from fastapi import APIRouter, Depends

app/api/endpoints/login.py

@@ -1,4 +1,3 @@
-import json
 from datetime import timedelta
 from typing import Any, List
 

app/api/endpoints/message.py

@@ -14,7 +14,7 @@
 from app.db.models import User
 from app.db.models.message import Message
 from app.db.user_oper import get_current_active_superuser
-from app.helper.serviceconfig import ServiceConfigHelper
+from app.helper.service import ServiceConfigHelper
 from app.log import logger
 from app.modules.wechat.WXBizMsgCrypt3 import WXBizMsgCrypt
 from app.schemas.types import MessageChannel

app/api/endpoints/transfer.py

@@ -1,4 +1,3 @@
-import json
 from pathlib import Path
 from typing import Any, Optional
 

app/chain/__init__.py

@@ -17,7 +17,7 @@
 from app.db.message_oper import MessageOper
 from app.db.user_oper import UserOper
 from app.helper.message import MessageHelper
-from app.helper.serviceconfig import ServiceConfigHelper
+from app.helper.service import ServiceConfigHelper
 from app.log import logger
 from app.schemas import TransferInfo, TransferTorrent, ExistMediaInfo, DownloadingTorrent, CommingMessage, Notification, \
     WebhookEventInfo, TmdbEpisode, MediaPerson, FileItem

app/chain/mediaserver.py

@@ -1,11 +1,10 @@
-import json
 import threading
 from typing import List, Union, Optional, Generator
 
 from app import schemas
 from app.chain import ChainBase
 from app.db.mediaserver_oper import MediaServerOper
-from app.helper.serviceconfig import ServiceConfigHelper
+from app.helper.service import ServiceConfigHelper
 from app.log import logger
 
 lock = threading.Lock()

app/chain/message.py

@@ -1,5 +1,4 @@
 import copy
-import json
 import re
 from typing import Any, Optional, Dict, Union
 

app/db/mediaserver_oper.py

@@ -1,4 +1,3 @@
-import json
 from typing import Optional
 
 from sqlalchemy.orm import Session

app/db/plugindata_oper.py

@@ -1,9 +1,7 @@
-import json
 from typing import Any
 
 from app.db import DbOper
 from app.db.models.plugindata import PluginData
-from app.utils.object import ObjectUtils
 
 
 class PluginDataOper(DbOper):

app/db/site_oper.py

@@ -1,4 +1,3 @@
-import json
 from datetime import datetime
 from typing import Tuple, List
 

app/db/systemconfig_oper.py

@@ -1,10 +1,8 @@
-import json
 from typing import Any, Union
 
 from app.db import DbOper
 from app.db.models.systemconfig import SystemConfig
 from app.schemas.types import SystemConfigKey
-from app.utils.object import ObjectUtils
 from app.utils.singleton import Singleton
 
 

app/db/transferhistory_oper.py

@@ -1,4 +1,3 @@
-import json
 import time
 from typing import Any, List
 

app/db/user_oper.py

@@ -1,4 +1,3 @@
-import json
 from typing import Optional
 
 from fastapi import Depends, HTTPException

app/db/userconfig_oper.py

@@ -1,10 +1,8 @@
-import json
 from typing import Any, Union, Dict, Optional
 
 from app.db import DbOper
 from app.db.models.userconfig import UserConfig
 from app.schemas.types import UserConfigKey
-from app.utils.object import ObjectUtils
 from app.utils.singleton import Singleton
 
 

app/helper/downloader.py

@@ -1,6 +1,6 @@
 from typing import Optional
 
-from app.helper.servicebase import ServiceBaseHelper
+from app.helper.service import ServiceBaseHelper
 from app.schemas import DownloaderConf, ServiceInfo
 from app.schemas.types import SystemConfigKey, ModuleType
 

app/helper/mediaserver.py

@@ -1,6 +1,6 @@
 from typing import Optional
 
-from app.helper.servicebase import ServiceBaseHelper
+from app.helper.service import ServiceBaseHelper
 from app.schemas import MediaServerConf, ServiceInfo
 from app.schemas.types import SystemConfigKey, ModuleType
 

app/helper/notification.py

@@ -1,6 +1,6 @@
 from typing import Optional
 
-from app.helper.servicebase import ServiceBaseHelper
+from app.helper.service import ServiceBaseHelper
 from app.schemas import NotificationConf, ServiceInfo
 from app.schemas.types import SystemConfigKey, ModuleType
 

app/helper/servicebase.py → app/helper/service.py

@@ -1,13 +1,73 @@
 from typing import Dict, List, Optional, Type, TypeVar, Generic, Iterator
 
 from app.core.module import ModuleManager
-from app.helper.serviceconfig import ServiceConfigHelper
-from app.schemas import ServiceInfo
-from app.schemas.types import SystemConfigKey, ModuleType
+from app.db.systemconfig_oper import SystemConfigOper
+from app.schemas import DownloaderConf, MediaServerConf, NotificationConf, NotificationSwitchConf, ServiceInfo
+from app.schemas.types import NotificationType, SystemConfigKey, ModuleType
 
 TConf = TypeVar("TConf")
 
 
+class ServiceConfigHelper:
+    """
+    配置帮助类，获取不同类型的服务配置
+    """
+
+    @staticmethod
+    def get_configs(config_key: SystemConfigKey, conf_type: Type) -> List:
+        """
+        通用获取配置的方法，根据 config_key 获取相应的配置并返回指定类型的配置列表
+
+        :param config_key: 系统配置的 key
+        :param conf_type: 用于实例化配置对象的类类型
+        :return: 配置对象列表
+        """
+        config_data = SystemConfigOper().get(config_key)
+        if not config_data:
+            return []
+        # 直接使用 conf_type 来实例化配置对象
+        return [conf_type(**conf) for conf in config_data]
+
+    @staticmethod
+    def get_downloader_configs() -> List[DownloaderConf]:
+        """
+        获取下载器的配置
+        """
+        return ServiceConfigHelper.get_configs(SystemConfigKey.Downloaders, DownloaderConf)
+
+    @staticmethod
+    def get_mediaserver_configs() -> List[MediaServerConf]:
+        """
+        获取媒体服务器的配置
+        """
+        return ServiceConfigHelper.get_configs(SystemConfigKey.MediaServers, MediaServerConf)
+
+    @staticmethod
+    def get_notification_configs() -> List[NotificationConf]:
+        """
+        获取消息通知渠道的配置
+        """
+        return ServiceConfigHelper.get_configs(SystemConfigKey.Notifications, NotificationConf)
+
+    @staticmethod
+    def get_notification_switches() -> List[NotificationSwitchConf]:
+        """
+        获取消息通知场景的开关
+        """
+        return ServiceConfigHelper.get_configs(SystemConfigKey.NotificationSwitchs, NotificationSwitchConf)
+
+    @staticmethod
+    def get_notification_switch(mtype: NotificationType) -> Optional[str]:
+        """
+        获取指定类型的消息通知场景的开关
+        """
+        switchs = ServiceConfigHelper.get_notification_switches()
+        for switch in switchs:
+            if switch.type == mtype.value:
+                return switch.action
+        return None
+
+
 class ServiceBaseHelper(Generic[TConf]):
     """
     通用服务帮助类，抽象获取配置和服务实例的通用逻辑
@@ -84,7 +144,7 @@ def get_services(self, type_filter: Optional[str] = None, name_filters: Optional
             if service_info.config and (
                     type_filter is None or service_info.type == type_filter
             ) and (
-                    name_filters_set is None or service_info.name in name_filters_set)
+                       name_filters_set is None or service_info.name in name_filters_set)
         }
 
     def get_service(self, name: str, type_filter: Optional[str] = None) -> Optional[ServiceInfo]:

app/modules/__init__.py

@@ -1,7 +1,7 @@
 from abc import abstractmethod, ABCMeta
 from typing import Generic, Tuple, Union, TypeVar, Type, Dict, Optional, Callable, Any
 
-from app.helper.serviceconfig import ServiceConfigHelper
+from app.helper.service import ServiceConfigHelper
 from app.schemas import Notification, MessageChannel, NotificationConf, MediaServerConf, DownloaderConf
 from app.schemas.types import ModuleType
 

app/modules/slack/__init__.py

@@ -2,7 +2,6 @@
 import re
 from typing import Optional, Union, List, Tuple, Any
 
-from app.core.config import settings
 from app.core.context import MediaInfo, Context
 from app.log import logger
 from app.modules import _ModuleBase, _MessageBase

app/modules/telegram/__init__.py

@@ -1,7 +1,6 @@
 import json
 from typing import Optional, Union, List, Tuple, Any, Dict
 
-from app.core.config import settings
 from app.core.context import MediaInfo, Context
 from app.log import logger
 from app.modules import _ModuleBase, _MessageBase

app/modules/vocechat/__init__.py

@@ -1,7 +1,6 @@
 import json
 from typing import Optional, Union, List, Tuple, Any, Dict
 
-from app.core.config import settings
 from app.core.context import Context, MediaInfo
 from app.log import logger
 from app.modules import _ModuleBase, _MessageBase