71 lines
2.3 KiB
Go
71 lines
2.3 KiB
Go
package jutuike
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
|
|
"github.com/zeromicro/go-zero/core/logx"
|
|
|
|
"gitee.com/chengdu-lenntc/third-platform-sdk/client"
|
|
"gitee.com/chengdu-lenntc/third-platform-sdk/util"
|
|
)
|
|
|
|
// JutuikeApi 美团-美天赚
|
|
// Api defines the interface of jutuike api
|
|
type JutuikeApi interface {
|
|
// GenerateLink 生成推广链接
|
|
GenerateLink(ctx context.Context, req GenerateLinkRequest) (*GenerateLinkData, error)
|
|
// QueryOrderList 查询订单列表
|
|
QueryOrderList(ctx context.Context, req QueryOrderListRequest) (*QueryOrderListData, error)
|
|
}
|
|
|
|
type jutuikeApiImpl struct {
|
|
log logx.Logger
|
|
client *Client
|
|
}
|
|
|
|
func newJutuikeApiImpl(log logx.Logger, client *Client) JutuikeApi {
|
|
return &jutuikeApiImpl{
|
|
log: log,
|
|
client: client,
|
|
}
|
|
}
|
|
|
|
// GenerateLink 生成推广链接
|
|
func (a *jutuikeApiImpl) GenerateLink(ctx context.Context, req GenerateLinkRequest) (*GenerateLinkData, error) {
|
|
if len(req.ApiKey) == 0 {
|
|
req.ApiKey = a.client.authConfig.ApiKey
|
|
}
|
|
args := util.StructToMap(req)
|
|
request := &client.HttpRequest{Headers: a.client.headers, QueryArgs: args}
|
|
response := new(GenerateLinkResponse)
|
|
if err := a.client.HttpGet(GetLinkUrl, request, &client.HttpResponse{Result: response}); err != nil {
|
|
return nil, err
|
|
}
|
|
if response.Code != 1 {
|
|
a.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": response}}).
|
|
Errorf("[jutuikeApiImpl][GenerateLink] response result error: %s", response.Msg)
|
|
return nil, errors.New(response.Msg)
|
|
}
|
|
return response.Data, nil
|
|
}
|
|
|
|
// QueryOrderList 查询订单列表
|
|
func (a *jutuikeApiImpl) QueryOrderList(ctx context.Context, req QueryOrderListRequest) (*QueryOrderListData, error) {
|
|
if len(req.ApiKey) == 0 {
|
|
req.ApiKey = a.client.authConfig.ApiKey
|
|
}
|
|
args := util.StructToMap(req)
|
|
request := &client.HttpRequest{Headers: a.client.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 != 1 {
|
|
a.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": response}}).
|
|
Errorf("[jutuikeApiImpl][QueryOrderList] response result error: %s", response.Msg)
|
|
return nil, errors.New(response.Msg)
|
|
}
|
|
return response.Data, nil
|
|
}
|