From fee78529dd45fecd3df09abe4dfeda30055b00b4 Mon Sep 17 00:00:00 2001 From: suyl <770236076@qq.com> Date: Fri, 9 Jul 2021 15:59:26 +0800 Subject: [PATCH] aa --- business/jxstore/event/event_tcp.go | 2 +- business/model/dao/dao_print.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/business/jxstore/event/event_tcp.go b/business/jxstore/event/event_tcp.go index b87c39e7e..ee79ba6da 100644 --- a/business/jxstore/event/event_tcp.go +++ b/business/jxstore/event/event_tcp.go @@ -286,7 +286,7 @@ func changePrintMsg(data string) (err error) { func HandleTcpMessages() { var ( db = dao.GetDB() - offset, pageSize = 0, 10 + offset, pageSize = 0, 1 ) for { //一直读? diff --git a/business/model/dao/dao_print.go b/business/model/dao/dao_print.go index 58733ec22..498120ec3 100644 --- a/business/model/dao/dao_print.go +++ b/business/model/dao/dao_print.go @@ -44,7 +44,7 @@ func GetPrintMsgs(db *DaoDB, statuss []int, beginAt, endAt time.Time, offset, pa sql += " AND created_at < ?" sqlParams = append(sqlParams, endAt) } - sql += " LIMIT ? OFFSET ?" + sql += "ORDER BY created_At LIMIT ? OFFSET ?" sqlParams = append(sqlParams, pageSize, offset) err = GetRows(db, &prints, sql, sqlParams) return prints, err