package dao

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

// GetTempByName 根据模板名称获取模板
func GetTempByName(userID, tempName string) ([]*app_model.SystemTemp, error) {
	sql := `SELECT * FROM system_temp WHERE 1=1`
	var param []interface{}
	if userID != "" {
		sql += ` AND user_id = ?`
		param = append(param, userID)
	}
	if tempName != "" {
		sql += ` AND temp_name = ?`
		param = append(param, tempName)
	}
	sql += ` AND deleted_at = ?`
	param = append(param, utils.DefaultTimeValue)
	var result []*app_model.SystemTemp

	if err := globals.GetDB().Select(&result, sql, param...); err != nil {
		return nil, err
	}
	return result, nil
}

// AddTemp 添加模板数据
func AddTemp(param *app_model.SystemTemp) error {
	return Insert(globals.GetDB(), param)
}

// UpdateOtherTempStatus 修改其他模板为非默认
func UpdateOtherTempStatus(userId string) error {
	_, err := globals.GetDB().Exec(`UPDATE  system_temp SET is_use = ? WHERE user_id = ?`, []interface{}{2, userId})
	return err
}

// UpdateTemp　修改模板数据
func UpdateTemp(param *app_model.SystemTemp, fields []string) error {
	return Update(globals.GetDB(), param, fields...)
}

// DeleteTemp 删除模板数据
func DeleteTemp(id int, userId string) error {
	_, err := globals.GetDB().Exec(`DELETE FROM system_temp WHERE id = ? AND user_id = ?`, []interface{}{id, userId}...)
	return err
}

// DeleteAllTemp 删除用户所属打印机所有模板
func DeleteAllTemp(userId string, printNo []string) error {
	_, err := globals.GetDB().Exec(`DELETE FROM system_temp WHERE user_id = ? AND print_sn IN (?)`, []interface{}{userId, printNo}...)
	return err
}

// SelectUserTemp 查询用户模板
func SelectUserTemp(userId string) ([]*app_model.SystemTemp, error) {
	var result []*app_model.SystemTemp
	if err := globals.GetDB().Select(&result, `SELECT * FROM system_temp WHERE user_id = ? AND  deleted_at = ? ORDER BY created_at desc `, []interface{}{userId}...); err != nil {
		return nil, err
	}
	return result, nil
}

// QuerySystemTemp 查询系统模板
func QuerySystemTemp() ([]*app_model.SystemTemp, error) {
	var result []*app_model.SystemTemp
	if err := globals.GetDB().Select(&result, `SELECT * FROM system_temp WHERE user_id = ? ORDER BY created_at desc `, []interface{}{"system_user"}...); err != nil {
		return nil, err
	}
	return result, nil
}

// SwitchTemp2User 切换模板
func SwitchTemp2User(tempId int, userId string) error {
	if _, err := globals.GetDB().Exec(`UPDATE system_temp SET is_use = 2 WHERE  user_id = ?`, []interface{}{userId}...); err != nil {
		return err
	}
	if _, err := globals.GetDB().Exec(`UPDATE system_temp SET is_use = 1 WHERE  id = ? AND user_id = ?`, []interface{}{tempId, userId}...); err != nil {
		return err
	}
	return nil
}