From ac5fe7a2669a029f0a7a1c2b818acd3cf2178449 Mon Sep 17 00:00:00 2001
From: jjxu <428192774@qq.com>
Date: Wed, 18 Jun 2025 11:41:20 +0800
Subject: [PATCH] Update chat.go

---
 pkg/service/asChat/logic/chat.go | 16 +++++++++-------
 1 file changed, 9 insertions(+), 7 deletions(-)

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