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): """停止缓存管理器"""