Merge pull request #1035 from MaiM-with-u/dev-refactor-logger

重构日志系统：使用 structlog 替代 loguru

Author: BBleae

bot.py

@@ -7,7 +7,7 @@
 import platform
 import traceback
 from dotenv import load_dotenv
-from src.common.logger_manager import get_logger
+from src.common.logger import get_logger
 
 # from src.common.logger import LogConfig, CONFIRM_STYLE_CONFIG
 from src.common.crash_logger import install_crash_handler
@@ -69,10 +69,9 @@ def load_env():
     # 直接加载生产环境变量配置
     if os.path.exists(".env"):
         load_dotenv(".env", override=True)
-        logger.success("成功加载环境变量配置")
+        logger.info("成功加载环境变量配置")
     else:
-        logger.error("未找到.env文件，请确保文件存在")
-        raise FileNotFoundError("未找到.env文件，请确保文件存在")
+        logger.warning("未找到.env文件，请确保程序所需的环境变量被正确设置")
 
 
 def scan_provider(env_config: dict):
@@ -199,6 +198,7 @@ def check_eula():
 
 
 def raw_main():
+    load_env()
     # 利用 TZ 环境变量设定程序工作的时区
     if platform.system().lower() != "windows":
         time.tzset()
@@ -211,8 +211,6 @@ def raw_main():
 
     easter_egg()
 
-    load_env()
-
     env_config = {key: os.getenv(key) for key in os.environ}
     scan_provider(env_config)
 
@@ -235,7 +233,7 @@ def raw_main():
             loop.run_until_complete(main_system.initialize())
             loop.run_until_complete(main_system.schedule_tasks())
         except KeyboardInterrupt:
-            # loop.run_until_complete(global_api.stop())
+            # loop.run_until_complete(get_global_api().stop())
             logger.warning("收到中断信号，正在优雅关闭...")
             if loop and not loop.is_closed():
                 try:

docs/plugin_quick_start.md

@@ -39,7 +39,7 @@ from src.plugin_system import (
     BasePlugin, register_plugin, BaseAction, BaseCommand,
     ComponentInfo, ActionInfo, CommandInfo, ActionActivationType, ChatMode
 )
-from src.common.logger_manager import get_logger
+from src.common.logger import get_logger
 
 logger = get_logger("my_first_plugin")
 

requirements.txt

@@ -15,15 +15,15 @@
 from src.chat.knowledge.llm_client import LLMClient
 from src.chat.knowledge.open_ie import OpenIE
 from src.chat.knowledge.kg_manager import KGManager
-from src.common.logger import get_module_logger
+from src.common.logger import get_logger
 from src.chat.knowledge.utils.hash import get_sha256
 
 
 # 添加项目根目录到 sys.path
 ROOT_PATH = os.path.abspath(os.path.join(os.path.dirname(__file__), ".."))
 OPENIE_DIR = global_config["persistence"]["openie_data_path"] or os.path.join(ROOT_PATH, "data/openie")
 
-logger = get_module_logger("OpenIE导入")
+logger = get_logger("OpenIE导入")
 
 
 def hash_deduplicate(

scripts/import_openie.py

@@ -12,7 +12,7 @@
 
 from rich.progress import Progress  # 替换为 rich 进度条
 
-from src.common.logger import get_module_logger
+from src.common.logger import get_logger
 from src.chat.knowledge.lpmmconfig import global_config
 from src.chat.knowledge.ie_process import info_extract_from_str
 from src.chat.knowledge.llm_client import LLMClient
@@ -28,7 +28,7 @@
     TextColumn,
 )
 
-logger = get_module_logger("LPMM知识库-信息提取")
+logger = get_logger("LPMM知识库-信息提取")
 
 
 ROOT_PATH = os.path.abspath(os.path.join(os.path.dirname(__file__), ".."))

scripts/info_extraction.py

@@ -32,7 +32,7 @@
 
 from src.chat.utils.chat_message_builder import build_readable_messages
 from src.common.database.database_model import Messages
-from src.common.logger_manager import get_logger
+from src.common.logger import get_logger
 from src.common.database.database import db
 from src.config.config import global_config
 from src.llm_models.utils_model import LLMRequest

scripts/message_retrieval_script.py

@@ -42,7 +42,7 @@
     GraphNodes,
     GraphEdges,
 )
-from src.common.logger_manager import get_logger
+from src.common.logger import get_logger
 
 logger = get_logger("mongodb_to_sqlite")
 

scripts/mongodb_to_sqlite.py

@@ -5,7 +5,7 @@
 import datetime  # 新增导入
 
 sys.path.append(os.path.abspath(os.path.join(os.path.dirname(__file__), "..")))
-from src.common.logger_manager import get_logger
+from src.common.logger import get_logger
 from src.chat.knowledge.lpmmconfig import global_config
 
 logger = get_logger("lpmm")

scripts/raw_data_preprocessor.py

@@ -1,6 +1,6 @@
 from src.chat.heart_flow.heartflow import heartflow
 from src.chat.heart_flow.sub_heartflow import ChatState
-from src.common.logger_manager import get_logger
+from src.common.logger import get_logger
 import time
 
 logger = get_logger("api")

src/api/apiforgui.py

@@ -3,7 +3,7 @@
 from fastapi import FastAPI
 from strawberry.fastapi import GraphQLRouter
 
-from src.common.server import global_server
+from src.common.server import get_global_server
 
 
 @strawberry.type
@@ -17,6 +17,6 @@ def hello(self) -> str:
 
 graphql_app = GraphQLRouter(schema)
 
-fast_api_app: FastAPI = global_server.get_app()
+fast_api_app: FastAPI = get_global_server().get_app()
 
 fast_api_app.include_router(graphql_app, prefix="/graphql")