Release v2.4.4

[Fix] 热重载之后不响应群内at

.gitignore

@@ -23,4 +23,5 @@ tips.py
 .venv
 bin/
 .vscode
-test_*
+test_*
+venv/

README.md

@@ -309,6 +309,6 @@ python3 main.py
 
 以及所有[贡献者](https://github.com/RockChinQ/QChatGPT/graphs/contributors)和其他为本项目提供支持的朋友们。
 
-<!-- ## 👍赞赏
+## 👍赞赏
 
-<img alt="赞赏码" src="res/mm_reward_qrcode_1672840549070.png" width="400" height="400"/> -->
+<img alt="赞赏码" src="res/mm_reward_qrcode_1672840549070.png" width="400" height="400"/>

config-template.py

@@ -241,6 +241,14 @@ process_message_timeout = 30
 # 回复消息时是否显示[GPT]前缀
 show_prefix = False
 
+# 回复前的强制延迟时间，降低机器人被腾讯风控概率
+# *此机制对命令和消息、私聊及群聊均生效
+# 每次处理时从以下的范围取一个随机秒数，
+# 当此次消息处理时间低于此秒数时，将会强制延迟至此秒数
+# 例如：[1.5, 3]，则每次处理时会随机取一个1.5-3秒的随机数，若处理时间低于此随机数，则强制延迟至此随机秒数
+# 若您不需要此功能，请将force_delay_range设置为[0, 0]
+force_delay_range = [1.5, 3]
+
 # 应用长消息处理策略的阈值
 # 当回复消息长度超过此值时，将使用长消息处理策略
 blob_message_threshold = 256

override-all.json

@@ -67,6 +67,10 @@
     "include_image_description": true,
     "process_message_timeout": 30,
     "show_prefix": false,
+    "force_delay_range": [
+        1.5,
+        3
+    ],
     "blob_message_threshold": 256,
     "blob_message_strategy": "forward",
     "wait_last_done": true,

pkg/qqbot/cmds/aamgr.py

@@ -260,8 +260,8 @@ def execute(context: Context) -> list:
 
     while True:
         try:
-            logging.debug('执行指令: {}'.format(path))
             node = __command_list__[path]
+            logging.debug('执行指令: {}'.format(path))
 
             # 检查权限
             if ctx.privilege < node['privilege']:

pkg/qqbot/manager.py

@@ -128,6 +128,7 @@ class QQBotManager:
                 self.bot_account_id = self.adapter.bot_account_id
         else:
             self.adapter = pkg.utils.context.get_qqbot_manager().adapter
+            self.bot_account_id = pkg.utils.context.get_qqbot_manager().bot_account_id
 
         pkg.utils.context.set_qqbot_manager(self)
 

pkg/qqbot/process.py

@@ -80,6 +80,10 @@ def process_message(launcher_type: str, launcher_id: int, text_message: str, mes
 
     text_message = text_message.strip()
 
+
+    # 为强制消息延迟计时
+    start_time = time.time()
+
     # 处理消息
     try:
 
@@ -168,4 +172,23 @@ def process_message(launcher_type: str, launcher_id: int, text_message: str, mes
     finally:
         pkg.openai.session.get_session(session_name).release_response_lock()
 
+    # 检查延迟时间
+    if config.force_delay_range[1] == 0:
+        delay_time = 0
+    else:
+        import random
+
+        # 从延迟范围中随机取一个值(浮点)
+        rdm = random.uniform(config.force_delay_range[0], config.force_delay_range[1])
+
+        spent = time.time() - start_time
+
+        # 如果花费时间小于延迟时间，则延迟
+        delay_time = rdm - spent if rdm - spent > 0 else 0
+
+    # 延迟
+    if delay_time > 0:
+        logging.info("[风控] 强制延迟{:.2f}秒(如需关闭，请到config.py修改force_delay_range字段)".format(delay_time))
+        time.sleep(delay_time)
+
     return MessageChain(reply)

pkg/qqbot/sources/nakuru.py

@@ -157,7 +157,6 @@ class NakuruProjectEventConverter(EventConverter):
             raise Exception("未支持转换的事件类型: " + str(event))
 
 
-
 class NakuruProjectAdapter(MessageSourceAdapter):
     """nakuru-project适配器"""
     bot: nakuru.CQHTTP
@@ -183,6 +182,9 @@ class NakuruProjectAdapter(MessageSourceAdapter):
             },
             timeout=5
         )
+        if resp.status_code == 403:
+            logging.error("go-cqhttp拒绝访问，请检查config.py中nakuru_config的token是否与go-cqhttp设置的access-token匹配")
+            raise Exception("go-cqhttp拒绝访问，请检查config.py中nakuru_config的token是否与go-cqhttp设置的access-token匹配")
         self.bot_account_id = int(resp.json()['data']['user_id'])
 
     def send_message(

requirements.txt

@@ -2,7 +2,7 @@ requests~=2.28.1
 openai~=0.27.6
 dulwich~=0.21.5
 colorlog~=6.6.0
-yiri-mirai~=0.2.6.1
+yiri-mirai~=0.2.7
 websockets
 urllib3~=1.26.10
 func_timeout~=4.3.5

tips-custom-template.py

@@ -27,7 +27,7 @@ replys_message = "[bot]err:请求超时"
 # 指令权限不足提示
 command_admin_message = "[bot]err:权限不足： "
 # 指令无效提示
-command_err_message = "[bot]err:指令执行出错："
+command_err_message = "[bot]err:指令不存在："
 
 # 会话重置提示
 command_reset_message = "[bot]:会话已重置"