antissoft / lvqianmeiye_ERP

  using System;
  using System.Collections.Generic;
  using System.Linq;
  using System.Threading.Tasks;
  using Mapster;
  using Microsoft.AspNetCore.Mvc;
  using NCC.ClayObject;
  using NCC.Common.Configuration;

  using NCC.Common.Core.Manager;

  using NCC.Common.Enum;
  using NCC.Common.Extension;
  using NCC.Common.Filter;

  using NCC.Common.Helper;
  using NCC.Common.Model.NPOI;
  using NCC.DataEncryption;

  using NCC.Dependency;
  using NCC.DynamicApiController;

  using NCC.Extend.Entitys.Dto.LqHytkHytk;

  using NCC.Extend.Entitys.Dto.LqHytkJksyj;
  using NCC.Extend.Entitys.Dto.LqHytkKjbsyj;

  using NCC.Extend.Entitys.Dto.LqHytkMx;

  using NCC.Extend.Entitys.Enum;

  using NCC.Extend.Entitys.lq_hytk_hytk;
  using NCC.Extend.Entitys.lq_hytk_jksyj;
  using NCC.Extend.Entitys.lq_hytk_kjbsyj;
  using NCC.Extend.Entitys.lq_hytk_mx;

  using NCC.Extend.Entitys.lq_kd_pxmx;

  using NCC.Extend.Interfaces.LqHytkHytk;
  using NCC.FriendlyException;

  using NCC.JsonSerialization;

  using SqlSugar;
  using Yitter.IdGenerator;

  
  namespace NCC.Extend.LqHytkHytk
  {
      /// <summary>

      /// 退卡_信息表服务

      /// </summary>

      [ApiDescriptionSettings(Tag = "绿纤退卡信息表服务", Name = "LqHytkHytk", Order = 200)]

      [Route("api/Extend/[controller]")]
      public class LqHytkHytkService : ILqHytkHytkService, IDynamicApiController, ITransient
      {
          private readonly ISqlSugarRepository<LqHytkHytkEntity> _lqHytkHytkRepository;
          private readonly ISqlSugarRepository<LqHytkMxEntity> _lqHytkMxRepository;

          private readonly ISqlSugarRepository<LqHytkJksyjEntity> _lqHytkJksyjRepository;
          private readonly ISqlSugarRepository<LqHytkKjbsyjEntity> _lqHytkKjbsyjRepository;

          private readonly SqlSugarScope _db;
          private readonly IUserManager _userManager;
  
          /// <summary>
          /// 初始化一个<see cref="LqHytkHytkService"/>类型的新实例
          /// </summary>
          public LqHytkHytkService(
              ISqlSugarRepository<LqHytkHytkEntity> lqHytkHytkRepository,
              ISqlSugarRepository<LqHytkMxEntity> lqHytkMxRepository,

              ISqlSugarRepository<LqHytkJksyjEntity> lqHytkJksyjRepository,
              ISqlSugarRepository<LqHytkKjbsyjEntity> lqHytkKjbsyjRepository,

              IUserManager userManager
          )

          {

              _lqHytkHytkRepository = lqHytkHytkRepository;

              _lqHytkMxRepository = lqHytkMxRepository;

              _lqHytkJksyjRepository = lqHytkJksyjRepository;
              _lqHytkKjbsyjRepository = lqHytkKjbsyjRepository;
              _db = _lqHytkHytkRepository.Context;

              _userManager = userManager;
          }
  

          #region 获取退卡信息列表

          /// <summary>

          /// 获取退卡信息列表

          /// </summary>

          /// <param name="input">查询参数</param>

          /// <returns></returns>

          [HttpGet("")]
          public async Task<dynamic> GetList([FromQuery] LqHytkHytkListQueryInput input)
          {
              var sidx = input.sidx == null ? "id" : input.sidx;

              List<string> queryTksj = input.tksj != null ? input.tksj.Split(',').ToObeject<List<string>>() : null;

              DateTime? startTksj = queryTksj != null ? Ext.GetDateTime(queryTksj.First()) : null;
              DateTime? endTksj = queryTksj != null ? Ext.GetDateTime(queryTksj.Last()) : null;
              var data = await _db.Queryable<LqHytkHytkEntity>()
                  .WhereIF(!string.IsNullOrEmpty(input.id), p => p.Id.Contains(input.id))
                  .WhereIF(!string.IsNullOrEmpty(input.md), p => p.Md.Equals(input.md))

                  .WhereIF(!string.IsNullOrEmpty(input.mdbh), p => p.Mdbh.Contains(input.mdbh))

                  .WhereIF(!string.IsNullOrEmpty(input.mdmc), p => p.Mdmc.Contains(input.mdmc))
                  .WhereIF(!string.IsNullOrEmpty(input.hy), p => p.Hy.Equals(input.hy))

                  .WhereIF(!string.IsNullOrEmpty(input.hymc), p => p.Hymc.Contains(input.hymc))

                  .WhereIF(!string.IsNullOrEmpty(input.hyzh), p => p.Hyzh.Contains(input.hyzh))

                  .WhereIF(!string.IsNullOrEmpty(input.gklx), p => p.Gklx.Contains(input.gklx))
                  .WhereIF(input.tkje.HasValue, p => p.Tkje == input.tkje)
                  .WhereIF(input.sgfy.HasValue, p => p.Sgfy == input.sgfy)

                  .WhereIF(!string.IsNullOrEmpty(input.bz), p => p.Bz.Contains(input.bz))

                  .WhereIF(!string.IsNullOrEmpty(input.tkzt), p => p.Tkzt.Contains(input.tkzt))
                  .WhereIF(!string.IsNullOrEmpty(input.tkyy), p => p.Tkyy.Contains(input.tkyy))

                  .WhereIF(!string.IsNullOrEmpty(input.fileUrl), p => p.FileUrl.Contains(input.fileUrl))
                  .WhereIF(queryTksj != null, p => p.Tksj >= new DateTime(startTksj.ToDate().Year, startTksj.ToDate().Month, startTksj.ToDate().Day, 0, 0, 0))
                  .WhereIF(queryTksj != null, p => p.Tksj <= new DateTime(endTksj.ToDate().Year, endTksj.ToDate().Month, endTksj.ToDate().Day, 23, 59, 59))

                  .WhereIF(!string.IsNullOrEmpty(input.czry), p => p.Czry.Equals(input.czry))

                  .WhereIF(input.isEffective != 0, p => p.IsEffective == input.isEffective)

                  .Select(it => new LqHytkHytkListOutput

                  {
                      id = it.Id,

                      md = it.Md,
                      mdbh = it.Mdbh,
                      mdmc = it.Mdmc,
                      hy = it.Hy,
                      hymc = it.Hymc,
                      hyzh = it.Hyzh,
                      gklx = it.Gklx,
                      tkje = it.Tkje,
                      sgfy = it.Sgfy,
                      bz = it.Bz,
                      tkzt = it.Tkzt,
                      tkyy = it.Tkyy,
                      tksj = it.Tksj,
                      czry = it.Czry,
                      fileUrl = it.FileUrl,

                      isEffective = it.IsEffective,

                      cancelRemark = it.CancelRemark,

                      actualRefundAmount = it.ActualRefundAmount

                  })
                  .MergeTable()
                  .OrderBy(sidx + " " + input.sort)
                  .ToPagedListAsync(input.currentPage, input.pageSize);
              return PageResult<LqHytkHytkListOutput>.SqlSugarPageResult(data);

          }

          #endregion

          #region 创建退卡信息及其关联的品项明细、健康师业绩、科技部老师业绩信息

          /// <summary>

          /// 创建退卡信息及其关联的品项明细、健康师业绩、科技部老师业绩信息

          /// </summary>

          /// <remarks>
          /// 创建退卡记录及其关联的品项明细、健康师业绩、科技部老师业绩信息

          ///

          /// 示例请求：
          /// ```json
          /// {
          ///   "md": "门店ID",
          ///   "mdbh": "门店编号",
          ///   "mdmc": "门店名称",
          ///   "hy": "会员ID",
          ///   "hymc": "会员姓名",
          ///   "hyzh": "会员账号",
          ///   "gklx": "顾客类型",
          ///   "tkje": 1000.00,
          ///   "sgfy": 50.00,
          ///   "bz": "备注",
          ///   "tkzt": "退卡状态",
          ///   "tkyy": "退卡原因",
          ///   "lqHytkMxList": [
          ///     {
          ///       "px": "品项编号",
          ///       "pxmc": "品项名称",
          ///       "pxjg": 100.00,
          ///       "tkje": 100.00,
          ///       "F_ProjectNumber": 1,
          ///       "F_SourceType": "来源类型",
          ///       "F_TotalPrice": 100.00,
          ///       "lqHytkJksyjList": [
          ///         {
          ///           "jks": "健康师",
          ///           "jksxm": "健康师姓名",
          ///           "jkszh": "健康师账号",
          ///           "jksyj": 50.00,
          ///           "F_jsjid": "金三角ID",
          ///           "F_tkpxid": "项目资料ID",
          ///           "F_LaborCost": 10.00,
          ///           "F_tkpxNumber": 1
          ///         }
          ///       ],
          ///       "lqHytkKjbsyjList": [
          ///         {
          ///           "kjbls": "科技部老师",
          ///           "kjblsxm": "科技部老师姓名",
          ///           "kjblszh": "科技部老师账号",
          ///           "kjblsyj": 30.00,
          ///           "F_tkpxid": "项目资料ID",
          ///           "F_LaborCost": 5.00,
          ///           "F_tkpxNumber": 1
          ///         }
          ///       ]
          ///     }
          ///   ]
          /// }
          /// ```

          ///

          /// 参数说明：
          /// - md: 门店ID
          /// - hy: 会员ID
          /// - lqHytkMxList: 退卡品项明细列表
          /// </remarks>
          /// <param name="input">退卡创建参数</param>
          /// <returns>无返回值</returns>
          /// <response code="200">创建成功</response>
          /// <response code="400">参数错误或数据验证失败</response>
          /// <response code="500">服务器内部错误</response>

          [HttpPost("")]
          public async Task Create([FromBody] LqHytkHytkCrInput input)
          {
              var userInfo = await _userManager.GetUserInfo();
              var entity = input.Adapt<LqHytkHytkEntity>();
              entity.Id = YitIdHelper.NextId().ToString();

              entity.F_CreateTime = DateTime.Now;
              entity.F_CreateUser = userInfo.userId;

              entity.IsEffective = StatusEnum.有效.GetHashCode();

              entity.Czry = userInfo.userId;

              try
              {

                  // 开启事务

                  _db.BeginTran();

                  // 新增退卡主表记录

                  var newEntity = await _db.Insertable(entity).IgnoreColumns(ignoreNullColumn: true).ExecuteReturnEntityAsync();

                  // 收集所有需要插入的实体，然后批量插入
                  var allMxEntities = new List<LqHytkMxEntity>();
                  var allJksyjEntities = new List<LqHytkJksyjEntity>();
                  var allKjbsyjEntities = new List<LqHytkKjbsyjEntity>();

                  // 处理品项明细列表
                  if (input.lqHytkMxList != null && input.lqHytkMxList.Any())

                  {

                      foreach (var item in input.lqHytkMxList)

                      {

                          // 创建品项明细实体
                          var lqHytkMxEntity = new LqHytkMxEntity
                          {
                              Id = YitIdHelper.NextId().ToString(),

                              RefundInfoId = newEntity.Id,
                              BillingItemId = item.billingItemId,

                              MemberId = newEntity.Hy,

                              CreateTime = DateTime.Now,
                              CreateUser = userInfo.userId,

                              Px = item.px,
                              Pxmc = item.pxmc,
                              Pxjg = item.pxjg,
                              Tkje = item.tkje,

                              ProjectNumber = item.F_ProjectNumber ?? 1,

                              SourceType = item.F_SourceType,
                              TotalPrice = item.F_TotalPrice ?? (item.pxjg * (item.F_ProjectNumber ?? 1)),

                              IsEffective = StatusEnum.有效.GetHashCode(),

                          };
                          allMxEntities.Add(lqHytkMxEntity);

                          // 收集该品项关联的健康师业绩
                          if (item.lqHytkJksyjList != null && item.lqHytkJksyjList.Any())
                          {
                              foreach (var ijks_tem in item.lqHytkJksyjList)
                              {

                                  allJksyjEntities.Add(new LqHytkJksyjEntity
                                  {
                                      Id = YitIdHelper.NextId().ToString(),
                                      Gltkbh = newEntity.Id,
                                      Jks = ijks_tem.jks,
                                      Jksxm = ijks_tem.jksxm,
                                      Jkszh = ijks_tem.jkszh,
                                      Jksyj = ijks_tem.jksyj,
                                      Tksj = DateTime.Now,
                                      F_jsjid = ijks_tem.F_jsjid,
                                      F_tkpxid = ijks_tem.F_tkpxid,
                                      F_LaborCost = ijks_tem.F_LaborCost,
                                      F_tkpxNumber = ijks_tem.F_tkpxNumber,
                                      F_CreateTime = DateTime.Now,
                                      F_CreateUser = userInfo.userId,

                                      CardReturn = lqHytkMxEntity.Id,
                                      IsEffective = StatusEnum.有效.GetHashCode(),
                                  }

                                  );

                              }
                          }

                          // 收集该品项关联的科技部老师业绩
                          if (item.lqHytkKjbsyjList != null && item.lqHytkKjbsyjList.Any())
                          {
                              foreach (var ikjbs_tem in item.lqHytkKjbsyjList)
                              {

                                  allKjbsyjEntities.Add(
                                      new LqHytkKjbsyjEntity
                                      {
                                          Id = YitIdHelper.NextId().ToString(),
                                          Gltkbh = newEntity.Id,
                                          Kjbls = ikjbs_tem.kjbls,
                                          Kjblsxm = ikjbs_tem.kjblsxm,
                                          Kjblszh = ikjbs_tem.kjblszh,
                                          Kjblsyj = ikjbs_tem.kjblsyj,
                                          Tksj = DateTime.Now,
                                          F_tkpxid = ikjbs_tem.F_tkpxid,
                                          F_LaborCost = ikjbs_tem.F_LaborCost,
                                          F_tkpxNumber = ikjbs_tem.F_tkpxNumber,
                                          F_CreateTime = DateTime.Now,
                                          F_CreateUser = userInfo.userId,

                                          CardReturn = lqHytkMxEntity.Id,

                                          IsEffective = StatusEnum.有效.GetHashCode(),

                                      }
                                  );

                              }
                          }

                      }

                  }

                  // 批量插入品项明细
                  if (allMxEntities.Any())

                  {

                      await _db.Insertable(allMxEntities).ExecuteCommandAsync();

                  }

                  // 批量插入健康师业绩
                  if (allJksyjEntities.Any())

                  {

                      await _db.Insertable(allJksyjEntities).ExecuteCommandAsync();

                  }

                  // 批量插入科技部老师业绩
                  if (allKjbsyjEntities.Any())

                  {

                      await _db.Insertable(allKjbsyjEntities).ExecuteCommandAsync();

                  }

                  // 关闭事务
                  _db.CommitTran();
              }
              catch (Exception ex)
              {
                  _db.RollbackTran();
                  throw NCCException.Oh(ErrorCode.COM1005, ex.Message);

              }
          }

          #endregion

          #region 更新退卡信息及其关联的品项明细、健康师业绩、科技部老师业绩信息

          /// <summary>

          /// 更新退卡信息及其关联的品项明细、健康师业绩、科技部老师业绩信息

          /// </summary>

          /// <remarks>
          /// 更新退卡记录及其关联的品项明细、健康师业绩、科技部老师业绩信息
          /// 先删除原有的关联数据，再插入新的数据
          /// </remarks>
          /// <param name="id">退卡ID</param>
          /// <param name="input">退卡更新参数</param>
          /// <returns>无返回值</returns>
          /// <response code="200">更新成功</response>
          /// <response code="400">参数错误或数据验证失败</response>
          /// <response code="500">服务器内部错误</response>

          [HttpPut("{id}")]
          public async Task Update(string id, [FromBody] LqHytkHytkUpInput input)
          {

              var userInfo = await _userManager.GetUserInfo();

              var entity = input.Adapt<LqHytkHytkEntity>();

              entity.Id = id;
              entity.F_ModifyTime = DateTime.Now;
              entity.F_ModifyUser = userInfo.userId;

              try
              {

                  // 开启事务

                  _db.BeginTran();

                  // 更新退卡主表记录
                  await _db.Updateable(entity).IgnoreColumns(true).ExecuteCommandAsync();

                  // 删除原有的关联数据

                  await _db.Deleteable<LqHytkMxEntity>().Where(x => x.RefundInfoId == id).ExecuteCommandAsync();

                  await _db.Deleteable<LqHytkJksyjEntity>().Where(x => x.Gltkbh == id).ExecuteCommandAsync();
                  await _db.Deleteable<LqHytkKjbsyjEntity>().Where(x => x.Gltkbh == id).ExecuteCommandAsync();

                  // 收集所有需要插入的实体，然后批量插入
                  var allMxEntities = new List<LqHytkMxEntity>();
                  var allJksyjEntities = new List<LqHytkJksyjEntity>();
                  var allKjbsyjEntities = new List<LqHytkKjbsyjEntity>();

                  // 处理品项明细列表
                  if (input.lqHytkMxList != null && input.lqHytkMxList.Any())

                  {

                      foreach (var item in input.lqHytkMxList)

                      {

                          // 创建品项明细实体
                          var lqHytkMxEntity = new LqHytkMxEntity
                          {
                              Id = YitIdHelper.NextId().ToString(),

                              RefundInfoId = id,
                              BillingItemId = item.billingItemId,

                              MemberId = entity.Hy,

                              CreateTime = DateTime.Now,
                              CreateUser = userInfo.userId,

                              Tksj = input.tksj,

                              Px = item.px,
                              Pxmc = item.pxmc,
                              Pxjg = item.pxjg,
                              Tkje = item.tkje,

                              ProjectNumber = item.F_ProjectNumber ?? 1,

                              SourceType = item.F_SourceType,
                              TotalPrice = item.F_TotalPrice ?? (item.pxjg * (item.F_ProjectNumber ?? 1)),

                          };
                          allMxEntities.Add(lqHytkMxEntity);

                          // 收集该品项关联的健康师业绩
                          if (item.lqHytkJksyjList != null && item.lqHytkJksyjList.Any())
                          {
                              foreach (var ijks_tem in item.lqHytkJksyjList)
                              {

                                  allJksyjEntities.Add(
                                      new LqHytkJksyjEntity
                                      {
                                          Id = YitIdHelper.NextId().ToString(),
                                          Gltkbh = id,
                                          Jks = ijks_tem.jks,
                                          Jksxm = ijks_tem.jksxm,
                                          Jkszh = ijks_tem.jkszh,
                                          Jksyj = ijks_tem.jksyj,
                                          Tksj = DateTime.Now,
                                          F_jsjid = ijks_tem.F_jsjid,
                                          F_tkpxid = ijks_tem.F_tkpxid,
                                          F_LaborCost = ijks_tem.F_LaborCost,
                                          F_tkpxNumber = ijks_tem.F_tkpxNumber,
                                          F_CreateTime = DateTime.Now,
                                          F_CreateUser = userInfo.userId,

                                      }
                                  );

                              }
                          }

                          // 收集该品项关联的科技部老师业绩
                          if (item.lqHytkKjbsyjList != null && item.lqHytkKjbsyjList.Any())
                          {
                              foreach (var ikjbs_tem in item.lqHytkKjbsyjList)
                              {

                                  allKjbsyjEntities.Add(
                                      new LqHytkKjbsyjEntity
                                      {
                                          Id = YitIdHelper.NextId().ToString(),
                                          Gltkbh = id,
                                          Kjbls = ikjbs_tem.kjbls,
                                          Kjblsxm = ikjbs_tem.kjblsxm,
                                          Kjblszh = ikjbs_tem.kjblszh,
                                          Kjblsyj = ikjbs_tem.kjblsyj,
                                          Tksj = DateTime.Now,
                                          F_tkpxid = ikjbs_tem.F_tkpxid,
                                          F_LaborCost = ikjbs_tem.F_LaborCost,
                                          F_tkpxNumber = ikjbs_tem.F_tkpxNumber,
                                          F_CreateTime = DateTime.Now,
                                          F_CreateUser = userInfo.userId,

                                      }
                                  );

                              }
                          }

                      }

                  }

                  // 批量插入品项明细
                  if (allMxEntities.Any())
                  {
                      await _db.Insertable(allMxEntities).ExecuteCommandAsync();
                  }

                  // 批量插入健康师业绩
                  if (allJksyjEntities.Any())
                  {
                      await _db.Insertable(allJksyjEntities).ExecuteCommandAsync();
                  }

                  // 批量插入科技部老师业绩
                  if (allKjbsyjEntities.Any())
                  {
                      await _db.Insertable(allKjbsyjEntities).ExecuteCommandAsync();
                  }

                  // 关闭事务

                  _db.CommitTran();
              }

              catch (Exception ex)

              {

                  _db.RollbackTran();

                  throw NCCException.Oh(ErrorCode.COM1005, ex.Message);

              }
          }

          #endregion

          #region 作废退卡信息

          /// <summary>

          /// 作废退卡信息

          /// </summary>

          /// <param name="id">主键</param>

          /// <returns></returns>

          [HttpPut("VoidRefundCardInfo/{id}")]

          public async Task<dynamic> VoidRefundCardInfo(string id, [FromQuery] string remarks = null)

          {

              try

              {

                  var entity = await _db.Queryable<LqHytkHytkEntity>().FirstAsync(p => p.Id == id && p.IsEffective == StatusEnum.有效.GetHashCode());
                  if (entity == null)
                  {
                      throw NCCException.Oh("退卡信息不存在或已被作废");
                  }
                  // 开启事务
                  _db.BeginTran();
                  // 更新主表

                  entity.IsEffective = StatusEnum.无效.GetHashCode();

                  entity.F_ModifyTime = DateTime.Now;

                  entity.CancelRemark = remarks;

                  await _db.Updateable(entity).ExecuteCommandAsync();
                  // 更新明细表

                  await _db.Updateable<LqHytkMxEntity>().SetColumns(it => new LqHytkMxEntity { IsEffective = StatusEnum.无效.GetHashCode() }).Where(w => w.RefundInfoId == id).ExecuteCommandAsync();

                  // 更新健康师业绩表

                  await _db.Updateable<LqHytkJksyjEntity>().SetColumns(it => new LqHytkJksyjEntity { IsEffective = StatusEnum.无效.GetHashCode() }).Where(w => w.Gltkbh == id).ExecuteCommandAsync();

                  // 更新科技部业绩表

                  await _db.Updateable<LqHytkKjbsyjEntity>().SetColumns(it => new LqHytkKjbsyjEntity { IsEffective = StatusEnum.无效.GetHashCode() }).Where(w => w.Gltkbh == id).ExecuteCommandAsync();

                  // 提交事务
                  _db.CommitTran();
                  return entity;
              }
              catch (Exception ex)
              {
                  _db.RollbackTran();
                  throw NCCException.Oh($"删除退卡信息失败: {ex.Message}");

              }
          }

          #endregion

          #region 物理删除退卡信息
          /// <summary>
          /// 物理删除退卡信息
          /// </summary>
          /// <remarks>
          /// 彻底删除退卡记录及其所有关联数据，包括：
          /// - 退卡主表记录
          /// - 退卡品项明细记录
          /// - 退卡健康师业绩记录
          /// - 退卡科技部老师业绩记录
          /// 
          /// 注意：此操作不可逆，请谨慎使用
          /// </remarks>
          /// <param name="id">退卡记录主键ID</param>
          /// <returns>删除结果</returns>
          /// <response code="200">删除成功</response>
          /// <response code="404">退卡记录不存在</response>
          /// <response code="500">服务器内部错误</response>
          [HttpDelete("physical/{id}")]
          public async Task<dynamic> PhysicalDelete(string id)
          {
              try
              {
                  // 检查退卡记录是否存在
                  var entity = await _db.Queryable<LqHytkHytkEntity>().FirstAsync(p => p.Id == id);
                  if (entity == null)
                  {
                      throw NCCException.Oh("退卡记录不存在");
                  }
  
                  // 开启事务
                  _db.BeginTran();
  
                  // 1. 删除退卡品项明细记录

                  await _db.Deleteable<LqHytkMxEntity>().Where(x => x.RefundInfoId == id).ExecuteCommandAsync();

  
                  // 2. 删除退卡健康师业绩记录

                  await _db.Deleteable<LqHytkJksyjEntity>().Where(x => x.Gltkbh == id).ExecuteCommandAsync();

  
                  // 3. 删除退卡科技部老师业绩记录

                  await _db.Deleteable<LqHytkKjbsyjEntity>().Where(x => x.Gltkbh == id).ExecuteCommandAsync();

  
                  // 4. 删除退卡主表记录

                  await _db.Deleteable<LqHytkHytkEntity>().Where(x => x.Id == id).ExecuteCommandAsync();

  
                  // 提交事务
                  _db.CommitTran();
  
                  return new
                  {
                      success = true,
                      message = "退卡记录已彻底删除",
                      deletedId = id,
                      deletedTime = DateTime.Now
                  };
              }
              catch (Exception ex)
              {
                  // 回滚事务
                  _db.RollbackTran();
                  throw NCCException.Oh($"物理删除退卡记录失败: {ex.Message}");
              }
          }
          #endregion
  

          #region 获取退卡信息详情

          /// <summary>
          /// 获取退卡信息详情
          /// </summary>
          /// <remarks>
          /// 获取退卡记录及其关联的品项明细、健康师业绩、科技部老师业绩信息
          /// 按照退卡的完整格式返回数据，不包含汇总信息

          ///

          /// 返回数据结构：
          /// - 主表信息：退卡基础信息、门店信息、会员信息、退卡金额等
          /// - 品项明细列表：每个品项包含完整的项目信息（项目次数、是否有效、来源类型等）
          /// - 健康师业绩列表：按品项关联的健康师业绩信息
          /// - 科技部老师业绩列表：按品项关联的科技部老师业绩信息
          /// </remarks>
          /// <param name="id">退卡记录主键ID</param>
          /// <returns>退卡记录完整信息</returns>
          /// <response code="200">查询成功</response>
          /// <response code="404">退卡记录不存在</response>
          /// <response code="500">服务器内部错误</response>
          [HttpGet("{id}")]
          public async Task<dynamic> GetInfo(string id)
          {

              try
              {

                  // 1. 查询主表信息

                  var entity = await _db.Queryable<LqHytkHytkEntity>().Where(p => p.Id == id).FirstAsync();

                  if (entity == null)
                  {

                      throw NCCException.Oh("退卡记录不存在");

                  }

                  var output = entity.Adapt<LqHytkHytkInfoOutput>();
  
                  // 2. 查询品项明细列表

                  var lqHytkMxList = await _db.Queryable<LqHytkMxEntity>().Where(w => w.RefundInfoId == entity.Id).ToListAsync();

  
                  // 3. 查询健康师业绩列表

                  var lqHytkJksyjList = await _db.Queryable<LqHytkJksyjEntity>().Where(w => w.Gltkbh == entity.Id).ToListAsync();

  
                  // 4. 查询科技部老师业绩列表

                  var lqHytkKjbsyjList = await _db.Queryable<LqHytkKjbsyjEntity>().Where(w => w.Gltkbh == entity.Id).ToListAsync();

  
                  // 5. 构建品项明细输出，每个品项关联对应的业绩信息
                  var mxOutputList = new List<LqHytkMxInfoOutput>();
                  foreach (var mx in lqHytkMxList)
                  {
                      var mxOutput = new LqHytkMxInfoOutput
                      {
                          id = mx.Id,

                          refundInfoId = mx.RefundInfoId,
                          billingItemId = mx.BillingItemId,

                          px = mx.Px,
                          pxmc = mx.Pxmc,
                          pxjg = mx.Pxjg,
                          tkje = mx.Tkje,

                          projectNumber = mx.ProjectNumber,

                          sourceType = mx.SourceType,
                          totalPrice = mx.TotalPrice,

                          isEffective = mx.IsEffective,

                      };
  
                      // 关联该品项的健康师业绩

                      var jksyjForMx = lqHytkJksyjList.Where(j => j.CardReturn == mx.Id).ToList();

                      mxOutput.lqHytkJksyjList = jksyjForMx.Adapt<List<LqHytkJksyjInfoOutput>>();
  
                      // 关联该品项的科技部老师业绩

                      var kjbsyjForMx = lqHytkKjbsyjList.Where(k => k.CardReturn == mx.Id).ToList();

                      mxOutput.lqHytkKjbsyjList = kjbsyjForMx.Adapt<List<LqHytkKjbsyjInfoOutput>>();
  
                      mxOutputList.Add(mxOutput);
                  }
  
                  // 6. 设置输出结果
                  output.lqHytkMxList = mxOutputList;
  
                  // 7. 设置全局业绩列表（用于兼容性，但主要使用品项关联的业绩）
                  output.lqHytkJksyjList = lqHytkJksyjList.Adapt<List<LqHytkJksyjInfoOutput>>();
                  output.lqHytkKjbsyjList = lqHytkKjbsyjList.Adapt<List<LqHytkKjbsyjInfoOutput>>();
  
                  return output;

              }

              catch (Exception ex)

              {

                  throw NCCException.Oh($"获取退卡记录详情失败: {ex.Message}");

              }
          }

          #endregion

      }
  }