From 35caf649c76ce0ce12bc74799b442e35b283593e Mon Sep 17 00:00:00 2001 From: gazebo Date: Thu, 13 Jun 2019 11:50:29 +0800 Subject: [PATCH] - fk --- business/partner/purchase/jd/store_sku.go | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) diff --git a/business/partner/purchase/jd/store_sku.go b/business/partner/purchase/jd/store_sku.go index 6c4b50f16..2ff16815f 100644 --- a/business/partner/purchase/jd/store_sku.go +++ b/business/partner/purchase/jd/store_sku.go @@ -43,7 +43,7 @@ func (p *PurchaseHandler) syncStoreSkus(ctx *jxcontext.Context, parentTask tasks // } task := tasksch.NewParallelTask("syncStoreSkus京东", tasksch.NewParallelConfig().SetBatchSize(batchSize).SetIsContinueWhenError(isContinueWhenError), ctx, func(t *tasksch.ParallelTask, batchItemList []interface{}, params ...interface{}) (retVal interface{}, err error) { - doWork := func(batchItemList []interface{}) (err error) { + doWork := func(batchItemList []interface{}) (isPartialFailed bool, err error) { var skuPriceInfoList []*jdapi.SkuPriceInfo var skuVendibilityList []*jdapi.StockVendibility var skuStockList []*jdapi.SkuStock @@ -119,6 +119,7 @@ func (p *PurchaseHandler) syncStoreSkus(ctx *jxcontext.Context, parentTask tasks if _, err = api.JdAPI.UpdateVendorStationPrice("", stationNo, skuPriceInfoList); err == nil { syncMask |= model.SyncFlagPriceMask } else { + isPartialFailed = isErrPartialFailed(err) errList = append(errList, partner.NewErrorCode(err.Error(), partner.ErrCodeChangePriceFailed, model.VendorIDJD)) } } @@ -141,10 +142,10 @@ func (p *PurchaseHandler) syncStoreSkus(ctx *jxcontext.Context, parentTask tasks } else if len(errList) > 1 { err = fmt.Errorf("%v", errList) } - return err + return isPartialFailed, err } - err = doWork(batchItemList) - if isErrPartialFailed(err) && len(batchItemList) > 1 { + isErrPartialFailed, err := doWork(batchItemList) + if isErrPartialFailed && len(batchItemList) > 1 { for _, v := range batchItemList { doWork([]interface{}{v}) }