74 lines
2.1 KiB
Go
74 lines
2.1 KiB
Go
package zjdg
|
||
|
||
import (
|
||
"context"
|
||
"errors"
|
||
"fmt"
|
||
"github.com/zeromicro/go-zero/core/logx"
|
||
"net/url"
|
||
"repository.lenntc.com/lenntc/third-platform-sdk/client"
|
||
"repository.lenntc.com/lenntc/third-platform-sdk/util"
|
||
)
|
||
|
||
// ZjdgApi 中捷乐淘-淘宝一分购
|
||
type ZjdgApi interface {
|
||
// ZoneAdd 获取推广编号-创建
|
||
ZoneAdd(ctx context.Context, req ZoneAddRequest) (*ZoneAddResponse, error)
|
||
// GenerateH5Url 生成H5链接
|
||
GenerateH5Url(ctx context.Context, req GenerateH5UrlRequest) (string, error)
|
||
}
|
||
type zjdgApiImpl struct {
|
||
log logx.Logger
|
||
client *Client
|
||
}
|
||
|
||
func newZjdgApiImpl(log logx.Logger, client *Client) ZjdgApi {
|
||
return &zjdgApiImpl{
|
||
log: log,
|
||
client: client,
|
||
}
|
||
}
|
||
|
||
// ZoneAdd 获取推广编号
|
||
func (a *zjdgApiImpl) ZoneAdd(ctx context.Context, req ZoneAddRequest) (*ZoneAddResponse, error) {
|
||
// 响应示例 {"code":0,"message":"获取成功","data":"1963667","token_id":""}
|
||
zoneAddUrl := fmt.Sprintf("%s%s", ZoneAddUrl, a.client.authConfig.UserId)
|
||
args := util.StructToMap(req)
|
||
request := &client.HttpRequest{Headers: a.client.headers, QueryArgs: args}
|
||
response := new(ZoneAddOriginResponse)
|
||
if err := a.client.HttpGet(zoneAddUrl, request, &client.HttpResponse{Result: response}); err != nil {
|
||
return nil, err
|
||
}
|
||
if response.Code != 0 {
|
||
return nil, fmt.Errorf("获取推广编号失败，返回Code=%d", response.Code)
|
||
}
|
||
return &ZoneAddResponse{
|
||
AdZoneId: response.Data,
|
||
}, nil
|
||
}
|
||
|
||
func (a *zjdgApiImpl) GenerateH5Url(ctx context.Context, req GenerateH5UrlRequest) (string, error) {
|
||
u, err := url.Parse(req.ActivityUrl)
|
||
if err != nil {
|
||
return "", errors.New("activityUrl不是一个url")
|
||
}
|
||
urlParams := u.Query()
|
||
for key, item := range urlParams {
|
||
if key == "adzoneid" {
|
||
urlParams.Set("adzoneid", req.Sid)
|
||
} else if key == "userid" {
|
||
urlParams.Set("userid", a.client.authConfig.UserId)
|
||
} else {
|
||
if len(item) > 0 {
|
||
urlParams.Set(key, item[0])
|
||
} else {
|
||
urlParams.Set(key, "")
|
||
}
|
||
}
|
||
fmt.Println(fmt.Sprintf("key=%s,val=%s,len=%d", key, item, len(item)))
|
||
}
|
||
u.RawQuery = urlParams.Encode()
|
||
|
||
return u.String(), nil
|
||
}
|