From 92fad81a291ebcf2497f05691980d91d2023eb8b Mon Sep 17 00:00:00 2001 From: gazebo Date: Fri, 26 Jul 2019 15:50:46 +0800 Subject: [PATCH] =?UTF-8?q?-=20syncStoreSkuNew=E4=B8=AD=E6=B2=A1=E6=9C=89?= =?UTF-8?q?=E5=BE=85=E5=90=8C=E6=AD=A5=E6=9D=A1=E7=9B=AE=E4=B8=8D=E5=90=AF?= =?UTF-8?q?=E5=8A=A8=E4=BB=BB=E5=8A=A1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- business/jxstore/cms/sync_store_sku.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/business/jxstore/cms/sync_store_sku.go b/business/jxstore/cms/sync_store_sku.go index e532662f5..6e5fec919 100644 --- a/business/jxstore/cms/sync_store_sku.go +++ b/business/jxstore/cms/sync_store_sku.go @@ -256,7 +256,7 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, isFull bo } else { skus, err = dao.GetStoreSkus(db, vendorID, storeID, skuIDs) } - if err != nil { + if err != nil || len(skus) == 0 { return err } formalizeStoreSkuList(skus) @@ -339,7 +339,7 @@ func syncStoreSkuNew(ctx *jxcontext.Context, parentTask tasksch.ITask, isFull bo task := tasksch.NewParallelTask("syncStoreSkuNew", tasksch.NewParallelConfig().SetParallelCount(1).SetIsContinueWhenError(isContinueWhenError), ctx, func(task *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { step := batchItemList[0].(int) - globals.SugarLogger.Debugf("step:%d", step) + // globals.SugarLogger.Debugf("step:%d", step) switch step { case 0: if len(deleteList) > 0 {