京东门店商品同步并发从1改为2
This commit is contained in:
@@ -437,7 +437,7 @@ func (v *VendorSync) SyncStoresSkus2(ctx *jxcontext.Context, parentTask tasksch.
|
|||||||
if handler := v.GetStoreHandler(loopMapInfo.VendorID); handler != nil {
|
if handler := v.GetStoreHandler(loopMapInfo.VendorID); handler != nil {
|
||||||
parallelCount := 5
|
parallelCount := 5
|
||||||
if model.MultiStoresVendorMap[loopMapInfo.VendorID] == 1 {
|
if model.MultiStoresVendorMap[loopMapInfo.VendorID] == 1 {
|
||||||
parallelCount = 1
|
parallelCount = 2
|
||||||
}
|
}
|
||||||
loopStoreTask := tasksch.NewParallelTask(fmt.Sprintf("处理平台%s", model.VendorChineseNames[loopMapInfo.VendorID]),
|
loopStoreTask := tasksch.NewParallelTask(fmt.Sprintf("处理平台%s", model.VendorChineseNames[loopMapInfo.VendorID]),
|
||||||
tasksch.NewParallelConfig().SetParallelCount(parallelCount).SetIsContinueWhenError(isContinueWhenError), ctx,
|
tasksch.NewParallelConfig().SetParallelCount(parallelCount).SetIsContinueWhenError(isContinueWhenError), ctx,
|
||||||
|
|||||||
Reference in New Issue
Block a user