third-platform-sdk/platform/meituan/api.go

package meituan

import (
	"context"
	"errors"
	"net/http"

	"github.com/zeromicro/go-zero/core/logx"

	"repository.lenntc.com/lenntc/third-platform-sdk/client"
	"repository.lenntc.com/lenntc/third-platform-sdk/util"
)

// MeituanApi 美团联盟 平台的api
type MeituanApi interface {
	// Sign 签名
	Sign(methodType string, url string, data map[string]interface{}) string
	// GenerateLink 获取推广链接
	GenerateLink(ctx context.Context, req GenerateLinkRequest) (*GenerateLinkResponse, error)
	// QueryOrderList 查询订单
	QueryOrderList(ctx context.Context, req QueryOrderListRequest) (*QueryOrderData, error)
	// QueryCouponList 查询商品
	QueryCouponList(ctx context.Context, req QueryCouponListRequest) (*QueryCouponListResponse, error)
}

type meituanApiImpl struct {
	log    logx.Logger
	client *Client
	sign   *Sign
}

func newMeituanApiImpl(log logx.Logger, client *Client, sign *Sign) MeituanApi {
	return &meituanApiImpl{
		log:    log,
		client: client,
		sign:   sign,
	}
}

// Sign 签名
func (a *meituanApiImpl) Sign(methodType string, uri string, data map[string]interface{}) string {
	headers := a.sign.BuildHeader(methodType, uri, data)
	if sign, ok := headers[SCaSignature]; ok {
		return sign
	}
	return ""
}

// GetLink 获取推广链接
func (a *meituanApiImpl) GenerateLink(ctx context.Context, req GenerateLinkRequest) (*GenerateLinkResponse, error) {
	args := util.StructToMap(req)
	headers := a.sign.BuildHeader(http.MethodPost, GetLinkUri, args)
	for k, v := range a.client.headers {
		headers[k] = v
	}
	request := &client.HttpRequest{Headers: headers, BodyArgs: args}
	response := new(GenerateLinkResponse)
	if err := a.client.HttpPost(GetLinkUrl, request, &client.HttpResponse{Result: response}); err != nil {
		return nil, err
	}
	if response.Code != 0 {
		a.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "args": args, "resp": response}}).
			Errorf("[meituanApiImpl][GenerateLink] response result error: %s", response.Message)
		return nil, errors.New(response.Message)
	}
	return response, nil
}

// QueryOrderList 查询订单
func (a *meituanApiImpl) QueryOrderList(ctx context.Context, req QueryOrderListRequest) (*QueryOrderData, error) {
	args := util.StructToMap(req)
	headers := a.sign.BuildHeader(http.MethodPost, GetOrderListUri, args)
	for k, v := range a.client.headers {
		headers[k] = v
	}
	request := &client.HttpRequest{Headers: headers, BodyArgs: args}
	response := new(QueryOrderListResponse)
	if err := a.client.HttpPost(GetOrderListUrl, request, &client.HttpResponse{Result: response}); err != nil {
		return nil, err
	}
	if response.Code != 0 {
		a.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": response}}).
			Errorf("[meituanApiImpl][QueryOrderList] response result error: %s", response.Message)
		return nil, errors.New(response.Message)
	}
	return response.Data, nil
}

// QueryCouponList 查询商品
func (a *meituanApiImpl) QueryCouponList(ctx context.Context, req QueryCouponListRequest) (*QueryCouponListResponse, error) {
	args := util.StructToMap(req)
	headers := a.sign.BuildHeader(http.MethodPost, GetProductListUri, args)
	for k, v := range a.client.headers {
		headers[k] = v
	}
	request := &client.HttpRequest{Headers: headers, BodyArgs: args}
	response := new(QueryCouponListResponse)
	if err := a.client.HttpPost(GetProductListUrl, request, &client.HttpResponse{Result: response}); err != nil {
		return nil, err
	}
	if response.Code != 0 {
		a.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": response}}).
			Errorf("[meituanApiImpl][QueryCouponList] response result error: %s", response.Message)
		return nil, errors.New(response.Message)
	}
	return response, nil
}