diff --git a/controllers/event_controller.go b/controllers/event_controller.go index c6a1cfda5..9de48ab3c 100644 --- a/controllers/event_controller.go +++ b/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中的客户端 } }