aa
This commit is contained in:
@@ -295,17 +295,17 @@ func (t *TcpClient) doPrint2(printMsgChan chan *model.PrintMsg) (err error) {
|
||||
globals.SugarLogger.Debugf("handleTcpMessages success, data: %v", hex.EncodeToString(data))
|
||||
printMsg.Status = printMsgAlreadySend
|
||||
dao.UpdateEntity(db, printMsg, "Status", "Comment")
|
||||
if t.CallBackMap[printMsg.PrintNo] != nil {
|
||||
t.RLock()
|
||||
select {
|
||||
case dataStr := <-t.CallBackMap[printMsg.PrintNo]:
|
||||
a, b := getCallbackMsgInfo(dataStr)
|
||||
t.changePrintMsg(dataStr, a, b)
|
||||
case <-timeoutChan:
|
||||
}
|
||||
t.RUnlock()
|
||||
|
||||
//if t.CallBackMap[printMsg.PrintNo] != nil {
|
||||
t.RLock()
|
||||
select {
|
||||
case dataStr := <-t.CallBackMap[printMsg.PrintNo]:
|
||||
a, b := getCallbackMsgInfo(dataStr)
|
||||
t.changePrintMsg(dataStr, a, b)
|
||||
case <-timeoutChan:
|
||||
}
|
||||
t.RUnlock()
|
||||
|
||||
//}
|
||||
//dataStr := <-printMsgCallbackChan
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user