89 lines
2.4 KiB
Go
89 lines
2.4 KiB
Go
package dtmsvr
|
|
|
|
import (
|
|
"errors"
|
|
|
|
"github.com/gin-gonic/gin"
|
|
"github.com/yedf/dtm/common"
|
|
"github.com/yedf/dtm/dtmcli"
|
|
"gorm.io/gorm"
|
|
)
|
|
|
|
func addRoute(engine *gin.Engine) {
|
|
engine.POST("/api/dtmsvr/prepare", common.WrapHandler(prepare))
|
|
engine.POST("/api/dtmsvr/submit", common.WrapHandler(submit))
|
|
engine.POST("/api/dtmsvr/registerXaBranch", common.WrapHandler(registerXaBranch))
|
|
engine.POST("/api/dtmsvr/registerTccBranch", common.WrapHandler(registerTccBranch))
|
|
engine.POST("/api/dtmsvr/abort", common.WrapHandler(abort))
|
|
engine.GET("/api/dtmsvr/query", common.WrapHandler(query))
|
|
engine.GET("/api/dtmsvr/all", common.WrapHandler(all))
|
|
engine.GET("/api/dtmsvr/newGid", common.WrapHandler(newGid))
|
|
}
|
|
|
|
func newGid(c *gin.Context) (interface{}, error) {
|
|
return M{"gid": GenGid(), "dtm_result": dtmcli.ResultSuccess}, nil
|
|
}
|
|
|
|
func prepare(c *gin.Context) (interface{}, error) {
|
|
t := TransFromContext(c)
|
|
t.Status = dtmcli.StatusPrepared
|
|
t.saveNew(dbGet())
|
|
return dtmcli.MapSuccess, nil
|
|
}
|
|
|
|
func submit(c *gin.Context) (interface{}, error) {
|
|
return svcSubmit(TransFromContext(c), c.Query("wait_result") == "1")
|
|
}
|
|
|
|
func abort(c *gin.Context) (interface{}, error) {
|
|
return svcAbort(TransFromContext(c), c.Query("wait_result") == "1")
|
|
}
|
|
|
|
func registerXaBranch(c *gin.Context) (interface{}, error) {
|
|
branch := TransBranch{}
|
|
err := c.BindJSON(&branch)
|
|
e2p(err)
|
|
return svcRegisterXaBranch(&branch)
|
|
}
|
|
|
|
func registerTccBranch(c *gin.Context) (interface{}, error) {
|
|
data := dtmcli.MS{}
|
|
err := c.BindJSON(&data)
|
|
e2p(err)
|
|
branch := TransBranch{
|
|
Gid: data["gid"],
|
|
BranchID: data["branch_id"],
|
|
Status: dtmcli.StatusPrepared,
|
|
Data: data["data"],
|
|
}
|
|
return svcRegisterTccBranch(&branch, data)
|
|
}
|
|
|
|
func query(c *gin.Context) (interface{}, error) {
|
|
gid := c.Query("gid")
|
|
if gid == "" {
|
|
return nil, errors.New("no gid specified")
|
|
}
|
|
trans := TransGlobal{}
|
|
db := dbGet()
|
|
db.Begin()
|
|
dbr := db.Must().Where("gid", gid).First(&trans)
|
|
if dbr.Error == gorm.ErrRecordNotFound {
|
|
return M{"transaction": nil, "branches": [0]int{}}, nil
|
|
}
|
|
branches := []TransBranch{}
|
|
db.Must().Where("gid", gid).Find(&branches)
|
|
return M{"transaction": trans, "branches": branches}, nil
|
|
}
|
|
|
|
func all(c *gin.Context) (interface{}, error) {
|
|
lastId := c.Query("last_id")
|
|
if lastId == "" {
|
|
lastId = "2000000000"
|
|
}
|
|
lid := dtmcli.MustAtoi(lastId)
|
|
trans := []TransGlobal{}
|
|
dbGet().Must().Where("id < ?", lid).Order("id desc").Limit(100).Find(&trans)
|
|
return M{"transactions": trans}, nil
|
|
}
|