elem添加推广位api
This commit is contained in:
parent
701b72bf89
commit
16308a1f62
@ -62,16 +62,19 @@ func (d *didiUnionApiImpl) Sign(params map[string]any) string {
|
|||||||
func (d *didiUnionApiImpl) GenerateH5Link(ctx context.Context, req GenerateLinkRequest, opt model.Option) (*GenerateLinkResponse, error) {
|
func (d *didiUnionApiImpl) GenerateH5Link(ctx context.Context, req GenerateLinkRequest, opt model.Option) (*GenerateLinkResponse, error) {
|
||||||
resp, err := d.client.clt.GenerateH5Link(ctx, req.ActivityID, req.PromotionID, req.SourceID, opt)
|
resp, err := d.client.clt.GenerateH5Link(ctx, req.ActivityID, req.PromotionID, req.SourceID, opt)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
d.log.WithFields(logx.LogField{Key: "req", Value: req}).Errorf("[didiUnionApiImpl][GenerateH5Link] get link http request error, error: %v", err)
|
d.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": resp}}).
|
||||||
|
Errorf("[didiUnionApiImpl][GenerateH5Link] get link http request error, error: %v", err)
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
if resp.Errno > 0 {
|
if resp.Errno > 0 {
|
||||||
d.log.WithFields(logx.LogField{Key: "req", Value: req}).Errorf("[didiUnionApiImpl][GenerateH5Link] get link error, error: %v", resp.ErrorMsg())
|
d.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": resp}}).
|
||||||
|
Errorf("[didiUnionApiImpl][GenerateH5Link] get link error, error: %v", resp.ErrorMsg())
|
||||||
return nil, errors.New(resp.ErrMsg)
|
return nil, errors.New(resp.ErrMsg)
|
||||||
}
|
}
|
||||||
var result *GenerateLinkResponse
|
var result *GenerateLinkResponse
|
||||||
if err := xcopy.SetJSONTag(false).Copy(&result, resp.Data); err != nil {
|
if err := xcopy.SetJSONTag(false).Copy(&result, resp.Data); err != nil {
|
||||||
d.log.WithFields(logx.LogField{Key: "req", Value: req}).Errorf("[didiUnionApiImpl][GenerateH5Link] copy resp to result error, error: %v", err)
|
d.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": resp}}).
|
||||||
|
Errorf("[didiUnionApiImpl][GenerateH5Link] copy resp to result error, error: %v", err)
|
||||||
return nil, errors.New(resp.ErrMsg)
|
return nil, errors.New(resp.ErrMsg)
|
||||||
}
|
}
|
||||||
return result, nil
|
return result, nil
|
||||||
@ -81,16 +84,19 @@ func (d *didiUnionApiImpl) GenerateH5Link(ctx context.Context, req GenerateLinkR
|
|||||||
func (d *didiUnionApiImpl) GenerateMiniLink(ctx context.Context, req GenerateLinkRequest, opt model.Option) (*GenerateLinkResponse, error) {
|
func (d *didiUnionApiImpl) GenerateMiniLink(ctx context.Context, req GenerateLinkRequest, opt model.Option) (*GenerateLinkResponse, error) {
|
||||||
resp, err := d.client.clt.GenerateMiniLink(ctx, req.ActivityID, req.PromotionID, req.SourceID, opt)
|
resp, err := d.client.clt.GenerateMiniLink(ctx, req.ActivityID, req.PromotionID, req.SourceID, opt)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
d.log.WithFields(logx.LogField{Key: "req", Value: req}).Errorf("[didiUnionApiImpl][GenerateMiniLink] http request error, error: %v", err)
|
d.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": resp}}).
|
||||||
|
Errorf("[didiUnionApiImpl][GenerateMiniLink] http request error, error: %v", err)
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
if resp.Errno > 0 {
|
if resp.Errno > 0 {
|
||||||
d.log.WithFields(logx.LogField{Key: "req", Value: req}).Errorf("[didiUnionApiImpl][GenerateMiniLink] get link error, error: %v", resp.ErrorMsg())
|
d.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": resp}}).
|
||||||
|
Errorf("[didiUnionApiImpl][GenerateMiniLink] get link error, error: %v", resp.ErrorMsg())
|
||||||
return nil, errors.New(resp.ErrMsg)
|
return nil, errors.New(resp.ErrMsg)
|
||||||
}
|
}
|
||||||
var result *GenerateLinkResponse
|
var result *GenerateLinkResponse
|
||||||
if err := xcopy.SetJSONTag(false).Copy(&result, resp.Data); err != nil {
|
if err := xcopy.SetJSONTag(false).Copy(&result, resp.Data); err != nil {
|
||||||
d.log.WithFields(logx.LogField{Key: "req", Value: req}).Errorf("[didiUnionApiImpl][GenerateMiniLink] copy resp to result error, error: %v", err)
|
d.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": resp}}).
|
||||||
|
Errorf("[didiUnionApiImpl][GenerateMiniLink] copy resp to result error, error: %v", err)
|
||||||
return nil, errors.New(resp.ErrMsg)
|
return nil, errors.New(resp.ErrMsg)
|
||||||
}
|
}
|
||||||
return result, nil
|
return result, nil
|
||||||
@ -100,16 +106,19 @@ func (d *didiUnionApiImpl) GenerateMiniLink(ctx context.Context, req GenerateLin
|
|||||||
func (d *didiUnionApiImpl) GenerateAlipayMiniLink(ctx context.Context, req GenerateLinkRequest, opt model.Option) (*GenerateLinkResponse, error) {
|
func (d *didiUnionApiImpl) GenerateAlipayMiniLink(ctx context.Context, req GenerateLinkRequest, opt model.Option) (*GenerateLinkResponse, error) {
|
||||||
resp, err := d.client.clt.GenerateAlipayMiniLink(ctx, req.ActivityID, req.PromotionID, req.SourceID, opt)
|
resp, err := d.client.clt.GenerateAlipayMiniLink(ctx, req.ActivityID, req.PromotionID, req.SourceID, opt)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
d.log.WithFields(logx.LogField{Key: "req", Value: req}).Errorf("[didiUnionApiImpl][GenerateAlipayMiniLink] http request error, error: %v", err)
|
d.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": resp}}).
|
||||||
|
Errorf("[didiUnionApiImpl][GenerateAlipayMiniLink] http request error, error: %v", err)
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
if resp.Errno > 0 {
|
if resp.Errno > 0 {
|
||||||
d.log.WithFields(logx.LogField{Key: "req", Value: req}).Errorf("[didiUnionApiImpl][GenerateAlipayMiniLink] get link error, error: %v", resp.ErrorMsg())
|
d.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": resp}}).
|
||||||
|
Errorf("[didiUnionApiImpl][GenerateAlipayMiniLink] get link error, error: %v", resp.ErrorMsg())
|
||||||
return nil, errors.New(resp.ErrMsg)
|
return nil, errors.New(resp.ErrMsg)
|
||||||
}
|
}
|
||||||
var result *GenerateLinkResponse
|
var result *GenerateLinkResponse
|
||||||
if err := xcopy.SetJSONTag(false).Copy(&result, resp.Data); err != nil {
|
if err := xcopy.SetJSONTag(false).Copy(&result, resp.Data); err != nil {
|
||||||
d.log.WithFields(logx.LogField{Key: "req", Value: req}).Errorf("[didiUnionApiImpl][GenerateAlipayMiniLink] copy resp to result error, error: %v", err)
|
d.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": resp}}).
|
||||||
|
Errorf("[didiUnionApiImpl][GenerateAlipayMiniLink] copy resp to result error, error: %v", err)
|
||||||
return nil, errors.New(resp.ErrMsg)
|
return nil, errors.New(resp.ErrMsg)
|
||||||
}
|
}
|
||||||
return result, nil
|
return result, nil
|
||||||
@ -119,16 +128,19 @@ func (d *didiUnionApiImpl) GenerateAlipayMiniLink(ctx context.Context, req Gener
|
|||||||
func (d *didiUnionApiImpl) GenerateH5Code(ctx context.Context, req GenerateCodeRequest, opt model.Option) (*GenerateCodeResponse, error) {
|
func (d *didiUnionApiImpl) GenerateH5Code(ctx context.Context, req GenerateCodeRequest, opt model.Option) (*GenerateCodeResponse, error) {
|
||||||
resp, err := d.client.clt.GenerateH5Code(ctx, req.Dsi, req.SourceID, opt)
|
resp, err := d.client.clt.GenerateH5Code(ctx, req.Dsi, req.SourceID, opt)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
d.log.WithFields(logx.LogField{Key: "req", Value: req}).Errorf("[didiUnionApiImpl][GenerateH5Code] http request error, error: %v", err)
|
d.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": resp}}).
|
||||||
|
Errorf("[didiUnionApiImpl][GenerateH5Code] http request error, error: %v", err)
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
if resp.Errno > 0 {
|
if resp.Errno > 0 {
|
||||||
d.log.WithFields(logx.LogField{Key: "req", Value: req}).Errorf("[didiUnionApiImpl][GenerateH5Code] get h5 code error, error: %v", resp.ErrorMsg())
|
d.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": resp}}).
|
||||||
|
Errorf("[didiUnionApiImpl][GenerateH5Code] get h5 code error, error: %v", resp.ErrorMsg())
|
||||||
return nil, errors.New(resp.ErrMsg)
|
return nil, errors.New(resp.ErrMsg)
|
||||||
}
|
}
|
||||||
var result *GenerateCodeResponse
|
var result *GenerateCodeResponse
|
||||||
if err := xcopy.SetJSONTag(false).Copy(&result, resp.Data); err != nil {
|
if err := xcopy.SetJSONTag(false).Copy(&result, resp.Data); err != nil {
|
||||||
d.log.WithFields(logx.LogField{Key: "req", Value: req}).Errorf("[didiUnionApiImpl][GenerateH5Code] copy resp to result error, error: %v", err)
|
d.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": resp}}).
|
||||||
|
Errorf("[didiUnionApiImpl][GenerateH5Code] copy resp to result error, error: %v", err)
|
||||||
return nil, errors.New(resp.ErrMsg)
|
return nil, errors.New(resp.ErrMsg)
|
||||||
}
|
}
|
||||||
return result, nil
|
return result, nil
|
||||||
@ -138,16 +150,19 @@ func (d *didiUnionApiImpl) GenerateH5Code(ctx context.Context, req GenerateCodeR
|
|||||||
func (d *didiUnionApiImpl) GenerateMiniCode(ctx context.Context, req GenerateCodeRequest, opt model.Option) (*GenerateCodeResponse, error) {
|
func (d *didiUnionApiImpl) GenerateMiniCode(ctx context.Context, req GenerateCodeRequest, opt model.Option) (*GenerateCodeResponse, error) {
|
||||||
resp, err := d.client.clt.GenerateMiniCode(ctx, req.Dsi, req.SourceID, opt)
|
resp, err := d.client.clt.GenerateMiniCode(ctx, req.Dsi, req.SourceID, opt)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
d.log.WithFields(logx.LogField{Key: "req", Value: req}).Errorf("[didiUnionApiImpl][GenerateMiniCode] http request error, error: %v", err)
|
d.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": resp}}).
|
||||||
|
Errorf("[didiUnionApiImpl][GenerateMiniCode] http request error, error: %v", err)
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
if resp.Errno > 0 {
|
if resp.Errno > 0 {
|
||||||
d.log.WithFields(logx.LogField{Key: "req", Value: req}).Errorf("[didiUnionApiImpl][GenerateMiniCode] get mini code error, error: %v", resp.ErrorMsg())
|
d.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": resp}}).
|
||||||
|
Errorf("[didiUnionApiImpl][GenerateMiniCode] get mini code error, error: %v", resp.ErrorMsg())
|
||||||
return nil, errors.New(resp.ErrMsg)
|
return nil, errors.New(resp.ErrMsg)
|
||||||
}
|
}
|
||||||
var result *GenerateCodeResponse
|
var result *GenerateCodeResponse
|
||||||
if err := xcopy.SetJSONTag(false).Copy(&result, resp.Data); err != nil {
|
if err := xcopy.SetJSONTag(false).Copy(&result, resp.Data); err != nil {
|
||||||
d.log.WithFields(logx.LogField{Key: "req", Value: req}).Errorf("[didiUnionApiImpl][GenerateMiniCode] copy resp to result error, error: %v", err)
|
d.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": resp}}).
|
||||||
|
Errorf("[didiUnionApiImpl][GenerateMiniCode] copy resp to result error, error: %v", err)
|
||||||
return nil, errors.New(resp.ErrMsg)
|
return nil, errors.New(resp.ErrMsg)
|
||||||
}
|
}
|
||||||
return result, nil
|
return result, nil
|
||||||
@ -157,16 +172,19 @@ func (d *didiUnionApiImpl) GenerateMiniCode(ctx context.Context, req GenerateCod
|
|||||||
func (d *didiUnionApiImpl) GeneratePoster(ctx context.Context, req GeneratePosterRequest, opt model.Option) (*GeneratePosterResponse, error) {
|
func (d *didiUnionApiImpl) GeneratePoster(ctx context.Context, req GeneratePosterRequest, opt model.Option) (*GeneratePosterResponse, error) {
|
||||||
resp, err := d.client.clt.GeneratePoster(ctx, req.Dsi, req.SourceID, opt)
|
resp, err := d.client.clt.GeneratePoster(ctx, req.Dsi, req.SourceID, opt)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
d.log.WithFields(logx.LogField{Key: "req", Value: req}).Errorf("[didiUnionApiImpl][GeneratePoster] http request error, error: %v", err)
|
d.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": resp}}).
|
||||||
|
Errorf("[didiUnionApiImpl][GeneratePoster] http request error, error: %v", err)
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
if resp.Errno > 0 {
|
if resp.Errno > 0 {
|
||||||
d.log.WithFields(logx.LogField{Key: "req", Value: req}).Errorf("[didiUnionApiImpl][GeneratePoster] generate poster error, error: %v", resp.ErrorMsg())
|
d.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": resp}}).
|
||||||
|
Errorf("[didiUnionApiImpl][GeneratePoster] generate poster error, error: %v", resp.ErrorMsg())
|
||||||
return nil, errors.New(resp.ErrMsg)
|
return nil, errors.New(resp.ErrMsg)
|
||||||
}
|
}
|
||||||
var result *GeneratePosterResponse
|
var result *GeneratePosterResponse
|
||||||
if err := xcopy.SetJSONTag(false).Copy(&result, resp.Data); err != nil {
|
if err := xcopy.SetJSONTag(false).Copy(&result, resp.Data); err != nil {
|
||||||
d.log.WithFields(logx.LogField{Key: "req", Value: req}).Errorf("[didiUnionApiImpl][GeneratePoster] copy resp to result error, error: %v", err)
|
d.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": resp}}).
|
||||||
|
Errorf("[didiUnionApiImpl][GeneratePoster] copy resp to result error, error: %v", err)
|
||||||
return nil, errors.New(resp.ErrMsg)
|
return nil, errors.New(resp.ErrMsg)
|
||||||
}
|
}
|
||||||
return result, nil
|
return result, nil
|
||||||
@ -176,16 +194,19 @@ func (d *didiUnionApiImpl) GeneratePoster(ctx context.Context, req GeneratePoste
|
|||||||
func (d *didiUnionApiImpl) QueryOrderList(ctx context.Context, req QueryOrderListRequest, opt model.Option) (*QueryOrderListResponse, error) {
|
func (d *didiUnionApiImpl) QueryOrderList(ctx context.Context, req QueryOrderListRequest, opt model.Option) (*QueryOrderListResponse, error) {
|
||||||
resp, err := d.client.clt.QueryOrderList(ctx, req.StartTime, req.EndTime, string(req.Typ), req.Page, req.Size, opt)
|
resp, err := d.client.clt.QueryOrderList(ctx, req.StartTime, req.EndTime, string(req.Typ), req.Page, req.Size, opt)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
d.log.WithFields(logx.LogField{Key: "req", Value: req}).Errorf("[didiUnionApiImpl][QueryOrderList] http request error, error: %v", err)
|
d.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": resp}}).
|
||||||
|
Errorf("[didiUnionApiImpl][QueryOrderList] http request error, error: %v", err)
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
if resp.Errno > 0 {
|
if resp.Errno > 0 {
|
||||||
d.log.WithFields(logx.LogField{Key: "req", Value: req}).Errorf("[didiUnionApiImpl][QueryOrderList] get order list error, error: %v", resp.ErrorMsg())
|
d.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": resp}}).
|
||||||
|
Errorf("[didiUnionApiImpl][QueryOrderList] get order list error, error: %v", resp.ErrorMsg())
|
||||||
return nil, errors.New(resp.ErrMsg)
|
return nil, errors.New(resp.ErrMsg)
|
||||||
}
|
}
|
||||||
var result *QueryOrderListResponse
|
var result *QueryOrderListResponse
|
||||||
if err := xcopy.SetJSONTag(false).Copy(&result, resp.Data); err != nil {
|
if err := xcopy.SetJSONTag(false).Copy(&result, resp.Data); err != nil {
|
||||||
d.log.WithFields(logx.LogField{Key: "req", Value: req}).Errorf("[didiUnionApiImpl][QueryOrderList] copy resp to result error, error: %v", err)
|
d.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": resp}}).
|
||||||
|
Errorf("[didiUnionApiImpl][QueryOrderList] copy resp to result error, error: %v", err)
|
||||||
return nil, errors.New(resp.ErrMsg)
|
return nil, errors.New(resp.ErrMsg)
|
||||||
}
|
}
|
||||||
return result, nil
|
return result, nil
|
||||||
@ -195,16 +216,19 @@ func (d *didiUnionApiImpl) QueryOrderList(ctx context.Context, req QueryOrderLis
|
|||||||
func (d *didiUnionApiImpl) SelfQueryOrder(ctx context.Context, req SelfQueryOrderRequest, opt model.Option) (*SelfQueryOrderResponse, error) {
|
func (d *didiUnionApiImpl) SelfQueryOrder(ctx context.Context, req SelfQueryOrderRequest, opt model.Option) (*SelfQueryOrderResponse, error) {
|
||||||
resp, err := d.client.clt.SelfQueryOrder(ctx, req.OrderID, opt)
|
resp, err := d.client.clt.SelfQueryOrder(ctx, req.OrderID, opt)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
d.log.WithFields(logx.LogField{Key: "req", Value: req}).Errorf("[didiUnionApiImpl][SelfQueryOrder] http request error, error: %v", err)
|
d.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": resp}}).
|
||||||
|
Errorf("[didiUnionApiImpl][SelfQueryOrder] http request error, error: %v", err)
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
if resp.Errno > 0 {
|
if resp.Errno > 0 {
|
||||||
d.log.WithFields(logx.LogField{Key: "req", Value: req}).Errorf("[didiUnionApiImpl][SelfQueryOrder] query self order error, error: %v", resp.ErrorMsg())
|
d.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": resp}}).
|
||||||
|
Errorf("[didiUnionApiImpl][SelfQueryOrder] query self order error, error: %v", resp.ErrorMsg())
|
||||||
return nil, errors.New(resp.ErrMsg)
|
return nil, errors.New(resp.ErrMsg)
|
||||||
}
|
}
|
||||||
var result *SelfQueryOrderResponse
|
var result *SelfQueryOrderResponse
|
||||||
if err := xcopy.SetJSONTag(false).Copy(&result, resp.Data); err != nil {
|
if err := xcopy.SetJSONTag(false).Copy(&result, resp.Data); err != nil {
|
||||||
d.log.WithFields(logx.LogField{Key: "req", Value: req}).Errorf("[didiUnionApiImpl][SelfQueryOrder] copy resp to result error, error: %v", err)
|
d.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": resp}}).
|
||||||
|
Errorf("[didiUnionApiImpl][SelfQueryOrder] copy resp to result error, error: %v", err)
|
||||||
return nil, errors.New(resp.ErrMsg)
|
return nil, errors.New(resp.ErrMsg)
|
||||||
}
|
}
|
||||||
return result, nil
|
return result, nil
|
||||||
|
|||||||
@ -3,8 +3,8 @@ package eleme_union
|
|||||||
import (
|
import (
|
||||||
"github.com/zeromicro/go-zero/core/logx"
|
"github.com/zeromicro/go-zero/core/logx"
|
||||||
|
|
||||||
|
"gitee.com/chengdu-lenntc/third-platform-sdk/sdk/topsdk/defaultability/domain"
|
||||||
"gitee.com/chengdu-lenntc/third-platform-sdk/sdk/topsdk/defaultability/request"
|
"gitee.com/chengdu-lenntc/third-platform-sdk/sdk/topsdk/defaultability/request"
|
||||||
"gitee.com/chengdu-lenntc/third-platform-sdk/sdk/topsdk/defaultability/response"
|
|
||||||
sdkutil "gitee.com/chengdu-lenntc/third-platform-sdk/sdk/topsdk/util"
|
sdkutil "gitee.com/chengdu-lenntc/third-platform-sdk/sdk/topsdk/util"
|
||||||
"gitee.com/chengdu-lenntc/third-platform-sdk/util"
|
"gitee.com/chengdu-lenntc/third-platform-sdk/util"
|
||||||
)
|
)
|
||||||
@ -15,11 +15,15 @@ type ElemeUnionApi interface {
|
|||||||
// Sign 签名
|
// Sign 签名
|
||||||
Sign(publicParam PublicParam, data map[string]interface{}) string
|
Sign(publicParam PublicParam, data map[string]interface{}) string
|
||||||
// KbItemPromotionShareCreate 本地生活媒体创建商品推广链接
|
// KbItemPromotionShareCreate 本地生活媒体创建商品推广链接
|
||||||
KbItemPromotionShareCreate(req *request.AlibabaAlscUnionKbItemPromotionShareCreateRequest) (*response.AlibabaAlscUnionKbItemPromotionShareCreateResponse, error)
|
KbItemPromotionShareCreate(req *request.AlibabaAlscUnionKbItemPromotionShareCreateRequest) (*domain.AlibabaAlscUnionKbItemPromotionShareCreateExtendDTO, error)
|
||||||
// ElemePromotionOfficialActivityGet 本地联盟饿了么推广官方活动查询
|
// ElemePromotionOfficialActivityGet 本地联盟饿了么推广官方活动查询
|
||||||
ElemePromotionOfficialActivityGet(req *request.AlibabaAlscUnionElemePromotionOfficialactivityGetRequest) (*response.AlibabaAlscUnionElemePromotionOfficialactivityGetResponse, error)
|
ElemePromotionOfficialActivityGet(req *request.AlibabaAlscUnionElemePromotionOfficialactivityGetRequest) (*domain.AlibabaAlscUnionElemePromotionOfficialactivityGetActivityPromotionDto, error)
|
||||||
|
// AlibabaAlscUnionMediaZoneAdd 本地生活媒体创建推广位
|
||||||
|
AlibabaAlscUnionMediaZoneAdd(req *request.AlibabaAlscUnionMediaZoneAddRequest) (*domain.AlibabaAlscUnionMediaZoneAddZoneInfoDTO, error)
|
||||||
|
// AlibabaAlscUnionMediaZoneGet 本地生活媒体查询推广位
|
||||||
|
AlibabaAlscUnionMediaZoneGet(req *request.AlibabaAlscUnionMediaZoneGetRequest) ([]*domain.AlibabaAlscUnionMediaZoneGetZoneInfoDTO, error)
|
||||||
// KbcpxPositiveOrderGet 本地生活媒体推广订单明细报表查询
|
// KbcpxPositiveOrderGet 本地生活媒体推广订单明细报表查询
|
||||||
KbcpxPositiveOrderGet(req *request.AlibabaAlscUnionKbcpxPositiveOrderGetRequest) (*response.AlibabaAlscUnionKbcpxPositiveOrderGetResponse, error)
|
KbcpxPositiveOrderGet(req *request.AlibabaAlscUnionKbcpxPositiveOrderGetRequest) ([]*domain.AlibabaAlscUnionKbcpxPositiveOrderGetOrderDetailReportDTO, error)
|
||||||
}
|
}
|
||||||
|
|
||||||
type elemeUnionApiImpl struct {
|
type elemeUnionApiImpl struct {
|
||||||
@ -42,31 +46,90 @@ func (a *elemeUnionApiImpl) Sign(publicParam PublicParam, data map[string]interf
|
|||||||
}
|
}
|
||||||
|
|
||||||
// KbItemPromotionShareCreate 本地生活媒体创建商品推广链接
|
// KbItemPromotionShareCreate 本地生活媒体创建商品推广链接
|
||||||
func (a *elemeUnionApiImpl) KbItemPromotionShareCreate(req *request.AlibabaAlscUnionKbItemPromotionShareCreateRequest) (*response.AlibabaAlscUnionKbItemPromotionShareCreateResponse, error) {
|
func (a *elemeUnionApiImpl) KbItemPromotionShareCreate(req *request.AlibabaAlscUnionKbItemPromotionShareCreateRequest) (*domain.AlibabaAlscUnionKbItemPromotionShareCreateExtendDTO, error) {
|
||||||
resp, err := a.client.abilityClient.AlibabaAlscUnionKbItemPromotionShareCreate(req)
|
resp, err := a.client.abilityClient.AlibabaAlscUnionKbItemPromotionShareCreate(req)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
a.log.WithFields(logx.LogField{Key: "req", Value: req}).Errorf("[elemeUnionApiImpl][GetLink] get link failed, error: %v", err)
|
a.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": resp}}).
|
||||||
|
Errorf("[elemeUnionApiImpl][GetLink] get link failed, error: %v", err)
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
return resp, nil
|
if !resp.ResultSuccess || resp.BizErrorCode != "" {
|
||||||
|
a.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": resp}}).
|
||||||
|
Errorf("[elemeUnionApiImpl][GetLink] response result error: %s", resp.BizErrorDesc)
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
|
||||||
|
return &resp.Result, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// ElemePromotionOfficialActivityGet 本地联盟饿了么推广官方活动查询
|
// ElemePromotionOfficialActivityGet 本地联盟饿了么推广官方活动查询
|
||||||
func (a *elemeUnionApiImpl) ElemePromotionOfficialActivityGet(req *request.AlibabaAlscUnionElemePromotionOfficialactivityGetRequest) (*response.AlibabaAlscUnionElemePromotionOfficialactivityGetResponse, error) {
|
func (a *elemeUnionApiImpl) ElemePromotionOfficialActivityGet(req *request.AlibabaAlscUnionElemePromotionOfficialactivityGetRequest) (*domain.AlibabaAlscUnionElemePromotionOfficialactivityGetActivityPromotionDto, error) {
|
||||||
resp, err := a.client.abilityClient.AlibabaAlscUnionElemePromotionOfficialactivityGet(req)
|
resp, err := a.client.abilityClient.AlibabaAlscUnionElemePromotionOfficialactivityGet(req)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
a.log.WithFields(logx.LogField{Key: "req", Value: req}).Errorf("[elemeUnionApiImpl][PromotionOfficialActivityGet] http request failed, error: %v", err)
|
a.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": resp}}).
|
||||||
|
Errorf("[elemeUnionApiImpl][PromotionOfficialActivityGet] http request failed, error: %v", err)
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
return resp, nil
|
if resp.ResultCode != 0 {
|
||||||
|
a.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": resp}}).
|
||||||
|
Errorf("[elemeUnionApiImpl][ElemePromotionOfficialActivityGet] response result error: %s", resp.Message)
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
return &resp.Data, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// AlibabaAlscUnionMediaZoneAdd 本地生活媒体创建推广位
|
||||||
|
func (a *elemeUnionApiImpl) AlibabaAlscUnionMediaZoneAdd(req *request.AlibabaAlscUnionMediaZoneAddRequest) (*domain.AlibabaAlscUnionMediaZoneAddZoneInfoDTO, error) {
|
||||||
|
resp, err := a.client.abilityClient.AlibabaAlscUnionMediaZoneAdd(req)
|
||||||
|
if err != nil {
|
||||||
|
a.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": resp}}).
|
||||||
|
Errorf("[elemeUnionApiImpl][AlibabaAlscUnionMediaZoneAdd] http request failed, error: %v", err)
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
if !resp.ResultSuccess || resp.BizErrorCode != 0 {
|
||||||
|
a.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": resp}}).
|
||||||
|
Errorf("[elemeUnionApiImpl][AlibabaAlscUnionMediaZoneAdd] response result error: %s", resp.BizErrorDesc)
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
return &resp.Result, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
// AlibabaAlscUnionMediaZoneGet 本地生活媒体查询推广位
|
||||||
|
func (a *elemeUnionApiImpl) AlibabaAlscUnionMediaZoneGet(req *request.AlibabaAlscUnionMediaZoneGetRequest) ([]*domain.AlibabaAlscUnionMediaZoneGetZoneInfoDTO, error) {
|
||||||
|
resp, err := a.client.abilityClient.AlibabaAlscUnionMediaZoneGet(req)
|
||||||
|
if err != nil {
|
||||||
|
a.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": resp}}).
|
||||||
|
Errorf("[elemeUnionApiImpl][AlibabaAlscUnionMediaZoneGet] http request failed, error: %v", err)
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
if !resp.ResultSuccess || resp.BizErrorCode != 0 {
|
||||||
|
a.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": resp}}).
|
||||||
|
Errorf("[elemeUnionApiImpl][AlibabaAlscUnionMediaZoneGet] response result error: %s", resp.BizErrorDesc)
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
var result []*domain.AlibabaAlscUnionMediaZoneGetZoneInfoDTO
|
||||||
|
for _, item := range resp.Result {
|
||||||
|
result = append(result, &item)
|
||||||
|
}
|
||||||
|
return result, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
// KbcpxPositiveOrderGet 本地生活媒体推广订单明细报表查询
|
// KbcpxPositiveOrderGet 本地生活媒体推广订单明细报表查询
|
||||||
func (a *elemeUnionApiImpl) KbcpxPositiveOrderGet(req *request.AlibabaAlscUnionKbcpxPositiveOrderGetRequest) (*response.AlibabaAlscUnionKbcpxPositiveOrderGetResponse, error) {
|
func (a *elemeUnionApiImpl) KbcpxPositiveOrderGet(req *request.AlibabaAlscUnionKbcpxPositiveOrderGetRequest) ([]*domain.AlibabaAlscUnionKbcpxPositiveOrderGetOrderDetailReportDTO, error) {
|
||||||
resp, err := a.client.abilityClient.AlibabaAlscUnionKbcpxPositiveOrderGet(req)
|
resp, err := a.client.abilityClient.AlibabaAlscUnionKbcpxPositiveOrderGet(req)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
a.log.WithFields(logx.LogField{Key: "req", Value: req}).Errorf("[elemeUnionApiImpl][GetPositiveOrders] get positive orders failed, error: %v", err)
|
a.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": resp}}).
|
||||||
|
Errorf("[elemeUnionApiImpl][KbcpxPositiveOrderGet] get positive orders failed, error: %v", err)
|
||||||
return nil, err
|
return nil, err
|
||||||
}
|
}
|
||||||
return resp, nil
|
if !resp.ResultSuccess || resp.BizErrorCode != 0 {
|
||||||
|
a.log.WithFields(logx.LogField{Key: "data", Value: map[string]any{"req": req, "resp": resp}}).
|
||||||
|
Errorf("[elemeUnionApiImpl][KbcpxPositiveOrderGet] response result error: %s", resp.BizErrorDesc)
|
||||||
|
return nil, err
|
||||||
|
}
|
||||||
|
var result []*domain.AlibabaAlscUnionKbcpxPositiveOrderGetOrderDetailReportDTO
|
||||||
|
for _, item := range resp.Result {
|
||||||
|
result = append(result, &item)
|
||||||
|
}
|
||||||
|
return result, nil
|
||||||
}
|
}
|
||||||
|
|||||||
@ -56,7 +56,7 @@ func (a *apiClientSuite) Test_ElemePromotionOfficialActivityGet() {
|
|||||||
req := &request.AlibabaAlscUnionElemePromotionOfficialactivityGetRequest{
|
req := &request.AlibabaAlscUnionElemePromotionOfficialactivityGetRequest{
|
||||||
QueryRequest: &domain.AlibabaAlscUnionElemePromotionOfficialactivityGetActivityRequest{
|
QueryRequest: &domain.AlibabaAlscUnionElemePromotionOfficialactivityGetActivityRequest{
|
||||||
Pid: pointer.String("alsc_23378482_4796002_15513017"),
|
Pid: pointer.String("alsc_23378482_4796002_15513017"),
|
||||||
ActivityId: pointer.String("10690"),
|
ActivityId: pointer.String("10690111"),
|
||||||
},
|
},
|
||||||
}
|
}
|
||||||
resp, err := a.api.ElemePromotionOfficialActivityGet(req)
|
resp, err := a.api.ElemePromotionOfficialActivityGet(req)
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user