a

controllers/event_controller.go

@@ -107,6 +107,7 @@ func (c *EventController) TestWebsocket() {
 			for k, _ := range clients {
 				delete(clients[k], userID)
 			}
+			delete(clientsHeart, userID)
 			// delete(clients, ws) //删除map中的客户端
 			break //结束循环
 		} else {
@@ -126,9 +127,9 @@ func (c *EventController) TestWebsocket() {
 			//如果这些人不在这个组的ws池子里就打上未读标记
 			for _, v := range userIDs {
 				fmt.Println("222222222222222222222222222222", v)
-				fmt.Println("333333333333333333333333333333", clients[s.GroupID][v])
+				fmt.Println("333333333333333333333333333333", clientsHeart[v] == nil)
 
-				if clients[s.GroupID][v] == nil {
+				if clientsHeart[v] == nil {
 					messageGroupReads, _ := dao.GetMessageGroupRead(db, v, s.GroupID)
 					for _, vv := range messageGroupReads {
 						vv.UnReadCount++