|
|
@ -44,148 +44,6 @@ namespace BBWY.Server.Business.Sync |
|
|
this.categoryCache = new ConcurrentDictionary<string, string>(); |
|
|
this.categoryCache = new ConcurrentDictionary<string, string>(); |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
private string GetMainSkuId(IList<ProductSkuResponse> skuList) |
|
|
|
|
|
{ |
|
|
|
|
|
var maxPrice = skuList.Max(s => s.Price); |
|
|
|
|
|
var sku = skuList.FirstOrDefault(s => s.Price == maxPrice && s.State == 1); |
|
|
|
|
|
return sku?.Id ?? string.Empty; |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
private bool CheckMainSkuState(IList<ProductSkuResponse> skuList, string mainSkuId) |
|
|
|
|
|
{ |
|
|
|
|
|
if (string.IsNullOrEmpty(mainSkuId)) |
|
|
|
|
|
return false; |
|
|
|
|
|
var mainSku = skuList.FirstOrDefault(s => s.Id == mainSkuId); |
|
|
|
|
|
if (mainSku == null || mainSku.State != 1) |
|
|
|
|
|
return false; |
|
|
|
|
|
return true; |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
private void SyncProduct(ShopResponse shop, ProductListResponse productList) |
|
|
|
|
|
{ |
|
|
|
|
|
var currentProductId = ""; |
|
|
|
|
|
try |
|
|
|
|
|
{ |
|
|
|
|
|
var shopId = long.Parse(shop.ShopId); |
|
|
|
|
|
List<Product> insertProductList = new List<Product>(); |
|
|
|
|
|
List<IUpdate<Product>> updateProductList = new List<IUpdate<Product>>(); |
|
|
|
|
|
|
|
|
|
|
|
List<ProductSku> inserSkuList = new List<ProductSku>(); |
|
|
|
|
|
List<IUpdate<ProductSku>> updateProductSkuList = new List<IUpdate<ProductSku>>(); |
|
|
|
|
|
|
|
|
|
|
|
var productIds = productList.Items.Select(p => p.Id); |
|
|
|
|
|
var dbProducts = fsql.Select<Product>().Where(p => p.ShopId == shopId && productIds.Contains(p.Id)).ToList(); |
|
|
|
|
|
var dbProductSkus = fsql.Select<ProductSku>().Where(s => s.ShopId == shopId && productIds.Contains(s.ProductId)).ToList(); |
|
|
|
|
|
|
|
|
|
|
|
foreach (var product in productList.Items) |
|
|
|
|
|
{ |
|
|
|
|
|
Thread.Sleep(200); |
|
|
|
|
|
currentProductId = product.Id; |
|
|
|
|
|
|
|
|
|
|
|
#region 检查sku
|
|
|
|
|
|
var skuList = productBusiness.GetProductSkuList(new SearchProductSkuRequest() |
|
|
|
|
|
{ |
|
|
|
|
|
AppKey = shop.AppKey, |
|
|
|
|
|
AppSecret = shop.AppSecret, |
|
|
|
|
|
AppToken = shop.AppToken, |
|
|
|
|
|
Platform = shop.PlatformId, |
|
|
|
|
|
Spu = product.Id, |
|
|
|
|
|
IsContainSource = true |
|
|
|
|
|
}); |
|
|
|
|
|
if (skuList == null || skuList.Count() == 0) |
|
|
|
|
|
continue; |
|
|
|
|
|
|
|
|
|
|
|
//排查已删除的sku
|
|
|
|
|
|
var currentDbSkus = dbProductSkus.Where(dbsku => dbsku.ProductId == product.Id).ToList(); |
|
|
|
|
|
var deletedSkuList = currentDbSkus.Where(dbsku => skuList.Count(s => s.Id == dbsku.Id) == 0).ToList(); |
|
|
|
|
|
if (deletedSkuList.Count() > 0) |
|
|
|
|
|
{ |
|
|
|
|
|
foreach (var deletedSku in deletedSkuList) |
|
|
|
|
|
{ |
|
|
|
|
|
var update = fsql.Update<ProductSku>(deletedSku.Id).Set(s => s.State, 4); |
|
|
|
|
|
updateProductSkuList.Add(update); |
|
|
|
|
|
} |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
foreach (var sku in skuList) |
|
|
|
|
|
{ |
|
|
|
|
|
var categoryId = sku.Source.Value<int>("categoryId"); |
|
|
|
|
|
var dbSku = dbProductSkus.FirstOrDefault(s => s.Id == sku.Id); |
|
|
|
|
|
if (dbSku == null) |
|
|
|
|
|
{ |
|
|
|
|
|
inserSkuList.Add(new ProductSku() |
|
|
|
|
|
{ |
|
|
|
|
|
Id = sku.Id, |
|
|
|
|
|
CreateTime = sku.CreateTime ?? DateTime.Now, |
|
|
|
|
|
Logo = sku.Logo, |
|
|
|
|
|
Platform = shop.PlatformId, |
|
|
|
|
|
Price = sku.Price, |
|
|
|
|
|
ProductId = sku.ProductId, |
|
|
|
|
|
ShopId = shopId, |
|
|
|
|
|
Title = sku.Title, |
|
|
|
|
|
State = sku.State, |
|
|
|
|
|
CategoryId = categoryId |
|
|
|
|
|
}); |
|
|
|
|
|
} |
|
|
|
|
|
else if (dbSku.State != sku.State || dbSku.Price != sku.Price || dbSku.CategoryId != categoryId) |
|
|
|
|
|
{ |
|
|
|
|
|
var update = fsql.Update<ProductSku>(dbSku.Id) |
|
|
|
|
|
.Set(s => s.State, sku.State) |
|
|
|
|
|
.Set(s => s.Price, sku.Price) |
|
|
|
|
|
.Set(s => s.CategoryId, categoryId); |
|
|
|
|
|
updateProductSkuList.Add(update); |
|
|
|
|
|
} |
|
|
|
|
|
} |
|
|
|
|
|
#endregion
|
|
|
|
|
|
|
|
|
|
|
|
#region 检查产品
|
|
|
|
|
|
var dbProduct = dbProducts.FirstOrDefault(dbp => dbp.Id == product.Id); |
|
|
|
|
|
if (dbProduct == null) |
|
|
|
|
|
{ |
|
|
|
|
|
insertProductList.Add(new Product() |
|
|
|
|
|
{ |
|
|
|
|
|
Id = product.Id, |
|
|
|
|
|
CreateTime = product.CreateTime ?? DateTime.Now, |
|
|
|
|
|
Platform = shop.PlatformId, |
|
|
|
|
|
ProductItemNum = product.ProductItemNum, |
|
|
|
|
|
ShopId = shopId, |
|
|
|
|
|
Title = product.Title, |
|
|
|
|
|
State = product.State, |
|
|
|
|
|
MainSkuId = GetMainSkuId(skuList) |
|
|
|
|
|
}); |
|
|
|
|
|
} |
|
|
|
|
|
else if (dbProduct.State != product.State || !CheckMainSkuState(skuList, dbProduct.MainSkuId)) |
|
|
|
|
|
{ |
|
|
|
|
|
string newMainSkuId = string.Empty; |
|
|
|
|
|
if (!CheckMainSkuState(skuList, dbProduct.MainSkuId)) |
|
|
|
|
|
newMainSkuId = GetMainSkuId(skuList); |
|
|
|
|
|
|
|
|
|
|
|
var update = fsql.Update<Product>(product.Id).SetIf(dbProduct.State != product.State, p => p.State, product.State) |
|
|
|
|
|
.SetIf(!string.IsNullOrEmpty(newMainSkuId), p => p.MainSkuId, newMainSkuId); |
|
|
|
|
|
updateProductList.Add(update); |
|
|
|
|
|
} |
|
|
|
|
|
#endregion
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
fsql.Transaction(() => |
|
|
|
|
|
{ |
|
|
|
|
|
fsql.Insert(insertProductList).ExecuteAffrows(); |
|
|
|
|
|
fsql.Insert(inserSkuList).ExecuteAffrows(); |
|
|
|
|
|
if (updateProductList.Count > 0) |
|
|
|
|
|
foreach (var update in updateProductList) |
|
|
|
|
|
update.ExecuteAffrows(); |
|
|
|
|
|
if (updateProductSkuList.Count > 0) |
|
|
|
|
|
foreach (var update in updateProductSkuList) |
|
|
|
|
|
update.ExecuteAffrows(); |
|
|
|
|
|
|
|
|
|
|
|
}); |
|
|
|
|
|
} |
|
|
|
|
|
catch (Exception ex) |
|
|
|
|
|
{ |
|
|
|
|
|
throw new Exception(currentProductId, ex); |
|
|
|
|
|
} |
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
private void SyncProduct(ShopResponse shop, bool IsSyncAllProduct = false) |
|
|
private void SyncProduct(ShopResponse shop, bool IsSyncAllProduct = false) |
|
|
{ |
|
|
{ |
|
|
try |
|
|
try |
|
|
|
