websotckty

This commit is contained in:
苏尹岚
2020-11-13 09:36:13 +08:00
parent b12c1b12c6
commit 80392c74d5

View File

@@ -97,10 +97,10 @@ func (c *EventController) TestWebsocket() {
if len(messageGroups) == 0 { if len(messageGroups) == 0 {
return return
} }
clientUser[userID] = ws
for _, v := range messageGroups { for _, v := range messageGroups {
clientUser[userID] = ws 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)