1

business/jxstore/event/event_tcp.go

@@ -166,9 +166,9 @@ func (t *TcpClient) HandleTcpMessages(printNo string) {
 
 	go func() {
 		for {
-			if time.Now().Second()%2 != 0 {
-				continue
-			}
+			//if time.Now().Second()%2 != 0 {
+			//	continue
+			//}
 			select {
 			case <-t.TimeoutMap[printNo]:
 				globals.SugarLogger.Debugf("HandleTcpMessages timeout")
@@ -260,7 +260,6 @@ func (t *TcpClient) doPrint(key string) (err error) {
 									close(t.TimeoutMap[key])
 								} else {
 									//等待回调
-									delete(t.MsgMap, key)
 									dataStr := <-t.CallBackMap[printMsg.PrintNo]
 									if dataStr != "" {
 										a, b := getCallbackMsgInfo(dataStr)