diff --git a/business/q_bida/withdrawal_record_utils.go b/business/q_bida/withdrawal_record_utils.go index dc112495a..b70765ab5 100644 --- a/business/q_bida/withdrawal_record_utils.go +++ b/business/q_bida/withdrawal_record_utils.go @@ -5,6 +5,7 @@ import ( "git.rosy.net.cn/baseapi/utils" "git.rosy.net.cn/jx-callback/business/model" "git.rosy.net.cn/jx-callback/business/model/dao" + "git.rosy.net.cn/jx-callback/globals" "git.rosy.net.cn/jx-callback/globals/api" ) @@ -38,29 +39,30 @@ func SendPayInfo2Ali(payOrder *model.WithdrawalRecord, param *model.AddWithdrawa func UpdateUserMoney(payOrder *model.WithdrawalRecord, userBill *model.UserBill) error { // 如果支付成功 db := dao.GetDB() - tx, _ := dao.Begin(db) - defer func() { - if r := recover(); r != nil { - panic(r) - } - dao.Commit(db, tx) - }() + //tx, _ := dao.Begin(db) + //defer func() { + // if r := recover(); r != nil { + // panic(r) + // } + // dao.Commit(db, tx) + //}() switch payOrder.OrderStatus { case model.WithdrawalRecordPaySuccess: userBill.AccountBalance = userBill.AccountBalance - payOrder.WithdrawalMoney bill := &userBill - if _, err := dao.UpdateEntityTx(tx, bill, "AccountBalance"); err != nil { - dao.Rollback(db, tx) + if _, err := dao.UpdateEntity(db, bill, "AccountBalance"); err != nil { + globals.SugarLogger.Debug("err=======", err) + //dao.Rollback(db, tx) return err } - if err := dao.CreateEntityTx(tx, payOrder); err != nil { - dao.Rollback(db, tx) + if err := dao.CreateEntity(db, payOrder); err != nil { + // dao.Rollback(db, tx) return err } case model.WithdrawalWaitRecord, model.WithdrawalRecordFail, model.WithdrawalRecordPayFail: - if err := dao.CreateEntityTx(tx, payOrder); err != nil { - dao.Rollback(db, tx) + if err := dao.CreateEntity(db, payOrder); err != nil { + // dao.Rollback(db, tx) return err } }