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

- fix return bug in CreateJdPromotion

Browse Source
This commit is contained in:
gazebo
2018-10-26 15:01:15 +08:00
parent d834422b4e
commit 301b845c44
1 changed files with 3 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -285,13 +285,9 @@ func CreateJdPromotion(ctx *jxcontext.Context, isIDJd bool, isAsync bool, params
return nil, nil return nil, nil
}, jxStoreIDs) }, jxStoreIDs)
task.AddChild(task1).Run() task.AddChild(task1).Run()
if _, err = task1.GetResult(0); err != nil { _, err = task1.GetResult(0)
return "", err
}
} else if step == 1 { } else if step == 1 {
if err = promotionHandler.CreatePromotionRules(infoId, "", 1, 1, 1, 1); err != nil { err = promotionHandler.CreatePromotionRules(infoId, "", 1, 1, 1, 1)
return "", err
}
} 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(jdapi.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))
@@ -302,9 +298,7 @@ func CreateJdPromotion(ctx *jxcontext.Context, isIDJd bool, isAsync bool, params
return nil, err return nil, err
}, promotionPrices) }, promotionPrices)
task.AddChild(task2).Run() task.AddChild(task2).Run()
if _, err = task2.GetResult(0); err != nil { _, err = task2.GetResult(0)
return "", err
}
} else if step == 3 { } else if step == 3 {
err = promotionHandler.ConfirmPromotion(infoId, "") err = promotionHandler.ConfirmPromotion(infoId, "")
} }