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

测试-饿百拉取平台商品-协程改为FOR循环

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

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

@@ -312,27 +312,39 @@ func (p *PurchaseHandler) GetStoreSkusFullInfo(ctx *jxcontext.Context, parentTas
if err == nil { if err == nil {
skuNameList = append(skuNameList, vendorSkuList2Jx(page1.List)...) skuNameList = append(skuNameList, vendorSkuList2Jx(page1.List)...)
if page1.Pages > 1 { if page1.Pages > 1 {
pages := make([]int, page1.Pages-1) // pages := make([]int, page1.Pages-1)
for i := 2; i <= page1.Pages; i++ { // for i := 2; i <= page1.Pages; i++ {
pages[i-2] = i // pages[i-2] = i
} // }
task := tasksch.NewParallelTask("ebai GetStoreSkusFullInfo", nil, ctx, // task := tasksch.NewParallelTask("ebai GetStoreSkusFullInfo", nil, ctx,
func(t *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { // func(t *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
callParams := &ebaiapi.SkuListParams{ // callParams := &ebaiapi.SkuListParams{
PageSize: ebaiapi.MaxSkuListPageSize, // PageSize: ebaiapi.MaxSkuListPageSize,
Page: batchItemList[0].(int), // 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))
} }
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)))
} }
} }
} }