From 09da354c8510a4cd5c8d20bea39a6c3a60b69868 Mon Sep 17 00:00:00 2001 From: gazebo Date: Fri, 19 Jul 2019 16:01:31 +0800 Subject: [PATCH] =?UTF-8?q?-=20SyncStoreSkus=E4=B8=AD=E5=8A=A0=E5=85=A5Syn?= =?UTF-8?q?cStoreCategory?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- business/partner/purchase/ebai/store_sku.go | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/business/partner/purchase/ebai/store_sku.go b/business/partner/purchase/ebai/store_sku.go index 56e6c927e..84192876f 100644 --- a/business/partner/purchase/ebai/store_sku.go +++ b/business/partner/purchase/ebai/store_sku.go @@ -194,6 +194,11 @@ func (p *PurchaseHandler) SyncStoreSkus(ctx *jxcontext.Context, parentTask tasks if err != nil { return "", err } + if len(skuIDs) == 0 { + if _, err = p.SyncStoreCategory(ctx, parentTask, storeID, false); err != nil { + return "", err + } + } return p.syncStoreSkus(ctx, parentTask, storeDetail, skuIDs, isAsync, isContinueWhenError) } @@ -225,9 +230,6 @@ func (p *PurchaseHandler) syncStoreSkus(ctx *jxcontext.Context, parentTask tasks globals.SugarLogger.Infof("SyncStoreSkus 不能创建商品所需的类别, storeID:%d, skuIDs:%v, isContinueWhenError:%t, userName:%s", storeID, skuIDs, isContinueWhenError, userName) return nil, errors.New("不能创建商品所需的类别") } - if _, err = p.SyncStoreCategory(ctx, parentTask, storeID, false); err != nil { - return nil, err - } } else if step == 1 { task := tasksch.NewParallelTask("SyncStoreSkus饿百2", tasksch.NewParallelConfig().SetIsContinueWhenError(isContinueWhenError), ctx, func(t *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) {