in seata/gateway/server_b/server_b.go [33:87]
func main() {
r := gin.Default()
r.POST("/service-b/try", func(context *gin.Context) {
account := &Account{}
err := context.ShouldBindJSON(account)
if err == nil {
context.JSON(200, gin.H{
"success": true,
"message": fmt.Sprintf("account %d tried!", account.ID),
})
return
}
context.JSON(400, gin.H{
"success": false,
"message": err.Error(),
})
})
r.POST("/service-b/confirm", func(context *gin.Context) {
account := &Account{}
err := context.BindJSON(account)
if err == nil {
fmt.Println(fmt.Sprintf("account %d confirmed!", account.ID))
context.JSON(200, gin.H{
"success": true,
"message": fmt.Sprintf("account %d confirmed!", account.ID),
})
return
}
context.JSON(400, gin.H{
"success": false,
"message": err.Error(),
})
})
r.POST("/service-b/cancel", func(context *gin.Context) {
account := &Account{}
err := context.BindJSON(account)
if err == nil {
fmt.Println(fmt.Sprintf("account %d canceled!", account.ID))
context.JSON(200, gin.H{
"success": true,
"message": fmt.Sprintf("account %d canceled!", account.ID),
})
return
}
context.JSON(400, gin.H{
"success": false,
"message": err.Error(),
})
})
r.Run(":8081")
}