From f06fac2dc95ae1d94f5bb11ae767ce8fed9417b4 Mon Sep 17 00:00:00 2001
From: minecraft1024a <wwwww95915@qq.com>
Date: Sat, 4 Oct 2025 21:04:49 +0800
Subject: [PATCH] =?UTF-8?q?fix(api):=20=E4=BF=AE=E5=A4=8D=E6=9C=BA?=
 =?UTF-8?q?=E5=99=A8=E4=BA=BA=E6=B6=88=E6=81=AF=E7=BB=9F=E8=AE=A1=E8=AE=A1?=
 =?UTF-8?q?=E6=95=B0=E5=99=A8=E9=80=BB=E8=BE=91?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

chore(logging): 移除 message_manager 各模块多余的启动日志

- 修复了 `get_bot_message_stats_by_chat` 接口中错误地将计数器重置为1而不是递增的问题。
- 清理了 `message_manager` 及其子模块中重复或不必要的启动日志，以减少日志冗余。
---
 src/api/message_router.py                           | 2 +-
 src/chat/message_manager/adaptive_stream_manager.py | 1 -
 src/chat/message_manager/batch_database_writer.py   | 1 -
 src/chat/message_manager/distribution_manager.py    | 1 -
 src/chat/message_manager/message_manager.py         | 2 --
 src/chat/message_manager/stream_cache_manager.py    | 1 -
 6 files changed, 1 insertion(+), 7 deletions(-)

diff --git a/src/api/message_router.py b/src/api/message_router.py
index e0f8f7004..9595463d1 100644
--- a/src/api/message_router.py
+++ b/src/api/message_router.py
@@ -151,7 +151,7 @@ async def get_bot_message_stats_by_chat(
             chat_id = msg.get("chat_id", "unknown")
             if chat_id not in stats:
                 stats[chat_id] = 0
-            stats[chat_id] = 1
+            stats[chat_id] += 1
 
         if format:
             chat_manager = get_chat_manager()
diff --git a/src/chat/message_manager/adaptive_stream_manager.py b/src/chat/message_manager/adaptive_stream_manager.py
index c48b2d300..b9fe6ab78 100644
--- a/src/chat/message_manager/adaptive_stream_manager.py
+++ b/src/chat/message_manager/adaptive_stream_manager.py
@@ -110,7 +110,6 @@ class AdaptiveStreamManager:
         self.is_running = True
         self.monitor_task = asyncio.create_task(self._system_monitor_loop(), name="system_monitor")
         self.adjustment_task = asyncio.create_task(self._adjustment_loop(), name="limit_adjustment")
-        logger.info("自适应流管理器已启动")
 
     async def stop(self):
         """停止自适应管理器"""
diff --git a/src/chat/message_manager/batch_database_writer.py b/src/chat/message_manager/batch_database_writer.py
index 4b35b01c1..de40efa51 100644
--- a/src/chat/message_manager/batch_database_writer.py
+++ b/src/chat/message_manager/batch_database_writer.py
@@ -72,7 +72,6 @@ class BatchDatabaseWriter:
 
         self.is_running = True
         self.writer_task = asyncio.create_task(self._batch_writer_loop(), name="batch_database_writer")
-        logger.info("批量数据库写入器已启动")
 
     async def stop(self):
         """停止批量写入器"""
diff --git a/src/chat/message_manager/distribution_manager.py b/src/chat/message_manager/distribution_manager.py
index 25b4dd6b1..69be66bf1 100644
--- a/src/chat/message_manager/distribution_manager.py
+++ b/src/chat/message_manager/distribution_manager.py
@@ -59,7 +59,6 @@ class StreamLoopManager:
             return
 
         self.is_running = True
-        logger.info("流循环管理器已启动")
 
     async def stop(self) -> None:
         """停止流循环管理器"""
diff --git a/src/chat/message_manager/message_manager.py b/src/chat/message_manager/message_manager.py
index d6d56294b..ede788c4d 100644
--- a/src/chat/message_manager/message_manager.py
+++ b/src/chat/message_manager/message_manager.py
@@ -60,7 +60,6 @@ class MessageManager:
         try:
             from src.chat.message_manager.batch_database_writer import init_batch_writer
             await init_batch_writer()
-            logger.info("📦 批量数据库写入器已启动")
         except Exception as e:
             logger.error(f"启动批量数据库写入器失败: {e}")
 
@@ -68,7 +67,6 @@ class MessageManager:
         try:
             from src.chat.message_manager.stream_cache_manager import init_stream_cache_manager
             await init_stream_cache_manager()
-            logger.info("🗄️ 流缓存管理器已启动")
         except Exception as e:
             logger.error(f"启动流缓存管理器失败: {e}")
 
diff --git a/src/chat/message_manager/stream_cache_manager.py b/src/chat/message_manager/stream_cache_manager.py
index fcbfd7bd4..19f0590d9 100644
--- a/src/chat/message_manager/stream_cache_manager.py
+++ b/src/chat/message_manager/stream_cache_manager.py
@@ -72,7 +72,6 @@ class TieredStreamCache:
 
         self.is_running = True
         self.cleanup_task = asyncio.create_task(self._cleanup_loop(), name="stream_cache_cleanup")
-        logger.info("分层流缓存管理器已启动")
 
     async def stop(self):
         """停止缓存管理器"""