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-03-17 18:27:25 +08:00
parent 757983c756
commit 6c767e160a
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -1899,7 +1899,7 @@ func UploadJdsImage(ctx *jxcontext.Context) (err error) {
utils.DefaultTimeValue, utils.DefaultTimeValue,
} }
dao.GetRows(db, &skuNames, sql, sqlParams) dao.GetRows(db, &skuNames, sql, sqlParams)
task := tasksch.NewParallelTask("uuuuu", tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx, task := tasksch.NewParallelTask("uuuuu", tasksch.NewParallelConfig().SetParallelCount(20).SetIsContinueWhenError(true), ctx,
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
v := batchItemList[0].(*model.SkuName) v := batchItemList[0].(*model.SkuName)
if v.Upc != nil { if v.Upc != nil {