antissoft / lvqianmeiye_ERP

  using System;
  using System.Collections.Generic;
  using System.Linq;
  using System.Threading.Tasks;
  using Mapster;
  using Microsoft.AspNetCore.Mvc;
  using Microsoft.Extensions.Logging;
  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.LqXhHyhk;

  using NCC.Extend.Entitys.Dto.LqXhJksyj;
  using NCC.Extend.Entitys.Dto.LqXhKjbsyj;
  using NCC.Extend.Entitys.Dto.LqXhPxmx;

  using NCC.Extend.Entitys.Enum;

  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_xh_hyhk;
  using NCC.Extend.Entitys.lq_xh_jksyj;
  using NCC.Extend.Entitys.lq_xh_kjbsyj;
  using NCC.Extend.Entitys.lq_xh_pxmx;

  using NCC.Extend.Interfaces.LqXhHyhk;
  using NCC.FriendlyException;

  using NCC.JsonSerialization;

  using SqlSugar;
  using Yitter.IdGenerator;

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

      /// 耗卡记录表服务

      /// </summary>

      [ApiDescriptionSettings(Tag = "绿纤耗卡记录表服务", Name = "LqXhHyhk", Order = 200, Groups = new[] { "Default" })]

      [Route("api/Extend/[controller]")]
      public class LqXhHyhkService : ILqXhHyhkService, IDynamicApiController, ITransient
      {
          private readonly ISqlSugarRepository<LqXhHyhkEntity> _lqXhHyhkRepository;
          private readonly ISqlSugarRepository<LqXhJksyjEntity> _lqXhJksyjRepository;
          private readonly ISqlSugarRepository<LqXhKjbsyjEntity> _lqXhKjbsyjRepository;
          private readonly ISqlSugarRepository<LqXhPxmxEntity> _lqXhPxmxRepository;
          private readonly SqlSugarScope _db;
          private readonly IUserManager _userManager;

          private readonly ILogger<LqXhHyhkService> _logger;

  
          /// <summary>
          /// 初始化一个<see cref="LqXhHyhkService"/>类型的新实例
          /// </summary>
          public LqXhHyhkService(
              ISqlSugarRepository<LqXhHyhkEntity> lqXhHyhkRepository,
              ISqlSugarRepository<LqXhJksyjEntity> lqXhJksyjRepository,
              ISqlSugarRepository<LqXhKjbsyjEntity> lqXhKjbsyjRepository,
              ISqlSugarRepository<LqXhPxmxEntity> lqXhPxmxRepository,

              IUserManager userManager,

              ILogger<LqXhHyhkService> logger
          )

          {

              _lqXhHyhkRepository = lqXhHyhkRepository;

              _db = _lqXhHyhkRepository.Context;
              _lqXhJksyjRepository = lqXhJksyjRepository;
              _lqXhKjbsyjRepository = lqXhKjbsyjRepository;
              _lqXhPxmxRepository = lqXhPxmxRepository;
              _userManager = userManager;

              _logger = logger;

          }
  

          #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<LqXhHyhkEntity>().FirstAsync(p => p.Id == id);
                  if (entity == null)
                  {
                      throw NCCException.Oh(ErrorCode.COM1005, "耗卡记录不存在");
                  }
  
                  var output = entity.Adapt<LqXhHyhkInfoOutput>();

                  //获取会员信息
                  var MemberInfo = await _db.Queryable<LqKhxxEntity>().FirstAsync(p => p.Id == entity.Hy);
                  output.hymc = MemberInfo.Khmc;
                  output.memberPhone = MemberInfo.Sjh;

  
                  // 2. 查询品项明细列表

                  var lqXhPxmxList = await _db.Queryable<LqXhPxmxEntity>().Where(w => w.ConsumeInfoId == entity.Id).ToListAsync();

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

                  var lqXhJksyjList = await _db.Queryable<LqXhJksyjEntity>().Where(w => w.Glkdbh == entity.Id).ToListAsync();

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

                  var lqXhKjbsyjList = await _db.Queryable<LqXhKjbsyjEntity>().Where(w => w.Glkdbh == entity.Id).ToListAsync();

  
                  // 5. 构建品项明细输出，每个品项关联对应的业绩信息
                  var pxmxOutputList = new List<LqXhPxmxInfoOutput>();
                  foreach (var pxmx in lqXhPxmxList)
                  {
                      var pxmxOutput = new LqXhPxmxInfoOutput
                      {
                          id = pxmx.Id,

                          consumeInfoId = pxmx.ConsumeInfoId,
                          billingItemId = pxmx.BillingItemId,

                          px = pxmx.Px,
                          pxmc = pxmx.Pxmc,
                          pxjg = pxmx.Pxjg,

                          memberId = pxmx.MemberId,
                          createTime = pxmx.CreateTIme,
                          projectNumber = pxmx.ProjectNumber,

                          sourceType = pxmx.SourceType,

                          totalPrice = pxmx.TotalPrice,

                          isEffective = pxmx.IsEffective,

                      };
  
                      // 关联该品项的健康师业绩
                      var jksyjForPx = lqXhJksyjList.Where(j => j.Kdpxid == pxmx.Id).ToList();
                      pxmxOutput.lqXhJksyjList = jksyjForPx.Adapt<List<LqXhJksyjInfoOutput>>();
  
                      // 关联该品项的科技部老师业绩
                      var kjbsyjForPx = lqXhKjbsyjList.Where(k => k.Hkpxid == pxmx.Id).ToList();
                      pxmxOutput.lqXhKjbsyjList = kjbsyjForPx.Adapt<List<LqXhKjbsyjInfoOutput>>();
  
                      pxmxOutputList.Add(pxmxOutput);
                  }

                  // 6. 设置输出结果
                  output.lqXhPxmxList = pxmxOutputList;

                  // 7. 设置全局业绩列表（用于兼容性，但主要使用品项关联的业绩）
                  output.lqXhJksyjList = lqXhJksyjList.Adapt<List<LqXhJksyjInfoOutput>>();
                  output.lqXhKjbsyjList = lqXhKjbsyjList.Adapt<List<LqXhKjbsyjInfoOutput>>();

                  return output;
              }
              catch (Exception ex)
              {
                  _logger.LogError(ex, "获取耗卡记录失败，ID：{Id}", id);
                  throw NCCException.Oh(ErrorCode.COM1000, "获取耗卡记录失败");
              }

          }

          #endregion

          #region 获取会员耗卡列表

          /// <summary>

          /// 获取会员耗卡列表
          /// </summary>
          /// <param name="input">请求参数</param>
          /// <returns></returns>

          [HttpGet("")]
          public async Task<dynamic> GetList([FromQuery] LqXhHyhkListQueryInput input)
          {
              var sidx = input.sidx == null ? "id" : input.sidx;
              List<string> queryHksj = input.hksj != null ? input.hksj.Split(',').ToObeject<List<string>>() : null;
              DateTime? startHksj = queryHksj != null ? Ext.GetDateTime(queryHksj.First()) : null;
              DateTime? endHksj = queryHksj != null ? Ext.GetDateTime(queryHksj.Last()) : null;
              var data = await _db.Queryable<LqXhHyhkEntity>()

                  .WhereIF(!string.IsNullOrEmpty(input.keyword), p => p.Hymc.Contains(input.keyword) || p.Hyzh.Contains(input.keyword) || p.MemberPhone.Contains(input.keyword))

                  .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.hyzh), p => p.Hyzh.Contains(input.hyzh))
                  .WhereIF(!string.IsNullOrEmpty(input.hymc), p => p.Hymc.Contains(input.hymc))
                  .WhereIF(!string.IsNullOrEmpty(input.gklx), p => p.Gklx.Equals(input.gklx))

                  .WhereIF(!string.IsNullOrEmpty(input.sfykjb), p => p.Sfykjb.Equals(input.sfykjb))
                  .WhereIF(queryHksj != null, p => p.Hksj >= new DateTime(startHksj.ToDate().Year, startHksj.ToDate().Month, startHksj.ToDate().Day, 0, 0, 0))
                  .WhereIF(queryHksj != null, p => p.Hksj <= new DateTime(endHksj.ToDate().Year, endHksj.ToDate().Month, endHksj.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 LqXhHyhkListOutput

                  {
                      id = it.Id,

                      md = it.Md,
                      mdbh = it.Mdbh,
                      mdmc = it.Mdmc,
                      hy = it.Hy,
                      hyzh = it.Hyzh,

                      hymc = SqlFunc.Subqueryable<LqKhxxEntity>().Where(w => w.Id == it.Hy).Select(w => w.Khmc),

                      gklx = it.Gklx,

                      xfje = SqlFunc.ToString(it.Xfje),
                      sgfy = SqlFunc.ToString(it.Sgfy),

                      sfykjb = it.Sfykjb,
                      hksj = it.Hksj,
                      czry = it.Czry,

                      memberPhone = SqlFunc.Subqueryable<LqKhxxEntity>().Where(w => w.Id == it.Hy).Select(w => w.Sjh),
                      isEffective = it.IsEffective,

                  })
                  .MergeTable()
                  .OrderBy(sidx + " " + input.sort)
                  .ToPagedListAsync(input.currentPage, input.pageSize);

  
              // 获取当前页的耗卡记录ID列表
              var consumeIds = data.list.Select(x => x.id).ToList();
  
              // 批量查询耗卡明细
              var consumeDetails = new List<LqXhPxmxInfoOutput>();
              if (consumeIds.Any())
              {
                  consumeDetails = await _db.Queryable<LqXhPxmxEntity>()
                      .Where(x => consumeIds.Contains(x.ConsumeInfoId) && x.IsEffective == StatusEnum.有效.GetHashCode())
                      .Select(x => new LqXhPxmxInfoOutput
                      {
                          id = x.Id,
                          consumeInfoId = x.ConsumeInfoId,
                          billingItemId = x.BillingItemId,
                          px = x.Px,
                          pxmc = x.Pxmc,
                          pxjg = x.Pxjg,
                          memberId = x.MemberId,
                          createTime = x.CreateTIme,
                          projectNumber = x.ProjectNumber,
                          sourceType = x.SourceType,
                          totalPrice = x.TotalPrice,
                          isEffective = x.IsEffective
                      })
                      .ToListAsync();
              }
  
              // 按耗卡记录ID分组耗卡明细
              var consumeDetailsGrouped = consumeDetails.GroupBy(x => x.consumeInfoId)
                  .ToDictionary(g => g.Key, g => g.ToList());
  
              // 为每个耗卡记录分配耗卡明细
              foreach (var item in data.list)
              {
                  item.ConsumeDetails = consumeDetailsGrouped.ContainsKey(item.id)
                      ? consumeDetailsGrouped[item.id]
                      : new List<LqXhPxmxInfoOutput>();
              }
  

              return PageResult<LqXhHyhkListOutput>.SqlSugarPageResult(data);

          }

          #endregion

          #region 新建会员耗卡

          /// <summary>
          /// 新建会员耗卡
          /// </summary>

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

          ///

          /// 示例请求：
          /// ```json
          /// {
          ///   "hyid": "会员ID",
          ///   "hkmd": "耗卡门店",
          ///   "hksj": "2025-01-11",
          ///   "lqXhPxmxList": [
          ///     {
          ///       "px": "品项编号",
          ///       "pxmc": "品项名称",
          ///       "pxjg": 100.00,
          ///       "projectNumber": 1,
          ///       "xfzs": "否",
          ///       "lqXhJksyjList": [
          ///         {
          ///           "jks": "健康师",
          ///           "jksxm": "健康师姓名",
          ///           "jksyj": "100"
          ///         }
          ///       ]
          ///     }
          ///   ]
          /// }
          /// ```

          ///

          /// 参数说明：
          /// - hyid: 会员ID
          /// - hkmd: 耗卡门店
          /// - lqXhPxmxList: 耗卡品项明细列表
          /// </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] LqXhHyhkCrInput input)
          {
              var userInfo = await _userManager.GetUserInfo();

              //首先判断当前时间是否是加班时间

              var entity = input.Adapt<LqXhHyhkEntity>();
              entity.Id = YitIdHelper.NextId().ToString();

              entity.Czry = _userManager.UserId;

              entity.MemberPhone = _db.Queryable<LqKhxxEntity>().Where(w => w.Id == entity.Hy).First().Sjh;

              entity.CreateTime = DateTime.Now;

              entity.IsEffective = StatusEnum.有效.GetHashCode();
              entity.UpdateTime = DateTime.Now;

              entity.OvertimeCoefficient = input.overtimeCoefficient ?? 0;

              entity.OriginalSgfy = input.sgfy;
              //加班手工费 = 原始手工费 * 加班系数
              entity.OvertimeSgfy = entity.OriginalSgfy * entity.OvertimeCoefficient;
              //最终手工费 = 原始手工费 + 加班手工费
              entity.Sgfy = entity.OriginalSgfy + entity.OvertimeSgfy;

              try
              {

                  // 开启事务

                  _db.BeginTran();

                  // 新增会员耗卡记录

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

                  // 收集所有需要插入的实体，然后批量插入
                  var allPxmxEntities = new List<LqXhPxmxEntity>();
                  var allJksyjEntities = new List<LqXhJksyjEntity>();
                  var allKjbsyjEntities = new List<LqXhKjbsyjEntity>();
                  // 处理品项明细列表
                  if (input.lqXhPxmxList != null && input.lqXhPxmxList.Any())

                  {

                      foreach (var item in input.lqXhPxmxList)

                      {

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

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

                              CreateTIme = DateTime.Now,
                              MemberId = entity.Hy,

                              OriginalProjectNumber = item.projectNumber ?? 0,
                              OvertimeProjectNumber = (decimal)(entity.OvertimeCoefficient * (item.projectNumber ?? 0)),
                              ProjectNumber = (decimal)((item.projectNumber ?? 0) + (entity.OvertimeCoefficient * (item.projectNumber ?? 0))),

                              TotalPrice = (decimal)(item.pxjg * (item.projectNumber ?? 1)),
                              Px = item.px,
                              Pxmc = item.pxmc,
                              Pxjg = item.pxjg,

                              SourceType = item.sourceType,

                              IsEffective = StatusEnum.有效.GetHashCode(),
  

                          };
                          allPxmxEntities.Add(lqXhPxmxEntity);

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

                                  allJksyjEntities.Add(
                                      new LqXhJksyjEntity
                                      {
                                          Id = YitIdHelper.NextId().ToString(),
                                          Glkdbh = newEntity.Id,
                                          Jks = ijks_tem.jks,
                                          Jksxm = ijks_tem.jksxm,
                                          Jkszh = ijks_tem.jkszh,
                                          Jksyj = ijks_tem.jksyj,
                                          Yjsj = DateTime.Now,
                                          JsjId = ijks_tem.jsjId,
                                          Kdpxid = lqXhPxmxEntity.Id,

                                          OriginalLaborCost = ijks_tem.laborCost,
                                          OvertimeLaborCost = (decimal)(entity.OvertimeCoefficient * (ijks_tem.laborCost ?? 0)),
                                          LaborCost = (decimal)((ijks_tem.laborCost ?? 0) + (entity.OvertimeCoefficient * (ijks_tem.laborCost ?? 0))),

                                          OriginalKdpxNumber = ijks_tem.kdpxNumber,
                                          OvertimeKdpxNumber = (decimal)(entity.OvertimeCoefficient * (ijks_tem.kdpxNumber ?? 0)),
                                          KdpxNumber = (decimal)((ijks_tem.kdpxNumber ?? 0) + (entity.OvertimeCoefficient * (ijks_tem.kdpxNumber ?? 0))),
                                          IsEffective = StatusEnum.有效.GetHashCode(),
  

                                      }
                                  );

                              }
                          }

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

                                  allKjbsyjEntities.Add(
                                      new LqXhKjbsyjEntity
                                      {
                                          Id = YitIdHelper.NextId().ToString(),
                                          Glkdbh = newEntity.Id,
                                          Kjbls = ikjbs_tem.kjbls,
                                          Kjblsxm = ikjbs_tem.kjblsxm,
                                          Kjblszh = ikjbs_tem.kjblszh,
                                          Kjblsyj = ikjbs_tem.kjblsyj,
                                          Yjsj = DateTime.Now,
                                          Hkpxid = lqXhPxmxEntity.Id,

                                          OriginalHdpxNumber = ikjbs_tem.hdpxNumber,
                                          OvertimeHdpxNumber = (decimal)(entity.OvertimeCoefficient * (ikjbs_tem.hdpxNumber ?? 0)),
                                          HdpxNumber = (decimal)((ikjbs_tem.hdpxNumber ?? 0) + (entity.OvertimeCoefficient * (ikjbs_tem.hdpxNumber ?? 0))),
                                          OriginalLaborCost = ikjbs_tem.laborCost,
                                          OvertimeLaborCost = (decimal)(entity.OvertimeCoefficient * (ikjbs_tem.laborCost ?? 0)),
                                          LaborCost = (decimal)((ikjbs_tem.laborCost ?? 0) + (entity.OvertimeCoefficient * (ikjbs_tem.laborCost ?? 0))),
                                          IsEffective = StatusEnum.有效.GetHashCode(),

                                      }
                                  );

                              }
                          }

                      }

                  }

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

                  {

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

                  }

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

                  {

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

                  }

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

                  _db.CommitTran();
              }

              catch (Exception ex)

              {

                  // 回滚事务

                  _db.RollbackTran();

                  Console.WriteLine($"新建会员耗卡失败: {ex.Message}");
                  Console.WriteLine($"堆栈跟踪: {ex.StackTrace}");
                  throw NCCException.Oh(ErrorCode.COM1000, $"新建会员耗卡失败: {ex.Message}");

              }
          }

          #endregion

          #region 获取会员耗卡无分页列表

          /// <summary>

          /// 获取会员耗卡无分页列表
          /// </summary>
          /// <param name="input">请求参数</param>
          /// <returns></returns>

          [NonAction]
          public async Task<dynamic> GetNoPagingList([FromQuery] LqXhHyhkListQueryInput input)
          {
              var sidx = input.sidx == null ? "id" : input.sidx;
              List<string> queryHksj = input.hksj != null ? input.hksj.Split(',').ToObeject<List<string>>() : null;
              DateTime? startHksj = queryHksj != null ? Ext.GetDateTime(queryHksj.First()) : null;
              DateTime? endHksj = queryHksj != null ? Ext.GetDateTime(queryHksj.Last()) : null;
              var data = await _db.Queryable<LqXhHyhkEntity>()
                  .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.hyzh), p => p.Hyzh.Contains(input.hyzh))
                  .WhereIF(!string.IsNullOrEmpty(input.hymc), p => p.Hymc.Contains(input.hymc))
                  .WhereIF(!string.IsNullOrEmpty(input.gklx), p => p.Gklx.Equals(input.gklx))

                  .WhereIF(!string.IsNullOrEmpty(input.sfykjb), p => p.Sfykjb.Equals(input.sfykjb))
                  .WhereIF(queryHksj != null, p => p.Hksj >= new DateTime(startHksj.ToDate().Year, startHksj.ToDate().Month, startHksj.ToDate().Day, 0, 0, 0))
                  .WhereIF(queryHksj != null, p => p.Hksj <= new DateTime(endHksj.ToDate().Year, endHksj.ToDate().Month, endHksj.ToDate().Day, 23, 59, 59))
                  .WhereIF(!string.IsNullOrEmpty(input.czry), p => p.Czry.Equals(input.czry))

                  .Select(it => new LqXhHyhkListOutput

                  {
                      id = it.Id,

                      md = it.Md,
                      mdbh = it.Mdbh,
                      mdmc = it.Mdmc,
                      hy = it.Hy,
                      hyzh = it.Hyzh,

                      hymc = SqlFunc.Subqueryable<LqKhxxEntity>().Where(w => w.Id == it.Hy).Select(w => w.Khmc),
                      memberPhone = SqlFunc.Subqueryable<LqKhxxEntity>().Where(w => w.Id == it.Hy).Select(w => w.Sjh),

                      gklx = it.Gklx,

                      xfje = SqlFunc.ToString(it.Xfje),
                      sgfy = SqlFunc.ToString(it.Sgfy),

                      sfykjb = it.Sfykjb,
                      hksj = it.Hksj,
                      czry = it.Czry,

                  })
                  .MergeTable()
                  .OrderBy(sidx + " " + input.sort)
                  .ToListAsync();

              return data;

          }

          #endregion

          #region 导出会员耗卡

          /// <summary>

          /// 导出会员耗卡
          /// </summary>
          /// <param name="input">请求参数</param>
          /// <returns></returns>

          [HttpGet("Actions/Export")]
          public async Task<dynamic> Export([FromQuery] LqXhHyhkListQueryInput input)
          {
              var userInfo = await _userManager.GetUserInfo();
              var exportData = new List<LqXhHyhkListOutput>();
              if (input.dataType == 0)
              {
                  var data = Clay.Object(await this.GetList(input));
                  exportData = data.Solidify<PageResult<LqXhHyhkListOutput>>().list;
              }
              else
              {
                  exportData = await this.GetNoPagingList(input);
              }

              List<ParamsModel> paramList =
                  "[{\"value\":\"耗卡编号\",\"field\":\"id\"},{\"value\":\"门店\",\"field\":\"md\"},{\"value\":\"门店编号\",\"field\":\"mdbh\"},{\"value\":\"门店名称\",\"field\":\"mdmc\"},{\"value\":\"会员\",\"field\":\"hy\"},{\"value\":\"会员账号\",\"field\":\"hyzh\"},{\"value\":\"会员名称\",\"field\":\"hymc\"},{\"value\":\"顾客类型\",\"field\":\"gklx\"},{\"value\":\"消费金额\",\"field\":\"xfje\"},{\"value\":\"手工费用\",\"field\":\"sgfy\"},{\"value\":\"是否有科技部\",\"field\":\"sfykjb\"},{\"value\":\"耗卡时间\",\"field\":\"hksj\"},{\"value\":\"操作人员\",\"field\":\"czry\"},]".ToList<ParamsModel>();

              ExcelConfig excelconfig = new ExcelConfig();
              excelconfig.FileName = "会员耗卡.xls";
              excelconfig.HeadFont = "微软雅黑";
              excelconfig.HeadPoint = 10;
              excelconfig.IsAllSizeColumn = true;
              excelconfig.ColumnModel = new List<ExcelColumnModel>();
              List<string> selectKeyList = input.selectKey.Split(',').ToList();
              foreach (var item in selectKeyList)
              {
                  var isExist = paramList.Find(p => p.field == item);
                  if (isExist != null)
                  {
                      excelconfig.ColumnModel.Add(new ExcelColumnModel() { Column = isExist.field, ExcelColumn = isExist.value });
                  }
              }
              var addPath = FileVariable.TemporaryFilePath + excelconfig.FileName;
              ExcelExportHelper<LqXhHyhkListOutput>.Export(exportData, excelconfig, addPath);
              var fileName = _userManager.UserId + "|" + addPath + "|xls";

              var output = new { name = excelconfig.FileName, url = "/api/File/Download?encryption=" + DESCEncryption.Encrypt(fileName, "NCC") };

              return output;
          }

          #endregion

          #region 批量删除会员耗卡

          /// <summary>
          /// 批量删除会员耗卡
          /// </summary>
          /// <param name="ids">主键数组</param>
          /// <returns></returns>
          [HttpPost("batchRemove")]
          public async Task BatchRemove([FromBody] List<string> ids)
          {
              var entitys = await _db.Queryable<LqXhHyhkEntity>().In(it => it.Id, ids).ToListAsync();
              if (entitys.Count > 0)
              {
                  try
                  {
                      //开启事务
                      _db.BeginTran();
                      //批量删除会员耗卡

                      await _db.Deleteable<LqXhHyhkEntity>().In(d => d.Id, ids).ExecuteCommandAsync();

  
                      //清空子表数据

                      await _db.Deleteable<LqXhJksyjEntity>().In(u => u.Glkdbh, ids).ExecuteCommandAsync();

  
                      //清空子表数据

                      await _db.Deleteable<LqXhKjbsyjEntity>().In(u => u.Glkdbh, ids).ExecuteCommandAsync();

  
                      //清空子表数据

                      await _db.Deleteable<LqXhPxmxEntity>().In(u => u.ConsumeInfoId, ids).ExecuteCommandAsync();

                      //关闭事务
                      _db.CommitTran();
                  }
                  catch (Exception)
                  {
                      //回滚事务
                      _db.RollbackTran();
                      throw NCCException.Oh(ErrorCode.COM1002);
                  }
              }
          }

          #endregion

          #region 更新会员耗卡

          /// <summary>

          /// 更新会员耗卡

          /// </summary>
          /// <param name="id">主键</param>
          /// <param name="input">参数</param>
          /// <returns></returns>
          [HttpPut("{id}")]
          public async Task Update(string id, [FromBody] LqXhHyhkUpInput input)
          {
              var entity = input.Adapt<LqXhHyhkEntity>();
              try
              {
                  //开启事务
                  _db.BeginTran();

                  //查询记录
                  var LqXhHyhkInfo = await _db.Queryable<LqXhHyhkEntity>().Where(p => p.Id == id && p.IsEffective == StatusEnum.有效.GetHashCode()).FirstAsync();
                  if (LqXhHyhkInfo == null)
                  {
                      throw NCCException.Oh(ErrorCode.COM1005, "耗卡记录不存在或已作废");
                  }

                  entity.UpdateTime = DateTime.Now;

                  entity.OvertimeCoefficient = input.overtimeCoefficient;
                  entity.OriginalSgfy = input.sgfy;
                  entity.OvertimeSgfy = (decimal)(entity.OvertimeCoefficient * input.sgfy);
                  entity.Sgfy = (decimal)(input.sgfy + (entity.OvertimeCoefficient * input.sgfy));

                  //更新会员耗卡记录
                  await _db.Updateable(entity).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();
  
                  //清空原有数据
                  await _db.Deleteable<LqXhJksyjEntity>().Where(u => u.Glkdbh == id).ExecuteCommandAsync();

                  await _db.Deleteable<LqXhKjbsyjEntity>().Where(u => u.Glkdbh == id).ExecuteCommandAsync();

                  await _db.Deleteable<LqXhPxmxEntity>().Where(u => u.ConsumeInfoId == id).ExecuteCommandAsync();

                  // 收集所有需要插入的实体，然后批量插入
                  var allPxmxEntities = new List<LqXhPxmxEntity>();
                  var allJksyjEntities = new List<LqXhJksyjEntity>();
                  var allKjbsyjEntities = new List<LqXhKjbsyjEntity>();

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

                  {

                      foreach (var item in input.lqXhPxmxList)

                      {

                          // 创建品项明细实体
                          var lqXhPxmxEntity = new LqXhPxmxEntity

                          {

                              Id = YitIdHelper.NextId().ToString(),
                              ConsumeInfoId = input.id,
                              BillingItemId = item.billingItemId,
                              CreateTIme = DateTime.Now,
                              MemberId = entity.Hy,

                              TotalPrice = item.pxjg * (item.projectNumber ?? 1),

                              Px = item.px,
                              Pxmc = item.pxmc,
                              Pxjg = item.pxjg,
                              SourceType = item.sourceType,

                              IsEffective = StatusEnum.有效.GetHashCode(),
                              OriginalProjectNumber = item.projectNumber ?? 0,
                              OvertimeProjectNumber = (decimal)(entity.OvertimeCoefficient * (item.projectNumber ?? 0)),
                              ProjectNumber = (decimal)((item.projectNumber ?? 0) + (entity.OvertimeCoefficient * (item.projectNumber ?? 0))),

                          };

                          allPxmxEntities.Add(lqXhPxmxEntity);

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

                                  allJksyjEntities.Add(
                                      new LqXhJksyjEntity
                                      {
                                          Id = YitIdHelper.NextId().ToString(),

                                          Glkdbh = input.id,

                                          Jks = ijks_tem.jks,
                                          Jksxm = ijks_tem.jksxm,
                                          Jkszh = ijks_tem.jkszh,
                                          Jksyj = ijks_tem.jksyj,
                                          Yjsj = DateTime.Now,
                                          JsjId = ijks_tem.jsjId,
                                          Kdpxid = lqXhPxmxEntity.Id,
                                          LaborCost = ijks_tem.laborCost,

                                          OriginalKdpxNumber = ijks_tem.kdpxNumber,
                                          OvertimeKdpxNumber = (decimal)(entity.OvertimeCoefficient * (ijks_tem.kdpxNumber ?? 0)),
                                          KdpxNumber = (decimal)((ijks_tem.kdpxNumber ?? 0) + (entity.OvertimeCoefficient * (ijks_tem.kdpxNumber ?? 0))),
                                          IsEffective = StatusEnum.有效.GetHashCode(),