diff --git a/compose.yml b/compose.yml index 17ec54e..ac85d9f 100644 --- a/compose.yml +++ b/compose.yml @@ -5,7 +5,7 @@ services: environment: IS_DOCKER_COMPOSE: '1' ports: - - '80:4005' + - '8080:8080' volumes: - .:/app/dtm mysql: diff --git a/dtmsvr/cron.go b/dtmsvr/cron.go index 341e254..082a9a9 100644 --- a/dtmsvr/cron.go +++ b/dtmsvr/cron.go @@ -27,9 +27,9 @@ func CronTransOnce(expireIn time.Duration, status string) bool { return true } -func CronCommitted() { +func CronSubmitted() { for { - notEmpty := CronTransOnce(time.Duration(0), "commitetd") + notEmpty := CronTransOnce(time.Duration(0), "submitted") if !notEmpty { sleepCronTime() } diff --git a/dtmsvr/main.go b/dtmsvr/main.go index b1c6a2f..7a8d8f7 100644 --- a/dtmsvr/main.go +++ b/dtmsvr/main.go @@ -13,7 +13,7 @@ var dtmsvrPort = 8080 func MainStart() { StartSvr() - go CronCommitted() + go CronSubmitted() go CronPrepared() } diff --git a/dtmsvr/trans_tcc.go b/dtmsvr/trans_tcc.go index 49b3444..6b7fb43 100644 --- a/dtmsvr/trans_tcc.go +++ b/dtmsvr/trans_tcc.go @@ -20,7 +20,7 @@ func (t *TransTccProcessor) GenBranches() []TransBranch { } func (t *TransTccProcessor) ExecBranch(db *common.DB, branch *TransBranch) { - resp, err := common.RestyClient.R().SetBody(branch.Data).SetQueryParams(t.getBranchParams(branch)).Post(branch.Url) + resp, err := common.RestyClient.R().SetBody(branch.Data).SetHeader("Content-type", "application/json").SetQueryParams(t.getBranchParams(branch)).Post(branch.Url) e2p(err) body := resp.String() if strings.Contains(body, "SUCCESS") {