fix(aichat): concurrent map w/r

Co-authored-by: github-actions[bot] <41898282+github-actions[bot]@users.noreply.github.com>

README.md

@@ -1635,7 +1635,9 @@ print("run[CQ:image,file="+j["img"]+"]")
   - [x] 设置AI聊天(不)以AI语音输出
   - [x] 设置AI聊天Agent性格
   - [x] 查看AI聊天Agent性格
-  - [x] 重置AI聊天Agent性格
+  - [x] 设置AI聊天Agent性别
+  - [x] 查看AI聊天Agent性别
+  - [x] 重置AI聊天Agent性格性别
   - [x] 重置AI聊天Agent
   - [x] 查看AI聊天配置 
   - [x] 重置AI聊天

go.mod

@@ -12,7 +12,7 @@ require (
 	github.com/FloatTech/sqlite v1.7.2
 	github.com/FloatTech/ttl v0.0.0-20250224045156-012b1463287d
 	github.com/FloatTech/zbpctrl v1.7.1
-	github.com/FloatTech/zbputils v1.7.2-0.20260106142643-d2d50560ae97
+	github.com/FloatTech/zbputils v1.7.2-0.20260117132036-29f021ceb949
 	github.com/RomiChan/syncx v0.0.0-20240418144900-b7402ffdebc7
 	github.com/RomiChan/websocket v1.4.3-0.20251002072000-d3eb41798438
 	github.com/Tnze/go-mc v1.20.2
@@ -24,10 +24,9 @@ require (
 	github.com/fumiama/cron v1.3.0
 	github.com/fumiama/deepinfra v0.0.0-20251221163610-e98ee3ba437a
 	github.com/fumiama/go-base16384 v1.7.1
-	github.com/fumiama/go-onebot-agent v0.0.0-20260106141737-1ac01594b67f
+	github.com/fumiama/go-onebot-agent v0.0.0-20260117094018-cd93ccfd6e04
 	github.com/fumiama/go-registry v0.2.7
 	github.com/fumiama/gotracemoe v0.0.3
-	github.com/fumiama/imgsz v0.0.4
 	github.com/fumiama/jieba v0.0.0-20221203025406-36c17a10b565
 	github.com/fumiama/slowdo v0.0.0-20241001074058-27c4fe5259a4
 	github.com/fumiama/terasu v1.0.2
@@ -44,10 +43,10 @@ require (
 	github.com/notnil/chess v1.10.0
 	github.com/pkg/errors v0.9.1
 	github.com/shirou/gopsutil/v4 v4.25.12
-	github.com/sirupsen/logrus v1.9.3
+	github.com/sirupsen/logrus v1.9.4
 	github.com/tidwall/gjson v1.18.0
 	github.com/wcharczuk/go-chart/v2 v2.1.2
-	github.com/wdvxdr1123/ZeroBot v1.8.3-0.20260103120253-8a8f1347f983
+	github.com/wdvxdr1123/ZeroBot v1.8.3-0.20260117102541-393033a35adb
 	gitlab.com/gomidi/midi/v2 v2.3.18
 	golang.org/x/image v0.34.0
 	golang.org/x/sys v0.39.0
@@ -66,6 +65,7 @@ require (
 	github.com/ericpauley/go-quantize v0.0.0-20200331213906-ae555eb2afa4 // indirect
 	github.com/fumiama/go-simple-protobuf v0.2.0 // indirect
 	github.com/fumiama/gofastTEA v0.1.3 // indirect
+	github.com/fumiama/imgsz v0.0.4 // indirect
 	github.com/fumiama/orbyte v0.0.0-20251002065953-3bb358367eb5 // indirect
 	github.com/gabriel-vasile/mimetype v1.4.12 // indirect
 	github.com/go-ole/go-ole v1.2.6 // indirect

go.sum

@@ -16,8 +16,8 @@ github.com/FloatTech/ttl v0.0.0-20250224045156-012b1463287d h1:mUQ/c3wXKsUGa4Sg9
 github.com/FloatTech/ttl v0.0.0-20250224045156-012b1463287d/go.mod h1:fHZFWGquNXuHttu9dUYoKuNbm3dzLETnIOnm1muSfDs=
 github.com/FloatTech/zbpctrl v1.7.1 h1:0yPEmCForhyMbnhTckmjDUFFDZgQp1RjO2bVF4ZVqOs=
 github.com/FloatTech/zbpctrl v1.7.1/go.mod h1:xmM4dSwHA02Gei3ogCRiG+RTrw/7Z69PfrN5NYf8BPE=
-github.com/FloatTech/zbputils v1.7.2-0.20260106142643-d2d50560ae97 h1:lmlg7nKGbr/+rwPFZ98z5IetB4ooTFZFyd1ovzd1gA4=
-github.com/FloatTech/zbputils v1.7.2-0.20260106142643-d2d50560ae97/go.mod h1:K80JcDL2x1rqsyOzMPSIqqqSiJncWwlPIgHcNXnYIAw=
+github.com/FloatTech/zbputils v1.7.2-0.20260117132036-29f021ceb949 h1:1AEUIu4up84J4VqrENGyzUuYEIaQ5xYNDwIm00voL5c=
+github.com/FloatTech/zbputils v1.7.2-0.20260117132036-29f021ceb949/go.mod h1:uX5JHIADt9/vSIriLZTRwkeVvOVwxOGiDyS5O1lTPGE=
 github.com/PuerkitoBio/goquery v1.5.1/go.mod h1:GsLWisAFVj4WgDibEWF4pvYnkVQBpKBKeU+7zCJoLcc=
 github.com/PuerkitoBio/goquery v1.8.0 h1:PJTF7AmFCFKk1N6V6jmKfrNH9tV5pNE6lZMkG0gta/U=
 github.com/PuerkitoBio/goquery v1.8.0/go.mod h1:ypIiRMtY7COPGk+I/YbZLbxsxn9g5ejnI2HSMtkjZvI=
@@ -67,8 +67,8 @@ github.com/fumiama/deepinfra v0.0.0-20251221163610-e98ee3ba437a h1:a0+2vaXajfxsN
 github.com/fumiama/deepinfra v0.0.0-20251221163610-e98ee3ba437a/go.mod h1:uqsWK/GM9OvKV0pXZOQB63rWugBbiXInY8E1JoRKhkg=
 github.com/fumiama/go-base16384 v1.7.1 h1:1P1x6FWRvd7PtbH4idDAGWAjKKcVxggxlROYKRXbw58=
 github.com/fumiama/go-base16384 v1.7.1/go.mod h1:OEn+947GV5gsbTAnyuUW/SrfxJYUdYupSIQXOuGOcXM=
-github.com/fumiama/go-onebot-agent v0.0.0-20260106141737-1ac01594b67f h1:U6/IW2KL7xeAlIjV6MJTXMqmzcJaMXi43S4zXjIv+3s=
-github.com/fumiama/go-onebot-agent v0.0.0-20260106141737-1ac01594b67f/go.mod h1:rTrS23rvTYuZcSngENJTvcBFTz1nGsImSv+bW7yfhqs=
+github.com/fumiama/go-onebot-agent v0.0.0-20260117094018-cd93ccfd6e04 h1:TAvkyECK+lSVh+AnVSPNfCmeCiYiJCd+z9QQwfjHSuw=
+github.com/fumiama/go-onebot-agent v0.0.0-20260117094018-cd93ccfd6e04/go.mod h1:rTrS23rvTYuZcSngENJTvcBFTz1nGsImSv+bW7yfhqs=
 github.com/fumiama/go-registry v0.2.7 h1:tLEqgEpsiybQMqBv0dLHm5leia/z1DhajMupwnOHeNs=
 github.com/fumiama/go-registry v0.2.7/go.mod h1:m+wp5fF8dYgVoFkBPZl+vlK90loymaJE0JCtocVQLEs=
 github.com/fumiama/go-simple-protobuf v0.2.0 h1:ACyN1MAlu7pDR3EszWgzUeNP+IRsSHwH6V9JCJA5R5o=
@@ -182,11 +182,10 @@ github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec h1:W09IVJc94
 github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec/go.mod h1:qqbHyh8v60DhA7CoWK5oRCqLrMHRGoxYCSS9EjAz6Eo=
 github.com/shirou/gopsutil/v4 v4.25.12 h1:e7PvW/0RmJ8p8vPGJH4jvNkOyLmbkXgXW4m6ZPic6CY=
 github.com/shirou/gopsutil/v4 v4.25.12/go.mod h1:EivAfP5x2EhLp2ovdpKSozecVXn1TmuG7SMzs/Wh4PU=
-github.com/sirupsen/logrus v1.9.3 h1:dueUQJ1C2q9oE3F7wvmSGAaVtTmUizReu6fjN8uqzbQ=
-github.com/sirupsen/logrus v1.9.3/go.mod h1:naHLuLoDiP4jHNo9R0sCBMtWGeIprob74mVsIT4qYEQ=
+github.com/sirupsen/logrus v1.9.4 h1:TsZE7l11zFCLZnZ+teH4Umoq5BhEIfIzfRDZ1Uzql2w=
+github.com/sirupsen/logrus v1.9.4/go.mod h1:ftWc9WdOfJ0a92nsE2jF5u5ZwH8Bv2zdeOC42RjbV2g=
 github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=
 github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=
-github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
 github.com/stretchr/testify v1.7.1/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=
 github.com/stretchr/testify v1.11.1 h1:7s2iGBzp5EwR7/aIZr8ao5+dra3wiQyKjjFuvgVKu7U=
 github.com/stretchr/testify v1.11.1/go.mod h1:wZwfW3scLgRK+23gO65QZefKpKQRnfz6sD981Nm4B6U=
@@ -206,8 +205,8 @@ github.com/tklauser/numcpus v0.11.0 h1:nSTwhKH5e1dMNsCdVBukSZrURJRoHbSEQjdEbY+9R
 github.com/tklauser/numcpus v0.11.0/go.mod h1:z+LwcLq54uWZTX0u/bGobaV34u6V7KNlTZejzM6/3MQ=
 github.com/wcharczuk/go-chart/v2 v2.1.2 h1:Y17/oYNuXwZg6TFag06qe8sBajwwsuvPiJJXcUcLL6E=
 github.com/wcharczuk/go-chart/v2 v2.1.2/go.mod h1:Zi4hbaqlWpYajnXB2K22IUYVXRXaLfSGNNR7P4ukyyQ=
-github.com/wdvxdr1123/ZeroBot v1.8.3-0.20260103120253-8a8f1347f983 h1:hb2FUDooAf3u32wCTgJcBBuGPZF1sjgj8NfJaSy529s=
-github.com/wdvxdr1123/ZeroBot v1.8.3-0.20260103120253-8a8f1347f983/go.mod h1:trueIIVRywKJa3ov4QphzVvzYzgCNrlXdf9JvPJOFW8=
+github.com/wdvxdr1123/ZeroBot v1.8.3-0.20260117102541-393033a35adb h1:pwmyrnnMzb0WygAwUgXoZckzJkusK4WSaXxXqsIJYmU=
+github.com/wdvxdr1123/ZeroBot v1.8.3-0.20260117102541-393033a35adb/go.mod h1:kCLja2sXXgbBTsEOyBNCuT4z9tI+URQ2y0q/GGXprzU=
 github.com/yuin/goldmark v1.4.13/go.mod h1:6yULJ656Px+3vBD8DxQVa3kxgyrAnzto9xy5taEt/CY=
 github.com/yusufpapurcu/wmi v1.2.4 h1:zFUKzehAFReQwLys1b/iSMl+JQGSCSjtVqQn9bBrPo0=
 github.com/yusufpapurcu/wmi v1.2.4/go.mod h1:SBZ9tNy3G9/m5Oi98Zks0QjeHVDvuK0qfxQmPyzfmi0=
@@ -268,7 +267,6 @@ golang.org/x/sys v0.0.0-20201204225414-ed752295db88/go.mod h1:h1NjWce9XRLGQEsW7w
 golang.org/x/sys v0.0.0-20210423082822-04245dca01da/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
 golang.org/x/sys v0.0.0-20210615035016-665e8c7367d1/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.0.0-20220520151302-bc2c85ada10a/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
-golang.org/x/sys v0.0.0-20220715151400-c0bba94af5f8/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.0.0-20220722155257-8c9f86f7a55f/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.5.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=
 golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=

gomod2nix.toml

@@ -29,8 +29,8 @@ schema = 3
     version = "v1.7.1"
     hash = "sha256-wkeiaUTpPVbpH7fcXeoLtG+aGIMJbvoc/9sbi2IXK0I="
   [mod."github.com/FloatTech/zbputils"]
-    version = "v1.7.2-0.20260104162610-89522e42ecca"
-    hash = "sha256-xvv7VHQ1XaYTP4+eCT6bZ6Zq48IWoqsYCBIGPk1P5sw="
+    version = "v1.7.2-0.20260117125851-7d47971e44a2"
+    hash = "sha256-uRNSP1/oLyOoxLi+QApOalEqlySrK6J1ic46ue4f6dg="
   [mod."github.com/PuerkitoBio/goquery"]
     version = "v1.8.0"
     hash = "sha256-I3QaPWATvBOL/F26fIiYWKS13yBUYo+9o3tcsGIu8tY="
@@ -92,8 +92,8 @@ schema = 3
     version = "v1.7.1"
     hash = "sha256-Fd1QaeYx+3q4C3XQXlPFnDmKPsoZH6837fN/7rn8i9s="
   [mod."github.com/fumiama/go-onebot-agent"]
-    version = "v0.0.0-20260104164334-63ab0bc7f53a"
-    hash = "sha256-t+jnemW581ehzDklZ8+CO9uQN3jaww6nefXSuVuFZpQ="
+    version = "v0.0.0-20260117094018-cd93ccfd6e04"
+    hash = "sha256-V4Lpzn+KC1SXblNv9GnVfKd0femTaqty7wqFXuD+Roo="
   [mod."github.com/fumiama/go-registry"]
     version = "v0.2.7"
     hash = "sha256-Rjl+z0Hlp2LMi8+pnFe5HrxctyHMi7UPiK33g/OgLdA="
@@ -224,8 +224,8 @@ schema = 3
     version = "v4.25.12"
     hash = "sha256-gzk9GW4+tXUWmxAVD3by/k4D/+l++TvajRVTkQJvwmM="
   [mod."github.com/sirupsen/logrus"]
-    version = "v1.9.3"
-    hash = "sha256-EnxsWdEUPYid+aZ9H4/iMTs1XMvCLbXZRDyvj89Ebms="
+    version = "v1.9.4"
+    hash = "sha256-ltRvmtM3XTCAFwY0IesfRqYIivyXPPuvkFjL4ARh1wg="
   [mod."github.com/tetratelabs/wazero"]
     version = "v1.5.0"
     hash = "sha256-fGdJM4LJrZA9jxHuYVo4EUQ3I1k0IVG3QQCBCgZkeZI="
@@ -248,8 +248,8 @@ schema = 3
     version = "v2.1.2"
     hash = "sha256-GXWWea/u6BezTsPPrWhTYiTetPP/YW6P+Sj4YdocPaM="
   [mod."github.com/wdvxdr1123/ZeroBot"]
-    version = "v1.8.3-0.20260103120253-8a8f1347f983"
-    hash = "sha256-/6biuhXUIYxyJ0uT1R5Yk8RD2cm9/SQWtFvcyQgnWJE="
+    version = "v1.8.3-0.20260117102541-393033a35adb"
+    hash = "sha256-Yz2OTU05kDZOHX8J04jX5Jg5ya9rwqsH0TySSBhMOp0="
   [mod."github.com/yusufpapurcu/wmi"]
     version = "v1.2.4"
     hash = "sha256-N+YDBjOW59YOsZ2lRBVtFsEEi48KhNQRb63/0ZSU3bA="

kanban/banner/banner.go

@@ -3,13 +3,13 @@
 package banner
 
 // Version ...
-var Version = "v1.10.9"
+var Version = "v1.10.16"
 
 // Copyright ...
 var Copyright = "© 2020 - 2026 FloatTech"
 
 // Banner ...
 var Banner = "* OneBot + ZeroBot + Golang\n" +
-	"* Version " + Version + " - 2026-01-06 21:24:56 +0800 CST\n" +
+	"* Version " + Version + " - 2026-01-17 21:00:49 +0800 CST\n" +
 	"* Copyright " + Copyright + ". All Rights Reserved.\n" +
 	"* Project: https://github.com/FloatTech/ZeroBot-Plugin"

plugin/aichat/main.go

@@ -2,6 +2,7 @@
 package aichat
 
 import (
+	"encoding/json"
 	"math/rand"
 	"strings"
 
@@ -51,6 +52,10 @@ func init() {
 			logrus.Warnln("ERROR: cannot get stor")
 			return false
 		}
+		if _, ok := ctx.State[zero.StateKeyPrefixKeep+"_chat_ag_hooked__"]; !ok && !stor.NoAgent() {
+			logrus.Infoln("[aichat] skip agent for ctx has not been hooked by agent")
+			return false
+		}
 		if !(ctx.ExtractPlainText() != "" &&
 			(!stor.NoReplyAt() || (stor.NoReplyAt() && !ctx.Event.IsToMe))) {
 			return false
@@ -59,10 +64,6 @@ func init() {
 		if !ctx.Event.IsToMe && rand.Intn(100) >= int(rate) {
 			return false
 		}
-		if chat.AC.Key == "" {
-			logrus.Warnln("ERROR: get extra err: empty key")
-			return false
-		}
 		if ctx.Event.IsToMe {
 			ctx.Block()
 		}
@@ -77,7 +78,7 @@ func init() {
 		topp, maxn := chat.AC.MParams()
 
 		logrus.Debugln("[aichat] agent mode test: noagent", stor.NoAgent(), "hasapi", chat.AC.AgentAPI != "", "hasmodel", chat.AC.AgentModelName != "")
-		if !stor.NoAgent() && chat.AC.AgentAPI != "" && chat.AC.AgentModelName != "" {
+		if !stor.NoAgent() && chat.AC.AgentAPI != "" && chat.AC.AgentModelName != "" && chat.AC.Key != "" {
 			logrus.Debugln("[aichat] enter agent mode")
 			x := deepinfra.NewAPI(chat.AC.AgentAPI, string(chat.AC.AgentKey))
 			mod, err := chat.AC.Type.Protocol(chat.AC.AgentModelName, temperature, topp, maxn)
@@ -110,6 +111,8 @@ func init() {
 			ctx.NoTimeout()
 			logrus.Debugln("[aichat] agent set no timeout")
 			hasresp := false
+			// ispuremsg := false
+			// hassavemem := false
 			for i := 0; i < 8; i++ { // 最大运行 8 轮因为问答上下文只有 16
 				reqs := chat.CallAgent(ag, zero.SuperUserPermission(ctx), i+1, x, mod, gid, role)
 				if len(reqs) == 0 {
@@ -117,11 +120,36 @@ func init() {
 					break
 				}
 				hasresp = true
+				ctx.State[zero.StateKeyPrefixKeep+"_chat_ag_triggered__"] = struct{}{}
 				for _, req := range reqs {
 					if req.Action == goba.SVM { // is a fake action
+						/*if hassavemem {
+							ag.AddTerminus(gid)
+							logrus.Warnln("[aichat] agent call save mem multi times, force inserting EOA")
+							return
+						}
+						hassavemem = true*/
 						continue
 					}
-					_ = ctx.CallAction(req.Action, req.Params)
+					/*if req.Action == "send_private_msg" || req.Action == "send_group_msg" {
+						if ispuremsg {
+							ag.AddTerminus(gid)
+							logrus.Warnln("[aichat] agent call send msg multi times, force inserting EOA")
+							return
+						}
+						ispuremsg = true
+					}*/
+					logrus.Debugln("[chat] agent triggered", gid, "add requ:", &req)
+					ag.AddRequest(gid, &req)
+					rsp := ctx.CallAction(req.Action, req.Params)
+					logrus.Debugln("[chat] agent triggered", gid, "add resp:", &rsp)
+					ag.AddResponse(gid, &goba.APIResponse{
+						Status:  rsp.Status,
+						Data:    json.RawMessage(rsp.Data.Raw),
+						Message: rsp.Message,
+						Wording: rsp.Wording,
+						RetCode: rsp.RetCode,
+					})
 				}
 			}
 			if hasresp {
@@ -157,7 +185,7 @@ func init() {
 				if t == "" {
 					continue
 				}
-				logrus.Infoln("[aichat] 回复内容:", t)
+				logrus.Debugln("[aichat] 回复内容:", t)
 				recCfg := airecord.GetConfig()
 				record := ""
 				if !fastfailnorecord && !stor.NoRecord() {

plugin/aichatcfg/main.go

@@ -29,9 +29,11 @@ var (
 			"- 查看AI聊天系统提示词\n" +
 			"- 重置AI聊天系统提示词\n" +
 			"- 设置AI聊天系统提示词xxx\n" +
-			"- 设置AI聊天Agent性格" +
-			"- 查看AI聊天Agent性格xxx" +
-			"- 重置AI聊天Agent性格\n" +
+			"- 设置AI聊天Agent性格xxx" +
+			"- 查看AI聊天Agent性格" +
+			"- 设置AI聊天Agent性别xxx" +
+			"- 查看AI聊天Agent性别" +
+			"- 重置AI聊天Agent性格性别\n" +
 			"- 设置AI聊天分隔符</think>(留空则清除)\n" +
 			"- 设置AI聊天(不)响应AT\n" +
 			"- 设置AI聊天最大长度4096\n" +
@@ -45,12 +47,6 @@ var (
 
 func init() {
 	en.UsePreHandler(chat.EnsureConfig, func(ctx *zero.Ctx) bool {
-		if !chat.IsAgentCharReady {
-			if chat.AC.AgentChar != "" {
-				chat.AgentChar = []byte(chat.AC.AgentChar)
-			}
-			chat.IsAgentCharReady = true
-		}
 		k := zero.StateKeyPrefixKeep + "aichatcfg_stor__"
 		if _, ok := ctx.State[k]; ok {
 			return true
@@ -98,7 +94,13 @@ func init() {
 	en.OnPrefix("设置AI聊天系统提示词", chat.EnsureConfig, zero.OnlyPrivate, zero.SuperUserPermission).SetBlock(true).
 		Handle(chat.NewExtraSetStr(&chat.AC.SystemP))
 	en.OnPrefix("设置AI聊天Agent性格", chat.EnsureConfig, zero.OnlyPrivate, zero.SuperUserPermission).SetBlock(true).
-		Handle(chat.NewExtraSetStr(&chat.AC.AgentChar))
+		Handle(chat.NewExtraSetStr(&chat.AC.AgentChar), func(_ *zero.Ctx) {
+			chat.AgentCharConfig.Chars = chat.AC.AgentChar
+		})
+	en.OnPrefix("设置AI聊天Agent性别", chat.EnsureConfig, zero.OnlyPrivate, zero.SuperUserPermission).SetBlock(true).
+		Handle(chat.NewExtraSetStr(&chat.AC.AgentSex), func(_ *zero.Ctx) {
+			chat.AgentCharConfig.Sex = chat.AC.AgentSex
+		})
 	en.OnFullMatch("查看AI聊天系统提示词", chat.EnsureConfig, zero.OnlyPrivate, zero.SuperUserPermission).SetBlock(true).Handle(func(ctx *zero.Ctx) {
 		ctx.SendChain(message.Text(chat.AC.SystemP))
 	})
@@ -119,13 +121,13 @@ func init() {
 		}
 		ctx.SendChain(message.Text("成功"))
 	})
-	en.OnFullMatch("重置AI聊天Agent性格", chat.EnsureConfig, zero.OnlyPrivate, zero.SuperUserPermission).SetBlock(true).Handle(func(ctx *zero.Ctx) {
+	en.OnFullMatch("重置AI聊天Agent性格性别", chat.EnsureConfig, zero.OnlyPrivate, zero.SuperUserPermission).SetBlock(true).Handle(func(ctx *zero.Ctx) {
 		c, ok := ctx.State["manager"].(*ctrl.Control[*zero.Ctx])
 		if !ok {
 			ctx.SendChain(message.Text("ERROR: no such plugin"))
 			return
 		}
-		chat.AC.AgentChar = ""
+		chat.ResetAgentCharConfig()
 		err := c.SetExtra(&chat.AC)
 		if err != nil {
 			ctx.SendChain(message.Text("ERROR: set extra err: ", err))
@@ -135,17 +137,17 @@ func init() {
 	})
 	en.OnPrefix("设置AI聊天分隔符", chat.EnsureConfig, zero.OnlyPrivate, zero.SuperUserPermission).SetBlock(true).
 		Handle(chat.NewExtraSetStr(&chat.AC.Separator))
-	en.OnRegex("^设置AI聊天(不)?响应AT$", chat.EnsureConfig, zero.SuperUserPermission).SetBlock(true).
+	en.OnRegex("^设置AI聊天(不)?响应AT$", zero.SuperUserPermission).SetBlock(true).
 		Handle(ctxext.NewStorageSaveBoolHandler(chat.BitmapNrat))
 	en.OnRegex("^设置AI聊天(不)?支持系统提示词$", chat.EnsureConfig, zero.OnlyPrivate, zero.SuperUserPermission).SetBlock(true).
 		Handle(chat.NewExtraSetBool(&chat.AC.NoSystemP))
-	en.OnRegex("^设置AI聊天(不)?使用Agent模式$", chat.EnsureConfig, zero.SuperUserPermission).SetBlock(true).
+	en.OnRegex("^设置AI聊天(不)?使用Agent模式$", zero.SuperUserPermission).SetBlock(true).
 		Handle(ctxext.NewStorageSaveBoolHandler(chat.BitmapNagt))
 	en.OnPrefix("设置AI聊天最大长度", chat.EnsureConfig, zero.OnlyPrivate, zero.SuperUserPermission).SetBlock(true).
 		Handle(chat.NewExtraSetUint(&chat.AC.MaxN))
 	en.OnPrefix("设置AI聊天TopP", chat.EnsureConfig, zero.OnlyPrivate, zero.SuperUserPermission).SetBlock(true).
 		Handle(chat.NewExtraSetFloat32(&chat.AC.TopP))
-	en.OnRegex("^设置AI聊天(不)?以AI语音输出$", chat.EnsureConfig, zero.AdminPermission).SetBlock(true).
+	en.OnRegex("^设置AI聊天(不)?以AI语音输出$", zero.AdminPermission).SetBlock(true).
 		Handle(ctxext.NewStorageSaveBoolHandler(chat.BitmapNrec))
 	en.OnFullMatch("查看AI聊天配置", chat.EnsureConfig, zero.SuperUserPermission).SetBlock(true).
 		Handle(func(ctx *zero.Ctx) {

plugin/crypter/handlers.go

@@ -3,7 +3,6 @@ package crypter
 
 import (
 	"github.com/FloatTech/AnimeAPI/airecord"
-	"github.com/sirupsen/logrus"
 	zero "github.com/wdvxdr1123/ZeroBot"
 	"github.com/wdvxdr1123/ZeroBot/message"
 )
@@ -12,7 +11,6 @@ import (
 func houEncryptHandler(ctx *zero.Ctx) {
 	text := ctx.State["regex_matched"].([]string)[1]
 	result := encodeHou(text)
-	logrus.Infoln("[crypter] 回复内容:", result)
 	recCfg := airecord.GetConfig()
 	record := ctx.GetAIRecord(recCfg.ModelID, recCfg.Customgid, result)
 	if record != "" {

plugin/drawlots/main.go

@@ -36,7 +36,7 @@ var (
 	lotsList = func() map[string]info {
 		lotsList, err := getList()
 		if err != nil {
-			logrus.Infoln("[drawlots]加载失败:", err)
+			logrus.Infoln("[drawlots]加载失败:", err, "(如果从未使用过该插件, 这是正常现象)")
 		} else {
 			logrus.Infoln("[drawlots]加载", len(lotsList), "个抽签")
 		}

plugin/guessmusic/guessmusic.go

@@ -11,8 +11,6 @@ import (
 	"sync"
 	"time"
 
-	log "github.com/sirupsen/logrus"
-
 	"github.com/FloatTech/floatbox/file"
 	"github.com/FloatTech/zbputils/ctxext"
 	"github.com/pkg/errors"
@@ -30,7 +28,7 @@ func init() {
 	var err1 error
 	t2s, err1 = gocc.New("t2s")
 	if err1 != nil {
-		log.Infof("[guessmusic]:%s", err1)
+		panic(err1)
 	}
 
 	engine.OnRegex(`^(个人|团队)猜歌(-(.*))?$`, zero.OnlyGroup).SetBlock(true).Limit(ctxext.LimitByGroup).

plugin/minecraftobserver/store_test.go

@@ -3,8 +3,9 @@ package minecraftobserver
 import (
 	"errors"
 	"fmt"
-	"github.com/jinzhu/gorm"
 	"testing"
+
+	"github.com/jinzhu/gorm"
 )
 
 func cleanTestData(t *testing.T) {

plugin/rsshub/domain/job.go

@@ -28,7 +28,7 @@ func (repo *RssDomain) syncRss(ctx context.Context) (updated map[int64]*RssClien
 		feed, err = repo.rssHubClient.FetchFeed(channel.RssHubFeedPath)
 		// 如果获取失败，则跳过
 		if err != nil {
-			logrus.WithContext(ctx).Errorf("[rsshub syncRss] fetch path(%+v) error: %v", channel.RssHubFeedPath, err)
+			logrus.WithContext(ctx).Warnf("[rsshub syncRss] fetch path(%+v) error: %v", channel.RssHubFeedPath, err)
 			continue
 		}
 		rv := convertFeedToRssView(0, channel.RssHubFeedPath, feed)
@@ -42,27 +42,27 @@ func (repo *RssDomain) syncRss(ctx context.Context) (updated map[int64]*RssClien
 		var needUpdate bool
 		needUpdate, err = repo.checkSourceNeedUpdate(ctx, cv.Source)
 		if err != nil {
-			logrus.WithContext(ctx).Errorf("[rsshub syncRss] checkSourceNeedUpdate error: %v", err)
+			logrus.WithContext(ctx).Warnf("[rsshub syncRss] checkSourceNeedUpdate error: %v", err)
 			err = nil
 			continue
 		}
 		// 保存
-		logrus.WithContext(ctx).Infof("[rsshub syncRss] cv %+v, need update(real): %v", cv.Source, needUpdate)
+		logrus.WithContext(ctx).Debugf("[rsshub syncRss] cv %+v, need update(real): %v", cv.Source, needUpdate)
 		// 如果需要更新，更新channel 和 content
 		if needUpdate {
 			err = repo.storage.UpsertSource(ctx, cv.Source)
 			if err != nil {
-				logrus.WithContext(ctx).Errorf("[rsshub syncRss] upsert source error: %v", err)
+				logrus.WithContext(ctx).Warnf("[rsshub syncRss] upsert source error: %v", err)
 			}
 		}
 		var updateChannelView = &RssClientView{Source: cv.Source, Contents: []*RssContent{}}
 		err = repo.processContentsUpdate(ctx, cv, updateChannelView)
 		if err != nil {
-			logrus.WithContext(ctx).Errorf("[rsshub syncRss] processContentsUpdate error: %v", err)
+			logrus.WithContext(ctx).Warnf("[rsshub syncRss] processContentsUpdate error: %v", err)
 			continue
 		}
 		if len(updateChannelView.Contents) == 0 {
-			logrus.WithContext(ctx).Infof("[rsshub syncRss] cv %s, no new content", cv.Source.RssHubFeedPath)
+			logrus.WithContext(ctx).Debugf("[rsshub syncRss] cv %s, no new content", cv.Source.RssHubFeedPath)
 			continue
 		}
 		updateChannelView.Sort()
@@ -80,7 +80,7 @@ func (repo *RssDomain) checkSourceNeedUpdate(ctx context.Context, source *RssSou
 		return
 	}
 	if sourceInDB == nil {
-		logrus.WithContext(ctx).Errorf("[rsshub syncRss] source not found: %v", source.RssHubFeedPath)
+		logrus.WithContext(ctx).Warnf("[rsshub syncRss] source not found: %v", source.RssHubFeedPath)
 		return
 	}
 	source.ID = sourceInDB.ID
@@ -102,13 +102,13 @@ func (repo *RssDomain) processContentsUpdate(ctx context.Context, cv *RssClientV
 		var existed bool
 		existed, err = repo.processContentItemUpdate(ctx, content)
 		if err != nil {
-			logrus.WithContext(ctx).Errorf("[rsshub syncRss] upsert content error: %v", err)
+			logrus.WithContext(ctx).Warnf("[rsshub syncRss] upsert content error: %v", err)
 			err = nil
 			continue
 		}
 		if !existed {
 			updateChannelView.Contents = append(updateChannelView.Contents, content)
-			logrus.WithContext(ctx).Infof("[rsshub syncRss] cv %s, add new content: %v", cv.Source.RssHubFeedPath, content.Title)
+			logrus.WithContext(ctx).Debugf("[rsshub syncRss] cv %s, add new content: %v", cv.Source.RssHubFeedPath, content.Title)
 		}
 	}
 	return err
@@ -127,7 +127,7 @@ func (repo *RssDomain) processContentItemUpdate(ctx context.Context, content *Rs
 	// 保存
 	err = repo.storage.UpsertContent(ctx, content)
 	if err != nil {
-		logrus.WithContext(ctx).Errorf("[rsshub syncRss] upsert content error: %v", err)
+		logrus.WithContext(ctx).Warnf("[rsshub syncRss] upsert content error: %v", err)
 		return
 	}
 	return

plugin/rsshub/domain/rawFeed.go

@@ -36,11 +36,11 @@ func (c *RssHubClient) FetchFeed(path string) (feed *gofeed.Feed, err error) {
 		}
 	}
 	if err != nil {
-		logrus.Errorf("[rsshub FetchFeed] fetch feed error: %v", err)
+		logrus.Warnf("[rsshub FetchFeed] fetch feed error: %v", err)
 		return nil, err
 	}
 	if len(data) == 0 {
-		logrus.Errorf("[rsshub FetchFeed] fetch feed error: data is empty")
+		logrus.Warnf("[rsshub FetchFeed] fetch feed error: data is empty")
 		return nil, errors.New("feed data is empty")
 	}
 	feed, err = gofeed.NewParser().Parse(bytes.NewBuffer(data))

plugin/rsshub/domain/rssHub.go

@@ -33,7 +33,7 @@ func newRssDomain(dbPath string) (*RssDomain, error) {
 	}
 	orm, err := gorm.Open("sqlite3", dbPath)
 	if err != nil {
-		logrus.Errorf("[rsshub NewRssDomain] open db error: %v", err)
+		logrus.Warnf("[rsshub NewRssDomain] open db error: %v", err)
 		panic(err)
 	}
 	repo := &RssDomain{
@@ -42,7 +42,7 @@ func newRssDomain(dbPath string) (*RssDomain, error) {
 	}
 	err = repo.storage.initDB()
 	if err != nil {
-		logrus.Errorf("[rsshub NewRssDomain] open db error: %v", err)
+		logrus.Warnf("[rsshub NewRssDomain] open db error: %v", err)
 		panic(err)
 	}
 	return repo, nil
@@ -54,15 +54,15 @@ func (repo *RssDomain) Subscribe(ctx context.Context, gid int64, feedPath string
 	// 验证
 	feed, err := repo.rssHubClient.FetchFeed(feedPath)
 	if err != nil {
-		logrus.WithContext(ctx).Errorf("[rsshub Subscribe] add source error: %v", err)
+		logrus.WithContext(ctx).Warnf("[rsshub Subscribe] add source error: %v", err)
 		return
 	}
-	logrus.WithContext(ctx).Infof("[rsshub Subscribe] try get source success: %v", len(feed.Title))
+	logrus.WithContext(ctx).Debugf("[rsshub Subscribe] try get source success: %v", len(feed.Title))
 	// 新建source结构体
 	rv = convertFeedToRssView(0, feedPath, feed)
 	feedChannel, err := repo.storage.GetSourceByRssHubFeedLink(ctx, feedPath)
 	if err != nil {
-		logrus.WithContext(ctx).Errorf("[rsshub Subscribe] query source by feedPath error: %v", err)
+		logrus.WithContext(ctx).Warnf("[rsshub Subscribe] query source by feedPath error: %v", err)
 		return
 	}
 	// 如果已经存在
@@ -76,30 +76,30 @@ func (repo *RssDomain) Subscribe(ctx context.Context, gid int64, feedPath string
 	// 保存
 	err = repo.storage.UpsertSource(ctx, rv.Source)
 	if err != nil {
-		logrus.WithContext(ctx).Errorf("[rsshub Subscribe] save source error: %v", err)
+		logrus.WithContext(ctx).Warnf("[rsshub Subscribe] save source error: %v", err)
 		return
 	}
-	logrus.Infof("[rsshub Subscribe] save/update source success %v", rv.Source.ID)
+	logrus.Debugf("[rsshub Subscribe] save/update source success %v", rv.Source.ID)
 	// 添加群号到订阅
 	subscribe, err := repo.storage.GetSubscribeByID(ctx, gid, rv.Source.ID)
 	if err != nil {
-		logrus.WithContext(ctx).Errorf("[rsshub Subscribe] query subscribe error: %v", err)
+		logrus.WithContext(ctx).Warnf("[rsshub Subscribe] query subscribe error: %v", err)
 		return
 	}
-	logrus.WithContext(ctx).Infof("[rsshub Subscribe] query subscribe success: %v", subscribe)
+	logrus.WithContext(ctx).Debugf("[rsshub Subscribe] query subscribe success: %v", subscribe)
 	// 如果已经存在，直接返回
 	if subscribe != nil {
 		isSubExisted = true
-		logrus.WithContext(ctx).Infof("[rsshub Subscribe] subscribe existed: %v", subscribe)
+		logrus.WithContext(ctx).Debugf("[rsshub Subscribe] subscribe existed: %v", subscribe)
 		return
 	}
 	// 如果不存在，保存
 	err = repo.storage.CreateSubscribe(ctx, gid, rv.Source.ID)
 	if err != nil {
-		logrus.WithContext(ctx).Errorf("[rsshub Subscribe] save subscribe error: %v", err)
+		logrus.WithContext(ctx).Warnf("[rsshub Subscribe] save subscribe error: %v", err)
 		return
 	}
-	logrus.WithContext(ctx).Infof("[rsshub Subscribe] success: %v", len(rv.Contents))
+	logrus.WithContext(ctx).Debugf("[rsshub Subscribe] success: %v", len(rv.Contents))
 	return
 }
 
@@ -107,31 +107,31 @@ func (repo *RssDomain) Subscribe(ctx context.Context, gid int64, feedPath string
 func (repo *RssDomain) Unsubscribe(ctx context.Context, gid int64, feedPath string) (err error) {
 	existedSubscribes, ifExisted, err := repo.storage.GetIfExistedSubscribe(ctx, gid, feedPath)
 	if err != nil {
-		logrus.WithContext(ctx).Errorf("[rsshub Subscribe] query sub by route error: %v", err)
+		logrus.WithContext(ctx).Warnf("[rsshub Subscribe] query sub by route error: %v", err)
 		return errors.New("数据库错误")
 	}
-	logrus.WithContext(ctx).Infof("[rsshub Subscribe] query source by route success: %v", existedSubscribes)
+	logrus.WithContext(ctx).Debugf("[rsshub Subscribe] query source by route success: %v", existedSubscribes)
 	// 如果不存在订阅关系，直接返回
 	if !ifExisted || existedSubscribes == nil {
-		logrus.WithContext(ctx).Infof("[rsshub Subscribe] source existed: %v", ifExisted)
+		logrus.WithContext(ctx).Debugf("[rsshub Subscribe] source existed: %v", ifExisted)
 		return errors.New("频道不存在")
 	}
 	err = repo.storage.DeleteSubscribe(ctx, existedSubscribes.ID)
 	if err != nil {
-		logrus.WithContext(ctx).Errorf("[rsshub Subscribe] delete source error: %v", err)
+		logrus.WithContext(ctx).Warnf("[rsshub Subscribe] delete source error: %v", err)
 		return errors.New("删除失败")
 	}
 	// 查询是否还有群订阅这个频道
 	subscribesNeedsToDel, err := repo.storage.GetSubscribesBySource(ctx, feedPath)
 	if err != nil {
-		logrus.WithContext(ctx).Errorf("[rsshub Subscribe] query source by route error: %v", err)
+		logrus.WithContext(ctx).Warnf("[rsshub Subscribe] query source by route error: %v", err)
 		return
 	}
 	// 没有群订阅的时候，把频道删除
 	if len(subscribesNeedsToDel) == 0 {
 		err = repo.storage.DeleteSource(ctx, existedSubscribes.RssSourceID)
 		if err != nil {
-			logrus.WithContext(ctx).Errorf("[rsshub Subscribe] delete source error: %v", err)
+			logrus.WithContext(ctx).Warnf("[rsshub Subscribe] delete source error: %v", err)
 			return errors.New("清除频道信息失败")
 		}
 	}
@@ -142,11 +142,11 @@ func (repo *RssDomain) Unsubscribe(ctx context.Context, gid int64, feedPath stri
 func (repo *RssDomain) GetSubscribedChannelsByGroupID(ctx context.Context, gid int64) ([]*RssClientView, error) {
 	channels, err := repo.storage.GetSubscribedChannelsByGroupID(ctx, gid)
 	if err != nil {
-		logrus.WithContext(ctx).Errorf("[rsshub GetSubscribedChannelsByGroupID] GetSubscribedChannelsByGroupID error: %v", err)
+		logrus.WithContext(ctx).Warnf("[rsshub GetSubscribedChannelsByGroupID] GetSubscribedChannelsByGroupID error: %v", err)
 		return nil, err
 	}
 	rv := make([]*RssClientView, len(channels))
-	logrus.WithContext(ctx).Infof("[rsshub GetSubscribedChannelsByGroupID] query subscribe success: %v", len(channels))
+	logrus.WithContext(ctx).Debugf("[rsshub GetSubscribedChannelsByGroupID] query subscribe success: %v", len(channels))
 	for i, cn := range channels {
 		rv[i] = &RssClientView{
 			Source: cn,
@@ -162,13 +162,13 @@ func (repo *RssDomain) Sync(ctx context.Context) (groupView map[int64][]*RssClie
 	// 获取所有频道
 	updatedViews, err := repo.syncRss(ctx)
 	if err != nil {
-		logrus.WithContext(ctx).Errorf("[rsshub Sync] sync rss feed error: %v", err)
+		logrus.WithContext(ctx).Warnf("[rsshub Sync] sync rss feed error: %v", err)
 		return
 	}
-	logrus.WithContext(ctx).Infof("[rsshub Sync] updated channels: %v", len(updatedViews))
+	logrus.WithContext(ctx).Debugf("[rsshub Sync] updated channels: %v", len(updatedViews))
 	subscribes, err := repo.storage.GetSubscribes(ctx)
 	if err != nil {
-		logrus.WithContext(ctx).Errorf("[rsshub Sync] get subscribes error: %v", err)
+		logrus.WithContext(ctx).Warnf("[rsshub Sync] get subscribes error: %v", err)
 		return
 	}
 	for _, subscribe := range subscribes {

plugin/rsshub/domain/storageRepo.go

@@ -19,7 +19,7 @@ type repoStorage struct {
 func (s *repoStorage) initDB() (err error) {
 	err = s.orm.AutoMigrate(&RssSource{}, &RssContent{}, &RssSubscribe{}).Error
 	if err != nil {
-		logrus.Errorf("[rsshub initDB] error: %v", err)
+		logrus.Warnf("[rsshub initDB] error: %v", err)
 		return err
 	}
 	return nil
@@ -28,7 +28,7 @@ func (s *repoStorage) initDB() (err error) {
 
 // GetSubscribesBySource Impl
 func (s *repoStorage) GetSubscribesBySource(ctx context.Context, feedPath string) ([]*RssSubscribe, error) {
-	logrus.WithContext(ctx).Infof("[rsshub GetSubscribesBySource] feedPath: %s", feedPath)
+	logrus.WithContext(ctx).Debugf("[rsshub GetSubscribesBySource] feedPath: %s", feedPath)
 	rs := make([]*RssSubscribe, 0)
 	err := s.orm.Model(&RssSubscribe{}).Joins(fmt.Sprintf("%s left join %s on %s.rss_source_id=%s.id", tableNameRssSubscribe, tableNameRssSource, tableNameRssSubscribe, tableNameRssSource)).
 		Where("rss_source.rss_hub_feed_path = ?", feedPath).Select("rss_subscribe.*").Find(&rs).Error
@@ -36,7 +36,7 @@ func (s *repoStorage) GetSubscribesBySource(ctx context.Context, feedPath string
 		if errors.Is(err, gorm.ErrRecordNotFound) {
 			return nil, nil
 		}
-		logrus.WithContext(ctx).Errorf("[rsshub GetSubscribesBySource] error: %v", err)
+		logrus.WithContext(ctx).Warnf("[rsshub GetSubscribesBySource] error: %v", err)
 		return nil, err
 	}
 	return rs, nil
@@ -56,7 +56,7 @@ func (s *repoStorage) GetIfExistedSubscribe(ctx context.Context, gid int64, feed
 		if errors.Is(err, gorm.ErrRecordNotFound) {
 			return nil, false, nil
 		}
-		logrus.WithContext(ctx).Errorf("[rsshub GetIfExistedSubscribe] error: %v", err)
+		logrus.WithContext(ctx).Warnf("[rsshub GetIfExistedSubscribe] error: %v", err)
 		return nil, false, err
 	}
 	if rs.ID == 0 {
@@ -76,14 +76,14 @@ func (s *repoStorage) UpsertSource(ctx context.Context, source *RssSource) (err
 		if errors.Is(err, gorm.ErrRecordNotFound) {
 			err = s.orm.Create(source).Omit("id").Error
 			if err != nil {
-				logrus.WithContext(ctx).Errorf("[rsshub] add source error: %v", err)
+				logrus.WithContext(ctx).Warnf("[rsshub] add source error: %v", err)
 				return
 			}
 		}
 		return
 	}
 	source.ID = querySource.ID
-	logrus.WithContext(ctx).Infof("[rsshub] update source: %+v", source.UpdatedParsed)
+	logrus.WithContext(ctx).Debugf("[rsshub] update source: %+v", source.UpdatedParsed)
 	err = s.orm.Model(&source).Where(&RssSource{ID: source.ID}).
 		Updates(&RssSource{
 			Title:         source.Title,
@@ -94,7 +94,7 @@ func (s *repoStorage) UpsertSource(ctx context.Context, source *RssSource) (err
 			Mtime:         time.Now(),
 		}).Error
 	if err != nil {
-		logrus.WithContext(ctx).Errorf("[rsshub] update source error: %v", err)
+		logrus.WithContext(ctx).Warnf("[rsshub] update source error: %v", err)
 		return
 	}
 	logrus.Println("[rsshub] add source success: ", source.ID)
@@ -109,10 +109,10 @@ func (s *repoStorage) GetSources(ctx context.Context) (sources []RssSource, err
 		if errors.Is(err, gorm.ErrRecordNotFound) {
 			return nil, errors.New("source not found")
 		}
-		logrus.WithContext(ctx).Errorf("[rsshub] get sources error: %v", err)
+		logrus.WithContext(ctx).Warnf("[rsshub] get sources error: %v", err)
 		return
 	}
-	logrus.WithContext(ctx).Infof("[rsshub] get sources success: %d", len(sources))
+	logrus.WithContext(ctx).Debugf("[rsshub] get sources success: %d", len(sources))
 	return
 }
 
@@ -124,7 +124,7 @@ func (s *repoStorage) GetSourceByRssHubFeedLink(ctx context.Context, rssHubFeedL
 		if errors.Is(err, gorm.ErrRecordNotFound) {
 			return nil, nil
 		}
-		logrus.WithContext(ctx).Errorf("[rsshub] get source error: %v", err)
+		logrus.WithContext(ctx).Warnf("[rsshub] get source error: %v", err)
 		return
 	}
 	return
@@ -134,7 +134,7 @@ func (s *repoStorage) GetSourceByRssHubFeedLink(ctx context.Context, rssHubFeedL
 func (s *repoStorage) DeleteSource(ctx context.Context, fID int64) (err error) {
 	err = s.orm.Delete(&RssSource{}, "id = ?", fID).Error
 	if err != nil {
-		logrus.WithContext(ctx).Errorf("[rsshub] storage.DeleteSource: %v", err)
+		logrus.WithContext(ctx).Warnf("[rsshub] storage.DeleteSource: %v", err)
 		if errors.Is(err, gorm.ErrRecordNotFound) {
 			return errors.New("source not found")
 		}
@@ -161,7 +161,7 @@ func (s *repoStorage) UpsertContent(ctx context.Context, content *RssContent) (e
 	}
 	err = s.orm.Create(content).Omit("id").Error
 	if err != nil {
-		logrus.WithContext(ctx).Errorf("[rsshub] storage.UpsertContent: %v", err)
+		logrus.WithContext(ctx).Warnf("[rsshub] storage.UpsertContent: %v", err)
 		return
 	}
 	return
@@ -171,7 +171,7 @@ func (s *repoStorage) UpsertContent(ctx context.Context, content *RssContent) (e
 func (s *repoStorage) DeleteSourceContents(ctx context.Context, channelID int64) (rows int64, err error) {
 	err = s.orm.Delete(&RssSubscribe{}).Where(&RssSubscribe{RssSourceID: channelID}).Error
 	if err != nil {
-		logrus.WithContext(ctx).Errorf("[rsshub] storage.DeleteSourceContents: %v", err)
+		logrus.WithContext(ctx).Warnf("[rsshub] storage.DeleteSourceContents: %v", err)
 		return
 	}
 	return
@@ -185,7 +185,7 @@ func (s *repoStorage) IsContentHashIDExist(ctx context.Context, hashID string) (
 		if errors.Is(err, gorm.ErrRecordNotFound) {
 			return false, nil
 		}
-		logrus.WithContext(ctx).Errorf("[rsshub] storage.IsContentHashIDExist: %v", err)
+		logrus.WithContext(ctx).Warnf("[rsshub] storage.IsContentHashIDExist: %v", err)
 		return false, err
 	}
 	return true, nil
@@ -204,7 +204,7 @@ func (s *repoStorage) CreateSubscribe(ctx context.Context, gid, rssSourceID int6
 	}
 	err = s.orm.Create(&RssSubscribe{GroupID: gid, RssSourceID: rssSourceID}).Omit("id").Error
 	if err != nil {
-		logrus.WithContext(ctx).Errorf("[rsshub] storage.CreateSubscribe: %v", err)
+		logrus.WithContext(ctx).Warnf("[rsshub] storage.CreateSubscribe: %v", err)
 		return
 	}
 	return
@@ -214,7 +214,7 @@ func (s *repoStorage) CreateSubscribe(ctx context.Context, gid, rssSourceID int6
 func (s *repoStorage) DeleteSubscribe(ctx context.Context, subscribeID int64) (err error) {
 	err = s.orm.Delete(&RssSubscribe{}, "id = ?", subscribeID).Error
 	if err != nil {
-		logrus.WithContext(ctx).Errorf("[rsshub] storage.DeleteSubscribe error: %v", err)
+		logrus.WithContext(ctx).Warnf("[rsshub] storage.DeleteSubscribe error: %v", err)
 		return
 	}
 	return
@@ -228,7 +228,7 @@ func (s *repoStorage) GetSubscribeByID(ctx context.Context, gid int64, subscribe
 		if errors.Is(err, gorm.ErrRecordNotFound) {
 			return nil, nil
 		}
-		logrus.WithContext(ctx).Errorf("[rsshub] storage.GetSubscribeByID: %v", err)
+		logrus.WithContext(ctx).Warnf("[rsshub] storage.GetSubscribeByID: %v", err)
 		return nil, err
 	}
 	return
@@ -247,7 +247,7 @@ func (s *repoStorage) GetSubscribedChannelsByGroupID(ctx context.Context, gid in
 			err = nil
 			return
 		}
-		logrus.WithContext(ctx).Errorf("[rsshub] storage.GetSubscribedChannelsByGroupID: %v", err)
+		logrus.WithContext(ctx).Warnf("[rsshub] storage.GetSubscribedChannelsByGroupID: %v", err)
 		return
 	}
 	return
@@ -262,7 +262,7 @@ func (s *repoStorage) GetSubscribes(ctx context.Context) (res []*RssSubscribe, e
 			err = nil
 			return
 		}
-		logrus.WithContext(ctx).Errorf("[rsshub] storage.GetSubscribes: %v", err)
+		logrus.WithContext(ctx).Warnf("[rsshub] storage.GetSubscribes: %v", err)
 		return
 	}
 	return

winres/winres.json

@@ -12,7 +12,7 @@
       "0409": {
         "identity": {
           "name": "ZeroBot-Plugin",
-          "version": "1.10.9.2338"
+          "version": "1.10.16.2369"
         },
         "description": "",
         "minimum-os": "vista",
@@ -36,23 +36,23 @@
     "#1": {
       "0000": {
         "fixed": {
-          "file_version": "1.10.9.2338",
-          "product_version": "v1.10.9",
-          "timestamp": "2026-01-06T21:25:04+08:00"
+          "file_version": "1.10.16.2369",
+          "product_version": "v1.10.16",
+          "timestamp": "2026-01-17T21:01:01+08:00"
         },
         "info": {
           "0409": {
             "Comments": "OneBot plugins based on ZeroBot",
             "CompanyName": "FloatTech",
             "FileDescription": "https://github.com/FloatTech/ZeroBot-Plugin",
-            "FileVersion": "1.10.9.2338",
+            "FileVersion": "1.10.16.2369",
             "InternalName": "",
             "LegalCopyright": "© 2020 - 2026 FloatTech. All Rights Reserved.",
             "LegalTrademarks": "",
             "OriginalFilename": "ZBP.EXE",
             "PrivateBuild": "",
             "ProductName": "ZeroBot-Plugin",
-            "ProductVersion": "v1.10.9",
+            "ProductVersion": "v1.10.16",
             "SpecialBuild": ""
           }
         }