完善ws

controllers/event.go

@@ -1,11 +1,12 @@
 package controllers
 
 import (
-	"fmt"
 	"log"
 	"net/http"
 	"time"
 
+	"git.rosy.net.cn/jx-callback/globals"
+
 	"git.rosy.net.cn/jx-callback/business/model/dao"
 
 	"git.rosy.net.cn/jx-callback/business/model"
@@ -142,7 +143,7 @@ func (c *EventController) TestWebsocket() {
 		//接收客户端的消息
 		err := ws.ReadJSON(&s)
 		if err != nil {
-			log.Printf("页面可能断开啦 ws.ReadJSON error: %v", err.Error())
+			globals.SugarLogger.Debugf("页面可能断开啦 ws.ReadJSON error: %v", err.Error())
 			delete(clients, ws) //删除map中的客户端
 			break               //结束循环
 		} else {
@@ -150,7 +151,7 @@ func (c *EventController) TestWebsocket() {
 			db := dao.GetDB()
 			dao.WrapAddIDCULDEntity(&s, "")
 			dao.CreateEntity(db, &s)
-			fmt.Println("接受到从页面上反馈回来的信息 ", utils.Format4Output(s, false))
+			// fmt.Println("接受到从页面上反馈回来的信息 ", utils.Format4Output(s, false))
 		}
 	}
 }
@@ -164,13 +165,13 @@ func handleMessages() {
 	for {
 		//读取通道中的消息
 		msg := <-broadcast
-		fmt.Println("clients len ", len(clients))
+		globals.SugarLogger.Debugf("clients len ", len(clients))
 		//循环map客户端
 		for client := range clients {
 			//把通道中的消息发送给客户端
 			err := client.WriteJSON(msg)
 			if err != nil {
-				log.Printf("client.WriteJSON error: %v", err)
+				globals.SugarLogger.Debugf("client.WriteJSON error: %v", err)
 				client.Close()          //关闭
 				delete(clients, client) //删除map中的客户端
 			}