From 4fcc832f9dc6899c4fcc196d42e84328cd5a760d Mon Sep 17 00:00:00 2001
From: suyl <770236076@qq.com>
Date: Fri, 9 Jul 2021 10:12:09 +0800
Subject: [PATCH] aa

---
 business/jxstore/event/event_tcp.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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