diff --git a/platformapi/tao_vegetable/api_token.go b/platformapi/tao_vegetable/api_token.go index 749d83ea..9616e95b 100644 --- a/platformapi/tao_vegetable/api_token.go +++ b/platformapi/tao_vegetable/api_token.go @@ -4,9 +4,9 @@ import ( "encoding/json" "git.rosy.net.cn/baseapi/utils" "git.rosy.net.cn/jx-callback/globals" + "git.rosy.net.cn/topsdk/ability304" + "git.rosy.net.cn/topsdk/ability304/request" "topsdk" - "topsdk/ability304" - "topsdk/ability304/request" ) const ( @@ -20,7 +20,9 @@ func NewTaoVegetable(appKey, appSecret, serverUrl string) API { } type API struct { - client topsdk.TopClient + client topsdk.TopClient + token string + refreshToken string } func (a API) GetStoreToken(code, uuId string) (*StoreTokenInfo, error) { diff --git a/platformapi/tao_vegetable/store_categary.go b/platformapi/tao_vegetable/store_categary.go index f58d2b23..eeeb5293 100644 --- a/platformapi/tao_vegetable/store_categary.go +++ b/platformapi/tao_vegetable/store_categary.go @@ -3,13 +3,12 @@ package tao_vegetable import ( "encoding/json" "fmt" - "topsdk/ability587" - "topsdk/ability587/domain" - "topsdk/ability587/request" + "git.rosy.net.cn/topsdk/ability587" + "git.rosy.net.cn/topsdk/ability587/domain" + "git.rosy.net.cn/topsdk/ability587/request" ) func (a API) GetStoreCategoryInfo(code string) (*CategoryInfo, error) { - a.client.ServerUrl = "https://eco.taobao.com/router/rest/alibaba.wdk.sku.category.query" storeCategory := ability587.NewAbility587(&a.client) resp, err := storeCategory.AlibabaWdkSkuCategoryQuery(&request.AlibabaWdkSkuCategoryQueryRequest{Param: &domain.AlibabaWdkSkuCategoryQueryCategoryDo{Code: &code}}, "") if err != nil { diff --git a/platformapi/tao_vegetable/store_sku.go b/platformapi/tao_vegetable/store_sku.go index b9c50920..3847e820 100644 --- a/platformapi/tao_vegetable/store_sku.go +++ b/platformapi/tao_vegetable/store_sku.go @@ -1,20 +1,66 @@ package tao_vegetable +import ( + "fmt" + "git.rosy.net.cn/baseapi/utils" + "git.rosy.net.cn/jx-callback/globals" + "git.rosy.net.cn/topsdk/ability585" + "git.rosy.net.cn/topsdk/ability585/domain" + "git.rosy.net.cn/topsdk/ability585/request" +) + +// AddStoreSku 新增门店商品 +func (a API) AddStoreSku(param *request.AlibabaWdkSkuAddRequest) (*[]domain.AlibabaWdkSkuAddApiResult, error) { + client := ability585.NewAbility585(&a.client) + + data, err := client.AlibabaWdkSkuAdd(param, a.token) + if err != nil { + globals.SugarLogger.Debugf("requestId[%s],err[%s]", data.RequestId, utils.Format4Output(err, false)) + return nil, err + } + + if data.Result.ErrCode != nil { + globals.SugarLogger.Debugf("requestId[%s],err[%s]", data.RequestId, utils.Format4Output(data.Result, false)) + return nil, fmt.Errorf(*data.Result.ErrMsg) + } + + return data.Result.Models, nil +} + +// UpdateStoreSku 更新门店商品 +func (a API) UpdateStoreSku(param *request.AlibabaWdkSkuUpdateRequest) (*[]domain.AlibabaWdkSkuUpdateApiResult, error) { + client := ability585.NewAbility585(&a.client) + + data, err := client.AlibabaWdkSkuUpdate(param, a.token) + if err != nil { + globals.SugarLogger.Debugf("requestId[%s],err[%s]", data.RequestId, utils.Format4Output(err, false)) + return nil, err + } + + if data.Result.ErrCode != nil { + globals.SugarLogger.Debugf("requestId[%s],err[%s]", data.RequestId, utils.Format4Output(data.Result, false)) + return nil, fmt.Errorf(*data.Result.ErrMsg) + } + + return data.Result.Models, nil +} + +// QueryStoreSKu 查询门店商品 +func (a API) QueryStoreSKu(param *request.AlibabaWdkSkuQueryRequest) (*[]domain.AlibabaWdkSkuQueryApiResult, error) { + client := ability585.NewAbility585(&a.client) + + data, err := client.AlibabaWdkSkuQuery(param, a.token) + if err != nil { + globals.SugarLogger.Debugf("requestId[%s],err[%s]", data.RequestId, utils.Format4Output(err, false)) + return nil, err + } + + if data.Result.ErrCode != nil { + globals.SugarLogger.Debugf("requestId[%s],err[%s]", data.RequestId, utils.Format4Output(data.Result, false)) + return nil, fmt.Errorf(*data.Result.ErrMsg) + } + + return data.Result.Models, nil +} -//func (a API) QueryStoreDetailsList() { -// a.client.ServerUrl = "qimen.taobao.qimen.pos.store.get" -// storeCategory := ability587.NewAbility587(&a.client) -// resp, err := storeCategory.AlibabaWdkSkuCategoryQuery(&request.AlibabaWdkSkuCategoryQueryRequest{Param: &domain.AlibabaWdkSkuCategoryQueryCategoryDo{Code: &code}}, "") -// if err != nil { -// return nil, err -// } -// if resp.Result.ErrMsg != nil { -// return nil, fmt.Errorf("requestId:" + resp.RequestId + "msg:" + *resp.Result.ErrMsg) -// } -// var info *CategoryInfo -// if err := json.Unmarshal([]byte(*resp.Result.Model), &info); err != nil { -// return nil, err -// } // -// return info, nil -//} diff --git a/platformapi/tao_vegetable/store_test.go b/platformapi/tao_vegetable/store_test.go index 610326ae..90a7cad4 100644 --- a/platformapi/tao_vegetable/store_test.go +++ b/platformapi/tao_vegetable/store_test.go @@ -4,10 +4,10 @@ import ( "git.rosy.net.cn/baseapi" "git.rosy.net.cn/baseapi/utils" "git.rosy.net.cn/jx-callback/globals" + "git.rosy.net.cn/topsdk/ability587/domain" + "git.rosy.net.cn/topsdk/ability587/request" "go.uber.org/zap" "testing" - "topsdk/ability587/domain" - "topsdk/ability587/request" ) var ( diff --git a/platformapi/tao_vegetable/upload_img.go b/platformapi/tao_vegetable/upload_img.go new file mode 100644 index 00000000..df68fbf3 --- /dev/null +++ b/platformapi/tao_vegetable/upload_img.go @@ -0,0 +1,27 @@ +package tao_vegetable + +import ( + "fmt" + "git.rosy.net.cn/baseapi/utils" + "git.rosy.net.cn/jx-callback/globals" + "git.rosy.net.cn/topsdk/ability1475" + "git.rosy.net.cn/topsdk/ability1475/request" +) + +// UploadImg 上传图片 +func (a API) UploadImg(param *request.AlibabaWdkPictureUploadRequest) (string, error) { + client := ability1475.NewAbility1475(&a.client) + + data, err := client.AlibabaWdkPictureUpload(param, a.token) + if err != nil { + globals.SugarLogger.Debugf("requestId[%s],err[%s]", data.RequestId, utils.Format4Output(err, false)) + return "", err + } + + if data.Result.ErrCode != nil { + globals.SugarLogger.Debugf("requestId[%s],err[%s]", data.RequestId, utils.Format4Output(data.Result, false)) + return "", fmt.Errorf(*data.Result.ErrMsg) + } + + return *data.Result.Model.FullUrl, nil +}