From a52c7842f1bb99b188babdfc64b6e51a1613953a Mon Sep 17 00:00:00 2001
From: “wangming” <“wangming@antissoft.com”>
Date: Thu, 6 Nov 2025 12:45:01 +0800
Subject: [PATCH] 更新服务类：LqKdKdjlbService、LqKhxxService、LqTkjlbService

---
 netcore/src/Modularity/Extend/NCC.Extend/LqKdKdjlbService.cs |  2 +-
 netcore/src/Modularity/Extend/NCC.Extend/LqKhxxService.cs    |  2 +-
 netcore/src/Modularity/Extend/NCC.Extend/LqTkjlbService.cs   | 55 +++++++++++++++++++++++++++++++++++++++++++++++++------
 3 files changed, 51 insertions(+), 8 deletions(-)

diff --git a/netcore/src/Modularity/Extend/NCC.Extend/LqKdKdjlbService.cs b/netcore/src/Modularity/Extend/NCC.Extend/LqKdKdjlbService.cs
index f963270..6dae74b 100644
--- a/netcore/src/Modularity/Extend/NCC.Extend/LqKdKdjlbService.cs
+++ b/netcore/src/Modularity/Extend/NCC.Extend/LqKdKdjlbService.cs
@@ -2513,7 +2513,7 @@ namespace NCC.Extend.LqKdKdjlb
                 // 查询消费数量
                 var consumedCount = await _db.Queryable<LqXhPxmxEntity>()
                     .Where(x => x.BillingItemId == billingItemId && x.IsEffective == StatusEnum.有效.GetHashCode())
-                    .SumAsync(x => x.ProjectNumber);
+                    .SumAsync(x => x.OriginalProjectNumber);
 
                 // 查询退卡数量
                 var refundedCount = await _db.Queryable<LqHytkMxEntity>()
diff --git a/netcore/src/Modularity/Extend/NCC.Extend/LqKhxxService.cs b/netcore/src/Modularity/Extend/NCC.Extend/LqKhxxService.cs
index ed0d154..ad22a1d 100644
--- a/netcore/src/Modularity/Extend/NCC.Extend/LqKhxxService.cs
+++ b/netcore/src/Modularity/Extend/NCC.Extend/LqKhxxService.cs
@@ -563,7 +563,7 @@ namespace NCC.Extend.LqKhxx
                     .Select(x => new
                     {
                         BillingItemId = x.BillingItemId,
-                        TotalConsumed = SqlFunc.AggregateSum(x.ProjectNumber)
+                        TotalConsumed = SqlFunc.AggregateSum(x.OriginalProjectNumber)
                     })
                     .ToListAsync();
 
diff --git a/netcore/src/Modularity/Extend/NCC.Extend/LqTkjlbService.cs b/netcore/src/Modularity/Extend/NCC.Extend/LqTkjlbService.cs
index fd9ab12..baa800e 100644
--- a/netcore/src/Modularity/Extend/NCC.Extend/LqTkjlbService.cs
+++ b/netcore/src/Modularity/Extend/NCC.Extend/LqTkjlbService.cs
@@ -20,6 +20,7 @@ using NCC.Extend.Entitys.Enum;
 using NCC.Extend.Entitys.lq_event;
 using NCC.Extend.Entitys.lq_eventuser;
 using NCC.Extend.Entitys.lq_kd_kdjlb;
+using NCC.Extend.Entitys.lq_kd_pxmx;
 using NCC.Extend.Entitys.lq_khxx;
 using NCC.Extend.Entitys.lq_mdxx;
 using NCC.Extend.Entitys.lq_tkjlb;
@@ -203,13 +204,55 @@ namespace NCC.Extend.LqTkjlb
                     throw NCCException.Oh("创建客户信息失败");
                 }
                 var storeinfo = await _db.Queryable<LqMdxxEntity>().Where(u => u.Id == eventUserInfo.StoreId).FirstAsync();
-                return new { entity = entity, storeinfo = storeinfo };
+                //会员添加成功后，就默认进行一个体验开单操作
+                var kdentity = new LqKdKdjlbEntity
+                {
+                    Id = YitIdHelper.NextId().ToString(),
+                    Djmd = eventUserInfo.StoreId,
+                    Kdrq = DateTime.Now,
+                    Gjlx = MemberTypeEnum.线索.GetHashCode().ToString(),
+                    Zdyj = 0,
+                    Sfyj = 0,
+                    Qk = 0,
+                    PaidDebt = 0,
+                    DeductAmount = 0,
+                    Fkfs = "微信",
+                    Sfskdd = "否",
+                    Kdhy = MemberId,
+                    CreateUser = input.expansionUserId,
+                    CreateTime = DateTime.Now,
+                    IsEffective = StatusEnum.有效.GetHashCode(),
+                };
+                var kdResult = await _db.Insertable(kdentity).IgnoreColumns(ignoreNullColumn: true).ExecuteCommandAsync();
+                if (!(kdResult > 0))
+                {
+                    throw NCCException.Oh("添加开单记录失败");
+                }
+                //添加品项明细表
+                var pxmxentity = new LqKdPxmxEntity
+                {
+                    Id = YitIdHelper.NextId().ToString(),
+                    Glkdbh = kdentity.Id,
+                    Px = "61",
+                    Pxmc = "女神卡",
+                    Pxjg = 0,
+                    Yjsj = DateTime.Now,
+                    MemberId = MemberId,
+                    ProjectNumber = 0,
+                    IsEnabled = StatusEnum.有效.GetHashCode(),
+                    SourceType = "体验",
+                    TotalPrice = 0,
+                    ActualPrice = 0,
+                    IsEffective = StatusEnum.有效.GetHashCode(),
+                    CreateTIme = DateTime.Now,
+                };
+                var pxmxResult = await _db.Insertable(pxmxentity).IgnoreColumns(ignoreNullColumn: true).ExecuteCommandAsync();
+                if (!(pxmxResult > 0))
+                {
+                    throw NCCException.Oh("添加品项明细表失败");
+                }
+                return new { entity = entity, storeinfo = storeinfo, kdentity = kdentity, pxmxentity = pxmxentity };
             });
-
-            if (!result.IsSuccess)
-            {
-                return NCCException.Oh($"创建拓客记录失败：{result.ErrorMessage}");
-            }
             return result.Data;
         }
         #endregion
--
libgit2 0.21.4