diff --git a/business/jxstore/initdata/initdata.go b/business/jxstore/initdata/initdata.go index 78d2ecf0c..e16b9e9e9 100644 --- a/business/jxstore/initdata/initdata.go +++ b/business/jxstore/initdata/initdata.go @@ -344,8 +344,8 @@ func UploadImg4Vendors(ctx *jxcontext.Context, isAsync, isContinueWhenError bool WHERE t1.img_hash_code <> '' AND t1.img <> t2.main_url; `) case 3: // 上传DataResource中缺失的平台图片 - dataResList, err := dao.GetNeedUploadDataResource(db) - if err == nil && len(dataResList) > 0 { + dataResList, err2 := dao.GetNeedUploadDataResource(db) + if err = err2; err == nil && len(dataResList) > 0 { uploadTask := tasksch.NewParallelTask("批量上传图片至平台", tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError).SetParallelCount(2), ctx, func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {