aa

business/jxstore/event/event_tcp.go

@@ -33,17 +33,17 @@ func ListenTcp() {
 }
 
 func (t *TcpClient) handleConn(c net.Conn) {
-	var (
-		printNo     string //打印机编号
-		printStatus *GetPrintStatus
-	)
 	if c == nil {
 		globals.SugarLogger.Debugf("conn is nil")
 		return
 	}
 	defer c.Close()
-	buffer := make([]byte, 1024)
 	for {
+		var (
+			printNo     string //打印机编号
+			printStatus *GetPrintStatus
+			buffer      = make([]byte, 1024)
+		)
 		n, err := c.Read(buffer)
 		if err != nil {
 			if err == io.EOF {
@@ -51,6 +51,9 @@ func (t *TcpClient) handleConn(c net.Conn) {
 			} else {
 				fmt.Println("ReadString err", err)
 			}
+			if printNo != "" {
+				t.clear(printNo)
+			}
 			return
 		}
 		//也可能是查状态的（openAPI外部查询，一次性的）