aa
This commit is contained in:
@@ -348,7 +348,7 @@ func HandleTcpMessages() {
|
|||||||
//一直读?
|
//一直读?
|
||||||
var err error
|
var err error
|
||||||
time.Sleep(time.Second / 2)
|
time.Sleep(time.Second / 2)
|
||||||
prints, _ := dao.GetPrintMsgs(db, []int{printMsgWait, printMsgAlreadySend}, time.Now().Add(-time.Hour*3), time.Now(), offset, pageSize)
|
prints, _ := dao.GetPrintMsgs(db, []int{printMsgWait}, time.Now().Add(-time.Hour*3), time.Now(), offset, pageSize)
|
||||||
for _, printMsg := range prints {
|
for _, printMsg := range prints {
|
||||||
var (
|
var (
|
||||||
data []byte
|
data []byte
|
||||||
|
|||||||
Reference in New Issue
Block a user