From feef77a600f5035080194f60c01f4376a3ca0808 Mon Sep 17 00:00:00 2001 From: gazebo Date: Fri, 17 Jan 2020 23:18:08 +0800 Subject: [PATCH] =?UTF-8?q?=E4=B8=B4=E6=97=B6=E6=8A=8A=E4=BA=AC=E4=B8=9C?= =?UTF-8?q?=E7=9A=84=E5=B9=B6=E5=8F=91=E6=94=B9=E4=B8=BA2=20=E6=AF=8F?= =?UTF-8?q?=E6=99=9A=E4=BA=AC=E4=B8=9C=E5=90=8C=E6=AD=A5=E4=B8=8D=E5=BC=BA?= =?UTF-8?q?=E5=88=B6=E8=AE=BE=E7=BD=AE=E5=90=8C=E6=AD=A5=E6=A0=87=E5=BF=97?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- business/jxstore/cms/sync.go | 3 ++- business/jxstore/misc/misc.go | 2 +- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/business/jxstore/cms/sync.go b/business/jxstore/cms/sync.go index ae156de21..ff75ef3c4 100644 --- a/business/jxstore/cms/sync.go +++ b/business/jxstore/cms/sync.go @@ -620,7 +620,8 @@ func (v *VendorSync) LoopStoresMap2(ctx *jxcontext.Context, parentTask tasksch.I if len(loopInfoList) == 1 { taskName = fmt.Sprintf("%s,处理平台%s", taskName, model.VendorChineseNames[loopInfoList[0].VendorID]) } - task = tasksch.NewParallelTask(taskName, tasksch.NewParallelConfig().SetIsContinueWhenError(true), ctx, handler, loopInfoList) + // 临时把京东的并发改为2 + task = tasksch.NewParallelTask(taskName, tasksch.NewParallelConfig().SetIsContinueWhenError(true).SetParallelCount(2), ctx, handler, loopInfoList) if isAsync { buildSetFinishHook(task, ctx) } diff --git a/business/jxstore/misc/misc.go b/business/jxstore/misc/misc.go index b3f9a987d..8145f26fb 100644 --- a/business/jxstore/misc/misc.go +++ b/business/jxstore/misc/misc.go @@ -201,7 +201,7 @@ func syncStoreSku() { }) errList.AddErr(err) - _, err = cms.CurVendorSync.SyncStoresSkus2(jxcontext.AdminCtx, nil, 0, db, partner.GetMultiStoreVendorIDs(), nil, false, nil, []int{27379}, syncFlag, true, true) + _, err = cms.CurVendorSync.SyncStoresSkus2(jxcontext.AdminCtx, nil, 0, db, partner.GetMultiStoreVendorIDs(), nil, false, nil, []int{27379}, 0 /*syncFlag*/, true, true) // _, err = cms.CurVendorSync.FullSyncStoresSkus(jxcontext.AdminCtx, db, partner.GetMultiStoreVendorIDs(), nil, false, []int{27379}, true, true) errList.AddErr(err) case 1: