🔖 v1.7.0

更换百度一下为百度百科 (#627 )
fix slow aifalse (#631 )
2026-02-06 23:30:20 +00:00 · 2023-03-20 12:28:19 +08:00 · 2023-03-20 12:23:52 +08:00 · 2023-03-20 11:59:03 +08:00 · 2023-03-20 11:57:46 +08:00 · 2023-03-18 12:07:13 +08:00
33 changed files with 1614 additions and 497 deletions
--- a/.github/workflows/release.yml
+++ b/.github/workflows/release.yml
@@ -22,6 +22,6 @@ jobs:
        uses: goreleaser/goreleaser-action@master
        with:
          version: latest
-          args: release --rm-dist
+          args: release --clean
        env:
          GITHUB_TOKEN: ${{ secrets.GITHUB_TOKEN }}
--- a/README.md
+++ b/README.md
@@ -1,7 +1,6 @@
 <div align="center">
-  <a href="https://crypko.ai/crypko/5k8HyUVTq5421/">
  <img src=".github/hua_nobg_512.gif" alt="椛" width = "400">
-  </a><br>
+  <br>

  <h1>ZeroBot-Plugin</h1>

@@ -10,7 +9,7 @@
  ZeroBot-Plugin 是 ZeroBot 的 实用插件合集<br><br>


-  <img src="http://cmoe.azurewebsites.net/cmoe?name=ZeroBot-Plugin&theme=r34" /><br>
+  <img src="https://counter.seku.su/cmoe?name=ZeroBot-Plugin&theme=r34" /><br>

  [![miraigo](https://img.shields.io/badge/OneBot-MiraiGo-green.svg?style=social&logo=appveyor)](https://github.com/Mrs4s/MiraiGo)
  [![oicq](https://img.shields.io/badge/OneBot-OICQ-green.svg?style=social&logo=appveyor)](https://github.com/takayama-lily/oicq)
@@ -18,7 +17,7 @@

  [![go](https://goreportcard.com/badge/github.com/FloatTech/ZeroBot-Plugin?style=flat-square&logo=go)](https://goreportcard.com/badge/github.com/FloatTech/ZeroBot-Plugin)
  [![onebot](https://img.shields.io/badge/onebot-v11-black?style=flat-square&logo=data:image/png;base64,iVBORw0KGgoAAAANSUhEUgAAAHAAAABwCAMAAADxPgR5AAAAGXRFWHRTb2Z0d2FyZQBBZG9iZSBJbWFnZVJlYWR5ccllPAAAAAxQTFRF////29vbr6+vAAAAk1hCcwAAAAR0Uk5T////AEAqqfQAAAKcSURBVHja7NrbctswDATQXfD//zlpO7FlmwAWIOnOtNaTM5JwDMa8E+PNFz7g3waJ24fviyDPgfhz8fHP39cBcBL9KoJbQUxjA2iYqHL3FAnvzhL4GtVNUcoSZe6eSHizBcK5LL7dBr2AUZlev1ARRHCljzRALIEog6H3U6bCIyqIZdAT0eBuJYaGiJaHSjmkYIZd+qSGWAQnIaz2OArVnX6vrItQvbhZJtVGB5qX9wKqCMkb9W7aexfCO/rwQRBzsDIsYx4AOz0nhAtWu7bqkEQBO0Pr+Ftjt5fFCUEbm0Sbgdu8WSgJ5NgH2iu46R/o1UcBXJsFusWF/QUaz3RwJMEgngfaGGdSxJkE/Yg4lOBryBiMwvAhZrVMUUvwqU7F05b5WLaUIN4M4hRocQQRnEedgsn7TZB3UCpRrIJwQfqvGwsg18EnI2uSVNC8t+0QmMXogvbPg/xk+Mnw/6kW/rraUlvqgmFreAA09xW5t0AFlHrQZ3CsgvZm0FbHNKyBmheBKIF2cCA8A600aHPmFtRB1XvMsJAiza7LpPog0UJwccKdzw8rdf8MyN2ePYF896LC5hTzdZqxb6VNXInaupARLDNBWgI8spq4T0Qb5H4vWfPmHo8OyB1ito+AysNNz0oglj1U955sjUN9d41LnrX2D/u7eRwxyOaOpfyevCWbTgDEoilsOnu7zsKhjRCsnD/QzhdkYLBLXjiK4f3UWmcx2M7PO21CKVTH84638NTplt6JIQH0ZwCNuiWAfvuLhdrcOYPVO9eW3A67l7hZtgaY9GZo9AFc6cryjoeFBIWeU+npnk/nLE0OxCHL1eQsc1IciehjpJv5mqCsjeopaH6r15/MrxNnVhu7tmcslay2gO2Z1QfcfX0JMACG41/u0RrI9QAAAABJRU5ErkJggg==)](https://t.me/zerobotplugin)
-  [![zerobot](https://img.shields.io/badge/zerobot-v1.6.10-black?style=flat-square&logo=go)](https://github.com/wdvxdr1123/ZeroBot)
+  [![zerobot](https://img.shields.io/badge/zerobot-v1.6.11-black?style=flat-square&logo=go)](https://github.com/wdvxdr1123/ZeroBot)
  [![license](https://img.shields.io/github/license/FloatTech/ZeroBot-Plugin.svg?style=flat-square&logo=gnu)](https://raw.githubusercontent.com/FloatTech/ZeroBot-Plugin/master/LICENSE)
  [![tencent-qq](https://img.shields.io/badge/group-1048452984-red?style=flat-square&logo=tencent-qq)](https://jq.qq.com/?_wv=1027&k=QMb7x1mM)
  [![telegram](https://img.shields.io/badge/Telegram-click%20me-informational?style=flat-square&logo=telegram)](https://t.me/zerobotplugin)
@@ -38,15 +37,18 @@

 > 如果您对开发插件感兴趣，欢迎加入[ZeroBot-Plugin-Playground](https://github.com/FloatTech/ZeroBot-Plugin-Playground)

+> webui持续开发中, 欢迎加入[ZeroBot-Plugin-Webui](https://github.com/FloatTech/ZeroBot-Plugin-Webui)
+
 ## 命令行参数
 > `[]`代表是可选参数
 ```bash
-zerobot [-h] [-n nickname] [-t token] [-u url] [-p prefix] [-d|w] [-c|s config.json] [-l latency] [-r ringlen] [-x max process time] [qq1 qq2 qq3 ...] [&]
+zerobot [-h] [-n nickname] [-t token] [-u url] [-g url] [-p prefix] [-d|w] [-c|s config.json] [-l latency] [-r ringlen] [-x max process time] [qq1 qq2 qq3 ...] [&]
 ```
 - **-h**: 显示帮助
 - **-n nickname**: 设置默认昵称，默认为`椛椛`
 - **-t token**: 设置`AccessToken`，默认为空
 - **-u url**: 设置`Url`，默认为`ws://127.0.0.1:6700`
+- ~~**-g url**~~(默认禁用): 设置`webui url`，默认为`127.0.0.1:3000`
 - **-p prefix**: 设置命令前缀，默认为`/`
 - **-d|w**: 开启 debug | warning 级别及以上日志输出
 - **-c config.json**: 从`config.json`加载`bot`配置
@@ -86,8 +88,12 @@ zerobot [-h] [-n nickname] [-t token] [-u url] [-p prefix] [-d|w] [-c|s config.j

 ## 功能
 > 在编译时，以下功能除插件控制外，均可通过注释`main.go`中的相应`import`而物理禁用，减小插件体积。
+
 > 通过插件控制，还可动态管理某个功能在某个群的打开/关闭。
-> 插件的优先级为`import`的先后顺序
+
+> 插件的优先级为`import`的先后顺序。
+
+> `webui`默认禁用不编译，打开后会增加程序体积。

 <details>
  <summary>插件控制</summary>
@@ -130,9 +136,14 @@ zerobot [-h] [-n nickname] [-t token] [-u url] [-p prefix] [-d|w] [-c|s config.j

  - [x] /服务列表

-  - [x] /设置服务列表显示行数 xx
+  - [x] /设置服务列表显示行数 xx (默认值为 9, 该设置仅运行时有效, zbp 重启后重置)
+
+  - [x] (默认禁用) /设置webui用户名 zerobot 密码 123456
+
+  - [x] (默认禁用) /webui启动
+
+  - [x] (默认禁用) /webui停止

-	默认值为9,该设置仅运行时有效,zbp重启后重置
  - [x] @Bot 插件冲突检测 (会在本群发送一条消息并在约 1s 后撤回以检测其它同类 bot 中已启用的插件并禁用)

 </details>
@@ -425,11 +436,11 @@ print("run[CQ:image,file="+j["img"]+"]")

 </details>
 <details>
-  <summary>百度一下</summary>
+  <summary>百度百科</summary>

  `import _ "github.com/FloatTech/ZeroBot-Plugin/plugin/baidu"`

-  - [x] 百度下[xxx]
+  - [x] 百度/百科[xxx]

 </details>
 <details>
@@ -548,7 +559,7 @@ print("run[CQ:image,file="+j["img"]+"]")
  
  - [x] b站推送列表
  
-  - [x] 拉取b站推送 (使用job执行定时任务------记录在"@every 10s"触发的指令) 
+  - [x] 拉取b站推送 (使用job执行定时任务------记录在"@every 5m"触发的指令) 

 </details>
 <details>
@@ -648,6 +659,24 @@ print("run[CQ:image,file="+j["img"]+"]")

  - [x] 教你一篇小作文[作文]

+</details>
+<details>
+  <summary>多功能抽签</summary>
+
+  `import _ "github.com/FloatTech/ZeroBot-Plugin/plugin/drawlots"`
+
+  支持图包文件夹和gif抽签
+
+  - [x] (刷新)抽签列表
+  
+  - [x] 抽[签名]签
+  
+  - [x] 看签[gif签名]
+	
+  - [x] 加签[签名][gif图片]
+	
+  - [x] 删签[gif签名]
+
 </details>
 <details>
  <summary>女装</summary>
@@ -792,6 +821,16 @@ print("run[CQ:image,file="+j["img"]+"]")

  - [x] 来点黑丝/白丝/jk/巨乳/足控/网红

+</details>
+<details>
+  <summary>一言</summary>
+
+  `import _ "github.com/FloatTech/ZeroBot-Plugin/plugin/hitokoto"`
+
+  - [x] 一言[xxx]
+  
+  - [x] 系列一言
+
 </details>
 <details>
  <summary>炉石</summary>
@@ -1244,6 +1283,22 @@ print("run[CQ:image,file="+j["img"]+"]")

  - [x] 黄油角色[@xxx]

+</details>
+<details>
+  <summary>steam</summary>
+
+  `import _ "github.com/FloatTech/ZeroBot-Plugin/plugin/steam"`
+
+  - [x] steam[添加|删除]订阅xxxxx
+
+  - [x] steam查看订阅
+
+  - [x] steam绑定 api key xxxxxxx
+
+  - [x] 查看apikey
+
+  - [x] 拉取steam订阅 (使用job执行定时任务------记录在"@every 1m"触发的指令) 
+
 </details>
 <details>
  <summary>抽塔罗牌</summary>
@@ -1301,7 +1356,7 @@ print("run[CQ:image,file="+j["img"]+"]")

 </details>
 <details>
-  <summary>vtb语录</summary>
+  <summary>vtb点歌</summary>

  `import _ "github.com/FloatTech/ZeroBot-Plugin/plugin/vtbmusic"`

--- a/console/console_ansi.go
+++ b/console/console_ansi.go
@@ -1,3 +1,5 @@
+//go:build !windows
+
 // Package console sets console's behavior on init
 package console

--- a/console/console_windows.go
+++ b/console/console_windows.go
@@ -1,3 +1,4 @@
+// Package console sets console's behavior on init
 package console

 import (
@@ -72,11 +73,11 @@ func init() {
 	mode |= windows.ENABLE_PROCESSED_OUTPUT            // 启用处理后的输出

 	err = windows.SetConsoleMode(stdout, mode)
-	if err != nil {
-		panic(err)
-	}
 	// windows 带颜色 log 自定义格式
-	logrus.SetFormatter(&LogFormat{})
+	logrus.SetFormatter(&logFormat{hasColor: err == nil})
+	if err != nil {
+		logrus.Warnln("VT100设置失败, 将以无色模式输出")
+	}

 	err = setConsoleTitle("ZeroBot-Blugin " + banner.Version + " " + banner.Copyright)
 	if err != nil {
@@ -95,17 +96,23 @@ const (
 	colorReset     = "\x1b[0m"
 )

-// LogFormat specialize for zbp
-type LogFormat struct{}
+// logFormat specialize for zbp
+type logFormat struct {
+	hasColor bool
+}

 // Format implements logrus.Formatter
-func (f LogFormat) Format(entry *logrus.Entry) ([]byte, error) {
+func (f logFormat) Format(entry *logrus.Entry) ([]byte, error) {
 	buf := new(bytes.Buffer)

 	buf.WriteByte('[')
-	buf.WriteString(getLogLevelColorCode(entry.Level))
+	if f.hasColor {
+		buf.WriteString(getLogLevelColorCode(entry.Level))
+	}
 	buf.WriteString(strings.ToUpper(entry.Level.String()))
-	buf.WriteString(colorReset)
+	if f.hasColor {
+		buf.WriteString(colorReset)
+	}
 	buf.WriteString("] ")
 	buf.WriteString(entry.Message)
 	buf.WriteString(" \n")
--- a/go.mod
+++ b/go.mod
@@ -4,15 +4,15 @@ go 1.20

 require (
 	github.com/Baidu-AIP/golang-sdk v1.1.1
-	github.com/FloatTech/AnimeAPI v1.6.1-0.20230301080805-a8aa0e4cee1f
-	github.com/FloatTech/floatbox v0.0.0-20230301074105-03017a267762
+	github.com/FloatTech/AnimeAPI v1.6.1-0.20230316111643-46d40c9d80e3
+	github.com/FloatTech/floatbox v0.0.0-20230316111222-7ffde57284cc
 	github.com/FloatTech/gg v1.1.2
-	github.com/FloatTech/imgfactory v0.2.2-0.20230215052637-9f7b05520ca9
+	github.com/FloatTech/imgfactory v0.2.2-0.20230315152233-49741fc994f9
 	github.com/FloatTech/rendercard v0.0.10-0.20230223064326-45d29fa4ede9
 	github.com/FloatTech/sqlite v1.5.7
 	github.com/FloatTech/ttl v0.0.0-20220715042055-15612be72f5b
-	github.com/FloatTech/zbpctrl v1.5.3-0.20230301071613-f2c5c97cec88
-	github.com/FloatTech/zbputils v1.6.2-0.20230301080528-6560d8a50f34
+	github.com/FloatTech/zbpctrl v1.5.3-0.20230316111343-dd078fa43fe3
+	github.com/FloatTech/zbputils v1.6.2-0.20230316111555-2d1ec958de04
 	github.com/RomiChan/syncx v0.0.0-20221202055724-5f842c53020e
 	github.com/RomiChan/websocket v1.4.3-0.20220227141055-9b2c6168c9c5
 	github.com/antchfx/htmlquery v1.2.5
@@ -37,7 +37,7 @@ require (
 	github.com/sirupsen/logrus v1.9.0
 	github.com/tidwall/gjson v1.14.4
 	github.com/wcharczuk/go-chart/v2 v2.1.0
-	github.com/wdvxdr1123/ZeroBot v1.6.10
+	github.com/wdvxdr1123/ZeroBot v1.6.11
 	gitlab.com/gomidi/midi/v2 v2.0.25
 	golang.org/x/image v0.3.0
 	golang.org/x/sys v0.4.0
@@ -68,6 +68,7 @@ require (
 	github.com/mattn/go-isatty v0.0.16 // indirect
 	github.com/nfnt/resize v0.0.0-20180221191011-83c6a9932646 // indirect
 	github.com/onsi/ginkgo/v2 v2.2.0 // indirect
+	github.com/pbnjay/memory v0.0.0-20210728143218-7b4eea64cf58 // indirect
 	github.com/pkumza/numcn v1.0.0 // indirect
 	github.com/power-devops/perfstat v0.0.0-20210106213030-5aafc221ea8c // indirect
 	github.com/quic-go/qpack v0.4.0 // indirect
@@ -87,6 +88,7 @@ require (
 	golang.org/x/mod v0.6.0 // indirect
 	golang.org/x/net v0.4.0 // indirect
 	golang.org/x/tools v0.2.0 // indirect
+	gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c // indirect
 	modernc.org/libc v1.21.5 // indirect
 	modernc.org/mathutil v1.5.0 // indirect
 	modernc.org/memory v1.4.0 // indirect
--- a/go.sum
+++ b/go.sum
@@ -2,24 +2,24 @@ github.com/Baidu-AIP/golang-sdk v1.1.1 h1:RQsAmgDSAkiq22I6n7XJ2t3afgzFeqjY46FGhv
 github.com/Baidu-AIP/golang-sdk v1.1.1/go.mod h1:bXnGw7xPeKt8aF7UCELKrV6UZ/46spItONK1RQBQj1Y=
 github.com/BurntSushi/xgb v0.0.0-20160522181843-27f122750802/go.mod h1:IVnqGOEym/WlBOVXweHU+Q+/VP0lqqI8lqeDx9IjBqo=
 github.com/DATA-DOG/go-sqlmock v1.3.3/go.mod h1:f/Ixk793poVmq4qj/V1dPUg2JEAKC73Q5eFN3EC/SaM=
-github.com/FloatTech/AnimeAPI v1.6.1-0.20230301080805-a8aa0e4cee1f h1:X1qnXmZgogBgTdhpXz3Gl31nHdh5X6EP1F7iKH7JRHg=
-github.com/FloatTech/AnimeAPI v1.6.1-0.20230301080805-a8aa0e4cee1f/go.mod h1:4oFxa7b00MOHULzGm0GN97u/VqCq0J0NvLCF7Puymbs=
-github.com/FloatTech/floatbox v0.0.0-20230301074105-03017a267762 h1:UU9kPDPm9vRA2/qRTK33fa07AEnE6skjdyyvImAlel0=
-github.com/FloatTech/floatbox v0.0.0-20230301074105-03017a267762/go.mod h1:J0zCOJayFOyswwCNlqBQGu2q7OPjiu78kjr0oVF+MrM=
+github.com/FloatTech/AnimeAPI v1.6.1-0.20230316111643-46d40c9d80e3 h1:SyXS1YXrRuzO3YVCZB/5gSX7vaFbSMwzN+RXLNNKq5M=
+github.com/FloatTech/AnimeAPI v1.6.1-0.20230316111643-46d40c9d80e3/go.mod h1:h+22XrJTgcn0m4aM3o1pYo5G0+Mv4v7wW5xvZQ4LabY=
+github.com/FloatTech/floatbox v0.0.0-20230316111222-7ffde57284cc h1:1yentlIEJImE0rla5xE7o73ZW37eS/byFhPEwx9WYEs=
+github.com/FloatTech/floatbox v0.0.0-20230316111222-7ffde57284cc/go.mod h1:FwQm6wk+b4wuW54KCKn3zccMX47Q5apnHD/Yakzv0fI=
 github.com/FloatTech/gg v1.1.2 h1:YolgOYg3uDHc1+g0bLtt6QuRA/pvLn+b9IBCIhOOX88=
 github.com/FloatTech/gg v1.1.2/go.mod h1:uzPzAeT35egARdRuu+1oyjU3CmTwCceoq3Vvje7LpcI=
-github.com/FloatTech/imgfactory v0.2.2-0.20230215052637-9f7b05520ca9 h1:Havq0z/N79KeD50L7ms+Hv8F4Sw98Dt8lXM8jECp04o=
-github.com/FloatTech/imgfactory v0.2.2-0.20230215052637-9f7b05520ca9/go.mod h1:el5hGpj1C1bDRxcTXYRwEivDCr40zZeJpcrLrB1fajs=
+github.com/FloatTech/imgfactory v0.2.2-0.20230315152233-49741fc994f9 h1:IzZLuM/fgKclyMaU/Qb1qlLdGrs2FTietkqOWhh07Gw=
+github.com/FloatTech/imgfactory v0.2.2-0.20230315152233-49741fc994f9/go.mod h1:el5hGpj1C1bDRxcTXYRwEivDCr40zZeJpcrLrB1fajs=
 github.com/FloatTech/rendercard v0.0.10-0.20230223064326-45d29fa4ede9 h1:hffajvmQFfP68U6wUwHemPuuwCUoss+SEFfoLYwbGwE=
 github.com/FloatTech/rendercard v0.0.10-0.20230223064326-45d29fa4ede9/go.mod h1:NBFPhWae4hqVMeG8ELBBnUQkKce3nDjkljVn6PdiUNs=
 github.com/FloatTech/sqlite v1.5.7 h1:Bvo4LSojcZ6dVtbHrkqvt6z4v8e+sj0G5PSUIvdawsk=
 github.com/FloatTech/sqlite v1.5.7/go.mod h1:zFbHzRfB+CJ+VidfjuVbrcin3DAz283F7hF1hIeHzpY=
 github.com/FloatTech/ttl v0.0.0-20220715042055-15612be72f5b h1:tvciXWq2nuvTbFeJGLDNIdRX3BI546D3O7k7vrVueZw=
 github.com/FloatTech/ttl v0.0.0-20220715042055-15612be72f5b/go.mod h1:fHZFWGquNXuHttu9dUYoKuNbm3dzLETnIOnm1muSfDs=
-github.com/FloatTech/zbpctrl v1.5.3-0.20230301071613-f2c5c97cec88 h1:jdTWiYXGtYZhxIn9oGYkObNVa8GtJvki+ihsoMlLJPs=
-github.com/FloatTech/zbpctrl v1.5.3-0.20230301071613-f2c5c97cec88/go.mod h1:8IRMtcWhK4S8QdpStJqXQZtIBgAqUH72Imq3BQ45TWg=
-github.com/FloatTech/zbputils v1.6.2-0.20230301080528-6560d8a50f34 h1:RyZCH94Rwx8tP+f22NH+ZUckq7xrIeqpt313W8dHcqE=
-github.com/FloatTech/zbputils v1.6.2-0.20230301080528-6560d8a50f34/go.mod h1:IZtlPpQUAcZcf3YRZqcIyDsxFcklArub1Sjz1ZIa6M0=
+github.com/FloatTech/zbpctrl v1.5.3-0.20230316111343-dd078fa43fe3 h1:mCVrTvS2LMNaI2bNA1Gu/B4F5MnfGaTaJClgR6+rhdA=
+github.com/FloatTech/zbpctrl v1.5.3-0.20230316111343-dd078fa43fe3/go.mod h1:IagyEhY38VcbbQgVRzAM9f9mhaUn90rM5BTPfudtl1g=
+github.com/FloatTech/zbputils v1.6.2-0.20230316111555-2d1ec958de04 h1:ovL+7SAPTBCXy6XNRSdJhNvHtbueWCwEb/jtztmizAc=
+github.com/FloatTech/zbputils v1.6.2-0.20230316111555-2d1ec958de04/go.mod h1:jUmX4WBgGRcfjGeIobmVao10AHmXtL3gT00qLbx3/yo=
 github.com/PuerkitoBio/goquery v1.5.1/go.mod h1:GsLWisAFVj4WgDibEWF4pvYnkVQBpKBKeU+7zCJoLcc=
 github.com/RomiChan/syncx v0.0.0-20221202055724-5f842c53020e h1:wR3MXQ3VbUlPKOOUwLOYgh/QaJThBTYtsl673O3lqSA=
 github.com/RomiChan/syncx v0.0.0-20221202055724-5f842c53020e/go.mod h1:vD7Ra3Q9onRtojoY5sMCLQ7JBgjUsrXDnDKyFxqpf9w=
@@ -126,8 +126,11 @@ github.com/jinzhu/now v1.0.1 h1:HjfetcXq097iXP0uoPCdnM4Efp5/9MsM0/M+XOTeR3M=
 github.com/jinzhu/now v1.0.1/go.mod h1:d3SSVoowX0Lcu0IBviAWJpolVfI5UJVZZ7cO71lE/z8=
 github.com/jozsefsallai/gophersauce v1.0.1 h1:BA3ovtQRrAb1qYU9JoRLbDHpxnDunlNcEkEfhCvDDCM=
 github.com/jozsefsallai/gophersauce v1.0.1/go.mod h1:YVEI7djliMTmZ1Vh01YPF8bUHi+oKhe3yXgKf1T49vg=
+github.com/kr/pretty v0.2.1/go.mod h1:ipq/a2n7PKx3OHsz4KJII5eveXtPO4qwEXGdVfWzfnI=
 github.com/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE=
 github.com/kr/pretty v0.3.1/go.mod h1:hoEshYVHaxMs3cyo3Yncou5ZscifuDolrwPKZanG3xk=
+github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ=
+github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI=
 github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=
 github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=
 github.com/lib/pq v1.1.1 h1:sJZmqHoEaY7f+NPP8pgLB/WxulyR3fewgCM2qaSlBb4=
@@ -151,6 +154,8 @@ github.com/nfnt/resize v0.0.0-20180221191011-83c6a9932646/go.mod h1:jpp1/29i3P1S
 github.com/onsi/ginkgo/v2 v2.2.0 h1:3ZNA3L1c5FYDFTTxbFeVGGD8jYvjYauHD30YgLxVsNI=
 github.com/onsi/ginkgo/v2 v2.2.0/go.mod h1:MEH45j8TBi6u9BMogfbp0stKC5cdGjumZj5Y7AG4VIk=
 github.com/onsi/gomega v1.20.1 h1:PA/3qinGoukvymdIDV8pii6tiZgC8kbmJO6Z5+b002Q=
+github.com/pbnjay/memory v0.0.0-20210728143218-7b4eea64cf58 h1:onHthvaw9LFnH4t2DcNVpwGmV9E1BkGknEliJkfwQj0=
+github.com/pbnjay/memory v0.0.0-20210728143218-7b4eea64cf58/go.mod h1:DXv8WO4yhMYhSNPKjeNKa5WY9YCIEBRbNzFFPJbWO6Y=
 github.com/pkg/diff v0.0.0-20210226163009-20ebb0f2a09e/go.mod h1:pJLUxLENpZxwdsKMEsNbx1VGcRFpLqf3715MtcvvzbA=
 github.com/pkg/errors v0.8.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=
 github.com/pkg/errors v0.9.1 h1:FEBLx1zS214owpjy7qsBeixbURkuhQAwrK5UwLGTwt4=
@@ -198,8 +203,8 @@ github.com/tklauser/numcpus v0.6.0 h1:kebhY2Qt+3U6RNK7UqpYNA+tJ23IBEGKkB7JQBfDYm
 github.com/tklauser/numcpus v0.6.0/go.mod h1:FEZLMke0lhOUG6w2JadTzp0a+Nl8PF/GFkQ5UVIcaL4=
 github.com/wcharczuk/go-chart/v2 v2.1.0 h1:tY2slqVQ6bN+yHSnDYwZebLQFkphK4WNrVwnt7CJZ2I=
 github.com/wcharczuk/go-chart/v2 v2.1.0/go.mod h1:yx7MvAVNcP/kN9lKXM/NTce4au4DFN99j6i1OwDclNA=
-github.com/wdvxdr1123/ZeroBot v1.6.10 h1:exmPWNjWtOMLgLQW/svQDybExRJAfDkjpE3S2U6fBOY=
-github.com/wdvxdr1123/ZeroBot v1.6.10/go.mod h1:y29UIOy0RD3P+0meDNIWRhcJF3jtWPN9xP9hgt/AJAU=
+github.com/wdvxdr1123/ZeroBot v1.6.11 h1:44Wr6CsCtWlFensK5IhuVCWkosdRw0rA8SygVD8DgoI=
+github.com/wdvxdr1123/ZeroBot v1.6.11/go.mod h1:y29UIOy0RD3P+0meDNIWRhcJF3jtWPN9xP9hgt/AJAU=
 github.com/yuin/goldmark v1.3.5/go.mod h1:mwnBkeHKe2W/ZEtQ+71ViKU8L12m81fl3OWwC1Zlc8k=
 github.com/yuin/goldmark v1.4.13/go.mod h1:6yULJ656Px+3vBD8DxQVa3kxgyrAnzto9xy5taEt/CY=
 github.com/yusufpapurcu/wmi v1.2.2 h1:KBNDSne4vP5mbSWnJbO+51IMOXJB67QiYCSBrubbPRg=
@@ -293,9 +298,10 @@ golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8T
 golang.org/x/xerrors v0.0.0-20191011141410-1b5146add898/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
 golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
-google.golang.org/protobuf v1.28.0 h1:w43yiav+6bVFTBQFZX0r7ipe9JQ1QsbMgHwbBziscLw=
+google.golang.org/protobuf v1.28.1 h1:d0NfwRgPtno5B1Wa6L2DAG+KivqkdutMf1UhdNx175w=
 gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
-gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127 h1:qIbj1fsPNlZgppZ+VLlY7N33q108Sa+fhmuc+sWQYwY=
+gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk=
+gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c/go.mod h1:JHkPIbrfpd72SG/EVd6muEfDQjcINNoR0C8j2r3qZ4Q=
 gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=
 gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=
 gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=
--- a/kanban/banner/banner.go
+++ b/kanban/banner/banner.go
@@ -3,13 +3,13 @@
 package banner

 // Version ...
-var Version = "v1.7.0-beta1"
+var Version = "v1.7.0"

 // Copyright ...
 var Copyright = "© 2020 - 2023 FloatTech"

 // Banner ...
 var Banner = "* OneBot + ZeroBot + Golang\n" +
-	"* Version " + Version + " - 2023-03-01 16:16:25 +0800 CST\n" +
+	"* Version " + Version + " - 2023-03-20 12:27:42 +0800 CST\n" +
 	"* Copyright " + Copyright + ". All Rights Reserved.\n" +
 	"* Project: https://github.com/FloatTech/ZeroBot-Plugin"
--- a/main.go
+++ b/main.go
@@ -82,6 +82,7 @@ import (
 	_ "github.com/FloatTech/ZeroBot-Plugin/plugin/dailynews"        // 今日早报
 	_ "github.com/FloatTech/ZeroBot-Plugin/plugin/danbooru"         // DeepDanbooru二次元图标签识别
 	_ "github.com/FloatTech/ZeroBot-Plugin/plugin/diana"            // 嘉心糖发病
+	_ "github.com/FloatTech/ZeroBot-Plugin/plugin/drawlots"         // 多功能抽签
 	_ "github.com/FloatTech/ZeroBot-Plugin/plugin/dress"            // 女装
 	_ "github.com/FloatTech/ZeroBot-Plugin/plugin/drift_bottle"     // 漂流瓶
 	_ "github.com/FloatTech/ZeroBot-Plugin/plugin/emojimix"         // 合成emoji
@@ -94,6 +95,7 @@ import (
 	_ "github.com/FloatTech/ZeroBot-Plugin/plugin/github"           // 搜索GitHub仓库
 	_ "github.com/FloatTech/ZeroBot-Plugin/plugin/guessmusic"       // 猜歌
 	_ "github.com/FloatTech/ZeroBot-Plugin/plugin/heisi"            // 黑丝
+	_ "github.com/FloatTech/ZeroBot-Plugin/plugin/hitokoto"         // 一言
 	_ "github.com/FloatTech/ZeroBot-Plugin/plugin/hs"               // 炉石
 	_ "github.com/FloatTech/ZeroBot-Plugin/plugin/hyaku"            // 百人一首
 	_ "github.com/FloatTech/ZeroBot-Plugin/plugin/image_finder"     // 关键字搜图
@@ -129,6 +131,7 @@ import (
 	_ "github.com/FloatTech/ZeroBot-Plugin/plugin/setutime"         // 来份涩图
 	_ "github.com/FloatTech/ZeroBot-Plugin/plugin/shadiao"          // 沙雕app
 	_ "github.com/FloatTech/ZeroBot-Plugin/plugin/shindan"          // 测定
+	_ "github.com/FloatTech/ZeroBot-Plugin/plugin/steam"            // steam相关
 	_ "github.com/FloatTech/ZeroBot-Plugin/plugin/tarot"            // 抽塔罗牌
 	_ "github.com/FloatTech/ZeroBot-Plugin/plugin/tiangou"          // 舔狗日记
 	_ "github.com/FloatTech/ZeroBot-Plugin/plugin/tracemoe"         // 搜番
@@ -191,6 +194,8 @@ import (
 	"github.com/wdvxdr1123/ZeroBot/driver"
 	"github.com/wdvxdr1123/ZeroBot/message"

+	// webctrl "github.com/FloatTech/zbputils/control/web"
+
 	"github.com/FloatTech/ZeroBot-Plugin/kanban/banner"
 	// -----------------------以上为内置依赖，勿动------------------------ //
 )
@@ -209,6 +214,7 @@ func init() {
 	d := flag.Bool("d", false, "Enable debug level log and higher.")
 	w := flag.Bool("w", false, "Enable warning level log and higher.")
 	h := flag.Bool("h", false, "Display this help.")
+	// g := flag.String("g", "127.0.0.1:3000", "Set webui url.")
 	// 直接写死 AccessToken 时，请更改下面第二个参数
 	token := flag.String("t", "", "Set AccessToken of WSClient.")
 	// 直接写死 URL 时，请更改下面第二个参数
@@ -228,13 +234,12 @@ func init() {
 		fmt.Println("Usage:")
 		flag.PrintDefaults()
 		os.Exit(0)
-	} else {
-		if *d && !*w {
-			logrus.SetLevel(logrus.DebugLevel)
-		}
-		if *w {
-			logrus.SetLevel(logrus.WarnLevel)
-		}
+	}
+	if *d && !*w {
+		logrus.SetLevel(logrus.DebugLevel)
+	}
+	if *w {
+		logrus.SetLevel(logrus.WarnLevel)
 	}

 	for _, s := range flag.Args() {
@@ -294,6 +299,9 @@ func init() {
 		logrus.Infoln("[main] 配置文件已保存到", *save)
 		os.Exit(0)
 	}
+
+	// 启用 webui
+	// go webctrl.RunGui(*g)
 }

 func main() {
--- a/plugin/ai_false/ai_false.go
+++ b/plugin/ai_false/ai_false.go
@@ -187,7 +187,13 @@ func drawstatus(m *ctrl.Control[*zero.Ctx], uid int64, botname string) (sendimg
 		back = imgfactory.Size(back, int(bw*cw/bw), int(bh*cw/bw)).Image()
 		canvas.DrawImage(back, 0, 0)
 	}
-
+	var blurback image.Image
+	bwg := &sync.WaitGroup{}
+	bwg.Add(1)
+	go func() {
+		defer bwg.Done()
+		blurback = imaging.Blur(canvas.Image(), 8)
+	}()
 	wg := &sync.WaitGroup{}
 	wg.Add(5)

@@ -200,8 +206,8 @@ func drawstatus(m *ctrl.Control[*zero.Ctx], uid int64, botname string) (sendimg
 	go func() {
 		defer wg.Done()
 		titlecard := gg.NewContext(cardw, titlecardh)
-
-		titlecard.DrawImage(imaging.Blur(canvas.Image(), 8), -70, -70)
+		bwg.Wait()
+		titlecard.DrawImage(blurback, -70, -70)

 		titlecard.DrawRoundedRectangle(1, 1, float64(titlecard.W()-1*2), float64(titlecardh-1*2), 16)
 		titlecard.SetLineWidth(3)
@@ -253,8 +259,8 @@ func drawstatus(m *ctrl.Control[*zero.Ctx], uid int64, botname string) (sendimg
 	go func() {
 		defer wg.Done()
 		basiccard := gg.NewContext(cardw, basiccardh)
-
-		basiccard.DrawImage(imaging.Blur(canvas.Image(), 8), -70, -70-titlecardh-40)
+		bwg.Wait()
+		basiccard.DrawImage(blurback, -70, -70-titlecardh-40)

 		basiccard.DrawRoundedRectangle(1, 1, float64(basiccard.W()-1*2), float64(basiccardh-1*2), 16)
 		basiccard.SetLineWidth(3)
@@ -317,7 +323,8 @@ func drawstatus(m *ctrl.Control[*zero.Ctx], uid int64, botname string) (sendimg
 	go func() {
 		defer wg.Done()
 		diskcard := gg.NewContext(cardw, diskcardh)
-		diskcard.DrawImage(imaging.Blur(canvas.Image(), 8), -70, -70-titlecardh-40-basiccardh-40)
+		bwg.Wait()
+		diskcard.DrawImage(blurback, -70, -70-titlecardh-40-basiccardh-40)

 		diskcard.DrawRoundedRectangle(1, 1, float64(diskcard.W()-1*2), float64(diskcardh-1*2), 16)
 		diskcard.SetLineWidth(3)
@@ -335,6 +342,7 @@ func drawstatus(m *ctrl.Control[*zero.Ctx], uid int64, botname string) (sendimg
 		if dslen == 1 {
 			diskcard.SetRGBA255(192, 192, 192, 255)
 			diskcard.DrawRoundedRectangle(40, 40, float64(diskcard.W())-40-100, 50, 12)
+			diskcard.ClipPreserve()
 			diskcard.Fill()

 			switch {
@@ -348,7 +356,7 @@ func drawstatus(m *ctrl.Control[*zero.Ctx], uid int64, botname string) (sendimg

 			diskcard.DrawRoundedRectangle(40, 40, (float64(diskcard.W())-40-100)*diskstate[0].precent*0.01, 50, 12)
 			diskcard.Fill()
-
+			diskcard.ResetClip()
 			diskcard.SetRGBA255(30, 30, 30, 255)

 			fw, _ := diskcard.MeasureString(diskstate[0].name)
@@ -392,8 +400,8 @@ func drawstatus(m *ctrl.Control[*zero.Ctx], uid int64, botname string) (sendimg
 	go func() {
 		defer wg.Done()
 		moreinfocard := gg.NewContext(cardw, moreinfocardh)
-
-		moreinfocard.DrawImage(imaging.Blur(canvas.Image(), 8), -70, -70-titlecardh-40-basiccardh-40-diskcardh-40)
+		bwg.Wait()
+		moreinfocard.DrawImage(blurback, -70, -70-titlecardh-40-basiccardh-40-diskcardh-40)

 		moreinfocard.DrawRoundedRectangle(1, 1, float64(moreinfocard.W()-1*2), float64(moreinfocard.H()-1*2), 16)
 		moreinfocard.SetLineWidth(3)
@@ -430,7 +438,7 @@ func drawstatus(m *ctrl.Control[*zero.Ctx], uid int64, botname string) (sendimg
 		shadow.Stroke()
 		shadow.DrawRoundedRectangle(70, float64(70+titlecardh+40), float64(cardw), float64(basiccardh), 16)
 		shadow.Stroke()
-		shadow.DrawRoundedRectangle(70, float64(70+titlecardh+40+basiccardh+40), float64(cardw), float64(basiccardh), 16)
+		shadow.DrawRoundedRectangle(70, float64(70+titlecardh+40+basiccardh+40), float64(cardw), float64(diskcardh), 16)
 		shadow.Stroke()
 		shadow.DrawRoundedRectangle(70, float64(70+titlecardh+40+basiccardh+40+diskcardh+40), float64(cardw), float64(moreinfocardh), 16)
 		shadow.Stroke()
@@ -567,23 +575,21 @@ func diskstate() (stateinfo []*status, err error) {
 	if err != nil {
 		return
 	}
-	stateinfo = make([]*status, len(parts))
-	for i, v := range parts {
+	stateinfo = make([]*status, 0, len(parts))
+	for _, v := range parts {
 		mp := v.Mountpoint
+		if strings.HasPrefix(mp, "/snap/") || strings.HasPrefix(mp, "/apex/") {
+			continue
+		}
 		diskusage, err := disk.Usage(mp)
-		usage := ""
-		precent := 0.0
 		if err != nil {
-			usage = err.Error()
-		} else {
-			usage = storagefmt(float64(diskusage.Used)) + " / " + storagefmt(float64(diskusage.Total))
-			precent = math.Round(diskusage.UsedPercent)
+			continue
 		}
-		stateinfo[i] = &status{
-			precent: precent,
+		stateinfo = append(stateinfo, &status{
+			precent: math.Round(diskusage.UsedPercent),
 			name:    mp,
-			text:    []string{usage},
-		}
+			text:    []string{storagefmt(float64(diskusage.Used)) + " / " + storagefmt(float64(diskusage.Total))},
+		})
 	}
 	return stateinfo, nil
 }
--- a/plugin/atri/atri.go
+++ b/plugin/atri/atri.go
@@ -40,7 +40,7 @@ func randText(text ...string) message.MessageSegment {
 }

 // isAtriSleeping 凌晨0点到6点，ATRI 在睡觉，不回应任何请求
-func isAtriSleeping(ctx *zero.Ctx) bool {
+func isAtriSleeping(*zero.Ctx) bool {
 	if now := time.Now().Hour(); now >= 1 && now < 6 {
 		return false
 	}
--- a/plugin/baidu/search.go
+++ b/plugin/baidu/search.go
@@ -1,27 +1,51 @@
-// Package baidu 百度一下
+// Package baidu 百度百科
 package baidu

 import (
-	"net/url"
-
-	zero "github.com/wdvxdr1123/ZeroBot"
-	"github.com/wdvxdr1123/ZeroBot/message"
+	"encoding/json"
+	"fmt"

+	"github.com/FloatTech/floatbox/web"
 	ctrl "github.com/FloatTech/zbpctrl"
 	"github.com/FloatTech/zbputils/control"
-	"github.com/FloatTech/zbputils/ctxext"
+	zero "github.com/wdvxdr1123/ZeroBot"
+	"github.com/wdvxdr1123/ZeroBot/message"
 )

-func init() {
-	control.Register("baidu", &ctrl.Options[*zero.Ctx]{
-		DisableOnDefault: false,
-		Brief:            "不会百度吗",
-		Help:             "- 百度下[xxx]",
-	}).OnPrefix("百度下").SetBlock(true).Limit(ctxext.LimitByGroup).
-		Handle(func(ctx *zero.Ctx) {
-			txt := ctx.State["args"].(string)
-			if txt != "" {
-				ctx.SendChain(message.Text("https://buhuibaidu.me/?s=" + url.QueryEscape(txt)))
-			}
-		})
+const (
+	api = "https://api.a20safe.com/api.php?api=21&key=7d06a110e9e20a684e02934549db1d3d&text=%s" // api地址
+)
+
+type result struct {
+	Code int    `json:"code"`
+	Msg  string `json:"msg"`
+	Data []struct {
+		Content string `json:"content"`
+	} `json:"data"`
+}
+
+func init() { // 主函数
+	en := control.Register("baidu", &ctrl.Options[*zero.Ctx]{
+		DisableOnDefault: false,
+		Help: "百度百科\n" +
+			"- 百度/百科[关键字]",
+	})
+	en.OnRegex(`^[百度|百科]\s*(.+)$`).SetBlock(true).Handle(func(ctx *zero.Ctx) {
+		es, err := web.GetData(fmt.Sprintf(api, ctx.State["regex_matched"].([]string)[1])) // 将网站返回结果赋值
+		if err != nil {
+			ctx.SendChain(message.Text("出现错误捏：", err))
+			return
+		}
+		var r result                 // r数组
+		err = json.Unmarshal(es, &r) // 填api返回结果，struct地址
+		if err != nil {
+			ctx.SendChain(message.Text("出现错误捏：", err))
+			return
+		}
+		if r.Code == 0 && len(r.Data) > 0 {
+			ctx.SendChain(message.Text(r.Data[0].Content)) // 输出提取后的结果
+		} else {
+			ctx.SendChain(message.Text("API访问错误"))
+		}
+	})
 }
--- a/plugin/baiduaudit/audit.go
+++ b/plugin/baiduaudit/audit.go
@@ -4,115 +4,51 @@ package baiduaudit
 import (
 	"encoding/json"
 	"fmt"
-	"os"
 	"strconv"
+	"strings"

 	"github.com/Baidu-AIP/golang-sdk/aip/censor"
+	"github.com/sirupsen/logrus"
+	zero "github.com/wdvxdr1123/ZeroBot"
+	"github.com/wdvxdr1123/ZeroBot/message"
+
 	"github.com/FloatTech/floatbox/binary"
-	"github.com/FloatTech/floatbox/file"
 	ctrl "github.com/FloatTech/zbpctrl"
 	"github.com/FloatTech/zbputils/control"
 	"github.com/FloatTech/zbputils/img/text"
-	zero "github.com/wdvxdr1123/ZeroBot"
-	"github.com/wdvxdr1123/ZeroBot/message"
 )

-// 服务网址:https://console.bce.baidu.com/ai/?_=1665977657185#/ai/antiporn/overview/index
-// 返回参数说明：https://cloud.baidu.com/doc/ANTIPORN/s/Nk3h6xbb2
-type baiduRes struct {
-	LogID          int         `json:"log_id"`         // 请求唯一id
-	Conclusion     string      `json:"conclusion"`     // 审核结果，可取值：合规、不合规、疑似、审核失败
-	ConclusionType int         `json:"conclusionType"` // 审核结果类型，可取值1.合规，2.不合规，3.疑似，4.审核失败
-	Data           []auditData `json:"data"`
-	ErrorCode      int         `json:"error_code"` // 错误提示码，失败才返回，成功不返回
-	ErrorMsg       string      `json:"error_msg"`  // 错误提示信息，失败才返回，成功不返回
-}
-
-type auditData struct {
-	Type           int    `json:"type"`           // 审核主类型，11：百度官方违禁词库、12：文本反作弊、13:自定义文本黑名单、14:自定义文本白名单
-	SubType        int    `json:"subType"`        // 审核子类型，0:含多种类型，具体看官方链接，1:违禁违规、2:文本色情、3:敏感信息、4:恶意推广、5:低俗辱骂 6:恶意推广-联系方式、7:恶意推广-软文推广
-	Conclusion     string `json:"conclusion"`     // 审核结果，可取值：合规、不合规、疑似、审核失败
-	ConclusionType int    `json:"conclusionType"` // 审核结果类型，可取值1.合规，2.不合规，3.疑似，4.审核失败
-	Msg            string `json:"msg"`            // 不合规项描述信息
-	Hits           []hit  `json:"hits"`
-} // 不合规/疑似/命中白名单项详细信息。响应成功并且conclusion为疑似或不合规或命中白名单时才返回，响应失败或conclusion为合规且未命中白名单时不返回。
-
-type hit struct {
-	DatasetName string   `json:"datasetName"`           // 违规项目所属数据集名称
-	Words       []string `json:"words"`                 // 送检文本命中词库的关键词（备注：建议参考新字段“wordHitPositions”，包含信息更丰富：关键词以及对应的位置及标签信息）
-	Probability float64  `json:"probability,omitempty"` // 不合规项置信度
-} //	送检文本违规原因的详细信息
-type keyConfig struct {
-	Key1   string          `json:"key1"`   // 百度云服务内容审核key存储
-	Key2   string          `json:"key2"`   // 百度云服务内容审核key存储
-	Groups map[int64]group `json:"groups"` // 群配置存储
-}
-
-type group struct {
-	Enable             EnableMark             // 是否启用内容审核
-	TextAudit          EnableMark             // 文本检测
-	ImageAudit         EnableMark             // 图像检测
-	DMRemind           EnableMark             // 撤回提示
-	MoreRemind         EnableMark             // 详细违规提示
-	DMBAN              EnableMark             // 撤回后禁言
-	BANTimeAddEnable   EnableMark             // 禁言累加
-	BANTime            int64                  // 标准禁言时间，禁用累加，但开启禁言的的情况下采用该值
-	MaxBANTimeAddRange int64                  // 最大禁言时间累加范围，最高禁言时间
-	BANTimeAddTime     int64                  // 禁言累加时间，该值是开启禁累加功能后，再次触发时，根据被禁次数X该值计算出的禁言时间
-	WhiteListType      [8]bool                // 类型白名单，处于白名单类型的违规，不会被触发 0:含多种类型，具体看官方链接，1:违禁违规、2:文本色情、3:敏感信息、4:恶意推广、5:低俗辱骂 6:恶意推广-联系方式、7:恶意推广-软文推广
-	AuditHistory       map[int64]auditHistory // 被封禁用户列表
-}
-
-// EnableMark 启用：●，禁用：○
-type EnableMark bool
-
-// String 打印启用状态
-func (em EnableMark) String() string {
-	if em {
-		return "开启"
-	}
-	return "关闭"
-}
-
-type auditHistory struct {
-	Count   int64      `json:"key2"`    // 被禁次数
-	ResList []baiduRes `json:"reslist"` // 禁言原因
-}
-
-var bdcli *censor.ContentCensorClient // 百度云审核服务Client
-var typetext = [8]string{
-	0: "默认违禁词库",
-	1: "违禁违规",
-	2: "文本色情",
-	3: "敏感信息",
-	4: "恶意推广",
-	5: "低俗辱骂",
-	6: "恶意推广-联系方式",
-	7: "恶意推广-软文推广",
-} // 文本类型
-
 var (
-	config     keyConfig // 插件配置
-	configinit bool      // 配置初始化
-	configpath string    // 配置路径
+	bdcli  *censor.ContentCensorClient // 百度云审核服务Client
+	txttyp = [...]string{
+		0: "默认违禁词库",
+		1: "违禁违规",
+		2: "文本色情",
+		3: "敏感信息",
+		4: "恶意推广",
+		5: "低俗辱骂",
+		6: "恶意推广-联系方式",
+		7: "恶意推广-软文推广",
+	} // 文本类型
+	config = newconfig() // 插件配置
 )

 func init() {
 	engine := control.Register("baiduaudit", &ctrl.Options[*zero.Ctx]{
 		DisableOnDefault: false,
 		Brief:            "百度内容审核",
-		Help: "##该功能来自百度内容审核，需购买相关服务，并创建app##\n" +
+		Help: "##该功能来自百度内容审核, 需购买相关服务, 并创建app##\n" +
 			"- 获取BDAKey\n" +
 			"- 配置BDAKey [API key] [Secret Key]\n" +
 			"- 开启/关闭内容审核\n" +
 			"- 开启/关闭撤回提示\n" +
 			"- 开启/关闭详细提示\n" +
 			"- 开启/关闭撤回禁言\n" +
-			"##禁言时间设置## 禁言时间计算方式为：禁言次数*每次禁言累加时间,当达到最大禁言时间时，再次触发按最大禁言时间计算\n" +
+			"##禁言时间设置## 禁言时间计算方式为：禁言次数*每次禁言累加时间,当达到最大禁言时间时, 再次触发按最大禁言时间计算\n" +
 			"- 开启/关闭禁言累加\n" +
-			"- 设置撤回禁言时间[分钟，默认:1]\n" +
-			"- 设置最大禁言时间[分钟，默认:60,最大43200]\n" +
-			"- 设置每次累加时间[分钟，默认:1]\n" +
+			"- 设置撤回禁言时间[分钟, 默认:1]\n" +
+			"- 设置最大禁言时间[分钟, 默认:60,最大43200]\n" +
+			"- 设置每次累加时间[分钟, 默认:1]\n" +
 			"##检测类型设置## 类型编号列表:[1:违禁违规、2:文本色情、3:敏感信息、4:恶意推广、5:低俗辱骂 6:恶意推广-联系方式、7:恶意推广-软文推广]\n" +
 			"- 查看检测类型\n" +
 			"- 查看检测配置\n" +
@@ -121,15 +57,19 @@ func init() {
 			"- 开启/关闭文本检测\n" +
 			"- 开启/关闭图像检测\n" +
 			"##测试功能##\n" +
-			"- 测试文本检测[文本内容]\n" +
-			"- 测试图像检测[图片]\n",
+			"- ^文本检测[文本内容]\n" +
+			"- ^图像检测[图片]\n",
 		PrivateDataFolder: "baiduaudit",
 	})
-	configpath = engine.DataFolder() + "config.json"
-	loadConfig()
-	if configinit {
+
+	configpath := engine.DataFolder() + "config.json"
+	err := config.load(configpath)
+	if err != nil {
+		logrus.Warnln("[baiduaudit] 加载配置错误:", err)
+	} else if config.Key1 != "" && config.Key2 != "" {
 		bdcli = censor.NewClient(config.Key1, config.Key2)
 	}
+
 	engine.OnFullMatch("获取BDAKey", zero.SuperUserPermission).SetBlock(true).
 		Handle(func(ctx *zero.Ctx) {
 			ctx.SendChain(message.Text("接口key创建网址:\n" +
@@ -138,28 +78,33 @@ func init() {
 				"https://console.bce.baidu.com/ai/?_=1665977657185#/ai/antiporn/overview/resource/getFree"))
 		})

-	engine.OnRegex("^查看检测(类型|配置)$", zero.AdminPermission, clientCheck).SetBlock(true).
+	engine.OnRegex("^查看检测(类型|配置)$", zero.AdminPermission, hasinit).SetBlock(true).
 		Handle(func(ctx *zero.Ctx) {
 			// 获取群配置
-			group := getGroup(ctx.Event.GroupID)
-			var msgs string
+			group := config.groupof(ctx.Event.GroupID)
+			msg := ""
 			k1 := ctx.State["regex_matched"].([]string)[1]
 			if k1 == "类型" {
-				msgs += "本群检测类型:"
-				find := false
+				sb := strings.Builder{}
+				sb.WriteString("本群检测类型:")
+				found := false
 				// 遍历群检测类型名单
-				for i, v := range group.WhiteListType {
+				for i, v := range group.copyWhiteListType() {
 					if !v {
-						find = true
-						msgs += fmt.Sprint("\n", i, ".", typetext[i])
+						found = true
+						sb.WriteByte('\n')
+						sb.WriteString(strconv.Itoa(i))
+						sb.WriteByte('.')
+						sb.WriteString(txttyp[i])
 					}
 				}
-				if !find {
-					msgs += "无"
+				if !found {
+					sb.WriteString("无")
 				}
+				msg = sb.String()
 			} else {
 				// 生成配置文本
-				msgs = fmt.Sprintf("本群配置:\n"+
+				msg = fmt.Sprintf("本群配置:\n"+
 					"内容审核:%s\n"+
 					"-文本:%s\n"+
 					"-图像:%s\n"+
@@ -171,138 +116,145 @@ func init() {
 					"-每次累加时间:%v分钟\n"+
 					"-最大禁言时间:%v分钟", group.Enable, group.TextAudit, group.ImageAudit, group.DMRemind, group.MoreRemind, group.DMBAN, group.BANTimeAddEnable, group.BANTime, group.BANTimeAddTime, group.MaxBANTimeAddRange)
 			}
-			b, err := text.RenderToBase64(msgs, text.FontFile, 300, 20)
+			b, err := text.RenderToBase64(msg, text.FontFile, 300, 20)
 			if err != nil {
 				ctx.SendChain(message.Text("ERROR: ", err))
 				return
 			}
 			ctx.SendChain(message.Image("base64://" + binary.BytesToString(b)))
 		})
-	engine.OnRegex("^设置(不)?检测类型([01234567])$", zero.AdminPermission, clientCheck).SetBlock(true).
+
+	engine.OnRegex("^设置(不)?检测类型([0-7])$", zero.AdminPermission, hasinit).SetBlock(true).
 		Handle(func(ctx *zero.Ctx) {
-			defer jsonSave(config, configpath)
 			k1 := ctx.State["regex_matched"].([]string)[1]
 			k2 := ctx.State["regex_matched"].([]string)[2]
-			group := getGroup(ctx.Event.GroupID)
+			group := config.groupof(ctx.Event.GroupID)
 			inputType, _ := strconv.Atoi(k2)
-			if k1 == "不" {
-				group.WhiteListType[inputType] = true // 不检测：则进入类型白名单
-			} else {
-				group.WhiteListType[inputType] = false // 检测：则退出白名单
+			group.setWhiteListType(inputType, k1 == "不")
+			err := config.saveto(configpath)
+			if err != nil {
+				ctx.SendChain(message.Text("ERROR: ", err))
+				return
 			}
-			config.Groups[ctx.Event.GroupID] = group
-			ctx.SendChain(message.At(ctx.Event.UserID), message.Text(fmt.Sprintf("本群将%s检测%s类型内容", k1, typetext[inputType])))
+			ctx.SendChain(message.At(ctx.Event.UserID), message.Text(fmt.Sprintf("本群将%s检测%s类型内容", k1, txttyp[inputType])))
 		})
-	engine.OnRegex("^设置(最大|每次|撤回)(累加|禁言)时间(\\d{1,5})$", zero.AdminPermission, clientCheck).SetBlock(true).
+
+	engine.OnRegex("^设置(最大|每次|撤回)(累加|禁言)时间(\\d{1,5})$", zero.AdminPermission, hasinit).SetBlock(true).
 		Handle(func(ctx *zero.Ctx) {
-			defer jsonSave(config, configpath)
 			k1 := ctx.State["regex_matched"].([]string)[1]
 			k3 := ctx.State["regex_matched"].([]string)[3]
-			group := getGroup(ctx.Event.GroupID)
 			time, _ := strconv.ParseInt(k1, 10, 64)
-			switch k1 {
-			case "最大":
-				group.MaxBANTimeAddRange = time
-			case "每次":
-				group.BANTimeAddTime = time
-			case "撤回":
-				group.BANTime = time
+			config.groupof(ctx.Event.GroupID).set(func(g *group) {
+				switch k1 {
+				case "最大":
+					g.MaxBANTimeAddRange = time
+				case "每次":
+					g.BANTimeAddTime = time
+				case "撤回":
+					g.BANTime = time
+				}
+			})
+			err := config.saveto(configpath)
+			if err != nil {
+				ctx.SendChain(message.Text("ERROR: ", err))
+				return
 			}
-			config.Groups[ctx.Event.GroupID] = group
 			ctx.SendChain(message.At(ctx.Event.UserID), message.Text(fmt.Sprintf("本群%s禁言累加时间已设置为%s", k3, k1)))
 		})
-	engine.OnRegex("^(开启|关闭)(内容审核|撤回提示|撤回禁言|禁言累加|详细提示|文本检测|图像检测)$", zero.AdminPermission, clientCheck).SetBlock(true).
+
+	engine.OnRegex("^(开启|关闭)(内容审核|撤回提示|撤回禁言|禁言累加|详细提示|文本检测|图像检测)$", zero.AdminPermission, hasinit).SetBlock(true).
 		Handle(func(ctx *zero.Ctx) {
-			defer jsonSave(config, configpath)
 			k1 := ctx.State["regex_matched"].([]string)[1]
 			k2 := ctx.State["regex_matched"].([]string)[2]
-			isEnable := EnableMark(false)
-			group := getGroup(ctx.Event.GroupID)
-			if k1 == "开启" {
-				isEnable = true
+			isEnable := mark(k1 == "开启")
+			config.groupof(ctx.Event.GroupID).set(func(g *group) {
+				switch k2 {
+				case "内容审核":
+					g.Enable = isEnable
+				case "撤回提示":
+					g.DMRemind = isEnable
+				case "撤回禁言":
+					g.DMBAN = isEnable
+				case "禁言累加":
+					g.BANTimeAddEnable = isEnable
+				case "详细提示":
+					g.MoreRemind = isEnable
+				case "文本检测":
+					g.TextAudit = isEnable
+				case "图像检测":
+					g.ImageAudit = isEnable
+				}
+			})
+			err := config.saveto(configpath)
+			if err != nil {
+				ctx.SendChain(message.Text("ERROR: ", err))
+				return
 			}
-			switch k2 {
-			case "内容审核":
-				group.Enable = isEnable
-			case "撤回提示":
-				group.DMRemind = isEnable
-			case "撤回禁言":
-				group.DMBAN = isEnable
-			case "禁言累加":
-				group.BANTimeAddEnable = isEnable
-			case "详细提示":
-				group.MoreRemind = isEnable
-			case "文本检测":
-				group.TextAudit = isEnable
-			case "图像检测":
-				group.ImageAudit = isEnable
-			}
-			config.Groups[ctx.Event.GroupID] = group
 			ctx.SendChain(message.At(ctx.Event.UserID), message.Text(fmt.Sprintf("本群%s已%s", k2, k1)))
 		})
+
 	engine.OnRegex(`^配置BDAKey\s(.*)\s(.*)$`, zero.SuperUserPermission).SetBlock(true).
 		Handle(func(ctx *zero.Ctx) {
 			k1 := ctx.State["regex_matched"].([]string)[1]
 			k2 := ctx.State["regex_matched"].([]string)[2]
 			bdcli = censor.NewClient(k1, k2)
-			config.Key1 = k1
-			config.Key2 = k2
+			config.setkey(k1, k2)
 			if bdcli != nil {
-				jsonSave(config, configpath)
+				err := config.saveto(configpath)
+				if err != nil {
+					ctx.SendChain(message.Text("ERROR: ", err))
+					return
+				}
 				ctx.SendChain(message.Text("配置成功"))
 			}
 		})
-	engine.OnMessage().SetBlock(false).Handle(func(ctx *zero.Ctx) {
-		group, ok := config.Groups[ctx.Event.GroupID]
-		// 如果没该配置，或者审核功能未开启直接跳过
-		if !ok || !bool(group.Enable) {
+
+	engine.OnMessage(config.isgroupexist).SetBlock(false).Handle(func(ctx *zero.Ctx) {
+		group := config.groupof(ctx.Event.GroupID)
+		if !bool(group.Enable) {
 			return
 		}
+		var bdres baiduRes
+		var err error
 		for _, elem := range ctx.Event.Message {
 			switch elem.Type {
 			case "image":
-				if !group.ImageAudit {
-					return
+				if !group.ImageAudit || elem.Data["url"] == "" {
+					continue
 				}
 				res := bdcli.ImgCensorUrl(elem.Data["url"], nil)
-				bdres, err := jsonToBaiduRes(res)
+				bdres, err = parse2BaiduRes(res)
 				if err != nil {
-					ctx.SendChain(message.Text("Error:", bdres.ErrorMsg, "(", bdres.ErrorCode, ")"))
-					return
+					continue
 				}
-				banCheck(ctx, bdres)
-
 			case "text":
-				if !group.TextAudit {
-					return
+				if !group.TextAudit || elem.Data["text"] == "" {
+					continue
 				}
-				res := bdcli.TextCensor(elem.Data["text"])
-				bdres, err := jsonToBaiduRes(res)
+				bdres, err = parse2BaiduRes(bdcli.TextCensor(elem.Data["text"]))
 				if err != nil {
-					ctx.SendChain(message.Text("Error:", bdres.ErrorMsg, "(", bdres.ErrorCode, ")"))
-					return
+					continue
 				}
-				banCheck(ctx, bdres)
+			default:
+				continue
 			}
 		}
+		bdres.audit(ctx, configpath)
 	})
-	engine.OnPrefix("文本检测", clientCheck).SetBlock(false).
+
+	engine.OnPrefix("^文本检测", hasinit).SetBlock(false).
 		Handle(func(ctx *zero.Ctx) {
-			if bdcli == nil {
-				ctx.SendChain(message.Text("Key未配置"))
-				return
-			}
 			args := ctx.ExtractPlainText()
 			res := bdcli.TextCensor(args)
-			bdres, err := jsonToBaiduRes(res)
+			bdres, err := parse2BaiduRes(res)
 			if err != nil {
-				ctx.SendChain(message.Text("Error:", bdres.ErrorMsg, "(", bdres.ErrorCode, ")"))
+				ctx.SendChain(message.Text("ERROR: ", bdres.ErrorMsg, "(", bdres.ErrorCode, ")"))
 				return
 			}
-			group := getGroup(ctx.Event.GroupID)
-			ctx.SendChain(buildResp(bdres, group)...)
+			ctx.Send(config.groupof(ctx.Event.GroupID).reply(&bdres))
 		})
-	engine.OnPrefix("^图像检测", clientCheck).SetBlock(false).
+
+	engine.OnPrefix("^图像检测", hasinit).SetBlock(false).
 		Handle(func(ctx *zero.Ctx) {
 			var urls []string
 			for _, elem := range ctx.Event.Message {
@@ -316,105 +268,17 @@ func init() {
 				return
 			}
 			res := bdcli.ImgCensorUrl(urls[0], nil)
-			bdres, err := jsonToBaiduRes(res)
+			bdres, err := parse2BaiduRes(res)
 			if err != nil {
-				ctx.SendChain(message.Text("Error:", bdres.ErrorMsg, "(", bdres.ErrorCode, ")"))
+				ctx.SendChain(message.Text("ERROR: ", bdres.ErrorMsg, "(", bdres.ErrorCode, ")"))
 				return
 			}
-			group := getGroup(ctx.Event.GroupID)
-			ctx.SendChain(buildResp(bdres, group)...)
+			ctx.Send(config.groupof(ctx.Event.GroupID).reply(&bdres))
 		})
 }

-// 禁言检测
-func banCheck(ctx *zero.Ctx, bdres baiduRes) {
-	// 如果返回类型为2（不合规），0为合规，3为疑似
-	if bdres.ConclusionType == 2 {
-		// 创建消息ID
-		mid := message.NewMessageIDFromInteger(ctx.Event.MessageID.(int64))
-		// 获取群配置
-		group := getGroup(ctx.Event.GroupID)
-		// 检测群配置里的不检测类型白名单，忽略掉不检测的违规类型
-		for i, b := range group.WhiteListType {
-			if i == bdres.Data[0].SubType && b {
-				return
-			}
-		}
-		// 生成回复文本
-		res := buildResp(bdres, group)
-		// 撤回消息
-		ctx.DeleteMessage(mid)
-		// 查看是否启用撤回后禁言
-		if group.DMBAN {
-			// 从历史违规记录中获取指定用户
-			user := group.getUser(ctx.Event.UserID)
-			// 用户违规次数自增
-			user.Count++
-			// 用户违规原因记录
-			user.ResList = append(user.ResList, bdres)
-			// 覆写该用户到群违规记录中
-			group.AuditHistory[ctx.Event.UserID] = user
-			// 覆写该群信息
-			config.Groups[ctx.Event.GroupID] = group
-			// 保存到json
-			jsonSave(config, configpath)
-			var bantime int64
-			// 查看是否开启禁言累加功能，并计算禁言时间
-			if group.BANTimeAddEnable {
-				bantime = user.Count * group.BANTimeAddTime * 60
-			} else {
-				bantime = group.BANTime * 60
-			}
-			// 执行禁言
-			ctx.SetGroupBan(ctx.Event.GroupID, ctx.Event.UserID, bantime)
-		}
-		// 查看是否开启撤回提示
-		if group.DMRemind {
-			res = append(res, message.At(ctx.Event.Sender.ID))
-			ctx.SendChain(res...)
-		}
-	}
-}
-
-// 获取群配置
-func getGroup(groupID int64) group {
-	g, ok := config.Groups[groupID]
-	if ok {
-		return g
-	}
-	if config.Groups == nil {
-		config.Groups = make(map[int64]group)
-	}
-	g = group{
-		TextAudit:          true,
-		ImageAudit:         true,
-		BANTime:            1,
-		MaxBANTimeAddRange: 60,
-		BANTimeAddTime:     1,
-		WhiteListType:      [8]bool{},
-		AuditHistory:       map[int64]auditHistory{},
-	}
-	config.Groups[groupID] = g
-	return g
-}
-
-// 从群历史违规记录中获取用户
-func (group *group) getUser(userID int64) auditHistory {
-	audit, ok := group.AuditHistory[userID]
-	if ok {
-		return audit
-	}
-	// 如果没有用户，则创建一个并返回
-	if group.AuditHistory == nil {
-		group.AuditHistory = make(map[int64]auditHistory)
-	}
-	audit = auditHistory{0, []baiduRes{}}
-	group.AuditHistory[userID] = audit
-	return audit
-}
-
 // 客户端是否初始化检测
-func clientCheck(ctx *zero.Ctx) bool {
+func hasinit(ctx *zero.Ctx) bool {
 	if bdcli == nil {
 		ctx.SendChain(message.Text("Key未配置"))
 		return false
@@ -422,79 +286,7 @@ func clientCheck(ctx *zero.Ctx) bool {
 	return true
 }

-// 加载JSON配置文件
-func loadConfig() {
-	if file.IsExist(configpath) {
-		data, err := os.OpenFile(configpath, os.O_RDONLY, 0755)
-		if err != nil {
-			panic(err)
-		}
-		err = json.NewDecoder(data).Decode(&config)
-		if err != nil {
-			panic(err)
-		}
-		configinit = true
-	} else {
-		config = keyConfig{}
-		configinit = false
-	}
-}
-
-// 保存配置文件
-func jsonSave(v keyConfig, path string) {
-	jsf, _ := os.OpenFile(path, os.O_WRONLY|os.O_CREATE|os.O_TRUNC, 0666)
-	defer func(file *os.File) {
-		err := file.Close()
-		if err != nil {
-			fmt.Println(err)
-		}
-	}(jsf) // 结束时关闭句柄，释放资源
-	err := json.NewEncoder(jsf).Encode(v)
-	if err != nil {
-		fmt.Println(err)
-	}
-}
-
-// JSON反序列化
-func jsonToBaiduRes(resjson string) (baiduRes, error) {
-	var bdres baiduRes
-	err := json.Unmarshal(binary.StringToBytes(resjson), &bdres)
-	return bdres, err
-}
-
-// 生成回复文本
-func buildResp(bdres baiduRes, group group) []message.MessageSegment {
-	// 建立消息段
-	msgs := make([]message.MessageSegment, 0, 8)
-	// 生成简略审核结果回复
-	msgs = append(msgs, message.Text(bdres.Conclusion, "\n"))
-	// 查看是否开启详细审核内容提示，并确定审核内容值为疑似，或者不合规
-	if !group.MoreRemind {
-		return msgs
-	}
-	// 遍历返回的不合规数据，生成详细违规内容
-	for i, datum := range bdres.Data {
-		msgs = append(msgs, message.Text("[", i, "]:", datum.Msg, "\n"))
-		// 检查命中词条是否大于0
-		if len(datum.Hits) == 0 {
-			return msgs
-		}
-		// 遍历打印命中的违规词条
-		for _, hit := range datum.Hits {
-			if len(datum.Hits) == 0 {
-				return msgs
-			}
-			msgs = append(msgs, message.Text("("))
-			for i4, i3 := range hit.Words {
-				// 检查是否是最后一个要打印的词条，如果是则不加上逗号
-				if i4 != len(hit.Words)-1 {
-					msgs = append(msgs, message.Text(i3, ","))
-				} else {
-					msgs = append(msgs, message.Text(i3))
-				}
-			}
-			msgs = append(msgs, message.Text(")"))
-		}
-	}
-	return msgs
+func parse2BaiduRes(resjson string) (bdres baiduRes, err error) {
+	err = json.Unmarshal(binary.StringToBytes(resjson), &bdres)
+	return
 }
--- a/plugin/baiduaudit/model.go
+++ b/plugin/baiduaudit/model.go
@@ -0,0 +1,271 @@
+package baiduaudit
+
+import (
+	"encoding/json"
+	"os"
+	"sync"
+	"sync/atomic"
+
+	"github.com/FloatTech/floatbox/file"
+	zero "github.com/wdvxdr1123/ZeroBot"
+	"github.com/wdvxdr1123/ZeroBot/message"
+)
+
+// 服务网址:https://console.bce.baidu.com/ai/?_=1665977657185#/ai/antiporn/overview/index
+// 返回参数说明：https://cloud.baidu.com/doc/ANTIPORN/s/Nk3h6xbb2
+type baiduRes struct {
+	mu sync.Mutex `json:"-"`
+	// LogID          int          `json:"log_id"`         // 请求唯一id
+	Conclusion     string       `json:"conclusion"`     // 审核结果, 可取值：合规、不合规、疑似、审核失败
+	ConclusionType int          `json:"conclusionType"` // 审核结果类型, 可取值1.合规, 2.不合规, 3.疑似, 4.审核失败
+	Data           []*auditData `json:"data"`
+	ErrorCode      int          `json:"error_code"` // 错误提示码, 失败才返回, 成功不返回
+	ErrorMsg       string       `json:"error_msg"`  // 错误提示信息, 失败才返回, 成功不返回
+}
+
+// 禁言检测
+func (bdres *baiduRes) audit(ctx *zero.Ctx, configpath string) {
+	bdres.mu.Lock()
+	defer bdres.mu.Unlock()
+	// 如果返回类型为2（不合规）, 0为合规, 3为疑似
+	if bdres.ConclusionType != 2 {
+		return
+	}
+	// 创建消息ID
+	mid := message.NewMessageIDFromInteger(ctx.Event.MessageID.(int64))
+	// 获取群配置
+	group := config.groupof(ctx.Event.GroupID)
+	// 检测群配置里的不检测类型白名单, 忽略掉不检测的违规类型
+	for i, b := range group.copyWhiteListType() {
+		if i == bdres.Data[0].SubType && b {
+			return
+		}
+	}
+	// 生成回复文本
+	res := group.reply(bdres)
+	// 撤回消息
+	ctx.DeleteMessage(mid)
+	// 查看是否启用撤回后禁言
+	if group.DMBAN {
+		// 从历史违规记录中获取指定用户
+		user := group.historyof(ctx.Event.UserID)
+		// 用户违规次数自增
+		atomic.AddInt64(&user.Count, 1)
+		user.mu.Lock()
+		// 用户违规原因记录
+		user.ResList = append(user.ResList, bdres)
+		user.mu.Unlock()
+		// 保存到json
+		err := config.saveto(configpath)
+		if err != nil {
+			ctx.SendChain(message.Text("ERROR: ", err))
+		}
+		var bantime int64
+		// 查看是否开启禁言累加功能, 并计算禁言时间
+		if group.BANTimeAddEnable {
+			bantime = atomic.LoadInt64(&user.Count) * group.BANTimeAddTime * 60
+		} else {
+			bantime = group.BANTime * 60
+		}
+		// 执行禁言
+		ctx.SetGroupBan(ctx.Event.GroupID, ctx.Event.UserID, bantime)
+	}
+	// 查看是否开启撤回提示
+	if group.DMRemind {
+		res = append(res, message.At(ctx.Event.Sender.ID))
+		ctx.Send(res)
+	}
+}
+
+type auditData struct {
+	// Type           int    `json:"type"`           // 审核主类型, 11：百度官方违禁词库、12：文本反作弊、13:自定义文本黑名单、14:自定义文本白名单
+	SubType int `json:"subType"` // 审核子类型, 0:含多种类型, 具体看官方链接, 1:违禁违规、2:文本色情、3:敏感信息、4:恶意推广、5:低俗辱骂 6:恶意推广-联系方式、7:恶意推广-软文推广
+	// Conclusion     string `json:"conclusion"`     // 审核结果, 可取值：合规、不合规、疑似、审核失败
+	// ConclusionType int    `json:"conclusionType"` // 审核结果类型, 可取值1.合规, 2.不合规, 3.疑似, 4.审核失败
+	Msg  string `json:"msg"` // 不合规项描述信息
+	Hits []*hit `json:"hits"`
+} // 不合规/疑似/命中白名单项详细信息.响应成功并且conclusion为疑似或不合规或命中白名单时才返回, 响应失败或conclusion为合规且未命中白名单时不返回.
+
+type auditHistory struct {
+	mu      sync.Mutex  `json:"-"`
+	Count   int64       `json:"key2"`    // 被禁次数
+	ResList []*baiduRes `json:"reslist"` // 禁言原因
+}
+
+type hit struct {
+	// DatasetName string   `json:"datasetName"`           // 违规项目所属数据集名称
+	Words []string `json:"words"` // 送检文本命中词库的关键词（备注：建议参考新字段“wordHitPositions”, 包含信息更丰富：关键词以及对应的位置及标签信息）
+	// Probability float64  `json:"probability,omitempty"` // 不合规项置信度
+} // 送检文本违规原因的详细信息
+
+type keyConfig struct {
+	mu     sync.Mutex       `json:"-"`
+	Key1   string           `json:"key1"`   // 百度云服务内容审核key存储
+	Key2   string           `json:"key2"`   // 百度云服务内容审核key存储
+	Groups map[int64]*group `json:"groups"` // 群配置存储
+}
+
+func newconfig() (kc keyConfig) {
+	kc.Groups = make(map[int64]*group, 64)
+	return
+}
+
+func (kc *keyConfig) setkey(k1, k2 string) {
+	kc.mu.Lock()
+	defer kc.mu.Unlock()
+	kc.Key1 = k1
+	kc.Key2 = k2
+}
+
+// 加载JSON配置文件
+func (kc *keyConfig) load(filename string) error {
+	if file.IsNotExist(filename) {
+		return nil
+	}
+	f, err := os.Open(filename)
+	if err != nil {
+		return err
+	}
+	kc.mu.Lock()
+	defer kc.mu.Unlock()
+	return json.NewDecoder(f).Decode(kc)
+}
+
+func (kc *keyConfig) isgroupexist(ctx *zero.Ctx) (ok bool) {
+	kc.mu.Lock()
+	defer kc.mu.Unlock()
+	_, ok = kc.Groups[ctx.Event.GroupID]
+	return
+}
+
+// 获取群配置
+func (kc *keyConfig) groupof(groupID int64) *group {
+	kc.mu.Lock()
+	defer kc.mu.Unlock()
+	g, ok := kc.Groups[groupID]
+	if ok {
+		return g
+	}
+	g = &group{
+		TextAudit:          true,
+		ImageAudit:         true,
+		BANTime:            1,
+		MaxBANTimeAddRange: 60,
+		BANTimeAddTime:     1,
+		AuditHistory:       map[int64]*auditHistory{},
+	}
+	kc.Groups[groupID] = g
+	return g
+}
+
+// 保存配置文件
+func (kc *keyConfig) saveto(filename string) error {
+	kc.mu.Lock()
+	defer kc.mu.Unlock()
+	f, err := os.Create(filename)
+	if err != nil {
+		return err
+	}
+	defer f.Close()
+	return json.NewEncoder(f).Encode(kc)
+}
+
+type group struct {
+	mu                 sync.Mutex
+	Enable             mark                    // 是否启用内容审核
+	TextAudit          mark                    // 文本检测
+	ImageAudit         mark                    // 图像检测
+	DMRemind           mark                    // 撤回提示
+	MoreRemind         mark                    // 详细违规提示
+	DMBAN              mark                    // 撤回后禁言
+	BANTimeAddEnable   mark                    // 禁言累加
+	BANTime            int64                   // 标准禁言时间, 禁用累加, 但开启禁言的的情况下采用该值
+	MaxBANTimeAddRange int64                   // 最大禁言时间累加范围, 最高禁言时间
+	BANTimeAddTime     int64                   // 禁言累加时间, 该值是开启禁累加功能后, 再次触发时, 根据被禁次数X该值计算出的禁言时间
+	WhiteListType      [8]bool                 // 类型白名单, 处于白名单类型的违规, 不会被触发 0:含多种类型, 具体看官方链接, 1:违禁违规、2:文本色情、3:敏感信息、4:恶意推广、5:低俗辱骂 6:恶意推广-联系方式、7:恶意推广-软文推广
+	AuditHistory       map[int64]*auditHistory // 被封禁用户列表
+}
+
+func (g *group) set(f func(g *group)) {
+	g.mu.Lock()
+	f(g)
+	g.mu.Unlock()
+}
+
+func (g *group) setWhiteListType(typ int, ok bool) {
+	g.mu.Lock()
+	defer g.mu.Unlock()
+	g.WhiteListType[typ] = ok
+}
+
+func (g *group) copyWhiteListType() [8]bool {
+	g.mu.Lock()
+	defer g.mu.Unlock()
+	return g.WhiteListType
+}
+
+// 从群历史违规记录中获取用户
+func (g *group) historyof(userID int64) *auditHistory {
+	g.mu.Lock()
+	defer g.mu.Unlock()
+	audit, ok := g.AuditHistory[userID]
+	if ok {
+		return audit
+	}
+	// 如果没有用户, 则创建一个并返回
+	if g.AuditHistory == nil {
+		g.AuditHistory = make(map[int64]*auditHistory)
+	}
+	audit = &auditHistory{}
+	g.AuditHistory[userID] = audit
+	return audit
+}
+
+// 生成回复文本
+func (g *group) reply(bdres *baiduRes) message.Message {
+	g.mu.Lock()
+	defer g.mu.Unlock()
+	// 建立消息段
+	msgs := make([]message.MessageSegment, 0, 8)
+	// 生成简略审核结果回复
+	msgs = append(msgs, message.Text(bdres.Conclusion, "\n"))
+	// 查看是否开启详细审核内容提示, 并确定审核内容值为疑似, 或者不合规
+	if !g.MoreRemind {
+		return msgs
+	}
+	// 遍历返回的不合规数据, 生成详细违规内容
+	for i, datum := range bdres.Data {
+		msgs = append(msgs, message.Text("[", i, "]:", datum.Msg, "\n"))
+		// 检查命中词条是否大于0
+		if len(datum.Hits) == 0 {
+			return msgs
+		}
+		// 遍历打印命中的违规词条
+		for _, hit := range datum.Hits {
+			if len(datum.Hits) == 0 {
+				return msgs
+			}
+			msgs = append(msgs, message.Text("("))
+			for i4, i3 := range hit.Words {
+				// 检查是否是最后一个要打印的词条, 如果是则不加上逗号
+				if i4 != len(hit.Words)-1 {
+					msgs = append(msgs, message.Text(i3, ","))
+				} else {
+					msgs = append(msgs, message.Text(i3))
+				}
+			}
+			msgs = append(msgs, message.Text(")"))
+		}
+	}
+	return msgs
+}
+
+type mark bool
+
+// String 打印启用状态
+func (em mark) String() string {
+	if em {
+		return "开启"
+	}
+	return "关闭"
+}
--- a/plugin/bilibili/bilibili.go
+++ b/plugin/bilibili/bilibili.go
@@ -56,7 +56,7 @@ func init() {
 			"- 查成分 [xxx]\n" +
 			"- 查弹幕 [xxx]\n" +
 			"- 设置b站cookie b_ut=7;buvid3=0;i-wanna-go-back=-1;innersign=0;\n" +
-			"- 更新vup" +
+			"- 更新vup\n" +
 			"Tips: (412就是拦截的意思,建议私聊把cookie设全)\n",
 		PublicDataFolder: "Bilibili",
 	})
--- a/plugin/coser/coser.go
+++ b/plugin/coser/coser.go
@@ -44,6 +44,9 @@ func init() {
 				return "", err
 			}
 			arr := gjson.Get(helper.BytesToString(data), "data.data").Array()
+			if len(arr) == 0 {
+				return "", errors.New("data is empty")
+			}
 			pic := arr[rand.Intn(len(arr))]
 			return pic.String(), nil
 		}, web.GetData, time.Minute)
--- a/plugin/drawlots/main.go
+++ b/plugin/drawlots/main.go
@@ -0,0 +1,253 @@
+// Package drawlots 多功能抽签插件
+package drawlots
+
+import (
+	"bytes"
+	"errors"
+	"image"
+	"image/color"
+	"image/gif"
+	"math/rand"
+	"os"
+	"strconv"
+	"strings"
+
+	"github.com/FloatTech/floatbox/file"
+	"github.com/FloatTech/floatbox/web"
+	"github.com/FloatTech/imgfactory"
+	ctrl "github.com/FloatTech/zbpctrl"
+	control "github.com/FloatTech/zbputils/control"
+	"github.com/FloatTech/zbputils/ctxext"
+	"github.com/FloatTech/zbputils/img/text"
+	"github.com/fumiama/jieba/util/helper"
+	"github.com/sirupsen/logrus"
+	zero "github.com/wdvxdr1123/ZeroBot"
+	"github.com/wdvxdr1123/ZeroBot/message"
+)
+
+type info struct {
+	lotsType string // 文件后缀
+	quantity int    // 签数
+}
+
+var (
+	lotsList = func() map[string]info {
+		lotsList, err := getList()
+		if err != nil {
+			logrus.Infoln("[drawlots]加载失败:", err)
+		} else {
+			logrus.Infoln("[drawlots]加载", len(lotsList), "个抽签")
+		}
+		return lotsList
+	}()
+	en = control.Register("drawlots", &ctrl.Options[*zero.Ctx]{
+		DisableOnDefault: false,
+		Brief:            "多功能抽签",
+		Help: "支持图包文件夹和gif抽签\n" +
+			"-------------\n" +
+			"- (刷新)抽签列表\n- 抽[签名]签\n- 看[gif签名]签\n- 加[签名]签[gif图片]\n- 删[gif签名]签",
+		PrivateDataFolder: "drawlots",
+	}).ApplySingle(ctxext.DefaultSingle)
+	datapath = file.BOTPATH + "/" + en.DataFolder()
+)
+
+func init() {
+	en.OnFullMatchGroup([]string{"抽签列表", "刷新抽签列表"}).SetBlock(true).Handle(func(ctx *zero.Ctx) {
+		lotsList, err := getList() // 刷新列表
+		if err != nil {
+			ctx.SendChain(message.Text("ERROR:", err))
+			return
+		}
+		messageText := &strings.Builder{}
+		messageText.WriteString(" 签 名 [ 类 型 ]----签数\n")
+		messageText.WriteString("———————————\n")
+		for name, fileInfo := range lotsList {
+			messageText.WriteString(name + "[" + fileInfo.lotsType + "]----" + strconv.Itoa(fileInfo.quantity) + "\n")
+			messageText.WriteString("----------\n")
+		}
+		textPic, err := text.RenderToBase64(messageText.String(), text.BoldFontFile, 400, 50)
+		if err != nil {
+			ctx.SendChain(message.Text("ERROR:", err))
+			return
+		}
+		ctx.SendChain(message.Image("base64://" + helper.BytesToString(textPic)))
+	})
+	en.OnRegex(`^抽(.+)签$`).SetBlock(true).Handle(func(ctx *zero.Ctx) {
+		lotsType := ctx.State["regex_matched"].([]string)[1]
+		fileInfo, ok := lotsList[lotsType]
+		if !ok {
+			ctx.Send(message.ReplyWithMessage(ctx.Event.MessageID, message.Text("才...才没有", lotsType, "签这种东西啦")))
+			return
+		}
+		if fileInfo.lotsType == "folder" {
+			picPath, err := randFile(lotsType, 3)
+			if err != nil {
+				ctx.SendChain(message.Text("ERROR:", err))
+				return
+			}
+			ctx.SendChain(message.Reply(ctx.Event.MessageID), message.Image("file:///"+picPath))
+			return
+		}
+		lotsImg, err := randGif(lotsType + "." + fileInfo.lotsType)
+		if err != nil {
+			ctx.SendChain(message.Text("ERROR:", err))
+			return
+		}
+		// 生成图片
+		data, err := imgfactory.ToBytes(lotsImg)
+		if err != nil {
+			ctx.SendChain(message.Text("ERROR:", err))
+			return
+		}
+		ctx.SendChain(message.Reply(ctx.Event.MessageID), message.ImageBytes(data))
+	})
+	en.OnRegex(`^看(.+)签$`, zero.UserOrGrpAdmin).SetBlock(true).Limit(ctxext.LimitByUser).Handle(func(ctx *zero.Ctx) {
+		id := ctx.Event.MessageID
+		lotsName := ctx.State["regex_matched"].([]string)[1]
+		fileInfo, ok := lotsList[lotsName]
+		if !ok {
+			ctx.Send(message.ReplyWithMessage(id, message.Text("才...才没有", lotsName, "签这种东西啦")))
+			return
+		}
+		if fileInfo.lotsType == "folder" {
+			ctx.Send(message.ReplyWithMessage(id, message.Text("只能查看gif签哦~")))
+			return
+		}
+		ctx.Send(message.ReplyWithMessage(id, message.Image("file:///"+datapath+lotsName+"."+fileInfo.lotsType)))
+	})
+	en.OnRegex(`^加(.+)签.*`, zero.SuperUserPermission, zero.MustProvidePicture).SetBlock(true).Limit(ctxext.LimitByUser).Handle(func(ctx *zero.Ctx) {
+		id := ctx.Event.MessageID
+		lotsName := ctx.State["regex_matched"].([]string)[1]
+		if lotsName == "" {
+			ctx.Send(message.ReplyWithMessage(id, message.Text("请使用正确的指令形式哦~")))
+			return
+		}
+		picURL := ctx.State["image_url"].([]string)[0]
+		gifdata, err := web.GetData(picURL)
+		if err != nil {
+			return
+		}
+		im, err := gif.DecodeAll(bytes.NewReader(gifdata))
+		if err != nil {
+			ctx.SendChain(message.Text("ERROR:", err))
+			return
+		}
+		fileName := datapath + "/" + lotsName + ".gif"
+		err = file.DownloadTo(picURL, fileName)
+		if err != nil {
+			ctx.SendChain(message.Text("ERROR:", err))
+			return
+		}
+		lotsList[lotsName] = info{
+			lotsType: "gif",
+			quantity: len(im.Image),
+		}
+		ctx.Send(message.ReplyWithMessage(id, message.Text("成功！")))
+	})
+	en.OnRegex(`^删(.+)签$`, zero.SuperUserPermission).SetBlock(true).Limit(ctxext.LimitByUser).Handle(func(ctx *zero.Ctx) {
+		id := ctx.Event.MessageID
+		lotsName := ctx.State["regex_matched"].([]string)[1]
+		fileInfo, ok := lotsList[lotsName]
+		if !ok {
+			ctx.Send(message.ReplyWithMessage(id, message.Text("才...才没有", lotsName, "签这种东西啦")))
+			return
+		}
+		if fileInfo.lotsType == "folder" {
+			ctx.Send(message.ReplyWithMessage(id, message.Text("为了防止误删图源，图包请手动移除哦~")))
+			return
+		}
+		err := os.Remove(datapath + lotsName + "." + fileInfo.lotsType)
+		if err != nil {
+			ctx.SendChain(message.Text("ERROR:", err))
+			return
+		}
+		delete(lotsList, lotsName)
+		ctx.Send(message.ReplyWithMessage(id, message.Text("成功！")))
+	})
+}
+
+func getList() (list map[string]info, err error) {
+	list = make(map[string]info, 100)
+	files, err := os.ReadDir(datapath)
+	if err != nil {
+		return
+	}
+	if len(files) == 0 {
+		err = errors.New("什么签也没有哦~")
+		return
+	}
+	for _, lots := range files {
+		if lots.IsDir() {
+			files, _ := os.ReadDir(datapath + "/" + lots.Name())
+			list[lots.Name()] = info{
+				lotsType: "folder",
+				quantity: len(files),
+			}
+			continue
+		}
+		before, after, ok := strings.Cut(lots.Name(), ".")
+		if !ok || before == "" {
+			continue
+		}
+		file, err := os.Open(datapath + "/" + lots.Name())
+		if err != nil {
+			return nil, err
+		}
+		im, err := gif.DecodeAll(file)
+		_ = file.Close()
+		if err != nil {
+			return nil, err
+		}
+		list[before] = info{
+			lotsType: after,
+			quantity: len(im.Image),
+		}
+	}
+	return
+}
+
+func randFile(path string, indexMax int) (string, error) {
+	picPath := datapath + path
+	files, err := os.ReadDir(picPath)
+	if err != nil {
+		return "", err
+	}
+	if len(files) > 0 {
+		drawFile := files[rand.Intn(len(files))]
+		// 如果是文件夹就递归
+		if drawFile.IsDir() {
+			indexMax--
+			if indexMax <= 0 {
+				return "", errors.New("图包[" + path + "]存在太多非图片文件,请清理~")
+			}
+			return randFile(path, indexMax)
+		}
+		return picPath + "/" + drawFile.Name(), err
+	}
+	return "", errors.New("图包[" + path + "]不存在签内容！")
+}
+
+func randGif(gifName string) (image.Image, error) {
+	name := datapath + gifName
+	file, err := os.Open(name)
+	if err != nil {
+		return nil, err
+	}
+	im, err := gif.DecodeAll(file)
+	_ = file.Close()
+	if err != nil {
+		return nil, err
+	}
+	/*
+		firstImg, err := imgfactory.Load(name)
+		if err != nil {
+			return nil, err
+		}
+		v := im.Image[rand.Intn(len(im.Image))]
+		return imgfactory.Size(firstImg, firstImg.Bounds().Dx(), firstImg.Bounds().Dy()).InsertUpC(v, 0, 0, firstImg.Bounds().Dx()/2, firstImg.Bounds().Dy()/2).Clone().Image(),err
+	/*/
+	// 如果gif图片出现信息缺失请使用上面注释掉的代码，把下面注释了(上面代码部分图存在bug)
+	v := im.Image[rand.Intn(len(im.Image))]
+	return imgfactory.NewFactoryBG(v.Rect.Dx(), v.Rect.Dy(), color.NRGBA{0, 0, 0, 255}).InsertUp(v, 0, 0, 0, 0).Clone().Image(), err
+	// */
+}
--- a/plugin/hitokoto/hitokoto.go
+++ b/plugin/hitokoto/hitokoto.go
@@ -0,0 +1,174 @@
+// Package hitokoto 一言
+package hitokoto
+
+import (
+	"math/rand"
+	"strconv"
+	"strings"
+	"time"
+
+	"github.com/FloatTech/floatbox/binary"
+	fcext "github.com/FloatTech/floatbox/ctxext"
+	ctrl "github.com/FloatTech/zbpctrl"
+	"github.com/FloatTech/zbputils/control"
+	"github.com/FloatTech/zbputils/ctxext"
+	"github.com/FloatTech/zbputils/img/text"
+	zero "github.com/wdvxdr1123/ZeroBot"
+	"github.com/wdvxdr1123/ZeroBot/message"
+)
+
+func init() { // 插件主体
+	engine := control.Register("hitokoto", &ctrl.Options[*zero.Ctx]{
+		DisableOnDefault: false,
+		Brief:            "一言",
+		Help: "- 一言[xxx]\n" +
+			"- 系列一言",
+		PublicDataFolder: "Hitokoto",
+	})
+	getdb := fcext.DoOnceOnSuccess(func(ctx *zero.Ctx) bool {
+		dbfile := engine.DataFolder() + "hitokoto.db"
+		_, err := engine.GetLazyData("hitokoto.db", false)
+		if err != nil {
+			ctx.SendChain(message.Text("ERROR: ", err))
+			return false
+		}
+		hdb, err = initialize(dbfile)
+		if err != nil {
+			ctx.SendChain(message.Text("ERROR: ", err))
+			return false
+		}
+		return true
+	})
+	engine.OnPrefix(`一言`, getdb).SetBlock(true).
+		Handle(func(ctx *zero.Ctx) {
+			ctx.SendChain(message.Text("少女祈祷中..."))
+			args := ctx.State["args"].(string)
+			blist, err := hdb.getByKey(strings.TrimSpace(args))
+			if err != nil {
+				ctx.SendChain(message.Text("ERROR: ", err))
+				return
+			}
+			if len(blist) == 0 {
+				ctx.SendChain(message.Text("ERROR: hitokoto empty"))
+				return
+			}
+			m := make(message.Message, 0, 10)
+			text := strings.Builder{}
+			if len(blist) <= 10 {
+				for _, b := range blist {
+					text.WriteString(b.Hitokoto)
+					text.WriteString("\n——")
+					text.WriteString(b.From)
+					m = append(m, ctxext.FakeSenderForwardNode(ctx, message.Text(text.String())))
+					text.Reset()
+				}
+			} else {
+				indexes := map[int]struct{}{}
+				for i := 0; i < 10; i++ {
+					ind := rand.Intn(len(blist))
+					if _, ok := indexes[ind]; ok {
+						i--
+						continue
+					}
+					indexes[ind] = struct{}{}
+				}
+				for k := range indexes {
+					b := blist[k]
+					text.WriteString(b.Hitokoto)
+					text.WriteString("\n——")
+					text.WriteString(b.From)
+					m = append(m, ctxext.FakeSenderForwardNode(ctx, message.Text(text.String())))
+					text.Reset()
+				}
+			}
+			if id := ctx.Send(m).ID(); id == 0 {
+				ctx.SendChain(message.Text("ERROR: 可能被风控或下载图片用时过长，请耐心等待"))
+			}
+		})
+	engine.OnFullMatch(`系列一言`, getdb).SetBlock(true).
+		Handle(func(ctx *zero.Ctx) {
+			next := zero.NewFutureEvent("message", 999, false, ctx.CheckSession())
+			recv, cancel := next.Repeat()
+			defer cancel()
+			results, err := hdb.getAllCategory()
+			if err != nil {
+				ctx.SendChain(message.Text("ERROR: ", err))
+				return
+			}
+			tex := strings.Builder{}
+			tex.WriteString("请输入系列一言序号\n")
+			for i, v := range results {
+				tex.WriteString(strconv.Itoa(i))
+				tex.WriteString(". ")
+				tex.WriteString(v.Category)
+				tex.WriteString("\n")
+			}
+			base64Str, err := text.RenderToBase64(tex.String(), text.FontFile, 400, 20)
+			if err != nil {
+				ctx.SendChain(message.Text("ERROR: ", err))
+				return
+			}
+			ctx.SendChain(message.Image("base64://" + binary.BytesToString(base64Str)))
+			for {
+				select {
+				case <-time.After(time.Second * 120):
+					ctx.SendChain(message.Text("系列一言指令过期"))
+					return
+				case c := <-recv:
+					msg := c.Event.Message.ExtractPlainText()
+					num, err := strconv.Atoi(msg)
+					if err != nil {
+						ctx.SendChain(message.Text("请输入数字!"))
+						continue
+					}
+					if num < 0 || num >= len(results) {
+						ctx.SendChain(message.Text("序号非法!"))
+						continue
+					}
+					ctx.SendChain(message.Text("请欣赏系列一言: ", results[num].Category))
+					hlist, err := hdb.getByCategory(results[num].Category)
+					if err != nil {
+						ctx.SendChain(message.Text("ERROR: ", err))
+						return
+					}
+					if len(hlist) == 0 {
+						ctx.SendChain(message.Text("ERROR: hitokoto empty"))
+						return
+					}
+					m := make(message.Message, 0, 10)
+					text := strings.Builder{}
+					if len(hlist) <= 10 {
+						for _, b := range hlist {
+							text.WriteString(b.Hitokoto)
+							text.WriteString("\n——")
+							text.WriteString(b.From)
+							m = append(m, ctxext.FakeSenderForwardNode(ctx, message.Text(text.String())))
+							text.Reset()
+						}
+					} else {
+						indexes := map[int]struct{}{}
+						for i := 0; i < 10; i++ {
+							ind := rand.Intn(len(hlist))
+							if _, ok := indexes[ind]; ok {
+								i--
+								continue
+							}
+							indexes[ind] = struct{}{}
+						}
+						for k := range indexes {
+							b := hlist[k]
+							text.WriteString(b.Hitokoto)
+							text.WriteString("\n——")
+							text.WriteString(b.From)
+							m = append(m, ctxext.FakeSenderForwardNode(ctx, message.Text(text.String())))
+							text.Reset()
+						}
+					}
+					if id := ctx.Send(m).ID(); id == 0 {
+						ctx.SendChain(message.Text("ERROR: 可能被风控或下载图片用时过长，请耐心等待"))
+					}
+					return
+				}
+			}
+		})
+}
--- a/plugin/hitokoto/model.go
+++ b/plugin/hitokoto/model.go
@@ -0,0 +1,73 @@
+package hitokoto
+
+import (
+	"os"
+
+	"github.com/jinzhu/gorm"
+)
+
+// hdb 表情包数据库全局变量
+var hdb *hitokotodb
+
+// hitokotodb 表情包数据库
+type hitokotodb gorm.DB
+
+// initialize 初始化
+func initialize(dbpath string) (db *hitokotodb, err error) {
+	if _, err = os.Stat(dbpath); err != nil || os.IsNotExist(err) {
+		// 生成文件
+		f, err := os.Create(dbpath)
+		if err != nil {
+			return nil, err
+		}
+		_ = f.Close()
+	}
+	gdb, err := gorm.Open("sqlite3", dbpath)
+	if err != nil {
+		return
+	}
+	gdb.AutoMigrate(&hitokoto{})
+	return (*hitokotodb)(gdb), nil
+}
+
+type hitokoto struct {
+	ID         int    `json:"id" gorm:"column:id;primary_key"`
+	Hitokoto   string `json:"hitokoto" gorm:"column:hitokoto"`
+	Type       string `json:"type" gorm:"column:type"`
+	From       string `json:"from" gorm:"column:from"`
+	FromWho    string `json:"from_who" gorm:"column:from_who"`
+	Creator    string `json:"creator" gorm:"column:creator"`
+	CreatorUID int    `json:"creator_uid" gorm:"column:creator_uid"`
+	Reviewer   int    `json:"reviewer" gorm:"column:reviewer"`
+	UUID       string `json:"uuid" gorm:"column:uuid"`
+	CreatedAt  string `json:"created_at" gorm:"column:created_at"`
+	Category   string `json:"catogory" gorm:"column:category"`
+}
+
+// TableName 表名
+func (hitokoto) TableName() string {
+	return "hitokoto"
+}
+
+func (hdb *hitokotodb) getByKey(key string) (b []hitokoto, err error) {
+	db := (*gorm.DB)(hdb)
+	err = db.Where("hitokoto like ?", "%"+key+"%").Find(&b).Error
+	return
+}
+
+type result struct {
+	Category string
+	Count    int
+}
+
+func (hdb *hitokotodb) getAllCategory() (results []result, err error) {
+	db := (*gorm.DB)(hdb)
+	err = db.Table("hitokoto").Select("category, count(1) as count").Group("category").Scan(&results).Error
+	return
+}
+
+func (hdb *hitokotodb) getByCategory(category string) (h []hitokoto, err error) {
+	db := (*gorm.DB)(hdb)
+	err = db.Where("category = ?", category).Find(&h).Error
+	return
+}
--- a/plugin/jiami/jiami.go
+++ b/plugin/jiami/jiami.go
@@ -13,8 +13,8 @@ import (
 )

 const (
-	jiami1 = "http://ovooa.com/API/sho_u/?msg=%v"          // 加密api地址
-	jiami2 = "http://ovooa.com/API/sho_u/?format=1&msg=%v" // 解密api地址
+	jiami1 = "http://ovooa.caonm.net/API/sho_u/?msg=%v"          // 加密api地址
+	jiami2 = "http://ovooa.caonm.net/API/sho_u/?format=1&msg=%v" // 解密api地址

 )

--- a/plugin/kfccrazythursday/kfccrazythursday.go
+++ b/plugin/kfccrazythursday/kfccrazythursday.go
@@ -23,7 +23,7 @@ func init() {
 	engine.OnFullMatch("疯狂星期四").SetBlock(true).Handle(func(ctx *zero.Ctx) {
 		data, err := web.GetData(crazyURL)
 		if err != nil {
-			ctx.SendChain(message.Text("Error:", err))
+			ctx.SendChain(message.Text("ERROR: ", err))
 			return
 		}
 		ctx.SendChain(message.Text(gjson.ParseBytes(data).Get("@this.0.content").String()))
--- a/plugin/qqwife/command.go
+++ b/plugin/qqwife/command.go
@@ -302,7 +302,7 @@ func init() {
 func (sql *婚姻登记) 查看设置(gid int64) (dbinfo updateinfo, err error) {
 	sql.Lock()
 	defer sql.Unlock()
-	// 创建群表哥
+	// 创建群表格
 	err = sql.db.Create("updateinfo", &updateinfo{})
 	if err != nil {
 		return
@@ -350,7 +350,7 @@ func (sql *婚姻登记) 查户口(gid, uid int64) (info userinfo, err error) {
 	sql.Lock()
 	defer sql.Unlock()
 	gidstr := "group" + strconv.FormatInt(gid, 10)
-	// 创建群表哥
+	// 创建群表格
 	err = sql.db.Create(gidstr, &userinfo{})
 	if err != nil {
 		return
--- a/plugin/saucenao/searcher.go
+++ b/plugin/saucenao/searcher.go
@@ -74,15 +74,15 @@ func init() { // 插件主体
 							imgs = append(imgs, message.Image(m.String()))
 							continue
 						}
-						logrus.Debugln("[sausenao]开始下载", n)
-						logrus.Debugln("[sausenao]urls:", illust.ImageUrls)
+						logrus.Debugln("[saucenao]开始下载", n)
+						logrus.Debugln("[saucenao]urls:", illust.ImageUrls)
 						err1 := illust.DownloadToCache(i)
 						if err1 == nil {
 							m.SetFile(f)
 							_, _ = m.Push(ctxext.SendToSelf(ctx), ctxext.GetMessage(ctx))
 						}
 						if err1 != nil {
-							logrus.Debugln("[sausenao]下载err:", err1)
+							logrus.Debugln("[saucenao]下载err:", err1)
 						}
 					}
 					imgs = append(imgs, message.Image("file:///"+f))
@@ -109,8 +109,13 @@ func init() { // 插件主体
 	engine.OnKeywordGroup([]string{"以图搜图", "搜索图片", "以图识图"}, zero.MustProvidePicture).SetBlock(true).
 		Handle(func(ctx *zero.Ctx) {
 			// 开始搜索图片
+			pics, ok := ctx.State["image_url"].([]string)
+			if !ok {
+				ctx.SendChain(message.Text("ERROR: 未获取到图片链接"))
+				return
+			}
 			ctx.SendChain(message.Text("少女祈祷中..."))
-			for _, pic := range ctx.State["image_url"].([]string) {
+			for _, pic := range pics {
 				if saucenaocli != nil {
 					resp, err := saucenaocli.FromURL(pic)
 					if err == nil && resp.Count() > 0 {
@@ -157,27 +162,27 @@ func init() { // 插件主体
 					ctx.SendChain(message.Text("请私聊发送 设置 saucenao api key [apikey] 以启用 saucenao 搜图 (方括号不需要输入), key 请前往 https://saucenao.com/user.php?page=search-api 获取"))
 				}
 				// ascii2d 搜索
-				if result, err := ascii2d.ASCII2d(pic); err != nil {
+				result, err := ascii2d.ASCII2d(pic)
+				if err != nil {
 					ctx.SendChain(message.Text("ERROR: ", err))
 					continue
-				} else {
-					msg := message.Message{ctxext.FakeSenderForwardNode(ctx, message.Text("ascii2d搜图结果"))}
-					for i := 0; i < len(result) && i < 5; i++ {
-						msg = append(msg, ctxext.FakeSenderForwardNode(ctx,
-							message.Image(result[i].Thumb),
-							message.Text(fmt.Sprintf(
-								"标题: %s\n图源: %s\n画师: %s\n画师链接: %s\n图片链接: %s",
-								result[i].Name,
-								result[i].Type,
-								result[i].AuthNm,
-								result[i].Author,
-								result[i].Link,
-							))),
-						)
-					}
-					if id := ctx.Send(msg).ID(); id == 0 {
-						ctx.SendChain(message.Text("ERROR: 可能被风控了"))
-					}
+				}
+				msg := message.Message{ctxext.FakeSenderForwardNode(ctx, message.Text("ascii2d搜图结果"))}
+				for i := 0; i < len(result) && i < 5; i++ {
+					msg = append(msg, ctxext.FakeSenderForwardNode(ctx,
+						message.Image(result[i].Thumb),
+						message.Text(fmt.Sprintf(
+							"标题: %s\n图源: %s\n画师: %s\n画师链接: %s\n图片链接: %s",
+							result[i].Name,
+							result[i].Type,
+							result[i].AuthNm,
+							result[i].Author,
+							result[i].Link,
+						))),
+					)
+				}
+				if id := ctx.Send(msg).ID(); id == 0 {
+					ctx.SendChain(message.Text("ERROR: 可能被风控了"))
 				}
 			}
 		})
--- a/plugin/score/sign_in.go
+++ b/plugin/score/sign_in.go
@@ -167,7 +167,7 @@ func init() {
 			}
 			// draw head
 			nickName := ctx.CardOrNickName(uid)
-			canvas.DrawStringWrapped(nickName, 350, 180, 0.5, 0.5, 0.5, 0.5, gg.AlignLeft)
+			canvas.DrawString(nickName, 350, 180)
 			canvas.Fill()
 			// main draw
 			data, err = file.GetLazyData(text.FontFile, control.Md5File, true)
--- a/plugin/setutime/setu_geter.go
+++ b/plugin/setutime/setu_geter.go
@@ -236,10 +236,7 @@ func (p *imgpool) add(ctx *zero.Ctx, imgtype string, id int64) error {
 		return err
 	}
 	// 添加插画到对应的数据库table
-	if err := p.db.Insert(imgtype, illust); err != nil {
-		return err
-	}
-	return nil
+	return p.db.Insert(imgtype, illust)
 }

 func (p *imgpool) remove(imgtype string, id int64) error {
--- a/plugin/sleep_manage/sleep_manage.go
+++ b/plugin/sleep_manage/sleep_manage.go
@@ -55,13 +55,13 @@ func timeDuration(time time.Duration) (hour, minute, second int64) {
 }

 // 只统计6点到12点的早安
-func isMorning(ctx *zero.Ctx) bool {
+func isMorning(*zero.Ctx) bool {
 	now := time.Now().Hour()
 	return now >= 6 && now <= 12
 }

 // 只统计21点到凌晨3点的晚安
-func isEvening(ctx *zero.Ctx) bool {
+func isEvening(*zero.Ctx) bool {
 	now := time.Now().Hour()
 	return now >= 21 || now <= 3
 }
--- a/plugin/steam/listenter.go
+++ b/plugin/steam/listenter.go
@@ -0,0 +1,134 @@
+package steam
+
+import (
+	"fmt"
+	"strconv"
+	"strings"
+	"time"
+
+	"github.com/FloatTech/floatbox/binary"
+	"github.com/FloatTech/floatbox/web"
+	ctrl "github.com/FloatTech/zbpctrl"
+	"github.com/tidwall/gjson"
+	zero "github.com/wdvxdr1123/ZeroBot"
+	"github.com/wdvxdr1123/ZeroBot/message"
+)
+
+// ----------------------- 远程调用 ----------------------
+const (
+	URL            = "https://api.steampowered.com/"                          // steam API 调用地址
+	StatusURL      = "ISteamUser/GetPlayerSummaries/v2/?key=%+v&steamids=%+v" // 根据用户steamID获取用户状态
+	steamapikeygid = 3
+)
+
+var apiKey string
+
+func init() {
+	engine.OnRegex(`^steam绑定\s*api\s*key\s*(.*)$`, zero.OnlyPrivate, zero.SuperUserPermission).SetBlock(true).Handle(func(ctx *zero.Ctx) {
+		apiKey = ctx.State["regex_matched"].([]string)[1]
+		m := ctx.State["manager"].(*ctrl.Control[*zero.Ctx])
+		_ = m.Manager.Response(steamapikeygid)
+		err := m.Manager.SetExtra(steamapikeygid, apiKey)
+		if err != nil {
+			ctx.SendChain(message.Text("[steam] ERROR: 保存apikey失败！"))
+			return
+		}
+		ctx.SendChain(message.Text("保存apikey成功！"))
+	})
+	engine.OnFullMatch("查看apikey", zero.OnlyPrivate, zero.SuperUserPermission, getDB).SetBlock(true).Handle(func(ctx *zero.Ctx) {
+		ctx.SendChain(message.Text("apikey为: ", apiKey))
+	})
+	engine.OnFullMatch("拉取steam订阅", getDB).SetBlock(true).Handle(func(ctx *zero.Ctx) {
+		su := zero.BotConfig.SuperUsers[0]
+		// 获取所有处于监听状态的用户信息
+		infos, err := database.findAll()
+		if err != nil {
+			// 挂了就给管理员发消息
+			ctx.SendPrivateMessage(su, message.Text("[steam] ERROR: ", err))
+			return
+		}
+		if len(infos) == 0 {
+			return
+		}
+		// 收集这波用户的streamId，然后查当前的状态，并建立信息映射表
+		streamIds := make([]string, len(infos))
+		localPlayerMap := make(map[int64]*player)
+		for i := 0; i < len(infos); i++ {
+			streamIds[i] = strconv.FormatInt(infos[i].SteamID, 10)
+			localPlayerMap[infos[i].SteamID] = &infos[i]
+		}
+		// 将所有用户状态查一遍
+		playerStatus, err := getPlayerStatus(streamIds...)
+		if err != nil {
+			// 出错就发消息
+			ctx.SendPrivateMessage(su, message.Text("[steam] ERROR: ", err))
+			return
+		}
+		// 遍历返回的信息做对比，假如信息有变化则发消息
+		now := time.Now()
+		msg := make(message.Message, 0, len(playerStatus))
+		for _, playerInfo := range playerStatus {
+			msg = msg[:0]
+			localInfo := localPlayerMap[playerInfo.SteamID]
+			// 排除不需要处理的情况
+			if localInfo.GameID == 0 && playerInfo.GameID == 0 {
+				continue
+			}
+			// 打开游戏
+			if localInfo.GameID == 0 && playerInfo.GameID != 0 {
+				msg = append(msg, message.Text(playerInfo.PersonaName, "正在玩", playerInfo.GameExtraInfo))
+				localInfo.LastUpdate = now.Unix()
+			}
+			// 更换游戏
+			if localInfo.GameID != 0 && playerInfo.GameID != localInfo.GameID && playerInfo.GameID != 0 {
+				msg = append(msg, message.Text(playerInfo.PersonaName, "玩了", (now.Unix()-localInfo.LastUpdate)/60, "分钟后, 丢下了", localInfo.GameExtraInfo, ", 转头去玩", playerInfo.GameExtraInfo))
+				localInfo.LastUpdate = now.Unix()
+			}
+			// 关闭游戏
+			if playerInfo.GameID != localInfo.GameID && playerInfo.GameID == 0 {
+				msg = append(msg, message.Text(playerInfo.PersonaName, "玩了", (now.Unix()-localInfo.LastUpdate)/60, "分钟后, 关掉了", localInfo.GameExtraInfo))
+				localInfo.LastUpdate = 0
+			}
+			if len(msg) != 0 {
+				groups := strings.Split(localInfo.Target, ",")
+				for _, groupString := range groups {
+					group, err := strconv.ParseInt(groupString, 10, 64)
+					if err != nil {
+						ctx.SendPrivateMessage(su, message.Text("[steam] ERROR: ", err, "\nOTHER: SteamID ", localInfo.SteamID))
+						continue
+					}
+					ctx.SendGroupMessage(group, msg)
+				}
+			}
+			// 更新数据
+			localInfo.GameID = playerInfo.GameID
+			localInfo.GameExtraInfo = playerInfo.GameExtraInfo
+			if err = database.update(localInfo); err != nil {
+				ctx.SendPrivateMessage(su, message.Text("[steam] ERROR: ", err, "\nEXP: 更新数据失败\nOTHER: SteamID ", localInfo.SteamID))
+			}
+		}
+	})
+}
+
+// getPlayerStatus 获取用户状态
+func getPlayerStatus(streamIds ...string) ([]*player, error) {
+	players := make([]*player, 0)
+	// 拼接请求地址
+	url := fmt.Sprintf(URL+StatusURL, apiKey, strings.Join(streamIds, ","))
+	// 拉取并解析数据
+	data, err := web.GetData(url)
+	if err != nil {
+		return players, err
+	}
+	dataStr := binary.BytesToString(data)
+	index := gjson.Get(dataStr, "response.players.#").Uint()
+	for i := uint64(0); i < index; i++ {
+		players = append(players, &player{
+			SteamID:       gjson.Get(dataStr, fmt.Sprintf("response.players.%d.steamid", i)).Int(),
+			PersonaName:   gjson.Get(dataStr, fmt.Sprintf("response.players.%d.personaname", i)).String(),
+			GameID:        gjson.Get(dataStr, fmt.Sprintf("response.players.%d.gameid", i)).Int(),
+			GameExtraInfo: gjson.Get(dataStr, fmt.Sprintf("response.players.%d.gameextrainfo", i)).String(),
+		})
+	}
+	return players, nil
+}
--- a/plugin/steam/steam.go
+++ b/plugin/steam/steam.go
@@ -0,0 +1,158 @@
+// Package steam 获取steam用户状态
+package steam
+
+import (
+	"strconv"
+	"strings"
+	"time"
+
+	"github.com/FloatTech/floatbox/binary"
+	"github.com/FloatTech/floatbox/math"
+	ctrl "github.com/FloatTech/zbpctrl"
+	"github.com/FloatTech/zbputils/control"
+	"github.com/FloatTech/zbputils/ctxext"
+	"github.com/FloatTech/zbputils/img/text"
+	zero "github.com/wdvxdr1123/ZeroBot"
+	"github.com/wdvxdr1123/ZeroBot/message"
+)
+
+var (
+	engine = control.Register("steam", &ctrl.Options[*zero.Ctx]{
+		DisableOnDefault: false,
+		Brief:            "steam相关插件",
+		Help: "- steam添加订阅 xxxxxxx (可输入需要绑定的 steamid)\n" +
+			"- steam删除订阅 xxxxxxx (删除你创建的对于 steamid 的绑定)\n" +
+			"- steam查询订阅 (查询本群内所有的绑定对象)\n" +
+			"-----------------------\n" +
+			"- steam绑定 api key xxxxxxx (密钥在steam网站申请, 申请地址: https://steamcommunity.com/dev/registerkey)\n" +
+			"- 查看apikey (查询已经绑定的密钥)\n" +
+			"- 拉取steam订阅 (使用插件定时任务开始)\n" +
+			"-----------------------\n" +
+			"Tips: steamID在用户资料页的链接上面, 形如7656119820673xxxx\n" +
+			"需要先私聊绑定apikey, 订阅用户之后使用job插件设置定时, 例: \n" +
+			"记录在\"@every 1m\"触发的指令\n" +
+			"拉取steam订阅",
+		PrivateDataFolder: "steam",
+	}).ApplySingle(ctxext.DefaultSingle)
+)
+
+func init() {
+	// 创建绑定流程
+	engine.OnRegex(`^steam添加订阅\s*(\d+)$`, zero.OnlyGroup, getDB).SetBlock(true).Handle(func(ctx *zero.Ctx) {
+		steamidstr := ctx.State["regex_matched"].([]string)[1]
+		steamID := math.Str2Int64(steamidstr)
+		// 获取用户状态
+		playerStatus, err := getPlayerStatus(steamidstr)
+		if err != nil {
+			ctx.SendChain(message.Text("[steam] ERROR: ", err, "\nEXP: 添加失败, 获取用户信息错误"))
+			return
+		}
+		if len(playerStatus) == 0 {
+			ctx.SendChain(message.Text("[steam] ERROR: 需要添加的用户不存在, 请检查id或url"))
+			return
+		}
+		playerData := playerStatus[0]
+		// 判断用户是否已经初始化：若未初始化，通过用户的steamID获取当前状态并初始化；若已经初始化则更新用户信息
+		info, err := database.find(steamID)
+		if err != nil {
+			ctx.SendChain(message.Text("[steam] ERROR: ", err, "\nEXP: 添加失败，数据库错误"))
+			return
+		}
+		// 处理数据
+		groupID := strconv.FormatInt(ctx.Event.GroupID, 10)
+		if info.Target == "" {
+			info = player{
+				SteamID:       steamID,
+				PersonaName:   playerData.PersonaName,
+				Target:        groupID,
+				GameID:        playerData.GameID,
+				GameExtraInfo: playerData.GameExtraInfo,
+				LastUpdate:    time.Now().Unix(),
+			}
+		} else if !strings.Contains(info.Target, groupID) {
+			info.Target = strings.Join([]string{info.Target, groupID}, ",")
+		}
+		// 更新数据库
+		if err = database.update(&info); err != nil {
+			ctx.SendChain(message.Text("[steam] ERROR: ", err, "\nEXP: 更新数据库失败"))
+			return
+		}
+		ctx.SendChain(message.Text("添加成功"))
+	})
+	// 删除绑定流程
+	engine.OnRegex(`^steam删除订阅\s*(\d+)$`, zero.OnlyGroup, getDB).SetBlock(true).Handle(func(ctx *zero.Ctx) {
+		steamID := math.Str2Int64(ctx.State["regex_matched"].([]string)[1])
+		groupID := strconv.FormatInt(ctx.Event.GroupID, 10)
+		// 判断是否已经绑定该steamID，若已绑定就将群列表从推送群列表钟去除
+		info, err := database.findWithGroupID(steamID, groupID)
+		if err != nil {
+			ctx.SendChain(message.Text("[steam] ERROR: ", err, "\nEXP: 删除失败，数据库错误"))
+			return
+		}
+		if info.SteamID == 0 {
+			ctx.SendChain(message.Text("[steam] ERROR: 所需要删除的用户不存在。"))
+			return
+		}
+		// 从绑定列表中剔除需要删除的对象
+		targets := strings.Split(info.Target, ",")
+		newTargets := make([]string, 0)
+		for _, target := range targets {
+			if target == groupID {
+				continue
+			}
+			newTargets = append(newTargets, target)
+		}
+		if len(newTargets) == 0 {
+			if err = database.del(steamID); err != nil {
+				ctx.SendChain(message.Text("[steam] ERROR: ", err, "\nEXP: 删除失败，数据库错误"))
+				return
+			}
+		} else {
+			info.Target = strings.Join(newTargets, ",")
+			if err = database.update(&info); err != nil {
+				ctx.SendChain(message.Text("[steam] ERROR: ", err, "\nEXP: 删除失败，数据库错误"))
+				return
+			}
+		}
+		ctx.SendChain(message.Text("删除成功"))
+	})
+	// 查询当前群绑定信息
+	engine.OnFullMatch("steam查询订阅", zero.OnlyGroup, getDB).SetBlock(true).Handle(func(ctx *zero.Ctx) {
+		// 获取群信息
+		groupID := strconv.FormatInt(ctx.Event.GroupID, 10)
+		// 获取所有绑定信息
+		infos, err := database.findAll()
+		if err != nil {
+			ctx.SendChain(message.Text("[steam] ERROR: ", err, "\nEXP: 查询订阅失败, 数据库错误"))
+			return
+		}
+		if len(infos) == 0 {
+			ctx.SendChain(message.Text("[steam] ERROR: 还未订阅过用户关系！"))
+			return
+		}
+		// 遍历所有信息，如果包含该群就收集对应的steamID
+		var sb strings.Builder
+		head := " 查询steam订阅成功, 该群订阅的用户有: \n"
+		sb.WriteString(head)
+		for _, info := range infos {
+			if strings.Contains(info.Target, groupID) {
+				sb.WriteString(" ")
+				sb.WriteString(info.PersonaName)
+				sb.WriteString(":")
+				sb.WriteString(strconv.FormatInt(info.SteamID, 10))
+				sb.WriteString("\n")
+			}
+		}
+		if sb.String() == head {
+			ctx.SendChain(message.Text("查询成功，该群暂时还没有被绑定的用户！"))
+			return
+		}
+		// 组装并返回结果
+		data, err := text.RenderToBase64(sb.String(), text.FontFile, 400, 18)
+		if err != nil {
+			ctx.SendChain(message.Text("[steam] ERROR: ", err))
+			return
+		}
+		ctx.SendChain(message.Image("base64://" + binary.BytesToString(data)))
+	})
+}
--- a/plugin/steam/store.go
+++ b/plugin/steam/store.go
@@ -0,0 +1,117 @@
+package steam
+
+import (
+	"strconv"
+	"sync"
+	"time"
+
+	fcext "github.com/FloatTech/floatbox/ctxext"
+	sql "github.com/FloatTech/sqlite"
+	ctrl "github.com/FloatTech/zbpctrl"
+	zero "github.com/wdvxdr1123/ZeroBot"
+	"github.com/wdvxdr1123/ZeroBot/message"
+)
+
+var (
+	database streamDB
+	// 开启并检查数据库链接
+	getDB = fcext.DoOnceOnSuccess(func(ctx *zero.Ctx) bool {
+		database.db.DBPath = engine.DataFolder() + "steam.db"
+		err := database.db.Open(time.Hour * 24)
+		if err != nil {
+			ctx.SendChain(message.Text("[steam] ERROR: ", err))
+			return false
+		}
+		if err = database.db.Create(TableListenPlayer, &player{}); err != nil {
+			ctx.SendChain(message.Text("[steam] ERROR: ", err))
+			return false
+		}
+		// 校验密钥是否初始化
+		m := ctx.State["manager"].(*ctrl.Control[*zero.Ctx])
+		_ = m.Manager.Response(steamapikeygid)
+		_ = m.Manager.GetExtra(steamapikeygid, &apiKey)
+		if apiKey == "" {
+			ctx.SendChain(message.Text("ERROR: 未设置steam apikey"))
+			return false
+		}
+		return true
+	})
+)
+
+// streamDB 继承方法的存储结构
+type streamDB struct {
+	sync.RWMutex
+	db sql.Sqlite
+}
+
+const (
+	// TableListenPlayer 存储查询用户信息
+	TableListenPlayer = "listen_player"
+)
+
+// player 用户状态存储结构体
+type player struct {
+	SteamID       int64  `json:"steam_id"`        // 绑定用户标识ID
+	PersonaName   string `json:"persona_name"`    // 用户昵称
+	Target        string `json:"target"`          // 信息推送群组
+	GameID        int64  `json:"game_id"`         // 游戏ID
+	GameExtraInfo string `json:"game_extra_info"` // 游戏信息
+	LastUpdate    int64  `json:"last_update"`     // 更新时间
+}
+
+// update 如果主键不存在则插入一条新的数据，如果主键存在直接复写
+func (sql *streamDB) update(dbInfo *player) error {
+	sql.Lock()
+	defer sql.Unlock()
+	return sql.db.Insert(TableListenPlayer, dbInfo)
+}
+
+// find 根据主键查信息
+func (sql *streamDB) find(steamID int64) (dbInfo player, err error) {
+	sql.Lock()
+	defer sql.Unlock()
+	condition := "where steam_id = " + strconv.FormatInt(steamID, 10)
+	if !sql.db.CanFind(TableListenPlayer, condition) {
+		return player{}, nil // 规避没有该用户数据的报错
+	}
+	err = sql.db.Find(TableListenPlayer, &dbInfo, condition)
+	return
+}
+
+// findWithGroupID 根据用户steamID和groupID查询信息
+func (sql *streamDB) findWithGroupID(steamID int64, groupID string) (dbInfo player, err error) {
+	sql.Lock()
+	defer sql.Unlock()
+	condition := "where steam_id = " + strconv.FormatInt(steamID, 10) + " AND target LIKE '%" + groupID + "%'"
+	if !sql.db.CanFind(TableListenPlayer, condition) {
+		return player{}, nil // 规避没有该用户数据的报错
+	}
+	err = sql.db.Find(TableListenPlayer, &dbInfo, condition)
+	return
+}
+
+// findAll 查询所有库信息
+func (sql *streamDB) findAll() (dbInfos []player, err error) {
+	sql.Lock()
+	defer sql.Unlock()
+	var info player
+	num, err := sql.db.Count(TableListenPlayer)
+	if err != nil || num == 0 {
+		return
+	}
+	dbInfos = make([]player, 0, num)
+	err = sql.db.FindFor(TableListenPlayer, &info, "", func() error {
+		if info.SteamID != 0 {
+			dbInfos = append(dbInfos, info)
+		}
+		return nil
+	})
+	return
+}
+
+// del 删除指定数据
+func (sql *streamDB) del(steamID int64) error {
+	sql.Lock()
+	defer sql.Unlock()
+	return sql.db.Del(TableListenPlayer, "where steam_id = "+strconv.FormatInt(steamID, 10))
+}
--- a/plugin/warframeapi/api.go
+++ b/plugin/warframeapi/api.go
@@ -7,6 +7,9 @@ import (
 	"net/http"
 	"sort"

+	"github.com/RomiChan/syncx"
+	"github.com/sirupsen/logrus"
+
 	"github.com/FloatTech/floatbox/web"
 )

@@ -68,27 +71,40 @@ func getitemsorder(cnName string, onlyMaxRank bool) (od orders, it *itemsInSet,
 	return
 }

-func newwm() (wmitems map[string]items, itemNames []string) {
-	var itemapi wfAPIItem // WarFrame市场的数据实例
+type wmdata struct {
+	wmitems   map[string]items
+	itemNames []string
+}

+var (
+	wderr error
+	wd    = syncx.Lazy[*wmdata]{Init: func() (d *wmdata) {
+		d, wderr = newwm()
+		return
+	}}
+)
+
+func newwm() (*wmdata, error) {
+	var itemapi wfAPIItem // WarFrame市场的数据实例
+	var wd wmdata
 	data, err := web.RequestDataWithHeaders(&http.Client{}, wfitemurl, "GET", func(request *http.Request) error {
 		request.Header.Add("Accept", "application/json")
 		request.Header.Add("Language", "zh-hans")
 		return nil
 	}, nil)
 	if err != nil {
-		panic(err)
+		return &wd, err
 	}
 	err = json.Unmarshal(data, &itemapi)
 	if err != nil {
-		panic(err)
+		return &wd, err
 	}
-
-	wmitems = make(map[string]items, len(itemapi.Payload.Items)*4)
-	itemNames = make([]string, len(itemapi.Payload.Items))
+	wd.wmitems = make(map[string]items, len(itemapi.Payload.Items)*4)
+	wd.itemNames = make([]string, len(itemapi.Payload.Items))
 	for i, v := range itemapi.Payload.Items {
-		wmitems[v.ItemName] = v
-		itemNames[i] = v.ItemName
+		wd.wmitems[v.ItemName] = v
+		wd.itemNames[i] = v.ItemName
 	}
-	return
+	logrus.Infoln("[wfapi] 获取", len(wd.itemNames), "项内容")
+	return &wd, nil
 }
--- a/plugin/warframeapi/main.go
+++ b/plugin/warframeapi/main.go
@@ -10,13 +10,12 @@ import (
 	ctrl "github.com/FloatTech/zbpctrl"
 	"github.com/FloatTech/zbputils/control"
 	"github.com/FloatTech/zbputils/ctxext"
+	"github.com/RomiChan/syncx"
 	"github.com/lithammer/fuzzysearch/fuzzy"
 	zero "github.com/wdvxdr1123/ZeroBot"
 	"github.com/wdvxdr1123/ZeroBot/message"
 )

-var wmitems, itemNames = newwm()
-
 func init() {
 	eng := control.Register("warframeapi", &ctrl.Options[*zero.Ctx]{
 		DisableOnDefault: false,
@@ -234,10 +233,24 @@ func init() {
 			ctx.SendChain(message.Text("已拉取服务器时间并同步到本地模拟"))
 		})
 	// 根据名称从Warframe市场查询物品售价
-	eng.OnPrefix(".wm ").SetBlock(true).
+	eng.OnPrefix(".wm ", func(ctx *zero.Ctx) bool {
+		if wd.Get().wmitems == nil || wd.Get().itemNames == nil {
+			if wderr != nil { // 获取失败
+				ctx.SendChain(message.Text("ERROR: 获取Warframe市场物品列表失败: ", wderr))
+			} else {
+				ctx.SendChain(message.Text("ERROR: Warframe市场物品列表为空!"))
+			}
+			wd = syncx.Lazy[*wmdata]{Init: func() (d *wmdata) {
+				d, wderr = newwm()
+				return
+			}}
+			return false
+		}
+		return true
+	}).SetBlock(true).
 		Handle(func(ctx *zero.Ctx) {
 			// 根据输入的名称, 从游戏物品名称列表中进行模糊搜索
-			sol := fuzzy.FindNormalizedFold(ctx.State["args"].(string), itemNames)
+			sol := fuzzy.FindNormalizedFold(ctx.State["args"].(string), wd.Get().itemNames)
 			// 物品名称
 			var name string

@@ -282,16 +295,17 @@ func init() {
 			if onlymaxrank {
 				msgs = msgs[:0]
 			}
-			sells, iteminfo, txt, err := getitemsorder(wmitems[name].URLName, onlymaxrank)
+
+			sells, iteminfo, txt, err := getitemsorder(wd.Get().wmitems[name].URLName, onlymaxrank)
 			if !onlymaxrank {
 				if iteminfo.ZhHans.WikiLink == "" {
 					msgs = append(msgs, ctxext.FakeSenderForwardNode(ctx,
-						message.Image("https://warframe.market/static/assets/"+wmitems[name].Thumb),
-						message.Text("\n", wmitems[name].ItemName)))
+						message.Image("https://warframe.market/static/assets/"+wd.Get().wmitems[name].Thumb),
+						message.Text("\n", wd.Get().wmitems[name].ItemName)))
 				} else {
 					msgs = append(msgs, ctxext.FakeSenderForwardNode(ctx,
-						message.Image("https://warframe.market/static/assets/"+wmitems[name].Thumb),
-						message.Text("\n", wmitems[name].ItemName, "\nwiki: ", iteminfo.ZhHans.WikiLink)))
+						message.Image("https://warframe.market/static/assets/"+wd.Get().wmitems[name].Thumb),
+						message.Text("\n", wd.Get().wmitems[name].ItemName, "\nwiki: ", iteminfo.ZhHans.WikiLink)))
 				}
 			}

--- a/winres/icon.png
+++ b/winres/icon.png
--- a/winres/icon16.png
+++ b/winres/icon16.png
--- a/winres/winres.json
+++ b/winres/winres.json
@@ -12,7 +12,7 @@
      "0409": {
        "identity": {
          "name": "ZeroBot-Plugin",
-          "version": "1.7.0.1721"
+          "version": "1.7.0.1760"
        },
        "description": "",
        "minimum-os": "vista",
@@ -36,23 +36,23 @@
    "#1": {
      "0000": {
        "fixed": {
-          "file_version": "1.7.0.1721",
-          "product_version": "v1.7.0-beta1",
-          "timestamp": "2023-03-01T16:16:47+08:00"
+          "file_version": "1.7.0.1760",
+          "product_version": "v1.7.0",
+          "timestamp": "2023-03-20T12:28:01+08:00"
        },
        "info": {
          "0409": {
            "Comments": "OneBot plugins based on ZeroBot",
            "CompanyName": "FloatTech",
            "FileDescription": "https://github.com/FloatTech/ZeroBot-Plugin",
-            "FileVersion": "1.7.0.1721",
+            "FileVersion": "1.7.0.1760",
            "InternalName": "",
            "LegalCopyright": "© 2020 - 2023 FloatTech. All Rights Reserved.",
            "LegalTrademarks": "",
            "OriginalFilename": "ZBP.EXE",
            "PrivateBuild": "",
            "ProductName": "ZeroBot-Plugin",
-            "ProductVersion": "v1.7.0-beta1",
+            "ProductVersion": "v1.7.0",
            "SpecialBuild": ""
          }
        }
Author	SHA1	Message	Date
源文雨	68386910c4	🔖 v1.7.0	2023-03-20 12:28:19 +08:00
莲宝坏坏坏	1734f1f7d4	更换百度一下为百度百科 (#627 )	2023-03-20 12:23:52 +08:00
DreamZero	86b87c2b4e	fix slow aifalse (#631 )	2023-03-20 11:59:03 +08:00
DreamZero	e9eb4c5602	Fix steam & lint (#630 ) * fix * make lint happy	2023-03-20 11:57:46 +08:00
方柳煜	6474b36ccd	修复底部出现黑条的问题 (#626 )	2023-03-18 12:07:13 +08:00
github-actions[bot]	107149892c	🎨 改进代码样式 (#625 ) Co-authored-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com>	2023-03-18 00:32:36 +08:00
DreamZero	f1dba97922	feat: steam plugin (#621 )	2023-03-18 00:30:22 +08:00
莲宝坏坏坏	bc3c4303be	fix jiami api (#624 )	2023-03-18 00:28:31 +08:00
源文雨	f7a61ed0ee	🎨 edit README	2023-03-16 19:24:26 +08:00
源文雨	107b38e2f5	Merge branch 'master' of https://github.com/FloatTech/ZeroBot-Plugin	2023-03-16 19:22:38 +08:00
源文雨	0d85fa04e1	🔖 v1.7.0-beta5	2023-03-16 19:22:30 +08:00
KoiParadise	1d8f5a7869	fix: unexpected misplaced name (#622 )	2023-03-16 19:21:18 +08:00
源文雨	5e93368e57	fix #586 : 以图搜图分开发找不到 url	2023-03-16 19:20:28 +08:00
源文雨	56e931665e	fix: gif by @nekohouse09	2023-03-16 19:18:35 +08:00
方柳煜	e5b2b369e3	修改加签逻辑 (#620 ) * Update main.go * Update main.go * Update main.go	2023-03-15 23:03:01 +08:00
苜蓿紫	58cf08fc39	fix typo (#619 ) * fix typo * fix typo	2023-03-14 19:57:10 +08:00
源文雨	c18f9b8b72	🔖 v1.7.0-beta4	2023-03-12 12:28:53 +08:00
源文雨	0df465e1c6	fix: saucenao panic	2023-03-12 12:27:29 +08:00
himawari	8b010321d5	✨ 添加一言 (#616 ) * ✨ 添加一言 * 🎨 优化随机数 * 🎨 更新包 * 🎨 优化随机结构 * 🎨 修改随机算法 --------- Co-authored-by: 源文雨 <41315874+fumiama@users.noreply.github.com>	2023-03-12 11:09:07 +08:00
Fox_white	e1591c44b6	Fix: Intn Panic when the len is 0 (#617 )	2023-03-11 15:45:40 +08:00
源文雨	cc26eb1332	优化 ai_false diskstate	2023-03-11 11:48:40 +08:00
源文雨	366c7acb90	Update README.md	2023-03-10 22:26:33 +08:00
苜蓿紫	d8cb5206e8	update: drawlots (#613 )	2023-03-09 22:14:26 +08:00
源文雨	90efebf02f	🔖 v1.7.0-beta3	2023-03-09 13:57:31 +08:00
源文雨	960cd3ad8b	fix: drawlots	2023-03-09 13:56:51 +08:00
源文雨	09a3e807c9	🚑 默认不编译webui	2023-03-09 13:55:15 +08:00
苜蓿紫	fb2718b495	fix README.md (#612 ) 修正抽签readme	2023-03-09 13:29:31 +08:00
方柳煜	1550cb7fcc	新增多功能抽签插件 (#606 )	2023-03-09 00:04:09 +08:00
源文雨	7b27bc8f7a	update icon	2023-03-08 16:21:46 +08:00
github-actions[bot]	54598fbf54	🎨 改进代码样式 (#611 ) Co-authored-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com>	2023-03-08 00:57:14 +08:00
himawari	bb844eaa40	Feature gui 20230219 (#597 ) * ✨ 添加gui * 🐛 添加位置 * ✨ 修改为0.0.0.0 * ✨ 添加webui说明 * 🎨 修改为本地 * ✨ 添加webui默认url * 📝 修改readme * 🎨 修改方法名 * ✨ 修改readme * 🎨 修改命令 * 🎨 更新包 * 🎨 调整位置	2023-03-08 00:44:47 +08:00
源文雨	4ef6f584c9	Update README.md	2023-03-07 19:14:08 +08:00
源文雨	861b3cc82f	优化baiduaudit	2023-03-05 00:46:53 +08:00
源文雨	5226548cec	优化代码结构	2023-03-04 23:30:51 +08:00
github-actions[bot]	d41ae01f01	🎨 改进代码样式 (#609 ) Co-authored-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com>	2023-03-04 19:57:35 +08:00
GenesisAN	e294059de4	fix 初始化未能获取数据的问题 (#602 ) * fix 初始化未能获取数据的问题 * fix 添加读写锁 * fix lint * fix lint * change 改为全局锁	2023-03-04 19:54:56 +08:00
源文雨	84bc79eaa6	fix	2023-03-01 21:14:51 +08:00
源文雨	8f9a396821	fix: platform that fails to set vt100	2023-03-01 21:13:18 +08:00
源文雨	6f96c389c4	make ci happy	2023-03-01 16:21:18 +08:00