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