打印机

dao/print_dao.go

@@ -1,7 +1,9 @@
 package dao
 
 import (
+	"errors"
 	"git.rosy.net.cn/baseapi/utils"
+	"git.rosy.net.cn/jx-print/globals"
 	"git.rosy.net.cn/jx-print/model"
 	"github.com/jmoiron/sqlx"
 	"time"
@@ -225,3 +227,22 @@ func GetPrinter(db *sqlx.DB, printNo, iccID string) (printer *model.Printer, err
 	}
 	return printer, err
 }
+
+// GetPrintById 根据用户id和打印机编号获取打印机
+func GetPrintById(userId, printNo string) (bool, error) {
+	var printer []*model.Printer
+	sql := `SELECT * FROM printer WHERE print_no = ? AND user_id = ? AND deleted_at = ?`
+	if err := globals.GetDB().Select(&printer, sql, []interface{}{printNo, userId, utils.DefaultTimeValue}...); err != nil {
+		return false, err
+	}
+	if len(printer) != 1 {
+		return false, errors.New("用户打印机数据异常,联系管理员") // 打印机编号唯一
+	}
+	return true, nil
+}
+
+// DeletePrinterMsg 删除打印机消息
+func DeletePrinterMsg(printNos []string) error {
+	_, err := globals.GetDB().Exec(`DELETE FROM print_msg WHERE print_no IN (?) `, []interface{}{printNos}...)
+	return err
+}

dao/print_setting.go

@@ -0,0 +1,77 @@
+package dao
+
+import (
+	"git.rosy.net.cn/baseapi/utils"
+	"git.rosy.net.cn/jx-print/globals"
+	settingModel "git.rosy.net.cn/jx-print/model/app_model"
+)
+
+type PrintSettingDao struct{}
+
+var PrintSettingInfoDao = new(PrintSettingDao)
+
+// QueryPrintNoIsExit 查询打印机绑定设置是否存在
+func (p *PrintSettingDao) QueryPrintNoIsExit(printNo string) (bool, error) {
+	sql := `SELECT COUNT(print_no) count FROM print_setting WHERE deleted_at = ? and print_no = ?`
+	//查总数
+	count := 0
+	row := globals.GetDB().DB.QueryRow(sql, []interface{}{utils.DefaultTimeValue, printNo}...)
+	if err := row.Scan(&count); err != nil {
+		return false, err
+	}
+	if count != 0 {
+		return false, nil
+	}
+	return true, nil
+}
+
+// InsertPrintSetting 插入打印机设置
+func (p *PrintSettingDao) InsertPrintSetting(param *settingModel.PrintSetting) error {
+	return Insert(globals.GetDB(), param)
+}
+
+// UpdatePrinterSetting 修改打印机配置
+func (p *PrintSettingDao) UpdatePrinterSetting(param *settingModel.UpdatePrintSetting) error {
+	db := globals.GetDB()
+	sql := `UPDATE print_setting SET `
+	var param2 []interface{}
+
+	if param.CallNameSetting != 0 {
+		sql += ` call_name_setting = ? `
+		param2 = append(param2, param.CallNameSetting)
+	}
+	if param.SystemVoice != 0 {
+		sql += ` system_voice = ? `
+		param2 = append(param2, param.SystemVoice)
+	}
+	if param.PrintVoiceSetting != "" {
+		sql += ` print_voice_setting = ? `
+		param2 = append(param2, param.PrintVoiceSetting)
+	}
+	if param.OrderVoiceSetting != "" {
+		sql += ` order_voice_setting = ? `
+		param2 = append(param2, param.OrderVoiceSetting)
+	}
+	if param.RiderVoiceSetting != "" {
+		sql += ` rider_voice_setting = ? `
+		param2 = append(param2, param.RiderVoiceSetting)
+	}
+	if param.CustomerVoiceSetting != "" {
+		sql += ` customer_voice_setting = ? `
+		param2 = append(param2, param.CustomerVoiceSetting)
+	}
+	if param.PickingSetting != "" {
+		sql += ` picking_setting = ? `
+		param2 = append(param2, param.PickingSetting)
+	}
+	sql += ` WHERE print_no = ? `
+
+	_, err := db.Exec(sql, param2...)
+	return err
+}
+
+// DeleteSetting 删除打印机设置
+func (p *PrintSettingDao) DeleteSetting(printNo []string) error {
+	_, err := globals.GetDB().Exec(`DELETE FROM print_setting WHERE print_no in (?)`, []interface{}{printNo}...)
+	return err
+}

dao/temp_dao.go

@@ -39,7 +39,7 @@ func UpdateOtherTempStatus(userId string) error {
 	return err
 }
 
-// UpdateTemp　删除模板数据
+// UpdateTemp　修改模板数据
 func UpdateTemp(param *app_model.SystemTemp, fields []string) error {
 	return Update(globals.GetDB(), param, fields...)
 }
@@ -50,6 +50,12 @@ func DeleteTemp(id int, userId string) error {
 	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
@@ -62,7 +68,7 @@ func SelectUserTemp(userId string) ([]*app_model.SystemTemp, error) {
 // 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 = 'system_user' ORDER BY created_at desc `, ""); err != nil {
+	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