gardel/Mofox-Core
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

优化

Browse Source
This commit is contained in:
meng_xi_pan
2025-04-05 01:54:31 +08:00
parent 02643d729e
commit aadd494151
1 changed files with 8 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
src/plugins/chat/message_buffer.py
View File

@@ -46,6 +46,13 @@ class MessageBuffer:
if person_id_ not in self.buffer_pool: if person_id_ not in self.buffer_pool:
self.buffer_pool[person_id_] = OrderedDict() self.buffer_pool[person_id_] = OrderedDict()
# 标记该用户之前的未处理消息
for cache_msg in self.buffer_pool[person_id_].values():
if cache_msg.result == "U":
cache_msg.result = "F"
cache_msg.cache_determination.set()
logger.debug(f"被新消息覆盖信息id: {cache_msg.message.message_info.message_id}")
# 查找最近的处理成功消息(T) # 查找最近的处理成功消息(T)
recent_F_count = 0 recent_F_count = 0
for msg_id in reversed(self.buffer_pool[person_id_]): for msg_id in reversed(self.buffer_pool[person_id_]):
@@ -63,13 +70,6 @@ class MessageBuffer:
logger.debug(f"快速处理消息(已堆积{recent_F_count}条F): {message.message_info.message_id}") logger.debug(f"快速处理消息(已堆积{recent_F_count}条F): {message.message_info.message_id}")
return return
# 标记该用户之前的未处理消息
for cache_msg in self.buffer_pool[person_id_].values():
if cache_msg.result == "U":
cache_msg.result = "F"
cache_msg.cache_determination.set()
logger.debug(f"被新消息覆盖信息id: {cache_msg.message.message_info.message_id}")
# 添加新消息 # 添加新消息
self.buffer_pool[person_id_][message.message_info.message_id] = CacheMessages(message=message) self.buffer_pool[person_id_][message.message_info.message_id] = CacheMessages(message=message)
@@ -93,7 +93,7 @@ class MessageBuffer:
async with self.lock: async with self.lock:
if (person_id_ not in self.buffer_pool or if (person_id_ not in self.buffer_pool or
message_id not in self.buffer_pool[person_id_]): message_id not in self.buffer_pool[person_id_]):
logger.debug(f"消息异常被清理，msgid: {message_id}") logger.debug(f"消息已被清理，msgid: {message_id}")
return return
cache_msg = self.buffer_pool[person_id_][message_id] cache_msg = self.buffer_pool[person_id_][message_id]