diff --git a/business/jxstore/event/event_tcp.go b/business/jxstore/event/event_tcp.go index 2b2142ae5..f83eb5743 100644 --- a/business/jxstore/event/event_tcp.go +++ b/business/jxstore/event/event_tcp.go @@ -2,7 +2,6 @@ package event import ( "encoding/hex" - "encoding/json" "fmt" "git.rosy.net.cn/baseapi/utils" "git.rosy.net.cn/jx-callback/business/model/dao" @@ -41,9 +40,9 @@ func (t *TcpClient) handleConn(c net.Conn) { defer c.Close() for { var ( - printNo string //打印机编号 - printStatus *GetPrintStatus - buffer = make([]byte, 1024) + printNo string //打印机编号 + //printStatus *GetPrintStatus + buffer = make([]byte, 1024) ) n, err := c.Read(buffer) if err != nil { @@ -55,14 +54,14 @@ func (t *TcpClient) handleConn(c net.Conn) { return } //也可能是查状态的(openAPI外部查询,一次性的) - if err = json.Unmarshal(buffer[:n], &printStatus); err == nil { - fmt.Println("handleConn msg: ", string(buffer[:n])) - if printStatus != nil { - status := t.getPrintStatus(printStatus.PrintNo) - c.Write([]byte(utils.Int2Str(status))) - c.Close() - } - } + //if err = json.Unmarshal(buffer[:n], &printStatus); err == nil { + // fmt.Println("handleConn msg: ", string(buffer[:n])) + // if printStatus != nil { + // status := t.getPrintStatus(printStatus.PrintNo) + // c.Write([]byte(utils.Int2Str(status))) + // c.Close() + // } + //} //看是心跳还是打印回调 data := hex.EncodeToString(buffer[:n]) //globals.SugarLogger.Debugf("handleConn msg ....................: %v", data)