From 61e03a6a7b0ce2fe5cd7100cdae9e95951fb8813 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E6=9D=8E=E5=AF=BB=E6=AC=A2?= Date: Thu, 25 Jan 2024 16:27:12 +0800 Subject: [PATCH] =?UTF-8?q?:art:=20=E9=80=BB=E8=BE=91=E4=BC=98=E5=8C=96?= =?UTF-8?q?=EF=BC=8C=E9=82=A3=E4=B8=AA=E7=BD=91=E9=A1=B5=EF=BC=8C=E5=A4=A7?= =?UTF-8?q?=E5=A4=A7=E5=9C=B0=E6=8F=90=E9=80=9F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- entity/friend.go | 23 +++++++++++++---------- service/friend.go | 34 ++++++++++++++++++++++++++++++---- service/group.go | 7 +++---- service/message.go | 6 ++++++ views/index.html | 8 ++++---- views/static/js/index.js | 5 +++-- vo/friend.go | 22 +++++++++++----------- 7 files changed, 70 insertions(+), 35 deletions(-) diff --git a/entity/friend.go b/entity/friend.go index 69d4b6c..8012c27 100644 --- a/entity/friend.go +++ b/entity/friend.go @@ -1,22 +1,24 @@ package entity import ( + "go-wechat/common/types" "time" ) // Friend // @description: 好友列表 type Friend struct { - Wxid string `json:"wxid"` // 微信原始Id - CustomAccount string `json:"customAccount"` // 微信号 - Nickname string `json:"nickname"` // 昵称 - Pinyin string `json:"pinyin"` // 昵称拼音大写首字母 - PinyinAll string `json:"pinyinAll"` // 昵称全拼 - EnableAi bool `json:"enableAI" gorm:"type:tinyint(1) default 0 not null"` // 是否使用AI - AiModel string `json:"aiModel"` // AI模型 - EnableChatRank bool `json:"enableChatRank" gorm:"type:tinyint(1) default 0 not null"` // 是否使用聊天排行 - EnableWelcome bool `json:"enableWelcome" gorm:"type:tinyint(1) default 0 not null"` // 是否启用迎新 - IsOk bool `json:"isOk" gorm:"type:tinyint(1) default 0 not null"` // 是否正常 + Wxid string `json:"wxid"` // 微信原始Id + CustomAccount string `json:"customAccount"` // 微信号 + Nickname string `json:"nickname"` // 昵称 + Pinyin string `json:"pinyin"` // 昵称拼音大写首字母 + PinyinAll string `json:"pinyinAll"` // 昵称全拼 + LastActive types.DateTime `json:"lastActive"` // 最后活跃时间 + EnableAi bool `json:"enableAI" gorm:"type:tinyint(1) default 0 not null"` // 是否使用AI + AiModel string `json:"aiModel"` // AI模型 + EnableChatRank bool `json:"enableChatRank" gorm:"type:tinyint(1) default 0 not null"` // 是否使用聊天排行 + EnableWelcome bool `json:"enableWelcome" gorm:"type:tinyint(1) default 0 not null"` // 是否启用迎新 + IsOk bool `json:"isOk" gorm:"type:tinyint(1) default 0 not null"` // 是否正常 } func (Friend) TableName() string { @@ -34,6 +36,7 @@ type GroupUser struct { IsMember bool `json:"isMember" gorm:"type:tinyint(1) default 0 not null"` // 是否群成员 IsAdmin bool `json:"isAdmin" gorm:"type:tinyint(1) default 0 not null"` // 是否群主 JoinTime time.Time `json:"joinTime"` // 加入时间 + LastActive time.Time `json:"lastActive"` // 最后活跃时间 LeaveTime *time.Time `json:"leaveTime"` // 离开时间 SkipChatRank bool `json:"skipChatRank" gorm:"type:tinyint(1) default 0 not null"` // 是否跳过聊天排行 } diff --git a/service/friend.go b/service/friend.go index ce2b92e..f5e44a4 100644 --- a/service/friend.go +++ b/service/friend.go @@ -4,6 +4,7 @@ import ( "go-wechat/client" "go-wechat/entity" "go-wechat/vo" + "log" "strings" ) @@ -16,10 +17,11 @@ func GetAllFriend() (friends, groups []vo.FriendItem, err error) { var records []vo.FriendItem err = client.MySQL. Table("t_friend AS tf"). - Joins("LEFT JOIN t_message AS tm ON tf.wxid = tm.from_user"). - Select("tf.*", "MAX(tm.create_at) AS last_active_time"). - Group("tf.wxid"). - Order("last_active_time DESC"). + //Joins("LEFT JOIN t_message AS tm ON tf.wxid = tm.from_user"). + //Select("tf.*", "MAX(tm.create_at) AS last_active"). + Select("tf.*"). + //Group("tf.wxid"). + Order("tf.last_active DESC"). Find(&records).Error if err != nil { return @@ -60,3 +62,27 @@ func CheckIsEnableCommand(userId string) (flag bool) { client.MySQL.Model(&entity.Friend{}).Where("enable_command = 1").Where("wxid = ?", userId).Count(&coo) return coo > 0 } + +// updateLastActive +// @description: 更新最后活跃时间 +// @param msg +func updateLastActive(msg entity.Message) { + var err error + // 如果是群，更新群成员最后活跃时间 + if strings.HasSuffix(msg.FromUser, "@chatroom") { + err = client.MySQL.Model(&entity.GroupUser{}). + Where("group_id = ?", msg.FromUser). + Where("wxid = ?", msg.GroupUser). + Update("last_active", msg.CreateTime).Error + if err != nil { + log.Printf("更新群成员最后活跃时间失败, 错误信息: %v", err) + } + } + // 更新群或者好友活跃时间 + err = client.MySQL.Model(&entity.Friend{}). + Where("wxid = ?", msg.FromUser). + Update("last_active", msg.CreateTime).Error + if err != nil { + log.Printf("更新群或者好友活跃时间失败, 错误信息: %v", err) + } +} diff --git a/service/group.go b/service/group.go index 85c3187..1475497 100644 --- a/service/group.go +++ b/service/group.go @@ -13,10 +13,9 @@ import ( func GetGroupUsersByGroupId(groupId string) (records []vo.GroupUserItem, err error) { err = client.MySQL. Table("t_group_user AS tgu"). - Joins("LEFT JOIN t_message AS tm ON tm.from_user = tgu.group_id AND tm.group_user = tgu.wxid"). - //Select("tgu.wxid", "tgu.nickname", "tgu.head_image", "tgu.is_member", "tgu.leave_time", - // "tgu.skip_chat_rank", "MAX(tm.create_at) AS last_active_time"). - Select("tgu.*", "MAX(tm.create_at) AS last_active_time"). + //Joins("LEFT JOIN t_message AS tm ON tm.from_user = tgu.group_id AND tm.group_user = tgu.wxid"). + //Select("tgu.*", "MAX(tm.create_at) AS last_active"). + Select("tgu.*"). Where("tgu.group_id = ?", groupId). Group("tgu.group_id, tgu.wxid"). Order("tgu.join_time DESC"). diff --git a/service/message.go b/service/message.go index 18c2a0b..2e0c9cf 100644 --- a/service/message.go +++ b/service/message.go @@ -32,4 +32,10 @@ func SaveMessage(msg entity.Message) { log.Printf("消息入库失败, 错误信息: %v", err) } log.Printf("消息入库成功，消息Id: %d", msg.MsgId) + + // 更新最后活跃时间 + // 只处理收到的消息 + if msg.MsgId > 1 { + go updateLastActive(msg) + } } diff --git a/views/index.html b/views/index.html index 1339217..c197d94 100644 --- a/views/index.html +++ b/views/index.html @@ -47,10 +47,10 @@ {{ .CustomAccount }} {{ .Nickname }} - {{ if eq .LastActiveTime.IsNil true }} + {{ if eq .LastActive.IsNil true }} 无数据 {{ else }} - {{ .LastActiveTime }} + {{ .LastActive }} {{ end }} @@ -110,10 +110,10 @@ {{ .Wxid }} {{ .Nickname }} - {{ if eq .LastActiveTime.IsNil true }} + {{ if eq .LastActive.IsNil true }} 无数据 {{ else }} - {{ .LastActiveTime }} + {{ .LastActive }} {{ end }} diff --git a/views/static/js/index.js b/views/static/js/index.js index c01a214..200c819 100644 --- a/views/static/js/index.js +++ b/views/static/js/index.js @@ -113,7 +113,8 @@ function getGroupUsers(groupId, groupName) { const groupUsers = response.data // 循环渲染数据 groupUsers.forEach((groupUser, i) => { - const { wxid, nickname, isMember, isAdmin, joinTime, lastActiveTime, leaveTime, skipChatRank } = groupUser; + console.log(groupUser) + const { wxid, nickname, isMember, isAdmin, joinTime, lastActive, leaveTime, skipChatRank } = groupUser; let row = tbody.insertRow(i); // Insert data into cells @@ -122,7 +123,7 @@ function getGroupUsers(groupId, groupName) { row.insertCell(2).innerHTML = `
${isMember ? '是' : '否'}
`; row.insertCell(3).innerHTML = `
${isAdmin ? '是' : '否'}
`; row.insertCell(4).innerHTML = joinTime; - row.insertCell(5).innerHTML = lastActiveTime; + row.insertCell(5).innerHTML = lastActive; row.insertCell(6).innerHTML = leaveTime; row.insertCell(7).innerHTML = ``; }); diff --git a/vo/friend.go b/vo/friend.go index 874d368..335a526 100644 --- a/vo/friend.go +++ b/vo/friend.go @@ -12,26 +12,26 @@ type FriendItem struct { Pinyin string // 昵称拼音大写首字母 PinyinAll string // 昵称全拼 Wxid string // 微信原始Id + LastActive types.DateTime // 最后活跃时间 EnableAi bool // 是否使用AI AiModel string // AI模型 EnableChatRank bool // 是否使用聊天排行 EnableWelcome bool // 是否使用迎新 EnableCommand bool // 是否启用指令 IsOk bool // 是否还在通讯库(群聊是要还在群里也算) - LastActiveTime types.DateTime // 最后活跃时间 } // GroupUserItem // @description: 群成员列表数据 type GroupUserItem struct { - Wxid string `json:"wxid"` // 微信Id - Account string `json:"account"` // 账号 - HeadImage string `json:"headImage"` // 头像 - Nickname string `json:"nickname"` // 昵称 - IsMember bool `json:"isMember" ` // 是否群成员 - IsAdmin bool `json:"isAdmin"` // 是否群主 - JoinTime types.DateTime `json:"joinTime"` // 加入时间 - LastActiveTime types.DateTime `json:"lastActiveTime"` // 最后活跃时间 - LeaveTime types.DateTime `json:"leaveTime"` // 离开时间 - SkipChatRank bool `json:"skipChatRank" ` // 是否跳过聊天排行 + Wxid string `json:"wxid"` // 微信Id + Account string `json:"account"` // 账号 + HeadImage string `json:"headImage"` // 头像 + Nickname string `json:"nickname"` // 昵称 + IsMember bool `json:"isMember" ` // 是否群成员 + IsAdmin bool `json:"isAdmin"` // 是否群主 + JoinTime types.DateTime `json:"joinTime"` // 加入时间 + LastActive types.DateTime `json:"lastActive"` // 最后活跃时间 + LeaveTime types.DateTime `json:"leaveTime"` // 离开时间 + SkipChatRank bool `json:"skipChatRank" ` // 是否跳过聊天排行 }