diff --git a/app/main.go b/app/main.go index c161740..1e28dd3 100644 --- a/app/main.go +++ b/app/main.go @@ -31,7 +31,8 @@ func main() { } // quick_start 比较独立,单独作为一个例子运行,方便新人上手 if len(os.Args) > 1 && (os.Args[1] == "quick_start" || os.Args[1] == "qs") { - examples.QuickStarMain() + examples.QsStartSvr() + examples.QsFireRequest() wait() } diff --git a/dtmcli/tcc.go b/dtmcli/tcc.go index e6fe79e..e29f1dc 100644 --- a/dtmcli/tcc.go +++ b/dtmcli/tcc.go @@ -75,6 +75,7 @@ func (t *Tcc) CallBranch(body interface{}, tryURL string, confirmURL string, can return common.RestyClient.R(). SetBody(body). SetQueryParams(common.MS{ + "dtm": t.Dtm, "gid": t.Gid, "branch_id": branchID, "trans_type": "tcc", diff --git a/examples/main_tcc_barrier.go b/examples/main_tcc_barrier.go index 4c03c43..8e29935 100644 --- a/examples/main_tcc_barrier.go +++ b/examples/main_tcc_barrier.go @@ -68,7 +68,7 @@ func adjustBalance(sdb *sql.DB, uid int, amount int) (interface{}, error) { return nil, dbr.Error } if dbr.RowsAffected == 0 { - return nil, fmt.Errorf("update trading error") + return nil, fmt.Errorf("update 0 rows") } return "SUCCESS", nil } diff --git a/examples/quick_start.go b/examples/quick_start.go index 3dc06c2..335b6bc 100644 --- a/examples/quick_start.go +++ b/examples/quick_start.go @@ -18,12 +18,6 @@ const qsBusiPort = 8082 var qsBusi = fmt.Sprintf("http://localhost:%d%s", qsBusiPort, qsBusiAPI) -// QuickStarMain called by app/main.go -func QuickStarMain() { - QsStartSvr() - QsFireRequest() -} - // QsStartSvr 1 func QsStartSvr() { app := common.GetGinApp()