diff --git a/business/jxstore/event/event_tcp.go b/business/jxstore/event/event_tcp.go index aaa84b940..42f757e41 100644 --- a/business/jxstore/event/event_tcp.go +++ b/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外部查询,一次性的)