diff --git a/business/jxstore/event/event_tcp.go b/business/jxstore/event/event_tcp.go index cb73e90a6..e5b81c72c 100644 --- a/business/jxstore/event/event_tcp.go +++ b/business/jxstore/event/event_tcp.go @@ -156,8 +156,9 @@ func (t *TcpClient) HandleTcpMessages(printNo string) { prints, _ := dao.GetPrintMsgs(db, printNo, []int{printMsgWait}, time.Now().Add(-time.Hour*3), time.Now(), offset, pageSize) for _, printMsg := range prints { printMsg.Status = printMsgAlreadyLoad - dao.UpdateEntity(db, printMsg, "Status") - t.addMsgChan(printMsg) + if _, err := dao.UpdateEntity(db, printMsg, "Status"); err == nil { + t.addMsgChan(printMsg) + } } } }()