diff --git a/plugins/dify/main.py b/plugins/dify/main.py index 4f32444..f458111 100644 --- a/plugins/dify/main.py +++ b/plugins/dify/main.py @@ -122,7 +122,6 @@ class DifyPlugin(MessagePluginInterface): self.LOG.info(f"插件执行: {self.name}:{content}") sender = message.get("sender") roomid = message.get("roomid", "") - wcf: Wcf = message.get("wcf") gbm: GroupBotManager = message.get("gbm") # 处理被@的消息 @@ -135,10 +134,10 @@ class DifyPlugin(MessagePluginInterface): query = re.sub(r"@.*?[\u2005|\s]", "", content).strip() if not query: - wcf.send_text("请在@我的同时提供问题内容", roomid, sender) + self.message_util.send_text_msg("请在@我的同时提供问题内容", roomid, sender) return True, "没有提供问题内容" - self.message_util.send_text_msg("⏳AI 正在加油,请稍候… 😊", roomid, sender) + # self.message_util.send_text_msg("⏳AI 正在加油,请稍候… 😊", roomid, sender) try: # 调用Dify API获取回复 @@ -151,18 +150,18 @@ class DifyPlugin(MessagePluginInterface): # 判断是否为本地文件路径 if os.path.isfile(response): # 如果是文件路径,使用发送文件方法 - wcf.send_file(response, roomid) + self.message_util.send_file(response, roomid) else: # 如果是普通文本,使用发送文本方法 - wcf.send_text(response, roomid, sender) + self.message_util.send_text_msg(response, roomid, sender) return True, "发送成功" else: - wcf.send_text("❌未能获取到回复,请稍后再试", roomid, sender) + self.message_util.send_text_msg("❌未能获取到回复,请稍后再试", roomid, sender) return True, "未获取到回复" except Exception as e: self.LOG.error(f"处理Dify聊天请求出错: {e}") - wcf.send_text(f"❌请求出错:{str(e)}", roomid, sender) + self.message_util.send_text_msg(f"❌请求出错:{str(e)}", roomid, sender) return True, f"处理出错: {e}" # 原有的命令处理逻辑 @@ -171,7 +170,7 @@ class DifyPlugin(MessagePluginInterface): # 检查命令格式 if len(parts) < 2 or not parts[1].strip(): - wcf.send_text(f"{self.command_format}", + self.message_util.send_text_msg(f"{self.command_format}", (roomid if roomid else sender), sender) return True, "命令格式错误" @@ -179,8 +178,7 @@ class DifyPlugin(MessagePluginInterface): if roomid and gbm.get_group_permission(roomid, Feature.AI_CAPABILITY) == PermissionStatus.DISABLED: return False, "没有权限" - self.message_util.send_text_msg("⏳AI 正在加油,请稍候… 😊", (roomid if roomid else sender), - sender if roomid else "") + # self.message_util.send_text_msg("⏳AI 正在加油,请稍候… 😊", (roomid if roomid else sender),sender if roomid else "") # 获取查询内容 query = parts[1].strip() @@ -200,18 +198,18 @@ class DifyPlugin(MessagePluginInterface): # 判断是否为本地文件路径 if os.path.isfile(response): # 如果是文件路径,使用发送文件方法 - wcf.send_file(response, (roomid if roomid else sender)) + self.message_util.send_file(response, (roomid if roomid else sender)) else: # 如果是普通文本,使用发送文本方法 - wcf.send_text(response, (roomid if roomid else sender), sender if roomid else "") + self.message_util.send_text_msg(response, (roomid if roomid else sender), sender if roomid else "") return True, "发送成功" else: - wcf.send_text("❌未能获取到回复,请稍后再试", (roomid if roomid else sender), sender if roomid else "") + self.message_util.send_text_msg("❌未能获取到回复,请稍后再试", (roomid if roomid else sender), sender if roomid else "") return True, "未获取到回复" except Exception as e: self.LOG.error(f"处理Dify聊天请求出错: {e}") - wcf.send_text(f"❌请求出错:{str(e)}", (roomid if roomid else sender), sender if roomid else "") + self.message_util.send_text_msg(f"❌请求出错:{str(e)}", (roomid if roomid else sender), sender if roomid else "") return True, f"处理出错: {e}"