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

更新商品前缀让他们自己同步把

Browse Source
This commit is contained in:
苏尹岚
2020-07-17 09:53:33 +08:00
parent 23833a6004
commit 9174b5438f
1 changed files with 43 additions and 67 deletions
Download Patch File Download Diff File Expand all files Collapse all files

40
business/jxstore/cms/sku.go
View File

@@ -2567,10 +2567,8 @@ func UpdateSkuExinfoMap(ctx *jxcontext.Context, nameIDs []int, imgWaterMark stri
if toTimeP.Before(fromTimeP) { if toTimeP.Before(fromTimeP) {
return "", fmt.Errorf("结束时间不可以小于开始时间！开始时间：[%v]，结束时间：[%v]", fromTimeP, toTimeP) return "", fmt.Errorf("结束时间不可以小于开始时间！开始时间：[%v]，结束时间：[%v]", fromTimeP, toTimeP)
} }
taskSeqFunc := func(task *tasksch.SeqTask, step int, params ...interface{}) (result interface{}, err error) { task := tasksch.NewParallelTask("UpdateSkuExinfoMap", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(isContinueWhenError), ctx,
switch step { func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
case 0:
taskFunc := func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
nameID := batchItemList[0].(int) nameID := batchItemList[0].(int)
skuEx := &model.SkuExinfoMap{ skuEx := &model.SkuExinfoMap{
NameID: nameID, NameID: nameID,
@@ -2599,7 +2597,6 @@ func UpdateSkuExinfoMap(ctx *jxcontext.Context, nameIDs []int, imgWaterMark stri
if len(skuList) > 0 { if len(skuList) > 0 {
for _, v := range skuList { for _, v := range skuList {
skuIDs = append(skuIDs, v.ID) skuIDs = append(skuIDs, v.ID)
retVal = []int{v.ID}
} }
if partner.IsMultiStore(vendorID) { if partner.IsMultiStore(vendorID) {
for _, v := range skuIDs { for _, v := range skuIDs {
@@ -2612,34 +2609,13 @@ func UpdateSkuExinfoMap(ctx *jxcontext.Context, nameIDs []int, imgWaterMark stri
} }
} }
return retVal, err return retVal, err
} }, nameIDs)
taskParallel := tasksch.NewParallelTask("UpdateSkuExinfoMap", tasksch.NewParallelConfig().SetParallelCount(parallelCount), ctx, taskFunc, nameIDs) tasksch.HandleTask(task, nil, true).Run()
tasksch.HandleTask(taskParallel, nil, true).Run() if isAsync {
_, err = task.GetResult(0) hint = task.GetID()
// err = err2
// if len(result) > 0 {
// for _, v := range result {
// skuIDs = append(skuIDs, int(utils.Interface2Int64WithDefault(v, 0)))
// }
// }
case 1:
// if len(skuIDs) > 0 {
// if partner.IsMultiStore(vendorID) {
// CurVendorSync.SyncSkus(ctx, db, nil, skuIDs, isAsync, isContinueWhenError, ctx.GetUserName())
// } else {
// CurVendorSync.SyncStoresSkus2(ctx, nil, 0, db, []int{vendorID}, nil, false, skuIDs, nil, model.SyncFlagModifiedMask, isAsync, isContinueWhenError)
// }
// }
}
return result, err
}
taskSeq := tasksch.NewSeqTask2("更新商品前缀", ctx, isContinueWhenError, taskSeqFunc, 2)
tasksch.HandleTask(taskSeq, nil, true).Run()
if !isAsync {
_, err = taskSeq.GetResult(0)
hint = "1"
} else { } else {
hint = taskSeq.GetID() _, err = task.GetResult(0)
hint = "1"
} }
return hint, err return hint, err
} }