Replace `logging` with centralized `loguru`-based logger across all modules.

src/voice_dialogue/api/app.py

@@ -1,4 +1,3 @@
-import logging
 from typing import Dict, Any
 
 from fastapi import FastAPI, HTTPException, APIRouter
@@ -7,19 +6,13 @@ from fastapi.responses import RedirectResponse
 from fastapi.staticfiles import StaticFiles
 
 from voice_dialogue.config.paths import FRONTEND_ASSETS_PATH
+from voice_dialogue.utils.logger import logger
 from .core.config import AppConfig
 from .core.lifespan import lifespan
 from .middleware.logging import LoggingMiddleware
 from .middleware.rate_limit import RateLimitMiddleware
 from .routes import tts_routes, asr_routes, system_routes, websocket_routes
 
-# 配置日志
-logging.basicConfig(
-    level=logging.INFO,
-    format='%(asctime)s - %(name)s - %(levelname)s - %(message)s'
-)
-logger = logging.getLogger(__name__)
-
 
 def create_app() -> FastAPI:
     """创建并配置FastAPI应用"""

src/voice_dialogue/api/core/config.py

@@ -1,9 +1,7 @@
-import logging
 from typing import Dict, Any
 
 from voice_dialogue.services.audio.generators import tts_config_registry
-
-logger = logging.getLogger(__name__)
+from voice_dialogue.utils.logger import logger
 
 
 class TTSConfigInitializer:

src/voice_dialogue/api/core/lifespan.py

@@ -1,18 +1,15 @@
-import logging
 import time
 from contextlib import asynccontextmanager
 
 from fastapi import FastAPI
 
 from voice_dialogue.services.audio.generators import tts_config_registry
-from voice_dialogue.utils import get_system_language
+from voice_dialogue.utils import get_system_language, logger
 from .config import TTSConfigInitializer
 from .service_factories import get_core_voice_service_definitions
 from .service_manager import ServiceManager
 from ..schemas.tts_schemas import generate_model_id
 
-logger = logging.getLogger(__name__)
-
 
 class LifespanManager:
     """应用生命周期管理器"""
@@ -38,16 +35,15 @@ class LifespanManager:
             default_tts_config = tts_config_registry.get_default_config_for_system()
             current_tts_model_id = None
             current_tts_character_name = None
-            
+
             if default_tts_config:
                 current_tts_model_id = generate_model_id(
-                    default_tts_config.tts_type.value, 
+                    default_tts_config.tts_type.value,
                     default_tts_config.character_name
                 )
                 current_tts_character_name = default_tts_config.character_name
                 logger.info(f"系统默认TTS模型: {current_tts_character_name} (ID: {current_tts_model_id})")
 
-
             # 获取服务定义
             service_definitions = get_core_voice_service_definitions(system_language)
 

src/voice_dialogue/api/core/service_manager.py

@@ -1,9 +1,8 @@
-import logging
 import time
 from dataclasses import dataclass
 from typing import Dict, List, Callable, Any, Optional
 
-logger = logging.getLogger(__name__)
+from voice_dialogue.utils.logger import logger
 
 
 @dataclass

src/voice_dialogue/api/middleware/logging.py

@@ -1,10 +1,9 @@
-import logging
 import time
 
-from fastapi import Request, Response
+from fastapi import Request
 from starlette.middleware.base import BaseHTTPMiddleware
 
-logger = logging.getLogger(__name__)
+from voice_dialogue.utils.logger import logger
 
 
 class LoggingMiddleware(BaseHTTPMiddleware):

src/voice_dialogue/api/routes/asr_routes.py

@@ -1,14 +1,12 @@
-import logging
-
 from fastapi import APIRouter, HTTPException, Request, BackgroundTasks
 
 from voice_dialogue.services.speech.recognizers import asr_manager
+from voice_dialogue.utils.logger import logger
 from ..core.service_factories import get_asr_worker_service_definition
 from ..schemas.asr_schemas import (
     SupportedLanguagesResponse, ASRInstanceRequest, ASRInstanceResponse
 )
 
-logger = logging.getLogger(__name__)
 router = APIRouter()
 
 _asr_creation_status = {

src/voice_dialogue/api/routes/system_routes.py

@@ -1,16 +1,15 @@
 import asyncio
-import logging
 import time
 
 from fastapi import APIRouter, HTTPException, BackgroundTasks, Request
 
 from voice_dialogue.core.constants import session_manager
+from voice_dialogue.utils.logger import logger
 from ..core.service_factories import get_audio_capture_service_definition
 from ..schemas.system_schemas import (
     SystemStatusResponse, SystemResponse
 )
 
-logger = logging.getLogger(__name__)
 router = APIRouter()
 
 # 全局系统状态

src/voice_dialogue/api/routes/tts_routes.py

@@ -1,16 +1,15 @@
-import logging
 from typing import Optional
 
 from fastapi import APIRouter, HTTPException, BackgroundTasks, Request
 
 from voice_dialogue.services.audio.generators import tts_config_registry
+from voice_dialogue.utils.logger import logger
 from ..core.service_factories import get_tts_audio_generator_service_definition
 from ..schemas.tts_schemas import (
     TTSModelInfo, TTSModelListResponse, TTSModelLoadRequest,
     TTSModelLoadResponse, TTSModelStatusResponse, generate_model_id
 )
 
-logger = logging.getLogger(__name__)
 router = APIRouter()
 
 # TTS模型加载状态管理

src/voice_dialogue/api/routes/websocket_routes.py

@@ -1,13 +1,11 @@
-import logging
 from queue import Empty
 
-
 from fastapi import APIRouter, WebSocket, WebSocketDisconnect
 
 from voice_dialogue.core.constants import websocket_message_queue, session_manager
+from voice_dialogue.utils.logger import logger
 
 ws = APIRouter()
-logger = logging.getLogger(__name__)
 
 
 @ws.websocket("/api/v1/ws")

src/voice_dialogue/api/server.py

@@ -6,6 +6,8 @@ API服务器启动器
 
 import uvicorn
 
+from voice_dialogue.utils.logger import logger
+
 
 def launch_api_server(host: str = "0.0.0.0", port: int = 8000, reload: bool = False):
     """
@@ -16,20 +18,24 @@ def launch_api_server(host: str = "0.0.0.0", port: int = 8000, reload: bool = Fa
         port (int): 服务器端口，默认为 8000
         reload (bool): 是否启用热重载，默认为 False
     """
-    print(f'{"=" * 80}\n正在启动API服务器...\n{"=" * 80}')
-    print(f"服务器地址: http://{host}:{port}")
-    print(f"API文档: http://{host}:{port}/docs")
-    print(f"热重载: {'启用' if reload else '禁用'}")
-    print(f'{"=" * 80}')
-
-    # 导入并启动FastAPI应用
-    uvicorn.run(
+    logger.info(f'{"=" * 80}')
+    logger.info(f'正在启动API服务器...')
+    logger.info(f"服务器地址: http://{host}:{port}")
+    logger.info(f"API文档: http://{host}:{port}/docs")
+    logger.info(f"热重载: {'启用' if reload else '禁用'}")
+    logger.info(f'{"=" * 80}')
+
+    uvicorn_config = uvicorn.Config(
         "voice_dialogue.api.app:app",
         host=host,
         port=port,
         reload=reload,
-        log_level="info"
+        log_level="info",
+        log_config=None,  # 不使用uvicorn的日志配置文件
+        use_colors=True,  # 启用彩色日志
     )
+    server = uvicorn.Server(uvicorn_config)
+    server.run()
 
 
 if __name__ == "__main__":

src/voice_dialogue/core/launcher.py

@@ -20,6 +20,7 @@ from voice_dialogue.services.audio.player import AudioStreamPlayer
 from voice_dialogue.services.speech.monitor import SpeechStateMonitor
 from voice_dialogue.services.speech.recognizer import ASRWorker
 from voice_dialogue.services.text.generator import LLMResponseGenerator
+from voice_dialogue.utils.logger import logger
 
 
 def launch_system(
@@ -58,7 +59,7 @@ def launch_system(
     # 导入speaker配置相关功能
 
     threads = []
-    
+
     # 音频采集
     audio_frame_probe = EchoCancellingAudioCapture(audio_frames_queue=audio_frames_queue)
     audio_frame_probe.start()
@@ -74,7 +75,7 @@ def launch_system(
 
     # 语音识别
     whisper_worker = ASRWorker(
-        user_voice_queue=user_voice_queue, 
+        user_voice_queue=user_voice_queue,
         transcribed_text_queue=transcribed_text_queue,
         language=user_language
     )
@@ -114,8 +115,8 @@ def launch_system(
     while not all([thread.is_ready for thread in threads]):
         time.sleep(0.1)
 
-    print(f'{"=" * 80}\n服务启动成功\n{"=" * 80}')
-    
+    logger.info(f'{"=" * 80}\n服务启动成功\n{"=" * 80}')
+
     # 等待所有线程结束
     for thread in threads:
         thread.join()

src/voice_dialogue/services/audio/capture.py

@@ -11,6 +11,7 @@ import numpy as np
 
 from voice_dialogue.config.paths import LIBRARIES_PATH
 from voice_dialogue.core.base import BaseThread
+from voice_dialogue.utils.logger import logger
 
 
 class EchoCancellingAudioCapture(BaseThread):
@@ -66,6 +67,6 @@ class EchoCancellingAudioCapture(BaseThread):
                     # 无数据时等待
                     time.sleep(0.01)
         except Exception as e:
-            print(f'回声消除音频捕获器运行时发生错误: {e}')
+            logger.error(f'回声消除音频捕获器运行时发生错误: {e}')
         finally:
             audio_recorder.stopRecord()

src/voice_dialogue/services/audio/generators/configs/__init__.py

@@ -20,9 +20,9 @@ try:
     }
 
 except ImportError as e:
-    import logging
+    from voice_dialogue.utils.logger import logger
 
-    logging.warning(f"Failed to import some config modules: {e}")
+    logger.warning(f"Failed to import some config modules: {e}")
     __all__ = []
     CONFIG_GETTERS = {}
 
@@ -35,8 +35,8 @@ def get_all_configs():
             configs = getter_func()
             all_configs.extend(configs)
         except Exception as e:
-            import logging
-            logging.error(f"Failed to load configs from {getter_func.__name__}: {e}")
+            from voice_dialogue.utils.logger import logger
+            logger.error(f"Failed to load configs from {getter_func.__name__}: {e}")
     return all_configs
 
 
@@ -46,7 +46,7 @@ def get_configs_by_type(tts_type: str):
         try:
             return CONFIG_GETTERS[tts_type]()
         except Exception as e:
-            import logging
-            logging.error(f"Failed to load configs for {tts_type}: {e}")
+            from voice_dialogue.utils.logger import logger
+            logger.error(f"Failed to load configs for {tts_type}: {e}")
             return []
     return []

src/voice_dialogue/services/audio/generators/manager.py

@@ -1,11 +1,11 @@
 import importlib.util
 import inspect
-import logging
 import re
 from dataclasses import dataclass
 from pathlib import Path
 from typing import Dict, Type
 
+from voice_dialogue.utils.logger import logger
 from .models.base import BaseTTSConfig
 from .runtime.interface import TTSInterface
 
@@ -22,11 +22,11 @@ class TTSRegistryTables:
 
     def print(self, key: str = None) -> None:
         """打印已注册的TTS类"""
-        print("\nTTS Registry Tables: \n")
+        logger.info("\nTTS Registry Tables: \n")
         headers = ["register name", "class name", "class location"]
 
         if self.tts_classes and (key is None or "tts_classes" in key):
-            print(f"-----------    ** tts_classes **    --------------")
+            logger.info(f"-----------    ** tts_classes **    --------------")
             metas = []
             for register_key, tts_class in self.tts_classes.items():
                 class_file = inspect.getfile(tts_class)
@@ -46,12 +46,12 @@ class TTSRegistryTables:
             col_widths = [max(len(str(item)) for item in col) for col in zip(*data)]
 
             for row in data:
-                print(
+                logger.info(
                     "| "
                     + " | ".join(str(item).ljust(width) for item, width in zip(row, col_widths))
                     + " |"
                 )
-        print("\n")
+        logger.info("\n")
 
     def register(self, register_table_key: str, key: str = None) -> callable:
         """装饰器，用于注册TTS类"""
@@ -59,18 +59,18 @@ class TTSRegistryTables:
         def decorator(target_class):
             if not hasattr(self, register_table_key):
                 setattr(self, register_table_key, {})
-                logging.debug(f"New TTS registry table added: {register_table_key}")
+                logger.debug(f"New TTS registry table added: {register_table_key}")
 
             registry = getattr(self, register_table_key)
             registry_key = key if key is not None else target_class.__name__
 
             if registry_key in registry:
-                logging.debug(
+                logger.debug(
                     f"Key {registry_key} already exists in {register_table_key}, re-register"
                 )
 
             registry[registry_key] = target_class
-            logging.info(f"Registered TTS class: {registry_key} -> {target_class.__name__}")
+            logger.info(f"Registered TTS class: {registry_key} -> {target_class.__name__}")
             return target_class
 
         return decorator
@@ -160,11 +160,11 @@ def register_all_tts():
             )
             module = importlib.util.module_from_spec(spec)
             spec.loader.exec_module(module)
-            logging.info(f"Successfully imported TTS module: {module_name}")
+            logger.info(f"Successfully imported TTS module: {module_name}")
         except ImportError as e:
-            logging.warning(f"Failed to import TTS module {module_name}: {e}")
+            logger.warning(f"Failed to import TTS module {module_name}: {e}")
         except Exception as e:
-            logging.error(f"Unexpected error importing TTS module {module_name}: {e}")
+            logger.error(f"Unexpected error importing TTS module {module_name}: {e}")
 
 
 # 在模块导入时自动注册所有TTS

src/voice_dialogue/services/audio/generators/models/__init__.py

@@ -22,9 +22,9 @@ try:
     _moyoyo_available = True
 except ImportError:
     _moyoyo_available = False
-    import logging
+    from voice_dialogue.utils.logger import logger
 
-    logging.warning("MoYoYo TTS config not available")
+    logger.warning("MoYoYo TTS config not available")
 
 try:
     from .kokoro import KokoroTTSConfig
@@ -32,9 +32,9 @@ try:
     _kokoro_available = True
 except ImportError:
     _kokoro_available = False
-    import logging
+    from voice_dialogue.utils.logger import logger
 
-    logging.warning("Kokoro TTS config not available")
+    logger.warning("Kokoro TTS config not available")
 
 # 动态构建导出列表
 __all__ = [
@@ -60,8 +60,8 @@ def _auto_register_configs():
             for config in get_moyoyo_configs():
                 tts_config_registry.register_config(config)
     except Exception as e:
-        import logging
-        logging.error(f"Failed to auto-register configs: {e}")
+        from voice_dialogue.utils.logger import logger
+        logger.error(f"Failed to auto-register configs: {e}")
 
     try:
         if _kokoro_available:
@@ -69,8 +69,8 @@ def _auto_register_configs():
             for config in get_kokoro_configs():
                 tts_config_registry.register_config(config)
     except Exception as e:
-        import logging
-        logging.error(f"Failed to auto-register configs: {e}")
+        from voice_dialogue.utils.logger import logger
+        logger.error(f"Failed to auto-register configs: {e}")
 
 
 # 模块加载时自动注册配置

src/voice_dialogue/services/audio/generators/models/base.py

@@ -1,4 +1,3 @@
-import logging
 import typing
 from abc import ABC, abstractmethod
 from enum import Enum
@@ -6,7 +5,7 @@ from pathlib import Path
 
 from pydantic import BaseModel
 
-logger = logging.getLogger(__name__)
+from voice_dialogue.utils.logger import logger
 
 
 class TTSConfigType(Enum):

src/voice_dialogue/services/audio/generators/runtime/__init__.py

@@ -21,9 +21,9 @@ try:
     __all__.append('MoYoYoTTS')
 except ImportError as e:
     # 如果某些TTS实现无法导入，不影响整体功能
-    import logging
+    from voice_dialogue.utils.logger import logger
 
-    logging.warning(f"Failed to import some TTS implementations: {e}")
+    logger.warning(f"Failed to import some TTS implementations: {e}")
 
 try:
     from .kokoro import KokoroTTS
@@ -31,6 +31,6 @@ try:
     __all__.append('KokoroTTS')
 except ImportError as e:
     # 如果某些TTS实现无法导入，不影响整体功能
-    import logging
+    from voice_dialogue.utils.logger import logger
 
-    logging.warning(f"Failed to import some TTS implementations: {e}")
+    logger.warning(f"Failed to import some TTS implementations: {e}")

src/voice_dialogue/services/audio/generators/runtime/kokoro.py

@@ -6,6 +6,7 @@ from kokoro_onnx import Kokoro
 from voice_dialogue.services.audio.generators.configs.kokoro import KokoroTTSConfig
 from voice_dialogue.services.audio.generators.manager import tts_tables
 from voice_dialogue.services.audio.generators.runtime.interface import TTSInterface
+from voice_dialogue.utils.logger import logger
 
 
 @tts_tables.register("tts_classes", "kokoro")
@@ -35,12 +36,12 @@ class KokoroTTS(TTSInterface):
             self.espeak_ng = en.G2P(trf=False, british=False, fallback=fallback)
 
     def warmup(self, warmup_steps: int = 1) -> None:
-        print('[INFO:] Warming up Kokoro TTS engine...')
+        logger.info('[INFO:] Warming up Kokoro TTS engine...')
         warmup_texts = ['Warming up TTS engine.', '预热文字转音频引擎。']
         for _ in range(warmup_steps):
             for warmup_text in warmup_texts:
                 self.synthesize(warmup_text)
-        print('[INFO:] Warm up Kokoro TTS engine finished.')
+        logger.info('[INFO:] Warm up Kokoro TTS engine finished.')
 
     def synthesize(self, text: str, **kwargs) -> Tuple[np.ndarray, int]:
         phonemes, _ = self.espeak_ng(text)

src/voice_dialogue/services/audio/generators/runtime/moyoyo.py

@@ -8,6 +8,7 @@ from voice_dialogue.config.paths import load_third_party
 from voice_dialogue.services.audio.generators.manager import tts_tables
 from voice_dialogue.services.audio.generators.models.moyoyo import MoYoYoTTSConfig
 from voice_dialogue.services.audio.generators.runtime.interface import TTSInterface
+from voice_dialogue.utils.logger import logger
 
 load_third_party()
 
@@ -43,12 +44,12 @@ class MoYoYoTTS(TTSInterface):
 
     def warmup(self, warmup_steps: int = 1) -> None:
         """预热TTS引擎"""
-        print('[INFO:] Warming up MoYoYo TTS engine...')
+        logger.info('[INFO:] Warming up MoYoYo TTS engine...')
         warmup_texts = ['Warming up TTS engine.', '预热文字转音频引擎。']
         for _ in range(warmup_steps):
             for warmup_text in warmup_texts:
                 self.tts_module.generate_audio(warmup_text, warmup=True)
-        print('[INFO:] Warm up MoYoYo TTS engine finished.')
+        logger.info('[INFO:] Warm up MoYoYo TTS engine finished.')
 
     def synthesize(self, text: str, **kwargs) -> Tuple[np.ndarray, int]:
         """合成语音"""

src/voice_dialogue/services/audio/player.py

@@ -12,6 +12,7 @@ from voice_dialogue.core.constants import (
     silence_over_threshold_event
 )
 from voice_dialogue.models.voice_task import VoiceTask, AnswerDisplayMessage
+from voice_dialogue.utils.logger import logger
 
 
 class AudioStreamPlayer(BaseThread):
@@ -40,7 +41,7 @@ class AudioStreamPlayer(BaseThread):
                 task_id = voice_task.id
                 answer_id = voice_task.answer_id
                 if user_still_speaking_event.is_set():
-                    print('用户还有说话')
+                    logger.info('用户还有说话')
                     voice_state_manager.drop_audio_task(task_id)
                     dropped_audio_cache[answer_id] = answer_id
                     user_still_speaking_event.clear()
@@ -84,7 +85,7 @@ class AudioStreamPlayer(BaseThread):
                     self.playing_audio(audio_data, sample_rate)
 
                 if self.audio_playing_queue.empty():
-                    print(f'回答播放完了')
+                    logger.info(f'回答播放完了')
 
                 break
 

src/voice_dialogue/services/speech/monitor.py

@@ -19,6 +19,7 @@ from voice_dialogue.core.constants import (
 )
 from voice_dialogue.core.enums import AudioState
 from voice_dialogue.models.voice_task import VoiceTask
+from voice_dialogue.utils.logger import logger
 
 
 class SpeechMonitorConfig:
@@ -280,6 +281,6 @@ class SpeechStateMonitor(BaseThread):
 
             except Exception as e:
                 # 错误处理，防止线程崩溃
-                print(f"SpeechStateMonitor 处理错误: {e}")
+                logger.error(f"SpeechStateMonitor 处理错误: {e}")
                 time.sleep(0.1)  # 避免错误循环
                 continue

src/voice_dialogue/services/speech/recognizers/manager.py

@@ -1,10 +1,10 @@
 import importlib.util
 import inspect
-import logging
 import re
 from dataclasses import dataclass
 from typing import Dict, Type, List, Literal, Optional
 
+from voice_dialogue.utils.logger import logger
 from .models import ASRInterface
 
 
@@ -20,11 +20,11 @@ class ASRRegistryTables:
 
     def print(self, key: str = None) -> None:
         """打印已注册的ASR类"""
-        print("\nASR Registry Tables: \n")
+        logger.info("\nASR Registry Tables: \n")
         headers = ["register name", "class name", "class location", "supported languages"]
 
         if self.asr_classes and (key is None or "asr_classes" in key):
-            print(f"-----------    ** asr_classes **    --------------")
+            logger.info(f"-----------    ** asr_classes **    --------------")
             metas = []
             for register_key, asr_class in self.asr_classes.items():
                 class_file = inspect.getfile(asr_class)
@@ -53,12 +53,12 @@ class ASRRegistryTables:
             col_widths = [max(len(str(item)) for item in col) for col in zip(*data)]
 
             for row in data:
-                print(
+                logger.info(
                     "| "
                     + " | ".join(str(item).ljust(width) for item, width in zip(row, col_widths))
                     + " |"
                 )
-        print("\n")
+        logger.info("\n")
 
     def register(self, register_table_key: str, key: str = None) -> callable:
         """装饰器，用于注册ASR类"""
@@ -66,18 +66,18 @@ class ASRRegistryTables:
         def decorator(target_class):
             if not hasattr(self, register_table_key):
                 setattr(self, register_table_key, {})
-                logging.debug(f"New ASR registry table added: {register_table_key}")
+                logger.debug(f"New ASR registry table added: {register_table_key}")
 
             registry = getattr(self, register_table_key)
             registry_key = key if key is not None else target_class.__name__
 
             if registry_key in registry:
-                logging.debug(
+                logger.debug(
                     f"Key {registry_key} already exists in {register_table_key}, re-register"
                 )
 
             registry[registry_key] = target_class
-            logging.info(f"Registered ASR class: {registry_key} -> {target_class.__name__}")
+            logger.info(f"Registered ASR class: {registry_key} -> {target_class.__name__}")
             return target_class
 
         return decorator
@@ -121,11 +121,11 @@ class ASRManager:
             asr_class = asr_tables.asr_classes[asr_type]
             instance = asr_class()
 
-            logging.info(f"成功创建ASR实例: {asr_type} for language: {language}")
+            logger.info(f"成功创建ASR实例: {asr_type} for language: {language}")
             return instance
 
         except Exception as e:
-            logging.error(f"创建ASR实例失败: {e}")
+            logger.error(f"创建ASR实例失败: {e}")
             raise
 
     def get_or_create_asr(self, language: Literal['auto', 'zh', 'en']) -> ASRInterface:
@@ -165,7 +165,7 @@ class ASRManager:
             raise ValueError(f"ASR类型 '{asr_type}' 未注册")
 
         self._language_to_asr_mapping[language] = asr_type
-        logging.info(f"更新语言映射: {language} -> {asr_type}")
+        logger.info(f"更新语言映射: {language} -> {asr_type}")
 
     def list_registered_asr(self) -> Dict[str, Type[ASRInterface]]:
         """列出所有已注册的ASR类型"""
@@ -190,7 +190,7 @@ class ASRManager:
                 # languages = asr_tables._get_asr_supported_languages(asr_key)
                 # supported_languages[asr_key] = languages
             except Exception as e:
-                logging.warning(f"获取ASR引擎 '{asr_key}' 支持的语言失败: {e}")
+                logger.warning(f"获取ASR引擎 '{asr_key}' 支持的语言失败: {e}")
                 supported_languages[asr_key] = ['unknown']
 
         return supported_languages
@@ -251,9 +251,9 @@ class ASRManager:
 
     def cleanup(self) -> None:
         """清理所有ASR实例"""
-        logging.info("清理ASR实例...")
+        logger.info("清理ASR实例...")
         self._asr_instances.clear()
-        logging.info("ASR实例清理完成")
+        logger.info("ASR实例清理完成")
 
     def print_registry(self) -> None:
         """打印注册表信息"""
@@ -301,11 +301,11 @@ def register_all_asr():
             )
             module = importlib.util.module_from_spec(spec)
             spec.loader.exec_module(module)
-            logging.info(f"Successfully imported ASR module: {module_name}")
+            logger.info(f"Successfully imported ASR module: {module_name}")
         except ImportError as e:
-            logging.warning(f"Failed to import ASR module {module_name}: {e}")
+            logger.warning(f"Failed to import ASR module {module_name}: {e}")
         except Exception as e:
-            logging.error(f"Unexpected error importing ASR module {module_name}: {e}")
+            logger.error(f"Unexpected error importing ASR module {module_name}: {e}")
 
 
 # 在模块导入时自动注册所有ASR

src/voice_dialogue/services/speech/recognizers/models/__init__.py

@@ -7,15 +7,15 @@ try:
 
     __all__.append('FunASRClient')
 except ImportError as e:
-    import logging
+    from voice_dialogue.utils.logger import logger
 
-    logging.warning(f"Failed to import some FunASR implementations: {e}")
+    logger.warning(f"Failed to import some FunASR implementations: {e}")
 
 try:
     from .whisper import WhisperCppClient
 
     __all__.append('WhisperCppClient')
 except ImportError as e:
-    import logging
+    from voice_dialogue.utils.logger import logger
 
-    logging.warning(f"Failed to import some Whisper implementations: {e}")
+    logger.warning(f"Failed to import some Whisper implementations: {e}")

src/voice_dialogue/services/speech/recognizers/models/funasr.py

@@ -8,6 +8,7 @@ from voice_dialogue.config import paths
 from voice_dialogue.services.speech.recognizers.manager import asr_tables
 from voice_dialogue.services.speech.recognizers.models.base import ASRInterface
 from voice_dialogue.services.speech.recognizers.utils import ensure_minimum_audio_duration
+from voice_dialogue.utils.logger import logger
 
 
 @asr_tables.register('asr_classes', 'funasr')
@@ -29,12 +30,12 @@ class FunASRClient(ASRInterface):
         self.punc_model = CT_Transformer(punc_model_path, quantize=True)
 
     def warmup(self) -> None:
-        print('[INFO] Warming up FunASR model...')
+        logger.info('[INFO] Warming up FunASR model...')
         try:
             self.transcribe(self.warmup_audiodata)
-            print('[INFO] FunASR model warmed up.')
+            logger.info('[INFO] FunASR model warmed up.')
         except Exception as e:
-            print(f'[WARNING] FunASR model warmup failed: {e}')
+            logger.warning(f'[WARNING] FunASR model warmup failed: {e}')
 
     def _fix_spaced_uppercase(self, text: str) -> str:
         """
@@ -60,7 +61,7 @@ class FunASRClient(ASRInterface):
             try:
                 content, _ = self.punc_model(content)
             except UnboundLocalError as e:
-                print(f'[WARNING] Punctuation model failed: {e}')
+                logger.warning(f'[WARNING] Punctuation model failed: {e}')
             content = self._fix_spaced_uppercase(content)
             transcibed_texts.append(content)
         return " ".join(transcibed_texts)

src/voice_dialogue/services/speech/recognizers/models/whisper.py

@@ -7,6 +7,7 @@ from voice_dialogue.config import paths
 from voice_dialogue.services.speech.recognizers.manager import asr_tables
 from voice_dialogue.services.speech.recognizers.models.base import ASRInterface
 from voice_dialogue.services.speech.recognizers.utils import ensure_minimum_audio_duration
+from voice_dialogue.utils.logger import logger
 
 
 @asr_tables.register('asr_classes', 'whisper')
@@ -30,12 +31,12 @@ class WhisperCppClient(ASRInterface):
         self.whisper = Model(model=model, models_dir=models_dir)
 
     def warmup(self) -> None:
-        print('[INFO] Warming up Whisper model...')
+        logger.info('[INFO] Warming up Whisper model...')
         try:
             self.transcribe(self.warmup_audiodata)
-            print('[INFO] Whisper model warmed up.')
+            logger.info('[INFO] Whisper model warmed up.')
         except Exception as e:
-            print(f'[WARNING] Whisper model warmup failed: {e}')
+            logger.warning(f'[WARNING] Whisper model warmup failed: {e}')
 
     def transcribe(self, audio_array: np.ndarray, language="en"):
         if language == "zh":

src/voice_dialogue/services/text/generator.py

@@ -12,6 +12,7 @@ from voice_dialogue.core.constants import chat_history_cache
 from voice_dialogue.models.voice_task import VoiceTask, QuestionDisplayMessage
 from voice_dialogue.services.text.processor import preprocess_sentence_text, \
     create_langchain_chat_llamacpp_instance, create_langchain_pipeline, warmup_langchain_pipeline
+from voice_dialogue.utils.logger import logger
 
 CHINESE_SYSTEM_PROMPT = (
     "你是善于模拟真实的思考过程的AI助手。"
@@ -129,7 +130,7 @@ class LLMResponseGenerator(BaseThread):
         is_first_sentence = True
 
         user_question = voice_task.transcribed_text
-        print(f'用户问题: {user_question}')
+        logger.info(f'用户问题: {user_question}')
         if self.websocket_message_queue:
             self.websocket_message_queue.put_nowait(
                 QuestionDisplayMessage(
@@ -177,7 +178,7 @@ class LLMResponseGenerator(BaseThread):
             self._handle_remaining_chunks(voice_task, chunks, answer_index)
 
         except Exception as e:
-            print(f'处理语音任务时发生错误: {e}')
+            logger.error(f'处理语音任务时发生错误: {e}')
 
     def _handle_remaining_chunks(self, voice_task: VoiceTask, chunks: list, answer_index: int) -> None:
         """处理剩余的 chunks"""
@@ -197,11 +198,11 @@ class LLMResponseGenerator(BaseThread):
 
         # 打印芯片信息和优化配置
         chip_summary = get_apple_silicon_summary()
-        print(f"检测到芯片: {chip_summary['chip_name']}")
-        print(f"性能核心数: {chip_summary['performance_cores']}")
-        print(f"使用线程数: {chip_summary['optimal_n_threads']} (仅使用性能核心)")
-        print(f"上下文窗口: {chip_summary['optimal_n_ctx']}")
-        print(f"配置说明: {chip_summary['config_note']}")
+        logger.info(f"检测到芯片: {chip_summary['chip_name']}")
+        logger.info(f"性能核心数: {chip_summary['performance_cores']}")
+        logger.info(f"使用线程数: {chip_summary['optimal_n_threads']} (仅使用性能核心)")
+        logger.info(f"上下文窗口: {chip_summary['optimal_n_ctx']}")
+        logger.info(f"配置说明: {chip_summary['config_note']}")
 
         self.model_instance = create_langchain_chat_llamacpp_instance(
             local_model_path=model_path, model_params=model_params
@@ -219,4 +220,4 @@ class LLMResponseGenerator(BaseThread):
             except Empty:
                 continue
             except Exception as e:
-                print(f'AnswerGeneratorWorker 运行时发生错误: {e}')
+                logger.error(f'AnswerGeneratorWorker 运行时发生错误: {e}')

src/voice_dialogue/services/text/processor.py

@@ -9,6 +9,7 @@ from langchain_core.prompts import (
 )
 from langchain_core.runnables import RunnableWithMessageHistory
 
+from voice_dialogue.utils.logger import logger
 from voice_dialogue.utils.strings import (
     remove_emojis, convert_comma_separated_numbers, convert_uppercase_words_to_lowercase
 )
@@ -18,7 +19,7 @@ def create_langchain_chat_llamacpp_instance(
         local_model_path: str,
         model_params: dict | None = None
 ) -> ChatLlamaCpp:
-    print(">>>>>>> Initializing LlamaCpp Langchain instance...")
+    logger.info(">>>>>>> Initializing LlamaCpp Langchain instance...")
 
     model_path = pathlib.Path(local_model_path)
     callback_manager = CallbackManager([StreamingStdOutCallbackHandler()])
@@ -55,7 +56,7 @@ def create_langchain_pipeline(langchain_instance, system_prompt: str, get_sessio
 
 
 def warmup_langchain_pipeline(pipeline):
-    print("Warmup chat pipeline...")
+    logger.info("Warmup chat pipeline...")
 
     user_input = 'Hello, this is warming up step, if you understand, output "Ok".'
     config = {"configurable": {"session_id": 'warmup'}}

src/voice_dialogue/utils/__init__.py

@@ -4,6 +4,7 @@ from .download_utils import (
     download_model_from_huggingface, download_file_from_huggingface, check_file_exists_on_huggingface,
     download_lora_from_huggingface, download_civitai_file
 )
+from .logger import logger
 from .strings import remove_emojis
 from .system import get_system_language, get_system_info
 
@@ -63,4 +64,5 @@ __all__ = (
     'LRUCacheDict',
     'get_system_language',
     'get_system_info',
+    'logger',
 )

src/voice_dialogue/utils/logger.py

@@ -1,81 +1,37 @@
-import logging
 import sys
-from logging.handlers import RotatingFileHandler
-from pathlib import Path
+
+from loguru import logger as _logger
+
+__all__ = ("logger",)
 
 
 def setup_logger(
-        logger_name: str = "app",
-        log_file: str = "app.log",
-        level: int = logging.INFO,
-        log_format: str = "%(asctime)s - %(name)s - %(levelname)s - %(message)s",
-        max_bytes: int = 5_242_880,  # 5MB
-        backup_count: int = 3
-) -> logging.Logger:
+        level: str = "INFO",
+        log_format: str = "<green>{time:YYYY-MM-DD HH:mm:ss}</green> | <level>{level: <8}</level> | <cyan>{name}</cyan>:<cyan>{function}</cyan>:<cyan>{line}</cyan> - <level>{message}</level>",
+) -> object:
     """
-    Configure and return a logger with both file and console handlers.
+    Configure and return a loguru logger with console output only.
 
     Args:
-        logger_name: Name of the logger
-        log_file: Path to the log file
-        level: Logging level
-        log_format: Format string for log messages
-        max_bytes: Maximum size of log file before rotation
-        backup_count: Number of backup files to keep
+        level: 日志级别 (INFO, DEBUG, WARNING, ERROR, CRITICAL)
+        log_format: 日志格式字符串
 
     Returns:
-        logging.Logger: Configured logger instance
+        loguru.logger: 配置好的logger实例
     """
-    # Create logger
-    logger = logging.getLogger(logger_name)
-    logger.setLevel(level)
-
-    # Create formatters
-    formatter = logging.Formatter(log_format)
-
-    # Ensure log directory exists
-    log_path = Path(log_file)
-    log_path.parent.mkdir(parents=True, exist_ok=True)
-
-    # Create and configure file handler with rotation
-    file_handler = RotatingFileHandler(
-        log_file,
-        maxBytes=max_bytes,
-        backupCount=backup_count,
-        encoding='utf-8'
+    # 移除所有现有的处理器
+    _logger.remove()
+
+    # 添加控制台处理器
+    _logger.add(
+        sys.stdout,
+        level=level.upper(),
+        format=log_format,
+        colorize=True,
+        enqueue=True  # 使日志线程安全
     )
-    file_handler.setFormatter(formatter)
-    file_handler.setLevel(level)
 
-    # Create and configure console handler
-    console_handler = logging.StreamHandler(sys.stdout)
-    console_handler.setFormatter(formatter)
-    console_handler.setLevel(level)
+    return _logger
 
-    # Add handlers to logger if they haven't been added already
-    if not logger.handlers:
-        logger.addHandler(file_handler)
-        logger.addHandler(console_handler)
 
-    return logger
-
-
-# Example usage
-if __name__ == "__main__":
-    # Basic setup
-    logger = setup_logger()
-    logger.info("Basic logger initialized")
-
-    # Custom setup example
-    custom_logger = setup_logger(
-        logger_name="custom_app",
-        log_file="logs/custom.log",
-        level=logging.DEBUG,
-        log_format="%(asctime)s [%(levelname)s] %(name)s: %(message)s",
-        max_bytes=1_048_576,  # 1MB
-        backup_count=5
-    )
-    custom_logger.debug("Custom logger initialized")
-    custom_logger.info("This is an info message")
-    custom_logger.warning("This is a warning message")
-    custom_logger.error("This is an error message")
+logger = setup_logger()