kaiyuan/chatgpt-on-wechat
1
0
Fork 0
mirror of https://github.com/zhayujie/chatgpt-on-wechat.git synced 2026-06-02 00:57:41 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: wechatmp event and query timeout

Browse Source
This commit is contained in:
lanvent
2023-04-07 20:53:21 +08:00
parent 9c208ffa2c
commit 3a3affd3ec
2 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
channel/wechatmp/receive.py
View File

@@ -19,10 +19,10 @@ class WeChatMPMessage(ChatMessage):
self.from_user_id = xmlData.find('FromUserName').text self.from_user_id = xmlData.find('FromUserName').text
self.create_time = xmlData.find('CreateTime').text self.create_time = xmlData.find('CreateTime').text
self.msg_type = xmlData.find('MsgType').text self.msg_type = xmlData.find('MsgType').text
if self.msg_type != 'event': try:
self.msg_id = xmlData.find('MsgId').text self.msg_id = xmlData.find('MsgId').text
else: except:
self.msg_id = self.create_time self.msg_id = self.from_user_id+self.create_time
self.is_group = False self.is_group = False
# reply to other_user_id # reply to other_user_id
@@ -39,7 +39,7 @@ class WeChatMPMessage(ChatMessage):
self.pic_url = xmlData.find('PicUrl').text self.pic_url = xmlData.find('PicUrl').text
self.media_id = xmlData.find('MediaId').text self.media_id = xmlData.find('MediaId').text
elif self.msg_type == 'event': elif self.msg_type == 'event':
self.event = xmlData.find('Event').text self.content = xmlData.find('Event').text
else: # video, shortvideo, location, link else: # video, shortvideo, location, link
# not implemented # not implemented
pass pass

4
channel/wechatmp/wechatmp_channel.py
View File

@@ -150,7 +150,7 @@ class SubsribeAccountQuery():
channel.query2[cache_key] = False channel.query2[cache_key] = False
channel.query3[cache_key] = False channel.query3[cache_key] = False
# Request again # Request again
elif cache_key in channel.running: elif cache_key in channel.running and channel.query1.get(cache_key) == True and channel.query2.get(cache_key) == True and channel.query3.get(cache_key) == True:
channel.query1[cache_key] = False #To improve waiting experience, this can be set to True. channel.query1[cache_key] = False #To improve waiting experience, this can be set to True.
channel.query2[cache_key] = False #To improve waiting experience, this can be set to True. channel.query2[cache_key] = False #To improve waiting experience, this can be set to True.
channel.query3[cache_key] = False channel.query3[cache_key] = False
@@ -231,7 +231,7 @@ class SubsribeAccountQuery():
return replyPost return replyPost
elif wechat_msg.msg_type == 'event': elif wechat_msg.msg_type == 'event':
logger.info("[wechatmp] Event {} from {}".format(wechat_msg.Event, wechat_msg.from_user_id)) logger.info("[wechatmp] Event {} from {}".format(wechat_msg.content, wechat_msg.from_user_id))
trigger_prefix = conf().get('single_chat_prefix',[''])[0] trigger_prefix = conf().get('single_chat_prefix',[''])[0]
content = textwrap.dedent(f"""\ content = textwrap.dedent(f"""\
感谢您的关注！ 感谢您的关注！