package dao

import (
	"git.rosy.net.cn/baseapi/utils"
	"git.rosy.net.cn/jx-callback/business/model"
	"git.rosy.net.cn/jx-callback/globals"
)

// QueryUserPrinter 查询用户打印机
func QueryUserPrinter(userId, printNo string) (*model.Printer, error) {
	sql := `
		SELECT *
		  FROM printer
	    WHERE 1 = 1 AND deleted_at = ?
	`
	sqlParams := []interface{}{
		utils.DefaultTimeValue,
	}

	if printNo != "" {
		sql += " AND print_no = ?"
		sqlParams = append(sqlParams, printNo)
	}
	if userId != "" {
		sql += " AND user_id = ?"
		sqlParams = append(sqlParams, userId)
	}
	var printer = &model.Printer{}
	err := GetRow(GetDB(), &printer, sql, sqlParams)
	return printer, err
}

func GetPrinters(db *DaoDB, appID int, printNo string, status, statusNeq int) (printers []*model.Printer, err error) {
	sql := `
		SELECT *
		  FROM printer
	    WHERE 1 = 1 AND deleted_at = ?
	`
	sqlParams := []interface{}{
		utils.DefaultTimeValue,
	}
	if appID != 0 {
		sql += " AND app_id = ?"
		sqlParams = append(sqlParams, appID)
	}
	if printNo != "" {
		sql += " AND print_no = ?"
		sqlParams = append(sqlParams, printNo)
	}
	if status != 0 {
		sql += " AND status = ?"
		sqlParams = append(sqlParams, status)
	}
	if statusNeq != 0 {
		sql += " AND status <> ?"
		sqlParams = append(sqlParams, statusNeq)
	}
	err = GetRows(db, &printers, sql, sqlParams)

	globals.SugarLogger.Debugf("======printers====  %s", utils.Format4Output(printers, false))
	return printers, err
}

func GetPrintMsgs(db *DaoDB, printNo, msgID string, status, statusNeq int) (printMsgs []*model.PrintMsg, err error) {
	sql := `
		SELECT *
		  FROM print_msg
         WHERE 1 = 1 AND deleted_at = ? 
	`
	sqlParams := []interface{}{
		utils.DefaultTimeValue,
	}
	if status != model.PrintMsgAll {
		sql += " AND status = ?"
		sqlParams = append(sqlParams, status)
	}
	if statusNeq != model.PrintMsgAll {
		sql += " AND status <> ?"
		sqlParams = append(sqlParams, statusNeq)
	}
	if printNo != "" {
		sql += " AND print_no = ?"
		sqlParams = append(sqlParams, printNo)
	}
	if msgID != "" {
		sql += " AND msg_id = ?"
		sqlParams = append(sqlParams, msgID)
	}
	err = GetRows(db, &printMsgs, sql, sqlParams)
	return printMsgs, err
}