试试查状态
This commit is contained in:
@@ -4,6 +4,7 @@ import (
|
|||||||
"encoding/hex"
|
"encoding/hex"
|
||||||
"encoding/json"
|
"encoding/json"
|
||||||
"fmt"
|
"fmt"
|
||||||
|
"git.rosy.net.cn/baseapi/utils"
|
||||||
"git.rosy.net.cn/jx-callback/business/jxutils"
|
"git.rosy.net.cn/jx-callback/business/jxutils"
|
||||||
"git.rosy.net.cn/jx-callback/business/model"
|
"git.rosy.net.cn/jx-callback/business/model"
|
||||||
"git.rosy.net.cn/jx-callback/business/model/dao"
|
"git.rosy.net.cn/jx-callback/business/model/dao"
|
||||||
@@ -111,7 +112,7 @@ type TcpClient struct {
|
|||||||
|
|
||||||
type GetPrintStatus struct {
|
type GetPrintStatus struct {
|
||||||
PrintNo string //打印机编号
|
PrintNo string //打印机编号
|
||||||
|
AppID int
|
||||||
}
|
}
|
||||||
|
|
||||||
func ListenTcp() {
|
func ListenTcp() {
|
||||||
@@ -135,8 +136,8 @@ func ListenTcp() {
|
|||||||
|
|
||||||
func handleConn(c net.Conn) {
|
func handleConn(c net.Conn) {
|
||||||
var (
|
var (
|
||||||
printNo string //打印机编号
|
printNo string //打印机编号
|
||||||
printMsg *PrintInfo
|
printStatus *GetPrintStatus
|
||||||
)
|
)
|
||||||
if c == nil {
|
if c == nil {
|
||||||
globals.SugarLogger.Debugf("conn is nil")
|
globals.SugarLogger.Debugf("conn is nil")
|
||||||
@@ -155,7 +156,13 @@ func handleConn(c net.Conn) {
|
|||||||
return
|
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])
|
data := hex.EncodeToString(buffer[:n])
|
||||||
//证明是心跳
|
//证明是心跳
|
||||||
|
|||||||
Reference in New Issue
Block a user