feat: gewechat 主动消息

2025-01-18 22:31:17 +08:00
parent be2d5a91c7
commit 01f4e0b961
2 changed files with 14 additions and 24 deletions
@@ -21,28 +21,6 @@ class GewechatPlatformEvent(AstrMessageEvent):
        
    @staticmethod
    async def send_with_client(message: MessageChain, user_name: str):
-        # plain = ""
-        # for comp in message.chain:
-        #     if isinstance(comp, Plain):
-        #         if message.is_split_:
-        #             await client.send_msg(comp.text, user_name)
-        #         else:
-        #             plain += comp.text
-        #     elif isinstance(comp, Image):
-        #         if comp.file and comp.file.startswith("file:///"):
-        #             file_path = comp.file.replace("file:///", "")
-        #             with open(file_path, "rb") as f:
-        #                 await client.send_image(user_name, fd=f)
-        #         elif comp.file and comp.file.startswith("http"):
-        #             image_path = await download_image_by_url(comp.file)
-        #             with open(image_path, "rb") as f:
-        #                 await client.send_image(user_name, fd=f)
-        #     else:
-        #         logger.error(f"不支持的 vchat(微信适配器) 消息类型: {comp}")
-        #     await asyncio.sleep(random.uniform(0.5, 1.5)) # 🤓
-        
-        # if plain:
-        #     await client.send_msg(plain, user_name)
        pass
                
        
@@ -9,6 +9,7 @@ from astrbot.core.platform.astr_message_event import MessageSesion
 from ...register import register_platform_adapter
 from .gewechat_event import GewechatPlatformEvent
 from .client import SimpleGewechatClient
+from astrbot.core.message.components import Plain

 if sys.version_info >= (3, 12):
    from typing import override
@@ -28,8 +29,19 @@ class GewechatPlatformAdapter(Platform):
    
    @override
    async def send_by_session(self, session: MessageSesion, message_chain: MessageChain):
-        # from_username = session.session_id.split('$$')[0]
-        # await GewechatPlatformEvent.send_with_client(self.client, message_chain, from_username)
+        to_wxid = session.session_id
+        if "_" in to_wxid:
+            # 群聊，开启了独立会话
+            _, to_wxid = to_wxid.split("_")
+        
+        if not to_wxid:
+            logger.error("无法获取到 to_wxid。")
+            return
+        
+        for comp in message_chain.chain:
+            if isinstance(comp, Plain):
+                await self.client.post_text(to_wxid, comp.text)
+
        await super().send_by_session(session, message_chain)
    
    @override