🎉 first commit

handler/parse.go

@@ -0,0 +1,54 @@
+package handler
+
+import (
+	"encoding/json"
+	"go-wechat/entity"
+	"go-wechat/model"
+	"go-wechat/service"
+	"go-wechat/types"
+	"log"
+	"net"
+	"strings"
+	"time"
+)
+
+// Parse
+// @description: 解析消息
+// @param msg
+func Parse(remoteAddr net.Addr, msg []byte) {
+	var m model.Message
+	if err := json.Unmarshal(msg, &m); err != nil {
+		log.Printf("[%s]消息解析失败： %v", remoteAddr, err)
+		log.Printf("[%s]消息内容： %d -> %v", remoteAddr, len(msg), string(msg))
+		return
+	}
+	// 提取出群成员信息
+	groupUser := ""
+	msgStr := m.Content
+	if strings.Contains(m.FromUser, "@") {
+		// 系统消息不单独处理
+		if m.Type != types.MsgTypeRecalled && m.Type != types.MsgTypeSys {
+			groupUser = strings.Split(m.Content, "\n")[0]
+			groupUser = strings.ReplaceAll(groupUser, ":", "")
+
+			// 文字消息单独提出来处理一下
+			msgStr = strings.Join(strings.Split(m.Content, "\n")[1:], "\n")
+		}
+	}
+	log.Printf("%s\n消息来源: %s\n群成员: %s\n消息类型: %v\n消息内容: %s", remoteAddr, m.FromUser, groupUser, m.Type, msgStr)
+
+	// 转换为结构体之后入库
+	var ent entity.Message
+	ent.MsgId = m.MsgId
+	ent.CreateTime = m.CreateTime
+	ent.CreateAt = time.Unix(int64(m.CreateTime), 0)
+	ent.Content = msgStr
+	ent.FromUser = m.FromUser
+	ent.GroupUser = groupUser
+	ent.ToUser = m.ToUser
+	ent.Type = m.Type
+	ent.DisplayFullContent = m.DisplayFullContent
+	ent.Raw = string(msg)
+
+	go service.SaveMessage(ent)
+}