diff --git a/business/jxstore/event/event_tcp.go b/business/jxstore/event/event_tcp.go index 906dc4a20..671ff35e8 100644 --- a/business/jxstore/event/event_tcp.go +++ b/business/jxstore/event/event_tcp.go @@ -348,7 +348,7 @@ func HandleTcpMessages() { //一直读? var err error time.Sleep(time.Second / 2) - prints, _ := dao.GetPrintMsgs(db, []int{printMsgWait, printMsgAlreadySend}, 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 { var ( data []byte