From 098e5bc8dbee3a99f12e6abf6ea445f26f1ef163 Mon Sep 17 00:00:00 2001
From: shanji <18996038927@163.com>
Date: Wed, 30 Aug 2023 16:16:02 +0800
Subject: [PATCH] =?UTF-8?q?=E7=BC=96=E8=BE=91=E9=87=87=E8=B4=AD=E6=96=B9?=
 =?UTF-8?q?=E6=A1=88=E6=96=B0=E5=A2=9E=E5=88=86=E7=BB=84=E5=90=8D=E5=AD=97?=
 =?UTF-8?q?=E8=87=AA=E5=A2=9E?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../PurchaseScheme/PurchaseSchemeBusiness.cs  | 29 +++++++++++++++++--
 1 file changed, 26 insertions(+), 3 deletions(-)

diff --git a/BBWYB.Server.Business/PurchaseScheme/PurchaseSchemeBusiness.cs b/BBWYB.Server.Business/PurchaseScheme/PurchaseSchemeBusiness.cs
index 63ac8a3..301ed96 100644
--- a/BBWYB.Server.Business/PurchaseScheme/PurchaseSchemeBusiness.cs
+++ b/BBWYB.Server.Business/PurchaseScheme/PurchaseSchemeBusiness.cs
@@ -305,22 +305,43 @@ namespace BBWYB.Server.Business
             List<long> deletePurchaseSchemeIdList = new List<long>();
             List<IUpdate<PurchaseScheme>> updatePurchaseSchemeList = new List<IUpdate<PurchaseScheme>>();
             List<PurchaseSchemeGroup> insertPurchaseSchemeGroupsList = new List<PurchaseSchemeGroup>();
+            IInsert<PurchaseSchemeGroupIndex> insertPurchaseSchemeGroupIndex = null;
+            IUpdate<PurchaseSchemeGroupIndex> updatePurchaseSchemeGroupIndex = null;
 
             if (batchCURDSchemeRequest.AddPurchaseSchemeList != null && batchCURDSchemeRequest.AddPurchaseSchemeList.Count > 0)
             {
+                var firstScheme = batchCURDSchemeRequest.AddPurchaseSchemeList.First();
+
                 ExtractNewPurchaser(batchCURDSchemeRequest.AddPurchaseSchemeList, newPurchaserList);
 
                 #region 新建分组
                 long? newPurchaseGroupId = null;
                 if (batchCURDSchemeRequest.AddPurchaseSchemeList.Any(ps => ps.SchemeGroupId == 0 || ps.SchemeGroupId == null))
                 {
-                    //新增分组
-                    var firstScheme = batchCURDSchemeRequest.AddPurchaseSchemeList.First();
+                    var dbPurchaseSchemeGroupIndex = fsql.Select<PurchaseSchemeGroupIndex>().Where(psgi => psgi.ProductId == firstScheme.ProductId).ToOne();
+                    if (dbPurchaseSchemeGroupIndex == null)
+                    {
+                        dbPurchaseSchemeGroupIndex = new PurchaseSchemeGroupIndex()
+                        {
+                            CreateTime = DateTime.Now,
+                            Index = 1,
+                            ProductId = firstScheme.ProductId,
+                            ShopId = firstScheme.ShopId
+                        };
+                        insertPurchaseSchemeGroupIndex = fsql.Insert(dbPurchaseSchemeGroupIndex);
+                    }
+                    else
+                    {
+                        dbPurchaseSchemeGroupIndex.Index++;
+                        updatePurchaseSchemeGroupIndex = fsql.Update<PurchaseSchemeGroupIndex>(dbPurchaseSchemeGroupIndex.ProductId)
+                                                             .Set(x => x.Index, dbPurchaseSchemeGroupIndex.Index);
+                    }
+
                     var insertSchemeGroup = new PurchaseSchemeGroup()
                     {
                         Id = idGenerator.NewLong(),
                         CreateTime = DateTime.Now,
-                        GroupName = $"{firstScheme.ProductId}-{DateTime.Now:yyyyMMddHHmmss}",
+                        GroupName = $"{firstScheme.ProductId}-{dbPurchaseSchemeGroupIndex.Index}",
                         ProductId = firstScheme.ProductId,
                         ShopId = firstScheme.ShopId
                     };
@@ -436,6 +457,8 @@ namespace BBWYB.Server.Business
                     foreach (var update in updatePurchaseSchemeList)
                         update.ExecuteAffrows();
                 }
+                insertPurchaseSchemeGroupIndex?.ExecuteAffrows();
+                updatePurchaseSchemeGroupIndex?.ExecuteAffrows();
             });
         }