package mixrepoimpl

import (
	"context"
	"github.com/go-kratos/kratos/v2/log"
	"voucher/internal/biz/kx"
	"voucher/internal/biz/mixrepos"
	"voucher/internal/conf"
)

// KxMixRepoImpl kx 空港
type KxMixRepoImpl struct {
	bc *conf.Bootstrap
}

func NewKxMixRepoImpl(bc *conf.Bootstrap) mixrepos.KxMixRepo {
	return &KxMixRepoImpl{bc: bc}
}

func (s *KxMixRepoImpl) Request(ctx context.Context, req *kx.SynNotice) error {

	body, err := req.Marshal()
	if err != nil {
		log.Errorf("请求kx Marshal 报错:%s", err.Error())
		return err
	}

	log.Warnf("请求kx,reqBody:%s", string(body))

	//h := http.Header{
	//	"Content-Type": []string{"application/json"},
	//}
	//url := s.bc.Cmb.KxNoticeUrl
	//
	//_, bodyBytes, err := request.Post(ctx, url, body, request.WithHeaders(h), request.WithTimeout(time.Second*20))
	//if err != nil {
	//	log.Errorf("请求kx报错,url:%s,body:%s,err:%v", url, string(body), err)
	//	return err
	//}
	//
	//log.Warnf("请求kx,url:%s,reqBody:%s,respBody:%s", url, string(body), string(bodyBytes))

	//var response *v1.CmbReply
	//if err = json.Unmarshal(bodyBytes, &response); err != nil {
	//	log.Errorf("请求kx返回数据解析报错:%s,url:%s,reqBody:%s,respBody:%s", err.Error(), url, string(bodyBytes))
	//	return err
	//}
	//
	//if response.RespCode != vo.CmbResponseStatusSuccess.GetValue() {
	//	log.Errorf("请求kx返回报错:msg:%s,url:%s,respBody:%s", response.RespMsg, url, string(bodyBytes))
	//	return fmt.Errorf(response.RespMsg)
	//}

	return nil
}