From cda3eaef57b28333206974078fcc48d9efc290b1 Mon Sep 17 00:00:00 2001
From: taoshihan1991 <630892807@qq.com>
Date: Wed, 10 Mar 2021 10:11:51 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E6=8E=92=E6=9F=A5=E6=97=A5?=
 =?UTF-8?q?=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 ws/user.go | 10 ++++++----
 1 file changed, 6 insertions(+), 4 deletions(-)

diff --git a/ws/user.go b/ws/user.go
index 0f80d70..fbbe34b 100644
--- a/ws/user.go
+++ b/ws/user.go
@@ -5,6 +5,7 @@ import (
 	"github.com/gin-gonic/gin"
 	"github.com/gorilla/websocket"
 	"github.com/taoshihan1991/imaptool/models"
+	"github.com/taoshihan1991/imaptool/tools"
 	"log"
 )
 
@@ -90,10 +91,11 @@ func OneKefuMessage(toId string, str []byte) {
 	mKefuConns, ok := KefuList[toId]
 	if mKefuConns != nil && ok {
 		for _, kefu := range mKefuConns {
-			log.Println("OneKefuMessage lock")
-			kefu.Mux.Lock()
-			defer kefu.Mux.Unlock()
-			log.Println("OneKefuMessage unlock")
+			//log.Println("OneKefuMessage lock")
+			//kefu.Mux.Lock()
+			//defer kefu.Mux.Unlock()
+			//log.Println("OneKefuMessage unlock")
+			tools.Logger().Println("send_kefu_message", websocket.TextMessage)
 			kefu.Conn.WriteMessage(websocket.TextMessage, str)
 		}
 	}