diff --git a/business/jxstore/event/event_tcp.go b/business/jxstore/event/event_tcp.go index 39857c5dd..206bd51af 100644 --- a/business/jxstore/event/event_tcp.go +++ b/business/jxstore/event/event_tcp.go @@ -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 {