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

- limit the batchsize of CreatePromotionSku to 50.

Browse Source
This commit is contained in:
gazebo
2018-10-29 16:25:41 +08:00
parent 4288c5f5e9
commit 63b745460f
1 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
business/jxstore/promotion/jd_promotion.go
View File

@@ -50,6 +50,7 @@ const (
const ( const (
DefaultLimitSkuCount = 100 DefaultLimitSkuCount = 100
MaxPromotionSkuCount = jdapi.MaxPromotionSkuCount / 4
) )
type SkuPrice struct { type SkuPrice struct {
@@ -289,7 +290,7 @@ func CreateJdPromotion(ctx *jxcontext.Context, isIDJd bool, isAsync bool, params
} else if step == 1 { } else if step == 1 {
err = promotionHandler.CreatePromotionRules(infoId, "", 1, 1, 1, 1) err = promotionHandler.CreatePromotionRules(infoId, "", 1, 1, 1, 1)
} else if step == 2 { } else if step == 2 {
task2 := tasksch.NewParallelTask("CreateJdPromotion CreatePromotionSku", tasksch.NewParallelConfig().SetBatchSize(jdapi.MaxPromotionSkuCount), userName, func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { task2 := tasksch.NewParallelTask("CreateJdPromotion CreatePromotionSku", tasksch.NewParallelConfig().SetBatchSize(MaxPromotionSkuCount), userName, func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
skus := make([]map[string]interface{}, len(batchItemList)) skus := make([]map[string]interface{}, len(batchItemList))
for k, v := range batchItemList { for k, v := range batchItemList {
skus[k] = v.(map[string]interface{}) skus[k] = v.(map[string]interface{})