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

aa

Browse Source
This commit is contained in:
苏尹岚
2021-04-06 16:31:38 +08:00
parent b84ff3e0f7
commit a66e7bc13d
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -1857,7 +1857,7 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
}
}
task := tasksch.NewParallelTask("uuuuu", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(true), ctx,
task := tasksch.NewParallelTask("uuuuu", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx,
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
storeMap := batchItemList[0].(*model.StoreMap)
FreeBatchInfo("uuuuu2", func(task tasksch.ITask, batchedStoreSkuList []int64) (result interface{}, successCount int, err error) {
@@ -1871,7 +1871,9 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
})
}
}
err = api.JdAPI.DelVipPrice(utils.Int2Str(storeMap.StoreID), list)
if len(list) > 0 {
err = api.JdAPI.DelVipPrice(utils.Int2Str(storeMap.StoreID), list)
}
return result, 0, err
}, ctx, task, vendorThingIDs, 50, true)
return retVal, err