a

controllers/event_controller.go

@@ -112,29 +112,28 @@ func (c *EventController) TestWebsocket() {
 		} else {
 			//接受消息 业务逻辑
 			broadcast <- s
+			//发聊天消息时，这个组所有的成员包括创建者都在userIDs里
+			userIDs := []string{}
+			if results, err := dao.GetMessageGroups(db, "", s.GroupID, 0, true, ""); err == nil {
+				for _, v := range results {
+					userIDs = append(userIDs, v.UserID)
+					for _, vv := range v.MessageGroupMembers {
+						userIDs = append(userIDs, vv.UserID)
+					}
+				}
+			}
+			//如果这些人不在这个组的ws池子里就打上未读标记
+			for _, v := range userIDs {
+				if clients[s.GroupID][v] == nil {
+					messageGroupReads, _ := dao.GetMessageGroupRead(db, v, s.GroupID)
+					for _, vv := range messageGroupReads {
+						vv.UnReadCount++
+						dao.UpdateEntity(db, vv, "UnReadCount")
+					}
+				}
+			}
 			utils.CallFuncAsync(func() {
 				if s.GroupID != 0 {
-					//发聊天消息时，这个组所有的成员包括创建者都在userIDs里
-					userIDs := []string{}
-					if results, err := dao.GetMessageGroups(db, "", s.GroupID, 0, true, ""); err == nil {
-						for _, v := range results {
-							userIDs = append(userIDs, v.UserID)
-							for _, vv := range v.MessageGroupMembers {
-								userIDs = append(userIDs, vv.UserID)
-							}
-						}
-					}
-					//如果这些人不在这个组的ws池子里就打上未读标记
-					for _, v := range userIDs {
-						fmt.Println("11111111111111111111111111111111111", utils.Format4Output(clients[s.GroupID][v], false))
-						if clients[s.GroupID][v] == nil {
-							messageGroupReads, _ := dao.GetMessageGroupRead(db, v, s.GroupID)
-							for _, vv := range messageGroupReads {
-								vv.UnReadCount++
-								dao.UpdateEntity(db, vv, "UnReadCount")
-							}
-						}
-					}
 					dao.WrapAddIDCULDEntity(s, "")
 					dao.CreateEntity(db, s)
 				}