liulei/jx-print
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
邹宗楠
2022-12-07 15:15:02 +08:00
parent c3c4855988
commit 7f7613b0cb
2 changed files with 8 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
dao/print_bill.go
View File

@@ -7,7 +7,10 @@ import (
) )
// QueryPrintBill 查询打印机账户是否存在 // QueryPrintBill 查询打印机账户是否存在
func QueryPrintBill(userId, printNo string) ([]*app_model.PrintBill, error) { func QueryPrintBill(db *sqlx.Tx, userId, printNo string) ([]*app_model.PrintBill, error) {
if db == nil {
db = globals.GetTxDb()
}
sql := `SELECT * FROM print_bill WHERE 1 = 1 ` sql := `SELECT * FROM print_bill WHERE 1 = 1 `
var param []interface{} var param []interface{}
if userId != "" { if userId != "" {
@@ -20,7 +23,7 @@ func QueryPrintBill(userId, printNo string) ([]*app_model.PrintBill, error) {
} }
var result []*app_model.PrintBill var result []*app_model.PrintBill
if err := globals.GetDB().Select(&result, sql, param...); err != nil { if err := db.Select(&result, sql, param...); err != nil {
return nil, err return nil, err
} }
return result, nil return result, nil
@@ -46,7 +49,7 @@ func AddMoney(db *sqlx.Tx, printNo string, money int64) error {
// UpdateBillToUser 当打印机账户从菜市绑定时,未分配用户,用户再使用小程序绑定时,将打印机分配给用户! // UpdateBillToUser 当打印机账户从菜市绑定时,未分配用户,用户再使用小程序绑定时,将打印机分配给用户!
func UpdateBillToUser(db *sqlx.Tx, param *app_model.PrintBill) error { func UpdateBillToUser(db *sqlx.Tx, param *app_model.PrintBill) error {
sql := `UPDATE print_bill SET user_id = ? WHERE print_no = ?` sql := `UPDATE print_bill SET user_id = ? WHERE print_no = ?`
_, err := globals.GetTxDb().Exec(sql, []interface{}{param.UserId, param.PrintNo}...) _, err := db.Exec(sql, []interface{}{param.UserId, param.PrintNo}...)
return err return err
} }

4
services/print_server/app_server/print_bill.go
View File

@@ -15,7 +15,7 @@ var PrintBillServer = new(PrintBill)
// InitPPrintBill 初始化打印机账户 // InitPPrintBill 初始化打印机账户
func (p *PrintBill) InitPPrintBill(tx *sqlx.Tx, bill *app_model.PrintBill) error { func (p *PrintBill) InitPPrintBill(tx *sqlx.Tx, bill *app_model.PrintBill) error {
// 查询打印机是否有账户,没有添加 // 查询打印机是否有账户,没有添加
result, err := dao.QueryPrintBill("", bill.PrintNo) result, err := dao.QueryPrintBill(tx, "", bill.PrintNo)
if err != nil { if err != nil {
return err return err
} }
@@ -40,7 +40,7 @@ func (p *PrintBill) InitPPrintBill(tx *sqlx.Tx, bill *app_model.PrintBill) error
// QueryPrintBill 查询打印机余额 // QueryPrintBill 查询打印机余额
func (p *PrintBill) QueryPrintBill(userId, printNo string) (*app_model.PrintBill, error) { func (p *PrintBill) QueryPrintBill(userId, printNo string) (*app_model.PrintBill, error) {
result, err := dao.QueryPrintBill(userId, printNo) result, err := dao.QueryPrintBill(nil, userId, printNo)
if err != nil { if err != nil {
return nil, err return nil, err
} }