diff --git a/controller/chat.go b/controller/chat.go index 9f5fa53..1655c3c 100644 --- a/controller/chat.go +++ b/controller/chat.go @@ -84,6 +84,7 @@ func NewChatServer(c *gin.Context){ kefuConn.WriteMessage(websocket.TextMessage,str) } } + sendPingOnlineUsers() } } log.Println(err) @@ -190,7 +191,7 @@ func sendPingOnlineUsers() { } } msg := TypeMessage{ - Type: "getOnlineUsers", + Type: "allUsers", Data: result, } str, _ := json.Marshal(msg) @@ -255,6 +256,7 @@ func singleBroadcaster(){ kefuConn.WriteMessage(websocket.TextMessage,str) } } + sendPingOnlineUsers() //客服上线 case "kfOnline": json.Unmarshal(msgData, &clientMsg) diff --git a/main.go b/main.go index d82a8d9..300ac0b 100644 --- a/main.go +++ b/main.go @@ -46,7 +46,7 @@ func main() { //前后聊天 engine.GET("/chat_server", controller.NewChatServer) //获取消息 - engine.GET("/messages",middleware.JwtApiMiddleware, controller.GetVisitorMessage) + engine.GET("/messages", controller.GetVisitorMessage) //发送单条消息 engine.POST("/message",controller.SendMessage) //获取未读消息数 diff --git a/static/html/chat_main.html b/static/html/chat_main.html index 0dc13f8..d484caf 100644 --- a/static/html/chat_main.html +++ b/static/html/chat_main.html @@ -9,6 +9,7 @@ +