ruff

src/plugins/chat/message_buffer.py

@@ -6,7 +6,7 @@ from .message import MessageRecv
 from ..message.message_base import BaseMessageInfo
 import hashlib
 from typing import Dict
-from dataclasses import dataclass, field
+from dataclasses import field
 from collections import OrderedDict
 import random
 import time
@@ -20,7 +20,7 @@ class CacheMessages:
     result: str = "U"
 
 
-class MassageBuffer:
+class MessageBuffer:
     def __init__(self):
         self.buffer_pool: Dict[str, OrderedDict[str, CacheMessages]] = {}
         self.lock = asyncio.Lock()
@@ -59,7 +59,7 @@ class MassageBuffer:
                 return
 
             # 标记该用户之前的未处理消息
-            for msg_id, cache_msg in self.buffer_pool[person_id_].items():
+            for cache_msg in self.buffer_pool[person_id_].values:
                 if cache_msg.result == "U":
                     cache_msg.result = "F"
                     cache_msg.cache_determination.set()
@@ -174,4 +174,4 @@ class MassageBuffer:
         await person_info_manager.update_one_field(person_id, "msg_interval_list", message_interval_list, data)
 
 
-message_buffer = MassageBuffer()
+message_buffer = MessageBuffer()

src/plugins/chat_module/reasoning_chat/reasoning_chat.py

@@ -181,9 +181,9 @@ class ReasoningChat:
             if message.message_segment.type == "text":
                 logger.info(f"触发缓冲，已炸飞消息：{message.processed_plain_text}")
             elif message.message_segment.type == "image":
-                logger.info(f"触发缓冲，已炸飞表情包/图片")
+                logger.info("触发缓冲，已炸飞表情包/图片")
             elif message.message_segment.type == "seglist":
-                logger.info(f"触发缓冲，已炸飞消息列")
+                logger.info("触发缓冲，已炸飞消息列")
             return
 
         is_mentioned = is_mentioned_bot_in_message(message)

src/plugins/chat_module/think_flow_chat/think_flow_chat.py

@@ -204,9 +204,9 @@ class ThinkFlowChat:
             if message.message_segment.type == "text":
                 logger.info(f"触发缓冲，已炸飞消息：{message.processed_plain_text}")
             elif message.message_segment.type == "image":
-                logger.info(f"触发缓冲，已炸飞表情包/图片")
+                logger.info("触发缓冲，已炸飞表情包/图片")
             elif message.message_segment.type == "seglist":
-                logger.info(f"触发缓冲，已炸飞消息列")
+                logger.info("触发缓冲，已炸飞消息列")
             return
 
         is_mentioned = is_mentioned_bot_in_message(message)

src/plugins/person_info/person_info.py

@@ -3,15 +3,14 @@ from ...common.database import db
 import copy
 import hashlib
 from typing import Any, Callable, Dict, TypeVar
-T = TypeVar('T')  # 泛型类型
 import datetime
 import asyncio
 import numpy
-
 import matplotlib.pyplot as plt
 from pathlib import Path
 import pandas as pd
 
+
 """
 PersonInfoManager 类方法功能摘要：
 1. get_person_id - 根据平台和用户ID生成MD5哈希的唯一person_id