From d8152daba634f4b43f4a87982e2579d5f2ec89f9 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E8=8B=8F=E5=B0=B9=E5=B2=9A?= <770236076@qq.com>
Date: Thu, 20 Aug 2020 10:50:02 +0800
Subject: [PATCH] =?UTF-8?q?=E5=AE=8C=E5=96=84ws?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 controllers/event.go | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)

diff --git a/controllers/event.go b/controllers/event.go
index e8ac1d600..bfbd969e0 100644
--- a/controllers/event.go
+++ b/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中的客户端
 			}