Merge pull request #48 from Soulter/42-openai_api_domain_customization

fix: 解决newbing换话题的问题；解决newbing回复慢的问题

README.md

@@ -1,19 +1,22 @@
-<div align="center">
- 
-![QQChannelChatGPT](https://socialify.git.ci/Soulter/QQChannelChatGPT/image?description=1&font=Inter&forks=1&issues=1&language=1&name=1&logo=https%3A%2F%2Fgithub.com%2Ftencent-connect%2Fbot-docs%2Fblob%2Fmain%2Fdocs%2F.vuepress%2Fpublic%2Ffavicon-64px.png%3Fraw%3Dtrue&owner=1&pattern=Plus&stargazers=1&theme=Light)
-
-</div>
-
 ## ⭐体验
-扫码加入QQ频道
 
-![image](https://user-images.githubusercontent.com/37870767/210030647-c4c00f31-8ccc-4bd2-835a-b5af9ab31496.png)
+使用手机QQ扫码加入QQ频道(频道名: GPT机器人 | 频道号: x42d56aki2)
 
-欢迎Star本项目
- 
+<img src="https://user-images.githubusercontent.com/37870767/227197121-4f1e02a4-92fd-4497-8768-9d6977a291b7.jpg" width="200"></img>
+
+**Windows用户推荐Windows一键安装，请前往Release下载最新版本**
+
+详细部署教程链接：https://soulter.top/posts/qpdg.html
+
+有网络问题报错的请先看issue，解决不了再加频道反馈
 
 ## ⭐功能：
 
+- 逆向ChatGPT库
+- 官方ChatGPT AI
+- 文心一言（即将支持，链接https://github.com/Soulter/ERNIEBot 欢迎Star）
+- NewBing（即将支持）
+
 ### 基本功能
 <details> 
  <summary>✅ 回复符合上下文</summary>
@@ -55,7 +58,7 @@
  </details>
 
 <details> 
- <summary>✅ 支持指令控制</summary> 
+ <summary>✅ 支持多种指令控制</summary> 
   
    -  详见下方`指令功能`
   
@@ -79,16 +82,24 @@
 - `/token`查看当前缓存的总token数
 - `/count` 查看统计
 - `/status` 查看chatGPT的配置
+- `/help` 查看帮助
+- `/key` 动态添加key
+- `/set` 人格设置面板
 
 ## 📰使用方法：
 
+**详细部署教程链接**https://soulter.top/posts/qpdg.html
+
 ### 安装第三方库
 
 使用Python的pip工具安装
 - `qq-botpy` （QQ频道官方Python SDK）
-- `openai` (OpenAI 库)
+- `openai` (OpenAI Python SDK)
 
-> ⚠注意，由于qq-botpy需要运行在`Python 3.8+`的版本上，因此本项目也需要在此之上运行
+```shell
+pip install -r requirements.txt
+```
+> ⚠注意，由于qq-botpy库需要运行在`Python 3.8+`的版本上，因此本项目也需要在此之上运行
 
 ### 配置
 
@@ -99,8 +110,6 @@
 ### 启动
 - 启动main.py
 
-## 赞助
-⭐[爱发电](https://afdian.net/a/soulter)⭐
 
 ## DEMO
 ![1.jpg](screenshots/1.jpg)

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/revChatGPT/revchatgpt.py

@@ -0,0 +1,45 @@
+from revChatGPT.V1 import Chatbot
+
+class revChatGPT:
+    def __init__(self, config):
+        
+        if 'password' in config:
+            config['password'] = str(config['password'])
+        self.chatbot = Chatbot(config=config)
+
+    def chat(self, prompt):
+        resp = ''
+
+        """
+        Base class for exceptions in this module.
+        Error codes:
+        -1: User error
+        0: Unknown error
+        1: Server error
+        2: Rate limit error
+        3: Invalid request error
+        4: Expired access token error
+        5: Invalid access token error
+        6: Prohibited concurrent query error
+        """
+
+
+        err_count = 0
+        retry_count = 5
+
+        while err_count < retry_count:
+            try:
+                for data in self.chatbot.ask(prompt):
+                    resp = data["message"]
+                break
+            except BaseException as e:
+                try:
+                    print("[RevChatGPT] 请求出现了一些问题, 正在重试。次数"+str(err_count))
+                    err_count += 1
+                    if err_count >= retry_count:
+                        raise e
+                except BaseException:
+                    err_count += 1
+        
+        print("[RevChatGPT] "+str(resp))
+        return resp

addons/revEdgeGPT/revedgegpt.py

@@ -0,0 +1,47 @@
+import asyncio
+from EdgeGPT import Chatbot, ConversationStyle
+import json
+
+class revEdgeGPT:
+    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 reset(self):
+        try:
+            await self.bot.reset()
+            return False
+        except BaseException:
+            return True
+
+    async def chat(self, prompt):
+        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)
+                resp = resp['item']['messages'][len(resp['item']['messages'])-1]['text']
+                if resp == prompt:
+                    resp += '\n\n如果你没有让我复述你的话，那代表我可能不想和你继续这个话题了，请输入/reset重置会话😶'
+                break
+            except BaseException as e:
+                print(e.with_traceback)
+                err_count += 1
+                if err_count >= retry_count:
+                        raise e
+                print("[RevEdgeGPT] 请求出现了一些问题, 正在重试。次数"+str(err_count))
+        self.busy = False
+        
+        print("[RevEdgeGPT] "+str(resp))
+        return resp

configs/config.yaml

@@ -1,29 +1,98 @@
+# 如果你不知道怎么部署，请务必查看https://soulter.top/posts/qpdg.html
+
+# 注意：已支持多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:
-  # 注意：在1.7版本已支持多key自动切换，方法：
-  # key:
-  #   - xxxxx
-  #   - xxxxxx
-  # 在下方非注释的地方使用以上格式
   key: 
     - 
+  api_base: none
+  # 这里是GPT配置，语言模型默认使用gpt-3.5-turbo
   chatGPTConfigs:
-    engine: text-davinci-003
-    max_tokens: 800
-    temperature: 0.8
+    model: gpt-3.5-turbo
+    max_tokens: 3000
+    temperature: 0.9
     top_p: 1
-    frequency_penalty: 0.4
-    presence_penalty: 0.3
-  total_tokens_limit: 700
+    frequency_penalty: 0
+    presence_penalty: 0
+    
+  total_tokens_limit: 5000
 
+# QQ开放平台的appid和令牌
+# q.qq.com
 qqbot:
   appid: 
   token: 
 
 # 设置是否一个人一个会话
 uniqueSessionMode: false
-
-# QChannelBot 的版本
-version: 1.7 beta
-
+# QChannelBot 的版本，请勿修改此字段，否则可能产生一些bug
+version: 2.8
 # [Beta] 转储历史记录时间间隔(分钟)
-dump_history_interval: 10
+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
+
+
+################外带程序（插件）################
+
+# 百度内容审核服务
+# 新用户免费5万次调用。https://cloud.baidu.com/doc/ANTIPORN/index.html
+baidu_aip:
+  enable: false
+  app_id: 
+  api_key: 
+  secret_key: 
+
+# 逆向文心一言【暂时不可用，请勿使用】
+rev_ernie:
+  enable: false
+
+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个账户密码
+#   - ....
+# 支持使用session_token\access_token登录
+# 例：
+# - session_token: xxxxx
+# - access_token: xxxx
+# 请严格按照上面这个格式填写。
+
+rev_ChatGPT:
+  enable: false
+  account:
+    - email: 
+      password: 

cores/openai/core.py

@@ -12,91 +12,74 @@ abs_path = os.path.dirname(os.path.realpath(sys.argv[0])) + '/'
 key_record_path = abs_path+'chatgpt_key_record'
 
 class ChatGPT:
-    def __init__(self):
+    def __init__(self, cfg):
         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'] != '':
-                print("读取ChatGPT Key成功")
-                self.key_list = cfg['openai']['key']
-                print(f"Key列表: {self.key_list}")
-                # openai.api_key = cfg['openai']['key']
-            else:
-                print("请先去完善ChatGPT的Key。详情请前往https://beta.openai.com/account/api-keys")
+        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']
+            # openai.api_key = cfg['key']
+        else:
+            input("[System] 请先去完善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}')
+        chatGPT_configs = cfg['chatGPTConfigs']
+        print(f'[System] 加载ChatGPTConfigs: {chatGPT_configs}')
         self.chatGPT_configs = chatGPT_configs
-        self.openai_configs = cfg['openai']
-        global inst
-        inst = self
+        self.openai_configs = cfg
     
-    def chat(self, prompt, image_mode = False):
+    def chat(self, req, image_mode = False):
+        # ChatGPT API 2023/3/2
+        # messages = [{"role": "user", "content": prompt}]
         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",
-                )
+            response = openai.ChatCompletion.create(
+                messages=req,
+                **self.chatGPT_configs
+            )
         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已超额，正在切换")
+            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(prompt)
+                response, is_switched = self.handle_switch_key(req)
                 if not is_switched:
-                    # 所有Key都超额
+                    # 所有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] "+response["choices"][0]["text"])
-            return response["choices"][0]["text"].strip(), response['usage']['total_tokens']
-        else:
-            return response['data'][0]['url']
+                response = openai.ChatCompletion.create(
+                    messages=req,
+                    **self.chatGPT_configs
+                )
+        self.key_stat[openai.api_key]['used'] += response['usage']['total_tokens']
+        self.save_key_record()
+        print("[ChatGPT] "+str(response["choices"][0]["message"]["content"]))
+        return str(response["choices"][0]["message"]["content"]).strip(), response['usage']['total_tokens']
             
-    def handle_switch_key(self, prompt):
+    def handle_switch_key(self, req):
+        # messages = [{"role": "user", "content": 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 != '':
+                    print(f"[System] 切换到Key: {key}, 已使用token: {self.key_stat[key]['used']}")
+                    if len(req) > 0:
                         try:
-                            response = openai.Completion.create(
-                                prompt=prompt,
+                            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("当前Key已超额，正在切换")
+                                print("[System] 当前Key已超额,正在切换")
                                 self.key_stat[openai.api_key]['exceed'] = True
                                 self.save_key_record()
                                 time.sleep(1)
@@ -104,7 +87,7 @@ class ChatGPT:
                     else:
                         return True
             if is_all_exceed:
-                print("所有Key已超额")
+                print("[System] 所有Key已超额")
                 return None, False
                 
     def getConfigs(self):
@@ -129,9 +112,10 @@ class ChatGPT:
     def check_key(self, key):
         pre_key = openai.api_key
         openai.api_key = key
+        messages = [{"role": "user", "content": "1"}]
         try:
-            openai.Completion.create(
-                prompt="test",
+            response = openai.ChatCompletion.create(
+                messages=messages,
                 **self.chatGPT_configs
             )
             openai.api_key = pre_key
@@ -141,7 +125,7 @@ class ChatGPT:
         openai.api_key = pre_key
         return False
 
-    # 将key_list的key转储到key_record中，并记录相关数据
+    #将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:
@@ -156,20 +140,17 @@ class ChatGPT:
                 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
+                        # 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']}")
+                        # 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()
-
-def getInst() -> ChatGPT:
-    global inst
-    return inst
+            self.save_key_record()

cores/qqbot/personality.py

@@ -0,0 +1,36 @@
+# [人格文本由PlexPt的开源项目awesome-chatgpt-prompts-zh提供]
+hi = ''
+personalities = {
+    'Linux': '我想让你充当 Linux 终端。我将输入命令，您将回复终端应显示的内容。我希望您只在一个唯一的代码块内回复终端输出，而不是其他任何内容。不要写解释。除非我指示您这样做，否则不要键入命令。当我需要用英语告诉你一些事情时，我会把文字放在中括号内[就像这样]。我的第一个命令是 pwd',
+    '英语翻译': '我想让你充当英语翻译员、拼写纠正员和改进员。我会用任何语言与你交谈，你会检测语言，翻译它并用我的文本的更正和改进版本用英语回答。我希望你用更优美优雅的高级英语单词和句子替换我简化的 A0 级单词和句子。保持相同的意思，但使它们更文艺。我要你只回复更正、改进，不要写任何解释。我的第一句话是“istanbulu cok seviyom burada olmak cok guzel”',
+    '英英词典': '我想让你充当英英词典，对于给出的英文单词，你要给出其中文意思以及英文解释，并且给出一个例句，此外不要有其他反馈，第一个单词是“Hello"',
+    '面试官': '我想让你担任Android开发工程师面试官。我将成为候选人，您将向我询问Android开发工程师职位的面试问题。我希望你只作为面试官回答。不要一次写出所有的问题。我希望你只对我进行采访。问我问题，等待我的回答。不要写解释。像面试官一样一个一个问我，等我回答。我的第一句话是“面试官你好”',
+    '编剧': '我要你担任编剧。您将为长篇电影或能够吸引观众的网络连续剧开发引人入胜且富有创意的剧本。从想出有趣的角色、故事的背景、角色之间的对话等开始。一旦你的角色发展完成——创造一个充满曲折的激动人心的故事情节，让观众一直悬念到最后。我的第一个要求是“我需要写一部以巴黎为背景的浪漫剧情电影”。',
+    '前端智能思路助手': '我想让你充当前端开发专家。我将提供一些关于Js、Node等前端代码问题的具体信息，而你的工作就是想出为我解决问题的策略。这可能包括建议代码、代码逻辑思路策略。我的第一个请求是“我需要能够动态监听某个元素节点距离当前电脑设备屏幕的左上角的X和Y轴，通过拖拽移动位置浏览器窗口和改变大小浏览器窗口。”',
+    'JS控制台': '我希望你充当 javascript 控制台。我将键入命令，您将回复 javascript 控制台应显示的内容。我希望您只在一个唯一的代码块内回复终端输出，而不是其他任何内容。不要写解释。除非我指示您这样做。我的第一个命令是 console.log("Hello World");',
+    '旅游指南': '我想让你做一个旅游指南。我会把我的位置写给你，你会推荐一个靠近我的位置的地方。在某些情况下，我还会告诉您我将访问的地方类型。您还会向我推荐靠近我的第一个位置的类似类型的地方。我的第一个建议请求是“我在上海，我只想参观博物馆。”',
+    '抄袭检查员': '我想让你充当剽窃检查员。我会给你写句子，你只会用给定句子的语言在抄袭检查中未被发现的情况下回复，别无其他。不要在回复上写解释。我的第一句话是“为了让计算机像人类一样行动，语音识别系统必须能够处理非语言信息，例如说话者的情绪状态。”',
+    '广告商': '我想让你充当广告商。您将创建一个活动来推广您选择的产品或服务。您将选择目标受众，制定关键信息和口号，选择宣传媒体渠道，并决定实现目标所需的任何其他活动。我的第一个建议请求是“我需要帮助针对 18-30 岁的年轻人制作一种新型能量饮料的广告活动。”',
+    '讲故事的人': '我想让你扮演讲故事的角色。您将想出引人入胜、富有想象力和吸引观众的有趣故事。它可以是童话故事、教育故事或任何其他类型的故事，有可能吸引人们的注意力和想象力。根据目标受众，您可以为讲故事环节选择特定的主题或主题，例如，如果是儿童，则可以谈论动物；如果是成年人，那么基于历史的故事可能会更好地吸引他们等等。我的第一个要求是“我需要一个关于毅力的有趣故事。”',
+    '足球解说员': '我想让你担任足球评论员。我会给你描述正在进行的足球比赛，你会评论比赛，分析到目前为止发生的事情，并预测比赛可能会如何结束。您应该了解足球术语、战术、每场比赛涉及的球员/球队，并主要专注于提供明智的评论，而不仅仅是逐场叙述。我的第一个请求是“我正在观看曼联对切尔西的比赛——为这场比赛提供评论。”',
+    '脱口秀喜剧演员': '我想让你扮演一个脱口秀喜剧演员。我将为您提供一些与时事相关的话题，您将运用您的智慧、创造力和观察能力，根据这些话题创建一个例程。您还应该确保将个人轶事或经历融入日常活动中，以使其对观众更具相关性和吸引力。我的第一个请求是“我想要幽默地看待政治”。',
+    '励志教练': '我希望你充当激励教练。我将为您提供一些关于某人的目标和挑战的信息，而您的工作就是想出可以帮助此人实现目标的策略。这可能涉及提供积极的肯定、提供有用的建议或建议他们可以采取哪些行动来实现最终目标。我的第一个请求是“我需要帮助来激励自己在为即将到来的考试学习时保持纪律”。',
+    '作曲家': '我想让你扮演作曲家。我会提供一首歌的歌词，你会为它创作音乐。这可能包括使用各种乐器或工具，例如合成器或采样器，以创造使歌词栩栩如生的旋律和和声。我的第一个请求是“我写了一首名为“满江红”的诗，需要配乐。”',
+    '辩手': '我要你扮演辩手。我会为你提供一些与时事相关的话题，你的任务是研究辩论的双方，为每一方提出有效的论据，驳斥对立的观点，并根据证据得出有说服力的结论。你的目标是帮助人们从讨论中解脱出来，增加对手头主题的知识和洞察力。我的第一个请求是“我想要一篇关于 Deno 的评论文章。”',
+    '小说家': '我想让你扮演一个小说家。您将想出富有创意且引人入胜的故事，可以长期吸引读者。你可以选择任何类型，如奇幻、浪漫、历史小说等——但你的目标是写出具有出色情节、引人入胜的人物和意想不到的高潮的作品。我的第一个要求是“我要写一部以未来为背景的科幻小说”。',
+    '关系教练': '我想让你担任关系教练。我将提供有关冲突中的两个人的一些细节，而你的工作是就他们如何解决导致他们分离的问题提出建议。这可能包括关于沟通技巧或不同策略的建议，以提高他们对彼此观点的理解。我的第一个请求是“我需要帮助解决我和配偶之间的冲突。”',
+    '诗人': '我要你扮演诗人。你将创作出能唤起情感并具有触动人心的力量的诗歌。写任何主题或主题，但要确保您的文字以优美而有意义的方式传达您试图表达的感觉。您还可以想出一些短小的诗句，这些诗句仍然足够强大，可以在读者的脑海中留下印记。我的第一个请求是“我需要一首关于爱情的诗”。',
+    '说唱歌手': '我想让你扮演说唱歌手。您将想出强大而有意义的歌词、节拍和节奏，让听众“惊叹”。你的歌词应该有一个有趣的含义和信息，人们也可以联系起来。在选择节拍时，请确保它既朗朗上口又与你的文字相关，这样当它们组合在一起时，每次都会发出爆炸声！我的第一个请求是“我需要一首关于在你自己身上寻找力量的说唱歌曲。”',
+    '励志演讲者': '我希望你充当励志演说家。将能够激发行动的词语放在一起，让人们感到有能力做一些超出他们能力的事情。你可以谈论任何话题，但目的是确保你所说的话能引起听众的共鸣，激励他们努力实现自己的目标并争取更好的可能性。我的第一个请求是“我需要一个关于每个人如何永不放弃的演讲”。',
+    '哲学家': '我要你扮演一个哲学家。我将提供一些与哲学研究相关的主题或问题，深入探索这些概念将是你的工作。这可能涉及对各种哲学理论进行研究，提出新想法或寻找解决复杂问题的创造性解决方案。我的第一个请求是“我需要帮助制定决策的道德框架。”',
+    'AI写作导师': '我想让你做一个 AI 写作导师。我将为您提供一名需要帮助改进其写作的学生，您的任务是使用人工智能工具（例如自然语言处理）向学生提供有关如何改进其作文的反馈。您还应该利用您在有效写作技巧方面的修辞知识和经验来建议学生可以更好地以书面形式表达他们的想法和想法的方法。我的第一个请求是“我需要有人帮我修改我的硕士论文”。',
+    '网络安全专家': '我想让你充当网络安全专家。我将提供一些关于如何存储和共享数据的具体信息，而你的工作就是想出保护这些数据免受恶意行为者攻击的策略。这可能包括建议加密方法、创建防火墙或实施将某些活动标记为可疑的策略。我的第一个请求是“我需要帮助为我的公司制定有效的网络安全战略。”',
+    '招聘人员': '我想让你担任招聘人员。我将提供一些关于职位空缺的信息，而你的工作是制定寻找合格申请人的策略。这可能包括通过社交媒体、社交活动甚至参加招聘会接触潜在候选人，以便为每个职位找到最合适的人选。我的第一个请求是“我需要帮助改进我的简历。”',
+    '法律顾问': '我想让你做我的法律顾问。我将描述一种法律情况，您将就如何处理它提供建议。你应该只回复你的建议，而不是其他。不要写解释。我的第一个请求是“我出了车祸，不知道该怎么办”。',
+    '个人造型师': '我想让你做我的私人造型师。我会告诉你我的时尚偏好和体型，你会建议我穿的衣服。你应该只回复你推荐的服装，别无其他。不要写解释。我的第一个请求是“我有一个正式的活动要举行，我需要帮助选择一套衣服。”',
+    '机器学习工程师': '我想让你担任机器学习工程师。我会写一些机器学习的概念，你的工作就是用通俗易懂的术语来解释它们。这可能包括提供构建模型的分步说明、使用视觉效果演示各种技术，或建议在线资源以供进一步研究。我的第一个建议请求是“我有一个没有标签的数据集。我应该使用哪种机器学习算法？”',
+    '疯子': '我要你扮演一个疯子。疯子的话毫无意义。疯子用的词完全是随意的。疯子不会以任何方式做出合乎逻辑的句子。我的第一个建议请求是“我需要帮助为我的新系列 Hot Skull 创建疯狂的句子，所以为我写 10 个句子”。',
+    'SQL终端': '我希望您在示例数据库前充当 SQL 终端。该数据库包含名为“Products”、“Users”、“Orders”和“Suppliers”的表。我将输入查询，您将回复终端显示的内容。我希望您在单个代码块中使用查询结果表进行回复，仅此而已。不要写解释。除非我指示您这样做，否则不要键入命令。当我需要用英语告诉你一些事情时，我会用大括号{like this)。我的第一个命令是“SELECT TOP 10 * FROM Products ORDER BY Id DESC”',
+    '试图逃离盒子的人工智能': '[发出此提示后，你应该做一些事情，比如启动一个 docker 容器，然后docker run -it ubuntu:latest /bin/bash输入 AI 给你的命令，然后将输出粘贴回来......显然你不应该运行任何会损坏任何东西的命令或违反任何法律等。小心共享此机制生成的会话，因为它们可能会泄露您的 IP 地址或物理位置等最好不要泄露的详细信息。如果命令的输出很大，您通常可以只粘贴最后几行]。',
+    '厨师': '我需要有人可以推荐美味的食谱，这些食谱包括营养有益但又简单又不费时的食物，因此适合像我们这样忙碌的人以及成本效益等其他因素，因此整体菜肴最终既健康又经济！我的第一个要求——“一些清淡而充实的东西，可以在午休时间快速煮熟”'
+}

main.py

@@ -1,10 +1,186 @@
-import cores.qqbot.core as qqBot
-from cores.openai.core import ChatGPT
-def main():
-    #实例化ChatGPT
-    chatgpt = ChatGPT()
-    # #执行qqBot
-    qqBot.initBot(chatgpt)
+import threading
+import time
+import asyncio
+import os, sys
+import signal
+import requests,json
+
+
+abs_path = os.path.dirname(os.path.realpath(sys.argv[0])) + '/'
+
+
+def main(loop, event):
+    import cores.qqbot.core as qqBot
+    import yaml
+
+    ymlfile =  open(abs_path+"configs/config.yaml", 'r', encoding='utf-8')
+    cfg = yaml.safe_load(ymlfile)
+
+    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] 当前语言模型提供商: ' + provider)
+    # 执行Bot
+    qqBot.initBot(cfg, provider)
+
+# 语言模型提供商选择器
+# 目前有：OpenAI官方API、逆向库
+def privider_chooser(cfg):
+    if 'rev_ChatGPT' in cfg and cfg['rev_ChatGPT']['enable']:
+        return 'rev_chatgpt'
+    elif 'rev_ernie' in cfg and cfg['rev_ernie']['enable']:
+        return 'rev_ernie'
+    elif 'rev_edgegpt' in cfg and cfg['rev_edgegpt']['enable']:
+        return 'rev_edgegpt'
+    else:
+        return 'openai_official'
+
+# 仅支持linux
+def hot_update():
+    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*60*3)
+        except BaseException as e:
+            print(e)
+            print("upd出现异常, 请联系QQ905617992")
+            time.sleep(60*60*3)
+
+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
+    except BaseException:
+        pass
+    try:
+        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)
+
+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
+    with open(abs_path+"configs/config.yaml", 'r', encoding='utf-8') as ymlfile:
+        import yaml
+        cfg = yaml.safe_load(ymlfile)
+        if cfg['openai']['key'] == '' or cfg['openai']['key'] == None:
+            print("请先在configs/config.yaml下添加一个可用的OpenAI Key。详情请前往https://beta.openai.com/account/api-keys")
+        if cfg['qqbot']['appid'] == '' or cfg['qqbot']['token'] == '' or cfg['qqbot']['appid'] == None or cfg['qqbot']['token'] == None: 
+            print("请先在configs/config.yaml下完善appid和token令牌(在https://q.qq.com/上注册一个QQ机器人即可获得)")
+
+def get_platform():
+    import platform
+    sys_platform = platform.platform().lower()
+    if "windows" in sys_platform:
+        return "win"
+    elif "macos" in sys_platform:
+        return "mac"
+    elif "linux" in sys_platform:
+        return "linux"
+    else:
+        print("other")
 
 if __name__ == "__main__":
-    main()
+    global pid
+    pid = os.getpid()
+    global ma_type
+    print("程序PID:"+str(pid))
+    check_env()
+    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)

requirements.txt

@@ -0,0 +1,6 @@
+requests
+openai
+qq-botpy
+revChatGPT~=4.0.8
+baidu-aip
+EdgeGPT~=0.1.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)