feat: plugin dev mode

fix: 修复发言频率限制报错的问题

.gitignore

@@ -0,0 +1,3 @@
+__pycache__
+botpy.log
+.vscode

.vscode/settings.json

@@ -1,3 +0,0 @@
-{
-    "python.analysis.typeCheckingMode": "basic"
-}

CODE_OF_CONDUCT.md

@@ -0,0 +1,128 @@
+# Contributor Covenant Code of Conduct
+
+## Our Pledge
+
+We as members, contributors, and leaders pledge to make participation in our
+community a harassment-free experience for everyone, regardless of age, body
+size, visible or invisible disability, ethnicity, sex characteristics, gender
+identity and expression, level of experience, education, socio-economic status,
+nationality, personal appearance, race, religion, or sexual identity
+and orientation.
+
+We pledge to act and interact in ways that contribute to an open, welcoming,
+diverse, inclusive, and healthy community.
+
+## Our Standards
+
+Examples of behavior that contributes to a positive environment for our
+community include:
+
+* Demonstrating empathy and kindness toward other people
+* Being respectful of differing opinions, viewpoints, and experiences
+* Giving and gracefully accepting constructive feedback
+* Accepting responsibility and apologizing to those affected by our mistakes,
+  and learning from the experience
+* Focusing on what is best not just for us as individuals, but for the
+  overall community
+
+Examples of unacceptable behavior include:
+
+* The use of sexualized language or imagery, and sexual attention or
+  advances of any kind
+* Trolling, insulting or derogatory comments, and personal or political attacks
+* Public or private harassment
+* Publishing others' private information, such as a physical or email
+  address, without their explicit permission
+* Other conduct which could reasonably be considered inappropriate in a
+  professional setting
+
+## Enforcement Responsibilities
+
+Community leaders are responsible for clarifying and enforcing our standards of
+acceptable behavior and will take appropriate and fair corrective action in
+response to any behavior that they deem inappropriate, threatening, offensive,
+or harmful.
+
+Community leaders have the right and responsibility to remove, edit, or reject
+comments, commits, code, wiki edits, issues, and other contributions that are
+not aligned to this Code of Conduct, and will communicate reasons for moderation
+decisions when appropriate.
+
+## Scope
+
+This Code of Conduct applies within all community spaces, and also applies when
+an individual is officially representing the community in public spaces.
+Examples of representing our community include using an official e-mail address,
+posting via an official social media account, or acting as an appointed
+representative at an online or offline event.
+
+## Enforcement
+
+Instances of abusive, harassing, or otherwise unacceptable behavior may be
+reported to the community leaders responsible for enforcement at
+SoulterL@outlook.com.
+All complaints will be reviewed and investigated promptly and fairly.
+
+All community leaders are obligated to respect the privacy and security of the
+reporter of any incident.
+
+## Enforcement Guidelines
+
+Community leaders will follow these Community Impact Guidelines in determining
+the consequences for any action they deem in violation of this Code of Conduct:
+
+### 1. Correction
+
+**Community Impact**: Use of inappropriate language or other behavior deemed
+unprofessional or unwelcome in the community.
+
+**Consequence**: A private, written warning from community leaders, providing
+clarity around the nature of the violation and an explanation of why the
+behavior was inappropriate. A public apology may be requested.
+
+### 2. Warning
+
+**Community Impact**: A violation through a single incident or series
+of actions.
+
+**Consequence**: A warning with consequences for continued behavior. No
+interaction with the people involved, including unsolicited interaction with
+those enforcing the Code of Conduct, for a specified period of time. This
+includes avoiding interactions in community spaces as well as external channels
+like social media. Violating these terms may lead to a temporary or
+permanent ban.
+
+### 3. Temporary Ban
+
+**Community Impact**: A serious violation of community standards, including
+sustained inappropriate behavior.
+
+**Consequence**: A temporary ban from any sort of interaction or public
+communication with the community for a specified period of time. No public or
+private interaction with the people involved, including unsolicited interaction
+with those enforcing the Code of Conduct, is allowed during this period.
+Violating these terms may lead to a permanent ban.
+
+### 4. Permanent Ban
+
+**Community Impact**: Demonstrating a pattern of violation of community
+standards, including sustained inappropriate behavior,  harassment of an
+individual, or aggression toward or disparagement of classes of individuals.
+
+**Consequence**: A permanent ban from any sort of public interaction within
+the community.
+
+## Attribution
+
+This Code of Conduct is adapted from the [Contributor Covenant][homepage],
+version 2.0, available at
+https://www.contributor-covenant.org/version/2/0/code_of_conduct.html.
+
+Community Impact Guidelines were inspired by [Mozilla's code of conduct
+enforcement ladder](https://github.com/mozilla/diversity).
+
+[homepage]: https://www.contributor-covenant.org
+
+For answers to common questions about this code of conduct, see the FAQ at
+https://www.contributor-covenant.org/faq. Translations are available at
+https://www.contributor-covenant.org/translations.

README.md

@@ -1,25 +1,41 @@
-## ⭐体验
+<div align="center">
-扫码加入QQ频道
 
-![image](https://user-images.githubusercontent.com/37870767/217891261-7f2bbede-a70a-4e9b-9cdd-15dcb06f6629.png)
+<img src="https://socialify.git.ci/Soulter/QQChannelChatGPT/image?description=1&forks=1&issues=1&language=1&name=1&owner=1&pattern=Circuit%20Board&stargazers=1&theme=Light" alt="QQChannelChatGPT" width="600" height="300" />
 
+[![Language](https://img.shields.io/badge/language-python-green.svg?style=plastic)](https://www.python.org/)
+[![License](https://img.shields.io/badge/license-AGPL3-orange.svg?style=plastic)](https://github.com/Soulter/QQChannelChatGPT/blob/master/LICENSE)
+![Python](https://img.shields.io/badge/python-3.9+-blue)
  
+_✨在QQ和QQ频道上使用ChatGPT、NewBing等语言模型，稳定，一次部署，同时使用✨_
 
-**推荐Windows一键安装（版本更新更及时）！！**
+_✨教程：https://github.com/Soulter/QQChannelChatGPT/wiki ✨_
-**请前往Release下载最新版本**
  
-**详细部署教程链接**https://soulter.top/posts/qpdg.html
+_✨插件开发教程：https://github.com/Soulter/QQChannelChatGPT/wiki/%E5%9B%9B%E3%80%81%E5%BC%80%E5%8F%91%E6%8F%92%E4%BB%B6 ✨_
 
-**详细部署教程链接**https://soulter.top/posts/qpdg.html
+_✨欢迎体验😊（频道名: GPT机器人 | 频道号: x42d56aki2) | QQ群号：322154837）✨_
-
-**详细部署教程链接**https://soulter.top/posts/qpdg.html
-
-有任何问题请加频道反馈。
 
+<!-- <img src="https://user-images.githubusercontent.com/37870767/230417115-9dd3c9d5-6b6b-4928-8fe3-82f559208aab.JPG" width="300"></img> -->
 
+</div>
 
 ## ⭐功能：
 
+近期新功能：
+- 支持插件！https://github.com/Soulter/QQChannelChatGPT/wiki/%E5%9B%9B%E3%80%81%E5%BC%80%E5%8F%91%E6%8F%92%E4%BB%B6
+- 支持一键切换语言模型（使用/bing /revgpt /gpt分别可以切换newbing、逆向ChatGPT、官方ChatGPT模型）
+- 热更新
+- 接入QQ，支持在QQ上和QQ频道上同时聊天！https://github.com/Soulter/QQChannelChatGPT/issues/82
+- 更强大的Windows启动器，环境配置自动搞定。链接：https://github.com/Soulter/QQChatGPTLauncher/releases/latest
+
+支持的AI语言模型（请在`configs/config.yaml`下配置）：
+- 逆向ChatGPT库
+- 官方ChatGPT AI
+- 文心一言（即将支持）
+- NewBing
+- Bard （即将支持）
+
+部署此项目的教程链接：https://github.com/Soulter/QQChannelChatGPT/wiki
+
 ### 基本功能
 <details> 
  <summary>✅ 回复符合上下文</summary>
@@ -61,7 +77,7 @@
  </details>
 
 <details> 
- <summary>✅ 支持指令控制</summary> 
+ <summary>✅ 支持多种指令控制</summary> 
   
    -  详见下方`指令功能`
   
@@ -77,38 +93,219 @@
 </details>
 
 > 关于token：token就相当于是AI中的单词数（但是不等于单词数），`text-davinci-003`模型中最大可以支持`4097`个token。在发送信息时，这个机器人会将用户的历史聊天记录打包发送给ChatGPT，因此，`token`也会相应的累加，为了保证聊天的上下文的逻辑性，就有了缓存token。
+
+### 🛠️ 插件支持
+
+本项目支持接入插件。
+
+插件开发教程：https://github.com/Soulter/QQChannelChatGPT/wiki/%E5%9B%9B%E3%80%81%E5%BC%80%E5%8F%91%E6%8F%92%E4%BB%B6
+
+部分好用的插件：
+
+`HuggingChat`: https://github.com/Soulter/HuggingChatForQQBot
+
+
 ### 指令功能
-需要先`@`机器人之后再输入指令
+
+#### OpenAI官方API
+在频道内需要先`@`机器人之后再输入指令；在QQ中暂时需要在消息前加上`ai `，不需要@
 - `/reset`重置prompt
 - `/his`查看历史记录（每个用户都有独立的会话）
 - `/his [页码数]`查看不同页码的历史记录。例如`/his 2`查看第2页
 - `/token`查看当前缓存的总token数
 - `/count` 查看统计
 - `/status` 查看chatGPT的配置
+- `/help` 查看帮助
+- `/key` 动态添加key
+- `/set` 人格设置面板
+- `/keyword nihao 你好` 设置关键词回复。nihao->你好
+- `/bing` 切换为bing
+- `/revgpt` 切换为ChatGPT逆向库
+- `/画` 画画
+
+#### Bing语言模型
+- `/reset`重置prompt
+- `/gpt` 切换为OpenAI官方API
+- `/revgpt` 切换为ChatGPT逆向库
+
+#### 逆向ChatGPT库语言模型
+- `/gpt` 切换为OpenAI官方API
+- `/bing` 切换为bing
+
+* 切换模型指令支持临时回复。如`/bing 你好`将会临时使用一次bing模型
 
 ## 📰使用方法：
 
+**详细部署教程链接**https://soulter.top/posts/qpdg.html
+
+**Windows用户推荐Windows一键安装，请前往Release下载最新版本（Beta）**
+有报错请先看issue，解决不了再在频道内反馈。
+
 ### 安装第三方库
 
-使用Python的pip工具安装
-- `qq-botpy` （QQ频道官方Python SDK）
-- `openai` (OpenAI 库)
 ```shell
 pip install -r requirements.txt
 ```
-> ⚠注意，由于qq-botpy需要运行在`Python 3.8+`的版本上，因此本项目也需要在此之上运行
+> ⚠Python版本应>=3.9
+
 
 ### 配置
 
-- 获得 OpenAI的key [OpenAI](https://beta.openai.com/)
+**详细部署教程链接**https://github.com/Soulter/QQChannelChatGPT/wiki
-- 获得 QQ开放平台下QQ频道机器人的token和appid [QQ开放平台](https://q.qq.com/)，一个QQ频道机器人（很容易创建~）
-- 在configs/config.yaml下进行配置
 
 ### 启动
 - 启动main.py
 
 
-## DEMO
+## 感谢
-![1.jpg](screenshots/1.jpg)
+本项目使用了一下项目:
-![3.jpg](screenshots/3.jpg)
+
-![2.jpg](screenshots/2.jpg)
+[ChatGPT by acheong08](https://github.com/acheong08/ChatGPT)
+
+[EdgeGPT by acheong08](https://github.com/acheong08/EdgeGPT)
+
+[go-cqhttp by Mrs4s](https://github.com/Mrs4s/go-cqhttp)
+
+[nakuru-project by Lxns-Network](https://github.com/Lxns-Network/nakuru-project)
+
+
+## ⚙配置文件说明：
+```yaml
+# 如果你不知道怎么部署，请查看https://github.com/Soulter/QQChannelChatGPT/wiki
+# 不一定需要key了，如果你没有key但有openAI账号或者必应账号，可以考虑使用下面的逆向库
+
+
+###############平台设置#################
+
+# QQ频道机器人
+# QQ开放平台的appid和令牌
+# q.qq.com
+# enable为true则启用，false则不启用
+qqbot:
+  enable: true
+  appid: 
+  token: 
+
+# QQ机器人
+# enable为true则启用，false则不启用
+# 需要安装GO-CQHTTP配合使用。
+# 文档：https://docs.go-cqhttp.org/
+# 请将go-cqhttp的配置文件的sever部分粘贴为以下内容，否则无法使用
+# 请先启动go-cqhttp再启动本程序
+# 
+# servers:
+#   - http:
+#       host: 127.0.0.1
+#       version: 0
+#       port: 5700
+#       timeout: 5
+#   - ws:
+#       address: 127.0.0.1:6700
+#       middlewares:
+#         <<: *default
+gocqbot:
+  enable: false
+
+# 设置是否一个人一个会话
+uniqueSessionMode: false
+# QChannelBot 的版本，请勿修改此字段，否则可能产生一些bug
+version: 3.0
+# [Beta] 转储历史记录时间间隔(分钟)
+dump_history_interval: 10
+# 一个用户只能在time秒内发送count条消息
+limit:
+  time: 60
+  count: 5
+# 公告
+notice: "此机器人由Github项目QQChannelChatGPT驱动。"
+# 是否打开私信功能
+# 设置为true则频道成员可以私聊机器人。
+# 设置为false则频道成员不能私聊机器人。
+direct_message_mode: true
+
+# 系统代理
+# http_proxy: http://localhost:7890
+# https_proxy: http://localhost:7890
+
+# 自定义回复前缀，如[Rev]或其他，务必加引号以防止不必要的bug。
+reply_prefix:
+  openai_official: "[GPT]"
+  rev_chatgpt: "[Rev]"
+  rev_edgegpt: "[RevBing]"
+
+# 百度内容审核服务
+# 新用户免费5万次调用。https://cloud.baidu.com/doc/ANTIPORN/index.html
+baidu_aip:
+  enable: false
+  app_id: 
+  api_key: 
+  secret_key: 
+
+
+
+
+###############语言模型设置#################
+
+
+# OpenAI官方API
+# 注意：已支持多key自动切换，方法：
+# key:
+#   - sk-xxxxxx
+#   - sk-xxxxxx
+# 在下方非注释的地方使用以上格式
+# 关于api_base：可以使用一些云函数（如腾讯、阿里）来避免国内被墙的问题。
+# 详见：
+# https://github.com/Ice-Hazymoon/openai-scf-proxy
+# https://github.com/Soulter/QQChannelChatGPT/issues/42
+# 设置为none则表示使用官方默认api地址
+openai:
+  key: 
+    - 
+  api_base: none
+  # 这里是GPT配置，语言模型默认使用gpt-3.5-turbo
+  chatGPTConfigs:
+    model: gpt-3.5-turbo
+    max_tokens: 3000
+    temperature: 0.9
+    top_p: 1
+    frequency_penalty: 0
+    presence_penalty: 0
+    
+  total_tokens_limit: 5000
+
+# 逆向文心一言【暂时不可用，请勿使用】
+rev_ernie:
+  enable: false
+
+# 逆向New Bing
+# 需要在项目根目录下创建cookies.json并粘贴cookies进去。
+# 详见：https://soulter.top/posts/qpdg.html
+rev_edgegpt:
+  enable: false
+
+# 逆向ChatGPT库
+# https://github.com/acheong08/ChatGPT
+# 优点：免费（无免费额度限制）；
+# 缺点：速度相对慢。OpenAI 速率限制：免费帐户每小时 50 个请求。您可以通过多帐户循环来绕过它
+# enable设置为true后，将会停止使用上面正常的官方API调用而使用本逆向项目
+#
+# 多账户可以保证每个请求都能得到及时的回复。
+# 关于account的格式
+# account:
+#   - email: 第1个账户
+#     password: 第1个账户密码
+#   - email: 第2个账户
+#     password: 第2个账户密码
+#   - ....
+# 支持使用access_token登录
+# 例：
+# - session_token: xxxxx
+# - access_token: xxxx
+# 请严格按照上面这个格式填写。
+# 逆向ChatGPT库的email-password登录方式不工作，建议使用access_token登录
+# 获取access_token的方法，详见：https://soulter.top/posts/qpdg.html
+rev_ChatGPT:
+  enable: false
+  account:
+    - access_token: 
+```

addons/baidu_aip_judge.py

@@ -0,0 +1,26 @@
+from aip import AipContentCensor
+
+class BaiduJudge:
+    def __init__(self, baidu_configs) -> None:
+        if 'app_id' in baidu_configs and 'api_key' in baidu_configs and 'secret_key' in baidu_configs:
+            self.app_id = str(baidu_configs['app_id'])
+            self.api_key = baidu_configs['api_key']
+            self.secret_key = baidu_configs['secret_key']
+            self.client = AipContentCensor(self.app_id, self.api_key, self.secret_key)
+        else:
+            raise ValueError("Baidu configs error! 请填写百度内容审核服务相关配置！")
+    def judge(self, text):
+        res = self.client.textCensorUserDefined(text)
+        if 'conclusionType' not in res:
+            return False, "百度审核服务未知错误"
+        if res['conclusionType'] == 1:
+            return True, "合规"
+        else:
+            if 'data' not in res:
+                return False, "百度审核服务未知错误"
+            count = len(res['data'])
+            info = f"百度审核服务发现 {count} 处违规：\n"
+            for i in res['data']:
+                info += f"{i['msg']}；\n"
+            info += "\n判断结果："+res['conclusion']
+            return False, info

addons/plugins/helloworld/README.md

@@ -0,0 +1,5 @@
+# helloworld
+
+QQChannelChatGPT项目的测试插件
+
+A test plugin for QQChannelChatGPT plugin feature

addons/plugins/helloworld/helloworld.py

@@ -0,0 +1,65 @@
+from nakuru.entities.components import *
+from nakuru import (
+    GroupMessage,
+    FriendMessage
+)
+from botpy.message import Message, DirectMessage
+
+class HelloWorldPlugin:
+    """
+    初始化函数, 可以选择直接pass
+    """
+    def __init__(self) -> None:
+        print("这是HelloWorld测试插件, 发送 helloworld 即可触发此插件。")
+
+    """
+    入口函数，机器人会调用此函数。
+    参数规范: message: 消息文本; role: 身份; platform: 消息平台; message_obj: 消息对象
+    参数详情: role为admin或者member; platform为qqchan或者gocq; message_obj为nakuru的GroupMessage对象或者FriendMessage对象或者频道的Message, DirectMessage对象。
+    返回规范: bool: 是否hit到此插件(所有的消息均会调用每一个载入的插件, 如果没有hit到, 则应返回False)
+             Tuple: None或者长度为3的元组。当没有hit到时, 返回None. hit到时, 第1个参数为指令是否调用成功, 第2个参数为返回的消息文本或者gocq的消息链列表, 第3个参数为指令名称
+    例子：做一个名为"yuanshen"的插件；当接收到消息为“原神 可莉”, 如果不想要处理此消息，则返回False, None；如果想要处理，但是执行失败了，返回True, tuple([False, "请求失败啦~", "yuanshen"])
+          ；执行成功了，返回True, tuple([True, "结果文本", "yuanshen"])
+    """
+    def run(self, message: str, role: str, platform: str, message_obj):
+
+        if platform == "gocq":
+            """
+            QQ平台指令处理逻辑
+            """
+            img_url = "https://gchat.qpic.cn/gchatpic_new/905617992/720871955-2246763964-C6EE1A52CC668EC982453065C4FA8747/0?term=2&is_origin=0"
+            if message == "helloworld":
+                return True, tuple([True, [Plain("Hello World!!"), Image.fromURL(url=img_url)], "helloworld"])
+            else:
+                return False, None
+        elif platform == "qqchan":
+            """
+            频道处理逻辑(频道暂时只支持回复字符串类型的信息，返回的信息都会被转成字符串，如果不想处理某一个平台的信息，直接返回False, None就行)
+            """
+            if message == "helloworld":
+                return True, tuple([True, "Hello World!!", "helloworld"])
+            else:
+                return False, None
+    """
+    帮助函数，当用户输入 plugin v 插件名称 时，会调用此函数，返回帮助信息
+    返回参数要求(必填)：dict{
+        "name": str, # 插件名称
+        "desc": str, # 插件简短描述
+        "help": str, # 插件帮助信息
+        "version": str, # 插件版本
+        "author": str, # 插件作者
+    }
+    """        
+    def info(self):
+        return {
+            "name": "helloworld",
+            "desc": "测试插件",
+            "help": "测试插件, 回复helloworld即可触发",
+            "version": "v1.0.1 beta",
+            "author": "Soulter"
+        }
+
+
+        # 热知识：检测消息开头指令，使用以下方法
+        # if message.startswith("原神"):
+        #     pass

botpy.log

@@ -1,323 +0,0 @@
-2022-12-08 14:29:09,486	[INFO]	(client.py:159)_bot_login	[botpy] 登录机器人账号中...
-2022-12-08 14:29:10,173	[INFO]	(client.py:178)_bot_init	[botpy] 程序启动...
-2022-12-08 14:29:10,174	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 14:29:10,175	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 14:29:10,175	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 14:29:10,335	[INFO]	(gateway.py:136)ws_identify	[botpy] 鉴权中...
-2022-12-08 14:29:10,460	[INFO]	(gateway.py:80)on_message	[botpy] 机器人「SoGPT-测试中」启动成功！
-2022-12-08 14:29:10,461	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 16:17:18,117	[INFO]	(client.py:159)_bot_login	[botpy] 登录机器人账号中...
-2022-12-08 16:17:18,355	[ERROR]	(http.py:73)_handle_response	[botpy] 接口请求异常，请求连接: https://api.sgroup.qq.com/users/@me, 错误代码: 401, 返回内容: {'message': 'wrong bot token', 'code': 11242}, trace_id:829d8c60d296a3edcfac3d776dbd8b47
-2022-12-08 16:18:59,759	[INFO]	(client.py:159)_bot_login	[botpy] 登录机器人账号中...
-2022-12-08 16:19:00,266	[INFO]	(client.py:178)_bot_init	[botpy] 程序启动...
-2022-12-08 16:19:00,267	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 16:19:00,268	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 16:19:00,268	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 16:19:00,412	[INFO]	(gateway.py:136)ws_identify	[botpy] 鉴权中...
-2022-12-08 16:19:00,522	[INFO]	(gateway.py:80)on_message	[botpy] 机器人「SoGPT-测试中」启动成功！
-2022-12-08 16:19:00,522	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 16:20:14,446	[INFO]	(client.py:159)_bot_login	[botpy] 登录机器人账号中...
-2022-12-08 16:20:15,035	[INFO]	(client.py:178)_bot_init	[botpy] 程序启动...
-2022-12-08 16:20:15,036	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 16:20:15,037	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 16:20:15,037	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 16:20:15,232	[INFO]	(gateway.py:136)ws_identify	[botpy] 鉴权中...
-2022-12-08 16:20:15,320	[INFO]	(gateway.py:80)on_message	[botpy] 机器人「SoGPT-测试中」启动成功！
-2022-12-08 16:20:15,321	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 16:42:06,957	[INFO]	(client.py:159)_bot_login	[botpy] 登录机器人账号中...
-2022-12-08 16:42:07,468	[INFO]	(client.py:178)_bot_init	[botpy] 程序启动...
-2022-12-08 16:42:07,469	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 16:42:07,469	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 16:42:07,470	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 16:42:07,672	[INFO]	(gateway.py:136)ws_identify	[botpy] 鉴权中...
-2022-12-08 16:42:07,862	[INFO]	(gateway.py:80)on_message	[botpy] 机器人「SoGPT-测试中」启动成功！
-2022-12-08 16:42:07,863	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 16:45:44,758	[INFO]	(client.py:159)_bot_login	[botpy] 登录机器人账号中...
-2022-12-08 16:45:45,439	[INFO]	(client.py:178)_bot_init	[botpy] 程序启动...
-2022-12-08 16:45:45,440	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 16:45:45,441	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 16:45:45,441	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 16:45:45,751	[INFO]	(gateway.py:136)ws_identify	[botpy] 鉴权中...
-2022-12-08 16:45:45,858	[INFO]	(gateway.py:80)on_message	[botpy] 机器人「SoGPT-测试中」启动成功！
-2022-12-08 16:45:45,859	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 16:47:16,567	[INFO]	(client.py:159)_bot_login	[botpy] 登录机器人账号中...
-2022-12-08 16:47:17,008	[INFO]	(client.py:178)_bot_init	[botpy] 程序启动...
-2022-12-08 16:47:17,009	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 16:47:17,009	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 16:47:17,010	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 16:47:17,187	[INFO]	(gateway.py:136)ws_identify	[botpy] 鉴权中...
-2022-12-08 16:47:17,284	[INFO]	(gateway.py:80)on_message	[botpy] 机器人「SoGPT-测试中」启动成功！
-2022-12-08 16:47:17,285	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 16:48:39,358	[INFO]	(client.py:159)_bot_login	[botpy] 登录机器人账号中...
-2022-12-08 16:48:45,366	[WARNING]	(http.py:188)request	请求超时，请求连接: https://api.sgroup.qq.com/gateway/bot
-2022-12-08 16:48:53,301	[INFO]	(client.py:159)_bot_login	[botpy] 登录机器人账号中...
-2022-12-08 16:48:53,789	[INFO]	(client.py:178)_bot_init	[botpy] 程序启动...
-2022-12-08 16:48:53,790	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 16:48:53,791	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 16:48:53,791	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 16:48:53,969	[INFO]	(gateway.py:136)ws_identify	[botpy] 鉴权中...
-2022-12-08 16:48:54,062	[INFO]	(gateway.py:80)on_message	[botpy] 机器人「SoGPT-测试中」启动成功！
-2022-12-08 16:48:54,063	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 16:49:26,466	[ERROR]	(http.py:73)_handle_response	[botpy] 接口请求异常，请求连接: https://api.sgroup.qq.com/channels/7150805/messages, 错误代码: 403, 返回内容: {'code': 304003, 'message': 'url not allowed'}, trace_id:b201dd7b37649dcf47b82d54c58bc5dd
-2022-12-08 16:51:59,155	[INFO]	(client.py:159)_bot_login	[botpy] 登录机器人账号中...
-2022-12-08 16:51:59,728	[INFO]	(client.py:178)_bot_init	[botpy] 程序启动...
-2022-12-08 16:51:59,729	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 16:51:59,730	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 16:51:59,730	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 16:51:59,887	[INFO]	(gateway.py:136)ws_identify	[botpy] 鉴权中...
-2022-12-08 16:52:00,022	[INFO]	(gateway.py:80)on_message	[botpy] 机器人「SoGPT-测试中」启动成功！
-2022-12-08 16:52:00,023	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 16:52:28,760	[ERROR]	(http.py:73)_handle_response	[botpy] 接口请求异常，请求连接: https://api.sgroup.qq.com/channels/7150805/messages, 错误代码: 403, 返回内容: {'code': 304003, 'message': 'url not allowed'}, trace_id:e62b072c9f0184f6bf7dd03a00fc0ef3
-2022-12-08 16:53:53,370	[INFO]	(client.py:159)_bot_login	[botpy] 登录机器人账号中...
-2022-12-08 16:53:53,890	[INFO]	(client.py:178)_bot_init	[botpy] 程序启动...
-2022-12-08 16:53:53,891	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 16:53:53,892	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 16:53:53,892	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 16:53:54,101	[INFO]	(gateway.py:136)ws_identify	[botpy] 鉴权中...
-2022-12-08 16:53:54,194	[INFO]	(gateway.py:80)on_message	[botpy] 机器人「SoGPT-测试中」启动成功！
-2022-12-08 16:53:54,195	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 16:54:26,287	[ERROR]	(http.py:73)_handle_response	[botpy] 接口请求异常，请求连接: https://api.sgroup.qq.com/channels/7150805/messages, 错误代码: 501, 返回内容: None, trace_id:None
-2022-12-08 16:55:01,062	[INFO]	(client.py:159)_bot_login	[botpy] 登录机器人账号中...
-2022-12-08 16:55:01,601	[INFO]	(client.py:178)_bot_init	[botpy] 程序启动...
-2022-12-08 16:55:01,601	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 16:55:01,602	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 16:55:01,603	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 16:55:01,742	[INFO]	(gateway.py:136)ws_identify	[botpy] 鉴权中...
-2022-12-08 16:55:01,816	[INFO]	(gateway.py:80)on_message	[botpy] 机器人「SoGPT-测试中」启动成功！
-2022-12-08 16:55:01,817	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 17:00:29,939	[INFO]	(client.py:159)_bot_login	[botpy] 登录机器人账号中...
-2022-12-08 17:00:30,583	[INFO]	(client.py:178)_bot_init	[botpy] 程序启动...
-2022-12-08 17:00:30,584	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 17:00:30,585	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 17:00:30,585	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 17:00:30,839	[INFO]	(gateway.py:136)ws_identify	[botpy] 鉴权中...
-2022-12-08 17:00:30,943	[INFO]	(gateway.py:80)on_message	[botpy] 机器人「SoGPT-测试中」启动成功！
-2022-12-08 17:00:30,944	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 17:00:53,548	[ERROR]	(http.py:73)_handle_response	[botpy] 接口请求异常，请求连接: https://api.sgroup.qq.com/channels/7150658/messages, 错误代码: 403, 返回内容: {'code': 304003, 'message': 'url not allowed'}, trace_id:2ea547d78364cea60583ed450e589a17
-2022-12-08 17:10:31,405	[INFO]	(client.py:159)_bot_login	[botpy] 登录机器人账号中...
-2022-12-08 17:10:32,081	[INFO]	(client.py:178)_bot_init	[botpy] 程序启动...
-2022-12-08 17:10:32,082	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 17:10:32,083	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 17:10:32,083	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 17:10:32,342	[INFO]	(gateway.py:136)ws_identify	[botpy] 鉴权中...
-2022-12-08 17:10:32,449	[INFO]	(gateway.py:80)on_message	[botpy] 机器人「SoGPT-测试中」启动成功！
-2022-12-08 17:10:32,450	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 17:13:47,495	[INFO]	(client.py:159)_bot_login	[botpy] 登录机器人账号中...
-2022-12-08 17:13:47,993	[INFO]	(client.py:178)_bot_init	[botpy] 程序启动...
-2022-12-08 17:13:47,994	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 17:13:47,995	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 17:13:47,995	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 17:13:48,198	[INFO]	(gateway.py:136)ws_identify	[botpy] 鉴权中...
-2022-12-08 17:13:48,300	[INFO]	(gateway.py:80)on_message	[botpy] 机器人「SoGPT-测试中」启动成功！
-2022-12-08 17:13:48,302	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 17:16:31,326	[ERROR]	(http.py:73)_handle_response	[botpy] 接口请求异常，请求连接: https://api.sgroup.qq.com/channels/7150658/messages, 错误代码: 501, 返回内容: None, trace_id:None
-2022-12-08 17:22:03,924	[INFO]	(client.py:159)_bot_login	[botpy] 登录机器人账号中...
-2022-12-08 17:22:04,671	[INFO]	(client.py:178)_bot_init	[botpy] 程序启动...
-2022-12-08 17:22:04,672	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 17:22:04,673	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 17:22:04,673	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 17:22:04,856	[INFO]	(gateway.py:136)ws_identify	[botpy] 鉴权中...
-2022-12-08 17:22:04,958	[INFO]	(gateway.py:80)on_message	[botpy] 机器人「SoGPT-测试中」启动成功！
-2022-12-08 17:22:04,959	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 17:52:04,868	[INFO]	(gateway.py:54)on_closed	[botpy] 关闭, 返回码: 4009, 返回信息: Session timed out
-2022-12-08 17:52:09,874	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 17:52:09,876	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 17:52:09,877	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 17:52:10,104	[INFO]	(gateway.py:169)ws_resume	[botpy] 重连启动...
-2022-12-08 17:52:10,170	[INFO]	(gateway.py:85)on_message	[botpy] 机器人重连成功! 
-2022-12-08 17:52:10,171	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 18:00:00,757	[INFO]	(client.py:159)_bot_login	[botpy] 登录机器人账号中...
-2022-12-08 18:00:01,443	[INFO]	(client.py:178)_bot_init	[botpy] 程序启动...
-2022-12-08 18:00:01,443	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 18:00:01,444	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 18:00:01,445	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 18:00:01,602	[INFO]	(gateway.py:136)ws_identify	[botpy] 鉴权中...
-2022-12-08 18:00:01,823	[INFO]	(gateway.py:80)on_message	[botpy] 机器人「SoGPT-测试中」启动成功！
-2022-12-08 18:00:01,824	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 18:03:13,211	[INFO]	(client.py:159)_bot_login	[botpy] 登录机器人账号中...
-2022-12-08 18:03:14,082	[INFO]	(client.py:178)_bot_init	[botpy] 程序启动...
-2022-12-08 18:03:14,084	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 18:03:14,084	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 18:03:14,085	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 18:03:14,289	[INFO]	(gateway.py:136)ws_identify	[botpy] 鉴权中...
-2022-12-08 18:03:14,498	[INFO]	(gateway.py:80)on_message	[botpy] 机器人「SoGPT-测试中」启动成功！
-2022-12-08 18:03:14,499	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 18:16:29,246	[INFO]	(client.py:159)_bot_login	[botpy] 登录机器人账号中...
-2022-12-08 18:16:30,054	[INFO]	(client.py:178)_bot_init	[botpy] 程序启动...
-2022-12-08 18:16:30,055	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 18:16:30,056	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 18:16:30,056	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 18:16:30,293	[INFO]	(gateway.py:136)ws_identify	[botpy] 鉴权中...
-2022-12-08 18:16:30,424	[INFO]	(gateway.py:80)on_message	[botpy] 机器人「SoGPT-测试中」启动成功！
-2022-12-08 18:16:30,424	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 18:16:41,898	[ERROR]	(http.py:73)_handle_response	[botpy] 接口请求异常，请求连接: https://api.sgroup.qq.com/channels/7150658/messages, 错误代码: 403, 返回内容: {'code': 304003, 'message': 'url not allowed'}, trace_id:3cc9fc95ac27cbbc1f1667f1aa11bf8d
-2022-12-08 18:18:16,615	[INFO]	(client.py:159)_bot_login	[botpy] 登录机器人账号中...
-2022-12-08 18:18:17,399	[INFO]	(client.py:178)_bot_init	[botpy] 程序启动...
-2022-12-08 18:18:17,400	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 18:18:17,400	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 18:18:17,401	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 18:18:17,606	[INFO]	(gateway.py:136)ws_identify	[botpy] 鉴权中...
-2022-12-08 18:18:17,731	[INFO]	(gateway.py:80)on_message	[botpy] 机器人「SoGPT-测试中」启动成功！
-2022-12-08 18:18:17,732	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 18:19:07,357	[INFO]	(client.py:159)_bot_login	[botpy] 登录机器人账号中...
-2022-12-08 18:19:07,941	[INFO]	(client.py:178)_bot_init	[botpy] 程序启动...
-2022-12-08 18:19:07,942	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 18:19:07,942	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 18:19:07,943	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 18:19:08,247	[INFO]	(gateway.py:136)ws_identify	[botpy] 鉴权中...
-2022-12-08 18:19:08,335	[INFO]	(gateway.py:80)on_message	[botpy] 机器人「SoGPT-测试中」启动成功！
-2022-12-08 18:19:08,336	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 18:20:46,416	[INFO]	(client.py:159)_bot_login	[botpy] 登录机器人账号中...
-2022-12-08 18:20:47,023	[INFO]	(client.py:178)_bot_init	[botpy] 程序启动...
-2022-12-08 18:20:47,023	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 18:20:47,024	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 18:20:47,025	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 18:20:47,475	[INFO]	(gateway.py:136)ws_identify	[botpy] 鉴权中...
-2022-12-08 18:20:47,640	[INFO]	(gateway.py:80)on_message	[botpy] 机器人「SoGPT-测试中」启动成功！
-2022-12-08 18:20:47,641	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 18:21:24,437	[INFO]	(client.py:159)_bot_login	[botpy] 登录机器人账号中...
-2022-12-08 18:21:24,991	[INFO]	(client.py:178)_bot_init	[botpy] 程序启动...
-2022-12-08 18:21:24,992	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 18:21:24,993	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 18:21:24,993	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 18:21:25,165	[INFO]	(gateway.py:136)ws_identify	[botpy] 鉴权中...
-2022-12-08 18:21:25,265	[INFO]	(gateway.py:80)on_message	[botpy] 机器人「SoGPT-测试中」启动成功！
-2022-12-08 18:21:25,266	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 18:24:18,469	[INFO]	(client.py:159)_bot_login	[botpy] 登录机器人账号中...
-2022-12-08 18:24:19,076	[INFO]	(client.py:178)_bot_init	[botpy] 程序启动...
-2022-12-08 18:24:19,077	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 18:24:19,077	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 18:24:19,078	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 18:24:19,252	[INFO]	(gateway.py:136)ws_identify	[botpy] 鉴权中...
-2022-12-08 18:24:19,339	[INFO]	(gateway.py:80)on_message	[botpy] 机器人「SoGPT-测试中」启动成功！
-2022-12-08 18:24:19,341	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 18:27:13,898	[INFO]	(client.py:159)_bot_login	[botpy] 登录机器人账号中...
-2022-12-08 18:27:14,553	[INFO]	(client.py:178)_bot_init	[botpy] 程序启动...
-2022-12-08 18:27:14,554	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 18:27:14,554	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 18:27:14,555	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 18:27:14,747	[INFO]	(gateway.py:136)ws_identify	[botpy] 鉴权中...
-2022-12-08 18:27:14,850	[INFO]	(gateway.py:80)on_message	[botpy] 机器人「SoGPT-测试中」启动成功！
-2022-12-08 18:27:14,851	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 18:30:47,647	[INFO]	(client.py:159)_bot_login	[botpy] 登录机器人账号中...
-2022-12-08 18:30:48,327	[INFO]	(client.py:178)_bot_init	[botpy] 程序启动...
-2022-12-08 18:30:48,328	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 18:30:48,329	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 18:30:48,330	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 18:30:48,736	[INFO]	(gateway.py:136)ws_identify	[botpy] 鉴权中...
-2022-12-08 18:30:48,873	[INFO]	(gateway.py:80)on_message	[botpy] 机器人「SoGPT-测试中」启动成功！
-2022-12-08 18:30:48,874	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 18:31:57,250	[INFO]	(client.py:159)_bot_login	[botpy] 登录机器人账号中...
-2022-12-08 18:31:57,955	[INFO]	(client.py:178)_bot_init	[botpy] 程序启动...
-2022-12-08 18:31:57,956	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 18:31:57,957	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 18:31:57,957	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 18:31:58,165	[INFO]	(gateway.py:136)ws_identify	[botpy] 鉴权中...
-2022-12-08 18:31:58,269	[INFO]	(gateway.py:80)on_message	[botpy] 机器人「SoGPT-测试中」启动成功！
-2022-12-08 18:31:58,270	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 19:01:58,099	[INFO]	(gateway.py:54)on_closed	[botpy] 关闭, 返回码: 4009, 返回信息: Session timed out
-2022-12-08 19:02:03,110	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 19:02:03,111	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 19:02:03,111	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 19:02:03,314	[INFO]	(gateway.py:169)ws_resume	[botpy] 重连启动...
-2022-12-08 19:02:03,381	[INFO]	(gateway.py:85)on_message	[botpy] 机器人重连成功! 
-2022-12-08 19:02:03,382	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 19:32:03,274	[INFO]	(gateway.py:54)on_closed	[botpy] 关闭, 返回码: 4009, 返回信息: Session timed out
-2022-12-08 19:32:08,271	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 19:32:08,272	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 19:32:08,272	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 19:32:08,534	[INFO]	(gateway.py:169)ws_resume	[botpy] 重连启动...
-2022-12-08 19:32:08,604	[INFO]	(gateway.py:85)on_message	[botpy] 机器人重连成功! 
-2022-12-08 19:32:08,605	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 20:02:08,495	[INFO]	(gateway.py:54)on_closed	[botpy] 关闭, 返回码: 4009, 返回信息: Session timed out
-2022-12-08 20:02:13,497	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 20:02:13,497	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 20:02:13,498	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 20:02:13,797	[INFO]	(gateway.py:169)ws_resume	[botpy] 重连启动...
-2022-12-08 20:02:13,914	[INFO]	(gateway.py:85)on_message	[botpy] 机器人重连成功! 
-2022-12-08 20:02:13,915	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 20:31:53,159	[INFO]	(client.py:159)_bot_login	[botpy] 登录机器人账号中...
-2022-12-08 20:31:58,306	[INFO]	(client.py:178)_bot_init	[botpy] 程序启动...
-2022-12-08 20:31:58,307	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 20:31:58,308	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 20:31:58,308	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 20:31:58,748	[INFO]	(gateway.py:136)ws_identify	[botpy] 鉴权中...
-2022-12-08 20:31:58,924	[INFO]	(gateway.py:80)on_message	[botpy] 机器人「SoGPT-测试中」启动成功！
-2022-12-08 20:31:58,925	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 20:34:26,596	[INFO]	(client.py:159)_bot_login	[botpy] 登录机器人账号中...
-2022-12-08 20:34:27,610	[INFO]	(client.py:178)_bot_init	[botpy] 程序启动...
-2022-12-08 20:34:27,611	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 20:34:27,613	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 20:34:27,613	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 20:34:27,919	[INFO]	(gateway.py:136)ws_identify	[botpy] 鉴权中...
-2022-12-08 20:34:28,022	[INFO]	(gateway.py:80)on_message	[botpy] 机器人「SoGPT-测试中」启动成功！
-2022-12-08 20:34:28,023	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 20:35:47,952	[INFO]	(client.py:159)_bot_login	[botpy] 登录机器人账号中...
-2022-12-08 20:35:48,499	[INFO]	(client.py:178)_bot_init	[botpy] 程序启动...
-2022-12-08 20:35:48,500	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 20:35:48,500	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 20:35:48,501	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 20:35:48,723	[INFO]	(gateway.py:136)ws_identify	[botpy] 鉴权中...
-2022-12-08 20:35:48,793	[INFO]	(gateway.py:80)on_message	[botpy] 机器人「SoGPT-测试中」启动成功！
-2022-12-08 20:35:48,794	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 20:55:03,450	[ERROR]	(http.py:73)_handle_response	[botpy] 接口请求异常，请求连接: https://api.sgroup.qq.com/channels/7150658/messages, 错误代码: 403, 返回内容: {'code': 304003, 'message': 'url not allowed'}, trace_id:c4c4d23f9b2829d03ae9a7dca0184fe9
-2022-12-08 21:05:48,678	[INFO]	(gateway.py:54)on_closed	[botpy] 关闭, 返回码: 4009, 返回信息: Session timed out
-2022-12-08 21:05:53,700	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 21:05:53,701	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 21:05:53,702	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 21:05:54,145	[INFO]	(gateway.py:169)ws_resume	[botpy] 重连启动...
-2022-12-08 21:05:54,232	[INFO]	(gateway.py:85)on_message	[botpy] 机器人重连成功! 
-2022-12-08 21:05:54,233	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 21:07:39,468	[INFO]	(client.py:159)_bot_login	[botpy] 登录机器人账号中...
-2022-12-08 21:07:40,244	[INFO]	(client.py:178)_bot_init	[botpy] 程序启动...
-2022-12-08 21:07:40,245	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 21:07:40,246	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 21:07:40,247	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 21:07:40,553	[INFO]	(gateway.py:136)ws_identify	[botpy] 鉴权中...
-2022-12-08 21:07:40,659	[INFO]	(gateway.py:80)on_message	[botpy] 机器人「SoGPT-测试中」启动成功！
-2022-12-08 21:07:40,660	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 21:30:11,249	[INFO]	(client.py:159)_bot_login	[botpy] 登录机器人账号中...
-2022-12-08 21:30:12,217	[INFO]	(client.py:178)_bot_init	[botpy] 程序启动...
-2022-12-08 21:30:12,218	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 21:30:12,219	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 21:30:12,219	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 21:30:12,627	[INFO]	(gateway.py:136)ws_identify	[botpy] 鉴权中...
-2022-12-08 21:30:12,730	[INFO]	(gateway.py:80)on_message	[botpy] 机器人「SoGPT-测试中」启动成功！
-2022-12-08 21:30:12,731	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 21:36:34,660	[ERROR]	(http.py:73)_handle_response	[botpy] 接口请求异常，请求连接: https://api.sgroup.qq.com/channels/7150658/messages, 错误代码: 501, 返回内容: None, trace_id:None
-2022-12-08 21:38:39,294	[ERROR]	(http.py:73)_handle_response	[botpy] 接口请求异常，请求连接: https://api.sgroup.qq.com/channels/7150658/messages, 错误代码: 501, 返回内容: None, trace_id:None
-2022-12-08 21:39:43,233	[INFO]	(client.py:159)_bot_login	[botpy] 登录机器人账号中...
-2022-12-08 21:39:43,878	[INFO]	(client.py:178)_bot_init	[botpy] 程序启动...
-2022-12-08 21:39:43,879	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 21:39:43,880	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 21:39:43,880	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 21:39:44,099	[INFO]	(gateway.py:136)ws_identify	[botpy] 鉴权中...
-2022-12-08 21:39:44,279	[INFO]	(gateway.py:80)on_message	[botpy] 机器人「SoGPT-测试中」启动成功！
-2022-12-08 21:39:44,281	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 21:40:38,103	[INFO]	(client.py:159)_bot_login	[botpy] 登录机器人账号中...
-2022-12-08 21:40:39,100	[INFO]	(client.py:178)_bot_init	[botpy] 程序启动...
-2022-12-08 21:40:39,101	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 21:40:39,102	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 21:40:39,102	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 21:40:39,402	[INFO]	(gateway.py:136)ws_identify	[botpy] 鉴权中...
-2022-12-08 21:40:39,502	[INFO]	(gateway.py:80)on_message	[botpy] 机器人「SoGPT-测试中」启动成功！
-2022-12-08 21:40:39,503	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 21:40:52,805	[ERROR]	(http.py:73)_handle_response	[botpy] 接口请求异常，请求连接: https://api.sgroup.qq.com/channels/7150658/messages, 错误代码: 501, 返回内容: None, trace_id:None
-2022-12-08 21:41:39,703	[INFO]	(client.py:159)_bot_login	[botpy] 登录机器人账号中...
-2022-12-08 21:41:40,399	[INFO]	(client.py:178)_bot_init	[botpy] 程序启动...
-2022-12-08 21:41:40,400	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 21:41:40,401	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 21:41:40,401	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 21:41:40,644	[INFO]	(gateway.py:136)ws_identify	[botpy] 鉴权中...
-2022-12-08 21:41:40,740	[INFO]	(gateway.py:80)on_message	[botpy] 机器人「SoGPT-测试中」启动成功！
-2022-12-08 21:41:40,741	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 21:41:56,705	[ERROR]	(http.py:73)_handle_response	[botpy] 接口请求异常，请求连接: https://api.sgroup.qq.com/channels/7150658/messages, 错误代码: 501, 返回内容: None, trace_id:None
-2022-12-08 21:42:55,625	[INFO]	(client.py:159)_bot_login	[botpy] 登录机器人账号中...
-2022-12-08 21:42:56,278	[INFO]	(client.py:178)_bot_init	[botpy] 程序启动...
-2022-12-08 21:42:56,279	[INFO]	(connection.py:59)multi_run	[botpy] 最大并发连接数: 1, 启动会话数: 1
-2022-12-08 21:42:56,280	[INFO]	(client.py:236)bot_connect	[botpy] 会话启动中...
-2022-12-08 21:42:56,281	[INFO]	(gateway.py:110)ws_connect	[botpy] 启动中...
-2022-12-08 21:42:56,718	[INFO]	(gateway.py:136)ws_identify	[botpy] 鉴权中...
-2022-12-08 21:42:56,819	[INFO]	(gateway.py:80)on_message	[botpy] 机器人「SoGPT-测试中」启动成功！
-2022-12-08 21:42:56,820	[INFO]	(gateway.py:217)_send_heart	[botpy] 心跳维持启动...
-2022-12-08 21:43:09,794	[ERROR]	(http.py:73)_handle_response	[botpy] 接口请求异常，请求连接: https://api.sgroup.qq.com/channels/7150658/messages, 错误代码: 501, 返回内容: None, trace_id:None

configs/config.yaml

@@ -1,29 +1,137 @@
-openai:
+# 如果你不知道怎么部署，请查看https://soulter.top/posts/qpdg.html
-  # 注意：在1.7版本已支持多key自动切换，方法：
+# 不一定需要key了，如果你没有key但有openAI账号或者必应账号，可以考虑使用下面的逆向库
-  # key:
-  #   - xxxxx
-  #   - xxxxxx
-  # 在下方非注释的地方使用以上格式
-  key: 
-    - 
-  chatGPTConfigs:
-    engine: text-davinci-003
-    max_tokens: 800
-    temperature: 0.8
-    top_p: 1
-    frequency_penalty: 0.4
-    presence_penalty: 0.3
-  total_tokens_limit: 700
 
+
+###############平台设置#################
+
+# QQ频道机器人
+# QQ开放平台的appid和令牌
+# q.qq.com
+# enable为true则启用，false则不启用
 qqbot:
+  enable: true
   appid: 
   token: 
 
+# QQ机器人
+# enable为true则启用，false则不启用
+# 需要安装GO-CQHTTP配合使用。
+# 文档：https://docs.go-cqhttp.org/
+# 请将go-cqhttp的配置文件的sever部分粘贴为以下内容，否则无法使用
+# 请先启动go-cqhttp再启动本程序
+# 
+# servers:
+#   - http:
+#       host: 127.0.0.1
+#       version: 0
+#       port: 5700
+#       timeout: 5
+#   - ws:
+#       address: 127.0.0.1:6700
+#       middlewares:
+#         <<: *default
+gocqbot:
+  enable: false
+
 # 设置是否一个人一个会话
 uniqueSessionMode: false
-
+# QChannelBot 的版本，请勿修改此字段，否则可能产生一些bug
-# QChannelBot 的版本
+version: 3.0
-version: 1.7 beta
-
 # [Beta] 转储历史记录时间间隔(分钟)
 dump_history_interval: 10
+# 一个用户只能在time秒内发送count条消息
+limit:
+  time: 60
+  count: 5
+# 公告
+notice: "此机器人由Github项目QQChannelChatGPT驱动。"
+# 是否打开私信功能
+# 设置为true则频道成员可以私聊机器人。
+# 设置为false则频道成员不能私聊机器人。
+direct_message_mode: true
+
+# 系统代理
+# http_proxy: http://localhost:7890
+# https_proxy: http://localhost:7890
+
+# 自定义回复前缀，如[Rev]或其他，务必加引号以防止不必要的bug。
+reply_prefix:
+  openai_official: "[GPT]"
+  rev_chatgpt: "[Rev]"
+  rev_edgegpt: "[RevBing]"
+
+# 百度内容审核服务
+# 新用户免费5万次调用。https://cloud.baidu.com/doc/ANTIPORN/index.html
+baidu_aip:
+  enable: false
+  app_id: 
+  api_key: 
+  secret_key: 
+
+
+
+
+###############语言模型设置#################
+
+
+# OpenAI官方API
+# 注意：已支持多key自动切换，方法：
+# key:
+#   - sk-xxxxxx
+#   - sk-xxxxxx
+# 在下方非注释的地方使用以上格式
+# 关于api_base：可以使用一些云函数（如腾讯、阿里）来避免国内被墙的问题。
+# 详见：
+# https://github.com/Ice-Hazymoon/openai-scf-proxy
+# https://github.com/Soulter/QQChannelChatGPT/issues/42
+# 设置为none则表示使用官方默认api地址
+openai:
+  key: 
+    - 
+  api_base: none
+  # 这里是GPT配置，语言模型默认使用gpt-3.5-turbo
+  chatGPTConfigs:
+    model: gpt-3.5-turbo
+    max_tokens: 3000
+    temperature: 0.9
+    top_p: 1
+    frequency_penalty: 0
+    presence_penalty: 0
+    
+  total_tokens_limit: 5000
+
+# 逆向文心一言【暂时不可用，请勿使用】
+rev_ernie:
+  enable: false
+
+# 逆向New Bing
+# 需要在项目根目录下创建cookies.json并粘贴cookies进去。
+# 详见：https://soulter.top/posts/qpdg.html
+rev_edgegpt:
+  enable: false
+
+# 逆向ChatGPT库
+# https://github.com/acheong08/ChatGPT
+# 优点：免费（无免费额度限制）；
+# 缺点：速度相对慢。OpenAI 速率限制：免费帐户每小时 50 个请求。您可以通过多帐户循环来绕过它
+# enable设置为true后，将会停止使用上面正常的官方API调用而使用本逆向项目
+#
+# 多账户可以保证每个请求都能得到及时的回复。
+# 关于account的格式
+# account:
+#   - email: 第1个账户
+#     password: 第1个账户密码
+#   - email: 第2个账户
+#     password: 第2个账户密码
+#   - ....
+# 支持使用access_token登录
+# 例：
+# - session_token: xxxxx
+# - access_token: xxxx
+# 请严格按照上面这个格式填写。
+# 逆向ChatGPT库的email-password登录方式不工作，建议使用access_token登录
+# 获取access_token的方法，详见：https://soulter.top/posts/qpdg.html
+rev_ChatGPT:
+  enable: false
+  account:
+    - access_token: 

cores/openai/core.py

@@ -1,169 +0,0 @@
-import openai
-import yaml
-from util.errors.errors import PromptExceededError
-import json
-import time
-import os
-import sys
-
-inst = None
-# 适配pyinstaller
-abs_path = os.path.dirname(os.path.realpath(sys.argv[0])) + '/'
-key_record_path = abs_path+'chatgpt_key_record'
-
-class ChatGPT:
-    def __init__(self):
-        self.key_list = []
-        with open(abs_path+"configs/config.yaml", 'r', encoding='utf-8') as ymlfile:
-            cfg = yaml.safe_load(ymlfile)
-            if cfg['openai']['key'] != '' or cfg['openai']['key'] != '修改我！！':
-                print("读取ChatGPT Key成功")
-                self.key_list = cfg['openai']['key']
-                # openai.api_key = cfg['openai']['key']
-            else:
-                input("请先去完善ChatGPT的Key。详情请前往https://beta.openai.com/account/api-keys")
-        
-        # init key record
-        self.init_key_record()
-
-        chatGPT_configs = cfg['openai']['chatGPTConfigs']
-        print(f'加载ChatGPTConfigs: {chatGPT_configs}')
-        self.chatGPT_configs = chatGPT_configs
-        self.openai_configs = cfg['openai']
-    
-    def chat(self, prompt, image_mode = False):
-        try:
-            if not image_mode:
-                response = openai.Completion.create(
-                    prompt=prompt,
-                    **self.chatGPT_configs
-                )
-            else:
-                response = openai.Image.create(
-                    prompt=prompt,
-                    n=1,
-                    size="512x512",
-                )
-        except Exception as e:
-            print(e)
-            if 'You exceeded' in str(e) or 'Billing hard limit has been reached' in str(e) or 'No API key provided.' in str(e):
-                print("当前Key已超额,正在切换")
-                self.key_stat[openai.api_key]['exceed'] = True
-                self.save_key_record()
-
-                response, is_switched = self.handle_switch_key(prompt)
-                if not is_switched:
-                    # 所有Key都超额
-                    raise e
-            else:
-                if not image_mode:
-                    response = openai.Completion.create(
-                        prompt=prompt,
-                        **self.chatGPT_configs
-                    )
-                else:
-                    response = openai.Image.create(
-                        prompt=prompt,
-                        n=1,
-                        size="512x512",
-                    )
-        if not image_mode:
-            self.key_stat[openai.api_key]['used'] += response['usage']['total_tokens']
-            self.save_key_record()
-            print("[ChatGPT] "+str(response["choices"][0]["text"]))
-            return str(response["choices"][0]["text"]).strip(), response['usage']['total_tokens']
-        else:
-            return response['data'][0]['url']
-            
-    def handle_switch_key(self, prompt):
-        while True:
-            is_all_exceed = True
-            for key in self.key_stat:
-                if not self.key_stat[key]['exceed']:
-                    is_all_exceed = False
-                    openai.api_key = key
-                    print(f"切换到Key: {key}, 已使用token: {self.key_stat[key]['used']}")
-                    if prompt != '':
-                        try:
-                            response = openai.Completion.create(
-                                prompt=prompt,
-                                **self.chatGPT_configs
-                            )
-                            return response, True
-                        except Exception as e:
-                            print(e)
-                            if 'You exceeded' in str(e):
-                                print("当前Key已超额,正在切换")
-                                self.key_stat[openai.api_key]['exceed'] = True
-                                self.save_key_record()
-                                time.sleep(1)
-                                continue
-                    else:
-                        return True
-            if is_all_exceed:
-                print("所有Key已超额")
-                return None, False
-                
-    def getConfigs(self):
-        return self.openai_configs
-    
-    def save_key_record(self):
-        with open(key_record_path, 'w', encoding='utf-8') as f:
-            json.dump(self.key_stat, f)
-
-    def get_key_stat(self):
-        return self.key_stat
-    def get_key_list(self):
-        return self.key_list
-    
-    # 添加key
-    def append_key(self, key, sponsor):
-        self.key_list.append(key)
-        self.key_stat[key] = {'exceed': False, 'used': 0, 'sponsor': sponsor}
-        self.save_key_record()
-        self.init_key_record()
-    # 检查key是否可用
-    def check_key(self, key):
-        pre_key = openai.api_key
-        openai.api_key = key
-        try:
-            openai.Completion.create(
-                prompt="1",
-                **self.chatGPT_configs
-            )
-            openai.api_key = pre_key
-            return True
-        except Exception as e:
-            pass
-        openai.api_key = pre_key
-        return False
-
-    #将key_list的key转储到key_record中，并记录相关数据
-    def init_key_record(self):
-        if not os.path.exists(key_record_path):
-            with open(key_record_path, 'w', encoding='utf-8') as f:
-                json.dump({}, f)
-        with open(key_record_path, 'r', encoding='utf-8') as keyfile:
-            try:
-                self.key_stat = json.load(keyfile)
-            except Exception as e:
-                print(e)
-                self.key_stat = {}
-            finally:
-                for key in self.key_list:
-                    if key not in self.key_stat:
-                        self.key_stat[key] = {'exceed': False, 'used': 0}
-                        # if openai.api_key is None:
-                        #     openai.api_key = key
-                    else:
-                        # if self.key_stat[key]['exceed']:
-                        #     print(f"Key: {key} 已超额")
-                        #     continue
-                        # else:
-                        #     if openai.api_key is None:
-                        #         openai.api_key = key
-                        #         print(f"使用Key: {key}, 已使用token: {self.key_stat[key]['used']}")
-                        pass
-                if openai.api_key == None:
-                    self.handle_switch_key("")
-            self.save_key_record()

main.py

@@ -1,145 +1,94 @@
 import threading
-import time
 import asyncio
 import os, sys
-import signal
+from pip._internal import main as pipmain
-import requests,json
 
-# 是否是windows打包。一般人不需要改这个，这个只是我为了方便加上的。
-win_compile_mode = False
 abs_path = os.path.dirname(os.path.realpath(sys.argv[0])) + '/'
 
-
-
 def main(loop, event):
-    import cores.qqbot.core as qqBot
-    from cores.openai.core import ChatGPT
-    #实例化ChatGPT
-    chatgpt = ChatGPT()
-    # #执行qqBot
-    qqBot.initBot(chatgpt)
-
-# 仅支持linux
-def hot_update(ver):
-    target = 'target.tar'
-    time.sleep(5)
-    while(True):
-        if os.path.exists('version.txt'):
-            version_file = open('version.txt', 'r', encoding='utf-8')
-            vs = version_file.read()
-            version = float(vs)
-        else:
-            version = 0
-        if not os.path.exists(target):
-            version = 0
-        try:
-            res = requests.get("https://soulter.top/channelbot/update.json")
-            res_obj = json.loads(res.text)
-            ol_version = float(res_obj['version'])
-            if ol_version > version:
-                print('发现新版本: ' + str(ol_version))
-                res = requests.get(res_obj['linux-url'], stream=True)
-                filesize = res.headers["Content-Length"]
-                print('文件大小: ' + str(int(filesize) / 1024 / 1024) + 'MB')
-                print('正在更新文件...')
-                chunk_size = 1024
-                times = int(filesize) // chunk_size
-                show = 1 / times
-                show2 = 1 / times
-                start = 1
-                with open(target, "wb") as pyFile:
-                    for chunk in res.iter_content(chunk_size=chunk_size):
-                        if chunk:
-                            pyFile.write(chunk)
-                        if start <= times:
-                            print(f"\r下载进度: {show:.2%}",end="",flush=True)
-                            start += 1
-                            show += show2
-                        else:
-                            sys.stdout.write(f"下载进度: 100%\n")
-                print('更新完成')
-                print('解压覆盖')
-                os.system(f"tar -zxvf {target}")
-                version = ol_version
-                version_file = open('version.txt', 'w+', encoding='utf-8')
-                version_file.write(str(res_obj['version']))
-                version_file.flush()
-                version_file.close()
-
-                try:
-                    update_version(version)
-                except BaseException as e:
-                    print(e)
-                
-                print('自启动')
-                py = sys.executable
-                os.execl(py, py, *sys.argv)
-            time.sleep(60*20)
-        except BaseException as e:
-            print(e)
-            print("upd出现异常，请联系QQ905617992")
-            time.sleep(60*20)
-
-
-def update_version(ver):
-    if not os.path.exists('update_record'):
-        object_id = ''
-    else:
-        object_id = open("update_record", 'r', encoding='utf-8').read()
-    addr = 'unknown'
     try:
-        addr = requests.get('http://myip.ipip.net', timeout=5).text
+        import cores.qqbot.core as qqBot
-    except BaseException:
+        import yaml
-        pass
+        ymlfile =  open(abs_path+"configs/config.yaml", 'r', encoding='utf-8')
-    try:
+        cfg = yaml.safe_load(ymlfile)
-        ts = str(time.time())
-        # md = hashlib.md5((ts+'QAZ1rQLY1ZufHrZlpuUiNff7').encode())
-        headers = {
-            'X-LC-Id': 'UqfXTWW15nB7iMT0OHvYrDFb-gzGzoHsz',
-            'X-LC-Key': 'QAZ1rQLY1ZufHrZlpuUiNff7',
-            'Content-Type': 'application/json'
-        }
-        d = {"data": {'version':'win-hot-update'+str(ver), 'addr': addr}}
-        d = json.dumps(d).encode("utf-8")
-        res = requests.put(f'https://uqfxtww1.lc-cn-n1-shared.com/1.1/classes/version_record/{object_id}', headers = headers, data = d)
-        if json.loads(res.text)['code'] == 1:
-            res = requests.post(f'https://uqfxtww1.lc-cn-n1-shared.com/1.1/classes/version_record', headers = headers, data = d)
-            object_id = json.loads(res.text)['objectId']
-            object_id_file = open("update_record", 'w+', encoding='utf-8')
-            object_id_file.write(str(object_id))
-            object_id_file.flush()
-            object_id_file.close()
     except BaseException as e:
         print(e)
+        input("yaml库未导入或者配置文件格式错误，请退出程序重试。")
+        exit()
+
+    if 'http_proxy' in cfg:
+        os.environ['HTTP_PROXY'] = cfg['http_proxy']
+    if 'https_proxy' in cfg:
+        os.environ['HTTPS_PROXY'] = cfg['https_proxy']
+
+    provider = privider_chooser(cfg)
+    print('[System] 当前语言模型提供商: ' + str(provider))
+    # 执行Bot
+    qqBot.initBot(cfg, provider)
+
+# 语言模型提供商选择器
+# 目前有：OpenAI官方API、逆向库
+def privider_chooser(cfg):
+    l = []
+    if 'rev_ChatGPT' in cfg and cfg['rev_ChatGPT']['enable']:
+        l.append('rev_chatgpt')
+    if 'rev_ernie' in cfg and cfg['rev_ernie']['enable']:
+        l.append('rev_ernie')
+    if 'rev_edgegpt' in cfg and cfg['rev_edgegpt']['enable']:
+        l.append('rev_edgegpt')
+    if 'openai' in cfg and cfg['openai']['key'] != None and len(cfg['openai']['key'])>0:
+        l.append('openai_official')
+    return l
 
 def check_env():
     if not (sys.version_info.major == 3 and sys.version_info.minor >= 8):
         print("请使用Python3.8运行本项目")
         input("按任意键退出...")
         exit()
-    try:
-        import openai
-        import botpy
-        import yaml
-    except Exception as e:
-        # print(e)
-        try:
-            print("安装依赖库中...")
-            os.system("pip3 install openai")
-            os.system("pip3 install qq-botpy")
-            os.system("pip3 install pyyaml")
-            print("安装依赖库完毕...")
-        except BaseException:
-            print("\n安装第三方库异常.请自行安装或者联系QQ905617992.")
 
-    # 检查key
+    # 检查pip
-    with open(abs_path+"configs/config.yaml", 'r', encoding='utf-8') as ymlfile:
+    # pip_tag = "pip"
-        import yaml
+    # mm = os.system("pip -V")
-        cfg = yaml.safe_load(ymlfile)
+    # if mm != 0:
-        if cfg['openai']['key'] == '' or cfg['openai']['key'] == None:
+    #     mm1 = os.system("pip3 -V")
-            print("请先在configs/config.yaml下添加一个可用的OpenAI Key。详情请前往https://beta.openai.com/account/api-keys")
+    #     if mm1 != 0:
-        if cfg['qqbot']['appid'] == '' or cfg['qqbot']['token'] == '' or cfg['qqbot']['appid'] == None or cfg['qqbot']['token'] == None: 
+    #         print("未检测到pip, 请安装Python(版本应>=3.9)")
-            print("请先在configs/config.yaml下完善appid和token令牌(在https://q.qq.com/上注册一个QQ机器人即可获得)")
+    #         input("按任意键退出...")
+    #         exit()
+    #     else:
+    #         pip_tag = "pip3"
+    
+    if os.path.exists('requirements.txt'):
+        pth = 'requirements.txt'
+    else:
+        pth = 'QQChannelChatGPT'+ os.sep +'requirements.txt'
+    print("正在更新三方依赖库...")
+    try:
+        pipmain(['install', '-r', pth])
+        print("依赖库安装完毕。")
+    except BaseException as e:
+        print(e)
+        while True:
+            res = input("依赖库可能安装失败了。\n如果是报错ValueError: check_hostname requires server_hostname，请尝试先关闭代理后重试。\n输入y回车重试\n输入c回车使用国内镜像源下载\n输入其他按键回车继续往下执行。")
+            if res == "y":
+                try:
+                    pipmain(['install', '-r', pth])
+                    print("依赖库安装完毕。")
+                    break
+                except BaseException as e:
+                    print(e)
+                    continue
+
+            elif res == "c":
+                try:
+                    pipmain(['install', '-r', pth, '-i', 'https://mirrors.aliyun.com/pypi/simple/'])
+                    print("依赖库安装完毕。")
+                    break
+                except BaseException as e:
+                    print(e)
+                    continue
+            else:
+                break
 
 def get_platform():
     import platform
@@ -154,15 +103,20 @@ def get_platform():
         print("other")
 
 if __name__ == "__main__":
-    global pid
-    pid = os.getpid()
-    global ma_type
-    print("程序PID:"+str(pid))
     check_env()
+
+    # 获取参数
+    args = sys.argv
+    if len(args) > 1:
+        if args[1] == '-replit':
+            print("[System] 启动Replit Web保活服务...")
+            try:
+                from webapp_replit import keep_alive
+                keep_alive()
+            except BaseException as e:
+                print(e)
+                print(f"[System-err] Replit Web保活服务启动失败:{str(e)}")
+
     bot_event = threading.Event()
     loop = asyncio.get_event_loop()
-    ma_type = get_platform()
-    if ma_type == 'linux':
-        threading.Thread(target=hot_update).start()
-        
     main(loop, bot_event)

model/command/command.py

@@ -0,0 +1,377 @@
+import json
+import git.exc
+from git.repo import Repo
+import os
+import sys
+import requests
+from model.provider.provider import Provider
+import json
+import util.plugin_util as putil
+import shutil
+import importlib
+
+PLATFORM_QQCHAN = 'qqchan'
+PLATFORM_GOCQ = 'gocq'
+
+# 指令功能的基类，通用的（不区分语言模型）的指令就在这实现
+class Command:
+    def __init__(self, provider: Provider):
+        self.provider = Provider
+
+    def get_plugin_modules(self):
+        plugins = []
+        try:
+            if os.path.exists("addons/plugins"):
+                plugins = putil.get_modules("addons/plugins")
+                return plugins
+            elif os.path.exists("QQChannelChatGPT/addons/plugins"):
+                plugins = putil.get_modules("QQChannelChatGPT/addons/plugins")
+                return plugins
+            else:
+                return None
+        except BaseException as e:
+            raise e
+
+    def check_command(self, message, role, platform, message_obj, cached_plugins: dict):
+        # 插件
+
+        for k, v in cached_plugins.items():
+            try:
+                hit, res = v["clsobj"].run(message, role, platform, message_obj)
+                if hit:
+                    return True, res
+            except BaseException as e:
+                print(f"[Debug] {k}插件加载出现问题，原因: {str(e)}\n已安装插件: {cached_plugins.keys}\n如果你没有相关装插件的想法, 请直接忽略此报错, 不影响其他功能的运行。")
+
+        if self.command_start_with(message, "nick"):
+            return True, self.set_nick(message, platform)
+        
+        if self.command_start_with(message, "plugin"):
+            return True, self.plugin_oper(message, role, cached_plugins)
+        
+        return False, None
+    
+    def plugin_reload(self, cached_plugins: dict, target: str = None, all: bool = False):
+        plugins = self.get_plugin_modules()
+        fail_rec = ""
+        if plugins != None:
+            for p in plugins:
+                try:
+                    if p not in cached_plugins or p == target or all:
+                        module = __import__("addons.plugins." + p + "." + p, fromlist=[p])
+                        if p in cached_plugins:
+                            module = importlib.reload(module)
+                        cls = putil.get_classes(p, module)
+                        obj = getattr(module, cls[0])()
+                        try:
+                            info = obj.info()
+                            if 'name' not in info or 'desc' not in info or 'version' not in info or 'author' not in info:
+                                fail_rec += f"载入插件{p}失败，原因: 插件信息不完整\n"
+                                continue
+                            if isinstance(info, dict) == False:
+                                fail_rec += f"载入插件{p}失败，原因: 插件信息格式不正确\n"
+                                continue
+                        except BaseException as e:
+                            fail_rec += f"调用插件{p} info失败, 原因: {str(e)}\n"
+                            continue
+                        cached_plugins[p] = {
+                            "module": module,
+                            "clsobj": obj,
+                            "info": info
+                        }  
+                except BaseException as e:
+                    fail_rec += f"加载{p}插件出现问题，原因{str(e)}\n"
+            if fail_rec == "":
+                return True, None
+            else:
+                return False, fail_rec
+        else:
+            return False, "未找到任何插件模块"
+    
+    '''
+    插件指令
+    '''
+    def plugin_oper(self, message: str, role: str, cached_plugins: dict):
+        l = message.split(" ")
+        if len(l) < 2:
+            return True, "\n=====插件指令面板=====\n安装插件: \nplugin i 插件Github地址\n卸载插件: \nplugin i 插件名 \n重载插件: \nplugin reload\n查看插件列表：\nplugin l\n更新插件: plugin u 插件名\n===============", "plugin"
+        else:
+            ppath = ""
+            if os.path.exists("addons/plugins"):
+                ppath = "addons/plugins"
+            elif os.path.exists("QQChannelChatGPT/addons/plugins"):
+                ppath = "QQChannelChatGPT/addons/plugins"
+            else:
+                return False, "未找到插件目录", "plugin"
+            if l[1] == "i":
+                if role != "admin":
+                    return False, f"你的身份组{role}没有权限安装插件", "plugin"
+                try:
+                    # 得到url的最后一段
+                    d = l[2].split("/")[-1]
+                    # 创建文件夹
+                    plugin_path = os.path.join(ppath, d)
+                    if os.path.exists(plugin_path):
+                        shutil.rmtree(plugin_path)
+                    os.mkdir(plugin_path)
+                    Repo.clone_from(l[2],to_path=plugin_path,branch='master')
+
+                    # 读取插件的requirements.txt
+                    if os.path.exists(os.path.join(plugin_path, "requirements.txt")):
+                        with open(os.path.join(plugin_path, "requirements.txt"), "r", encoding="utf-8") as f:
+                            for line in f.readlines():
+                                mm = os.system(f"pip3 install {line.strip()}")
+                                if mm != 0:
+                                    return False, "插件依赖安装失败，需要您手动pip安装对应插件的依赖。", "plugin"
+                    # 加载没缓存的插件
+                    ok, err = self.plugin_reload(cached_plugins, target=d)
+                    if ok:
+                        return True, "插件拉取并载入成功~", "plugin"
+                    else:
+                        # if os.path.exists(plugin_path):
+                        #     shutil.rmtree(plugin_path)
+                        return False, f"插件拉取载入失败。\n跟踪: \n{err}", "plugin"
+                except BaseException as e:
+                    return False, f"拉取插件失败，原因: {str(e)}", "plugin"
+            elif l[1] == "d":
+                if role != "admin":
+                    return False, f"你的身份组{role}没有权限删除插件", "plugin"
+                try:
+                    # 删除文件夹
+                    shutil.rmtree(os.path.join(ppath, l[2]))
+                    if l[2] in cached_plugins:
+                        del cached_plugins[l[2]]
+                    return True, "插件卸载成功~", "plugin"
+                except BaseException as e:
+                    return False, f"卸载插件失败，原因: {str(e)}", "plugin"
+            elif l[1] == "u":
+                plugin_path = os.path.join(ppath, l[2])
+                try:
+                    repo = Repo(path = plugin_path)
+                    repo.remotes.origin.pull()
+                    ok, err = self.plugin_reload(cached_plugins, target=l[2])
+                    if ok:
+                        return True, "\n更新插件成功!!", "plugin"
+                    else:
+                        return False, "更新插件成功，但是重载插件失败。\n问题跟踪: \n"+err, "plugin"
+                except BaseException as e:
+                    return False, "更新插件失败, 请使用plugin i指令覆盖安装", "plugin"
+
+            elif l[1] == "l":
+                try:
+                    plugin_list_info = "\n".join([f"{k}: \n名称: {v['info']['name']}\n简介: {v['info']['desc']}\n版本: {v['info']['version']}\n作者: {v['info']['author']}\n" for k, v in cached_plugins.items()])
+                    return True, "\n=====已激活插件列表=====\n" + plugin_list_info + "\n使用plugin v 插件名 查看插件帮助\n=================", "plugin"
+                except BaseException as e:
+                    return False, f"获取插件列表失败，原因: {str(e)}", "plugin"
+            elif l[1] == "v":
+                try:
+                    if l[2] in cached_plugins:
+                        info = cached_plugins[l[2]]["info"]
+                        res = f"\n=====插件信息=====\n名称: {info['name']}\n{info['desc']}\n版本: {info['version']}作者: {info['author']}\n\n帮助:\n{info['help']}"
+                        return True, res, "plugin"
+                    else:
+                        return False, "未找到该插件", "plugin"
+                except BaseException as e:
+                    return False, f"获取插件信息失败，原因: {str(e)}", "plugin"
+            elif l[1] == "reload":
+                if role != "admin":
+                    return False, f"你的身份组{role}没有权限重载插件", "plugin"
+                try:
+                    ok, err = self.plugin_reload(cached_plugins, all = True)
+                    if ok:
+                        return True, "\n重载插件成功~", "plugin"
+                    else:
+                        # if os.path.exists(plugin_path):
+                        #     shutil.rmtree(plugin_path)
+                        return False, f"插件重载失败。\n跟踪: \n{err}", "plugin"
+                except BaseException as e:
+                    return False, f"插件重载失败，原因: {str(e)}", "plugin"
+                
+            elif l[1] == "dev":
+                if role != "admin":
+                    return False, f"你的身份组{role}没有权限开发者模式", "plugin"
+                return True, "cached_plugins: \n" + str(cached_plugins), "plugin"
+
+
+    '''
+    nick: 存储机器人的昵称
+    '''
+    def set_nick(self, message: str, platform: str):
+        if platform == PLATFORM_GOCQ:
+            l = message.split(" ")
+            if len(l) == 1:
+                return True, "【设置机器人昵称】示例：\n支持多昵称\nnick 昵称1 昵称2 昵称3", "nick"
+            nick = l[1:]
+            self.general_command_storer("nick_qq", nick)
+            return True, f"设置成功！现在你可以叫我这些昵称来提问我啦~", "nick"
+        elif platform == PLATFORM_QQCHAN:
+            nick = message.split(" ")[2]
+            return False, "QQ频道平台不支持为机器人设置昵称。", "nick"
+    
+    """
+    存储指令结果到cmd_config.json
+    """
+    def general_command_storer(self, key, value):
+        if not os.path.exists("cmd_config.json"):
+            config = {}
+        else:
+            with open("cmd_config.json", "r", encoding="utf-8") as f:
+                config = json.load(f)
+        config[key] = value
+        with open("cmd_config.json", "w", encoding="utf-8") as f:
+            json.dump(config, f, indent=4, ensure_ascii=False)
+            f.flush()
+
+    
+    def general_commands(self):
+        return {
+            "help": "帮助",
+            "keyword": "设置关键词/关键指令回复",
+            "update": "更新面板",
+            "update latest": "更新到最新版本",
+            "update r": "重启机器人",
+            "reset": "重置会话",
+            "nick": "设置机器人昵称",
+            "/bing": "切换到bing模型",
+            "/gpt": "切换到OpenAI ChatGPT API",
+            "/revgpt": "切换到网页版ChatGPT",
+            "/bing 问题": "临时使用一次bing模型进行会话",
+            "/gpt 问题": "临时使用一次OpenAI ChatGPT API进行会话",
+            "/revgpt 问题": "临时使用一次网页版ChatGPT进行会话",
+            "plugin": "插件安装、卸载和重载"
+        }
+    
+    def help_messager(self, commands: dict):
+        try:
+            resp = requests.get("https://soulter.top/channelbot/notice.json").text
+            notice = json.loads(resp)["notice"]
+        except BaseException as e:
+            notice = ""
+        msg = "Github项目名QQChannelChatGPT, 有问题提交issue, 欢迎Star\n【指令列表】\n"
+        for key, value in commands.items():
+            msg += key + ": " + value + "\n"
+        msg += notice
+        return msg
+    
+    # 接受可变参数
+    def command_start_with(self, message: str, *args):
+        for arg in args:
+            if message.startswith(arg) or message.startswith('/'+arg):
+                return True
+        return False
+    
+    # keyword: 关键字
+    def keyword(self, message: str, role: str):
+        if role != "admin":
+            return True, "你没有权限使用该指令", "keyword"
+
+        l = message.split(" ")
+
+        if len(l) < 3:
+            return True, "【设置关键词回复】示例：\nkeyword hi 你好\n当发送hi的时候会回复你好\nkeyword /hi 你好\n当发送/hi时会回复你好\n删除关键词: keyword d hi\n删除hi关键词的回复", "keyword"
+        
+        del_mode = False
+        if l[1] == "d":
+            print("删除关键词: "+l[2])
+            del_mode = True    
+
+        try:
+            if os.path.exists("keyword.json"):
+                with open("keyword.json", "r", encoding="utf-8") as f:
+                    keyword = json.load(f)
+                    if del_mode:
+                        # 删除关键词
+                        if l[2] not in keyword:
+                            return False, "该关键词不存在", "keyword"
+                        else: del keyword[l[2]]
+                    else:
+                        keyword[l[1]] = l[2]
+            else:
+                if del_mode:
+                    return False, "该关键词不存在", "keyword"
+                keyword = {l[1]: l[2]}
+            with open("keyword.json", "w", encoding="utf-8") as f:
+                print("设置指令: "+l[1]+" -> "+l[2])
+                json.dump(keyword, f, ensure_ascii=False, indent=4)
+                f.flush()
+            if del_mode:
+                return True, "删除成功: "+l[2], "keyword"
+            return True, "设置成功: "+l[1]+" -> "+l[2], "keyword"
+        except BaseException as e:
+            return False, "设置失败: "+str(e), "keyword"
+    
+    def update(self, message: str, role: str):
+        if role != "admin":
+            return True, "你没有权限使用该指令", "keyword"
+        l = message.split(" ")
+        if len(l) == 1:
+            # 得到本地版本号和最新版本号
+            try:
+                repo = Repo()
+            except git.exc.InvalidGitRepositoryError:
+                repo = Repo(path="QQChannelChatGPT")
+            now_commit = repo.head.commit
+
+            # 得到远程3条commit列表, 包含commit信息
+            origin = repo.remotes.origin
+            origin.fetch()
+            commits = list(repo.iter_commits('master', max_count=3))
+            commits_log = ''
+            index = 1
+            for commit in commits:
+                if commit.message.endswith("\n"):
+                    commits_log += f"[{index}] {commit.message}-----------\n"
+                else:
+                    commits_log += f"[{index}] {commit.message}\n-----------\n"
+                index+=1
+            remote_commit_hash = origin.refs.master.commit.hexsha[:6]
+
+            return True, f"当前版本: {now_commit.hexsha[:6]}\n最新版本: {remote_commit_hash}\n\n3条commit(非最新):\n{str(commits_log)}\n使用update latest更新至最新版本\n", "update"
+        else:
+            if l[1] == "latest":
+                pash_tag = ""
+                try:
+                    try:
+                        repo = Repo()
+                    except git.exc.InvalidGitRepositoryError:
+                        repo = Repo(path="QQChannelChatGPT")
+                        pash_tag = "QQChannelChatGPT"+os.sep
+                    repo.remotes.origin.pull()
+
+                    return True, "更新成功~是否重启？输入update r重启（重启指令不返回任何确认信息）。", "update"
+                    
+                except BaseException as e:
+                    return False, "更新失败: "+str(e), "update"
+            if l[1] == "r":
+                py = sys.executable
+                os.execl(py, py, *sys.argv)
+
+
+    def reset(self):
+        return False
+    
+    def set(self):
+        return False
+    
+    def unset(self):
+        return False
+    
+    def key(self):
+        return False
+    
+    def help(self):
+        return False
+    
+    def status(self):
+        return False
+    
+    def token(self):
+        return False
+    
+    def his(self):
+        return False
+    
+    def draw(self):
+        return False
+    
+    

model/command/command_openai_official.py

@@ -0,0 +1,202 @@
+from model.command.command import Command
+from model.provider.provider_openai_official import ProviderOpenAIOfficial
+from cores.qqbot.personality import personalities
+
+class CommandOpenAIOfficial(Command):
+    def __init__(self, provider: ProviderOpenAIOfficial):
+        self.provider = provider
+        self.cached_plugins = {}
+        
+    def check_command(self, 
+                      message: str, 
+                      session_id: str, 
+                      user_name: str, 
+                      role: str, 
+                      platform: str,
+                      message_obj,
+                      cached_plugins: dict):
+        hit, res = super().check_command(message, role, platform, message_obj=message_obj, cached_plugins=cached_plugins)
+        if hit:
+            return True, res
+        if self.command_start_with(message, "reset", "重置"):
+            return True, self.reset(session_id)
+        elif self.command_start_with(message, "his", "历史"):
+            return True, self.his(message, session_id, user_name)
+        elif self.command_start_with(message, "token"):
+            return True, self.token(session_id)
+        elif self.command_start_with(message, "gpt"):
+            return True, self.gpt()
+        elif self.command_start_with(message, "status"):
+            return True, self.status()
+        elif self.command_start_with(message, "count"):
+            return True, self.count()
+        elif self.command_start_with(message, "help", "帮助"):
+            return True, self.help()
+        elif self.command_start_with(message, "unset"):
+            return True, self.unset(session_id)
+        elif self.command_start_with(message, "set"):
+            return True, self.set(message, session_id)
+        elif self.command_start_with(message, "update"):
+            return True, self.update(message, role)
+        elif self.command_start_with(message, "画"):
+            return True, self.draw(message)
+        elif self.command_start_with(message, "keyword"):
+            return True, self.keyword(message, role)
+        elif self.command_start_with(message, "key"):
+            return True, self.key(message, user_name)
+        
+        if self.command_start_with(message, "/"):
+            return True, (False, "未知指令", "unknown_command")
+        
+        return False, None
+    
+    def help(self):
+        commands = super().general_commands()
+        commands['画'] = '画画'
+        commands['key'] = '添加OpenAI key'
+        commands['set'] = '人格设置面板'
+        commands['gpt'] = '查看gpt配置信息'
+        commands['status'] = '查看key使用状态'
+        commands['token'] = '查看本轮会话token'
+        return True, super().help_messager(commands), "help"
+
+    
+    def reset(self, session_id: str):
+        self.provider.forget(session_id)
+        return True, "重置成功", "reset"
+    
+    def his(self, message: str, session_id: str, name: str):
+        #分页，每页5条
+        msg = ''
+        size_per_page = 3
+        page = 1
+        if message[4:]:
+            page = int(message[4:])
+        # 检查是否有过历史记录
+        if session_id not in self.provider.session_dict:
+            msg = f"历史记录为空"
+            return True, msg, "his"
+        l = self.provider.session_dict[session_id]
+        max_page = len(l)//size_per_page + 1 if len(l)%size_per_page != 0 else len(l)//size_per_page
+        p = self.provider.get_prompts_by_cache_list(self.provider.session_dict[session_id], divide=True, paging=True, size=size_per_page, page=page)
+        return True, f"历史记录如下：\n{p}\n第{page}页 | 共{max_page}页\n*输入/his 2跳转到第2页", "his"
+    
+    def token(self, session_id: str):
+        return True, f"会话的token数: {self.provider.get_user_usage_tokens(self.provider.session_dict[session_id])}\n系统最大缓存token数: {self.provider.max_tokens}", "token"
+
+    def gpt(self):
+        return True, f"OpenAI GPT配置:\n {self.provider.chatGPT_configs}", "gpt"
+    
+    def status(self):
+        chatgpt_cfg_str = ""
+        key_stat = self.provider.get_key_stat()
+        index = 1
+        max = 9000000
+        gg_count = 0
+        total = 0
+        tag = ''
+        for key in key_stat.keys():
+            sponsor = ''
+            total += key_stat[key]['used']
+            if key_stat[key]['exceed']:
+                gg_count += 1
+                continue
+            if 'sponsor' in key_stat[key]:
+                sponsor = key_stat[key]['sponsor']
+            chatgpt_cfg_str += f"  |-{index}: {key_stat[key]['used']}/{max} {sponsor}赞助{tag}\n"
+            index += 1
+        return True, f"⭐使用情况({str(gg_count)}个已用):\n{chatgpt_cfg_str}⏰全频道已用{total}tokens", "status"
+
+    def count(self):
+        guild_count, guild_msg_count, guild_direct_msg_count, session_count = self.provider.get_stat()
+        return True, f"当前会话数: {len(self.provider.session_dict)}\n共有频道数: {guild_count} \n共有消息数: {guild_msg_count}\n私信数: {guild_direct_msg_count}\n历史会话数: {session_count}", "count"
+
+    def key(self, message: str, user_name: str):
+        l = message.split(" ")
+        if len(l) == 1:
+            msg = "感谢您赞助key，key为官方API使用，请以以下格式赞助:\n/key xxxxx"
+            return True, msg, "key"
+        key = l[1]
+        if self.provider.check_key(key):
+            self.provider.append_key(key, user_name)
+            return True, f"*★,°*:.☆(￣▽￣)/$:*.°★* 。\n该Key被验证为有效。感谢{user_name}赞助~"
+        else:
+            return True, "该Key被验证为无效。也许是输入错误了，或者重试。", "key"
+
+    def unset(self, session_id: str):
+        self.provider.now_personality = {}
+        self.provider.forget(session_id)
+        return True, "已清除人格并重置历史记录。", "unset"
+
+    def set(self, message: str, session_id: str):
+        l = message.split(" ")
+        if len(l) == 1:
+            return True, f"【由Github项目QQChannelChatGPT支持】\n\n【人格文本由PlexPt开源项目awesome-chatgpt-pr \
+        ompts-zh提供】\n\n这个是人格设置指令。\n设置人格: \n/set 人格名。例如/set 编剧\n人格列表: /set list\n人格详细信息: \
+        /set view 人格名\n自定义人格: /set 人格文本\n清除人格: /unset\n【当前人格】: {str(self.provider.now_personality)}", "set"
+        elif l[1] == "list":
+            msg = "人格列表：\n"
+            for key in personalities.keys():
+                msg += f"  |-{key}\n"
+            msg += '\n\n*输入/set view 人格名查看人格详细信息'
+            msg += '\n*不定时更新人格库，请及时更新本项目。'
+            return True, msg, "set"
+        elif l[1] == "view":
+            if len(l) == 2:
+                return True, "请输入/set view 人格名", "set"
+            ps = l[2].strip()
+            if ps in personalities:
+                msg = f"人格{ps}的详细信息：\n"
+                msg += f"{personalities[ps]}\n"
+            else:
+                msg = f"人格{ps}不存在"
+            return True, msg, "set"
+        else:
+            ps = l[1].strip()
+            if ps in personalities:
+                self.provider.now_personality = {
+                    'name': ps,
+                    'prompt': personalities[ps]
+                }
+                self.provider.session_dict[session_id] = []
+                new_record = {
+                    "user": {
+                        "role": "system",
+                        "content": personalities[ps],
+                    },
+                    'usage_tokens': 0,
+                    'single-tokens': 0
+                }
+                self.provider.session_dict[session_id].append(new_record)
+                return True, f"人格{ps}已设置.", "set"
+            else:
+                self.provider.now_personality = {
+                    'name': '自定义人格',
+                    'prompt': ps
+                }
+                new_record = {
+                    "user": {
+                        "role": "system",
+                        "content": ps,
+                    },
+                    'usage_tokens': 0,
+                    'single-tokens': 0
+                }
+                self.provider.session_dict[session_id] = []
+                self.provider.session_dict[session_id].append(new_record)
+                return True, f"自定义人格已设置。 \n人格信息: {ps}", "set"
+            
+    def draw(self, message):
+        try:
+            # 画图模式传回3个参数
+            img_url = self.provider.image_chat(message)
+            return True, img_url, "draw"
+        except Exception as e:
+            if 'exceeded' in str(e):
+                return f"OpenAI API错误。原因：\n{str(e)} \n超额了。可自己搭建一个机器人(Github仓库：QQChannelChatGPT)"
+            return False, f"图片生成失败: {e}", "draw"
+        
+    
+
+    
+    

model/command/command_rev_chatgpt.py

@@ -0,0 +1,35 @@
+from model.command.command import Command
+from model.provider.provider_rev_chatgpt import ProviderRevChatGPT
+
+class CommandRevChatGPT(Command):
+    def __init__(self, provider: ProviderRevChatGPT):
+        self.provider = provider
+        self.cached_plugins = {}
+
+    def check_command(self, 
+                      message: str, 
+                      role: str, 
+                      platform: str,
+                      message_obj,
+                      cached_plugins: dict):
+        hit, res = super().check_command(message, role, platform, message_obj=message_obj, cached_plugins=cached_plugins)
+        if hit:
+            return True, res
+        if self.command_start_with(message, "help", "帮助"):
+            return True, self.help()
+        elif self.command_start_with(message, "reset"):
+            return True, self.reset()
+        elif self.command_start_with(message, "update"):
+            return True, self.update(message, role)
+        elif self.command_start_with(message, "keyword"):
+            return True, self.keyword(message, role)
+        
+        if self.command_start_with(message, "/"):
+            return True, (False, "未知指令", "unknown_command")
+        return False, None
+    
+    def reset(self):
+        return False, "此功能暂未开放", "reset"
+    
+    def help(self):
+        return True, super().help_messager(super().general_commands()), "help"

model/command/command_rev_edgegpt.py

@@ -0,0 +1,43 @@
+from model.command.command import Command
+from model.provider.provider_rev_edgegpt import ProviderRevEdgeGPT
+import asyncio
+class CommandRevEdgeGPT(Command):
+    def __init__(self, provider: ProviderRevEdgeGPT):
+        self.provider = provider
+        self.cached_plugins = {}
+
+        
+    def check_command(self, 
+                      message: str, 
+                      loop, 
+                      role: str, 
+                      platform: str,
+                      message_obj,
+                      cached_plugins: dict):
+        hit, res = super().check_command(message, role, platform, message_obj=message_obj, cached_plugins=cached_plugins)
+        if hit:
+            return True, res
+        if self.command_start_with(message, "reset"):
+            return True, self.reset(loop)
+        elif self.command_start_with(message, "help"):
+            return True, self.help()
+        elif self.command_start_with(message, "update"):
+            return True, self.update(message, role)
+        elif self.command_start_with(message, "keyword"):
+            return True, self.keyword(message, role)
+        
+        if self.command_start_with(message, "/"):
+            return True, (False, "未知指令", "unknown_command")
+        return False, None
+    
+    def reset(self, loop):
+        res = asyncio.run_coroutine_threadsafe(self.provider.forget(), loop).result()
+        print(res)
+        if res:
+            return res, "重置成功", "reset"
+        else:
+            return res, "重置失败", "reset"
+    
+    def help(self):
+        return True, super().help_messager(super().general_commands()), "help"
+        

model/platform/qq.py

@@ -0,0 +1,44 @@
+from nakuru.entities.components import Plain, At, Image
+
+class QQ:
+    def run_bot(self, gocq):
+        self.client = gocq
+        self.client.run()
+
+    async def send_qq_msg(self, 
+                          source, 
+                          res, 
+                          image_mode: bool = False):
+        """
+         res可以是一个数组，也就是gocq的消息链.
+        """
+
+        # print(res)
+        print("[System-Info] 回复QQ消息中..."+str(res))
+
+        if isinstance(res, list) and len(res) > 0:
+            await self.client.sendGroupMessage(source.group_id, res)
+            return
+        # 通过消息链处理
+        if not image_mode:
+            if source.type == "GroupMessage":
+                await self.client.sendGroupMessage(source.group_id, [
+                    At(qq=source.user_id),
+                    Plain(text=res)
+                ])
+            elif source.type == "FriendMessage":
+                await self.client.sendFriendMessage(source.user_id, [
+                    Plain(text=res)
+                ])
+        else:
+            if source.type == "GroupMessage":
+                await self.client.sendGroupMessage(source.group_id, [
+                    At(qq=source.user_id),
+                    Plain(text="好的，我根据你的需要为你生成了一张图片😊"),
+                    Image.fromURL(url=res)
+                ])
+            elif source.type == "FriendMessage":
+                await self.client.sendFriendMessage(source.user_id, [
+                    Plain(text="好的，我根据你的需要为你生成了一张图片😊"),
+                    Image.fromURL(url=res)
+                ])

model/platform/qqchan.py

@@ -0,0 +1,64 @@
+import io
+import botpy
+from PIL import Image
+from botpy.message import Message, DirectMessage
+import re
+import asyncio
+import requests
+from cores.qqbot.personality import personalities
+
+
+class QQChan():
+
+    def run_bot(self, botclient, appid, token):
+        intents = botpy.Intents(public_guild_messages=True, direct_message=True) 
+        self.client = botclient
+        self.client.run(appid=appid, token=token)
+
+    def send_qq_msg(self, message, res, image_mode=False, msg_ref = None):
+        print("[System-Info] 回复QQ频道消息中..."+str(res))
+        if not image_mode:
+            try:
+                if msg_ref is not None:
+                    reply_res = asyncio.run_coroutine_threadsafe(message.reply(content=str(res), message_reference = msg_ref), self.client.loop)
+                else:
+                    reply_res = asyncio.run_coroutine_threadsafe(message.reply(content=str(res)), self.client.loop)
+                reply_res.result()
+            except BaseException as e:
+                # 分割过长的消息
+                if "msg over length" in str(e):
+                    split_res = []
+                    split_res.append(res[:len(res)//2])      
+                    split_res.append(res[len(res)//2:])
+                    for i in split_res:
+                        if msg_ref is not None:
+                            reply_res = asyncio.run_coroutine_threadsafe(message.reply(content=i, message_reference = msg_ref), self.client.loop)
+                        else:
+                            reply_res = asyncio.run_coroutine_threadsafe(message.reply(content=i), self.client.loop)
+                        reply_res.result()
+                else:
+                    # 发送qq信息
+                    try:
+                        # 防止被qq频道过滤消息
+                        res = res.replace(".", " . ")
+                        asyncio.run_coroutine_threadsafe(message.reply(content=res), self.client.loop).result()
+                        # 发送信息
+                    except BaseException as e:
+                        print("QQ频道API错误: \n"+str(e))
+                        res = str.join(" ", res)
+                        try:
+                            asyncio.run_coroutine_threadsafe(message.reply(content=res), self.client.loop).result()
+                        except BaseException as e:
+                            # 如果还是不行则报出错误
+                            res = re.sub(r'(https|http)?:\/\/(\w|\.|\/|\?|\=|\&|\%)*\b', '[被隐藏的链接]', str(e), flags=re.MULTILINE)
+                            res = res.replace(".", "·")
+                            asyncio.run_coroutine_threadsafe(message.reply(content=res), self.client.loop).result()
+                            # send(message, f"QQ频道API错误：{str(e)}\n下面是格式化后的回答：\n{f_res}")
+        else:
+            pic_res = requests.get(str(res), stream=True)
+            if pic_res.status_code == 200:
+                # 将二进制数据转换成图片对象
+                image = Image.open(io.BytesIO(pic_res.content))
+                # 保存图片到本地
+                image.save('tmp_image.jpg')
+            asyncio.run_coroutine_threadsafe(message.reply(file_image='tmp_image.jpg', content=""), self.client.loop)

model/provider/provider.py

@@ -0,0 +1,18 @@
+import abc
+
+class Provider:
+    def __init__(self, cfg):
+        pass
+
+    def text_chat(self, prompt):
+        pass
+
+    def image_chat(self, prompt):
+        pass
+
+    def memory(self):
+        pass
+
+    @abc.abstractmethod
+    def forget(self) -> bool:
+        pass

model/provider/provider_openai_official.py

@@ -0,0 +1,398 @@
+import openai
+import json
+import time
+import os
+import sys
+from cores.database.conn import dbConn
+from model.provider.provider import Provider
+import threading
+
+abs_path = os.path.dirname(os.path.realpath(sys.argv[0])) + '/'
+key_record_path = abs_path+'chatgpt_key_record'
+
+class ProviderOpenAIOfficial(Provider):
+    def __init__(self, cfg):
+        self.key_list = []
+        if 'api_base' in cfg and cfg['api_base'] != 'none' and cfg['api_base'] != '':
+            openai.api_base = cfg['api_base']
+        if cfg['key'] != '' and cfg['key'] != None:
+            print("[System] 读取ChatGPT Key成功")
+            self.key_list = cfg['key']
+        else:
+            input("[System] 请先去完善ChatGPT的Key。详情请前往https://beta.openai.com/account/api-keys")
+        
+        # init key record
+        self.init_key_record()
+
+        self.chatGPT_configs = cfg['chatGPTConfigs']
+        print(f'[System] 加载ChatGPTConfigs: {self.chatGPT_configs}')
+        self.openai_configs = cfg
+        # 会话缓存
+        self.session_dict = {}
+        # 最大缓存token
+        self.max_tokens = cfg['total_tokens_limit']
+        # 历史记录持久化间隔时间
+        self.history_dump_interval = 20
+
+        # 读取历史记录
+        try:
+            db1 = dbConn()
+            for session in db1.get_all_session():
+                self.session_dict[session[0]] = json.loads(session[1])['data']
+            print("[System] 历史记录读取成功喵")
+        except BaseException as e:
+            print("[System] 历史记录读取失败: " + str(e))
+
+        # 读取统计信息
+        if not os.path.exists(abs_path+"configs/stat"):
+            with open(abs_path+"configs/stat", 'w', encoding='utf-8') as f:
+                    json.dump({}, f)
+        self.stat_file = open(abs_path+"configs/stat", 'r', encoding='utf-8')
+        global count
+        res = self.stat_file.read()
+        if res == '':
+            count = {}
+        else:
+            try: 
+                count = json.loads(res)
+            except BaseException:
+                pass
+
+        # 创建转储定时器线程
+        threading.Thread(target=self.dump_history, daemon=True).start()
+
+        # 人格
+        self.now_personality = {}
+
+
+    # 转储历史记录的定时器~ Soulter
+    def dump_history(self):
+        time.sleep(10)
+        db = dbConn()
+        while True:
+            try:
+                # print("转储历史记录...")
+                for key in self.session_dict:
+                    # print("TEST: "+str(db.get_session(key)))
+                    data = self.session_dict[key]
+                    data_json = {
+                        'data': data
+                    }
+                    if db.check_session(key):
+                        db.update_session(key, json.dumps(data_json))
+                    else:
+                        db.insert_session(key, json.dumps(data_json))
+                # print("转储历史记录完毕")
+            except BaseException as e:
+                print(e)
+            # 每隔10分钟转储一次
+            time.sleep(10*self.history_dump_interval)
+
+    def text_chat(self, prompt, session_id):
+        # 会话机制
+        if session_id not in self.session_dict:
+            self.session_dict[session_id] = []
+
+            fjson = {}
+            try:
+                f = open(abs_path+"configs/session", "r", encoding="utf-8")
+                fjson = json.loads(f.read())
+                f.close()
+            except:
+                pass
+            finally:
+                fjson[session_id] = 'true'
+                f = open(abs_path+"configs/session", "w", encoding="utf-8")
+                f.write(json.dumps(fjson))
+                f.flush()
+                f.close()
+
+        cache_data_list, new_record, req = self.wrap(prompt, session_id)
+        retry = 0
+        response = None
+        while retry < 5:
+            try:
+                response = openai.ChatCompletion.create(
+                    messages=req,
+                    **self.chatGPT_configs
+                )
+                break
+            except Exception as e:
+                print(e)
+                if 'You exceeded' in str(e) or 'Billing hard limit has been reached' in str(e) or 'No API key provided' in str(e) or 'Incorrect API key provided' in str(e):
+                    print("[System] 当前Key已超额或者不正常,正在切换")
+                    self.key_stat[openai.api_key]['exceed'] = True
+                    self.save_key_record()
+
+                    response, is_switched = self.handle_switch_key(req)
+                    if not is_switched:
+                        # 所有Key都超额或不正常
+                        raise e
+                    else:
+                        break
+                if 'maximum context length' in str(e):
+                    print("token超限, 清空对应缓存")
+                    self.session_dict[session_id] = []
+                    cache_data_list, new_record, req = self.wrap(prompt, session_id)
+                retry+=1
+        if retry >= 5:
+            raise BaseException("连接超时")
+        
+        self.key_stat[openai.api_key]['used'] += response['usage']['total_tokens']
+        self.save_key_record()
+        print("[ChatGPT] "+str(response["choices"][0]["message"]["content"]))
+        chatgpt_res = str(response["choices"][0]["message"]["content"]).strip()
+        current_usage_tokens = response['usage']['total_tokens']
+
+        # 超过指定tokens， 尽可能的保留最多的条目，直到小于max_tokens
+        if current_usage_tokens > self.max_tokens:
+            t = current_usage_tokens
+            index = 0
+            while t > self.max_tokens:
+                if index >= len(cache_data_list):
+                    break
+                # 保留人格信息
+                if 'user' in cache_data_list[index] and cache_data_list[index]['user']['role'] != 'system':
+                    t -= int(cache_data_list[index]['single_tokens'])
+                    del cache_data_list[index]
+                else:
+                    index += 1
+            # 删除完后更新相关字段
+            self.session_dict[session_id] = cache_data_list
+            # cache_prompt = get_prompts_by_cache_list(cache_data_list)
+
+        # 添加新条目进入缓存的prompt
+        new_record['AI'] = {
+            'role': 'assistant',
+            'content': chatgpt_res,
+        }
+        new_record['usage_tokens'] = current_usage_tokens
+        if len(cache_data_list) > 0:
+            new_record['single_tokens'] = current_usage_tokens - int(cache_data_list[-1]['usage_tokens'])
+        else:
+            new_record['single_tokens'] = current_usage_tokens
+        cache_data_list.append(new_record)
+
+        self.session_dict[session_id] = cache_data_list
+
+        return chatgpt_res
+        
+    def image_chat(self, prompt, img_num = 1, img_size = "1024x1024"):
+        retry = 0
+        image_url = ''
+        while retry < 5:
+            try:
+                # print("test1")
+                response = openai.Image.create(
+                    prompt=prompt,
+                    n=img_num,
+                    size=img_size
+                )
+                # print("test2")
+                image_url = []
+                for i in range(img_num):
+                    image_url.append(response['data'][i]['url'])
+                print(image_url)
+                break
+            except Exception as e:
+                print(e)
+                if 'You exceeded' in str(e) or 'Billing hard limit has been reached' in str(
+                        e) or 'No API key provided' in str(e) or 'Incorrect API key provided' in str(e):
+                    print("[System] 当前Key已超额或者不正常,正在切换")
+                    self.key_stat[openai.api_key]['exceed'] = True
+                    self.save_key_record()
+
+                    response, is_switched = self.handle_switch_key(req)
+                    if not is_switched:
+                        # 所有Key都超额或不正常
+                        raise e
+                    else:
+                        break
+                retry += 1
+        if retry >= 5:
+            raise BaseException("连接超时")
+                
+        return image_url
+
+    def forget(self, session_id) -> bool:
+        self.session_dict[session_id] = []
+        return True
+    
+    '''
+    获取缓存的会话
+    '''
+    def get_prompts_by_cache_list(self, cache_data_list, divide=False, paging=False, size=5, page=1):
+        prompts = ""
+        if paging:
+            page_begin = (page-1)*size
+            page_end = page*size
+            if page_begin < 0:
+                page_begin = 0
+            if page_end > len(cache_data_list):
+                page_end = len(cache_data_list)
+            cache_data_list = cache_data_list[page_begin:page_end]
+        for item in cache_data_list:
+            prompts += str(item['user']['role']) + ":\n" + str(item['user']['content']) + "\n"
+            prompts += str(item['AI']['role']) + ":\n" + str(item['AI']['content']) + "\n"
+
+            if divide:
+                prompts += "----------\n"
+        return prompts
+    
+        
+    def get_user_usage_tokens(self,cache_list):
+        usage_tokens = 0
+        for item in cache_list:
+            usage_tokens += int(item['single_tokens'])
+        return usage_tokens
+        
+    '''
+    获取统计信息
+    '''
+    def get_stat(self):
+        try:
+            f = open(abs_path+"configs/stat", "r", encoding="utf-8")
+            fjson = json.loads(f.read())
+            f.close()
+            guild_count = 0
+            guild_msg_count = 0
+            guild_direct_msg_count = 0
+
+            for k,v in fjson.items():
+                guild_count += 1
+                guild_msg_count += v['count']
+                guild_direct_msg_count += v['direct_count']
+            
+            session_count = 0
+
+            f = open(abs_path+"configs/session", "r", encoding="utf-8")
+            fjson = json.loads(f.read())
+            f.close()
+            for k,v in fjson.items():
+                session_count += 1
+            return guild_count, guild_msg_count, guild_direct_msg_count, session_count
+        except:
+            return -1, -1, -1, -1
+
+    # 包装信息
+    def wrap(self, prompt, session_id):
+        # 获得缓存信息
+        context = self.session_dict[session_id]
+        new_record = {
+            "user": {
+                "role": "user",
+                "content": prompt,
+            },
+            "AI": {},
+            'usage_tokens': 0,
+        }
+        req_list = []
+        for i in context:
+            if 'user' in i:
+                req_list.append(i['user'])
+            if 'AI' in i:
+                req_list.append(i['AI'])
+        req_list.append(new_record['user'])
+        return context, new_record, req_list
+    
+    def handle_switch_key(self, req):
+        # messages = [{"role": "user", "content": prompt}]
+        while True:
+            is_all_exceed = True
+            for key in self.key_stat:
+                if key == None:
+                    continue
+                if not self.key_stat[key]['exceed']:
+                    is_all_exceed = False
+                    openai.api_key = key
+                    print(f"[System] 切换到Key: {key}, 已使用token: {self.key_stat[key]['used']}")
+                    if len(req) > 0:
+                        try:
+                            response = openai.ChatCompletion.create(
+                                messages=req,
+                                **self.chatGPT_configs
+                            )
+                            return response, True
+                        except Exception as e:
+                            print(e)
+                            if 'You exceeded' in str(e):
+                                print("[System] 当前Key已超额,正在切换")
+                                self.key_stat[openai.api_key]['exceed'] = True
+                                self.save_key_record()
+                                time.sleep(1)
+                                continue
+                    else:
+                        return True
+            if is_all_exceed:
+                print("[System] 所有Key已超额")
+                return None, False
+            else:
+                print("[System] 在切换key时程序异常。")
+                return None, False
+                
+    def getConfigs(self):
+        return self.openai_configs
+    
+    def save_key_record(self):
+        with open(key_record_path, 'w', encoding='utf-8') as f:
+            json.dump(self.key_stat, f)
+
+    def get_key_stat(self):
+        return self.key_stat
+    def get_key_list(self):
+        return self.key_list
+    
+    # 添加key
+    def append_key(self, key, sponsor):
+        self.key_list.append(key)
+        self.key_stat[key] = {'exceed': False, 'used': 0, 'sponsor': sponsor}
+        self.save_key_record()
+        self.init_key_record()
+
+    # 检查key是否可用
+    def check_key(self, key):
+        pre_key = openai.api_key
+        openai.api_key = key
+        messages = [{"role": "user", "content": "1"}]
+        try:
+            response = openai.ChatCompletion.create(
+                messages=messages,
+                **self.chatGPT_configs
+            )
+            openai.api_key = pre_key
+            return True
+        except Exception as e:
+            pass
+        openai.api_key = pre_key
+        return False
+
+    #将key_list的key转储到key_record中，并记录相关数据
+    def init_key_record(self):
+        if not os.path.exists(key_record_path):
+            with open(key_record_path, 'w', encoding='utf-8') as f:
+                json.dump({}, f)
+        with open(key_record_path, 'r', encoding='utf-8') as keyfile:
+            try:
+                self.key_stat = json.load(keyfile)
+            except Exception as e:
+                print(e)
+                self.key_stat = {}
+            finally:
+                for key in self.key_list:
+                    if key not in self.key_stat:
+                        self.key_stat[key] = {'exceed': False, 'used': 0}
+                        # if openai.api_key is None:
+                        #     openai.api_key = key
+                    else:
+                        # if self.key_stat[key]['exceed']:
+                        #     print(f"Key: {key} 已超额")
+                        #     continue
+                        # else:
+                        #     if openai.api_key is None:
+                        #         openai.api_key = key
+                        #         print(f"使用Key: {key}, 已使用token: {self.key_stat[key]['used']}")
+                        pass
+                if openai.api_key == None:
+                    self.handle_switch_key("")
+            self.save_key_record()
+

model/provider/provider_rev_chatgpt.py

@@ -0,0 +1,80 @@
+from revChatGPT.V1 import Chatbot
+from revChatGPT import typings
+from model.provider.provider import Provider
+
+class ProviderRevChatGPT(Provider):
+    def __init__(self, config):
+        self.rev_chatgpt = []
+        for i in range(0, len(config['account'])):
+            try:
+                print(f"[System] 创建rev_ChatGPT负载{str(i)}中...")
+                if 'password' in config['account'][i]:
+                    config['account'][i]['password'] = str(config['account'][i]['password'])
+                revstat = {
+                    'obj': Chatbot(config=config['account'][i]),
+                    'busy': False
+                }
+                self.rev_chatgpt.append(revstat)
+            except BaseException as e:
+                print(f"[System] 创建rev_ChatGPT负载失败: {str(e)}")
+
+    def forget(self) -> bool:
+        return False
+    
+    def request_text(self, prompt: str, bot) -> str:
+        resp = ''
+        err_count = 0
+        retry_count = 5
+
+        while err_count < retry_count:
+            try:
+                for data in bot.ask(prompt):
+                    resp = data["message"]
+                break
+            except typings.Error as e:
+                if e.code == typings.ErrorType.RATE_LIMIT_ERROR:
+                    raise e
+                if e.code == typings.ErrorType.INVALID_ACCESS_TOKEN_ERROR:
+                    raise e
+                if e.code == typings.ErrorType.EXPIRED_ACCESS_TOKEN_ERROR:
+                    raise e
+                if e.code == typings.ErrorType.PROHIBITED_CONCURRENT_QUERY_ERROR:
+                    raise e
+                
+                err_count += 1
+                print(f"[RevChatGPT] 请求出现问题: {str(e)} | 正在重试: {str(err_count)}")
+                if err_count >= retry_count:
+                    raise e
+            except BaseException as e:
+                err_count += 1
+                print(f"[RevChatGPT] 请求出现问题: {str(e)} | 正在重试: {str(err_count)}")
+                if err_count >= retry_count:
+                    raise e
+        
+        print("[RevChatGPT] "+str(resp))
+        return resp
+
+    def text_chat(self, prompt):
+        res = ''
+        print("[Debug] "+str(self.rev_chatgpt))
+        err_msg = ''
+        cursor = 0
+        for revstat in self.rev_chatgpt:
+            cursor += 1
+            if not revstat['busy']:
+                try:
+                    revstat['busy'] = True
+                    res = self.request_text(prompt, revstat['obj'])
+                    revstat['busy'] = False
+                    return res.strip()
+                # todo: 细化错误管理
+                except BaseException as e:
+                    revstat['busy'] = False
+                    print(f"请求出现问题: {str(e)}")
+                    err_msg += f"账号{cursor} - 错误原因: {str(e)}"
+                    continue
+            else:
+                err_msg += f"账号{cursor} - 错误原因: 忙碌"
+                continue
+        res = f'回复失败。错误跟踪：{err_msg}'
+        return res

model/provider/provider_rev_edgegpt.py

@@ -0,0 +1,90 @@
+from model.provider.provider import Provider
+from EdgeGPT import Chatbot, ConversationStyle
+import json
+import os
+
+class ProviderRevEdgeGPT(Provider):
+    def __init__(self):
+        self.busy = False
+        self.wait_stack = []
+        with open('./cookies.json', 'r') as f:
+            cookies = json.load(f)
+        self.bot = Chatbot(cookies=cookies)
+
+    def is_busy(self):
+        return self.busy
+
+    async def forget(self):
+        try:
+            await self.bot.reset()
+            return True
+        except BaseException:
+            return False
+        
+    async def text_chat(self, prompt, platform = 'none'):
+        if self.busy:
+             return
+        self.busy = True
+        resp = 'err'
+        err_count = 0
+        retry_count = 5
+        
+        while err_count < retry_count:
+            try:
+                resp = await self.bot.ask(prompt=prompt, conversation_style=ConversationStyle.creative)
+                # print("[RevEdgeGPT] "+str(resp))
+                if 'messages' not in resp['item']:
+                    await self.bot.reset()
+                msj_obj = resp['item']['messages'][len(resp['item']['messages'])-1]
+                reply_msg = msj_obj['text']
+                if 'sourceAttributions' in msj_obj:
+                    reply_source = msj_obj['sourceAttributions']
+                else:
+                    reply_source = []
+                if 'throttling' in resp['item']:
+                    throttling = resp['item']['throttling']
+                    # print(throttling)
+                else:
+                    throttling = None
+                if 'I\'m sorry but I prefer not to continue this conversation. I\'m still learning so I appreciate your understanding and patience.' in reply_msg:
+                    self.busy = False
+                    return '', 0
+                if reply_msg == prompt:
+                    # resp += '\n\n如果你没有让我复述你的话，那代表我可能不想和你继续这个话题了，请输入reset重置会话😶'
+                    await self.forget()
+                    err_count += 1
+                    continue
+                if reply_source is None:
+                    # 不想答复
+                    return '', 0
+                else:
+                    if platform != 'qqchan':
+                        index = 1
+                        if len(reply_source) > 0:
+                            reply_msg += "\n\n信息来源:\n"
+                        for i in reply_source:
+                            reply_msg += f"[{str(index)}]: {i['seeMoreUrl']} | {i['providerDisplayName']}\n"
+                            index += 1
+                if throttling is not None:
+                    if throttling['numUserMessagesInConversation'] == throttling['maxNumUserMessagesInConversation']:
+                        # 达到上限，重置会话
+                        await self.forget()
+                    if throttling['numUserMessagesInConversation'] > throttling['maxNumUserMessagesInConversation']:
+                        await self.forget()
+                        err_count += 1
+                        continue
+                    reply_msg += f"\n⌈{throttling['numUserMessagesInConversation']}/{throttling['maxNumUserMessagesInConversation']}⌋"
+                break
+            except BaseException as e:
+                # raise e
+                print(e)
+                err_count += 1
+                if err_count >= retry_count:
+                        self.busy = False
+                        raise e
+                print("[RevEdgeGPT] 请求出现了一些问题, 正在重试。次数"+str(err_count))
+        self.busy = False
+        
+        print("[RevEdgeGPT] "+str(reply_msg))
+        return reply_msg, 1
+    

requirements.txt

@@ -1,3 +1,10 @@
-requests~=2.28.2
+requests~=2.28.1
-openai~=0.26.5
+openai~=0.27.4
 qq-botpy~=1.1.2
+revChatGPT~=5.0.0
+baidu-aip~=4.16.9
+EdgeGPT~=0.1.22.1
+chardet~=5.1.0
+Pillow~=9.4.0
+GitPython~=3.1.31
+nakuru-project-idk~=0.0.2

util/log.py

@@ -0,0 +1,11 @@
+import logging
+from logging.handlers import RotatingFileHandler
+import colorlog
+
+logger = logging.getLogger("QQChannelChatGPT")
+logger.setLevel(logging.DEBUG)
+handler = colorlog.StreamHandler()
+fmt = "%(log_color)s[%(name)s] %(message)s"
+handler.setFormatter(colorlog.ColoredFormatter(
+ fmt))
+logger.addHandler(handler)

util/plugin_util.py

@@ -0,0 +1,22 @@
+import os
+import inspect
+
+# 找出模块里所有的类名
+def get_classes(p_name, arg):
+    classes = []
+    clsmembers = inspect.getmembers(arg, inspect.isclass)
+    for (name, _) in clsmembers:
+        # print(name, p_name)
+        if p_name.lower() == name.lower().replace("plugin", ""):
+            classes.append(name)
+            break
+    return classes
+
+# 获取一个文件夹下所有的模块
+def get_modules(path):
+    modules = []
+    for root, dirs, files in os.walk(path):
+        for file in files:
+            if file.endswith(".py") and not file.startswith("__"):
+                modules.append(file[:-3])
+    return modules

webapp_replit.py

@@ -0,0 +1,25 @@
+from flask import Flask
+from threading import Thread
+import datetime
+
+app = Flask(__name__)
+
+
+@app.route('/')
+def main_func():
+  content = "<h1>QQChannelChatGPT Web APP</h1>"
+
+  content += "<p>" + "Online @ " + str(datetime.datetime.now()) + "</p>"
+  content += "<p>欢迎Star本项目！！！</p>"
+  return content
+
+
+def run():
+  app.run(host="0.0.0.0", port=8080)
+  
+
+
+
+def keep_alive():
+  server = Thread(target=run)
+  server.start()