From 16308a1f623c1521760ddb1de4bacd1dafa673be Mon Sep 17 00:00:00 2001 From: wukesheng Date: Fri, 17 May 2024 11:45:26 +0800 Subject: [PATCH] =?UTF-8?q?elem=E6=B7=BB=E5=8A=A0=E6=8E=A8=E5=B9=BF?= =?UTF-8?q?=E4=BD=8Dapi?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- platform/didi-union/api.go | 72 +++++++++++++++++--------- platform/eleme-union/api.go | 89 +++++++++++++++++++++++++++----- platform/eleme-union/api_test.go | 2 +- 3 files changed, 125 insertions(+), 38 deletions(-) diff --git a/platform/didi-union/api.go b/platform/didi-union/api.go index 0bad328..d17f4e8 100644 --- a/platform/didi-union/api.go +++ b/platform/didi-union/api.go @@ -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) { resp, err := d.client.clt.GenerateH5Link(ctx, req.ActivityID, req.PromotionID, req.SourceID, opt) 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 } 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) } var result *GenerateLinkResponse 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 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) { resp, err := d.client.clt.GenerateMiniLink(ctx, req.ActivityID, req.PromotionID, req.SourceID, opt) 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 } 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) } var result *GenerateLinkResponse 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 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) { resp, err := d.client.clt.GenerateAlipayMiniLink(ctx, req.ActivityID, req.PromotionID, req.SourceID, opt) 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 } 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) } var result *GenerateLinkResponse 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 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) { resp, err := d.client.clt.GenerateH5Code(ctx, req.Dsi, req.SourceID, opt) 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 } 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) } var result *GenerateCodeResponse 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 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) { resp, err := d.client.clt.GenerateMiniCode(ctx, req.Dsi, req.SourceID, opt) 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 } 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) } var result *GenerateCodeResponse 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 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) { resp, err := d.client.clt.GeneratePoster(ctx, req.Dsi, req.SourceID, opt) 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 } 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) } var result *GeneratePosterResponse 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 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) { resp, err := d.client.clt.QueryOrderList(ctx, req.StartTime, req.EndTime, string(req.Typ), req.Page, req.Size, opt) 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 } 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) } var result *QueryOrderListResponse 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 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) { resp, err := d.client.clt.SelfQueryOrder(ctx, req.OrderID, opt) 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 } 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) } var result *SelfQueryOrderResponse 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 result, nil diff --git a/platform/eleme-union/api.go b/platform/eleme-union/api.go index 265f948..7178b47 100644 --- a/platform/eleme-union/api.go +++ b/platform/eleme-union/api.go @@ -3,8 +3,8 @@ package eleme_union import ( "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/response" sdkutil "gitee.com/chengdu-lenntc/third-platform-sdk/sdk/topsdk/util" "gitee.com/chengdu-lenntc/third-platform-sdk/util" ) @@ -15,11 +15,15 @@ type ElemeUnionApi interface { // Sign 签名 Sign(publicParam PublicParam, data map[string]interface{}) string // KbItemPromotionShareCreate 本地生活媒体创建商品推广链接 - KbItemPromotionShareCreate(req *request.AlibabaAlscUnionKbItemPromotionShareCreateRequest) (*response.AlibabaAlscUnionKbItemPromotionShareCreateResponse, error) + KbItemPromotionShareCreate(req *request.AlibabaAlscUnionKbItemPromotionShareCreateRequest) (*domain.AlibabaAlscUnionKbItemPromotionShareCreateExtendDTO, error) // 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(req *request.AlibabaAlscUnionKbcpxPositiveOrderGetRequest) (*response.AlibabaAlscUnionKbcpxPositiveOrderGetResponse, error) + KbcpxPositiveOrderGet(req *request.AlibabaAlscUnionKbcpxPositiveOrderGetRequest) ([]*domain.AlibabaAlscUnionKbcpxPositiveOrderGetOrderDetailReportDTO, error) } type elemeUnionApiImpl struct { @@ -42,31 +46,90 @@ func (a *elemeUnionApiImpl) Sign(publicParam PublicParam, data map[string]interf } // 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) 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 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 本地联盟饿了么推广官方活动查询 -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) 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 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 本地生活媒体推广订单明细报表查询 -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) 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 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 } diff --git a/platform/eleme-union/api_test.go b/platform/eleme-union/api_test.go index 690002e..84c31f7 100644 --- a/platform/eleme-union/api_test.go +++ b/platform/eleme-union/api_test.go @@ -56,7 +56,7 @@ func (a *apiClientSuite) Test_ElemePromotionOfficialActivityGet() { req := &request.AlibabaAlscUnionElemePromotionOfficialactivityGetRequest{ QueryRequest: &domain.AlibabaAlscUnionElemePromotionOfficialactivityGetActivityRequest{ Pid: pointer.String("alsc_23378482_4796002_15513017"), - ActivityId: pointer.String("10690"), + ActivityId: pointer.String("10690111"), }, } resp, err := a.api.ElemePromotionOfficialActivityGet(req)