websotckty

controllers/event_controller.go

@@ -149,9 +149,9 @@ func handleMessages() {
 		globals.SugarLogger.Debugf("clients len %v", len(clients))
 		//循环map客户端
 		for groupID, mmsg := range msg {
-			for _, client := range clients[groupID] {
+			for userID, client := range clients[groupID] {
 				//把通道中的消息发送给客户端
-				user, err := dao.GetUser(dao.GetDB(), mmsg.UserID)
+				user, err := dao.GetUser(dao.GetDB(), userID)
 				if err == nil {
 					mmsg.UserInfo = user
 				}
@@ -160,7 +160,7 @@ func handleMessages() {
 				if err != nil {
 					globals.SugarLogger.Debugf("client.WriteJSON error: %v", err)
 					client.Close() //关闭
-					delete(clients[mmsg.GroupID], mmsg.UserID)
+					delete(clients[mmsg.GroupID], userID)
 					// delete(clients, client) //删除map中的客户端
 				}
 			}