a

dao/print_dao.go

@@ -151,6 +151,63 @@ func GetPrintMessagesPage(db *sqlx.DB, printNo, msgID, beginAt, endAt string, of
 	return page, err
 }
 
+func GetPrintMessages(db *sqlx.DB, printNo, msgID, beginAt, endAt string, statusNeq int) (printMsgs []*model.PrintMsg, err error) {
+	var (
+		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(id) 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)
+	}
+	if statusNeq != 0 {
+		sqlOhter += " AND status <> ?"
+		sqlParams = append(sqlParams, statusNeq)
+	}
+	//查总数
+	row := db.DB.QueryRow(sqlCount+sqlOhter, sqlParams...)
+	if err = row.Scan(&count); err != nil {
+		return printMsgs, err
+	}
+	if err = db.Select(&printMsgs, sql+sqlOhter, sqlParams...); err == nil {
+		return printMsgs, err
+	}
+	return printMsgs, err
+}
+
 func GetPrinter(db *sqlx.DB, printNo, iccID string) (printer *model.Printer, err error) {
 	var (
 		printers []*model.Printer