feat: 在消息处理后记录关键词得分 (Task #1556)
This commit is contained in:
+10
@@ -8324,6 +8324,16 @@ class MessageMonitor:
|
|||||||
self._recent_processed_messages.append((_best_cleaned, now))
|
self._recent_processed_messages.append((_best_cleaned, now))
|
||||||
# ⭐ 添加到最近用户查询列表(用于跨轮语义去重)
|
# ⭐ 添加到最近用户查询列表(用于跨轮语义去重)
|
||||||
self._add_to_recent_user_queries(_best_cleaned)
|
self._add_to_recent_user_queries(_best_cleaned)
|
||||||
|
# ⭐ Task #1556: 记录关键词得分到数据库
|
||||||
|
if self._keyword_scorer:
|
||||||
|
try:
|
||||||
|
keywords = self._keyword_scorer.extract_keywords(_best_cleaned)
|
||||||
|
# 新消息得分为0(未匹配历史回复),记录为已处理
|
||||||
|
self._keyword_scorer.record_message_score(
|
||||||
|
platform, _best_cleaned, keywords, 0, [], is_new=True
|
||||||
|
)
|
||||||
|
except Exception as e:
|
||||||
|
logger.debug(f"[{platform}] 关键词记录失败: {e}")
|
||||||
self._last_new_msg_time[platform] = time.time()
|
self._last_new_msg_time[platform] = time.time()
|
||||||
self._last_msg[platform] = _best_cleaned
|
self._last_msg[platform] = _best_cleaned
|
||||||
engine_tag = self._last_chosen_engine.get(platform, "")
|
engine_tag = self._last_chosen_engine.get(platform, "")
|
||||||
|
|||||||
Reference in New Issue
Block a user