opensource/dtm
3
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

update travis

Browse Source
This commit is contained in:
yedongfu 2021-07-15 20:47:35 +08:00
parent 028be819ca
commit 681e43ba81
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
examples/main_xa.go
View File

@ -4,9 +4,9 @@ import (
"fmt" "fmt"
"github.com/gin-gonic/gin" "github.com/gin-gonic/gin"
"github.com/sirupsen/logrus"
"github.com/yedf/dtm/common" "github.com/yedf/dtm/common"
"github.com/yedf/dtm/dtmcli" "github.com/yedf/dtm/dtmcli"
"gorm.io/gorm"
) )
var XaClient *dtmcli.XaClient = nil var XaClient *dtmcli.XaClient = nil
@ -58,8 +58,7 @@ func xaTransIn(c *gin.Context) (interface{}, error) {
if req.TransInResult != "SUCCESS" { if req.TransInResult != "SUCCESS" {
return fmt.Errorf("tranIn failed") return fmt.Errorf("tranIn failed")
} }
dbr := db.Model(&UserAccount{}).Where("user_id = ?", 2). dbr := db.Exec("update user_account set balance=balance+? where user_id=?", req.Amount, 2)
Update("balance", gorm.Expr("balance + ?", req.Amount))
return dbr.Error return dbr.Error
}) })
e2p(err) e2p(err)
@ -72,8 +71,9 @@ func xaTransOut(c *gin.Context) (interface{}, error) {
if req.TransOutResult != "SUCCESS" { if req.TransOutResult != "SUCCESS" {
return fmt.Errorf("tranOut failed") return fmt.Errorf("tranOut failed")
} }
dbr := db.Model(&UserAccount{}).Where("user_id = ?", 1). logrus.Printf("before updating balance")
Update("balance", gorm.Expr("balance - ?", req.Amount)) dbr := db.Exec("update user_account set balance=balance-? where user_id=?", req.Amount, 1)
logrus.Printf("after updating balance")
return dbr.Error return dbr.Error
}) })
e2p(err) e2p(err)