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

fix：修复thinking_id的格式

Browse Source
This commit is contained in:
SengokuCola
2025-06-03 00:12:36 +08:00
parent 1ef124bf5e
commit 75cb982de8
1 changed files with 4 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
src/chat/normal_chat/normal_chat.py
View File

@@ -97,7 +97,7 @@ class NormalChat:
) )
thinking_time_point = round(time.time(), 2) thinking_time_point = round(time.time(), 2)
thinking_id = "mt" + str(thinking_time_point) thinking_id = "tid" + str(thinking_time_point)
thinking_message = MessageThinking( thinking_message = MessageThinking(
message_id=thinking_id, message_id=thinking_id,
chat_stream=self.chat_stream, chat_stream=self.chat_stream,
@@ -236,7 +236,6 @@ class NormalChat:
message=message, message=message,
is_mentioned=is_mentioned, is_mentioned=is_mentioned,
interested_rate=interest_value * self.willing_amplifier, interested_rate=interest_value * self.willing_amplifier,
rewind_response=False,
) )
except Exception as e: except Exception as e:
logger.error(f"[{self.stream_name}] 处理兴趣消息{msg_id}时出错: {e}\n{traceback.format_exc()}") logger.error(f"[{self.stream_name}] 处理兴趣消息{msg_id}时出错: {e}\n{traceback.format_exc()}")
@@ -245,7 +244,7 @@ class NormalChat:
# 改为实例方法, 移除 chat 参数 # 改为实例方法, 移除 chat 参数
async def normal_response( async def normal_response(
self, message: MessageRecv, is_mentioned: bool, interested_rate: float, rewind_response: bool = False self, message: MessageRecv, is_mentioned: bool, interested_rate: float
) -> None: ) -> None:
# 新增：如果已停用，直接返回 # 新增：如果已停用，直接返回
if self._disabled: if self._disabled:
@@ -288,11 +287,8 @@ class NormalChat:
# 回复前处理 # 回复前处理
await willing_manager.before_generate_reply_handle(message.message_info.message_id) await willing_manager.before_generate_reply_handle(message.message_info.message_id)
with Timer("创建思考消息", timing_results):
if rewind_response: thinking_id = await self._create_thinking_message(message)
thinking_id = await self._create_thinking_message(message, message.message_info.time)
else:
thinking_id = await self._create_thinking_message(message)
logger.debug(f"[{self.stream_name}] 创建捕捉器，thinking_id:{thinking_id}") logger.debug(f"[{self.stream_name}] 创建捕捉器，thinking_id:{thinking_id}")