feat: 增强LqKdKdjlbService的删除逻辑，添加消耗记录和储扣记录检查

- 在批量删除和单条删除方法中添加对消耗记录和储扣记录的检查，防止删除已消耗或有储扣的开单记录 - 引入新的实体类以支持检查逻辑，确保数据一致性和完整性

feat: 增强LqKdKdjlbService的删除逻辑，添加消耗记录和储扣记录检查
- 在批量删除和单条删除方法中添加对消耗记录和储扣记录的检查，防止删除已消耗或有储扣的开单记录 - 引入新的实体类以支持检查逻辑，确保数据一致性和完整性
“wangming”
1 parent 6dd1b9bf
Showing 1 changed file with 39 additions and 1 deletions
netcore/src/Modularity/Extend/NCC.Extend/LqKdKdjlbService.cs
@@ -20,15 +20,17 @@ using NCC.Extend.Entitys.Dto.Common;
 using NCC.Extend.Entitys.Dto.LqKdDeductinfo;
 using NCC.Extend.Entitys.Dto.LqKdKdjlb;
 using NCC.Extend.Entitys.Enum;
+using NCC.Extend.Entitys.lq_hytk_hytk;
 using NCC.Extend.Entitys.lq_hytk_mx;
 using NCC.Extend.Entitys.lq_jinsanjiao_user;
 using NCC.Extend.Entitys.lq_kd_deductinfo;
+using NCC.Extend.Entitys.lq_xh_hyhk;
+using NCC.Extend.Entitys.lq_xh_pxmx;
 using NCC.Extend.Entitys.lq_kd_jksyj;
 using NCC.Extend.Entitys.lq_kd_kdjlb;
 using NCC.Extend.Entitys.lq_kd_kjbsyj;
 using NCC.Extend.Entitys.lq_kd_pxmx;
 using NCC.Extend.Entitys.lq_khxx;
-using NCC.Extend.Entitys.lq_xh_pxmx;
 using NCC.Extend.Entitys.lq_xmzl;
 using NCC.Extend.Interfaces.LqKdKdjlb;
 using NCC.Extend.Utils;
@@ -841,6 +843,22 @@ namespace NCC.Extend.LqKdKdjlb
                 {
                     //开启事务
                     _db.BeginTran();
+                    // 检查是否有消耗记录
+                    var billingItemIds = await _db.Queryable<LqKdPxmxEntity>().Where(p => ids.Contains(p.Glkdbh)).Select(p => p.Id).ToListAsync();
+                    if (billingItemIds.Any())
+                    {
+                        var consumeRecords = await _db.Queryable<LqXhPxmxEntity>().Where(x => x.IsEffective == StatusEnum.有效.GetHashCode()).Where(x => billingItemIds.Contains(x.BillingItemId)).AnyAsync();
+                        if (consumeRecords)
+                        {
+                            throw NCCException.Oh("选中的开单记录中有已消耗的记录，不能删除");
+                        }
+                    }
+                    // 检查是否有储扣记录
+                    var deductRecords = await _db.Queryable<LqKdDeductinfoEntity>().Where(x => ids.Contains(x.BillingId) && x.IsEffective == StatusEnum.有效.GetHashCode()).AnyAsync();
+                    if (deductRecords)
+                    {
+                        throw NCCException.Oh("选中的开单记录中有储扣记录，不能删除");
+                    }
                     //批量删除开单记录表
                     await _db.Deleteable<LqKdKdjlbEntity>().In(d => d.Id, ids).ExecuteCommandAsync();
  
@@ -1038,6 +1056,26 @@ namespace NCC.Extend.LqKdKdjlb
             {
                 //开启事务
                 _db.BeginTran();
+                //先查询开单品项明细
+                var lqPxmxList = _db.Queryable<LqKdPxmxEntity>().Where(x => x.Glkdbh == id).ToList();
+                //判断是否有对应的消耗记录
+                var consumeRecords = await _db.Queryable<LqXhPxmxEntity>().Where(x => lqPxmxList.Select(y => y.Id).Contains(x.BillingItemId)).AnyAsync();
+                if (consumeRecords)
+                {
+                    throw NCCException.Oh("选中的开单记录中有已消耗的记录，不能删除");
+                }
+                //判断是否有对应的退卡记录
+                var refundRecords = await _db.Queryable<LqHytkMxEntity>().Where(x => lqPxmxList.Select(y => y.Id).Contains(x.BillingItemId)).AnyAsync();
+                if (refundRecords)
+                {
+                    throw NCCException.Oh("选中的开单记录中有退卡记录，不能删除");
+                }
+                //判断是否有对应的储扣记录
+                var deductRecords = await _db.Queryable<LqKdDeductinfoEntity>().Where(x => lqPxmxList.Select(y => y.Id).Contains(x.DeductId)).AnyAsync();
+                if (deductRecords)
+                {
+                    throw NCCException.Oh("选中的开单记录中有储扣记录，不能删除");
+                }
  
                 //删除开单记录表记录
                 await _db.Deleteable<LqKdKdjlbEntity>().Where(d => d.Id == id).ExecuteCommandAsync();