1

business/jxstore/cms/api_print.go

@@ -386,11 +386,11 @@ func DoPrintMsg(appID int, msgID, printNo, content string, orderNo string) (err
 		Status:  event.PrintMsgWait,
 	}
 
-	t, ok := event.TcpClientList[printNo]
+	t, ok := event.TcpClientList.Load(printNo)
 	if ok {
-		t.Lock()
+		t.(*event.TcpClient).Lock()
-		defer t.Unlock()
+		defer t.(*event.TcpClient).Unlock()
-		t.MsgMap[printNo] <- printMsg
+		t.(*event.TcpClient).MsgMap[printNo] <- printMsg
 		printMsg.Status = event.PrintMsgAlreadyLoad
 	} /*else {
 		t = event.NewTcpClient()

business/jxstore/event/event_tcp.go

@@ -88,11 +88,11 @@ func handleConn(c net.Conn) error {
 			callback = true
 		}
 
-		if _, have := TcpClientList[printNo]; !have {
+		if value, have := TcpClientList.Load(printNo); !have {
 			t = NewTcpClient()
-			TcpClientList[printNo] = t
+			TcpClientList.Store(printNo, t)
 		} else {
-			t = TcpClientList[printNo]
+			t = value.(*TcpClient)
 		}
 		if heartbeat {
 			// 证明是心跳

business/jxstore/event/event_tcp_utils.go

@@ -17,7 +17,7 @@ import (
 	"unicode/utf8"
 )
 
-var TcpClientList = make(map[string]*TcpClient, 0)
+var TcpClientList = new(sync.Map)
 
 const (
 	heartText           = "1e000f02000151" // 老版心跳
@@ -843,6 +843,7 @@ func HandleCheckTcpHeart(t *TcpClient, key string) {
 		close(t.CallBackMap[key])
 		//t.delConn(key)
 		t.clear(key)
+		TcpClientList.Delete(key)
 		return
 	}
 }