diff --git a/business/jxstore/event/event_tcp.go b/business/jxstore/event/event_tcp.go index bf07c08c2..ada019e17 100644 --- a/business/jxstore/event/event_tcp.go +++ b/business/jxstore/event/event_tcp.go @@ -370,6 +370,7 @@ 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") } @@ -382,7 +383,7 @@ func doPrint2(printMsgChan chan *model.PrintMsg) (err error) { ) for { select { - case printMsg, _ := <-printMsgChan: + case printMsg := <-printMsgChan: var ( data []byte c net.Conn