商品审核修改

This commit is contained in:
苏尹岚
2020-07-09 17:10:25 +08:00
parent c0e48d9f67
commit 4f207c3098

View File

@@ -4684,9 +4684,7 @@ func StoreSkuPriceAudit(ctx *jxcontext.Context, storeSkuAudits []*model.StoreSku
}
}
}
if len(storeSkuAudits2) > 0 {
return storeSkuAudits2, "", err
}
return storeSkuAudits2, "", err
}
task := tasksch.NewParallelTask("StoreSkuPriceAudit", tasksch.NewParallelConfig().SetParallelCount(5).SetIsContinueWhenError(isContinueWhenError), ctx,
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {