liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

aa

Browse Source
This commit is contained in:
suyl
2021-06-29 09:16:47 +08:00
parent 341afec0b7
commit ed7e2b2c69
2 changed files with 3 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
business/jxstore/event/event_tcp.go
View File

@@ -13,6 +13,7 @@ import (
"strconv" "strconv"
"strings" "strings"
"sync" "sync"
"time"
) )
const ( const (
@@ -153,8 +154,8 @@ func HandleTcpMessages() {
for { for {
//一直读？ //一直读？
var err error var err error
time.Sleep(time.Second / 2)
prints, _ := dao.GetPrintMsgs(db, printMsgWait, offset, pageSize) prints, _ := dao.GetPrintMsgs(db, printMsgWait, offset, pageSize)
globals.SugarLogger.Debugf("HandleTcpMessages, len prints: [%v]", len(prints))
for _, printMsg := range prints { for _, printMsg := range prints {
if printMsg != nil { if printMsg != nil {
if err = checkPrintMsg(printMsg); err == nil { if err = checkPrintMsg(printMsg); err == nil {

2
business/model/dao/dao_print.go
View File

@@ -29,7 +29,7 @@ func GetPrintMsgs(db *DaoDB, status, offset, pageSize int) (prints []*model.Prin
FROM print_msg FROM print_msg
WHERE 1 = 1 WHERE 1 = 1
AND status = ? AND status = ?
LIMIT ? OFFSET LIMIT ? OFFSET ?
` `
sqlParams := []interface{}{status, pageSize, offset} sqlParams := []interface{}{status, pageSize, offset}
err = GetRows(db, &prints, sql, sqlParams) err = GetRows(db, &prints, sql, sqlParams)