标准化服务

src/config/agent_config.py

@@ -11,9 +11,7 @@ class LongArticlesSearchAgentConfig(BaseSettings):
 
     # ============ 应用基础配置 ============
     app_name: str = Field(default="LongArticleSearchAgent", description="应用名称")
-    environment: str = Field(
-        default="development", description="运行环境: development/pre/production"
-    )
+    environment: str = Field(default="development", description="运行环境: development/pre/production")
     debug: bool = Field(default=False, description="调试模式")
 
     # ============ 数据库配置 ============
@@ -26,6 +24,4 @@ class LongArticlesSearchAgentConfig(BaseSettings):
     # elasticsearch: ElasticsearchConfig = Field(default_factory=ElasticsearchConfig)
     # apollo: ApolloConfig = Field(default_factory=ApolloConfig)
 
-    model_config = SettingsConfigDict(
-        env_file=".env", env_file_encoding="utf-8", case_sensitive=False, extra="ignore"
-    )
+    model_config = SettingsConfigDict(env_file=".env", env_file_encoding="utf-8", case_sensitive=False, extra="ignore")

src/config/aliyun/log.py

@@ -10,9 +10,7 @@ class AliyunLogConfig(BaseSettings):
     project: str = ""
     logstore: str = ""
 
-    model_config = SettingsConfigDict(
-        env_prefix="ALIYUN_LOG_", env_file=".env", case_sensitive=False, extra="ignore"
-    )
+    model_config = SettingsConfigDict(env_prefix="ALIYUN_LOG_", env_file=".env", case_sensitive=False, extra="ignore")
 
     def to_dict(self) -> dict:
         """转换为字典格式，用于兼容旧代码"""
@@ -22,4 +20,4 @@ class AliyunLogConfig(BaseSettings):
             "access_key_secret": self.access_key_secret,
             "project": self.project,
             "logstore": self.logstore,
-        }
+        }

src/config/api/deepseek.py

@@ -5,14 +5,10 @@ from pydantic_settings import BaseSettings, SettingsConfigDict
 
 
 class DeepSeekConfig(BaseSettings):
-    api_key: str = Field(
-        default="", description="DeepSeek API Key（环境变量 DEEP_SEEK_API_KEY）"
-    )
+    api_key: str = Field(default="", description="DeepSeek API Key（环境变量 DEEP_SEEK_API_KEY）")
     model: str = Field(default="deepseek-chat", description="模型，如V3, R1")
     reason_model: str = Field(default="", description="推理模型")
-    base_url: str = Field(
-        default="https://api.deepseek.com", description="base_url链接"
-    )
+    base_url: str = Field(default="https://api.deepseek.com", description="base_url链接")
 
     model_config = SettingsConfigDict(
         env_prefix="DEEP_SEEK_",

src/config/database/__init__.py

@@ -1,4 +1,4 @@
 from .mysql_config import SearchAgentMySQLConfig
 
 
-__all__ = ["SearchAgentMySQLConfig"]
+__all__ = ["SearchAgentMySQLConfig"]

src/config/database/mysql_config.py

@@ -13,9 +13,7 @@ class MySQLConfig(BaseSettings):
     minsize: int = 5
     maxsize: int = 20
 
-    model_config = SettingsConfigDict(
-        env_prefix="", case_sensitive=False, extra="ignore"
-    )
+    model_config = SettingsConfigDict(env_prefix="", case_sensitive=False, extra="ignore")
 
     def to_dict(self) -> dict:
         """转换为字典格式，用于兼容旧代码"""

src/core/api/v1/routes/route.py

@@ -27,9 +27,7 @@ def register_v1_blueprints(deps: ApiDependencies) -> Blueprint:
     return api
 
 
-def server_routes(
-    pools: AsyncMySQLPool, log_service: LogService, config: LongArticlesSearchAgentConfig
-) -> Blueprint:
+def server_routes(pools: AsyncMySQLPool, log_service: LogService, config: LongArticlesSearchAgentConfig) -> Blueprint:
     """
     兼容旧入口：保留 server_routes 签名，内部转为新的 deps + 统一注册。
     """

src/infra/database/mysql/__init__.py

@@ -1,4 +1,4 @@
 from .async_mysql_pool import AsyncMySQLPool
 
 
-__all__ = ["AsyncMySQLPool"]
+__all__ = ["AsyncMySQLPool"]

src/infra/database/mysql/async_mysql_pool.py

@@ -55,9 +55,7 @@ class AsyncMySQLPool:
                 await pool.wait_closed()
                 logger.info(f"{name} MySQL pool closed successfully")
 
-    async def async_fetch(
-        self, query, db_name="search_agent", params=None, cursor_type=DictCursor
-    ):
+    async def async_fetch(self, query, db_name="search_agent", params=None, cursor_type=DictCursor):
         pool = self.pools.get(db_name)
         if not pool:
             await self.init_pools()
@@ -84,9 +82,7 @@ class AsyncMySQLPool:
             )
             return None
 
-    async def async_save(
-        self, query, params, db_name="search_agent", batch: bool = False
-    ):
+    async def async_save(self, query, params, db_name="search_agent", batch: bool = False):
         pool = self.pools.get(db_name)
         if not pool:
             await self.init_pools()

src/infra/trace/logging/log_service.py

@@ -77,9 +77,7 @@ class LogService:
         safe_items = [
             (
                 str(k),
-                json.dumps(v, ensure_ascii=False)
-                if isinstance(v, (dict, list))
-                else str(v),
+                json.dumps(v, ensure_ascii=False) if isinstance(v, (dict, list)) else str(v),
             )
             for k, v in contents.items()
         ]