diff --git a/BBWY.Server.Business/Sync/ProductSyncBusiness.cs b/BBWY.Server.Business/Sync/ProductSyncBusiness.cs index fafba1bd..270bcad2 100644 --- a/BBWY.Server.Business/Sync/ProductSyncBusiness.cs +++ b/BBWY.Server.Business/Sync/ProductSyncBusiness.cs @@ -37,9 +37,9 @@ namespace BBWY.Server.Business.Sync this.productBusiness = productBusiness; } - private void SyncProduct(ShopResponse shop, ProductListResponse productList, out string productId) + private void SyncProduct(ShopResponse shop, ProductListResponse productList) { - productId = ""; + var currentProductId = ""; try { var shopId = long.Parse(shop.ShopId); @@ -55,7 +55,7 @@ namespace BBWY.Server.Business.Sync foreach (var product in productList.Items) { - productId = product.Id; + currentProductId = product.Id; var dbProduct = dbProducts.FirstOrDefault(dbp => dbp.Id == product.Id); if (dbProduct == null) { @@ -127,7 +127,7 @@ namespace BBWY.Server.Business.Sync } catch (Exception ex) { - throw new Exception(productId, ex); + throw new Exception(currentProductId, ex); } } @@ -149,7 +149,7 @@ namespace BBWY.Server.Business.Sync var productList = productBusiness.GetProductList(request); if (productList == null || productList.Count == 0) return; - SyncProduct(shop, productList, out string productId); + SyncProduct(shop, productList); if (productList.Items.Count < 50 || !IsSyncAllProduct) break; request.PageIndex++; @@ -181,11 +181,11 @@ namespace BBWY.Server.Business.Sync public void SyncAllShopAllProduct() { var shopList = venderBusiness.GetShopList(); - SyncProduct(shopList.FirstOrDefault(s => s.ShopName == "瑞源玩具专营店"), true); //瑞源玩具专营店 - //foreach (var shop in shopList) - //{ - // Task.Factory.StartNew(() => SyncProduct(shop, true), System.Threading.CancellationToken.None, TaskCreationOptions.LongRunning, taskSchedulerManager.ProductSyncTaskScheduler); - //} + //SyncProduct(shopList.FirstOrDefault(s => s.ShopName == "瑞源玩具专营店"), true); //瑞源玩具专营店 + foreach (var shop in shopList) + { + Task.Factory.StartNew(() => SyncProduct(shop, true), System.Threading.CancellationToken.None, TaskCreationOptions.LongRunning, taskSchedulerManager.ProductSyncTaskScheduler); + } } } }