From ce8ffb7f879edc21f05c3d693fcf957784f9cbed Mon Sep 17 00:00:00 2001
From: jianweie code <jianweie@163.com>
Date: Tue, 16 May 2023 23:39:24 +0800
Subject: [PATCH] =?UTF-8?q?=E3=80=90=E4=BF=AE=E5=A4=8D=E3=80=91=E4=BF=AE?=
 =?UTF-8?q?=E5=A4=8Dsku=E8=B4=A7=E5=93=81=E5=AF=B9=E5=BA=94=E7=9A=84?=
 =?UTF-8?q?=E4=B8=89=E7=BA=A7=E5=88=86=E9=94=80=E7=BB=86=E5=88=99=E5=AD=98?=
 =?UTF-8?q?=E5=9C=A8=E5=A4=9A=E6=8F=92=E5=85=A5=E9=87=8D=E5=A4=8D=E7=BB=86?=
 =?UTF-8?q?=E5=88=99=E6=95=B0=E6=8D=AE=E7=9A=84=E9=97=AE=E9=A2=98=E3=80=82?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../Good/CoreCmsGoodsRepository.cs            | 21 ++++---------------
 1 file changed, 4 insertions(+), 17 deletions(-)

diff --git a/CoreCms.Net.Repository/Good/CoreCmsGoodsRepository.cs b/CoreCms.Net.Repository/Good/CoreCmsGoodsRepository.cs
index 0bec07d5..5778054e 100644
--- a/CoreCms.Net.Repository/Good/CoreCmsGoodsRepository.cs
+++ b/CoreCms.Net.Repository/Good/CoreCmsGoodsRepository.cs
@@ -504,8 +504,7 @@ namespace CoreCms.Net.Repository
                         }
                         //剩余的老数据
                         var oldDataProducts = products.Where(p => oldPostProductsIds.Contains(p.id)).ToList();
-                        var oldDistributions = await DbClient.Queryable<CoreCmsProductsDistribution>()
-                            .Where(p => oldPostProductsIds.Contains(p.productsId)).ToListAsync();
+                        var oldDistributions = await DbClient.Queryable<CoreCmsProductsDistribution>().Where(p => oldPostProductsIds.Contains(p.productsId)).ToListAsync();
                         if (oldDataProducts.Any())
                         {
                             oldDataProducts.ForEach(p =>
@@ -553,8 +552,10 @@ namespace CoreCms.Net.Repository
                             var newDt = new List<CoreCmsProductsDistribution>();
                             if (oldDistributions.Any())
                             {
+                                //获取已经存在的序列
                                 var ids = oldDistributions.Select(p => p.productsId).ToList();
-                                var oldNoDtProduts = oldPostProducts.Where(p => ids.Contains(p.id)).ToList();
+                                //判断货品里面是否存在三级分销细则没有对应的数据，如果存在未对应的，就新增。
+                                var oldNoDtProduts = oldPostProducts.Where(p => !ids.Contains(p.id)).ToList();
                                 if (oldNoDtProduts.Any())
                                 {
                                     oldNoDtProduts.ForEach(p =>
@@ -569,20 +570,6 @@ namespace CoreCms.Net.Repository
                                         newDt.Add(pd);
                                     });
                                 }
-                                else
-                                {
-                                    oldPostProducts.ForEach(p =>
-                                    {
-                                        var pd = new CoreCmsProductsDistribution();
-                                        pd.createTime = DateTime.Now;
-                                        pd.productsSN = p.sn;
-                                        pd.levelOne = p.levelOne;
-                                        pd.levelTwo = p.levelTwo;
-                                        pd.levelThree = p.levelThree;
-                                        pd.productsId = p.id;
-                                        newDt.Add(pd);
-                                    });
-                                }
                             }
 
                             var upOldData = await DbClient.Updateable(oldDataProducts).ExecuteCommandHasChangeAsync();