From 5b1475fa133a8142929d52ea7985e984b0c93a29 Mon Sep 17 00:00:00 2001 From: gazebo Date: Thu, 26 Sep 2019 17:35:08 +0800 Subject: [PATCH] =?UTF-8?q?err=E5=9C=A8UploadImg4Vendors=E4=B8=AD=E9=94=99?= =?UTF-8?q?=E8=AF=AF=E8=A2=AB=E5=B1=80=E9=83=A8=E4=BA=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- business/jxstore/initdata/initdata.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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) {