From 66fc931d3e18e9829c0ed07671981c008b6f4b6f Mon Sep 17 00:00:00 2001 From: liuwei Date: Mon, 26 May 2025 09:34:17 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E6=95=B4=E8=99=9A=E6=8B=9F=E7=BE=A4?= =?UTF-8?q?=E7=BB=84=E5=8A=9F=E8=83=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- plugins/group_virtual/main.py | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/plugins/group_virtual/main.py b/plugins/group_virtual/main.py index 6540c26..3c52dcb 100644 --- a/plugins/group_virtual/main.py +++ b/plugins/group_virtual/main.py @@ -42,7 +42,6 @@ class GroupVirtualPlugin(MessagePluginInterface): self.data = None self.message_cache = set() # 用于防止消息循环转发 self.group_virtual_redis = None - self.bot: WechatAPIClient = None def initialize(self, context: Dict[str, Any]) -> bool: """初始化插件""" @@ -91,7 +90,7 @@ class GroupVirtualPlugin(MessagePluginInterface): return len(chat_groups) > 0 @plugin_stats_decorator(plugin_name="跨群聊天") - def process_message(self, message: Dict[str, Any]) -> Tuple[bool, Optional[str]]: + async def process_message(self, message: Dict[str, Any]) -> Tuple[bool, Optional[str]]: """处理消息""" roomid = message.get("roomid", "") sender = message.get("sender", "") @@ -120,11 +119,11 @@ class GroupVirtualPlugin(MessagePluginInterface): # 处理每个虚拟聊天组的转发 for chat_group in chat_groups: - self._forward_message_in_chat_group(message, chat_group) + await self._forward_message_in_chat_group(message, chat_group) return True, "消息已转发" - def _forward_message_in_chat_group(self, message: Dict[str, Any], chat_group: Dict[str, Any]): + async def _forward_message_in_chat_group(self, message: Dict[str, Any], chat_group: Dict[str, Any]): """在虚拟聊天组内转发消息""" roomid = message.get("roomid", "") sender = message.get("sender", "") @@ -156,7 +155,7 @@ class GroupVirtualPlugin(MessagePluginInterface): # 转发到其他群 for group in chat_group["groups"]: if group["id"] != roomid: # 不转发回源群 - self.bot.send_text_message(group["id"], forward_content) + await self.bot.send_text_message(group["id"], forward_content) # 图片消息 暂时不支持。 # elif msg_type == 3: