antissoft / lvqianmeiye_ERP

  using System;
  using System.Collections.Generic;
  using System.Linq;
  using System.Net.Http;
  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.Common;

  using NCC.Extend.Entitys.Dto.LqKdKdjlb;

  using NCC.Extend.Entitys.Enum;

  using NCC.Extend.Entitys.lq_jinsanjiao_user;

  using NCC.Extend.Entitys.lq_kd_deductinfo;

  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_xmzl;
  using NCC.Extend.Interfaces.LqKdKdjlb;

  using NCC.Extend.Utils;

  using NCC.FriendlyException;
  using NCC.JsonSerialization;

  using NCC.System.Entitys.Permission;

  using SqlSugar;
  using Yitter.IdGenerator;

  
  namespace NCC.Extend.LqKdKdjlb
  {
      /// <summary>
      /// 开单记录表服务
      /// </summary>

      [ApiDescriptionSettings(Tag = "绿纤开单记录表服务", Name = "LqKdKdjlb", Order = 200)]

      [Route("api/Extend/[controller]")]
      public class LqKdKdjlbService : ILqKdKdjlbService, IDynamicApiController, ITransient
      {
          private readonly ISqlSugarRepository<LqKdKdjlbEntity> _lqKdKdjlbRepository;
          private readonly ISqlSugarRepository<LqKdJksyjEntity> _lqKdJksyjRepository;
          private readonly ISqlSugarRepository<LqKdKjbsyjEntity> _lqKdKjbsyjRepository;
          private readonly ISqlSugarRepository<LqKdPxmxEntity> _lqKdPxmxRepository;
          private readonly SqlSugarScope _db;
          private readonly IUserManager _userManager;

          private readonly WeChatBotService _weChatBotService;
          private readonly LqKdKdjlbStringGenerator _stringGenerator;

  
          /// <summary>
          /// 初始化一个<see cref="LqKdKdjlbService"/>类型的新实例
          /// </summary>
          public LqKdKdjlbService(
              ISqlSugarRepository<LqKdKdjlbEntity> lqKdKdjlbRepository,
              ISqlSugarRepository<LqKdJksyjEntity> lqKdJksyjRepository,
              ISqlSugarRepository<LqKdKjbsyjEntity> lqKdKjbsyjRepository,
              ISqlSugarRepository<LqKdPxmxEntity> lqKdPxmxRepository,

              IUserManager userManager,
              WeChatBotService weChatBotService,

              LqKdKdjlbStringGenerator stringGenerator
          )

          {

              _lqKdKdjlbRepository = lqKdKdjlbRepository;

              _db = _lqKdKdjlbRepository.Context;
              _lqKdJksyjRepository = lqKdJksyjRepository;
              _lqKdKjbsyjRepository = lqKdKjbsyjRepository;
              _lqKdPxmxRepository = lqKdPxmxRepository;
              _userManager = userManager;

              _weChatBotService = weChatBotService;
              _stringGenerator = stringGenerator;

          }

          #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<LqKdKdjlbEntity>().FirstAsync(p => p.Id == id);
                  if (entity == null)
                  {
                      throw NCCException.Oh(ErrorCode.COM1005, "开单记录不存在");
                  }

                  var output = entity.Adapt<LqKdKdjlbInfoOutput>();

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

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

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

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

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

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

  
                  // 5. 构建品项明细输出，每个品项关联对应的业绩信息
                  var pxmxOutputList = new List<LqKdPxmxInfoOutput>();
                  foreach (var pxmx in lqKdPxmxList)
                  {
                      var pxmxOutput = new LqKdPxmxInfoOutput
                      {
                          id = pxmx.Id,
                          glkdbh = pxmx.Glkdbh,
                          px = pxmx.Px,
                          pxmc = pxmx.Pxmc,
                          pxjg = pxmx.Pxjg,
                          projectNumber = pxmx.ProjectNumber,
                          isEnabled = pxmx.IsEnabled,
                          sourceType = pxmx.SourceType,
                          memberId = pxmx.MemberId,
                          createTime = pxmx.CreateTIme,

                          totalPrice = pxmx.TotalPrice,

                          actualPrice = pxmx.ActualPrice,

                      };
  
                      // 关联该品项的健康师业绩
                      var jksyjForPx = lqKdJksyjList.Where(j => j.Kdpxid == pxmx.Id).ToList();
                      pxmxOutput.lqKdJksyjList = jksyjForPx.Adapt<List<LqKdJksyjInfoOutput>>();
  
                      // 关联该品项的科技部老师业绩
                      var kjbsyjForPx = lqKdKjbsyjList.Where(k => k.Kdpxid == pxmx.Id).ToList();
                      pxmxOutput.lqKdKjbsyjList = kjbsyjForPx.Adapt<List<LqKdKjbsyjInfoOutput>>();
  
                      pxmxOutputList.Add(pxmxOutput);
                  }
  
                  // 6. 设置输出结果
                  output.lqKdPxmxList = pxmxOutputList;
  
                  // 7. 设置全局业绩列表（用于兼容性，但主要使用品项关联的业绩）
                  output.lqKdJksyjList = lqKdJksyjList.Adapt<List<LqKdJksyjInfoOutput>>();
                  output.lqKdKjbsyjList = lqKdKjbsyjList.Adapt<List<LqKdKjbsyjInfoOutput>>();
  
                  return output;
              }
              catch (Exception ex)
              {
                  Console.WriteLine($"获取开单记录失败: {ex.Message}");
                  throw NCCException.Oh(ErrorCode.COM1000, "获取开单记录失败");
              }

          }

          #endregion

          #region 获取开单记录表列表

          /// <summary>

          /// 获取开单记录表列表
          /// </summary>
          /// <param name="input">请求参数</param>
          /// <returns></returns>

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

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

              DateTime? startKdrq = queryKdrq != null ? Ext.GetDateTime(queryKdrq.First()) : null;
              DateTime? endKdrq = queryKdrq != null ? Ext.GetDateTime(queryKdrq.Last()) : null;
              var data = await _db.Queryable<LqKdKdjlbEntity>()
                  .WhereIF(!string.IsNullOrEmpty(input.id), p => p.Id.Contains(input.id))
                  .WhereIF(!string.IsNullOrEmpty(input.djmd), p => p.Djmd.Equals(input.djmd))
                  .WhereIF(!string.IsNullOrEmpty(input.jsj), p => p.Jsj.Equals(input.jsj))

                  .WhereIF(queryKdrq != null, p => p.Kdrq >= new DateTime(startKdrq.ToDate().Year, startKdrq.ToDate().Month, startKdrq.ToDate().Day, 0, 0, 0))
                  .WhereIF(queryKdrq != null, p => p.Kdrq <= new DateTime(endKdrq.ToDate().Year, endKdrq.ToDate().Month, endKdrq.ToDate().Day, 23, 59, 59))

                  .WhereIF(!string.IsNullOrEmpty(input.gjlx), p => p.Gjlx.Equals(input.gjlx))
                  .WhereIF(!string.IsNullOrEmpty(input.hgjg), p => p.Hgjg.Equals(input.hgjg))
                  .WhereIF(!string.IsNullOrEmpty(input.zdyj), p => p.Zdyj.Equals(input.zdyj))
                  .WhereIF(!string.IsNullOrEmpty(input.sfyj), p => p.Sfyj.Equals(input.sfyj))
                  .WhereIF(!string.IsNullOrEmpty(input.qk), p => p.Qk.Equals(input.qk))
                  .WhereIF(!string.IsNullOrEmpty(input.ckfs), p => p.Ckfs.Equals(input.ckfs))

                  .WhereIF(!string.IsNullOrEmpty(input.fkfs), p => p.Fkfs.Equals(input.fkfs))
                  .WhereIF(!string.IsNullOrEmpty(input.fkyy), p => p.Fkyy.Equals(input.fkyy))
                  .WhereIF(!string.IsNullOrEmpty(input.fkpd), p => p.Fkpd.Contains(input.fkpd))
                  .WhereIF(!string.IsNullOrEmpty(input.khly), p => p.Khly.Equals(input.khly))
                  .WhereIF(!string.IsNullOrEmpty(input.tjr), p => p.Tjr.Contains(input.tjr))
                  .WhereIF(!string.IsNullOrEmpty(input.sfskdd), p => p.Sfskdd.Equals(input.sfskdd))
                  .WhereIF(!string.IsNullOrEmpty(input.jj), p => p.Jj.Contains(input.jj))
                  .WhereIF(!string.IsNullOrEmpty(input.bz), p => p.Bz.Contains(input.bz))
                  .WhereIF(!string.IsNullOrEmpty(input.kdhy), p => p.Kdhy.Equals(input.kdhy))
                  .WhereIF(!string.IsNullOrEmpty(input.kdhyc), p => p.Kdhyc.Contains(input.kdhyc))

                  .WhereIF(!string.IsNullOrEmpty(input.kdhysjh), p => p.Kdhysjh.Contains(input.kdhysjh))

                  .WhereIF(!string.IsNullOrEmpty(input.jksyj), p => p.Jksyj.Contains(input.jksyj))

                  .WhereIF(!string.IsNullOrEmpty(input.kjblsyj), p => p.Kjblsyj.Contains(input.kjblsyj))

                  .WhereIF(!string.IsNullOrEmpty(input.pxxx), p => p.Pxxx.Contains(input.pxxx))

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

                  .Select(it => new LqKdKdjlbListOutput

                  {
                      id = it.Id,

                      djmd = it.Djmd,
                      jsj = it.Jsj,
                      kdrq = it.Kdrq,
                      gjlx = it.Gjlx,
                      hgjg = it.Hgjg,
                      zdyj = it.Zdyj,
                      sfyj = it.Sfyj,
                      qk = it.Qk,
                      ckfs = it.Ckfs,

                      fkfs = it.Fkfs,
                      fkyy = it.Fkyy,
                      fkpd = it.Fkpd,
                      khly = it.Khly,
                      tjr = it.Tjr,

                      deductAmount = it.DeductAmount,

                      sfskdd = it.Sfskdd,
                      jj = it.Jj,
                      bz = it.Bz,
                      kdhy = it.Kdhy,
                      kdhyc = it.Kdhyc,
                      kdhysjh = it.Kdhysjh,
                      jksyj = it.Jksyj,
                      kjblsyj = it.Kjblsyj,
                      pxxx = it.Pxxx,

                      IsEffective = it.IsEffective,

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

              return PageResult<LqKdKdjlbListOutput>.SqlSugarPageResult(data);

          }

          #endregion

          #region 新建开单记录表

          /// <summary>
          /// 新建开单记录表
          /// </summary>
          /// <param name="input">参数</param>
          /// <returns></returns>
          [HttpPost("")]
          public async Task Create([FromBody] LqKdKdjlbCrInput input)
          {
              var userInfo = await _userManager.GetUserInfo();
              var entity = input.Adapt<LqKdKdjlbEntity>();

              var HealthInstructorNames = "";

              entity.Id = YitIdHelper.NextId().ToString();

              entity.CreateTime = DateTime.Now;
              entity.UpdateTime = DateTime.Now;

              try
              {
                  //开启事务
                  _db.BeginTran();

                  //新增开单记录表记录

                  entity.CreateUser = userInfo.userId;

                  entity.DeductAmount = input.lqKdKdjlbDeductList.Sum(x => x.Amount ?? 0);//计算储扣总金额

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

                  //循环品相信息
                  // 收集所有需要插入的实体，然后批量插入
                  var allPxmxEntities = new List<LqKdPxmxEntity>();
                  var allJksyjEntities = new List<LqKdJksyjEntity>();
                  var allKjbsyjEntities = new List<LqKdKjbsyjEntity>();

                  var allDeductEntities = new List<LqKdDeductinfoEntity>();
                  // 处理扣款信息列表
                  foreach (var item in input.lqKdKdjlbDeductList)
                  {
                      var lqKdDeductEntity = new LqKdDeductinfoEntity
                      {
                          Id = YitIdHelper.NextId().ToString(),
                          BillingId = newEntity.Id,
                          DeductId = item.DeductId,
                          DeductType = item.DeductType,
                          Amount = item.Amount,
                      };
                      allDeductEntities.Add(lqKdDeductEntity);
                  }

                  // 处理品项明细列表
                  foreach (var item in input.lqKdPxmxList)

                  {

                      // 创建品项明细实体
                      var lqKdPxmxEntity = new LqKdPxmxEntity

                      {

                          Id = YitIdHelper.NextId().ToString(),
                          Glkdbh = newEntity.Id,

                          Yjsj = input.kdrq,

                          CreateTIme = DateTime.Now,
                          MemberId = entity.Kdhy,
                          IsEnabled = 0,

                          ProjectNumber = item.projectNumber,
                          TotalPrice = (decimal)(item.pxjg * item.projectNumber),

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

                          ActualPrice = item.actualPrice,

                      };
                      allPxmxEntities.Add(lqKdPxmxEntity);

                      // 收集该品项关联的健康师业绩
                      if (item.lqKdJksyjList != null && item.lqKdJksyjList.Any())

                      {

                          //把jksxm保存到HealthInstructorNames

                          foreach (var ijks_tem in item.lqKdJksyjList)

                          {

                              HealthInstructorNames += ijks_tem.jksxm + ",";
                              allJksyjEntities.Add(new LqKdJksyjEntity
                              {
                                  Id = YitIdHelper.NextId().ToString(),
                                  Glkdbh = newEntity.Id,
                                  Jks = ijks_tem.jks,
                                  Jksxm = ijks_tem.jksxm,
                                  Jkszh = ijks_tem.jkszh,
                                  Jksyj = ijks_tem.jksyj,
                                  Yjsj = input.kdrq,
                                  Jsj_id = ijks_tem.jsj_id,
                                  Kdpxid = lqKdPxmxEntity.Id,
                              });

                          }

                      }

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

                          {

                              allKjbsyjEntities.Add(
                                  new LqKdKjbsyjEntity
                                  {
                                      Id = YitIdHelper.NextId().ToString(),
                                      Glkdbh = newEntity.Id,
                                      Kjbls = ikjbs_tem.kjbls,
                                      Kjblsxm = ikjbs_tem.kjblsxm,
                                      Kjblszh = ikjbs_tem.kjblszh,
                                      Kjblsyj = ikjbs_tem.kjblsyj,

                                      Yjsj = input.kdrq,

                                      Kdpxid = lqKdPxmxEntity.Id,
                                  }
                              );

                          }

                      }

                  }

                  //通过会员id查询会员信息
                  var memberInfo = await _db.Queryable<LqKhxxEntity>().Where(u => u.Id == entity.Kdhy).FirstAsync();

                  //通过开单记录表查询这个会员开单金额
                  var kdAmount = await _db.Queryable<LqKdKdjlbEntity>().Where(u => u.Kdhy == entity.Kdhy).SumAsync(u => u.Sfyj);
                  //如果开单金额小于500，为散客，如果大于500，为会员
                  if (kdAmount < 500)
                  {
                      memberInfo.Khlx = MemberTypeEnum.散客.GetHashCode().ToString();
                  }
                  else
                  {
                      memberInfo.Khlx = MemberTypeEnum.会员.GetHashCode().ToString();
                  }

                  await _db.Updateable(memberInfo).ExecuteCommandAsync();

                  // 批量插入扣款信息
                  if (allDeductEntities.Any())
                  {
                      await _db.Insertable(allDeductEntities).ExecuteCommandAsync();
                  }

                  // 批量插入品项明细
                  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();

                  // 生成开单记录字符串并发送到企业微信
                  try
                  {
                      var entityInfo = await GetInfo(newEntity.Id);
                      if (entityInfo != null)
                      {

                          var orderRecordString = _stringGenerator.GenerateOrderRecordString(entityInfo);

                          Console.WriteLine("开单记录字符串生成成功:");
                          Console.WriteLine(orderRecordString);

                          // 发送到企业微信群
                          try
                          {

                              var sendResult = await _weChatBotService.SendOrderRecordMessage(orderRecordString);

                              if (sendResult)
                              {
                                  Console.WriteLine("开单记录已成功发送到企业微信群");
                              }
                              else
                              {
                                  Console.WriteLine("开单记录发送到企业微信群失败");
                              }
                          }
                          catch (Exception wechatEx)
                          {
                              Console.WriteLine($"发送企业微信消息异常: {wechatEx.Message}");
                          }
                      }
                  }
                  catch (Exception ex)
                  {
                      // 字符串生成失败不影响主流程，只记录日志
                      Console.WriteLine($"生成开单记录字符串失败: {ex.Message}");
                  }

              }

              catch (Exception ex)

              {
                  //回滚事务
                  _db.RollbackTran();

                  Console.WriteLine($"开单创建失败: {ex.Message}");
                  Console.WriteLine($"异常堆栈: {ex.StackTrace}");

                  throw NCCException.Oh(ErrorCode.COM1000);
              }
          }

          #endregion

          #region 获取开单记录表无分页列表

          /// <summary>

          /// 获取开单记录表无分页列表
          /// </summary>
          /// <param name="input">请求参数</param>
          /// <returns></returns>

          [NonAction]
          public async Task<dynamic> GetNoPagingList([FromQuery] LqKdKdjlbListQueryInput input)
          {
              var sidx = input.sidx == null ? "id" : input.sidx;

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

              DateTime? startKdrq = queryKdrq != null ? Ext.GetDateTime(queryKdrq.First()) : null;
              DateTime? endKdrq = queryKdrq != null ? Ext.GetDateTime(queryKdrq.Last()) : null;
              var data = await _db.Queryable<LqKdKdjlbEntity>()
                  .WhereIF(!string.IsNullOrEmpty(input.id), p => p.Id.Contains(input.id))
                  .WhereIF(!string.IsNullOrEmpty(input.djmd), p => p.Djmd.Equals(input.djmd))
                  .WhereIF(!string.IsNullOrEmpty(input.jsj), p => p.Jsj.Equals(input.jsj))

                  .WhereIF(queryKdrq != null, p => p.Kdrq >= new DateTime(startKdrq.ToDate().Year, startKdrq.ToDate().Month, startKdrq.ToDate().Day, 0, 0, 0))
                  .WhereIF(queryKdrq != null, p => p.Kdrq <= new DateTime(endKdrq.ToDate().Year, endKdrq.ToDate().Month, endKdrq.ToDate().Day, 23, 59, 59))

                  .WhereIF(!string.IsNullOrEmpty(input.gjlx), p => p.Gjlx.Equals(input.gjlx))
                  .WhereIF(!string.IsNullOrEmpty(input.hgjg), p => p.Hgjg.Equals(input.hgjg))
                  .WhereIF(!string.IsNullOrEmpty(input.zdyj), p => p.Zdyj.Equals(input.zdyj))
                  .WhereIF(!string.IsNullOrEmpty(input.sfyj), p => p.Sfyj.Equals(input.sfyj))
                  .WhereIF(!string.IsNullOrEmpty(input.qk), p => p.Qk.Equals(input.qk))
                  .WhereIF(!string.IsNullOrEmpty(input.ckfs), p => p.Ckfs.Equals(input.ckfs))

                  .WhereIF(!string.IsNullOrEmpty(input.fkfs), p => p.Fkfs.Equals(input.fkfs))
                  .WhereIF(!string.IsNullOrEmpty(input.fkyy), p => p.Fkyy.Equals(input.fkyy))
                  .WhereIF(!string.IsNullOrEmpty(input.fkpd), p => p.Fkpd.Contains(input.fkpd))
                  .WhereIF(!string.IsNullOrEmpty(input.khly), p => p.Khly.Equals(input.khly))
                  .WhereIF(!string.IsNullOrEmpty(input.tjr), p => p.Tjr.Contains(input.tjr))
                  .WhereIF(!string.IsNullOrEmpty(input.sfskdd), p => p.Sfskdd.Equals(input.sfskdd))
                  .WhereIF(!string.IsNullOrEmpty(input.jj), p => p.Jj.Contains(input.jj))
                  .WhereIF(!string.IsNullOrEmpty(input.bz), p => p.Bz.Contains(input.bz))
                  .WhereIF(!string.IsNullOrEmpty(input.kdhy), p => p.Kdhy.Equals(input.kdhy))
                  .WhereIF(!string.IsNullOrEmpty(input.kdhyc), p => p.Kdhyc.Contains(input.kdhyc))

                  .WhereIF(!string.IsNullOrEmpty(input.kdhysjh), p => p.Kdhysjh.Contains(input.kdhysjh))

                  .WhereIF(!string.IsNullOrEmpty(input.jksyj), p => p.Jksyj.Contains(input.jksyj))

                  .WhereIF(!string.IsNullOrEmpty(input.kjblsyj), p => p.Kjblsyj.Contains(input.kjblsyj))

                  .WhereIF(!string.IsNullOrEmpty(input.pxxx), p => p.Pxxx.Contains(input.pxxx))

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

                  .Select(it => new LqKdKdjlbListOutput

                  {
                      id = it.Id,

                      djmd = it.Djmd,
                      jsj = it.Jsj,
                      kdrq = it.Kdrq,
                      gjlx = it.Gjlx,
                      hgjg = it.Hgjg,
                      zdyj = it.Zdyj,
                      sfyj = it.Sfyj,
                      qk = it.Qk,
                      ckfs = it.Ckfs,

                      deductAmount = it.DeductAmount,

                      fkfs = it.Fkfs,
                      fkyy = it.Fkyy,
                      fkpd = it.Fkpd,
                      khly = it.Khly,
                      tjr = it.Tjr,
                      sfskdd = it.Sfskdd,
                      jj = it.Jj,
                      bz = it.Bz,
                      kdhy = it.Kdhy,
                      kdhyc = it.Kdhyc,
                      kdhysjh = it.Kdhysjh,
                      jksyj = it.Jksyj,
                      kjblsyj = it.Kjblsyj,
                      pxxx = it.Pxxx,

                      F_FIleUrl = it.F_FIleUrl,

                  })
                  .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] LqKdKdjlbListQueryInput input)
          {
              var userInfo = await _userManager.GetUserInfo();
              var exportData = new List<LqKdKdjlbListOutput>();
              if (input.dataType == 0)
              {
                  var data = Clay.Object(await this.GetList(input));
                  exportData = data.Solidify<PageResult<LqKdKdjlbListOutput>>().list;
              }
              else
              {
                  exportData = await this.GetNoPagingList(input);
              }

              List<ParamsModel> paramList =
                  "[{\"value\":\"开单编号\",\"field\":\"id\"},{\"value\":\"开单会员\",\"field\":\"kdhy\"},{\"value\":\"开单会员名称\",\"field\":\"kdhyc\"},{\"value\":\"会员手机号\",\"field\":\"kdhysjh\"},{\"value\":\"单据门店\",\"field\":\"djmd\"},{\"value\":\"金三角\",\"field\":\"jsj\"},{\"value\":\"开单日期\",\"field\":\"kdrq\"},{\"value\":\"顾客类型\",\"field\":\"gjlx\"},{\"value\":\"合作机构\",\"field\":\"hgjg\"},{\"value\":\"整单业绩\",\"field\":\"zdyj\"},{\"value\":\"实付业绩\",\"field\":\"sfyj\"},{\"value\":\"欠款\",\"field\":\"qk\"},{\"value\":\"储扣方式\",\"field\":\"ckfs\"},{\"value\":\"储扣明细\",\"field\":\"ckmx\"},{\"value\":\"付款方式\",\"field\":\"fkfs\"},{\"value\":\"付款医院\",\"field\":\"fkyy\"},{\"value\":\"付款判断\",\"field\":\"fkpd\"},{\"value\":\"客户来源\",\"field\":\"khly\"},{\"value\":\"推荐人\",\"field\":\"tjr\"},{\"value\":\"是否首开订单\",\"field\":\"sfskdd\"},{\"value\":\"简介\",\"field\":\"jj\"},{\"value\":\"备注\",\"field\":\"bz\"},{\"value\":\"健康师业绩\",\"field\":\"jksyj\"},{\"value\":\"科技部老师业绩\",\"field\":\"kjblsyj\"},{\"value\":\"品项信息\",\"field\":\"pxxx\"},{\"value\":\"方案其他\",\"field\":\"F_FIleUrl\"},]".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<LqKdKdjlbListOutput>.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<LqKdKdjlbEntity>().In(it => it.Id, ids).ToListAsync();
              if (entitys.Count > 0)
              {
                  try
                  {
                      //开启事务
                      _db.BeginTran();
                      //批量删除开单记录表

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

  
                      //清空子表数据

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

  
                      //清空子表数据

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

  
                      //清空子表数据

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

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

          #endregion

          #region 更新开单记录表

          /// <summary>
          /// 更新开单记录表
          /// </summary>

          /// <remarks>
          /// 更新开单记录及其关联的品项明细、健康师业绩、科技部老师业绩信息

          ///

          /// 示例请求：
          /// ```json
          /// {
          ///   "id": "开单编号",
          ///   "djmd": "单据门店",
          ///   "jsj": "金三角",
          ///   "kdrq": "2025-01-11",
          ///   "lqKdPxmxList": [
          ///     {
          ///       "px": "品项编号",
          ///       "pxmc": "品项名称",
          ///       "pxjg": 100.00,
          ///       "projectNumber": 1,
          ///       "sourceType": "购买",
          ///       "lqKdJksyjList": [
          ///         {
          ///           "jks": "健康师",
          ///           "jksxm": "健康师姓名",
          ///           "jksyj": "100"
          ///         }
          ///       ]
          ///     }
          ///   ]
          /// }
          /// ```

          ///

          /// 参数说明：
          /// - id: 开单记录主键ID
          /// - input: 开单记录更新参数，包含品项明细和业绩信息
          /// </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] LqKdKdjlbUpInput input)
          {
              var entity = input.Adapt<LqKdKdjlbEntity>();
              try
              {
                  //开启事务
                  _db.BeginTran();

                  //更新开单记录表记录

                  await _db.Updateable(entity).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();

  
                  //清空原有数据

                  await _db.Deleteable<LqKdJksyjEntity>().Where(u => u.Glkdbh == id).ExecuteCommandAsync();
                  await _db.Deleteable<LqKdKjbsyjEntity>().Where(u => u.Glkdbh == id).ExecuteCommandAsync();
                  await _db.Deleteable<LqKdPxmxEntity>().Where(u => u.Glkdbh == id).ExecuteCommandAsync();

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

                  {

                      foreach (var item in input.lqKdPxmxList)

                      {

                          // 创建品项明细实体
                          var lqKdPxmxEntity = new LqKdPxmxEntity
                          {
                              Id = YitIdHelper.NextId().ToString(),
                              Glkdbh = entity.Id,
                              CreateTIme = DateTime.Now,
                              MemberId = entity.Kdhy,
                              IsEnabled = 0,