diff --git a/business/jxstore/event/event_tcp.go b/business/jxstore/event/event_tcp.go index 7d44de595..8c244f88f 100644 --- a/business/jxstore/event/event_tcp.go +++ b/business/jxstore/event/event_tcp.go @@ -4,6 +4,7 @@ import ( "encoding/hex" "encoding/json" "fmt" + "git.rosy.net.cn/baseapi/utils" "git.rosy.net.cn/jx-callback/business/jxutils" "git.rosy.net.cn/jx-callback/business/model" "git.rosy.net.cn/jx-callback/business/model/dao" @@ -111,7 +112,7 @@ type TcpClient struct { type GetPrintStatus struct { PrintNo string //打印机编号 - + AppID int } func ListenTcp() { @@ -135,8 +136,8 @@ func ListenTcp() { func handleConn(c net.Conn) { var ( - printNo string //打印机编号 - printMsg *PrintInfo + printNo string //打印机编号 + printStatus *GetPrintStatus ) if c == nil { globals.SugarLogger.Debugf("conn is nil") @@ -155,7 +156,13 @@ func handleConn(c net.Conn) { return } //也可能是查状态的 - json.Unmarshal(buffer[:n], &printMsg) + if err = json.Unmarshal(buffer[:n], &printStatus); err == nil { + if printStatus != nil { + status := tcpClient.Clients[printStatus.PrintNo].Status + c.Write([]byte(utils.Int2Str(status))) + c.Close() + } + } //看是心跳还是打印返回 data := hex.EncodeToString(buffer[:n]) //证明是心跳