a
This commit is contained in:
@@ -373,6 +373,8 @@ func HandleTcpMessages() {
|
||||
prints, _ := dao.GetPrintMsgs(db, []int{printMsgWait}, time.Now().Add(-time.Hour*3), time.Now(), offset, pageSize)
|
||||
for _, printMsg := range prints {
|
||||
printMsgChan <- printMsg
|
||||
printMsg.Status = printMsgAlreadyLoad
|
||||
dao.UpdateEntity(db, printMsg, "Status")
|
||||
Loop:
|
||||
for {
|
||||
select {
|
||||
|
||||
Reference in New Issue
Block a user