diff --git a/BBWY.Server.Business/Sync/ProductSyncBusiness.cs b/BBWY.Server.Business/Sync/ProductSyncBusiness.cs index e659f07b..dbda2854 100644 --- a/BBWY.Server.Business/Sync/ProductSyncBusiness.cs +++ b/BBWY.Server.Business/Sync/ProductSyncBusiness.cs @@ -68,7 +68,6 @@ namespace BBWY.Server.Business.Sync List inserSkuList = new List(); List> updateProductSkuList = new List>(); - List deletedSkuIdList = new List(); var productIds = productList.Items.Select(p => p.Id); var dbProducts = fsql.Select().Where(p => p.ShopId == shopId && productIds.Contains(p.Id)).ToList(); @@ -95,7 +94,13 @@ namespace BBWY.Server.Business.Sync 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) - deletedSkuIdList.AddRange(deletedSkuList.Select(dbsku => dbsku.Id)); + { + foreach (var deletedSku in deletedSkuList) + { + var update = fsql.Update(deletedSku.Id).Set(s => s.State, 4); + updateProductSkuList.Add(update); + } + } foreach (var sku in skuList) { @@ -167,8 +172,6 @@ namespace BBWY.Server.Business.Sync if (updateProductSkuList.Count > 0) foreach (var update in updateProductSkuList) update.ExecuteAffrows(); - if (deletedSkuIdList.Count() > 0) - fsql.Delete(deletedSkuIdList).ExecuteAffrows(); }); }