Test4

Processor/ProcessC2CMessage.go

@@ -82,6 +82,9 @@ func (p *Processors) ProcessC2CMessage(data *dto.WSC2CMessageData) error {
 		//其实不需要用AppIDString,因为gensokyo是单机器人框架
 		//可以试着开发一个,会很棒的
 		echo.AddMsgID(AppIDString, userid64, data.ID)
+		//懒message_id池
+		echo.AddLazyMessageId(strconv.FormatInt(userid64, 10), data.ID, time.Now())
+		//储存类型
 		echo.AddMsgType(AppIDString, userid64, "group_private")
 		//储存当前群或频道号的类型 私信不需要
 		//idmap.WriteConfigv2(data.ChannelID, "type", "group_private")
@@ -162,6 +165,8 @@ func (p *Processors) ProcessC2CMessage(data *dto.WSC2CMessageData) error {
 		//为不支持双向echo的ob服务端映射
 		echo.AddMsgID(AppIDString, userid64, data.ID)
 		echo.AddMsgType(AppIDString, userid64, "group_private")
+		//懒message_id池
+		echo.AddLazyMessageId(strconv.FormatInt(userid64, 10), data.ID, time.Now())
 
 		//调试
 		PrintStructWithFieldNames(groupMsg)

Processor/ProcessChannelDirectMessage.go

@@ -98,6 +98,8 @@ func (p *Processors) ProcessChannelDirectMessage(data *dto.WSDirectMessageData)
 		//其实不需要用AppIDString,因为gensokyo是单机器人框架
 		echo.AddMsgID(AppIDString, userid64, data.ID)
 		echo.AddMsgType(AppIDString, userid64, "guild_private")
+		//懒message_id池
+		echo.AddLazyMessageId(strconv.FormatInt(userid64, 10), data.ID, time.Now())
 
 		// 调试
 		PrintStructWithFieldNames(privateMsg)
@@ -182,6 +184,8 @@ func (p *Processors) ProcessChannelDirectMessage(data *dto.WSDirectMessageData)
 			//储存当前群或频道号的类型
 			idmap.WriteConfigv2(data.ChannelID, "type", "guild_private")
 			//todo 完善频道类型信息转换
+			//懒message_id池
+			echo.AddLazyMessageId(strconv.FormatInt(userid64, 10), data.ID, time.Now())
 
 			//调试
 			PrintStructWithFieldNames(onebotMsg)
@@ -273,6 +277,8 @@ func (p *Processors) ProcessChannelDirectMessage(data *dto.WSDirectMessageData)
 			//储存当前群或频道号的类型
 			idmap.WriteConfigv2(fmt.Sprint(ChannelID64), "type", "guild_private")
 			echo.AddMsgType(AppIDString, ChannelID64, "guild_private")
+			//懒message_id池
+			echo.AddLazyMessageId(strconv.FormatInt(userid64, 10), data.ID, time.Now())
 
 			//调试
 			PrintStructWithFieldNames(groupMsg)

Processor/ProcessGroupMessage.go

@@ -102,6 +102,8 @@ func (p *Processors) ProcessGroupMessage(data *dto.WSGroupATMessageData) error {
 	//储存当前群或频道号的类型
 	idmap.WriteConfigv2(fmt.Sprint(GroupID64), "type", "group")
 	echo.AddMsgType(AppIDString, GroupID64, "group")
+	//懒message_id池
+	echo.AddLazyMessageId(strconv.FormatInt(GroupID64, 10), data.ID, time.Now())
 	// 调试
 	PrintStructWithFieldNames(groupMsg)
 

Processor/ProcessGuildATMessage.go

@@ -92,6 +92,8 @@ func (p *Processors) ProcessGuildATMessage(data *dto.WSATMessageData) error {
 		//储存当前群或频道号的类型
 		idmap.WriteConfigv2(data.ChannelID, "type", "guild")
 		//todo 完善频道转换
+		//懒message_id池
+		echo.AddLazyMessageId(data.ChannelID, data.ID, time.Now())
 
 		//调试
 		PrintStructWithFieldNames(onebotMsg)
@@ -187,6 +189,8 @@ func (p *Processors) ProcessGuildATMessage(data *dto.WSATMessageData) error {
 		//储存当前群或频道号的类型
 		idmap.WriteConfigv2(fmt.Sprint(ChannelID64), "type", "guild")
 		echo.AddMsgType(AppIDString, ChannelID64, "guild")
+		//懒message_id池
+		echo.AddLazyMessageId(strconv.FormatInt(ChannelID64, 10), data.ID, time.Now())
 
 		//调试
 		PrintStructWithFieldNames(groupMsg)

Processor/ProcessGuildNormalMessage.go

@@ -94,6 +94,8 @@ func (p *Processors) ProcessGuildNormalMessage(data *dto.WSMessageData) error {
 		//储存当前群或频道号的类型
 		idmap.WriteConfigv2(data.ChannelID, "type", "guild")
 		//todo 完善频道ob信息
+		//懒message_id池
+		echo.AddLazyMessageId(data.ChannelID, data.ID, time.Now())
 
 		//调试
 		PrintStructWithFieldNames(onebotMsg)
@@ -189,6 +191,8 @@ func (p *Processors) ProcessGuildNormalMessage(data *dto.WSMessageData) error {
 		//储存当前群或频道号的类型
 		idmap.WriteConfigv2(fmt.Sprint(ChannelID64), "type", "guild")
 		echo.AddMsgType(AppIDString, ChannelID64, "guild")
+		//懒message_id池
+		echo.AddLazyMessageId(strconv.FormatInt(ChannelID64, 10), data.ID, time.Now())
 
 		//调试
 		PrintStructWithFieldNames(groupMsg)

Processor/Processor.go

@@ -49,7 +49,7 @@ type OnebotChannelMessage struct {
 	Avatar      string      `json:"avatar"`
 	UserID      int64       `json:"user_id"`
 	RawMessage  string      `json:"raw_message"`
-	Echo        string      `json:"echo"`
+	Echo        string      `json:"echo,omitempty"`
 }
 
 // 群信息事件
@@ -64,7 +64,7 @@ type OnebotGroupMessage struct {
 	SubType     string      `json:"sub_type"`
 	Time        int64       `json:"time"`
 	Avatar      string      `json:"avatar"`
-	Echo        string      `json:"echo"`
+	Echo        string      `json:"echo,omitempty"`
 	Message     interface{} `json:"message"` // For array format
 	MessageSeq  int         `json:"message_seq"`
 	Font        int         `json:"font"`
@@ -82,7 +82,7 @@ type OnebotPrivateMessage struct {
 	SubType     string        `json:"sub_type"`
 	Time        int64         `json:"time"`
 	Avatar      string        `json:"avatar"`
-	Echo        string        `json:"echo"`
+	Echo        string        `json:"echo,omitempty"`
 	Message     interface{}   `json:"message"`     // For array format
 	MessageSeq  int           `json:"message_seq"` // Optional field
 	Font        int           `json:"font"`        // Optional field

config/config.go

@@ -58,6 +58,7 @@ type Settings struct {
 	Title                  string   `yaml:"title"`
 	HashID                 bool     `yaml:"hash_id"`
 	TwoWayEcho             bool     `yaml:"twoway_echo"`
+	LazyMessageId          bool     `yaml:"lazy_message_id"`
 }
 
 // LoadConfig 从文件中加载配置并初始化单例配置
@@ -403,6 +404,18 @@ func GetTwoWayEcho() bool {
 	return instance.Settings.TwoWayEcho
 }
 
+// 获取LazyMessageId状态
+func GetLazyMessageId() bool {
+	mu.Lock()
+	defer mu.Unlock()
+
+	if instance == nil {
+		mylog.Println("Warning: instance is nil when trying to get LazyMessageId value.")
+		return false
+	}
+	return instance.Settings.LazyMessageId
+}
+
 // 获取HashID
 func GetHashIDValue() bool {
 	mu.Lock()

echo/messageidmap.go

@@ -0,0 +1,61 @@
+package echo
+
+import (
+	"math/rand"
+	"sync"
+	"time"
+)
+
+type messageRecord struct {
+	messageID string
+	timestamp time.Time
+}
+
+type messageStore struct {
+	mu      sync.RWMutex
+	records map[string][]messageRecord
+}
+
+var instance *messageStore
+var once sync.Once
+
+// 惰性初始化
+func initInstance() *messageStore {
+	once.Do(func() {
+		instance = &messageStore{
+			records: make(map[string][]messageRecord),
+		}
+	})
+	return instance
+}
+
+// AddLazyMessageId 添加 message_id 和它的时间戳到指定群号
+func AddLazyMessageId(groupID, messageID string, timestamp time.Time) {
+	store := initInstance()
+	store.mu.Lock()
+	defer store.mu.Unlock()
+	store.records[groupID] = append(store.records[groupID], messageRecord{messageID: messageID, timestamp: timestamp})
+}
+
+// GetRecentMessages 获取指定群号中最近5分钟内的 message_id
+func GetLazyMessagesId(groupID string) string {
+	store := initInstance()
+	store.mu.RLock()
+	defer store.mu.RUnlock()
+
+	fiveMinutesAgo := time.Now().Add(-5 * time.Minute)
+	var recentMessages []string
+	for _, record := range store.records[groupID] {
+		if record.timestamp.After(fiveMinutesAgo) {
+			recentMessages = append(recentMessages, record.messageID)
+		}
+	}
+	var randomMessageID string
+	if len(recentMessages) > 0 {
+		randomIndex := rand.Intn(len(recentMessages))
+		randomMessageID = recentMessages[randomIndex]
+	} else {
+		randomMessageID = ""
+	}
+	return randomMessageID
+}

handlers/get_login_info.go

@@ -54,6 +54,4 @@ func getLoginInfo(client callapi.Client, api openapi.OpenAPI, apiv2 openapi.Open
 	} else {
 		mylog.Printf("响应get_login_info: %+v", outputMap)
 	}
-
-	return
 }

handlers/mark_msg_as_read.go

@@ -0,0 +1,45 @@
+package handlers
+
+import (
+	"github.com/hoshinonyaruko/gensokyo/callapi"
+	"github.com/hoshinonyaruko/gensokyo/mylog"
+	"github.com/tencent-connect/botgo/openapi"
+	"github.com/tidwall/gjson"
+)
+
+type MarkThisMessageAsReadAPIResponse struct {
+	Status  string       `json:"status"`
+	Data    gjson.Result `json:"data"`
+	Msg     string       `json:"msg"`
+	Wording string       `json:"wording"`
+	RetCode int64        `json:"retcode"`
+	Echo    interface{}  `json:"echo"`
+}
+
+func init() {
+	callapi.RegisterHandler("mark_msg_as_read", MarkThisMessageAsRead)
+}
+
+func MarkThisMessageAsRead(client callapi.Client, api openapi.OpenAPI, apiv2 openapi.OpenAPI, message callapi.ActionMessage) {
+
+	var response MarkThisMessageAsReadAPIResponse
+
+	response.Data.Str = "123"
+	response.Msg = "123"
+	response.RetCode = 0
+	response.Status = "ok"
+	response.Echo = message.Echo
+
+	// Convert the members slice to a map
+	outputMap := structToMap(response)
+
+	mylog.Printf("mark_msg_as_read: %+v\n", outputMap)
+
+	err := client.SendMessage(outputMap)
+	if err != nil {
+		mylog.Printf("Error sending message via client: %v", err)
+	} else {
+		mylog.Printf("响应mark_msg_as_read: %+v", outputMap)
+	}
+
+}

handlers/send_group_msg.go

@@ -46,9 +46,16 @@ func handleSendGroupMsg(client callapi.Client, api openapi.OpenAPI, apiv2 openap
 
 		// 使用 echo 获取消息ID
 		var messageID string
-		if echoStr, ok := message.Echo.(string); ok {
-			messageID = echo.GetMsgIDByKey(echoStr)
-			mylog.Println("echo取群组发信息对应的message_id:", messageID)
+		if config.GetLazyMessageId() {
+			//由于实现了Params的自定义unmarshell 所以可以类型安全的断言为string
+			messageID = echo.GetLazyMessagesId(message.Params.GroupID.(string))
+			mylog.Printf("GetLazyMessagesId: %v", messageID)
+		}
+		if messageID == "" {
+			if echoStr, ok := message.Echo.(string); ok {
+				messageID = echo.GetMsgIDByKey(echoStr)
+				mylog.Println("echo取群组发信息对应的message_id:", messageID)
+			}
 		}
 		//通过bolt数据库还原真实的GroupID
 		originalGroupID, err := idmap.RetrieveRowByIDv2(message.Params.GroupID.(string))

handlers/send_guild_channel_msg.go

@@ -54,9 +54,16 @@ func handleSendGuildChannelMsg(client callapi.Client, api openapi.OpenAPI, apiv2
 		//mylog.Printf("发送文本信息失败: %v,%v", channelID, channelID)
 		// 使用 echo 获取消息ID
 		var messageID string
-		if echoStr, ok := message.Echo.(string); ok {
-			messageID = echo.GetMsgIDByKey(echoStr)
-			mylog.Println("echo取频道发信息对应的message_id:", messageID)
+		if config.GetLazyMessageId() {
+			//由于实现了Params的自定义unmarshell 所以可以类型安全的断言为string
+			messageID = echo.GetLazyMessagesId(channelID)
+			mylog.Printf("GetLazyMessagesId: %v", messageID)
+		}
+		if messageID == "" {
+			if echoStr, ok := message.Echo.(string); ok {
+				messageID = echo.GetMsgIDByKey(echoStr)
+				mylog.Println("echo取频道发信息对应的message_id:", messageID)
+			}
 		}
 		// 如果messageID为空，通过函数获取
 		if messageID == "" {

handlers/send_msg.go

@@ -47,12 +47,19 @@ func handleSendMsg(client callapi.Client, api openapi.OpenAPI, apiv2 openapi.Ope
 	case "group":
 		// 解析消息内容
 		messageText, foundItems := parseMessageContent(message.Params)
-
 		// 使用 echo 获取消息ID
 		var messageID string
-		if echoStr, ok := message.Echo.(string); ok {
-			messageID = echo.GetMsgIDByKey(echoStr)
-			mylog.Println("echo取群组发信息对应的message_id:", messageID)
+		if config.GetLazyMessageId() {
+			//由于实现了Params的自定义unmarshell 所以可以类型安全的断言为string
+			messageID = echo.GetLazyMessagesId(message.Params.GroupID.(string))
+			mylog.Printf("GetLazyMessagesId: %v", messageID)
+		}
+		//判断是否使用了懒messageid,如果没有,优先从echo获取messageid
+		if messageID == "" {
+			if echoStr, ok := message.Echo.(string); ok {
+				messageID = echo.GetMsgIDByKey(echoStr)
+				mylog.Println("echo取群组发信息对应的message_id:", messageID)
+			}
 		}
 		mylog.Println("群组发信息messageText:", messageText)
 		//通过bolt数据库还原真实的GroupID
@@ -159,9 +166,16 @@ func handleSendMsg(client callapi.Client, api openapi.OpenAPI, apiv2 openapi.Ope
 
 		// 使用 echo 获取消息ID
 		var messageID string
-		if echoStr, ok := message.Echo.(string); ok {
-			messageID = echo.GetMsgIDByKey(echoStr)
-			mylog.Println("echo取私聊发信息对应的message_id:", messageID)
+		if config.GetLazyMessageId() {
+			//由于实现了Params的自定义unmarshell 所以可以类型安全的断言为string
+			messageID = echo.GetLazyMessagesId(UserID)
+			mylog.Printf("GetLazyMessagesId: %v", messageID)
+		}
+		if messageID == "" {
+			if echoStr, ok := message.Echo.(string); ok {
+				messageID = echo.GetMsgIDByKey(echoStr)
+				mylog.Println("echo取私聊发信息对应的message_id:", messageID)
+			}
 		}
 		// 如果messageID为空，通过函数获取
 		if messageID == "" {

handlers/send_private_msg.go

@@ -58,9 +58,16 @@ func handleSendPrivateMsg(client callapi.Client, api openapi.OpenAPI, apiv2 open
 
 		// 使用 echo 获取消息ID
 		var messageID string
-		if echoStr, ok := message.Echo.(string); ok {
-			messageID = echo.GetMsgIDByKey(echoStr)
-			mylog.Println("echo取私聊发信息对应的message_id:", messageID)
+		if config.GetLazyMessageId() {
+			//由于实现了Params的自定义unmarshell 所以可以类型安全的断言为string
+			messageID = echo.GetLazyMessagesId(UserID)
+			mylog.Printf("GetLazyMessagesId: %v", messageID)
+		}
+		if messageID == "" {
+			if echoStr, ok := message.Echo.(string); ok {
+				messageID = echo.GetMsgIDByKey(echoStr)
+				mylog.Println("echo取私聊发信息对应的message_id:", messageID)
+			}
 		}
 		// 如果messageID仍然为空，尝试使用config.GetAppID和UserID的组合来获取messageID
 		// 如果messageID为空，通过函数获取
@@ -175,9 +182,16 @@ func handleSendGuildChannelPrivateMsg(client callapi.Client, api openapi.OpenAPI
 
 	// 使用 echo 获取消息ID
 	var messageID string
-	if echoStr, ok := message.Echo.(string); ok {
-		messageID = echo.GetMsgIDByKey(echoStr)
-		mylog.Println("echo取私聊发信息对应的message_id:", messageID)
+	if config.GetLazyMessageId() {
+		//由于实现了Params的自定义unmarshell 所以可以类型安全的断言为string
+		messageID = echo.GetLazyMessagesId(message.Params.UserID.(string))
+		mylog.Printf("GetLazyMessagesId: %v", messageID)
+	}
+	if messageID == "" {
+		if echoStr, ok := message.Echo.(string); ok {
+			messageID = echo.GetMsgIDByKey(echoStr)
+			mylog.Println("echo取私聊发信息对应的message_id:", messageID)
+		}
 	}
 	mylog.Println("私聊信息messageText:", messageText)
 	//mylog.Println("foundItems:", foundItems)

handlers/set_group_whole_ban.go

@@ -11,7 +11,7 @@ import (
 )
 
 func init() {
-	callapi.RegisterHandler("get_group_whole_ban", setGroupBan)
+	callapi.RegisterHandler("get_group_whole_ban", setGroupWholeBan)
 }
 
 func setGroupWholeBan(client callapi.Client, api openapi.OpenAPI, apiv2 openapi.OpenAPI, message callapi.ActionMessage) {