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

beta

Browse Source
This commit is contained in:
苏尹岚
2020-11-12 15:10:07 +08:00
parent f7e49363ac
commit 20dbfa5c29
1 changed files with 35 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

47
business/jxstore/tempop/tempop.go
View File

@@ -10,6 +10,7 @@ import (
"git.rosy.net.cn/jx-callback/business/auth2/authprovider/weixin" "git.rosy.net.cn/jx-callback/business/auth2/authprovider/weixin"
"git.rosy.net.cn/jx-callback/business/partner/delivery" "git.rosy.net.cn/jx-callback/business/partner/delivery"
"git.rosy.net.cn/jx-callback/business/partner/putils"
"github.com/360EntSecGroup-Skylar/excelize" "github.com/360EntSecGroup-Skylar/excelize"
"github.com/qiniu/api.v7/storage" "github.com/qiniu/api.v7/storage"
@@ -1808,21 +1809,43 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
} }
} }
} }
if len(priceList) > 0 { task := tasksch.NewParallelTask("syncStoreSkuNew", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(true), ctx,
for k, v := range priceList { func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
if len(v) > 50 { step := batchItemList[0].(int)
for i := 0; i < len(v)/50+1; i++ { switch step {
j := i case 0:
if i == len(v)/50+1 { if len(priceList) > 0 {
handler.UpdateStoreSkusPrice(ctx, vendorOrgCode, 0, k, v[j:len(v)]) for k, v := range priceList {
} else { _, err = putils.FreeBatchStoreSkuInfo("更新门店商品价格", func(task tasksch.ITask, batchedStoreSkuList []*partner.StoreSkuInfo) (result interface{}, successCount int, err error) {
handler.UpdateStoreSkusPrice(ctx, vendorOrgCode, 0, k, v[j:50*(j+1)]) handler.UpdateStoreSkusPrice(ctx, vendorOrgCode, 0, k, batchedStoreSkuList)
return nil, 1, err
}, ctx, task, v, 50, true)
} }
j += 50
} }
case 1:
} }
} return retVal, err
} }, []int{0, 1, 2, 3})
tasksch.HandleTask(task, nil, true).Run()
_, err = task.GetResult(0)
return err
// if len(priceList) > 0 {
// for k, v := range priceList {
// if len(v) > 50 {
// for i := 0; i < len(v)/50+1; i++ {
// j := i
// if i == len(v)/50+1 {
// handler.UpdateStoreSkusPrice(ctx, vendorOrgCode, 0, k, v[j:len(v)])
// } else {
// handler.UpdateStoreSkusPrice(ctx, vendorOrgCode, 0, k, v[j:50*(j+1)])
// }
// j += 50
// }
// }
// }
// }
if len(statusList1) > 0 { if len(statusList1) > 0 {
// for k, v := range statusList1 { // for k, v := range statusList1 {
// handler.UpdateStoreSkusStatus(ctx, vendorOrgCode, 0, k, v, v[0].Status) // handler.UpdateStoreSkusStatus(ctx, vendorOrgCode, 0, k, v, v[0].Status)