get printmsg

dao/print_dao.go

@@ -4,6 +4,7 @@ import (
 	"git.rosy.net.cn/baseapi/utils"
 	"git.rosy.net.cn/jx-print/model"
 	"github.com/jmoiron/sqlx"
+	"time"
 )
 
 func GetPrinters(db *sqlx.DB, appID int, printNo string) (printers []*model.Printer, err error) {
@@ -78,3 +79,62 @@ func GetPrintersPage(db *sqlx.DB, appID int, printNo, name string, status, isOnl
 	}
 	return page, err
 }
+
+func GetPrintMessagesPage(db *sqlx.DB, printNo, msgID, beginAt, endAt string, offset, pageSize int) (page *model.PagedInfo, err error) {
+	var (
+		printMsgs          []*model.PrintMsg
+		count              int
+		beginTime, endTime time.Time
+	)
+	if beginAt == "" {
+		beginTime = utils.Time2Date(time.Now().AddDate(0, 0, -7))
+	} else {
+		beginTime = utils.Str2Time(beginAt)
+	}
+	if endAt == "" {
+		endTime = utils.Str2Time(utils.Time2Str(utils.Time2Date(time.Now())) + " 23:59:59")
+	} else {
+		endTime = utils.Str2Time(endAt)
+	}
+	sqlCount := `
+		SELECT COUNT(*) count
+	`
+	sql := `
+		SELECT *
+	`
+	sqlOhter := `
+		  FROM print_msg 
+         WHERE 1 = 1 AND deleted_at = ?
+	`
+	sqlParams := []interface{}{utils.DefaultTimeValue}
+	if printNo != "" {
+		sqlOhter += " AND print_no = ?"
+		sqlParams = append(sqlParams, printNo)
+	}
+	if msgID != "" {
+		sqlOhter += " AND msg_id = ?"
+		sqlParams = append(sqlParams, msgID)
+	}
+	if beginTime != utils.ZeroTimeValue {
+		sqlOhter += " AND created_at > ?"
+		sqlParams = append(sqlParams, beginTime)
+	}
+	if endTime != utils.ZeroTimeValue {
+		sqlOhter += " AND created_at < ?"
+		sqlParams = append(sqlParams, endTime)
+	}
+	//查总数
+	row := db.DB.QueryRow(sqlCount+sqlOhter, sqlParams...)
+	if err = row.Scan(&count); err != nil {
+		return page, err
+	}
+	sqlOhter += " LIMIT ? OFFSET ?"
+	sqlParams = append(sqlParams, pageSize, offset)
+	if err = db.Select(&printMsgs, sql+sqlOhter, sqlParams...); err == nil {
+		return &model.PagedInfo{
+			TotalCount: count,
+			Data:       printMsgs,
+		}, err
+	}
+	return page, err
+}