Browse Source

同步产品更新spu/spu标题

AddValidOverTime
shanji 2 years ago
parent
commit
e5f5154759
  1. 2
      BBWY.Server.Business/Sync/OrderSyncBusiness.cs
  2. 12
      BBWY.Server.Business/Sync/ProductSyncBusiness.cs

2
BBWY.Server.Business/Sync/OrderSyncBusiness.cs

@ -385,7 +385,7 @@ namespace BBWY.Server.Business
var currentDbOrderSkuList = dbOrderSkuList.Where(osku => osku.OrderId == orderId).ToList(); var currentDbOrderSkuList = dbOrderSkuList.Where(osku => osku.OrderId == orderId).ToList();
#region OrderSku
var itemInfoList = orderJToken["itemInfoList"] as JArray; var itemInfoList = orderJToken["itemInfoList"] as JArray;
foreach (var orderSkuJToken in itemInfoList) foreach (var orderSkuJToken in itemInfoList)
{ {

12
BBWY.Server.Business/Sync/ProductSyncBusiness.cs

@ -259,13 +259,14 @@ namespace BBWY.Server.Business.Sync
} }
#endregion #endregion
#region 找出状态变化的产品 #region 找出变化的产品 (状态,标题)
var stateChangeProductList = productList.Where(p => dbProductList.Any(dp => dp.Id == p.Id && dp.State != p.State)).ToList(); var stateChangeProductList = productList.Where(p => dbProductList.Any(dp => dp.Id == p.Id && (dp.State != p.State || dp.Title != p.Title))).ToList();
if (stateChangeProductList.Count() > 0) if (stateChangeProductList.Count() > 0)
{ {
foreach (var product in stateChangeProductList) foreach (var product in stateChangeProductList)
{ {
var update = fsql.Update<Product>(product.Id).Set(p => p.State, product.State); var update = fsql.Update<Product>(product.Id).Set(p => p.State, product.State)
.Set(p => p.Title, product.Title);
updateProductList.Add(update); updateProductList.Add(update);
} }
} }
@ -303,12 +304,13 @@ namespace BBWY.Server.Business.Sync
#endregion #endregion
#region 找出状态变化的SKU #region 找出状态变化的SKU
var stateChangeProductSkuList = productSkuList.Where(p => dbProductSkuList.Any(dp => dp.Id == p.Id && dp.State != p.State)).ToList(); var stateChangeProductSkuList = productSkuList.Where(p => dbProductSkuList.Any(dp => dp.Id == p.Id && (dp.State != p.State || dp.Title != p.Title))).ToList();
if (stateChangeProductSkuList.Count() > 0) if (stateChangeProductSkuList.Count() > 0)
{ {
foreach (var productSku in stateChangeProductSkuList) foreach (var productSku in stateChangeProductSkuList)
{ {
var update = fsql.Update<ProductSku>(productSku.Id).Set(p => p.State, productSku.State); var update = fsql.Update<ProductSku>(productSku.Id).Set(p => p.State, productSku.State)
.Set(p => p.Title, productSku.Title);
updateProductSkuList.Add(update); updateProductSkuList.Add(update);
} }
} }

Loading…
Cancel
Save