topsdk/ability304/Ability304.go

package ability304

import (
	"errors"
	"git.sunqdl.cn/fgqj/topsdk"
	"git.sunqdl.cn/fgqj/topsdk/ability304/request"
	"git.sunqdl.cn/fgqj/topsdk/ability304/response"
	"git.sunqdl.cn/fgqj/topsdk/util"
	"log"
)

type Ability304 struct {
	Client *topsdk.TopClient
}

func NewAbility304(client *topsdk.TopClient) *Ability304 {
	return &Ability304{client}
}

/*
获取授权账号对应的OpenUid1
*/
func (ability *Ability304) TaobaoOpenuidGet(req *request.TaobaoOpenuidGetRequest, session string) (*response.TaobaoOpenuidGetResponse, error) {
	if ability.Client == nil {
		return nil, errors.New("Ability304 topClient is nil")
	}
	var jsonStr, err = ability.Client.ExecuteWithSession("taobao.openuid.get", req.ToMap(), req.ToFileMap(), session)
	var respStruct = response.TaobaoOpenuidGetResponse{}
	if err != nil {
		log.Println("taobaoOpenuidGet error", err)
		return &respStruct, err
	}
	err = util.HandleJsonResponse(jsonStr, &respStruct)
	if respStruct.Body == "" || len(respStruct.Body) == 0 {
		respStruct.Body = jsonStr
	}
	return &respStruct, err
}

/*
通过订单获取对应买家的openUID
*/
func (ability *Ability304) TaobaoOpenuidGetBytrade(req *request.TaobaoOpenuidGetBytradeRequest, session string) (*response.TaobaoOpenuidGetBytradeResponse, error) {
	if ability.Client == nil {
		return nil, errors.New("Ability304 topClient is nil")
	}
	var jsonStr, err = ability.Client.ExecuteWithSession("taobao.openuid.get.bytrade", req.ToMap(), req.ToFileMap(), session)
	var respStruct = response.TaobaoOpenuidGetBytradeResponse{}
	if err != nil {
		log.Println("taobaoOpenuidGetBytrade error", err)
		return &respStruct, err
	}
	err = util.HandleJsonResponse(jsonStr, &respStruct)
	if respStruct.Body == "" || len(respStruct.Body) == 0 {
		respStruct.Body = jsonStr
	}
	return &respStruct, err
}

/*
TOPDNS配置
*/
func (ability *Ability304) TaobaoHttpdnsGet(req *request.TaobaoHttpdnsGetRequest) (*response.TaobaoHttpdnsGetResponse, error) {
	if ability.Client == nil {
		return nil, errors.New("Ability304 topClient is nil")
	}
	var jsonStr, err = ability.Client.Execute("taobao.httpdns.get", req.ToMap(), req.ToFileMap())
	var respStruct = response.TaobaoHttpdnsGetResponse{}
	if err != nil {
		log.Println("taobaoHttpdnsGet error", err)
		return &respStruct, err
	}
	err = util.HandleJsonResponse(jsonStr, &respStruct)
	if respStruct.Body == "" || len(respStruct.Body) == 0 {
		respStruct.Body = jsonStr
	}
	return &respStruct, err
}

/*
获取TOP通道解密秘钥
*/
func (ability *Ability304) TaobaoTopSecretGet(req *request.TaobaoTopSecretGetRequest) (*response.TaobaoTopSecretGetResponse, error) {
	if ability.Client == nil {
		return nil, errors.New("Ability304 topClient is nil")
	}
	var jsonStr, err = ability.Client.Execute("taobao.top.secret.get", req.ToMap(), req.ToFileMap())
	var respStruct = response.TaobaoTopSecretGetResponse{}
	if err != nil {
		log.Println("taobaoTopSecretGet error", err)
		return &respStruct, err
	}
	err = util.HandleJsonResponse(jsonStr, &respStruct)
	if respStruct.Body == "" || len(respStruct.Body) == 0 {
		respStruct.Body = jsonStr
	}
	return &respStruct, err
}

/*
通过mixnick转换openuid
*/
func (ability *Ability304) TaobaoOpenuidGetBymixnick(req *request.TaobaoOpenuidGetBymixnickRequest) (*response.TaobaoOpenuidGetBymixnickResponse, error) {
	if ability.Client == nil {
		return nil, errors.New("Ability304 topClient is nil")
	}
	var jsonStr, err = ability.Client.Execute("taobao.openuid.get.bymixnick", req.ToMap(), req.ToFileMap())
	var respStruct = response.TaobaoOpenuidGetBymixnickResponse{}
	if err != nil {
		log.Println("taobaoOpenuidGetBymixnick error", err)
		return &respStruct, err
	}
	err = util.HandleJsonResponse(jsonStr, &respStruct)
	if respStruct.Body == "" || len(respStruct.Body) == 0 {
		respStruct.Body = jsonStr
	}
	return &respStruct, err
}

/*
获取ISV发起请求服务器IP
*/
func (ability *Ability304) TaobaoAppipGet(req *request.TaobaoAppipGetRequest) (*response.TaobaoAppipGetResponse, error) {
	if ability.Client == nil {
		return nil, errors.New("Ability304 topClient is nil")
	}
	var jsonStr, err = ability.Client.Execute("taobao.appip.get", req.ToMap(), req.ToFileMap())
	var respStruct = response.TaobaoAppipGetResponse{}
	if err != nil {
		log.Println("taobaoAppipGet error", err)
		return &respStruct, err
	}
	err = util.HandleJsonResponse(jsonStr, &respStruct)
	if respStruct.Body == "" || len(respStruct.Body) == 0 {
		respStruct.Body = jsonStr
	}
	return &respStruct, err
}

/*
业务文件获取
*/
func (ability *Ability304) TaobaoFilesGet(req *request.TaobaoFilesGetRequest) (*response.TaobaoFilesGetResponse, error) {
	if ability.Client == nil {
		return nil, errors.New("Ability304 topClient is nil")
	}
	var jsonStr, err = ability.Client.Execute("taobao.files.get", req.ToMap(), req.ToFileMap())
	var respStruct = response.TaobaoFilesGetResponse{}
	if err != nil {
		log.Println("taobaoFilesGet error", err)
		return &respStruct, err
	}
	err = util.HandleJsonResponse(jsonStr, &respStruct)
	if respStruct.Body == "" || len(respStruct.Body) == 0 {
		respStruct.Body = jsonStr
	}
	return &respStruct, err
}

/*
刷新Access Token
*/
func (ability *Ability304) TaobaoTopAuthTokenRefresh(req *request.TaobaoTopAuthTokenRefreshRequest) (*response.TaobaoTopAuthTokenRefreshResponse, error) {
	if ability.Client == nil {
		return nil, errors.New("Ability304 topClient is nil")
	}
	var jsonStr, err = ability.Client.Execute("taobao.top.auth.token.refresh", req.ToMap(), req.ToFileMap())
	var respStruct = response.TaobaoTopAuthTokenRefreshResponse{}
	if err != nil {
		log.Println("taobaoTopAuthTokenRefresh error", err)
		return &respStruct, err
	}
	err = util.HandleJsonResponse(jsonStr, &respStruct)
	if respStruct.Body == "" || len(respStruct.Body) == 0 {
		respStruct.Body = jsonStr
	}
	return &respStruct, err
}

/*
获取Access Token
*/
func (ability *Ability304) TaobaoTopAuthTokenCreate(req *request.TaobaoTopAuthTokenCreateRequest) (*response.TaobaoTopAuthTokenCreateResponse, error) {
	if ability.Client == nil {
		return nil, errors.New("Ability304 topClient is nil")
	}
	var jsonStr, err = ability.Client.Execute("taobao.top.auth.token.create", req.ToMap(), req.ToFileMap())
	var respStruct = response.TaobaoTopAuthTokenCreateResponse{}
	if err != nil {
		log.Println("taobaoTopAuthTokenCreate error", err)
		return &respStruct, err
	}
	err = util.HandleJsonResponse(jsonStr, &respStruct)
	if respStruct.Body == "" || len(respStruct.Body) == 0 {
		respStruct.Body = jsonStr
	}
	return &respStruct, err
}

/*
sdk信息回调
*/
func (ability *Ability304) TaobaoTopSdkFeedbackUpload(req *request.TaobaoTopSdkFeedbackUploadRequest) (*response.TaobaoTopSdkFeedbackUploadResponse, error) {
	if ability.Client == nil {
		return nil, errors.New("Ability304 topClient is nil")
	}
	var jsonStr, err = ability.Client.Execute("taobao.top.sdk.feedback.upload", req.ToMap(), req.ToFileMap())
	var respStruct = response.TaobaoTopSdkFeedbackUploadResponse{}
	if err != nil {
		log.Println("taobaoTopSdkFeedbackUpload error", err)
		return &respStruct, err
	}
	err = util.HandleJsonResponse(jsonStr, &respStruct)
	if respStruct.Body == "" || len(respStruct.Body) == 0 {
		respStruct.Body = jsonStr
	}
	return &respStruct, err
}