diff --git a/examples/main_xa.go b/examples/main_xa.go index 3efebef..8bfbf49 100644 --- a/examples/main_xa.go +++ b/examples/main_xa.go @@ -13,26 +13,6 @@ import ( // XaClient XA client connection var XaClient *dtmcli.XaClient = nil -// UserAccount busi model -type UserAccount struct { - common.ModelBase - UserID int - Balance string -} - -// TableName gorm table name -func (u *UserAccount) TableName() string { return "dtm_busi.user_account" } - -// UserAccountTrading freeze user account table -type UserAccountTrading struct { - common.ModelBase - UserID int - TradingBalance string -} - -// TableName gorm table name -func (u *UserAccountTrading) TableName() string { return "dtm_busi.user_account_trading" } - func dbGet() *common.DB { return common.DbGet(config.DB) } diff --git a/examples/quick_start.go b/examples/quick_start.go index d4c48d2..3b3810d 100644 --- a/examples/quick_start.go +++ b/examples/quick_start.go @@ -8,7 +8,6 @@ import ( "github.com/sirupsen/logrus" "github.com/yedf/dtm/common" "github.com/yedf/dtm/dtmcli" - "gorm.io/gorm" ) // 启动命令:go run app/main.go qs @@ -44,13 +43,8 @@ func QsFireRequest() string { } func qsAdjustBalance(uid int, amount int) (interface{}, error) { - err := dbGet().Transaction(func(tx *gorm.DB) error { - return tx.Model(&UserAccount{}).Where("user_id = ?", uid).Update("balance", gorm.Expr("balance + ?", amount)).Error - }) - if err != nil { - return nil, err - } - return M{"dtm_result": "SUCCESS"}, nil + _, err := common.SdbExec(sdbGet(), "update dtm_busi.user_account set balance = balance + ? where user_id = ?", amount, uid) + return M{"dtm_result": "SUCCESS"}, err } func qsAddRoute(app *gin.Engine) {