xinyin025/LangBot
1
0
Fork 0
mirror of https://github.com/langbot-app/LangBot.git synced 2026-06-18 19:44:21 +00:00
Code Issues Packages Projects Releases Wiki Activity

优化收到小程序，公众号转账等消息时将其通过unknown传递出来，并修复voice字段写错问题

Browse Source
This commit is contained in:
Dong_master
2025-04-24 21:12:30 +08:00
parent 00cafb1188
commit 112f99d6d9
1 changed files with 18 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/platform/sources/gewechat.py
+18 -11
View File
@@ -151,8 +151,9 @@ class GewechatMessageConverter(adapter.MessageConverter):
) )
elif message["Data"]["MsgType"] == 49: elif message["Data"]["MsgType"] == 49:
# 支持微信聊天记录的消息类型，将 XML 内容转换为 MessageChain 传递 # 支持微信聊天记录的消息类型，将 XML 内容转换为 MessageChain 传递
content = message["Data"]["Content"]["string"]
try: try:
content = message["Data"]["Content"]["string"] # content = message["Data"]["Content"]["string"]
# 有三种可能的消息结构weid开头，私聊直接<?xml>和直接<msg> # 有三种可能的消息结构weid开头，私聊直接<?xml>和直接<msg>
if content.startswith('wxid'): if content.startswith('wxid'):
xml_list = content.split('\n')[2:] xml_list = content.split('\n')[2:]
@@ -192,24 +193,29 @@ class GewechatMessageConverter(adapter.MessageConverter):
return platform_message.MessageChain(message_list) return platform_message.MessageChain(message_list)
elif data_type == '51': elif data_type == '51':
return platform_message.MessageChain( return platform_message.MessageChain(
[platform_message.Plain(text=f'[视频号消息]')] [ # platform_message.Plain(text=f'[视频号消息]'),
platform_message.Unknown(text=content)]
) )
# print(content_data) # print(content_data)
elif data_type == '2000': elif data_type == '2000':
return platform_message.MessageChain( return platform_message.MessageChain(
[platform_message.Plain(text=f'[转账消息]')] [ # platform_message.Plain(text=f'[转账消息]'),
platform_message.Unknown(text=content)]
) )
elif data_type == '2001': elif data_type == '2001':
return platform_message.MessageChain( return platform_message.MessageChain(
[platform_message.Plain(text=f'[红包消息]')] [ # platform_message.Plain(text=f'[红包消息]'),
platform_message.Unknown(text=content)]
) )
elif data_type == '5': elif data_type == '5':
return platform_message.MessageChain( return platform_message.MessageChain(
[platform_message.Plain(text=f'[公众号消息]')] [ # platform_message.Plain(text=f'[公众号消息]'),
platform_message.Unknown(text=content)]
) )
elif data_type == '33' or data_type == '36': elif data_type == '33' or data_type == '36':
return platform_message.MessageChain( return platform_message.MessageChain(
[platform_message.Plain(text=f'[小程序消息]')] [ # platform_message.Plain(text=f'[小程序消息]'),
platform_message.Unknown(text=content)]
) )
# print(data_type.text) # print(data_type.text)
else: else:
@@ -219,8 +225,8 @@ class GewechatMessageConverter(adapter.MessageConverter):
content_bytes = content.encode('utf-8') content_bytes = content.encode('utf-8')
decoded_content = base64.b64decode(content_bytes) decoded_content = base64.b64decode(content_bytes)
return platform_message.MessageChain( return platform_message.MessageChain(
[platform_message.Unknown(content=decoded_content)] [platform_message.Unknown(text=decoded_content)]
) ) # 不对劲，十分有九分不对劲这里这么写不对吧
except Exception as e: except Exception as e:
return platform_message.MessageChain( return platform_message.MessageChain(
[platform_message.Plain(text=content)] [platform_message.Plain(text=content)]
@@ -228,7 +234,8 @@ class GewechatMessageConverter(adapter.MessageConverter):
except Exception as e: except Exception as e:
print(f"Error processing type 49 message: {str(e)}") print(f"Error processing type 49 message: {str(e)}")
return platform_message.MessageChain( return platform_message.MessageChain(
[platform_message.Plain(text="[无法解析的消息]")] [ # platform_message.Plain(text="[无法解析的消息]"),
platform_message.Unknown(text=content)]
) )
class GewechatEventConverter(adapter.EventConverter): class GewechatEventConverter(adapter.EventConverter):
@@ -402,7 +409,7 @@ class GeWeChatAdapter(adapter.MessagePlatformAdapter):
elif msg['type'] == 'WeChatForwardLink': elif msg['type'] == 'WeChatForwardLink':
self.bot.forward_url(app_id=self.config['app_id'], to_wxid=target_id, xml=msg['xml_data']) self.bot.forward_url(app_id=self.config['app_id'], to_wxid=target_id, xml=msg['xml_data'])
elif msg['type'] == 'voice': elif msg['type'] == 'voice':
self.bot.post_voice(app_id=self.config['app_id'], to_wxid=target_id, voice_url=msg['voice_url'],voice_duration=msg['length']) self.bot.post_voice(app_id=self.config['app_id'], to_wxid=target_id, voice_url=msg['url'],voice_duration=msg['length'])
@@ -455,7 +462,7 @@ class GeWeChatAdapter(adapter.MessagePlatformAdapter):
elif msg['type'] == 'WeChatForwardLink': elif msg['type'] == 'WeChatForwardLink':
self.bot.forward_url(app_id=self.config['app_id'], to_wxid=target_id, xml=msg['xml_data']) self.bot.forward_url(app_id=self.config['app_id'], to_wxid=target_id, xml=msg['xml_data'])
elif msg['type'] == 'voice': elif msg['type'] == 'voice':
self.bot.post_voice(app_id=self.config['app_id'], to_wxid=target_id, voice_url=msg['voice_url'], self.bot.post_voice(app_id=self.config['app_id'], to_wxid=target_id, voice_url=msg['url'],
voice_duration=msg['length']) voice_duration=msg['length'])
async def is_muted(self, group_id: int) -> bool: async def is_muted(self, group_id: int) -> bool: