package main

import (
	"database/sql"
	"github.com/gin-gonic/gin"
	_ "github.com/go-sql-driver/mysql"
	"log"
	"net/http"
)

var DB *sql.DB

func init() {
	db, err := sql.Open("mysql", "root:mashibing@tcp(192.168.177.131:3306)/saga?charset=utf8mb4&parseTime=True&loc=Local")
	if err != nil {
		log.Fatalln(err)
	}
	DB = db
}

type Req struct {
	Quantity int    `json:"quantity"`
	Id       int    `json:"id"`
	TxId     string `json:"tx_id"`
}

func main() {
	r := gin.Default()

	r.POST("/order-create", func(c *gin.Context) {
		req := &Req{}
		if err := c.BindJSON(req); err != nil {
			log.Fatalln(err)
		}
		// 创建订单和订单商品记录

		query := "insert into orders values (null, ?, 'confirmed', 1024)"
		result, err := DB.Exec(query, req.TxId)
		if err != nil {
			c.JSON(http.StatusOK, gin.H{"dtm_result": "FAILURE", "message": "order create failed"})
			return
		}
		orderId, err := result.LastInsertId()
		if err != nil {
			c.JSON(http.StatusOK, gin.H{"dtm_result": "FAILURE", "message": "order create failed"})
			return
		}
		query = "insert into order_products values (?, ?, ?, 99)"
		if _, err := DB.Exec(query, orderId, req.Id, req.Quantity); err != nil {
			c.JSON(http.StatusOK, gin.H{"dtm_result": "FAILURE", "message": "order products create failed"})
			return
		}

		c.JSON(http.StatusOK, gin.H{"dtm_result": "SUCCESS"})

	})
	r.POST("/order-create-compensate", func(c *gin.Context) {
		// 确认，生成订单信息，插入 orders 和 order_products 表记录，本例中，仅使用 order_products 表
		req := &Req{}
		if err := c.BindJSON(req); err != nil {
			log.Fatalln(err)
		}
		// 将订单状态更新为未确认
		query := "update orders set status='not confirmed' where tx_id=?"
		if _, err := DB.Exec(query, req.TxId); err != nil {
			c.JSON(http.StatusOK, gin.H{"dtm_result": "FAILURE", "message": "compensate order status failed"})
			return
		}

		c.JSON(http.StatusOK, gin.H{"dtm_result": "SUCCESS"})
	})

	r.Run(":8081")
}