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

- UploadImg4Vendors

Browse Source
This commit is contained in:
gazebo
2019-09-26 09:58:23 +08:00
parent 5e577c0632
commit b3c83924ba
1 changed files with 16 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

30
business/jxstore/initdata/initdata.go
View File

@@ -342,10 +342,6 @@ func UploadEbaiImg4SkuName(ctx *jxcontext.Context, nameIDs []int, isAsync, isCon
} }
func UploadImg4Vendors(ctx *jxcontext.Context, isAsync, isContinueWhenError bool) (hint string, err error) { func UploadImg4Vendors(ctx *jxcontext.Context, isAsync, isContinueWhenError bool) (hint string, err error) {
dataResList, err := dao.GetNeedUploadDataResource(dao.GetDB())
if err != nil {
return "", err
}
db := dao.GetDB() db := dao.GetDB()
rootTask := tasksch.NewSeqTask("UploadImg4Vendors", ctx, rootTask := tasksch.NewSeqTask("UploadImg4Vendors", ctx,
func(task *tasksch.SeqTask, step int, params ...interface{}) (result interface{}, err error) { func(task *tasksch.SeqTask, step int, params ...interface{}) (result interface{}, err error) {
@@ -396,20 +392,26 @@ func UploadImg4Vendors(ctx *jxcontext.Context, isAsync, isContinueWhenError bool
WHERE t1.img <> '' AND t2.id IS NULL; WHERE t1.img <> '' AND t2.id IS NULL;
`) `)
case 2: case 2:
uploadTask := tasksch.NewParallelTask("UploadImg4Vendors", dataResList, err := dao.GetNeedUploadDataResource(db)
tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError).SetParallelCount(5), ctx, if err == nil && len(dataResList) > 0 {
func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { uploadTask := tasksch.NewParallelTask("UploadImg4Vendors",
dataRes := batchItemList[0].(*model.DataResource) tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError).SetParallelCount(5), ctx,
_, err = datares.UploadImage2Vendors(ctx, task, dataRes, nil, false) func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {
return nil, err dataRes := batchItemList[0].(*model.DataResource)
}, dataResList) _, err = datares.UploadImage2Vendors(ctx, task, dataRes, nil, false)
tasksch.HandleTask(uploadTask, task, true).Run() return nil, err
_, err = uploadTask.GetResult(0) }, dataResList)
tasksch.HandleTask(uploadTask, task, true).Run()
_, err = uploadTask.GetResult(0)
}
} }
return result, err return result, err
}, 3) }, 3)
tasksch.HandleTask(rootTask, nil, true).Run()
if !isAsync { if !isAsync {
_, err = rootTask.GetResult(0) if _, err = rootTask.GetResult(0); err == nil {
hint = "1"
}
} else { } else {
hint = rootTask.ID hint = rootTask.ID
} }