diff --git a/business/jxstore/event/event_tcp.go b/business/jxstore/event/event_tcp.go index de3a5360c..810b7ef0b 100644 --- a/business/jxstore/event/event_tcp.go +++ b/business/jxstore/event/event_tcp.go @@ -193,7 +193,7 @@ func handleConn(c net.Conn) { var ( db = dao.GetDB() ) - prints, _ := dao.GetPrintMsgsFail(db, time.Now().Add(time.Hour*3), time.Now()) + prints, _ := dao.GetPrintMsgsFail(db, time.Now().Add(-time.Hour*3), time.Now()) for _, printMsg := range prints { var ( data []byte @@ -303,7 +303,7 @@ func HandleTcpMessages() { //一直读? var err error time.Sleep(time.Second / 2) - prints, _ := dao.GetPrintMsgs(db, printMsgWait, time.Now().Add(time.Hour*3), time.Now(), offset, pageSize) + prints, _ := dao.GetPrintMsgs(db, printMsgWait, time.Now().Add(-time.Hour*3), time.Now(), offset, pageSize) for _, printMsg := range prints { var ( data []byte