websotckty

This commit is contained in:
苏尹岚
2020-11-13 09:55:00 +08:00
parent aab7167e35
commit 8805d78dee

View File

@@ -100,10 +100,11 @@ func (c *EventController) TestWebsocket() {
clientUser[userID] = ws clientUser[userID] = ws
for _, v := range messageGroups { for _, v := range messageGroups {
if len(clients[v.GroupID]) > 0 { if len(clients[v.GroupID]) > 0 {
clients[v.GroupID][userID] = ws
} } else {
clients[v.GroupID] = clientUser clients[v.GroupID] = clientUser
} }
}
db := dao.GetDB() db := dao.GetDB()
if globals.IsProductEnv() { if globals.IsProductEnv() {
_, _, err = jxcontext.New(nil, c.GetString("token"), c.Ctx.ResponseWriter, c.Ctx.Request) _, _, err = jxcontext.New(nil, c.GetString("token"), c.Ctx.ResponseWriter, c.Ctx.Request)