aa
This commit is contained in:
@@ -375,13 +375,6 @@ func HandleTcpMessages() {
|
|||||||
printMsgChan <- printMsg
|
printMsgChan <- printMsg
|
||||||
printMsg.Status = printMsgAlreadyLoad
|
printMsg.Status = printMsgAlreadyLoad
|
||||||
dao.UpdateEntity(db, printMsg, "Status")
|
dao.UpdateEntity(db, printMsg, "Status")
|
||||||
Loop:
|
|
||||||
for {
|
|
||||||
if data, _ := <-printMsgCallbackChan; data != "" {
|
|
||||||
changePrintMsg(data)
|
|
||||||
break Loop
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -438,6 +431,11 @@ func doPrint2(printMsgChan chan *model.PrintMsg) (err error) {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
default:
|
||||||
|
select {
|
||||||
|
case data, _ := <-printMsgCallbackChan:
|
||||||
|
changePrintMsg(data)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return err
|
return err
|
||||||
|
|||||||
Reference in New Issue
Block a user