diff --git a/business/jxstore/event/event_tcp.go b/business/jxstore/event/event_tcp.go index 75b5f84dc..079c22765 100644 --- a/business/jxstore/event/event_tcp.go +++ b/business/jxstore/event/event_tcp.go @@ -169,7 +169,7 @@ func (t *TcpClient) HandleTcpMessages(printNo string) { timeNow := time.Now() timeStart := time.Date(timeNow.Year(), timeNow.Month(), timeNow.Day(), 0, 0, 0, 0, timeNow.Location()) timeEnd := time.Date(timeNow.Year(), timeNow.Month(), timeNow.Day(), 23, 59, 59, 0, timeNow.Location()) - prints, _ := dao.GetPrintMsgs(db, printNo, []int{printMsgWait}, timeStart, timeEnd, offset, pageSize) + prints, _ := dao.GetPrintMsgs(db, printNo, []int{printMsgWait, printMsgAlreadyLoad}, timeStart, timeEnd, offset, pageSize) for _, printMsg := range prints { printMsg.Status = printMsgAlreadyLoad //先避免重复读再插到channel? diff --git a/business/model/dao/dao_print.go b/business/model/dao/dao_print.go index 9f256998f..dd004e6de 100644 --- a/business/model/dao/dao_print.go +++ b/business/model/dao/dao_print.go @@ -53,9 +53,6 @@ func GetPrintMsgs(db *DaoDB, printNo string, statuss []int, beginAt, endAt time. sql += " ORDER BY a.created_at LIMIT ? OFFSET ?" sqlParams = append(sqlParams, pageSize, offset) err = GetRows(db, &prints, sql, sqlParams) - globals.SugarLogger.Debugf("======sql := %s", sql) - globals.SugarLogger.Debugf("======sql := %s", utils.Format4Output(sqlParams, false)) - globals.SugarLogger.Debugf("======prints := %s", utils.Format4Output(prints, false)) return prints, err }