From 60f82e36756293bea4b75adae821bb0b402830f2 Mon Sep 17 00:00:00 2001 From: gazebo Date: Thu, 23 May 2019 10:02:53 +0800 Subject: [PATCH] =?UTF-8?q?-=20FullSyncStoresSkus=E4=B8=AD=EF=BC=8C?= =?UTF-8?q?=E5=A6=82=E6=9E=9C=E8=AE=BE=E7=BD=AE=E4=BA=86isContinueWhenErro?= =?UTF-8?q?r=EF=BC=8C=E5=BF=BD=E7=95=A5=E5=8D=95=E4=B8=AA=E9=97=A8?= =?UTF-8?q?=E5=BA=97=E5=90=8C=E6=AD=A5=E9=94=99=E8=AF=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- business/jxstore/cms/sync.go | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/business/jxstore/cms/sync.go b/business/jxstore/cms/sync.go index a0309f0fc..fe98f44b0 100644 --- a/business/jxstore/cms/sync.go +++ b/business/jxstore/cms/sync.go @@ -430,7 +430,12 @@ func (v *VendorSync) FullSyncStoresSkus(ctx *jxcontext.Context, db *dao.DaoDB, v loopStoreTask := tasksch.NewSeqTask(fmt.Sprintf("处理平台%s", model.VendorChineseNames[loopMapInfo.VendorID]), ctx, func(task *tasksch.SeqTask, step int, params ...interface{}) (result interface{}, err error) { storeID := loopMapInfo.StoreMapList[step].StoreID - _, err = handler.FullSyncStoreSkus(ctx, task, storeID, false, isContinueWhenError) + if _, err = handler.FullSyncStoreSkus(ctx, task, storeID, false, isContinueWhenError); err != nil { + globals.SugarLogger.Debugf("FullSyncStoresSkus failed1 store:%d failed with error:%v", storeID, err) + if isContinueWhenError { + err = nil + } + } return nil, err }, len(loopMapInfo.StoreMapList)) t.AddChild(loopStoreTask).Run()