liulei/baseapi
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
邹宗楠
2023-08-02 18:50:54 +08:00
parent 5568704a52
commit 44ed7450ef
3 changed files with 257 additions and 162 deletions
Download Patch File Download Diff File Expand all files Collapse all files

47
platformapi/tao_vegetable/store_sku.go
View File

@@ -6,12 +6,9 @@ import (
"git.rosy.net.cn/baseapi/platformapi/tao_vegetable/sdk/ability585/domain"
"git.rosy.net.cn/baseapi/platformapi/tao_vegetable/sdk/ability585/request"
"git.rosy.net.cn/baseapi/platformapi/tao_vegetable/sdk/ability587"
domain587 "git.rosy.net.cn/baseapi/platformapi/tao_vegetable/sdk/ability587/domain"
request2 "git.rosy.net.cn/baseapi/platformapi/tao_vegetable/sdk/ability587/request"
"git.rosy.net.cn/baseapi/platformapi/tao_vegetable/sdk/ability589"
request589 "git.rosy.net.cn/baseapi/platformapi/tao_vegetable/sdk/ability589/request"
"git.rosy.net.cn/baseapi/utils"
"time"
)
// AddStoreSku 新增门店商品
@@ -106,28 +103,28 @@ func (a *API) StoreSkuUpdateOffShelf(param *request2.AlibabaAxChannelSkuStatusUp
}
// StoreSkuUpdateOffShelfList 门店商品上下架
func (a *API) StoreSkuUpdateOffShelfList(storeID int64, skuList []string) []string {
client := ability587.NewAbility587(&a.client)
errs := make([]string, 0, 0)
param := &request2.AlibabaAxChannelSkuStatusUpdateRequest{ChannelSkuUpdateStatusReq: &domain587.AlibabaAxChannelSkuStatusUpdateChannelSkuUpdateStatusReq{
StoreId: utils.String2Pointer(fmt.Sprintf("JX%d", storeID)),
ChannelCode: utils.String2Pointer("31"),
OnlineSaleFlag: utils.Int64ToPointer(0),
}}
for i := 0; i < len(skuList); i++ {
param.ChannelSkuUpdateStatusReq.SkuCode = utils.String2Pointer(skuList[i])
data, _ := client.AlibabaAxChannelSkuStatusUpdate(param, a.token)
if !*data.ApiResult.Success {
errs = append(errs, *data.ApiResult.ErrMsg)
}
if i%5 == 0 {
time.Sleep(1 * time.Second)
}
}
return errs
}
//func (a *API) StoreSkuUpdateOffShelfList(storeID int64, skuList []string) []string {
// client := ability587.NewAbility587(&a.client)
//
// errs := make([]string, 0, 0)
// param := &request2.AlibabaAxChannelSkuStatusUpdateRequest{ChannelSkuUpdateStatusReq: &domain587.AlibabaAxChannelSkuStatusUpdateChannelSkuUpdateStatusReq{
// StoreId: utils.String2Pointer(fmt.Sprintf("JX%d", storeID)),
// ChannelCode: utils.String2Pointer("31"),
// OnlineSaleFlag: utils.Int64ToPointer(0),
// }}
// for i := 0; i < len(skuList); i++ {
// param.ChannelSkuUpdateStatusReq.SkuCode = utils.String2Pointer(skuList[i])
// data, _ := client.AlibabaAxChannelSkuStatusUpdate(param, a.token)
// if !*data.ApiResult.Success {
// errs = append(errs, *data.ApiResult.ErrMsg)
// }
// if i%5 == 0 {
// time.Sleep(1 * time.Second)
// }
// }
//
// return errs
//}
// StoreSkuStock 商品库存同步
func (a *API) StoreSkuStock(param *request589.AlibabaWdkStockPublishRequest) error {