From 4abe35cdec7e9eef0deb654c14202558bef7856e Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E9=99=B6=E5=A3=AB=E6=B6=B5?= <630892807@qq.com>
Date: Sat, 27 Jun 2020 01:02:35 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E8=81=8A=E5=A4=A9?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 controller/chat.go | 24 +++---------------------
 1 file changed, 3 insertions(+), 21 deletions(-)

diff --git a/controller/chat.go b/controller/chat.go
index 8503c5c..8befcbc 100644
--- a/controller/chat.go
+++ b/controller/chat.go
@@ -94,24 +94,6 @@ func SendKefuOnline(kfMsg KfMessage, conn *websocket.Conn) {
 	conn.WriteMessage(1,jsonStrByte)
 }
 
-//发送给所有客服客户上线
-func SendOnekfuAllNotice(conn *websocket.Conn) {
-	result := make([]map[string]string, 0)
-	for _, user := range clientList {
-		userInfo := make(map[string]string)
-		userInfo["uid"] = user.id
-		userInfo["username"] = user.name
-		userInfo["avator"] = user.avator
-		result = append(result, userInfo)
-	}
-	msg := TypeMessage{
-		Type: "notice",
-		Data: result,
-	}
-	str, _ := json.Marshal(msg)
-	conn.WriteMessage(1,str)
-}
-
 //定时给客户端发送消息判断客户端是否在线
 func sendPingToClient() {
 	msg := TypeMessage{
@@ -147,7 +129,7 @@ func SendNoticeToAllKefu() {
 }
 
 //获取当前的在线用户
-func getOnlineUser(w *websocket.Conn,messageType int) {
+func getOnlineUser(w *websocket.Conn) {
 	result := make([]map[string]string, 0)
 	for _, user := range clientList {
 		userInfo := make(map[string]string)
@@ -161,7 +143,7 @@ func getOnlineUser(w *websocket.Conn,messageType int) {
 		Data: result,
 	}
 	str, _ := json.Marshal(msg)
-	w.WriteMessage(messageType,str)
+	w.WriteMessage(websocket.TextMessage,str)
 }
 //后端广播发送消息
 func singleBroadcaster(){
@@ -180,7 +162,7 @@ func singleBroadcaster(){
 		switch msgType {
 		//获取当前在线的所有用户
 		case "getOnlineUsers":
-			getOnlineUser(conn,websocket.TextMessage)
+			getOnlineUser(conn)
 		//用户上线
 		case "userInit":
 			json.Unmarshal(msgData, &userMsg)