fiee/fonchain-fiee
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update chat.go

Browse Source
This commit is contained in:
徐俊杰 2025-06-18 11:41:20 +08:00
parent 7b76dd5142
commit ac5fe7a266
1 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
pkg/service/asChat/logic/chat.go
View File

@ -65,13 +65,15 @@ func NewMessage(ctx context.Context, cache *chatCache.ChatCache, sender *account
return errors.New("消息发送失败") return errors.New("消息发送失败")
} }
fmt.Println("NewMessage 5 消息数量+1") fmt.Println("NewMessage 5 消息数量+1")
//新消息数量统计+1 if sender.Role != 3 {
noticeUserId := consts.ChatRoom.GetUserIdInSession(request.SessionId, sender.ID) //新消息数量统计+1
fmt.Println("NewMessage 5.1 消息数量配置结束") noticeUserId := consts.ChatRoom.GetUserIdInSession(request.SessionId, sender.ID)
fmt.Printf("noticeUserId %+v\n", noticeUserId) fmt.Println("NewMessage 5.1 消息数量配置结束")
for _, userId := range noticeUserId { fmt.Printf("noticeUserId %+v\n", noticeUserId)
fmt.Println("userId") for _, userId := range noticeUserId {
cache.IncreaseNewMessageTotal(userId, request.SessionId) fmt.Println("userId")
_ = cache.IncreaseNewMessageTotal(userId, request.SessionId)
}
} }
fmt.Println("NewMessage 6") fmt.Println("NewMessage 6")
//发送websocket消息提醒通知 //发送websocket消息提醒通知