perf: 优化代码

Author: insistence

ruoyi-fastapi-backend/module_admin/service/log_service.py

@@ -274,6 +274,10 @@ async def export_login_log_list_services(login_log_list: list) -> bytes:
 
 
 class LogQueueService:
+    """
+    日志队列服务
+    """
+
     @classmethod
     def _build_event_id(cls, request_id: str, log_type: str, source: str) -> str:
         """
@@ -346,6 +350,10 @@ async def enqueue_operation_log(cls, request: Request, operation_log: OperLogMod
 
 
 class LogAggregatorService:
+    """
+    日志聚合消费服务
+    """
+
     @classmethod
     async def _ensure_group(cls, redis: aioredis.Redis) -> None:
         """
@@ -394,6 +402,13 @@ async def _release_dedup(cls, redis: aioredis.Redis, event_id: str) -> None:
 
     @classmethod
     async def _claim_pending(cls, redis: aioredis.Redis, consumer_name: str) -> None:
+        """
+        认领并处理超时未确认的消息
+
+        :param redis: Redis连接对象
+        :param consumer_name: 消费者名称
+        :return: None
+        """
         if LogConfig.log_stream_claim_idle_ms <= 0:
             return
         start_id = '0-0'

ruoyi-fastapi-backend/utils/ai_util.py

@@ -60,47 +60,47 @@
 _storage_class_cache: dict[str, 'type[AsyncBaseDb]'] = {}
 
 
-def _resolve_provider_class(provider: str) -> 'type[Model] | None':
-    """
-    按需加载并缓存提供商模型类
-
-    :param provider: 提供商名称
-    :return: 模型类，未找到返回None
+class AiUtil:
     """
-    if provider in _provider_class_cache:
-        return _provider_class_cache[provider]
-    entry = _PROVIDER_REGISTRY.get(provider)
-    if entry is None:
-        return None
-    module_path, class_name = entry
-    cls = getattr(import_module(module_path), class_name)
-    _provider_class_cache[provider] = cls
-    return cls
-
-
-def _resolve_storage_class(db_type: str) -> 'type[AsyncBaseDb]':
+    AI工具类
     """
-    按需加载并缓存存储引擎类
 
-    :param db_type: 数据库类型
-    :return: 存储引擎类
-    """
-    if db_type in _storage_class_cache:
-        return _storage_class_cache[db_type]
-    entry = _STORAGE_ENGINE_REGISTRY.get(db_type)
-    if entry is None:
-        # 默认使用MySQL
-        entry = _STORAGE_ENGINE_REGISTRY['mysql']
-    module_path, class_name = entry
-    cls = getattr(import_module(module_path), class_name)
-    _storage_class_cache[db_type] = cls
-    return cls
+    @classmethod
+    def _resolve_provider_class(cls, provider: str) -> 'type[Model] | None':
+        """
+        按需加载并缓存提供商模型类
+
+        :param provider: 提供商名称
+        :return: 模型类，未找到返回None
+        """
+        if provider in _provider_class_cache:
+            return _provider_class_cache[provider]
+        entry = _PROVIDER_REGISTRY.get(provider)
+        if entry is None:
+            return None
+        module_path, class_name = entry
+        provider_cls = getattr(import_module(module_path), class_name)
+        _provider_class_cache[provider] = provider_cls
+        return provider_cls
 
+    @classmethod
+    def _resolve_storage_class(cls, db_type: str) -> 'type[AsyncBaseDb]':
+        """
+        按需加载并缓存存储引擎类
 
-class AiUtil:
-    """
-    AI工具类
-    """
+        :param db_type: 数据库类型
+        :return: 存储引擎类
+        """
+        if db_type in _storage_class_cache:
+            return _storage_class_cache[db_type]
+        entry = _STORAGE_ENGINE_REGISTRY.get(db_type)
+        if entry is None:
+            # 默认使用MySQL
+            entry = _STORAGE_ENGINE_REGISTRY['mysql']
+        module_path, class_name = entry
+        storage_cls = getattr(import_module(module_path), class_name)
+        _storage_class_cache[db_type] = storage_cls
+        return storage_cls
 
     @classmethod
     def get_storage_engine(cls) -> 'AsyncBaseDb':
@@ -109,7 +109,7 @@ def get_storage_engine(cls) -> 'AsyncBaseDb':
 
         :return: 存储引擎实例
         """
-        storage_engine_class = _resolve_storage_class(DataBaseConfig.db_type)
+        storage_engine_class = cls._resolve_storage_class(DataBaseConfig.db_type)
 
         return storage_engine_class(
             db_engine=async_engine,
@@ -164,9 +164,9 @@ def get_model_from_factory(
             params['host'] = base_url
         if provider == 'DashScope' and not base_url:
             params['base_url'] = 'https://dashscope.aliyuncs.com/compatible-mode/v1'
-        model_class = _resolve_provider_class(provider)
+        model_class = cls._resolve_provider_class(provider)
         if model_class is None:
             # 未知提供商，回退到OpenAI
-            model_class = _resolve_provider_class('OpenAI')
+            model_class = cls._resolve_provider_class('OpenAI')
 
         return model_class(**params)

ruoyi-fastapi-backend/utils/common_util.py

@@ -15,10 +15,11 @@
 
 from config.database import Base
 from config.env import CachePathConfig
+from utils.log_util import logger
 
 
 def worship() -> None:
-    print(r"""
+    logger.info(r"""
 ////////////////////////////////////////////////////////////////////
 //                          _ooOoo_                               //
 //                         o8888888o                              //

ruoyi-fastapi-frontend/src/settings.js

@@ -52,5 +52,5 @@ module.exports = {
   /**
    * 底部版权文本内容
    */
-  footerContent: 'Copyright © 2024-2025 insistence.tech All Rights Reserved.'
+  footerContent: 'Copyright © 2024-2026 insistence.tech All Rights Reserved.'
 }