diff --git a/src/plugins/chat/message_buffer.py b/src/plugins/chat/message_buffer.py index c1bac3b14..d42fc9973 100644 --- a/src/plugins/chat/message_buffer.py +++ b/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() \ No newline at end of file +message_buffer = MessageBuffer() \ No newline at end of file diff --git a/src/plugins/chat_module/reasoning_chat/reasoning_chat.py b/src/plugins/chat_module/reasoning_chat/reasoning_chat.py index 677baac52..13f055185 100644 --- a/src/plugins/chat_module/reasoning_chat/reasoning_chat.py +++ b/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) diff --git a/src/plugins/chat_module/think_flow_chat/think_flow_chat.py b/src/plugins/chat_module/think_flow_chat/think_flow_chat.py index 0f8d3298b..42e2b8e43 100644 --- a/src/plugins/chat_module/think_flow_chat/think_flow_chat.py +++ b/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) diff --git a/src/plugins/person_info/person_info.py b/src/plugins/person_info/person_info.py index 8f5949c5e..3cbccbe8a 100644 --- a/src/plugins/person_info/person_info.py +++ b/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