From 99266ea57913663f9880c512726c42cb7e5e7f28 Mon Sep 17 00:00:00 2001
From: yj <2077506045@qq.com>
Date: 星期一, 28 七月 2025 11:14:28 +0800
Subject: [PATCH] 新增忽略好友消息；删除多余文件
---
app/services/message_processor.py | 11 +++++++++--
1 files changed, 9 insertions(+), 2 deletions(-)
diff --git a/app/services/message_processor.py b/app/services/message_processor.py
index 12aaea2..e70555a 100644
--- a/app/services/message_processor.py
+++ b/app/services/message_processor.py
@@ -16,6 +16,7 @@
from app.services.redis_queue import redis_queue
from app.services.ecloud_client import ecloud_client
from app.services.dify_client import dify_client
+from app.services.friend_ignore_service import friend_ignore_service
from config import settings
@@ -99,6 +100,12 @@
or not data.get("content")
):
logger.warning(f"娑堟伅缂哄皯蹇呰瀛楁: data={data}")
+ return False
+
+ # 妫�鏌ュ彂閫佽�呮槸鍚﹀湪濂藉弸蹇界暐鍒楄〃涓�
+ from_user = data.get("fromUser")
+ if friend_ignore_service.is_friend_ignored(from_user):
+ logger.info(f"蹇界暐濂藉弸鍙戦�佺殑娑堟伅: fromUser={from_user}")
return False
return True
@@ -210,8 +217,8 @@
# 3.2 鑾峰彇鐢ㄦ埛鍦ㄥ綋鍓嶇兢缁勭殑conversation_id
conversation_id = redis_queue.get_conversation_id(from_user, from_group)
- # 璋冪敤Dify鎺ュ彛鍙戦�佹秷鎭�
- dify_response = dify_client.send_chat_message(
+ # 璋冪敤Dify鎺ュ彛鍙戦�佹秷鎭紙鏍规嵁閰嶇疆閫夋嫨妯″紡锛�
+ dify_response = dify_client.send_message(
query=content, user=from_user, conversation_id=conversation_id
)
--
Gitblit v1.9.1