添加count
This commit is contained in:
@@ -125,7 +125,7 @@ func DeletePrintMsg() {
|
||||
return
|
||||
}
|
||||
|
||||
func QueryPrintList(db *DaoDB, printNo, printKey string, status, isOnline int, page, size int) (print []*model.Printer, err error) {
|
||||
func QueryPrintList(db *DaoDB, printNo, printKey string, status, isOnline int, page, size int) (print []*model.Printer, count int, err error) {
|
||||
sql := `
|
||||
SELECT * FROM printer WHERE 1=1
|
||||
`
|
||||
@@ -151,6 +151,18 @@ func QueryPrintList(db *DaoDB, printNo, printKey string, status, isOnline int, p
|
||||
sql += ` ORDER BY status desc,is_online desc LIMIT ? OFFSET ? `
|
||||
sqlParams = append(sqlParams, size, page)
|
||||
|
||||
err = GetRows(db, &print, sql, sqlParams...)
|
||||
return print, err
|
||||
tx, _ := Begin(db)
|
||||
defer func() {
|
||||
if r := recover(); r != nil {
|
||||
Rollback(db, tx)
|
||||
}
|
||||
}()
|
||||
defer Commit(db, tx)
|
||||
|
||||
if err = GetRowsTx(tx, &print, sql, sqlParams...); err != nil {
|
||||
Rollback(db, tx)
|
||||
return nil, 0, err
|
||||
}
|
||||
count = GetLastTotalRowCountTx(tx)
|
||||
return print, count, err
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user