package comm

import (
	"encoding/json"
	"fmt"
	"log"

	"github.com/assimon/luuu/model/request"
	"github.com/assimon/luuu/model/service"
	"github.com/assimon/luuu/util/constant"
	"github.com/labstack/echo/v4"
)

// CreateTransaction 创建交易
func (c *BaseCommController) CreateTransaction(ctx echo.Context) (err error) {
	req := new(request.CreateTransactionRequest)
	if err = ctx.Bind(req); err != nil {
		return c.FailJson(ctx, constant.ParamsMarshalErr)
	}
	if err = c.ValidateStruct(ctx, req); err != nil {
		return c.FailJson(ctx, err)
	}
	resp, err := service.CreateTransaction(req)
	if err != nil {
		return c.FailJson(ctx, err)
	}
	return c.SucJson(ctx, resp)
}

// SwitchNetwork 切换支付网络，创建或返回子订单
func (c *BaseCommController) SwitchNetwork(ctx echo.Context) (err error) {
	req := new(request.SwitchNetworkRequest)
	if err = ctx.Bind(req); err != nil {
		return c.FailJson(ctx, constant.ParamsMarshalErr)
	}
	if err = c.ValidateStruct(ctx, req); err != nil {
		return c.FailJson(ctx, err)
	}
	resp, err := service.SwitchNetwork(req)
	if err != nil {
		return c.FailJson(ctx, err)
	}

	jsonBytes, err := json.MarshalIndent(resp, "", "  ")
	if err != nil {
		return c.FailJson(ctx, err)
	}

	fmt.Printf("switch network response: \n%s", string(jsonBytes))

	return c.SucJson(ctx, resp)
}

func (c *BaseCommController) CreateTransactionAndRedirect(ctx echo.Context) (err error) {
	req := new(request.CreateTransactionRequest)
	if err = ctx.Bind(req); err != nil {
		log.Println("bind request error:", err)
		return c.FailJson(ctx, constant.ParamsMarshalErr)
	}
	if err = c.ValidateStruct(ctx, req); err != nil {
		log.Println("validate request error:", err)
		return c.FailJson(ctx, err)
	}
	resp, err := service.CreateTransaction(req)
	if err != nil {
		log.Println("create transaction error:", err)
		return c.FailJson(ctx, err)
	}

	fmt.Printf("create transaction response: %+v\n", resp)

	tradeID := resp.TradeId

	ctx.Redirect(302, "/pay/checkout-counter/"+tradeID)

	return nil

}