1
This commit is contained in:
@@ -81,8 +81,6 @@ func (t *TcpClient) handleConn(c net.Conn) {
|
||||
//4、读打印channel并打印,并切等待回调channel中的消息
|
||||
//5、修改数据库中打印机状态(没在连接池中说明是重新连接的)
|
||||
//6、监听心跳时间,超过1分多钟就clear掉
|
||||
globals.SugarLogger.Debugf("handleConn timeout channel...: %s", utils.Format4Output(t.TimeoutMap[printNo], false))
|
||||
globals.SugarLogger.Debugf("handleConn timeout channel...: %s", utils.Format4Output(t, false))
|
||||
if t.getClients(printNo) == nil {
|
||||
t.addConn(c, printNo, status)
|
||||
t.buildAllMap(printNo)
|
||||
@@ -102,18 +100,14 @@ func (t *TcpClient) handleConn(c net.Conn) {
|
||||
t.setPrintStatusTime(printNo)
|
||||
}
|
||||
//状态不一致再更新状态(可能缺纸了,过热了等)
|
||||
//globals.SugarLogger.Debugf("比较缓存状态和真实状态缓存状态[%d],真实状态[%d]", t.getPrintStatus(printNo), status)
|
||||
if t.getPrintStatus(printNo) != status {
|
||||
//globals.SugarLogger.Debugf("更新打印机状态到数据库和缓存[%s:%d]", printNo, status)
|
||||
t.setPrintStatus(printNo, status)
|
||||
changePrinterStatus(printNo, status)
|
||||
}
|
||||
} else if strings.Contains(data, printText) || strings.Contains(data, printTextNew) { //打印回调
|
||||
globals.SugarLogger.Debugf("======回调 %s", data)
|
||||
//打印消息发送后,打印机会回调该条打印消息的状态(打印成功or失败,失败原因..)
|
||||
//将回调的信息放到回调channel中,打印成功后再打印下一条消息
|
||||
_, printNo = getCallbackMsgInfo(data)
|
||||
globals.SugarLogger.Debugf("======printNo %s", printNo)
|
||||
//更新打印机心跳时间(打印机本身不会在打印的同时,或回调的同时发心跳消息,会导致心跳判断超时,这里更新一下)
|
||||
t.setPrintStatusTime(printNo)
|
||||
t.addCallbackChan(printNo, data)
|
||||
|
||||
Reference in New Issue
Block a user