liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

测试

Browse Source
This commit is contained in:
Rosy-zhudan
2019-08-28 18:32:16 +08:00
parent e5e6c45e7a
commit 77da618442
1 changed files with 32 additions and 32 deletions
Download Patch File Download Diff File Expand all files Collapse all files

64
business/partner/purchase/ebai/store_sku2.go
View File

@@ -312,41 +312,41 @@ func (p *PurchaseHandler) GetStoreSkusFullInfo(ctx *jxcontext.Context, parentTas
if err == nil {
skuNameList = append(skuNameList, vendorSkuList2Jx(page1.List)...)
if page1.Pages > 1 {
// pages := make([]int, page1.Pages-1)
// for i := 2; i <= page1.Pages; i++ {
// pages[i-2] = i
// }
// task := tasksch.NewParallelTask("ebai GetStoreSkusFullInfo", nil, ctx,
// func(t *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
// callParams := &ebaiapi.SkuListParams{
// PageSize: ebaiapi.MaxSkuListPageSize,
// Page: batchItemList[0].(int),
// }
// pageSku, err2 := api.EbaiAPI.SkuList(utils.Int2Str(storeID), callParams)
// if err2 == nil {
// return pageSku.List, err2
// }
// return nil, err2
// }, pages)
// tasksch.HandleTask(task, parentTask, true).Run()
// result, err2 := task.GetResult(0)
// if err = err2; err == nil {
// for _, v := range result {
// skuNameList = append(skuNameList, vendorSku2Jx(v.(*ebaiapi.SkuInfo)))
// }
// }
for pageIndex := 2; pageIndex <= page1.Pages; pageIndex++ {
callParams := &ebaiapi.SkuListParams{
PageSize: ebaiapi.MaxSkuListPageSize,
Page: pageIndex,
}
pageSku, err2 := api.EbaiAPI.SkuList(utils.Int2Str(storeID), callParams)
if err2 == nil {
for _, v := range pageSku.List {
skuNameList = append(skuNameList, vendorSku2Jx(v))
pages := make([]int, page1.Pages-1)
for i := 2; i <= page1.Pages; i++ {
pages[i-2] = i
}
task := tasksch.NewParallelTask("ebai GetStoreSkusFullInfo", nil, ctx,
func(t *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
callParams := &ebaiapi.SkuListParams{
PageSize: ebaiapi.MaxSkuListPageSize,
Page: batchItemList[0].(int),
}
pageSku, err2 := api.EbaiAPI.SkuList(utils.Int2Str(storeID), callParams)
if err2 == nil {
return pageSku.List, err2
}
return nil, err2
}, pages)
tasksch.HandleTask(task, parentTask, false).Run()
result, err2 := task.GetResult(0)
if err = err2; err == nil {
for _, v := range result {
skuNameList = append(skuNameList, vendorSku2Jx(v.(*ebaiapi.SkuInfo)))
}
}
// for pageIndex := 2; pageIndex <= page1.Pages; pageIndex++ {
// callParams := &ebaiapi.SkuListParams{
// PageSize: ebaiapi.MaxSkuListPageSize,
// Page: pageIndex,
// }
// pageSku, err2 := api.EbaiAPI.SkuList(utils.Int2Str(storeID), callParams)
// if err2 == nil {
// for _, v := range pageSku.List {
// skuNameList = append(skuNameList, vendorSku2Jx(v))
// }
// }
// }
}
}
return skuNameList, err