Test4

Processor/ProcessGroupMessage.go

@@ -42,7 +42,6 @@ func (p *Processors) ProcessGroupMessage(data *dto.WSGroupATMessageData) error {
 		mylog.Printf("Error storing ID: %v", err)
 		return nil
 	}
-
 	//映射str的messageID到int
 	messageID64, err := idmap.StoreIDv2(data.ID)
 	if err != nil {
@@ -100,7 +99,6 @@ func (p *Processors) ProcessGroupMessage(data *dto.WSGroupATMessageData) error {
 	//储存当前群或频道号的类型
 	idmap.WriteConfigv2(fmt.Sprint(GroupID64), "type", "group")
 	echo.AddMsgType(AppIDString, GroupID64, "group")
-
 	// 调试
 	PrintStructWithFieldNames(groupMsg)
 

config/config.go

@@ -46,6 +46,7 @@ type Settings struct {
 	DeveloperLog           bool     `yaml:"developer_log"`
 	Username               string   `yaml:"server_user_name"`
 	Password               string   `yaml:"server_user_password"`
+	ImageLimit             int      `yaml:"image_sizelimit"`
 }
 
 // LoadConfig 从文件中加载配置并初始化单例配置
@@ -367,3 +368,16 @@ func GetServerUserPassword() string {
 	}
 	return instance.Settings.Password
 }
+
+// GetImageLimit 返回 ImageLimit 的值
+func GetImageLimit() int {
+	mu.Lock()
+	defer mu.Unlock()
+
+	if instance == nil {
+		mylog.Println("Warning: instance is nil when trying to get image limit value.")
+		return 0 // 或者返回一个默认的 ImageLimit 值
+	}
+
+	return instance.Settings.ImageLimit
+}

go.mod

@@ -15,6 +15,7 @@ require (
 	github.com/google/uuid v1.4.0 // indirect
 	github.com/mattn/go-colorable v0.1.13 // indirect
 	github.com/mvdan/xurls v1.1.0 // indirect
+	github.com/nfnt/resize v0.0.0-20180221191011-83c6a9932646 // indirect
 )
 
 replace github.com/tencent-connect/botgo => ./botgo

go.sum

@@ -84,6 +84,8 @@ github.com/modern-go/reflect2 v1.0.2 h1:xBagoLtFs94CBntxluKeaWgTMpvLxC4ur3nMaC9G
 github.com/modern-go/reflect2 v1.0.2/go.mod h1:yWuevngMOJpCy52FWWMvUC8ws7m/LJsjYzDa0/r8luk=
 github.com/mvdan/xurls v1.1.0 h1:OpuDelGQ1R1ueQ6sSryzi6P+1RtBpfQHM8fJwlE45ww=
 github.com/mvdan/xurls v1.1.0/go.mod h1:tQlNn3BED8bE/15hnSL2HLkDeLWpNPAwtw7wkEq44oU=
+github.com/nfnt/resize v0.0.0-20180221191011-83c6a9932646 h1:zYyBkD/k9seD2A7fsi6Oo2LfFZAehjjQMERAvZLEDnQ=
+github.com/nfnt/resize v0.0.0-20180221191011-83c6a9932646/go.mod h1:jpp1/29i3P1S/RLdc7JQKbRpFeM1dOBd8T9ki5s+AY8=
 github.com/nxadm/tail v1.4.4/go.mod h1:kenIhsEOeOJmVchQTgglprH7qJGnHDVpk1VPCcaMI8A=
 github.com/nxadm/tail v1.4.8/go.mod h1:+ncqLTQzXmGhMZNUePPaPqPvBxHAIsmXswZKocGu+AU=
 github.com/onsi/ginkgo v1.6.0/go.mod h1:lLunBs/Ym6LB5Z9jYTR76FiuTmxDTDusOGeTQH+WWjE=

handlers/get_group_member_info.go

@@ -0,0 +1,98 @@
+package handlers
+
+import (
+	"github.com/hoshinonyaruko/gensokyo/callapi"
+	"github.com/hoshinonyaruko/gensokyo/mylog"
+	"github.com/tencent-connect/botgo/openapi"
+)
+
+// 初始化handler，在程序启动时会被调用
+func init() {
+	callapi.RegisterHandler("get_group_member_info", getGroupMemberInfo)
+}
+
+// 成员信息的结构定义
+type MemberInfo struct {
+	UserID          int64  `json:"user_id"`
+	GroupID         int64  `json:"group_id"`
+	Nickname        string `json:"nickname"`
+	Card            string `json:"card"`
+	Sex             string `json:"sex"`
+	Age             int32  `json:"age"`
+	Area            string `json:"area"`
+	JoinTime        int32  `json:"join_time"`
+	LastSentTime    int32  `json:"last_sent_time"`
+	Level           string `json:"level"`
+	Role            string `json:"role"`
+	Unfriendly      bool   `json:"unfriendly"`
+	Title           string `json:"title"`
+	TitleExpireTime int64  `json:"title_expire_time"`
+	CardChangeable  bool   `json:"card_changeable"`
+	ShutUpTimestamp int64  `json:"shut_up_timestamp"`
+}
+
+// 构建单个成员的响应数据
+func buildResponseForSingleMember(memberInfo *MemberInfo, echoValue interface{}) map[string]interface{} {
+	// 构建成员数据的映射
+	memberMap := map[string]interface{}{
+		"group_id":          memberInfo.GroupID,
+		"user_id":           memberInfo.UserID,
+		"nickname":          memberInfo.Nickname,
+		"card":              memberInfo.Card,
+		"sex":               memberInfo.Sex,
+		"age":               memberInfo.Age,
+		"area":              memberInfo.Area,
+		"join_time":         memberInfo.JoinTime,
+		"last_sent_time":    memberInfo.LastSentTime,
+		"level":             memberInfo.Level,
+		"role":              memberInfo.Role,
+		"unfriendly":        memberInfo.Unfriendly,
+		"title":             memberInfo.Title,
+		"title_expire_time": memberInfo.TitleExpireTime,
+		"card_changeable":   memberInfo.CardChangeable,
+		"shut_up_timestamp": memberInfo.ShutUpTimestamp,
+	}
+
+	// 构建完整的响应映射
+	response := map[string]interface{}{
+		"retcode": 0,
+		"status":  "ok",
+		"data":    memberMap,
+		"echo":    echoValue,
+	}
+
+	return response
+}
+
+// getGroupMemberInfo是处理获取群成员信息的函数
+func getGroupMemberInfo(client callapi.Client, api openapi.OpenAPI, apiv2 openapi.OpenAPI, message callapi.ActionMessage) {
+	// 使用虚拟数据构造 MemberInfo
+	memberInfo := &MemberInfo{
+		UserID:          123456789, // 虚拟的 QQ 号
+		GroupID:         987654321, // 虚拟的群号
+		Nickname:        "主人",      // 虚拟昵称
+		Card:            "主人",
+		Sex:             "unknown", // 性别未知
+		Age:             20,        // 虚拟年龄
+		Area:            "虚拟地区",
+		JoinTime:        1630416000, // 虚拟加群时间戳
+		LastSentTime:    1630502400, // 虚拟最后发言时间戳
+		Level:           "1",        // 虚拟成员等级
+		Role:            "member",   // 角色为普通成员
+		Unfriendly:      false,      // 没有不良记录
+		Title:           "虚拟头衔",
+		TitleExpireTime: 1630598800, // 虚拟头衔过期时间
+		CardChangeable:  true,       // 允许修改群名片
+		ShutUpTimestamp: 0,          // 不在禁言中
+	}
+
+	// 构建响应JSON
+	responseJSON := buildResponseForSingleMember(memberInfo, message.Echo)
+	mylog.Printf("get_group_member_info: %s\n", responseJSON)
+
+	// 发送响应回去
+	err := client.SendMessage(responseJSON)
+	if err != nil {
+		mylog.Printf("发送消息时出错: %v", err)
+	}
+}

handlers/message_parser.go

@@ -4,6 +4,7 @@ import (
 	"path/filepath"
 	"regexp"
 	"runtime"
+	"strconv"
 	"strings"
 
 	"github.com/hoshinonyaruko/gensokyo/callapi"
@@ -160,15 +161,19 @@ func parseMessageContent(paramsMessage callapi.ParamsContent) (string, map[strin
 
 // at处理和链接处理
 func transformMessageText(messageText string) string {
+	// 首先，将AppID替换为BotID
+	messageText = strings.ReplaceAll(messageText, AppID, BotID)
+
 	// 使用正则表达式来查找所有[CQ:at,qq=数字]的模式
 	re := regexp.MustCompile(`\[CQ:at,qq=(\d+)\]`)
 	messageText = re.ReplaceAllStringFunc(messageText, func(m string) string {
 		submatches := re.FindStringSubmatch(m)
 		if len(submatches) > 1 {
 			realUserID, err := idmap.RetrieveRowByIDv2(submatches[1])
 			if err != nil {
+				// 如果出错，也替换成相应的格式，但使用原始QQ号
 				mylog.Printf("Error retrieving user ID: %v", err)
-				return m // 如果出错，返回原始匹配
+				return "<@!" + submatches[1] + ">"
 			}
 			return "<@!" + realUserID + ">"
 		}
@@ -208,11 +213,21 @@ func RevertTransformedText(data interface{}) string {
 
 	// 使用正则表达式来查找所有<@!数字>的模式
 	re := regexp.MustCompile(`<@!(\d+)>`)
-	// 使用正则表达式来替换找到的模式为[CQ:at,qq=数字]
+	// 使用正则表达式来替换找到的模式为[CQ:at,qq=用户ID]
 	messageText = re.ReplaceAllStringFunc(messageText, func(m string) string {
 		submatches := re.FindStringSubmatch(m)
 		if len(submatches) > 1 {
-			return "[CQ:at,qq=" + submatches[1] + "]"
+			//映射用户id
+			userID64, err := idmap.StoreIDv2(submatches[1])
+			if err != nil {
+				//如果储存失败(数据库损坏)返回原始值
+				mylog.Printf("Error storing ID: %v", err)
+				return "[CQ:at,qq=" + submatches[1] + "]"
+			}
+			//类型转换
+			userIDStr := strconv.FormatInt(userID64, 10)
+			//经过转换的cq码
+			return "[CQ:at,qq=" + userIDStr + "]"
 		}
 		return m
 	})

handlers/send_group_msg.go

@@ -158,9 +158,19 @@ func generateGroupMessage(id string, foundItems map[string][]string, messageText
 				MsgType: 0, // 默认文本类型
 			}
 		}
+		// 首先压缩图片 默认不压缩
+		compressedData, err := images.CompressSingleImage(imageData)
+		if err != nil {
+			mylog.Printf("Error compressing image: %v", err)
+			return &dto.MessageToCreate{
+				Content: "错误: 压缩图片失败",
+				MsgID:   id,
+				MsgType: 0, // 默认文本类型
+			}
+		}
 
 		// base64编码
-		base64Encoded := base64.StdEncoding.EncodeToString(imageData)
+		base64Encoded := base64.StdEncoding.EncodeToString(compressedData)
 
 		// 上传base64编码的图片并获取其URL
 		imageURL, err := images.UploadBase64ImageToServer(base64Encoded)
@@ -204,8 +214,18 @@ func generateGroupMessage(id string, foundItems map[string][]string, messageText
 				mylog.Printf("failed to decode base64 image: %v", err)
 				return nil
 			}
+			// 首先压缩图片 默认不压缩
+			compressedData, err := images.CompressSingleImage(fileImageData)
+			if err != nil {
+				mylog.Printf("Error compressing image: %v", err)
+				return &dto.MessageToCreate{
+					Content: "错误: 压缩图片失败",
+					MsgID:   id,
+					MsgType: 0, // 默认文本类型
+				}
+			}
 			// 将解码的图片数据转换回base64格式并上传
-			imageURL, err := images.UploadBase64ImageToServer(base64.StdEncoding.EncodeToString(fileImageData))
+			imageURL, err := images.UploadBase64ImageToServer(base64.StdEncoding.EncodeToString(compressedData))
 			if err != nil {
 				mylog.Printf("failed to upload base64 image: %v", err)
 				return nil

handlers/send_guild_channel_msg.go

@@ -8,6 +8,7 @@ import (
 	"github.com/hoshinonyaruko/gensokyo/callapi"
 	"github.com/hoshinonyaruko/gensokyo/config"
 	"github.com/hoshinonyaruko/gensokyo/idmap"
+	"github.com/hoshinonyaruko/gensokyo/images"
 	"github.com/hoshinonyaruko/gensokyo/mylog"
 
 	"github.com/hoshinonyaruko/gensokyo/echo"
@@ -143,9 +144,18 @@ func generateReplyMessage(id string, foundItems map[string][]string, messageText
 			}
 			return &reply, false
 		}
-
+		// 首先压缩图片
+		compressedData, err := images.CompressSingleImage(imageData)
+		if err != nil {
+			mylog.Printf("Error compressing image: %v", err)
+			return &dto.MessageToCreate{
+				Content: "错误: 压缩图片失败",
+				MsgID:   id,
+				MsgType: 0, // 默认文本类型
+			}, false
+		}
 		//base64编码
-		base64Encoded := base64.StdEncoding.EncodeToString(imageData)
+		base64Encoded := base64.StdEncoding.EncodeToString(compressedData)
 
 		// 当作base64图来处理
 		reply = dto.MessageToCreate{

handlers/send_private_msg.go

@@ -73,7 +73,7 @@ func handleSendPrivateMsg(client callapi.Client, api openapi.OpenAPI, apiv2 open
 
 		// 优先发送文本信息
 		if messageText != "" {
-			groupReply := generatePrivateMessage(messageID, nil, messageText)
+			groupReply := generateGroupMessage(messageID, nil, messageText)
 
 			// 进行类型断言
 			groupMessage, ok := groupReply.(*dto.MessageToCreate)
@@ -96,7 +96,8 @@ func handleSendPrivateMsg(client callapi.Client, api openapi.OpenAPI, apiv2 open
 			var singleItem = make(map[string][]string)
 			singleItem[key] = urls
 
-			groupReply := generatePrivateMessage(messageID, singleItem, "")
+			//先试试用群里一样的处理逻辑,看看能跑不
+			groupReply := generateGroupMessage(messageID, singleItem, "")
 
 			// 进行类型断言
 			richMediaMessage, ok := groupReply.(*dto.RichMediaMessage)
@@ -119,6 +120,7 @@ func handleSendPrivateMsg(client callapi.Client, api openapi.OpenAPI, apiv2 open
 	}
 }
 
+// 这里是只有群私聊会用到
 func generatePrivateMessage(id string, foundItems map[string][]string, messageText string) interface{} {
 	if imageURLs, ok := foundItems["local_image"]; ok && len(imageURLs) > 0 {
 		// 本地发图逻辑 todo 适配base64图片