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

如启用hot_reload，不处理1分钟前的历史消息避免重复提交

Browse Source
This commit is contained in:
lichengzhe
2023-03-21 22:12:06 +08:00
parent cfd423c991
commit 3d264207a8
1 changed files with 9 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
channel/wechat/wechat_channel.py
View File

@@ -14,6 +14,7 @@ from common.tmp_dir import TmpDir
from config import conf from config import conf
import requests import requests
import io import io
import time
thread_pool = ThreadPoolExecutor(max_workers=8) thread_pool = ThreadPoolExecutor(max_workers=8)
@@ -74,7 +75,11 @@ class WechatChannel(Channel):
from_user_id = msg['FromUserName'] from_user_id = msg['FromUserName']
to_user_id = msg['ToUserName'] # 接收人id to_user_id = msg['ToUserName'] # 接收人id
other_user_id = msg['User']['UserName'] # 对手方id other_user_id = msg['User']['UserName'] # 对手方id
create_time = msg['CreateTime'] # 消息时间
match_prefix = self.check_prefix(content, conf().get('single_chat_prefix')) match_prefix = self.check_prefix(content, conf().get('single_chat_prefix'))
if conf().get('hot_reload') == True and int(create_time) < int(time.time()) - 60: #跳过1分钟前的历史消息
logger.debug("[WX]history message skipped")
return
if "」\n- - - - - - - - - - - - - - -" in content: if "」\n- - - - - - - - - - - - - - -" in content:
logger.debug("[WX]reference query skipped") logger.debug("[WX]reference query skipped")
return return
@@ -108,6 +113,10 @@ class WechatChannel(Channel):
logger.debug("[WX]receive group msg: " + json.dumps(msg, ensure_ascii=False)) logger.debug("[WX]receive group msg: " + json.dumps(msg, ensure_ascii=False))
group_name = msg['User'].get('NickName', None) group_name = msg['User'].get('NickName', None)
group_id = msg['User'].get('UserName', None) group_id = msg['User'].get('UserName', None)
create_time = msg['CreateTime'] # 消息时间
if conf().get('hot_reload') == True and int(create_time) < int(time.time()) - 60: #跳过1分钟前的历史消息
logger.debug("[WX]history group message skipped")
return
if not group_name: if not group_name:
return "" return ""
origin_content = msg['Content'] origin_content = msg['Content']