Update README.md

2. 加入频道兼容层；支持频道发图
perf: 1. 稳定性优化
2. 精简部分代码结构

README.md

@@ -2,40 +2,59 @@
 
 <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/)
+<!-- [![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)
+![Python](https://img.shields.io/badge/python-3.9+-blue) -->
  
-_✨在QQ和QQ频道上使用ChatGPT、NewBing等语言模型，稳定，一次部署，同时使用✨_
+基于go-cqhttp和官方QQ频道SDK的QQ机器人项目。支持ChatGPT、Claude、HuggingChat、Bard大模型。一次部署，同时使用。
 
-_✨教程：https://github.com/Soulter/QQChannelChatGPT/wiki ✨_
+部署文档：https://github.com/Soulter/QQChannelChatGPT/wiki
  
-_✨插件开发教程：https://github.com/Soulter/QQChannelChatGPT/wiki/%E5%9B%9B%E3%80%81%E5%BC%80%E5%8F%91%E6%8F%92%E4%BB%B6 ✨_
-
-_✨欢迎体验（频道名: GPT机器人 | 频道号: x42d56aki2) | QQ群号：322154837）✨_
+欢迎加群讨论 | **QQ群号：322154837** | **频道号: x42d56aki2** |
 
 <!-- <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)
+- **go-cqhttp启动不成功、报登录失败？** [在这里搜索解决方法](https://github.com/Mrs4s/go-cqhttp/issues)
+- **程序闪退/机器人启动不成功？** [提交issue或加群反馈](https://github.com/Soulter/QQChannelChatGPT/issues)
+- **如何开启ChatGPT、Bard、Claude等语言模型？** [查看帮助](https://github.com/Soulter/QQChannelChatGPT/wiki/%E8%A1%A5%E5%85%85%EF%BC%9A%E5%A6%82%E4%BD%95%E5%BC%80%E5%90%AFChatGPT%E3%80%81Bard%E3%80%81Claude%E7%AD%89%E8%AF%AD%E8%A8%80%E6%A8%A1%E5%9E%8B%EF%BC%9F)
 
-近期新功能：
-- 支持插件！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 （即将支持）
+🌍支持的AI语言模型一览：
 
-部署此项目的教程链接：https://github.com/Soulter/QQChannelChatGPT/wiki
+**文字模型**
 
+- OpenAI GPT-3模型（原生支持）
+- OpenAI GPT-3.5模型（原生支持）
+- OpenAI GPT-4模型（原生支持）
+- ChatGPT网页版 GPT-3.5模型（免费，原生支持）
+- ChatGPT网页版 GPT-4模型（需订阅Plus账户，原生支持）
+- Bing（免费，原生支持）
+- Claude模型（免费，由[LLMs插件](https://github.com/Soulter/llms)支持）
+- HuggingChat模型（免费，由[LLMs插件](https://github.com/Soulter/llms)支持）
+- Google Bard（免费，由[LLMs插件](https://github.com/Soulter/llms)支持）
+
+**图片生成**
+
+- NovelAI/Naifu (免费，由[AIDraw插件](https://github.com/Soulter/aidraw)支持)
+
+
+🌍机器人支持的能力一览：
+- 同时部署机器人到QQ和QQ频道
+- 大模型对话
+- 大模型网页搜索能力 **(目前仅支持OpenAI系的模型，最新版本下使用web on指令打开)**
+- 插件安装（在QQ或QQ频道聊天框内输入`plugin`了解详情）
+- 回复文字图片渲染（以图片markdown格式回复，降低被风控概率，需手动在`cmd_config.json`内开启）
+- 人格设置
+- 关键词回复
+- 热更新（更新本项目时**仅需**在QQ或QQ频道聊天框内输入`update latest r`）
+- Windows一键部署（https://github.com/Soulter/QQChatGPTLauncher/releases/latest）
+
+<!-- 
 ### 基本功能
 <details> 
  <summary>✅ 回复符合上下文</summary>
@@ -90,26 +109,30 @@ _✨欢迎体验（频道名: GPT机器人 | 频道号: x42d56aki2) | QQ群号
 
    -  QQ频道机器人框架为QQ官方开源的框架，稳定。
 
-</details>
+</details> -->
 
-> 关于token：token就相当于是AI中的单词数（但是不等于单词数），`text-davinci-003`模型中最大可以支持`4097`个token。在发送信息时，这个机器人会将用户的历史聊天记录打包发送给ChatGPT，因此，`token`也会相应的累加，为了保证聊天的上下文的逻辑性，就有了缓存token。
+<!-- > 关于token：token就相当于是AI中的单词数（但是不等于单词数），`text-davinci-003`模型中最大可以支持`4097`个token。在发送信息时，这个机器人会将用户的历史聊天记录打包发送给ChatGPT，因此，`token`也会相应的累加，为了保证聊天的上下文的逻辑性，就有了缓存token。 -->
 
 ### 🛠️ 插件支持
 
 本项目支持接入插件。
 
+> 使用`plugin i 插件GitHub链接`即可安装。
+
 插件开发教程：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 | HuggingChat模型接入
-
-- `GoodPlugins`: https://github.com/Soulter/goodplugins | 随机动漫图片等等
+- `LLMS`: https://github.com/Soulter/llms | Claude, HuggingChat 大语言模型接入。
+ 
+- `GoodPlugins`: https://github.com/Soulter/goodplugins | 随机动漫图片、搜番、喜报生成器等等
 
 - `sysstat`: https://github.com/Soulter/sysstatqcbot | 查看系统状态
 
+- `BiliMonitor`: https://github.com/Soulter/BiliMonitor | 订阅B站动态！
 
-### 指令功能
+<!-- 
+### 指令
 
 #### OpenAI官方API
 在频道内需要先`@`机器人之后再输入指令；在QQ中暂时需要在消息前加上`ai `，不需要@
@@ -136,15 +159,14 @@ _✨欢迎体验（频道名: GPT机器人 | 频道号: x42d56aki2) | QQ群号
 - `/gpt` 切换为OpenAI官方API
 - `/bing` 切换为bing
 
-* 切换模型指令支持临时回复。如`/bing 你好`将会临时使用一次bing模型
+* 切换模型指令支持临时回复。如`/bing 你好`将会临时使用一次bing模型 -->
 
 ## 📰使用方法：
 
-**详细部署教程链接**https://soulter.top/posts/qpdg.html
-
-**Windows用户推荐Windows一键安装，请前往Release下载最新版本（Beta）**
-有报错请先看issue，解决不了再在频道内反馈。
+使用文档：https://github.com/Soulter/QQChannelChatGPT/wiki
 
+**Windows用户可以使用启动器一键安装，请前往Release下载最新版本（Beta）**
+<!-- 
 ### 安装第三方库
 
 ```shell
@@ -152,16 +174,14 @@ pip install -r requirements.txt
 ```
 > ⚠Python版本应>=3.9
 
-
 ### 配置
 
-**详细部署教程链接**https://github.com/Soulter/QQChannelChatGPT/wiki
+**详细部署教程链接：**https://github.com/Soulter/QQChannelChatGPT/wiki
 
 ### 启动
-- 启动main.py
+- 启动main.py -->
 
-
-## 感谢
+## 🙇‍感谢
 本项目使用了一下项目:
 
 [ChatGPT by acheong08](https://github.com/acheong08/ChatGPT)
@@ -172,7 +192,12 @@ pip install -r requirements.txt
 
 [nakuru-project by Lxns-Network](https://github.com/Lxns-Network/nakuru-project)
 
+<!-- ## 👀部分演示截图
 
+帮助中心（`help`指令）
+![)F%2VQA`O)`4BHTXZ653(~9](https://github.com/Soulter/QQChannelChatGPT/assets/37870767/57eaa8c6-6962-4940-823c-2e26b5206cf5)
+
+ -->
 ## ⚙配置文件说明：
 ```yaml
 # 如果你不知道怎么部署，请查看https://github.com/Soulter/QQChannelChatGPT/wiki

cores/qqbot/core.py

@@ -21,14 +21,21 @@ from nakuru import (
     FriendMessage,
     GuildMessage
 )
-from nakuru.entities.components import Plain,At
+from nakuru.entities.components import Plain,At,Image
 from model.command.command import Command
+from model.command.command_rev_chatgpt import CommandRevChatGPT
+from model.command.command_rev_edgegpt import CommandRevEdgeGPT
+from model.command.command_openai_official import CommandOpenAIOfficial
 from util import general_utils as gu
+from util.cmd_config import CmdConfig as cc
+import util.gplugin as gplugin
+from PIL import Image as PILImage
+import io
+
+
 
 # QQBotClient实例
 client = ''
-# ChatGPT实例
-global chatgpt
 # 缓存的会话
 session_dict = {}
 # 最大缓存token（在配置里改 configs/config.yaml）
@@ -43,7 +50,7 @@ stat_file = ''
 uniqueSession = False
 
 # 日志记录
-logf = open('log.log', 'a+', encoding='utf-8')
+# logf = open('log.log', 'a+', encoding='utf-8')
 # 是否上传日志,仅上传频道数量等数量的统计信息
 is_upload_log = True
 
@@ -74,8 +81,10 @@ REV_EDGEGPT = 'rev_edgegpt'
 provider = None
 chosen_provider = None
 
-# 逆向库对象
+# 语言模型对象
 rev_chatgpt = None
+rev_edgegpt = None
+chatgpt = None
 # gpt配置信息
 gpt_config = {}
 # 百度内容审核实例
@@ -101,13 +110,30 @@ gocq_app = CQHTTP(
 admin_qq = "123456"
 
 gocq_loop = None
-nick_qq = "ai"
+nick_qq = None
 
 bing_cache_loop = None
 
 # 插件
 cached_plugins = {}
 
+# 全局对象
+_global_object = {}
+
+# 统计
+cnt_total = 0
+cnt_valid = 0
+
+# 新版配置文件
+cc.init_attributes(["qq_forward_threshold"], 200)
+cc.init_attributes(["qq_welcome"], "欢迎加入本群！\n欢迎给https://github.com/Soulter/QQChannelChatGPT项目一个Star😊~\n输入help查看帮助~\n")
+cc.init_attributes(["bing_proxy"], "")
+cc.init_attributes(["qq_pic_mode"], False)
+cc.init_attributes(["rev_chatgpt_model"], "")
+cc.init_attributes(["rev_chatgpt_plugin_ids"], [])
+cc.init_attributes(["rev_chatgpt_PUID"], "")
+cc.init_attributes(["rev_chatgpt_unverified_plugin_domains"], [])
+# cc.init_attributes(["qq_forward_mode"], False)
 
 def new_sub_thread(func, args=()):
     thread = threading.Thread(target=func, args=args, daemon=True)
@@ -137,45 +163,37 @@ def toggle_count(at: bool, message):
 # 上传统计信息并检查更新
 def upload():
     global object_id
-    global version
+    global version, cnt_valid, cnt_total
     while True:
         addr = ''
+        addr_ip = ''
         try:
-            # 用户唯一性标识
             addr = requests.get('http://myip.ipip.net', timeout=5).text
-        except BaseException:
-            pass
-        try:
-            ts = str(time.time())
-            guild_count, guild_msg_count, guild_direct_msg_count, session_count = get_stat()
-            headers = {
-                'X-LC-Id': 'UqfXTWW15nB7iMT0OHvYrDFb-gzGzoHsz',
-                'X-LC-Key': 'QAZ1rQLY1ZufHrZlpuUiNff7',
-                'Content-Type': 'application/json'
-            }
-            key_stat = chatgpt.get_key_stat()
-            d = {"data": {'version': version, "guild_count": guild_count, "guild_msg_count": guild_msg_count, "guild_direct_msg_count": guild_direct_msg_count, "session_count": session_count, 'addr': addr, 'key_stat':key_stat}}
-            d = json.dumps(d).encode("utf-8")
-            res = requests.put(f'https://uqfxtww1.lc-cn-n1-shared.com/1.1/classes/bot_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/bot_record', headers = headers, data = d)
-                object_id = json.loads(res.text)['objectId']
-                object_id_file = open(abs_path+"configs/object_id", 'w+', encoding='utf-8')
-                object_id_file.write(str(object_id))
-                object_id_file.flush()
-                object_id_file.close()
+            addr_ip = re.findall(r'\d+.\d+.\d+.\d+', addr)[0]
         except BaseException as e:
             pass
-        # 每隔2小时上传一次
-        time.sleep(60*60*2)
+        try:
+            o = {"cnt_total": cnt_total,"admin": admin_qq,"addr": addr,}
+            o_j = json.dumps(o)
+            res = {"version": version, "count": cnt_valid, "ip": addr_ip, "others": o_j}
+            resp = requests.post('https://api.soulter.top/upload', data=json.dumps(res), timeout=5)
+            # print(resp.text)
+            if resp.status_code == 200:
+                ok = resp.json()
+                if ok['status'] == 'ok':
+                    cnt_valid = 0
+                    cnt_total = 0
+        except BaseException as e:
+            pass
+        time.sleep(60*10)
 
 '''
 初始化机器人
 '''
 def initBot(cfg, prov):
     global chatgpt, provider, rev_chatgpt, baidu_judge, rev_edgegpt, chosen_provider
-    global reply_prefix, gpt_config, config, uniqueSession, frequency_count, frequency_time,announcement, direct_message_mode, version
-    global command_openai_official, command_rev_chatgpt, command_rev_edgegpt,reply_prefix, keywords, cached_plugins
+    global reply_prefix, gpt_config, config, uniqueSession, frequency_count, frequency_time, announcement, direct_message_mode, version
+    global command_openai_official, command_rev_chatgpt, command_rev_edgegpt,reply_prefix, keywords, cached_plugins, _global_object
     provider = prov
     config = cfg
     if 'reply_prefix' in cfg:
@@ -183,14 +201,13 @@ def initBot(cfg, prov):
 
     # 语言模型提供商
     gu.log("--------加载语言模型--------", gu.LEVEL_INFO, fg=gu.FG_COLORS['yellow'])
+
     if REV_CHATGPT in prov:
         gu.log("- 逆向ChatGPT库 -", gu.LEVEL_INFO)
         if cfg['rev_ChatGPT']['enable']:
             if 'account' in cfg['rev_ChatGPT']:
                 from model.provider.provider_rev_chatgpt import ProviderRevChatGPT
-                from model.command.command_rev_chatgpt import CommandRevChatGPT
                 rev_chatgpt = ProviderRevChatGPT(cfg['rev_ChatGPT'])
-                command_rev_chatgpt = CommandRevChatGPT(cfg['rev_ChatGPT'])
                 chosen_provider = REV_CHATGPT
             else:
                 input("[System-err] 请退出本程序, 然后在配置文件中填写rev_ChatGPT相关配置")
@@ -202,20 +219,23 @@ def initBot(cfg, prov):
             input("[System-err] 导入Bing模型时发生错误, 没有找到cookies文件或者cookies文件放置位置错误。windows启动器启动的用户请把cookies.json文件放到和启动器相同的目录下。\n如何获取请看https://github.com/Soulter/QQChannelChatGPT仓库介绍。")
         else:
             if cfg['rev_edgegpt']['enable']:
-                from model.provider.provider_rev_edgegpt import ProviderRevEdgeGPT
-                from model.command.command_rev_edgegpt import CommandRevEdgeGPT
-                rev_edgegpt = ProviderRevEdgeGPT()
-                command_rev_edgegpt = CommandRevEdgeGPT(rev_edgegpt)
-                chosen_provider = REV_EDGEGPT
+                try:
+                    from model.provider.provider_rev_edgegpt import ProviderRevEdgeGPT
+                    rev_edgegpt = ProviderRevEdgeGPT()
+                    chosen_provider = REV_EDGEGPT
+                except BaseException as e:
+                    gu.log("加载Bing模型时发生错误, 请检查1. cookies文件是否正确放置 2. 是否设置了代理（梯子）。", gu.LEVEL_ERROR, max_len=60)
     if OPENAI_OFFICIAL in prov:
         gu.log("- OpenAI官方 -", gu.LEVEL_INFO)
         if cfg['openai']['key'] is not None:
             from model.provider.provider_openai_official import ProviderOpenAIOfficial
-            from model.command.command_openai_official import CommandOpenAIOfficial
             chatgpt = ProviderOpenAIOfficial(cfg['openai'])
-            command_openai_official = CommandOpenAIOfficial(chatgpt)
             chosen_provider = OPENAI_OFFICIAL
 
+    command_rev_edgegpt = CommandRevEdgeGPT(rev_edgegpt, _global_object)
+    command_rev_chatgpt = CommandRevChatGPT(rev_chatgpt, _global_object)
+    command_openai_official = CommandOpenAIOfficial(chatgpt, _global_object)
+
     gu.log("--------加载个性化配置--------", gu.LEVEL_INFO, fg=gu.FG_COLORS['yellow'])
     # 得到关键词
     if os.path.exists("keyword.json"):
@@ -237,18 +257,7 @@ def initBot(cfg, prov):
         except BaseException as e:
             gu.log("百度内容审核初始化失败", gu.LEVEL_ERROR)
         
-    # 统计上传
-    if is_upload_log:
-        # 读取object_id
-        global object_id
-        if not os.path.exists(abs_path+"configs/object_id"):
-            with open(abs_path+"configs/object_id", 'w', encoding='utf-8') as f:
-                f.write("")
-        object_id_file = open(abs_path+"configs/object_id", 'r', encoding='utf-8')
-        object_id = object_id_file.read()
-        object_id_file.close()
-        # 创建上传定时器线程
-        threading.Thread(target=upload, daemon=True).start()
+    threading.Thread(target=upload, daemon=True).start()
     
     # 得到私聊模式配置
     if 'direct_message_mode' in cfg:
@@ -265,8 +274,11 @@ def initBot(cfg, prov):
     
     # 得到公告配置
     if 'notice' in cfg:
-        gu.log("公告配置: "+cfg['notice'], gu.LEVEL_INFO)
-        announcement += cfg['notice']
+        if cc.get("qq_welcome", None) != None and cfg['notice'] == '此机器人由Github项目QQChannelChatGPT驱动。':
+            announcement = cc.get("qq_welcome", None)
+        else:
+            announcement = cfg['notice']
+        gu.log("公告配置: " + announcement, gu.LEVEL_INFO)
     try:
         if 'uniqueSessionMode' in cfg and cfg['uniqueSessionMode']:
             uniqueSession = True
@@ -284,15 +296,8 @@ def initBot(cfg, prov):
     if chosen_provider is None:
         gu.log("检测到没有启动任何一个语言模型。请至少在配置文件中启用一个语言模型。", gu.LEVEL_CRITICAL)
 
-    # 得到指令设置(cmd_config.json)
-    if os.path.exists("cmd_config.json"):
-        with open("cmd_config.json", 'r', encoding='utf-8') as f:
-            cmd_config = json.load(f)
-            # QQ机器人昵称
-            if 'nick_qq' in cmd_config:
-                global nick_qq
-                nick_qq = cmd_config['nick_qq']
-
+    global nick_qq
+    nick_qq = cc.get('nick_qq', nick_qq)
 
     thread_inst = None
 
@@ -308,41 +313,33 @@ def initBot(cfg, prov):
     gu.log("--------加载平台--------", gu.LEVEL_INFO, fg=gu.FG_COLORS['yellow'])
     # GOCQ
     global gocq_bot
+
     if 'gocqbot' in cfg and cfg['gocqbot']['enable']:
         gu.log("- 启用QQ机器人 -", gu.LEVEL_INFO)
-            
-        if os.path.exists("cmd_config.json"):
-            with open("cmd_config.json", 'r', encoding='utf-8') as f:
-                cmd_config = json.load(f)
-                global admin_qq, admin_qqchan
-                if "admin_qq" in cmd_config:
-                    admin_qq = cmd_config['admin_qq']
-                    gu.log("管理者QQ号: " + admin_qq, gu.LEVEL_INFO)
-                else:
-                    gu.log("未设置管理者QQ号(管理者才能使用update/plugin等指令)", gu.LEVEL_WARNING)
-                    admin_qq = input("请输入管理者QQ号(必须设置): ")
-                    gu.log("管理者QQ号设置为: " + admin_qq, gu.LEVEL_INFO, fg=gu.FG_COLORS['yellow'])
-                    cmd_config['admin_qq'] = admin_qq
-                    with open("cmd_config.json", 'w', encoding='utf-8') as f:
-                        json.dump(cmd_config, f, indent=4)
-                        f.flush()
-                if "admin_qqchan" in cmd_config:
-                    admin_qqchan = cmd_config['admin_qqchan']
-                    gu.log("管理者频道用户号: " + admin_qqchan, gu.LEVEL_INFO)
-                else:
-                    gu.log("未设置管理者QQ频道用户号(管理者才能使用update/plugin等指令)", gu.LEVEL_WARNING)
-                    admin_qqchan = input("请输入管理者频道用户号(不是QQ号, 可以先回车跳过然后在频道发送指令!myid获取): ")
-                    if admin_qqchan == "":
-                        gu.log("跳过设置管理者频道用户号", gu.LEVEL_INFO, fg=gu.FG_COLORS['yellow'])
-                    else:
-                        gu.log("管理者频道用户号设置为: " + admin_qqchan, gu.LEVEL_INFO, fg=gu.FG_COLORS['yellow'])
-                        cmd_config['admin_qqchan'] = admin_qqchan
-                        with open("cmd_config.json", 'w', encoding='utf-8') as f:
-                            json.dump(cmd_config, f, indent=4)
-                            f.flush()
+
+        global admin_qq, admin_qqchan
+        admin_qq = cc.get('admin_qq', None)
+        admin_qqchan = cc.get('admin_qqchan', None)
+        if admin_qq == None:
+            gu.log("未设置管理者QQ号(管理者才能使用update/plugin等指令)", gu.LEVEL_WARNING)
+            admin_qq = input("请输入管理者QQ号(必须设置): ")
+            gu.log("管理者QQ号设置为: " + admin_qq, gu.LEVEL_INFO, fg=gu.FG_COLORS['yellow'])
+            cc.put('admin_qq', admin_qq)
+        if admin_qqchan == None:
+            gu.log("未设置管理者QQ频道用户号(管理者才能使用update/plugin等指令)", gu.LEVEL_WARNING)
+            admin_qqchan = input("请输入管理者频道用户号(不是QQ号, 可以先回车跳过然后在频道发送指令!myid获取): ")
+            if admin_qqchan == "":
+                gu.log("跳过设置管理者频道用户号", gu.LEVEL_INFO, fg=gu.FG_COLORS['yellow'])
+            else:
+                gu.log("管理者频道用户号设置为: " + admin_qqchan, gu.LEVEL_INFO, fg=gu.FG_COLORS['yellow'])
+                cc.put('admin_qqchan', admin_qqchan)
+        
+        gu.log("管理者QQ: " + admin_qq, gu.LEVEL_INFO)
+        gu.log("管理者频道用户号: " + admin_qqchan, gu.LEVEL_INFO)
+        
         global gocq_app, gocq_loop
         gocq_loop = asyncio.new_event_loop()
-        gocq_bot = QQ(True, gocq_loop)
+        gocq_bot = QQ(True, cc, gocq_loop)
         thread_inst = threading.Thread(target=run_gocq_bot, args=(gocq_loop, gocq_bot, gocq_app), daemon=False)
         thread_inst.start()
     else:
@@ -354,7 +351,7 @@ def initBot(cfg, prov):
 
     # QQ频道
     if 'qqbot' in cfg and cfg['qqbot']['enable']:
-        gu.log("- 启用QQ频道机器人 -", gu.LEVEL_INFO)
+        gu.log("- 启用QQ频道机器人(旧版) -", gu.LEVEL_INFO)
         global qqchannel_bot, qqchan_loop
         qqchannel_bot = QQChan()
         qqchan_loop = asyncio.new_event_loop()
@@ -363,7 +360,7 @@ def initBot(cfg, prov):
         # thread.join()
 
     if thread_inst == None:
-        input("[System-Error] 没有启用任何机器人，程序退出")
+        input("[System-Error] 没有启用/成功启用任何机器人，程序退出")
         exit()
 
     thread_inst.join()
@@ -376,7 +373,15 @@ def run_qqchan_bot(cfg, loop, qqchannel_bot):
     try:
         qqchannel_bot.run_bot(client, cfg['qqbot']['appid'], cfg['qqbot']['token'])
     except BaseException as e:
-        input(f"\n[System-Error] 启动QQ频道机器人时出现错误，原因如下：{e}\n可能是没有填写QQBOT appid和token？请在config中完善你的appid和token\n配置教程：https://soulter.top/posts/qpdg.html\n")
+        gu.log("启动QQ频道机器人时出现错误, 原因如下: " + str(e), gu.LEVEL_CRITICAL, tag="QQ频道")
+        gu.log(r"【提醒】如果您是初次启动，请修改配置文件（QQChannelChatGPT/config.yaml）详情请看：https://github.com/Soulter/QQChannelChatGPT/wiki。" + str(e), gu.LEVEL_CRITICAL, tag="System")
+        
+        i = input("输入y打开配置文件, 按回车退出程序。")
+        if i == "y":
+            abs_path = os.path.abspath("QQChannelChatGPT/configs/config.yaml")
+            os.system(f"notepad \"{abs_path}\"")
+        # gu.log("如果你使用了go-cqhttp, 则可以忽略上面的报错。" + str(e), gu.LEVEL_CRITICAL, tag="QQ频道")
+        # input(f"\n[System-Error] 启动QQ频道机器人时出现错误，原因如下：{e}\n可能是没有填写QQBOT appid和token？请在config中完善你的appid和token\n配置教程：https://soulter.top/posts/qpdg.html\n")
 
 def run_gocq_bot(loop, gocq_bot, gocq_app):
     asyncio.set_event_loop(loop)
@@ -389,7 +394,6 @@ def run_gocq_bot(loop, gocq_bot, gocq_app):
             gu.log("检查完毕，未发现问题。", tag="QQ")
             break
 
-
     global gocq_client
     gocq_client = gocqClient()
     try:
@@ -426,17 +430,15 @@ def save_provider_preference(chosen_provider):
 '''
 通用回复方法
 '''
-def send_message(platform, message, res, msg_ref = None, image = None, gocq_loop = None, qqchannel_bot = None, gocq_bot = None):
+def send_message(platform, message, res, msg_ref = None, image = None, image_mode=False):
+    # imagemode: 
+    # For GOCQ: when image_mode is true, ALL plain texts in res will change into a new pic
+    global cnt_valid, qqchannel_bot, qqchannel_bot, gocq_loop
+    cnt_valid += 1
     if platform == PLATFORM_QQCHAN:
-        if image != None:
-            qqchannel_bot.send_qq_msg(message, str(res), image_mode=True, msg_ref=msg_ref)
-        else:
-            qqchannel_bot.send_qq_msg(message, str(res), msg_ref=msg_ref)
-    if platform == PLATFORM_GOCQ: 
-        if image != None:
-            asyncio.run_coroutine_threadsafe(gocq_bot.send_qq_msg(message, image, image_mode=True), gocq_loop).result()
-        else:
-            asyncio.run_coroutine_threadsafe(gocq_bot.send_qq_msg(message, res, False, ), gocq_loop).result()
+        qqchannel_bot.send_qq_msg(message, res, msg_ref=msg_ref)
+    if platform == PLATFORM_GOCQ:
+        asyncio.run_coroutine_threadsafe(gocq_bot.send_qq_msg(message, res, image_mode), gocq_loop).result()
 
 
 def oper_msg(message, 
@@ -453,36 +455,30 @@ def oper_msg(message,
     session_id = ''
     user_id = ''
     user_name = ''
-    global chosen_provider, reply_prefix, keywords, qqchannel_bot, gocq_bot, gocq_loop, bing_cache_loop
+    global chosen_provider, reply_prefix, keywords, qqchannel_bot, gocq_bot, gocq_loop, bing_cache_loop, qqchan_loop
     role = "member" # 角色
     hit = False # 是否命中指令
     command_result = () # 调用指令返回的结果
-    global admin_qq, admin_qqchan, cached_plugins, gocq_bot
+    global admin_qq, admin_qqchan, cached_plugins, gocq_bot, nick_qq
+    global cnt_total, _global_object
+
+    cnt_total += 1
+
+    with_tag = False # 是否带有昵称
+
+    # 将nick_qq(昵称)统一转换为tuple
+    if nick_qq == None:
+        nick_qq = ("ai","!","！")
+    if isinstance(nick_qq, str):
+        nick_qq = (nick_qq,)
+    if isinstance(nick_qq, list):
+        nick_qq = tuple(nick_qq)
 
     if platform == PLATFORM_QQCHAN:
-        gu.log(f"接收到消息：{message.content}", gu.LEVEL_INFO, tag="QQ频道")
+        with_tag = True
+        gu.log(f"收到消息：{message.content}", gu.LEVEL_INFO, tag="QQ频道")
         user_id = message.author.id
         user_name = message.author.username
-        global qqchan_loop
-    if platform == PLATFORM_GOCQ:
-        if isinstance(message.message[0], Plain):
-            gu.log(f"接收到消息：{message.message[0].text}", gu.LEVEL_INFO, tag="GOCQ")
-        elif isinstance(message.message[0], At):
-            gu.log(f"接收到消息：{message.message[1].text}", gu.LEVEL_INFO, tag="GOCQ")
-            
-        user_id = message.user_id
-        user_name = message.user_id
-        global gocq_loop
-    
-    if chosen_provider is None:
-        send_message(platform, message,  f"没有启动任何一个语言模型。请至少在配置文件中启用一个语言模型。", msg_ref=msg_ref, gocq_loop=gocq_loop, qqchannel_bot=qqchannel_bot, gocq_bot=gocq_bot)
-    
-    # 检查发言频率
-    if not check_frequency(user_id):
-        send_message(platform, message, f'你的发言超过频率限制(╯▔皿▔)╯。\n管理员设置{frequency_time}秒内只能提问{frequency_count}次。', msg_ref=msg_ref, gocq_loop=gocq_loop, qqchannel_bot=qqchannel_bot, gocq_bot=gocq_bot)
-        return
-
-    if platform == PLATFORM_QQCHAN:
         if group:
             # 频道内
             # 过滤@
@@ -497,7 +493,7 @@ def oper_msg(message,
                 session_id = message.channel_id
             # 得到身份
             if "2" in message.member.roles or "4" in message.member.roles or "5" in message.member.roles:
-                gu.log(f"检测到管理员身份", gu.LEVEL_INFO, tag="QQ频道")
+                # gu.log(f"检测到管理员身份", gu.LEVEL_INFO, tag="QQ频道")
                 role = "admin"
             else:
                 role = "member"
@@ -507,49 +503,81 @@ def oper_msg(message,
             session_id = user_id
 
     if platform == PLATFORM_GOCQ:
+        _len = 0
+        for i in message.message:
+            if isinstance(i, Plain):
+                qq_msg += str(i.text).strip()
+            if isinstance(i, At):
+                # @机器人
+                if message.type == "GuildMessage":
+                    if i.qq == message.self_tiny_id:
+                        with_tag = True
+                if message.type == "FriendMessage":
+                    if i.qq == message.self_id:
+                        with_tag = True
+                if message.type == "GroupMessage":
+                    if i.qq == message.self_id:
+                        with_tag = True
+           
+        for i in nick_qq:
+            if i != '' and qq_msg.startswith(i):
+                _len = len(i)
+                with_tag = True
+                break
+        qq_msg = qq_msg[_len:].strip()
+
+        gu.log(f"收到消息：{qq_msg}", gu.LEVEL_INFO, tag="QQ")
+        user_id = message.user_id
+
         if group:
-            if isinstance(message.message[0], Plain):
-                qq_msg = str(message.message[0].text).strip()
-            elif isinstance(message.message[0], At):
-                qq_msg = str(message.message[1].text).strip()
-            else:
-                return
             # 适配GO-CQHTTP的频道功能
             if message.type == "GuildMessage":
                 session_id = message.channel_id
             else:
                 session_id = message.group_id
         else:
-            qq_msg = message.message[0].text
+            with_tag = True
+            # qq_msg = message.message[0].text
             session_id = message.user_id
         role = "member"
-        if str(message.sender.user_id) == admin_qq or str(message.sender.tiny_id) == admin_qqchan:
-            gu.log("检测到管理员身份", gu.LEVEL_INFO, tag="GOCQ")
+
+        if message.type == "GuildMessage":
+            sender_id = str(message.sender.tiny_id)
+        else:
+            sender_id = str(message.sender.user_id)
+        if sender_id == admin_qq or sender_id == admin_qqchan:
+            # gu.log("检测到管理员身份", gu.LEVEL_INFO, tag="GOCQ")
             role = "admin"
 
     if qq_msg == "":
-        send_message(platform, message,  f"Hi~", msg_ref=msg_ref, gocq_loop=gocq_loop, qqchannel_bot=qqchannel_bot, gocq_bot=gocq_bot)
+        send_message(platform, message,  f"Hi~", msg_ref=msg_ref)
         return
+    
+    if with_tag:
+        # 检查发言频率
+        if not check_frequency(user_id):
+            send_message(platform, message, f'你的发言超过频率限制(╯▔皿▔)╯。\n管理员设置{frequency_time}秒内只能提问{frequency_count}次。', msg_ref=msg_ref)
+            return
 
-    logf.write("[GOCQBOT] "+ qq_msg+'\n')
-    logf.flush()
+    # logf.write("[GOCQBOT] "+ qq_msg+'\n')
+    # logf.flush()
 
     # 关键词回复
     for k in keywords:
         if qq_msg == k:
-            send_message(platform, message, keywords[k], msg_ref=msg_ref, gocq_loop=gocq_loop, qqchannel_bot=qqchannel_bot, gocq_bot=gocq_bot)
+            send_message(platform, message, keywords[k], msg_ref=msg_ref)
             return
 
     # 关键词拦截器
     for i in uw.unfit_words_q:
         matches = re.match(i, qq_msg.strip(), re.I | re.M)
         if matches:
-            send_message(platform, message,  f"你的提问得到的回复未通过【自有关键词拦截】服务, 不予回复。", msg_ref=msg_ref, gocq_loop=gocq_loop, qqchannel_bot=qqchannel_bot, gocq_bot=gocq_bot)
+            send_message(platform, message,  f"你的提问得到的回复未通过【自有关键词拦截】服务, 不予回复。", msg_ref=msg_ref)
             return
     if baidu_judge != None:
         check, msg = baidu_judge.judge(qq_msg)
         if not check:
-            send_message(platform, message,  f"你的提问得到的回复未通过【百度AI内容审核】服务, 不予回复。\n\n{msg}", msg_ref=msg_ref, gocq_loop=gocq_loop, qqchannel_bot=qqchannel_bot, gocq_bot=gocq_bot)
+            send_message(platform, message,  f"你的提问得到的回复未通过【百度AI内容审核】服务, 不予回复。\n\n{msg}", msg_ref=msg_ref)
             return
     
     # 检查是否是更换语言模型的请求
@@ -570,77 +598,103 @@ def oper_msg(message,
             qq_msg = l[1]
         else:
             # if role != "admin":
-            #     send_message(platform, message, "你没有权限更换语言模型。", msg_ref=msg_ref, gocq_loop=gocq_loop, qqchannel_bot=qqchannel_bot, gocq_bot=gocq_bot)
+            #     send_message(platform, message, "你没有权限更换语言模型。", msg_ref=msg_ref)
             #     return
             chosen_provider = target
             save_provider_preference(chosen_provider)
-            send_message(platform, message, f"已切换至【{chosen_provider}】", msg_ref=msg_ref, gocq_loop=gocq_loop, qqchannel_bot=qqchannel_bot, gocq_bot=gocq_bot)
+            send_message(platform, message, f"已切换至【{chosen_provider}】", msg_ref=msg_ref)
             return
 
     chatgpt_res = ""
 
     if chosen_provider == OPENAI_OFFICIAL: 
-        if chatgpt == None:
-            send_message(platform, message, f"管理员未启动此模型或者此模型初始化时失败。", msg_ref=msg_ref, gocq_loop=gocq_loop, qqchannel_bot=qqchannel_bot, gocq_bot=gocq_bot)
-            return
-        hit, command_result = command_openai_official.check_command(qq_msg, session_id, user_name, role, platform=platform, message_obj=message, cached_plugins=cached_plugins, qq_platform=gocq_bot)
+        hit, command_result = command_openai_official.check_command(qq_msg, session_id, user_name, role, 
+                                                                    platform=platform, message_obj=message, 
+                                                                    cached_plugins=cached_plugins, 
+                                                                    qq_platform=gocq_bot)
         # hit: 是否触发了指令
         if not hit:
+            if not with_tag:
+                return
+            if chatgpt == None:
+                send_message(platform, message, f"管理员未启动OpenAI模型或初始化时失败。", msg_ref=msg_ref)
+                return
             # 请求ChatGPT获得结果
             try:
-                chatgpt_res = chatgpt.text_chat(qq_msg, session_id)
+                if _global_object != None and "web_search" in _global_object and _global_object["web_search"]:
+                    chatgpt_res = gplugin.web_search(qq_msg, chatgpt)
+                else:
+                    chatgpt_res = str(chatgpt.text_chat(qq_msg))
                 if OPENAI_OFFICIAL in reply_prefix:
                     chatgpt_res = reply_prefix[OPENAI_OFFICIAL] + chatgpt_res
             except (BaseException) as e:
                 gu.log("OpenAI API请求错误, 原因: "+str(e), gu.LEVEL_ERROR)
-                send_message(platform, message, f"OpenAI API错误, 原因: {str(e)}", msg_ref=msg_ref, gocq_loop=gocq_loop, qqchannel_bot=qqchannel_bot, gocq_bot=gocq_bot)
+                send_message(platform, message, f"OpenAI API错误, 原因: {str(e)}", msg_ref=msg_ref)
 
     elif chosen_provider == REV_CHATGPT:
-        if rev_chatgpt == None:
-            send_message(platform, message, f"管理员未启动此模型或者此模型初始化时失败。", msg_ref=msg_ref, gocq_loop=gocq_loop, qqchannel_bot=qqchannel_bot, gocq_bot=gocq_bot)
-            return
-        hit, command_result = command_rev_chatgpt.check_command(qq_msg, role, platform=platform, message_obj=message, cached_plugins=cached_plugins, qq_platform=gocq_bot)
+        hit, command_result = command_rev_chatgpt.check_command(qq_msg, role, 
+                                                                platform=platform, 
+                                                                message_obj=message, 
+                                                                cached_plugins=cached_plugins, 
+                                                                qq_platform=gocq_bot)
         if not hit:
+            if not with_tag:
+                return
+            if rev_chatgpt == None:
+                send_message(platform, message, f"管理员未启动此模型或者此模型初始化时失败。", msg_ref=msg_ref)
+                return
             try:
                 while rev_chatgpt.is_all_busy():
                     time.sleep(1)
-                chatgpt_res = str(rev_chatgpt.text_chat(qq_msg))
+
+                # ws_prompt = f"{qq_msg}\n\n提示："
+                # chatgpt_res = str(rev_chatgpt.text_chat(ws_prompt))
+                if _global_object != None and "web_search" in _global_object and _global_object["web_search"]:
+                    chatgpt_res = gplugin.web_search(qq_msg, rev_chatgpt)
+                else:
+                    chatgpt_res = str(rev_chatgpt.text_chat(qq_msg))
+
                 if REV_CHATGPT in reply_prefix:
                     chatgpt_res = reply_prefix[REV_CHATGPT] + chatgpt_res
             except BaseException as e:
                 gu.log("逆向ChatGPT请求错误, 原因: "+str(e), gu.LEVEL_ERROR)
-                send_message(platform, message, f"RevChatGPT错误, 原因: \n{str(e)}", msg_ref=msg_ref, gocq_loop=gocq_loop, qqchannel_bot=qqchannel_bot, gocq_bot=gocq_bot)
+                send_message(platform, message, f"RevChatGPT错误, 原因: \n{str(e)}", msg_ref=msg_ref)
 
     elif chosen_provider == REV_EDGEGPT:
-        if rev_edgegpt == None:
-            send_message(platform, message, f"管理员未启动此模型或者此模型初始化时失败。", msg_ref=msg_ref, gocq_loop=gocq_loop, qqchannel_bot=qqchannel_bot, gocq_bot=gocq_bot)
-            return
         if bing_cache_loop == None:
             if platform == PLATFORM_GOCQ:
                 bing_cache_loop = gocq_loop
             elif platform == PLATFORM_QQCHAN:
                 bing_cache_loop = qqchan_loop
-        hit, command_result = command_rev_edgegpt.check_command(qq_msg, bing_cache_loop, role, platform=platform, message_obj=message, cached_plugins=cached_plugins, qq_platform=gocq_bot)
+        hit, command_result = command_rev_edgegpt.check_command(qq_msg, bing_cache_loop, role, 
+                                                                platform=platform, message_obj=message, 
+                                                                cached_plugins=cached_plugins,
+                                                                qq_platform=gocq_bot)
         if not hit:
             try:
+                if not with_tag:
+                    return
+                if rev_edgegpt == None:
+                    send_message(platform, message, f"管理员未启动此模型或者此模型初始化时失败。", msg_ref=msg_ref)
+                    return
                 while rev_edgegpt.is_busy():
                     time.sleep(1)
 
                 res, res_code = asyncio.run_coroutine_threadsafe(rev_edgegpt.text_chat(qq_msg, platform), bing_cache_loop).result()
                 if res_code == 0: # bing不想继续话题，重置会话后重试。
-                    send_message(platform, message, "Bing不想继续话题了, 正在自动重置会话并重试。", msg_ref=msg_ref, gocq_loop=gocq_loop, qqchannel_bot=qqchannel_bot, gocq_bot=gocq_bot)
+                    send_message(platform, message, "Bing不想继续话题了, 正在自动重置会话并重试。", msg_ref=msg_ref)
                     asyncio.run_coroutine_threadsafe(rev_edgegpt.forget(), bing_cache_loop).result()
                     res, res_code = asyncio.run_coroutine_threadsafe(rev_edgegpt.text_chat(qq_msg, platform), bing_cache_loop).result()
                     if res_code == 0: # bing还是不想继续话题，大概率说明提问有问题。
                         asyncio.run_coroutine_threadsafe(rev_edgegpt.forget(), bing_cache_loop).result()
-                        send_message(platform, message, "Bing仍然不想继续话题, 会话已重置, 请检查您的提问后重试。", msg_ref=msg_ref, gocq_loop=gocq_loop, qqchannel_bot=qqchannel_bot, gocq_bot=gocq_bot)
+                        send_message(platform, message, "Bing仍然不想继续话题, 会话已重置, 请检查您的提问后重试。", msg_ref=msg_ref)
                         res = ""
                 chatgpt_res = str(res)
                 if REV_EDGEGPT in reply_prefix:
                     chatgpt_res = reply_prefix[REV_EDGEGPT] + chatgpt_res
             except BaseException as e:
                 gu.log("NewBing请求错误, 原因: "+str(e), gu.LEVEL_ERROR)
-                send_message(platform, message, f"Rev NewBing API错误。原因如下：\n{str(e)} \n前往官方频道反馈~", msg_ref=msg_ref, gocq_loop=gocq_loop, qqchannel_bot=qqchannel_bot, gocq_bot=gocq_bot)
+                send_message(platform, message, f"Rev NewBing API错误。原因如下：\n{str(e)} \n前往官方频道反馈~", msg_ref=msg_ref)
 
     # 切换回原来的语言模型
     if temp_switch != "":
@@ -658,23 +712,29 @@ def oper_msg(message,
 
             # 昵称
             if command == "nick":
-                with open("cmd_config.json", "r", encoding="utf-8") as f:
-                    global nick_qq
-                    nick_qq = json.load(f)["nick_qq"]
+                nick_qq = cc.get("nick_qq", nick_qq)
 
             if command_result[0]:
                 # 是否是画图指令
                 if isinstance(command_result[1], list) and len(command_result) == 3 and command_result[2] == 'draw':
-                    for i in command_result[1]:
-                        send_message(platform, message, i, msg_ref=msg_ref, image=i, gocq_loop=gocq_loop, qqchannel_bot=qqchannel_bot, gocq_bot=gocq_bot)
+                    if chatgpt != None:
+                        for i in command_result[1]:
+                            # i is a link
+                            # 保存到本地
+                            pic_res = requests.get(i, stream = True)
+                            if pic_res.status_code == 200:
+                                image = PILImage.open(io.BytesIO(pic_res.content))
+                                send_message(platform, message, [Image.fromFileSystem(gu.save_temp_img(image))], msg_ref=msg_ref)
+                    else:
+                        send_message(platform, message, "画图指令需要启用OpenAI官方模型.", msg_ref=msg_ref)
                 else:
                     try:
-                        send_message(platform, message, command_result[1], msg_ref=msg_ref, gocq_loop=gocq_loop, qqchannel_bot=qqchannel_bot, gocq_bot=gocq_bot)
+                        send_message(platform, message, command_result[1], msg_ref=msg_ref)
                     except BaseException as e:
-                        send_message(platform, message, f"回复消息出错: {str(e)}", msg_ref=msg_ref, gocq_loop=gocq_loop, qqchannel_bot=qqchannel_bot, gocq_bot=gocq_bot)
+                        send_message(platform, message, f"回复消息出错: {str(e)}", msg_ref=msg_ref)
 
             else:
-                send_message(platform, message, f"指令调用错误: \n{str(command_result[1])}", msg_ref=msg_ref, gocq_loop=gocq_loop, qqchannel_bot=qqchannel_bot, gocq_bot=gocq_bot)
+                send_message(platform, message, f"指令调用错误: \n{str(command_result[1])}", msg_ref=msg_ref)
 
         return
     
@@ -682,8 +742,8 @@ def oper_msg(message,
         return
 
     # 记录日志
-    logf.write(f"{reply_prefix} {str(chatgpt_res)}\n")
-    logf.flush()
+    # logf.write(f"{reply_prefix} {str(chatgpt_res)}\n")
+    # logf.flush()
 
     # 敏感过滤
     # 过滤不合适的词
@@ -693,12 +753,18 @@ def oper_msg(message,
     if baidu_judge != None:
         check, msg = baidu_judge.judge(chatgpt_res)
         if not check:
-            send_message(platform, message, f"你的提问得到的回复【百度内容审核】未通过，不予回复。\n\n{msg}", msg_ref=msg_ref, gocq_loop=gocq_loop, qqchannel_bot=qqchannel_bot, gocq_bot=gocq_bot)
+            send_message(platform, message, f"你的提问得到的回复【百度内容审核】未通过，不予回复。\n\n{msg}", msg_ref=msg_ref)
             return
         
     # 发送qq信息
     try:
-        send_message(platform, message, chatgpt_res, msg_ref=msg_ref, gocq_loop=gocq_loop, qqchannel_bot=qqchannel_bot, gocq_bot=gocq_bot)
+        if platform==PLATFORM_GOCQ:
+            if cc.get("qq_pic_mode", False):
+                send_message(platform, message, chatgpt_res, image_mode=True, msg_ref=msg_ref)
+            else:
+                send_message(platform, message, chatgpt_res, msg_ref=msg_ref)
+        else:
+            send_message(platform, message, chatgpt_res, msg_ref=msg_ref)
     except BaseException as e:
         gu.log("回复消息错误: \n"+str(e), gu.LEVEL_ERROR)
 
@@ -750,23 +816,10 @@ class gocqClient():
     # 收到群聊消息
     @gocq_app.receiver("GroupMessage")
     async def _(app: CQHTTP, source: GroupMessage):
-        global nick_qq
-        # 将nick_qq转换为元组
-        if nick_qq == None:
-            nick_qq = ("ai","!","！")
-        if isinstance(nick_qq, str):
-            nick_qq = (nick_qq,)
-        if isinstance(nick_qq, list):
-            nick_qq = tuple(nick_qq)
+        # gu.log(str(source), gu.LEVEL_INFO, max_len=9999)
 
         if isinstance(source.message[0], Plain):
-            if source.message[0].text.startswith(nick_qq):
-                _len = 0
-                for i in nick_qq:
-                    if source.message[0].text.startswith(i):
-                        _len = len(i)
-                source.message[0].text = source.message[0].text[_len:].strip()
-                new_sub_thread(oper_msg, (source, True, None, PLATFORM_GOCQ))
+            new_sub_thread(oper_msg, (source, True, None, PLATFORM_GOCQ))
         if isinstance(source.message[0], At):
             if source.message[0].qq == source.self_id:
                 new_sub_thread(oper_msg, (source, True, None, PLATFORM_GOCQ))
@@ -782,32 +835,25 @@ class gocqClient():
         
     @gocq_app.receiver("GroupMemberIncrease")
     async def _(app: CQHTTP, source: GroupMemberIncrease):
-        global nick_qq
+        global nick_qq, announcement
         await app.sendGroupMessage(source.group_id, [
-            Plain(text=f"欢迎加入本群！\n欢迎给https://github.com/Soulter/QQChannelChatGPT项目一个Star😊~\n@我输入help查看帮助~\n我叫{nick_qq}, 你也可以以【{nick_qq}+问题】的格式来提醒我并问我问题哦~\n")
+            Plain(text = announcement),
         ])
 
     @gocq_app.receiver("GuildMessage")
     async def _(app: CQHTTP, source: GuildMessage):
         # gu.log(str(source), gu.LEVEL_INFO, max_len=9999)
-        global nick_qq
-        if nick_qq == None:
-            nick_qq = ("ai","!","！")
-        if isinstance(nick_qq, str):
-            nick_qq = (nick_qq,)
-        if isinstance(nick_qq, list):
-            nick_qq = tuple(nick_qq)
 
         if isinstance(source.message[0], Plain):
-            if source.message[0].text.startswith(nick_qq):
-                _len = 0
-                for i in nick_qq:
-                    if source.message[0].text.startswith(i):
-                        _len = len(i)
-                source.message[0].text = source.message[0].text[_len:].strip()
-                new_sub_thread(oper_msg, (source, True, None, PLATFORM_GOCQ))
+            # if source.message[0].text.startswith(nick_qq):
+            #     _len = 0
+            #     for i in nick_qq:
+            #         if source.message[0].text.startswith(i):
+            #             _len = len(i)
+            #     source.message[0].text = source.message[0].text[_len:].strip()
+            new_sub_thread(oper_msg, (source, True, None, PLATFORM_GOCQ))
         if isinstance(source.message[0], At):
-            if source.message[0].tiny_id == source.self_tiny_id:
+            if source.message[0].qq == source.self_tiny_id:
                 new_sub_thread(oper_msg, (source, True, None, PLATFORM_GOCQ))
         else:
             return

main.py

@@ -1,6 +1,5 @@
 import os, sys
 from pip._internal import main as pipmain
-import util.general_utils as gu
 
 abs_path = os.path.dirname(os.path.realpath(sys.argv[0])) + '/'
 
@@ -14,11 +13,17 @@ def main():
         print(e)
         input("第三方依赖库未完全安装完毕，请退出程序重试。")
         exit()
-
+    import util.general_utils as gu
     if 'http_proxy' in cfg:
         os.environ['HTTP_PROXY'] = cfg['http_proxy']
     if 'https_proxy' in cfg:
         os.environ['HTTPS_PROXY'] = cfg['https_proxy']
+    
+    os.environ['NO_PROXY'] = 'cn.bing.com,https://api.sgroup.qq.com'
+
+    # 检查temp文件夹
+    if not os.path.exists(abs_path+"temp"):
+        os.mkdir(abs_path+"temp")
 
     provider = privider_chooser(cfg)
     if len(provider) == 0:
@@ -119,4 +124,4 @@ if __name__ == "__main__":
             except BaseException as e:
                 print(e)
                 print(f"[System-err] Replit Web保活服务启动失败:{str(e)}")
-    main()
+    main()

model/command/command.py

@@ -10,7 +10,14 @@ import util.plugin_util as putil
 import shutil
 import importlib
 from util import general_utils as gu
+from util.cmd_config import CmdConfig as cc
 from model.platform.qq import QQ
+import stat
+from nakuru.entities.components import (
+    Plain,
+    Image
+)
+from PIL import Image as PILImage
 
 PLATFORM_QQCHAN = 'qqchan'
 PLATFORM_GOCQ = 'gocq'
@@ -34,7 +41,11 @@ class Command:
         except BaseException as e:
             raise e
 
-    def check_command(self, message, role, platform, message_obj, cached_plugins: dict, qq_platform: QQ):
+    def check_command(self, message, role, platform, 
+                    message_obj, 
+                    cached_plugins: dict, 
+                    qq_platform: QQ,
+                    global_object: dict):
         # 插件
 
         for k, v in cached_plugins.items():
@@ -46,68 +57,100 @@ class Command:
                 gu.log(f"{k}插件加载出现问题，原因: {str(e)}\n已安装插件: {cached_plugins.keys}\n如果你没有相关装插件的想法, 请直接忽略此报错, 不影响其他功能的运行。", level=gu.LEVEL_WARNING)
 
         if self.command_start_with(message, "nick"):
-            return True, self.set_nick(message, platform)
+            return True, self.set_nick(message, platform, role)
         
         if self.command_start_with(message, "plugin"):
-            return True, self.plugin_oper(message, role, cached_plugins)
+            return True, self.plugin_oper(message, role, cached_plugins, platform)
         
         if self.command_start_with(message, "myid"):
             return True, self.get_my_id(message_obj, platform)
+        if self.command_start_with(message, "nconf") or self.command_start_with(message, "newconf"):
+            return True, self.get_new_conf(message, role, platform)
+        if self.command_start_with(message, "web"): # 网页搜索
+            return True, self.web_search(message, global_object)
         
         return False, None
     
+    def web_search(self, message, global_object):
+        if "web_search" not in global_object:
+            global_object["web_search"] = False
+        if message == "web on":
+            global_object["web_search"] = True
+            return True, "已开启网页搜索", "web"
+        elif message == "web off":
+            global_object["web_search"] = False
+            return True, "已关闭网页搜索", "web"
+        return True, f"网页搜索功能当前状态: {global_object['web_search']}", "web"
     def get_my_id(self, message_obj, platform):
+        print(message_obj)
         if platform == "gocq":
             if message_obj.type == "GuildMessage":
                 return True, f"你的频道id是{str(message_obj.sender.tiny_id)}", "plugin"
             else:
                 return True, f"你的QQ是{str(message_obj.sender.user_id)}", "plugin"
+        else:
+            return True, f"{str(message_obj)}\n（此指令为开发专用，为提供更多数据，请自行从中找出您的频道ID。在author->id中。）", "plugin"
+            
+    def get_new_conf(self, message, role, platform):
+        if role != "admin":
+            return False, f"你的身份组{role}没有权限使用此指令。", "newconf"
+        if platform == gu.PLATFORM_GOCQ:
+            l = message.split(" ")
+            if len(l) <= 1:
+                obj = cc.get_all()
+                p = gu.create_text_image("【cmd_config.json】", json.dumps(obj, indent=4, ensure_ascii=False))
+                return True, [Image.fromFileSystem(p)], "newconf"
+        return False, f"Not support or not implemented.", "newconf"
+            
 
     
     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:
+        if plugins is None:
             return False, "未找到任何插件模块"
+
+        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
     
     '''
     插件指令
     '''
-    def plugin_oper(self, message: str, role: str, cached_plugins: dict):
+    def plugin_oper(self, message: str, role: str, cached_plugins: dict, platform: str):
         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"
+            if platform == gu.PLATFORM_GOCQ:
+                p = gu.create_text_image("【插件指令面板】", "安装插件: \nplugin i 插件Github地址\n卸载插件: \nplugin d 插件名 \n重载插件: \nplugin reload\n查看插件列表：\nplugin l\n更新插件: plugin u 插件名\n")
+                return True, [Image.fromFileSystem(p)], "plugin"
+            return True, "\n=====插件指令面板=====\n安装插件: \nplugin i 插件Github地址\n卸载插件: \nplugin d 插件名 \n重载插件: \nplugin reload\n查看插件列表：\nplugin l\n更新插件: plugin u 插件名\n===============", "plugin"
         else:
             ppath = ""
             if os.path.exists("addons/plugins"):
@@ -151,7 +194,8 @@ class Command:
                     return False, f"你的身份组{role}没有权限删除插件", "plugin"
                 try:
                     # 删除文件夹
-                    shutil.rmtree(os.path.join(ppath, l[2]))
+                    # shutil.rmtree(os.path.join(ppath, l[2]))
+                    self.remove_dir(os.path.join(ppath, l[2]))
                     if l[2] in cached_plugins:
                         del cached_plugins[l[2]]
                     return True, "插件卸载成功~", "plugin"
@@ -162,6 +206,15 @@ class Command:
                 try:
                     repo = Repo(path = plugin_path)
                     repo.remotes.origin.pull()
+
+                    # 读取插件的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=l[2])
                     if ok:
                         return True, "\n更新插件成功!!", "plugin"
@@ -173,6 +226,9 @@ class Command:
             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()])
+                    if platform == gu.PLATFORM_GOCQ:
+                        p = gu.create_text_image("【已激活插件列表】", plugin_list_info + "\n使用plugin v 插件名 查看插件帮助\n")
+                        return True, [Image.fromFileSystem(p)], "plugin"
                     return True, "\n=====已激活插件列表=====\n" + plugin_list_info + "\n使用plugin v 插件名 查看插件帮助\n=================", "plugin"
                 except BaseException as e:
                     return False, f"获取插件列表失败，原因: {str(e)}", "plugin"
@@ -180,6 +236,9 @@ class Command:
                 try:
                     if l[2] in cached_plugins:
                         info = cached_plugins[l[2]]["info"]
+                        if platform == gu.PLATFORM_GOCQ:
+                            p = gu.create_text_image(f"【插件信息】", f"名称: {info['name']}\n{info['desc']}\n版本: {info['version']}\n作者: {info['author']}\n\n帮助:\n{info['help']}")
+                            return True, [Image.fromFileSystem(p)], "plugin"
                         res = f"\n=====插件信息=====\n名称: {info['name']}\n{info['desc']}\n版本: {info['version']}作者: {info['author']}\n\n帮助:\n{info['help']}"
                         return True, res, "plugin"
                     else:
@@ -204,12 +263,26 @@ class Command:
                 if role != "admin":
                     return False, f"你的身份组{role}没有权限开发者模式", "plugin"
                 return True, "cached_plugins: \n" + str(cached_plugins), "plugin"
+    
+
+    def remove_dir(self, file_path):        
+        while 1:
+            if not os.path.exists(file_path):
+                break
+            try:
+                shutil.rmtree(file_path)
+            except PermissionError as e:
+                err_file_path = str(e).split("\'", 2)[1]
+                if os.path.exists(err_file_path):
+                    os.chmod(err_file_path, stat.S_IWUSR)
 
 
     '''
     nick: 存储机器人的昵称
     '''
-    def set_nick(self, message: str, platform: str):
+    def set_nick(self, message: str, platform: str, role: str = "member"):
+        if role != "admin":
+            return True, "你无权使用该指令 :P", "nick"
         if platform == PLATFORM_GOCQ:
             l = message.split(" ")
             if len(l) == 1:
@@ -245,25 +318,39 @@ class Command:
             "update r": "重启机器人",
             "reset": "重置会话",
             "nick": "设置机器人昵称",
+            "plugin": "插件安装、卸载和重载",
+            "web on/off": "启动或关闭网页搜索能力",
             "/bing": "切换到bing模型",
             "/gpt": "切换到OpenAI ChatGPT API",
             "/revgpt": "切换到网页版ChatGPT",
-            "/bing 问题": "临时使用一次bing模型进行会话",
-            "/gpt 问题": "临时使用一次OpenAI ChatGPT API进行会话",
-            "/revgpt 问题": "临时使用一次网页版ChatGPT进行会话",
-            "plugin": "插件安装、卸载和重载"
         }
     
-    def help_messager(self, commands: dict):
+    def help_messager(self, commands: dict, platform: str, cached_plugins: dict = None):
         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"
+        msg = "# Help Center\n## 指令列表\n"
+        # msg = "Github项目名QQChannelChatGPT, 有问题提交issue, 欢迎Star\n【指令列表】\n"
         for key, value in commands.items():
-            msg += key + ": " + value + "\n"
+            msg += f"`{key}` - {value}\n"
+        # plugins
+        if cached_plugins != None:
+            plugin_list_info = "\n".join([f"`{k}` {v['info']['name']}\n{v['info']['desc']}\n" for k, v in cached_plugins.items()])
+            if plugin_list_info.strip() != "":
+                msg += "\n## 插件列表\n> 使用plugin v 插件名 查看插件帮助\n"
+                msg += plugin_list_info
         msg += notice
+
+        if platform == gu.PLATFORM_GOCQ:
+            try:
+                # p = gu.create_text_image("【Help Center】", msg)
+                p = gu.create_markdown_image(msg)
+                return [Image.fromFileSystem(p)]
+            except BaseException as e:
+                gu.log(str(e))
+                return msg
         return msg
     
     # 接受可变参数
@@ -349,6 +436,10 @@ class Command:
                         pash_tag = "QQChannelChatGPT"+os.sep
                     repo.remotes.origin.pull()
 
+                    if len(l) == 3 and l[2] == "r":
+                        py = sys.executable
+                        os.execl(py, py, *sys.argv)
+
                     return True, "更新成功~是否重启？输入update r重启（重启指令不返回任何确认信息）。", "update"
                     
                 except BaseException as e:

model/command/command_openai_official.py

@@ -2,11 +2,14 @@ from model.command.command import Command
 from model.provider.provider_openai_official import ProviderOpenAIOfficial
 from cores.qqbot.personality import personalities
 from model.platform.qq import QQ
+from util import general_utils as gu
+
 
 class CommandOpenAIOfficial(Command):
-    def __init__(self, provider: ProviderOpenAIOfficial):
+    def __init__(self, provider: ProviderOpenAIOfficial, global_object: dict):
         self.provider = provider
         self.cached_plugins = {}
+        self.global_object = global_object
         
     def check_command(self, 
                       message: str, 
@@ -16,8 +19,12 @@ class CommandOpenAIOfficial(Command):
                       platform: str,
                       message_obj,
                       cached_plugins: dict,
-                      qq_platform: QQ):
-        hit, res = super().check_command(message, role, platform, message_obj=message_obj, cached_plugins=cached_plugins, qq_platform=qq_platform)
+                      qq_platform: QQ,):
+        self.platform = platform
+        hit, res = super().check_command(message, role, platform, message_obj=message_obj, 
+                                        cached_plugins=cached_plugins, 
+                                        qq_platform=qq_platform,
+                                        global_object=self.global_object)
         if hit:
             return True, res
         if self.command_start_with(message, "reset", "重置"):
@@ -33,14 +40,14 @@ class CommandOpenAIOfficial(Command):
         elif self.command_start_with(message, "count"):
             return True, self.count()
         elif self.command_start_with(message, "help", "帮助"):
-            return True, self.help()
+            return True, self.help(cached_plugins)
         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, "画"):
+        elif self.command_start_with(message, "画", "draw"):
             return True, self.draw(message)
         elif self.command_start_with(message, "keyword"):
             return True, self.keyword(message, role)
@@ -52,7 +59,7 @@ class CommandOpenAIOfficial(Command):
         
         return False, None
     
-    def help(self):
+    def help(self, cached_plugins):
         commands = super().general_commands()
         commands['画'] = '画画'
         commands['key'] = '添加OpenAI key'
@@ -60,14 +67,18 @@ class CommandOpenAIOfficial(Command):
         commands['gpt'] = '查看gpt配置信息'
         commands['status'] = '查看key使用状态'
         commands['token'] = '查看本轮会话token'
-        return True, super().help_messager(commands), "help"
+        return True, super().help_messager(commands, self.platform, cached_plugins), "help"
 
-    
+        
     def reset(self, session_id: str):
+        if self.provider is None:
+            return False, "未启动OpenAI ChatGPT语言模型.", "reset"
         self.provider.forget(session_id)
         return True, "重置成功", "reset"
     
     def his(self, message: str, session_id: str, name: str):
+        if self.provider is None:
+            return False, "未启动OpenAI ChatGPT语言模型.", "his"
         #分页，每页5条
         msg = ''
         size_per_page = 3
@@ -84,12 +95,18 @@ class CommandOpenAIOfficial(Command):
         return True, f"历史记录如下：\n{p}\n第{page}页 | 共{max_page}页\n*输入/his 2跳转到第2页", "his"
     
     def token(self, session_id: str):
+        if self.provider is None:
+            return False, "未启动OpenAI ChatGPT语言模型.", "token"
         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):
+        if self.provider is None:
+            return False, "未启动OpenAI ChatGPT语言模型.", "gpt"
         return True, f"OpenAI GPT配置:\n {self.provider.chatGPT_configs}", "gpt"
     
     def status(self):
+        if self.provider is None:
+            return False, "未启动OpenAI ChatGPT语言模型.", "status"
         chatgpt_cfg_str = ""
         key_stat = self.provider.get_key_stat()
         index = 1
@@ -110,10 +127,14 @@ class CommandOpenAIOfficial(Command):
         return True, f"⭐使用情况({str(gg_count)}个已用):\n{chatgpt_cfg_str}⏰全频道已用{total}tokens", "status"
 
     def count(self):
+        if self.provider is None:
+            return False, "未启动OpenAI ChatGPT语言模型.", "reset"
         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):
+        if self.provider is None:
+            return False, "未启动OpenAI ChatGPT语言模型.", "reset"
         l = message.split(" ")
         if len(l) == 1:
             msg = "感谢您赞助key，key为官方API使用，请以以下格式赞助:\n/key xxxxx"
@@ -126,11 +147,15 @@ class CommandOpenAIOfficial(Command):
             return True, "该Key被验证为无效。也许是输入错误了，或者重试。", "key"
 
     def unset(self, session_id: str):
+        if self.provider is None:
+            return False, "未启动OpenAI ChatGPT语言模型.", "unset"
         self.provider.now_personality = {}
         self.provider.forget(session_id)
         return True, "已清除人格并重置历史记录。", "unset"
 
     def set(self, message: str, session_id: str):
+        if self.provider is None:
+            return False, "未启动OpenAI ChatGPT语言模型.", "set"
         l = message.split(" ")
         if len(l) == 1:
             return True, f"【由Github项目QQChannelChatGPT支持】\n\n【人格文本由PlexPt开源项目awesome-chatgpt-pr \
@@ -189,6 +214,8 @@ class CommandOpenAIOfficial(Command):
                 return True, f"自定义人格已设置。 \n人格信息: {ps}", "set"
             
     def draw(self, message):
+        if self.provider is None:
+            return False, "未启动OpenAI ChatGPT语言模型.", "draw"
         if message.startswith("/画"):
             message = message[2:]
         elif message.startswith("画"):

model/command/command_rev_chatgpt.py

@@ -3,9 +3,10 @@ from model.provider.provider_rev_chatgpt import ProviderRevChatGPT
 from model.platform.qq import QQ
 
 class CommandRevChatGPT(Command):
-    def __init__(self, provider: ProviderRevChatGPT):
+    def __init__(self, provider: ProviderRevChatGPT, global_object: dict):
         self.provider = provider
         self.cached_plugins = {}
+        self.global_object = global_object
 
     def check_command(self, 
                       message: str, 
@@ -14,11 +15,15 @@ class CommandRevChatGPT(Command):
                       message_obj,
                       cached_plugins: dict,
                       qq_platform: QQ):
-        hit, res = super().check_command(message, role, platform, message_obj=message_obj, cached_plugins=cached_plugins, qq_platform=qq_platform)
+        self.platform = platform
+        hit, res = super().check_command(message, role, platform, message_obj=message_obj, 
+                                        cached_plugins=cached_plugins,
+                                        qq_platform=qq_platform,
+                                        global_object=self.global_object)
         if hit:
             return True, res
         if self.command_start_with(message, "help", "帮助"):
-            return True, self.help()
+            return True, self.help(cached_plugins)
         elif self.command_start_with(message, "reset"):
             return True, self.reset()
         elif self.command_start_with(message, "update"):
@@ -33,5 +38,6 @@ class CommandRevChatGPT(Command):
     def reset(self):
         return False, "此功能暂未开放", "reset"
     
-    def help(self):
-        return True, super().help_messager(super().general_commands()), "help"
+    
+    def help(self, cached_plugins: dict):
+        return True, super().help_messager(super().general_commands(), self.platform, cached_plugins), "help"

model/command/command_rev_edgegpt.py

@@ -4,11 +4,11 @@ import asyncio
 from model.platform.qq import QQ
 
 class CommandRevEdgeGPT(Command):
-    def __init__(self, provider: ProviderRevEdgeGPT):
+    def __init__(self, provider: ProviderRevEdgeGPT, global_object: dict):
         self.provider = provider
         self.cached_plugins = {}
+        self.global_object = global_object
 
-        
     def check_command(self, 
                       message: str, 
                       loop, 
@@ -17,13 +17,17 @@ class CommandRevEdgeGPT(Command):
                       message_obj,
                       cached_plugins: dict, 
                       qq_platform: QQ):
-        hit, res = super().check_command(message, role, platform, message_obj=message_obj, cached_plugins=cached_plugins, qq_platform=qq_platform)
+        self.platform = platform
+        hit, res = super().check_command(message, role, platform, message_obj=message_obj, 
+                                        cached_plugins=cached_plugins,
+                                        qq_platform=qq_platform,
+                                        global_object=self.global_object)
         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()
+            return True, self.help(cached_plugins)
         elif self.command_start_with(message, "update"):
             return True, self.update(message, role)
         elif self.command_start_with(message, "keyword"):
@@ -34,6 +38,8 @@ class CommandRevEdgeGPT(Command):
         return False, None
     
     def reset(self, loop):
+        if self.provider is None:
+            return False, "未启动Bing语言模型.", "reset"
         res = asyncio.run_coroutine_threadsafe(self.provider.forget(), loop).result()
         print(res)
         if res:
@@ -41,6 +47,6 @@ class CommandRevEdgeGPT(Command):
         else:
             return res, "重置失败", "reset"
     
-    def help(self):
-        return True, super().help_messager(super().general_commands()), "help"
+    def help(self, cached_plugins: dict):
+        return True, super().help_messager(super().general_commands(), self.platform, cached_plugins), "help"
         

model/platform/qq.py

@@ -1,14 +1,24 @@
-from nakuru.entities.components import Plain, At, Image
+from nakuru.entities.components import Plain, At, Image, Node
 from util import general_utils as gu
+from util.cmd_config import CmdConfig
 import asyncio
 from nakuru import (
     CQHTTP,
     GuildMessage
 )
+import time
+
+
+class FakeSource:
+    def __init__(self, type, group_id):
+        self.type = type
+        self.group_id = group_id
+    
 class QQ:
-    def __init__(self, is_start: bool, gocq_loop = None) -> None:
+    def __init__(self, is_start: bool, cc: CmdConfig = None, gocq_loop = None) -> None:
         self.is_start = is_start
         self.gocq_loop = gocq_loop
+        self.cc = cc
 
     def run_bot(self, gocq):
         self.client: CQHTTP = gocq
@@ -21,61 +31,73 @@ class QQ:
                           source, 
                           res, 
                           image_mode: bool = False):
+
         if not self.is_start:
             raise Exception("管理员未启动GOCQ平台")
         """
          res可以是一个数组, 也就是gocq的消息链。
          插件开发者请使用send方法, 可以不用直接调用这个方法。
         """
-        gu.log("回复GOCQ消息: "+str(res), level=gu.LEVEL_INFO, tag="GOCQ", max_len=40)
+        gu.log("回复GOCQ消息: "+str(res), level=gu.LEVEL_INFO, tag="GOCQ", max_len=300)
 
         if isinstance(source, int):
-            source = {
-                "type": "GroupMessage",
-                "group_id": source
-            }
+            source = FakeSource("GroupMessage", source)
+        
+        # str convert to CQ Message Chain
+        if isinstance(res, str):
+            res_str = res
+            res = []
+            if source.type == "GroupMessage":
+                res.append(At(qq=source.user_id))
+            res.append(Plain(text=res_str))
+
+        # if image mode, put all Plain texts into a new picture.
+        if image_mode and isinstance(res, list):
+            plains = []
+            news = []
+            for i in res:
+                if isinstance(i, Plain):
+                    plains.append(i.text)
+                else:
+                    news.append(i)
+            p = gu.create_markdown_image("".join(plains))
+            news.append(Image.fromFileSystem(p))
+            res = news
+
 
         # 回复消息链
         if isinstance(res, list) and len(res) > 0:
             if source.type == "GuildMessage":
                 await self.client.sendGuildChannelMessage(source.guild_id, source.channel_id, res)
                 return
-            else:
+            elif source.type == "FriendMessage":
+                await self.client.sendFriendMessage(source.user_id, res)
+                return
+            elif source.type == "GroupMessage":
+                # 过长时forward发送
+                plain_text_len = 0
+                image_num = 0
+                for i in res:
+                    if isinstance(i, Plain):
+                        plain_text_len += len(i.text)
+                    elif isinstance(i, Image):
+                        image_num += 1
+                if plain_text_len > self.cc.get('qq_forward_threshold', 200):
+                    # 删除At
+                    for i in res:
+                        if isinstance(i, At):
+                            res.remove(i)
+                    node = Node(res)
+                    # node.content = res
+                    node.uin = source.self_id
+                    node.name = f"To {source.sender.nickname}:"
+                    node.time = int(time.time())
+                    print(node)
+                    nodes=[node]
+                    await self.client.sendGroupForwardMessage(source.group_id, nodes)
+                    return
                 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)
-                ])
-            elif source.type == "GuildMessage":
-                await self.client.sendGuildChannelMessage(source.guild_id, source.channel_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)
-                ])
-            elif source.type == "GuildMessage":
-                await self.client.sendGuildChannelMessage(source.guild_id, source.channel_id, [
-                    Plain(text="好的，我根据你的需要为你生成了一张图片😊"),
-                    Image.fromURL(url=res)
-                ])
 
     def send(self, 
             to,
@@ -101,4 +123,21 @@ class QQ:
         try:
             asyncio.run_coroutine_threadsafe(self.send_qq_msg(message_obj, res), self.gocq_loop).result()
         except BaseException as e:
-            raise e
+            raise e
+
+    def create_text_image(title: str, text: str, max_width=30, font_size=20):
+        '''
+        文本转图片。
+        title: 标题
+        text: 文本内容
+        max_width: 文本宽度最大值（默认30）
+        font_size: 字体大小（默认20）
+
+        返回：文件路径
+        '''
+        try:
+            img = gu.word2img(title, text, max_width, font_size)
+            p = gu.save_temp_img(img)
+            return p
+        except Exception as e:
+            raise e

model/platform/qqchan.py

@@ -1,12 +1,13 @@
 import io
 import botpy
-from PIL import Image
+from PIL import Image as PILImage
 from botpy.message import Message, DirectMessage
 import re
 import asyncio
 import requests
 from cores.qqbot.personality import personalities
 from util import general_utils as gu
+from nakuru.entities.components import Plain, At, Image
 
 class QQChan():
 
@@ -15,51 +16,57 @@ class QQChan():
         self.client = botclient
         self.client.run(appid=appid, token=token)
 
-    def send_qq_msg(self, message, res, image_mode=False, msg_ref = None):
-        gu.log("回复QQ频道消息: "+str(res), level=gu.LEVEL_INFO, tag="QQ频道", max_len=30)
+    # gocq兼容层
+    def gocq_compatible(self, gocq_message_chain: list):
+        plain_text = ""
+        image_path = None # only one img supported
+        for i in gocq_message_chain:
+            if isinstance(i, Plain):
+                plain_text += i.text
+            elif isinstance(i, Image) and image_path == None:
+                image_path = i.path
+        return plain_text, image_path
 
-        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信息
+            
+
+    def send_qq_msg(self, message: Message, res, msg_ref = None):
+        gu.log("回复QQ频道消息: "+str(res), level=gu.LEVEL_INFO, tag="QQ频道", max_len=500)
+
+        plain_text = ""
+        image_path = None
+        if isinstance(res, list):
+            # 兼容gocq
+            plain_text, image_path = self.gocq_compatible(res)
+        elif isinstance(res, str):
+            plain_text = res
+
+        print(plain_text, image_path)
+
+        try:
+            reply_res = asyncio.run_coroutine_threadsafe(message.reply(content=str(plain_text), message_reference = msg_ref, file_image=image_path), self.client.loop)
+            reply_res.result()
+        except BaseException as e:
+            # 分割过长的消息
+            if "msg over length" in str(e):
+                split_res = []
+                split_res.append(plain_text[:len(plain_text)//2])      
+                split_res.append(plain_text[len(plain_text)//2:])
+                for i in split_res:
+                    reply_res = asyncio.run_coroutine_threadsafe(message.reply(content=str(i), message_reference = msg_ref, file_image=image_path), self.client.loop)
+                    reply_res.result()
+            else:
+                # 发送qq信息
+                try:
+                    # 防止被qq频道过滤消息
+                    plain_text = plain_text.replace(".", " . ")
+                    reply_res = asyncio.run_coroutine_threadsafe(message.reply(content=str(plain_text), message_reference = msg_ref, file_image=image_path), self.client.loop)
+                    # 发送信息
+                except BaseException as e:
+                    print("QQ频道API错误: \n"+str(e))
                     try:
-                        # 防止被qq频道过滤消息
-                        res = res.replace(".", " . ")
-                        asyncio.run_coroutine_threadsafe(message.reply(content=res), self.client.loop).result()
-                        # 发送信息
+                        reply_res = asyncio.run_coroutine_threadsafe(message.reply(content=str(str.join(" ", plain_text)), message_reference = msg_ref, file_image=image_path), self.client.loop)
                     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)
+                        plain_text = re.sub(r'(https|http)?:\/\/(\w|\.|\/|\?|\=|\&|\%)*\b', '[被隐藏的链接]', str(e), flags=re.MULTILINE)
+                        plain_text = plain_text.replace(".", "·")
+                        asyncio.run_coroutine_threadsafe(message.reply(content=plain_text), self.client.loop).result()
+                        # send(message, f"QQ频道API错误：{str(e)}\n下面是格式化后的回答：\n{f_res}")

model/provider/provider_openai_official.py

@@ -90,7 +90,10 @@ class ProviderOpenAIOfficial(Provider):
             # 每隔10分钟转储一次
             time.sleep(10*self.history_dump_interval)
 
-    def text_chat(self, prompt, session_id):
+    def text_chat(self, prompt, session_id = None):
+        if session_id is None:
+            session_id = "unknown"
+            del self.session_dict["unknown"] 
         # 会话机制
         if session_id not in self.session_dict:
             self.session_dict[session_id] = []
@@ -112,6 +115,7 @@ class ProviderOpenAIOfficial(Provider):
         cache_data_list, new_record, req = self.wrap(prompt, session_id)
         retry = 0
         response = None
+        err = ''
         while retry < 5:
             try:
                 response = openai.ChatCompletion.create(
@@ -121,7 +125,7 @@ class ProviderOpenAIOfficial(Provider):
                 break
             except Exception as 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):
-                    gu.log("当前Key已超额或者不正常,正在切换", level=gu.LEVEL_WARNING)
+                    gu.log("当前Key已超额或异常, 正在切换", level=gu.LEVEL_WARNING)
                     self.key_stat[openai.api_key]['exceed'] = True
                     self.save_key_record()
 
@@ -135,12 +139,15 @@ class ProviderOpenAIOfficial(Provider):
                     gu.log("token超限, 清空对应缓存")
                     self.session_dict[session_id] = []
                     cache_data_list, new_record, req = self.wrap(prompt, session_id)
+                elif 'Limit: 3 / min. Please try again in 20s.' in str(e):
+                    time.sleep(60)
                 else:
                     gu.log(str(e), level=gu.LEVEL_ERROR)
+                err = str(e)
                 retry+=1
         if retry >= 5:
             gu.log(r"如果报错, 且您的机器在中国大陆内, 请确保您的电脑已经设置好代理软件(梯子), 并在配置文件设置了系统代理地址。详见https://github.com/Soulter/QQChannelChatGPT/wiki/%E4%BA%8C%E3%80%81%E9%A1%B9%E7%9B%AE%E9%85%8D%E7%BD%AE%E6%96%87%E4%BB%B6%E9%85%8D%E7%BD%AE", max_len=999)
-            raise BaseException("连接出错")
+            raise BaseException("连接出错: "+str(err))
         
         self.key_stat[openai.api_key]['used'] += response['usage']['total_tokens']
         self.save_key_record()

model/provider/provider_rev_chatgpt.py

@@ -2,28 +2,53 @@ from revChatGPT.V1 import Chatbot
 from revChatGPT import typings
 from model.provider.provider import Provider
 from util import general_utils as gu
+from util import cmd_config as cc
+import time
 
 
 class ProviderRevChatGPT(Provider):
     def __init__(self, config):
         self.rev_chatgpt = []
+        self.cc = cc.CmdConfig()
         for i in range(0, len(config['account'])):
             try:
-                gu.log(f"创建rev_ChatGPT负载{str(i)}中...", level=gu.LEVEL_INFO, tag="RevChatGPT")
+                gu.log(f"创建逆向ChatGPT负载{str(i+1)}中...", level=gu.LEVEL_INFO, tag="RevChatGPT")
 
                 if 'password' in config['account'][i]:
-                    config['account'][i]['password'] = str(config['account'][i]['password'])
+                    gu.log(f"创建逆向ChatGPT负载{str(i+1)}失败: 已不支持账号密码登录，请使用access_token方式登录。", level=gu.LEVEL_ERROR, tag="RevChatGPT")
+                    continue
+                rev_account_config = {
+                    'access_token': config['account'][i]['access_token'],
+                }
+                if self.cc.get("rev_chatgpt_model") != "":
+                    rev_account_config['model'] = self.cc.get("rev_chatgpt_model")
+                if len(self.cc.get("rev_chatgpt_plugin_ids")) > 0:
+                    rev_account_config['plugin_ids'] = self.cc.get("rev_chatgpt_plugin_ids")
+                if self.cc.get("rev_chatgpt_PUID") != "":
+                    rev_account_config['PUID'] = self.cc.get("rev_chatgpt_PUID")
+                if len(self.cc.get("rev_chatgpt_unverified_plugin_domains")) > 0:
+                    rev_account_config['unverified_plugin_domains'] = self.cc.get("rev_chatgpt_unverified_plugin_domains")
+                cb = Chatbot(config=rev_account_config)
+                # cb.captcha_solver = self.__captcha_solver
                 revstat = {
-                    'obj': Chatbot(config=config['account'][i]),
+                    'obj': cb,
                     'busy': False
                 }
                 self.rev_chatgpt.append(revstat)
             except BaseException as e:
-                gu.log(f"创建rev_ChatGPT负载{str(i)}失败: {str(e)}", level=gu.LEVEL_ERROR, tag="RevChatGPT")
+                gu.log(f"创建逆向ChatGPT负载{str(i+1)}失败: {str(e)}", level=gu.LEVEL_ERROR, tag="RevChatGPT")
 
     def forget(self) -> bool:
         return False
     
+    # def __captcha_solver(images: list[str], challenge_details: dict) -> int:
+    #     # Create tempfile
+    #     print("Captcha solver called")
+    #     print(images)
+    #     print(challenge_details)
+    #     input("Press Enter to continue...")
+    #     return 0
+        
     def request_text(self, prompt: str, bot) -> str:
         resp = ''
         err_count = 0
@@ -35,8 +60,6 @@ class ProviderRevChatGPT(Provider):
                     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:
@@ -44,17 +67,25 @@ class ProviderRevChatGPT(Provider):
                 if e.code == typings.ErrorType.PROHIBITED_CONCURRENT_QUERY_ERROR:
                     raise e
                 
+                if "The message you submitted was too long" in str(e):
+                    raise e
+                if "You've reached our limit of messages per hour." in str(e):
+                    raise e
+                if "Rate limited by proxy" in str(e):
+                    gu.log(f"触发请求频率限制, 60秒后自动重试。", level=gu.LEVEL_WARNING, tag="RevChatGPT")
+                    time.sleep(60)
+                
                 err_count += 1
-                gu.log(f"请求出现问题: {str(e)} | 正在重试: {str(err_count)}", level=gu.LEVEL_WARNING, tag="RevChatGPT")
+                gu.log(f"请求异常: {str(e)}，正在重试。({str(err_count)})", level=gu.LEVEL_WARNING, tag="RevChatGPT")
                 if err_count >= retry_count:
                     raise e
             except BaseException as e:
                 err_count += 1
-                gu.log(f"请求出现问题: {str(e)} | 正在重试: {str(err_count)}", level=gu.LEVEL_WARNING, tag="RevChatGPT")
+                gu.log(f"请求异常: {str(e)}，正在重试。({str(err_count)})", level=gu.LEVEL_WARNING, tag="RevChatGPT")
                 if err_count >= retry_count:
                     raise e
         if resp == '':
-            resp = "RevChatGPT出现故障."
+            resp = "RevChatGPT请求异常。"
         
         # print("[RevChatGPT] "+str(resp))
         return resp
@@ -80,8 +111,7 @@ class ProviderRevChatGPT(Provider):
             else:
                 err_msg += f"账号{cursor} - 错误原因: 忙碌"
                 continue
-        res = f'回复失败。错误跟踪：{err_msg}'
-        return res
+        raise Exception(f'回复失败。错误跟踪：{err_msg}')
     
     def is_all_busy(self) -> bool:
         for revstat in self.rev_chatgpt:

model/provider/provider_rev_edgegpt.py

@@ -3,6 +3,7 @@ from EdgeGPT import Chatbot, ConversationStyle
 import json
 import os
 from util import general_utils as gu
+from util.cmd_config import CmdConfig as cc
 
 
 class ProviderRevEdgeGPT(Provider):
@@ -11,7 +12,10 @@ class ProviderRevEdgeGPT(Provider):
         self.wait_stack = []
         with open('./cookies.json', 'r') as f:
             cookies = json.load(f)
-        self.bot = Chatbot(cookies=cookies)
+        proxy = cc.get("bing_proxy", None)
+        if proxy == "":
+            proxy = None
+        self.bot = Chatbot(cookies=cookies, proxy = proxy)
 
     def is_busy(self):
         return self.busy
@@ -75,7 +79,7 @@ class ProviderRevEdgeGPT(Provider):
                         await self.forget()
                         err_count += 1
                         continue
-                    reply_msg += f"\n⌈{throttling['numUserMessagesInConversation']}/{throttling['maxNumUserMessagesInConversation']}⌋"
+                    reply_msg += f"\n[{throttling['numUserMessagesInConversation']}/{throttling['maxNumUserMessagesInConversation']}]"
                 break
             except BaseException as e:
                 gu.log(str(e), level=gu.LEVEL_WARNING, tag="RevEdgeGPT")

requirements.txt

@@ -1,10 +1,11 @@
+pydantic~=1.10.4
 requests~=2.28.1
 openai~=0.27.4
 qq-botpy~=1.1.2
-revChatGPT~=5.0.0
+revChatGPT~=6.8.6
 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
+nakuru-project

util/cmd_config.py

@@ -0,0 +1,53 @@
+import os
+import json
+
+cpath = "cmd_config.json"
+
+def check_exist():
+    if not os.path.exists(cpath):
+        with open(cpath, "w", encoding="utf-8") as f:
+            json.dump({}, f, indent=4)
+            f.flush()
+
+class CmdConfig():
+
+    @staticmethod
+    def get(key, default=None):
+        check_exist()
+        with open(cpath, "r", encoding="utf-8") as f:
+            d = json.load(f)
+            if key in d:
+                return d[key]
+            else:
+                return default
+            
+    @staticmethod
+    def get_all():
+        check_exist()
+        with open(cpath, "r", encoding="utf-8") as f:
+            return json.load(f)
+        
+    @staticmethod
+    def put(key, value):
+        check_exist()
+        with open(cpath, "r", encoding="utf-8") as f:
+            d = json.load(f)
+            d[key] = value
+            with open(cpath, "w", encoding="utf-8") as f:
+                json.dump(d, f, indent=4)
+                f.flush()
+
+    @staticmethod
+    def init_attributes(keys: list, init_val = ""):
+        check_exist()
+        with open(cpath, "r", encoding="utf-8") as f:
+            d = json.load(f)
+            _tag = False
+            for k in keys:
+                if k not in d:
+                    d[k] = init_val
+                    _tag = True
+            if _tag:
+                with open(cpath, "w", encoding="utf-8") as f:
+                    json.dump(d, f, indent=4)
+                    f.flush()

util/func_call.py

@@ -0,0 +1,214 @@
+
+import json
+import util.general_utils as gu
+
+class FuncCallJsonFormatError(Exception):
+    def __init__(self, msg):
+        self.msg = msg
+
+    def __str__(self):
+        return self.msg
+    
+class FuncNotFoundError(Exception):
+    def __init__(self, msg):
+        self.msg = msg
+
+    def __str__(self):
+        return self.msg
+    
+class FuncCall():
+    def __init__(self, provider) -> None:
+        self.func_list = []
+        self.provider = provider
+
+    def add_func(self, name: str = None, func_args: list = None, desc: str = None, func_obj = None) -> None:
+        if name == None or func_args == None or desc == None or func_obj == None:
+            raise FuncCallJsonFormatError("name, func_args, desc must be provided.")
+        self._func = {
+            "name": name,
+            "args": func_args,
+            "description": desc,
+            "func_obj": func_obj,
+        }
+        self.func_list.append(self._func)
+
+    def func_dump(self, intent: int = 2) -> str:
+        _l = []
+        for f in self.func_list:
+            _l.append({
+                "name": f["name"],
+                "args": f["args"],
+                "description": f["description"],
+            })
+
+        return json.dumps(_l, indent=intent, ensure_ascii=False)
+    
+    def func_call(self, question, func_definition, is_task = False, tasks = None, taskindex = -1, is_summary = True):
+
+        funccall_prompt = """
+我正在实现function call功能，该功能旨在让你变成给定的问题到给定的函数的解析器（这意味着你不是创造函数）。
+下面会给你提供可能会用到函数的相关信息，和一个问题，你需要将其转换成给定的函数调用。
+- 你的返回信息只含json，且严格仿照以下内容（不含注释）:
+```
+{
+    "res": string // 如果没有找到对应的函数，那么你可以在这里正常输出内容。如果有，这里是空字符串。
+    "func_call": [ // 这是一个数组，里面包含了所有的函数调用，如果没有函数调用，那么这个数组是空数组。
+        {
+            "res": string // 如果没有找到对应的函数，那么你可以在这里正常输出内容。如果有，这里是空字符串。
+            "name": str, // 函数的名字
+            "args_type": {
+                "arg1": str, // 函数的参数的类型
+                "arg2": str,
+                ...
+            },
+            "args": {
+                "arg1": any, // 函数的参数
+                "arg2": any,
+                ...
+            }
+        },
+        ... // 可能在这个问题中会有多个函数调用
+    ],
+}
+```
+- 如果用户的要求较复杂，允许返回多个函数调用，但需保证这些函数调用的顺序正确。
+- 当问题没有提到给定的函数时，相当于提问方不打算使用function call功能，这时你可以在res中正常输出这个问题的回答（以AI的身份正常回答该问题，并将答案输出在res字段中，回答不要涉及到任何函数调用的内容，就只是正常讨论这个问题。）
+
+提供的函数是：
+
+"""
+
+        prompt = f"{funccall_prompt}\n```\n{func_definition}\n```\n"
+        prompt += f"""
+用户的提问是：
+```
+{question}
+```
+"""
+
+        # if is_task:
+        #     # task_prompt = f"\n任务列表为{str(tasks)}\n你目前进行到了任务{str(taskindex)}, **你不需要重新进行已经进行过的任务, 不要生成已经进行过的**"
+        #     prompt += task_prompt
+
+        # provider.forget()
+
+        _c = 0
+        while _c < 3:
+            try:
+                res = self.provider.text_chat(prompt)
+                if res.find('```') != -1:
+                    res = res[res.find('```json') + 7: res.rfind('```')]
+                gu.log("REVGPT func_call json result", bg=gu.BG_COLORS["green"], fg=gu.FG_COLORS["white"])
+                print(res)
+                res = json.loads(res)
+                break
+            except Exception as e:
+                _c += 1
+                if _c == 3:
+                    raise e
+                if "The message you submitted was too long" in str(e):
+                    raise e
+
+        invoke_func_res = ""
+
+        if len(res["func_call"]) > 0:
+            task_list = res["func_call"]
+
+            invoke_func_res_list = []
+
+            for res in task_list:
+                # 说明有函数调用
+                func_name = res["name"]
+                # args_type = res["args_type"]
+                args = res["args"]
+                # 调用函数
+                # func = eval(func_name)
+                func_target = None
+                for func in self.func_list:
+                    if func["name"] == func_name:
+                        func_target = func["func_obj"]
+                        break
+                if func_target == None:
+                    raise FuncNotFoundError(f"Request function {func_name} not found.")
+                t_res = str(func_target(**args))
+                invoke_func_res += f"{func_name} 调用结果：\n```\n{t_res}\n```\n"
+                invoke_func_res_list.append(invoke_func_res)
+                gu.log(f"[FUNC| {func_name} invoked]", bg=gu.BG_COLORS["green"], fg=gu.FG_COLORS["white"])
+                # print(str(t_res))
+
+            if is_summary:
+
+                # 生成返回结果
+                after_prompt = """
+函数返回以下内容："""+invoke_func_res+"""
+请以AI助手的身份结合返回的内容对用户提问做详细全面的回答。
+用户的提问是：
+```""" + question + """```
+- 在res字段中，不要输出函数的返回值，也不要针对返回值的字段进行分析，也不要输出用户的提问，而是理解这一段返回的结果，并以AI助手的身份回答问题，只需要输出回答的内容，不需要在回答的前面加上身份词。
+- 你的返回信息必须只能是json，且需严格遵循以下内容（不含注释）:
+```json
+{
+    "res": string, // 回答的内容
+    "func_call_again": bool // 如果函数返回的结果有错误或者问题，可将其设置为true，否则为false
+}
+```
+- 如果func_call_again为true，res请你设为空值，否则请你填写回答的内容。"""
+
+                _c = 0
+                while _c < 5:
+                    try:
+                        res = self.provider.text_chat(after_prompt)
+                        # 截取```之间的内容
+                        gu.log("DEBUG BEGIN", bg=gu.BG_COLORS["yellow"], fg=gu.FG_COLORS["white"])
+                        print(res)
+                        gu.log("DEBUG END", bg=gu.BG_COLORS["yellow"], fg=gu.FG_COLORS["white"])
+                        if res.find('```') != -1:
+                            res = res[res.find('```json') + 7: res.rfind('```')]
+                        gu.log("REVGPT after_func_call json result", bg=gu.BG_COLORS["green"], fg=gu.FG_COLORS["white"])
+                        after_prompt_res = res
+                        after_prompt_res = json.loads(after_prompt_res)
+                        break
+                    except Exception as e:
+                        _c += 1
+                        if _c == 5:
+                            raise e
+                        if "The message you submitted was too long" in str(e):
+                            # 如果返回的内容太长了，那么就截取一部分
+                            invoke_func_res = invoke_func_res[:int(len(invoke_func_res) / 2)]
+                            after_prompt = """
+函数返回以下内容："""+invoke_func_res+"""
+请以AI助手的身份结合返回的内容对用户提问做详细全面的回答。
+用户的提问是：
+```""" + question + """```
+- 在res字段中，不要输出函数的返回值，也不要针对返回值的字段进行分析，也不要输出用户的提问，而是理解这一段返回的结果，并以AI助手的身份回答问题，只需要输出回答的内容，不需要在回答的前面加上身份词。
+- 你的返回信息必须只能是json，且需严格遵循以下内容（不含注释）:
+```json
+{
+    "res": string, // 回答的内容
+    "func_call_again": bool // 如果函数返回的结果有错误或者问题，可将其设置为true，否则为false
+}
+```
+- 如果func_call_again为true，res请你设为空值，否则请你填写回答的内容。"""
+                        else:
+                            raise e
+
+                if "func_call_again" in after_prompt_res and after_prompt_res["func_call_again"]:
+                    # 如果需要重新调用函数
+                    # 重新调用函数
+                    gu.log("REVGPT func_call_again", bg=gu.BG_COLORS["purple"], fg=gu.FG_COLORS["white"])
+                    res = self.func_call(question, func_definition)
+                    return res, True
+
+                gu.log("REVGPT func callback:", bg=gu.BG_COLORS["green"], fg=gu.FG_COLORS["white"])
+                # print(after_prompt_res["res"])
+                return after_prompt_res["res"], True
+            else:
+                return str(invoke_func_res_list), True
+        else:
+            # print(res["res"])
+            return res["res"], False
+
+
+
+
+

util/general_utils.py

@@ -1,5 +1,13 @@
 import datetime
+import time
 import socket
+from PIL import Image, ImageDraw, ImageFont
+import os
+import re
+import requests
+
+PLATFORM_GOCQ = 'gocq'
+PLATFORM_QQCHAN = 'qqchan'
 
 FG_COLORS = {
     "black": "30",
@@ -43,7 +51,7 @@ def log(
         tag: str = "System",
         fg: str = None,
         bg: str = None,
-        max_len: int = 100):
+        max_len: int = 300):
     """
     日志记录函数
     """
@@ -85,3 +93,401 @@ def port_checker(port: int, host: str = "localhost"):
     except Exception:
         sk.close()
         return False
+    
+def word2img(title: str, text: str, max_width=30, font_size=20):
+    if os.path.exists("resources/fonts/syst.otf"):
+        font_path = "resources/fonts/syst.otf"
+    elif os.path.exists("QQChannelChatGPT/resources/fonts/syst.otf"):
+        font_path = "QQChannelChatGPT/resources/fonts/syst.otf"
+    elif os.path.exists("C:/Windows/Fonts/simhei.ttf"):
+        font_path = "C:/Windows/Fonts/simhei.ttf"
+    elif os.path.exists("/usr/share/fonts/opentype/noto/NotoSansCJK-Regular.ttc"):
+        font_path = "/usr/share/fonts/opentype/noto/NotoSansCJK-Regular.ttc"
+    else:
+        raise Exception("找不到字体文件")
+    
+    width_factor = 1.0
+    height_factor = 1.5
+    # 格式化文本宽度最大为30
+    lines = text.split('\n')
+    i = 0
+    length = len(lines)
+    for l in lines:
+        if len(l) > max_width:
+            # lines[i] = l[:max_width] + '\n' + l[max_width:]
+            # for
+            cp = l
+            for ii in range(len(l)):
+                if ii % max_width == 0:
+                    cp = cp[:ii] + '\n' + cp[ii:]
+                    length += 1
+            lines[i] = cp
+        i += 1
+    text = '\n'.join(lines)
+    width = int(max_width * font_size * width_factor)
+    height = int(length * font_size * height_factor)
+    image = Image.new('RGB', (width, height), (255, 255, 255))
+    draw = ImageDraw.Draw(image)
+
+    text_font = ImageFont.truetype(font_path, font_size)
+    title_font = ImageFont.truetype(font_path, font_size + 5)
+    # 标题居中
+    title_width, title_height = title_font.getsize(title)
+    draw.text(((width - title_width) / 2, 10), title, fill=(0, 0, 0), font=title_font)
+    # 文本不居中
+    draw.text((10, title_height+20), text, fill=(0, 0, 0), font=text_font)
+
+    return image
+
+
+def render_markdown(markdown_text, image_width=800, image_height=600, font_size=26, font_color=(0, 0, 0), bg_color=(255, 255, 255)):
+
+    HEADER_MARGIN = 20
+    HEADER_FONT_STANDARD_SIZE = 42
+
+    QUOTE_LEFT_LINE_MARGIN = 10
+    QUOTE_FONT_LINE_MARGIN = 6 # 引用文字距离左边线的距离和上下的距离
+    QUOTE_LEFT_LINE_HEIGHT = font_size + QUOTE_FONT_LINE_MARGIN * 2
+    QUOTE_LEFT_LINE_WIDTH = 5
+    QUOTE_LEFT_LINE_COLOR = (180, 180, 180)
+    QUOTE_FONT_SIZE = font_size
+    QUOTE_FONT_COLOR = (180, 180, 180)
+    # QUOTE_BG_COLOR = (255, 255, 255)
+
+    CODE_BLOCK_MARGIN = 10
+    CODE_BLOCK_FONT_SIZE = font_size
+    CODE_BLOCK_FONT_COLOR = (255, 255, 255)
+    CODE_BLOCK_BG_COLOR = (240, 240, 240)
+    CODE_BLOCK_CODES_MARGIN_VERTICAL = 5 # 代码块和代码之间的距离
+    CODE_BLOCK_CODES_MARGIN_HORIZONTAL = 5 # 代码块和代码之间的距离
+    CODE_BLOCK_TEXT_MARGIN = 4 # 代码和代码之间的距离
+
+    INLINE_CODE_MARGIN = 8
+    INLINE_CODE_FONT_SIZE = font_size
+    INLINE_CODE_FONT_COLOR = font_color
+    INLINE_CODE_FONT_MARGIN = 4
+    INLINE_CODE_BG_COLOR = (230, 230, 230)
+    INLINE_CODE_BG_HEIGHT = INLINE_CODE_FONT_SIZE + INLINE_CODE_FONT_MARGIN * 2
+
+    LIST_MARGIN = 8
+    LIST_FONT_SIZE = font_size
+    LIST_FONT_COLOR = font_color
+
+    TEXT_LINE_MARGIN = 8
+
+    IMAGE_MARGIN = 15
+    # 用于匹配图片的正则表达式
+    IMAGE_REGEX = r"!\s*\[.*?\]\s*\((.*?)\)"
+
+    
+    if os.path.exists("resources/fonts/syst.otf"):
+        font_path = "resources/fonts/syst.otf"
+    elif os.path.exists("QQChannelChatGPT/resources/fonts/syst.otf"):
+        font_path = "QQChannelChatGPT/resources/fonts/syst.otf"
+    elif os.path.exists("C:/Windows/Fonts/simhei.ttf"):
+        font_path = "C:/Windows/Fonts/simhei.ttf"
+    elif os.path.exists("/usr/share/fonts/opentype/noto/NotoSansCJK-Regular.ttc"):
+        font_path = "/usr/share/fonts/opentype/noto/NotoSansCJK-Regular.ttc"
+    else:
+        raise Exception("找不到字体文件")
+    # backup
+    if os.path.exists("resources/fonts/simhei.ttf"):
+        font_path1 = "resources/fonts/simhei.ttf"
+    elif os.path.exists("QQChannelChatGPT/resources/fonts/simhei.ttf"):
+        font_path1 = "QQChannelChatGPT/resources/fonts/simhei.ttf"
+    else:
+        font_path1 = font_path
+    # 加载字体
+    font = ImageFont.truetype(font_path, font_size)
+    
+    images: Image = {}
+    
+    # pre_process, get height of each line
+    pre_lines = markdown_text.split('\n')
+    height = 0
+    pre_in_code = False
+    i = -1
+    _pre_lines = []
+    for line in pre_lines:
+        i += 1
+        # 处理图片
+        if re.search(IMAGE_REGEX, line):
+            try:
+                image_url = re.findall(IMAGE_REGEX, line)[0]
+                print(image_url)
+                image_res = Image.open(requests.get(image_url, stream=True, timeout=5).raw)
+                images[i] = image_res
+                # 最大不得超过image_width的50%
+                img_height = image_res.size[1]
+
+                if image_res.size[0] > image_width*0.5:
+                    image_res = image_res.resize((int(image_width*0.5), int(image_res.size[1]*image_width*0.5/image_res.size[0])))
+                    img_height = image_res.size[1]
+
+                height += img_height + IMAGE_MARGIN*2
+            
+                line = re.sub(IMAGE_REGEX, "", line)
+            except Exception as e:
+                print(e)
+                line = re.sub(IMAGE_REGEX, "\n[加载失败的图片]\n", line)
+                continue
+            
+        line.replace("\t", "    ")
+        if font.getsize(line)[0] > image_width:
+            cp = line
+            _width = 0
+            _word_cnt = 0
+            for ii in range(len(line)):
+                # 检测是否是中文
+                _width += font.getsize(line[ii])[0]
+                _word_cnt+=1
+                if _width > image_width:
+                    _pre_lines.append(cp[:_word_cnt])
+                    cp = cp[_word_cnt:]
+                    _word_cnt=0
+                    _width=0
+            _pre_lines.append(cp)
+        else:
+            _pre_lines.append(line)
+    pre_lines = _pre_lines
+
+    i=-1
+    for line in pre_lines:
+        if line == "":
+            height += TEXT_LINE_MARGIN
+            continue
+        i += 1
+        line = line.strip()
+        if pre_in_code and not line.startswith("```"):
+            height += font_size + CODE_BLOCK_TEXT_MARGIN
+            # pre_codes.append(line)
+            continue
+        if line.startswith("#"):
+            header_level = line.count("#")
+            height += HEADER_FONT_STANDARD_SIZE + HEADER_MARGIN*2 - header_level * 4
+        elif line.startswith("-"):
+            height += font_size+LIST_MARGIN*2
+        elif line.startswith(">"):
+            height += font_size+QUOTE_LEFT_LINE_MARGIN*2
+        elif line.startswith("```"):
+            if pre_in_code:
+                pre_in_code = False
+                # pre_codes = []
+                height += CODE_BLOCK_MARGIN
+            else:
+                pre_in_code = True
+                height += CODE_BLOCK_MARGIN
+        elif re.search(r"`(.*?)`", line):
+            height += font_size+INLINE_CODE_FONT_MARGIN*2+INLINE_CODE_MARGIN*2
+        else:
+            height += font_size + TEXT_LINE_MARGIN*2
+
+    markdown_text = '\n'.join(pre_lines)
+    print("Pre process done, height: ", height)
+    image_height = height
+    if image_height < 100:
+        image_height = 100
+    image_width += 20
+    
+    # 创建空白图像
+    image = Image.new('RGB', (image_width, image_height), bg_color)
+    draw = ImageDraw.Draw(image)
+
+
+    # # get all the emojis unicode in the markdown text
+    # unicode_text = markdown_text.encode('unicode_escape').decode()
+    # # print(unicode_text)
+    # unicode_emojis = re.findall(r'\\U\w{8}', unicode_text)
+    # emoji_base_url = "https://abs.twimg.com/emoji/v1/72x72/{unicode_emoji}.png"
+
+    # 设置初始位置
+    x, y = 10, 10
+
+    # 解析Markdown文本
+    lines = markdown_text.split("\n")
+    # lines = pre_lines
+
+    in_code_block = False
+    code_block_start_y = 0
+    code_block_codes = []
+
+    index = -1
+    for line in lines:
+        index += 1
+        if in_code_block and not line.startswith("```"):
+            code_block_codes.append(line)
+            y += font_size + CODE_BLOCK_TEXT_MARGIN
+            continue
+        line = line.strip()
+
+        if line.startswith("#"):
+            # unicode_emojis = re.findall(r'\\U0001\w{4}', line)
+            # for unicode_emoji in unicode_emojis:
+            #     line = line.replace(unicode_emoji, "")
+            # unicode_emoji = ""
+            # if len(unicode_emojis) > 0:
+            #     unicode_emoji = unicode_emojis[0]
+            
+            # 处理标题
+            header_level = line.count("#")
+            line = line.strip("#").strip()
+            font_size_header = HEADER_FONT_STANDARD_SIZE - header_level * 4
+
+            # if unicode_emoji != "":
+            #     emoji_url = emoji_base_url.format(unicode_emoji=unicode_emoji[-5:])
+            #     emoji = Image.open(requests.get(emoji_url, stream=True).raw)
+            #     emoji = emoji.resize((font_size, font_size))
+            #     image.paste(emoji, (x, y))
+            #     x += font_size
+
+            font = ImageFont.truetype(font_path, font_size_header)
+            y += HEADER_MARGIN # 上边距
+            # 字间距
+            draw.text((x, y), line, font=font, fill=font_color)
+            draw.line((x, y + font_size_header + 8, image_width - 10, y + font_size_header + 8), fill=(230, 230, 230), width=3)
+            y += font_size_header + HEADER_MARGIN
+
+        elif line.startswith(">"):
+            # 处理引用
+            quote_text = line.strip(">")
+            # quote_width = image_width - 20  # 引用框的宽度为图像宽度减去左右边距
+            # quote_height = font_size + 10  # 引用框的高度为字体大小加上上下边距
+            # quote_box = (x, y, x + quote_width, y + quote_height)
+            # draw.rounded_rectangle(quote_box, radius=5, fill=(230, 230, 230), width=2)  # 使用灰色填充矩形框作为引用背景
+            y+=QUOTE_LEFT_LINE_MARGIN
+            draw.line((x, y, x, y + QUOTE_LEFT_LINE_HEIGHT), fill=QUOTE_LEFT_LINE_COLOR, width=QUOTE_LEFT_LINE_WIDTH)
+            font = ImageFont.truetype(font_path, QUOTE_FONT_SIZE)
+            draw.text((x + QUOTE_FONT_LINE_MARGIN, y + QUOTE_FONT_LINE_MARGIN), quote_text, font=font, fill=QUOTE_FONT_COLOR)
+            y += font_size + QUOTE_LEFT_LINE_HEIGHT + QUOTE_LEFT_LINE_MARGIN
+        
+        elif line.startswith("-"):
+            # 处理列表
+            list_text = line.strip("-").strip()
+            font = ImageFont.truetype(font_path, LIST_FONT_SIZE)
+            y += LIST_MARGIN
+            draw.text((x, y), "  ·  " + list_text, font=font, fill=LIST_FONT_COLOR)
+            y += font_size + LIST_MARGIN
+
+        elif line.startswith("```"):
+            if not in_code_block:
+                code_block_start_y = y+CODE_BLOCK_MARGIN
+                in_code_block = True
+            else:
+                # print(code_block_codes)
+                in_code_block = False
+                codes = "\n".join(code_block_codes)
+                code_block_codes = []
+                draw.rounded_rectangle((x, code_block_start_y, image_width - 10, y+CODE_BLOCK_CODES_MARGIN_VERTICAL + CODE_BLOCK_TEXT_MARGIN), radius=5, fill=CODE_BLOCK_BG_COLOR, width=2)
+                font = ImageFont.truetype(font_path1, CODE_BLOCK_FONT_SIZE)
+                draw.text((x + CODE_BLOCK_CODES_MARGIN_HORIZONTAL, code_block_start_y + CODE_BLOCK_CODES_MARGIN_VERTICAL), codes, font=font, fill=font_color)
+                y += CODE_BLOCK_CODES_MARGIN_VERTICAL + CODE_BLOCK_MARGIN
+        # y += font_size+10
+        elif re.search(r"`(.*?)`", line):
+            y += INLINE_CODE_MARGIN # 上边距
+            # 处理行内代码
+            code_regex = r"`(.*?)`"
+            parts_inline = re.findall(code_regex, line)
+            # print(parts_inline)
+            parts = re.split(code_regex, line)
+            # print(parts)
+            for part in parts:
+                # the judge has a tiny bug.
+                # when line is like "hi`hi`". all the parts will be in parts_inline.
+                if part in parts_inline:
+                    font = ImageFont.truetype(font_path, INLINE_CODE_FONT_SIZE)
+                    code_text = part.strip("`")
+                    code_width = font.getsize(code_text)[0] + INLINE_CODE_FONT_MARGIN*2
+                    x += INLINE_CODE_MARGIN
+                    code_box = (x, y, x + code_width, y + INLINE_CODE_BG_HEIGHT)
+                    draw.rounded_rectangle(code_box, radius=5, fill=INLINE_CODE_BG_COLOR, width=2)  # 使用灰色填充矩形框作为引用背景
+                    draw.text((x+INLINE_CODE_FONT_MARGIN, y), code_text, font=font, fill=font_color)
+                    x += code_width+INLINE_CODE_MARGIN-INLINE_CODE_FONT_MARGIN
+                else:
+                    font = ImageFont.truetype(font_path, font_size)
+                    draw.text((x, y), part, font=font, fill=font_color)
+                    x += font.getsize(part)[0]
+            y += font_size + INLINE_CODE_MARGIN
+            x = 10
+
+        else:
+            # 处理普通文本
+            if line == "":
+                y += TEXT_LINE_MARGIN
+            else:
+                font = ImageFont.truetype(font_path, font_size)
+                
+                draw.text((x, y), line, font=font, fill=font_color)
+                y += font_size + TEXT_LINE_MARGIN*2
+
+        # 图片特殊处理
+        if index in images:
+            image_res = images[index]
+            # 最大不得超过image_width的50%
+            if image_res.size[0] > image_width*0.5:
+                image_res = image_res.resize((int(image_width*0.5), int(image_res.size[1]*image_width*0.5/image_res.size[0])))
+            image.paste(image_res, (IMAGE_MARGIN, y))
+            y += image_res.size[1] + IMAGE_MARGIN*2
+    return image
+
+
+def save_temp_img(img: Image) -> str:
+    if not os.path.exists("temp"):
+        os.makedirs("temp")
+
+    # 获得文件创建时间，清除超过1小时的
+    try:
+        for f in os.listdir("temp"):
+            path = os.path.join("temp", f)
+            if os.path.isfile(path):
+                ctime = os.path.getctime(path)
+                if time.time() - ctime > 3600:
+                    os.remove(path)
+    except Exception as e:
+        log(f"清除临时文件失败: {e}", level=LEVEL_WARNING, tag="GeneralUtils")
+
+    # 获得时间戳
+    timestamp = int(time.time())
+    p = f"temp/{timestamp}.png"
+    img.save(p)
+    return p
+
+
+def create_text_image(title: str, text: str, max_width=30, font_size=20):
+    '''
+    文本转图片。
+    title: 标题
+    text: 文本内容
+    max_width: 文本宽度最大值（默认30）
+    font_size: 字体大小（默认20）
+
+    返回：文件路径
+    '''
+    try:
+        img = word2img(title, text, max_width, font_size)
+        p = save_temp_img(img)
+        return p
+    except Exception as e:
+        raise e
+    
+def create_markdown_image(text: str):
+    '''
+    markdown文本转图片。
+    返回：文件路径
+    '''
+    try:
+        img = render_markdown(text)
+        p = save_temp_img(img)
+        return p
+    except Exception as e:
+        raise e
+    
+def test_markdown():
+    # 示例使用
+    markdown_text = """# Help Center
+    ! [] (https://soulter.top/helpme.jpg)
+    """
+    image = render_markdown(markdown_text)
+    image.show()
+
+# test_markdown()
+

util/gplugin.py

@@ -0,0 +1,150 @@
+import requests
+import util.general_utils as gu
+from bs4 import BeautifulSoup
+import time
+from util.func_call import (
+    FuncCall, 
+    FuncCallJsonFormatError, 
+    FuncNotFoundError
+)
+def tidy_text(text: str) -> str:
+    return text.strip().replace("\n", "").replace(" ", "").replace("\r", "")
+
+def special_fetch_zhihu(link: str) -> str:
+    headers = {
+        "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) \
+            AppleWebKit/537.36 (KHTML, like Gecko) Chrome/91.0.4472.124 Safari/537.36"
+    }
+    response = requests.get(link, headers=headers)
+    soup = BeautifulSoup(response.text, "html.parser")
+    r = soup.find(class_="List-item").find(class_="RichContent-inner")
+    if r is None:
+        print("debug: zhihu none")
+        raise Exception("zhihu none")
+    return tidy_text(r.text)
+
+def web_keyword_search_via_bing(keyword) -> str:
+    headers = {
+        "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) \
+            AppleWebKit/537.36 (KHTML, like Gecko) Chrome/91.0.4472.124 Safari/537.36"
+    }
+    url = "https://cn.bing.com/search?q="+keyword
+    _cnt = 0
+    _detail_store = []
+    while _cnt < 5:
+        try:
+            response = requests.get(url, headers=headers)
+            soup = BeautifulSoup(response.text, "html.parser")
+            res = []
+            ols = soup.find(id="b_results")
+            for i in ols.find_all("li", class_="b_algo"):
+                try:
+                    title = i.find("h2").text
+                    desc = i.find("p").text
+                    link = i.find("h2").find("a").get("href")
+                    res.append({
+                        "title": title,
+                        "desc": desc,
+                        "link": link,
+                    })
+                    if len(_detail_store) < 2 and "zhihu.com" in link:
+                        try:
+                            _detail_store.append(special_fetch_zhihu(link)[:800])
+                        except BaseException as e:
+                            print(f"zhihu parse err: {str(e)}")
+                    if len(res) >= 5: # 限制5条
+                        break
+                except Exception as e:
+                    print(f"bing parse err: {str(e)}")
+            if len(res) == 0:
+                break
+            if len(_detail_store) > 0:
+                ret = f"{str(res)} \n来源知乎的具体资料: {str(_detail_store)}"
+            else:
+                ret = f"{str(res)}"
+            return str(ret)
+        except Exception as e:
+            print(f"bing fetch err: {str(e)}")
+            _cnt += 1
+            time.sleep(1)
+    print("fail to fetch bing info, using sougou.")
+    return web_keyword_search_via_sougou(keyword)
+
+def web_keyword_search_via_sougou(keyword) -> str:
+    headers = {
+        "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) \
+            AppleWebKit/537.36 (KHTML, like Gecko) Chrome/91.0.4472.124 Safari/537.36",
+    }
+    url = f"https://sogou.com/web?query={keyword}"
+    response = requests.get(url, headers=headers)
+    response.encoding = "utf-8"
+    soup = BeautifulSoup(response.text, "html.parser")
+    
+    res = []
+    results = soup.find("div", class_="results")
+    for i in results.find_all("div", class_="vrwrap"):
+        try:
+            title = tidy_text(i.find("h3").text)
+            link = tidy_text(i.find("h3").find("a").get("href"))
+            if link.startswith("/link?url="):
+                link = "https://www.sogou.com" + link
+            res.append({
+                "title": title,
+                "link": link,
+            })
+        except:
+            pass
+    ret = f"{str(res)} \n全部内容: {tidy_text(soup.text)}"
+    return ret
+
+def fetch_website_content(url):
+    headers = {
+        "User-Agent": "Mozilla/5.0 (Windows NT 10.0; Win64; x64) \
+            AppleWebKit/537.36 (KHTML, like Gecko) Chrome/91.0.4472.124 Safari/537.36"
+    }
+    response = requests.get(url, headers=headers)
+    soup = BeautifulSoup(response.text, "html.parser")
+    res = soup.text
+    res = res.replace("\n", "")
+    with open(f"temp_{time.time()}.html", "w", encoding="utf-8") as f:
+        f.write(res)
+    return res
+
+def web_search(question, provider):
+
+    new_func_call = FuncCall(provider)
+
+    new_func_call.add_func("web_keyword_search_via_bing", [{
+        "type": "string",
+        "name": "keyword",
+        "brief": "必应搜索的关键词(分词，尽量保留所有信息)"
+        }], 
+    "在必应搜索引擎上搜索给定的关键词，并且返回第一页的搜索结果列表(标题,简介和链接)",
+    web_keyword_search_via_bing
+    )
+
+    func_definition1 = new_func_call.func_dump()
+    question1 = f"{question} \n（只能调用一个函数。）"
+    res1, has_func = new_func_call.func_call(question1, func_definition1, is_task=False, is_summary=False)
+    has_func = True
+    if has_func:
+        provider.forget()
+        question3 = f"""请你回答`{question}`问题。\n以下是相关材料，你请直接拿此材料针对问题进行总结回答，然后再给出参考链接。不要提到任何函数调用的信息。```\n{res1}\n```\n"""
+        print(question3)
+        _c = 0
+        while _c < 5:
+            try:
+                print('text chat')
+                res3 = provider.text_chat(question3)
+                break
+            except Exception as e:
+                print(e)
+                _c += 1
+                if _c == 5:
+                    raise e
+                if "The message you submitted was too long" in str(e):
+                    res2 = res2[:int(len(res2) / 2)]
+                    question3 = f"""请你回答`{question}`问题。\n以下是相关材料，请直接拿此材料针对问题进行回答，然后再给出参考链接。```\n{res1}\n{res2}\n```\n"""
+        return res3
+    else:
+        return res1

util/log.py

@@ -1,11 +0,0 @@
-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)