liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

aa

Browse Source
This commit is contained in:
suyl
2021-08-02 16:03:39 +08:00
parent 90d441d02f
commit a441c28bf5
1 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
business/jxstore/event/event_tcp.go
View File

@@ -156,10 +156,11 @@ func (t *TcpClient) HandleTcpMessages(printNo string) {
prints, _ := dao.GetPrintMsgs(db, printNo, []int{printMsgWait}, time.Now().Add(-time.Hour*3), time.Now(), offset, pageSize) prints, _ := dao.GetPrintMsgs(db, printNo, []int{printMsgWait}, time.Now().Add(-time.Hour*3), time.Now(), offset, pageSize)
for _, printMsg := range prints { for _, printMsg := range prints {
printMsg.Status = printMsgAlreadyLoad printMsg.Status = printMsgAlreadyLoad
dao.UpdateEntity(db, printMsg, "Status") if _, err := dao.UpdateEntity(db, printMsg, "Status"); err == nil {
t.addMsgChan(printMsg) t.addMsgChan(printMsg)
} }
} }
}
}() }()
} }