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-07-22 15:06:08 +08:00
parent c8678143c1
commit dda8b5c209
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -370,6 +370,7 @@ func HandleTcpMessages() {
//一直读？ //一直读？
prints, _ := dao.GetPrintMsgs(db, []int{printMsgWait}, time.Now().Add(-time.Hour*3), time.Now(), offset, pageSize) prints, _ := dao.GetPrintMsgs(db, []int{printMsgWait}, time.Now().Add(-time.Hour*3), time.Now(), offset, pageSize)
for _, printMsg := range prints { for _, printMsg := range prints {
printMsgChan <- printMsg
printMsg.Status = printMsgAlreadyLoad printMsg.Status = printMsgAlreadyLoad
dao.UpdateEntity(db, printMsg, "Status") dao.UpdateEntity(db, printMsg, "Status")
} }
@@ -382,7 +383,7 @@ func doPrint2(printMsgChan chan *model.PrintMsg) (err error) {
) )
for { for {
select { select {
case printMsg, _ := <-printMsgChan: case printMsg := <-printMsgChan:
var ( var (
data []byte data []byte
c net.Conn c net.Conn