1
This commit is contained in:
@@ -89,12 +89,10 @@ func handleConn(c net.Conn) error {
|
|||||||
callback = true
|
callback = true
|
||||||
}
|
}
|
||||||
|
|
||||||
t, ok := PrintObject[printNo]
|
t := NewTcpClient()
|
||||||
if !ok {
|
|
||||||
t = NewTcpClient()
|
|
||||||
buildAllMap(t, printNo)
|
buildAllMap(t, printNo)
|
||||||
PrintObject[printNo] = t
|
PrintObject[printNo] = t
|
||||||
}
|
|
||||||
if strings.Contains(string(buffer[0:n]), "print_no_clear") { // 清理缓存
|
if strings.Contains(string(buffer[0:n]), "print_no_clear") { // 清理缓存
|
||||||
param := struct {
|
param := struct {
|
||||||
PrintNoClear json.Number `json:"print_no_clear"`
|
PrintNoClear json.Number `json:"print_no_clear"`
|
||||||
|
|||||||
@@ -652,7 +652,7 @@ func Heartbeat(c net.Conn, t *TcpClient, data string, printNo string) {
|
|||||||
buildAllMap(t, printNo)
|
buildAllMap(t, printNo)
|
||||||
//t.TimeoutMap[printNo] <- true
|
//t.TimeoutMap[printNo] <- true
|
||||||
HandleTcpMessages(t, printNo)
|
HandleTcpMessages(t, printNo)
|
||||||
doPrint(t, printNo)
|
//doPrint(t, printNo)
|
||||||
if status == printerStatusOnline {
|
if status == printerStatusOnline {
|
||||||
//t.printFail()
|
//t.printFail()
|
||||||
}
|
}
|
||||||
@@ -667,10 +667,10 @@ func Heartbeat(c net.Conn, t *TcpClient, data string, printNo string) {
|
|||||||
//在加到连接池中已经更新了时间,所以放在else里
|
//在加到连接池中已经更新了时间,所以放在else里
|
||||||
t.setPrintStatusTime(printNo)
|
t.setPrintStatusTime(printNo)
|
||||||
}
|
}
|
||||||
|
doPrint(t, printNo)
|
||||||
//状态不一致再更新状态(可能缺纸了,过热了等)
|
//状态不一致再更新状态(可能缺纸了,过热了等)
|
||||||
t.setPrintStatus(printNo, status)
|
t.setPrintStatus(printNo, status)
|
||||||
changePrinterStatus(printNo, status)
|
changePrinterStatus(printNo, status)
|
||||||
doPrint(t, printNo)
|
|
||||||
}
|
}
|
||||||
|
|
||||||
// Callback 打印成功回调
|
// Callback 打印成功回调
|
||||||
|
|||||||
Reference in New Issue
Block a user