From b14c41722fa2ac50ea0cec3174d3be00a9a62de1 Mon Sep 17 00:00:00 2001
From: suyl <770236076@qq.com>
Date: Fri, 30 Jul 2021 18:28:10 +0800
Subject: [PATCH] a

---
 business/jxstore/event/event_tcp.go | 11 +++++++----
 1 file changed, 7 insertions(+), 4 deletions(-)

diff --git a/business/jxstore/event/event_tcp.go b/business/jxstore/event/event_tcp.go
index 4becccc6d..0141c7d27 100644
--- a/business/jxstore/event/event_tcp.go
+++ b/business/jxstore/event/event_tcp.go
@@ -146,6 +146,9 @@ func (t *TcpClient) HandleTcpMessages(printNo string) {
 		db               = dao.GetDB()
 		offset, pageSize = 0, 1
 	)
+	if !t.isExistMsg(printNo) {
+		return
+	}
 	globals.SugarLogger.Debugf("build HandleTcpMessages printNo: %s", printNo)
 	go func() {
 		for {
@@ -164,14 +167,14 @@ func (t *TcpClient) doPrint(key string) (err error) {
 	var (
 		db = dao.GetDB()
 	)
-	globals.SugarLogger.Debugf("doPrint printNo: %s", key)
 	if !t.isExistMsg(key) {
 		return err
 	}
-	go func(printNo string) {
+	globals.SugarLogger.Debugf("doPrint printNo: %s", key)
+	go func() {
 		for {
 			select {
-			case printMsg := <-t.MsgMap[printNo]:
+			case printMsg := <-t.MsgMap[key]:
 				var (
 					data []byte
 					c    net.Conn
@@ -217,7 +220,7 @@ func (t *TcpClient) doPrint(key string) (err error) {
 			case <-timeoutChan:
 			}
 		}
-	}(key)
+	}()
 	return err
 }