package internal

import (
	"encoding/json"
	"fmt"
	"gitea.cdlsxd.cn/sdk/plugin/dctw/v1/api/card"
	"gitea.cdlsxd.cn/sdk/plugin/dctw/v1/core"
	"gitea.cdlsxd.cn/sdk/plugin/proto"
	"github.com/go-playground/validator/v10"
)

type Config struct {
	AppId      string `json:"app_id" validate:"required"`
	AppKey     string `json:"app_key" validate:"required"`
	BaseUri    string `json:"base_uri" validate:"required"`
	NotifyUrl  string `json:"notify_url" validate:"required"`
	MerchantId string `json:"merchant_id" validate:"required"`
}

func (c *Config) validate() error {
	err := validator.New().Struct(c)
	if err != nil {
		for _, err = range err.(validator.ValidationErrors) {
			return fmt.Errorf("配置参数有误：" + err.Error())
		}
	}
	return nil
}

func transConfig(config []byte) (*Config, error) {
	var c Config
	err := json.Unmarshal(config, &c)
	if err != nil {
		return nil, err
	}
	if err = c.validate(); err != nil {
		return nil, err
	}
	return &c, nil
}

func (c *Config) dctW() (*card.Card, error) {
	server, err := core.NewDctWServer(
		&core.DctWConfig{
			AppId:   c.AppId,
			AppKey:  c.AppKey,
			BaseUri: c.BaseUri,
		},
		core.WithDebug(false),
	)
	if err != nil {
		return nil, err
	}
	return &card.Card{DctWServer: server}, nil
}

func (c *Config) orderReq(in *proto.OrderRequest) *card.Order {
	return &card.Order{
		Number:     in.Order.Quantity,
		MerchantId: c.MerchantId,
		OutTradeNo: in.Order.OrderNo,
		ProductId:  in.Product.ProductNo,
		Mobile:     in.Order.Account,
		NotifyUrl:  c.NotifyUrl,
		Version:    "1.0",
	}
}

func orderResp(request *proto.OrderRequest, resp *card.OrderResp) *proto.OrderResponse {
	data, _ := json.Marshal(resp)
	return &proto.OrderResponse{
		Result: &proto.Result{
			Status:  proto.Status_ING,
			OrderNo: request.Order.OrderNo,
			TradeNo: resp.TradeNo,
			Message: resp.Message,
			Data:    data,
		},
	}
}

func (c *Config) queryReq(in *proto.QueryRequest) *card.Query {
	return &card.Query{
		MerchantId: c.AppId,
		OutTradeNo: in.Order.OrderNo,
		Version:    "1.0",
	}
}

func queryResp(request *proto.QueryRequest, resp *card.QueryResp, cardCode *card.CardCode) (*proto.QueryResponse, error) {
	data, _ := json.Marshal(resp)
	extra, _ := cardCode.Json()
	pb := &proto.QueryResponse{
		Result: &proto.Result{
			Status:  resp.Status.GetOrderStatus(),
			OrderNo: request.Order.OrderNo,
			TradeNo: request.Order.TradeNo,
			Message: resp.Message,
			Data:    data,
			Extra:   extra,
		},
	}
	return pb, nil
}

func notifyResp(resp *card.Notify, cardCode *card.CardCode) (*proto.NotifyResponse, error) {
	data, _ := json.Marshal(resp)
	extra, _ := cardCode.Json()
	pb := &proto.NotifyResponse{
		Result: &proto.Result{
			Status:  resp.Status.GetOrderStatus(),
			OrderNo: resp.OutTradeNo,
			TradeNo: resp.TradeNo,
			Message: resp.Status.GetOrderStatusText(),
			Data:    data,
			Extra:   extra,
		},
		Return: "success",
	}
	return pb, nil
}