netcore/src/Modularity/Extend/NCC.Extend/LqXhHyhkService.cs

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>();
                // 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))
                .Select(it => new LqXhHyhkListOutput
                {
                    id = it.Id,
                    md = it.Md,
                    mdbh = it.Mdbh,
                    mdmc = it.Mdmc,
                    hy = it.Hy,
                    hyzh = it.Hyzh,
                    hymc = it.Hymc,
                    gklx = it.Gklx,
                    xfje = SqlFunc.ToString(it.Xfje),
                    sgfy = SqlFunc.ToString(it.Sgfy),
                    sfykjb = it.Sfykjb,
                    hksj = it.Hksj,
                    czry = it.Czry,
                    memberPhone = it.MemberPhone,
                })
                .MergeTable()
                .OrderBy(sidx + " " + input.sort)
                .ToPagedListAsync(input.currentPage, input.pageSize);
            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;
            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,
                            ProjectNumber = item.projectNumber ?? 1,
                            TotalPrice = (decimal)(item.pxjg * (item.projectNumber ?? 1)),
                            Px = item.px,
                            Pxmc = item.pxmc,
                            Pxjg = item.pxjg,
                            SourceType = item.sourceType,
                        };
                        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,
                                        LaborCost = ijks_tem.laborCost,
                                        KdpxNumber = ijks_tem.kdpxNumber,
                                    }
                                );
                            }
                        }
                        // 收集该品项关联的科技部老师业绩
                        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,
                                        LaborCost = ikjbs_tem.laborCost,
                                        HdpxNumber = ikjbs_tem.hdpxNumber,
                                    }
                                );
                            }
                        }
                    }
                }
                // 批量插入品项明细
                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 = it.Hymc,
                    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;
                //更新会员耗卡记录
                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,
                            ProjectNumber = item.projectNumber ?? 1,
                            TotalPrice = (decimal)(item.pxjg * (item.projectNumber ?? 1)),
                            Px = item.px,
                            Pxmc = item.pxmc,
                            Pxjg = item.pxjg,
                            SourceType = item.sourceType,
                        };
                        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,
                                        KdpxNumber = ijks_tem.kdpxNumber,
                                    }
                                );
                            }
                        }
                        // 收集该品项关联的科技部老师业绩
                        if (item.lqXhKjbsyjList != null && item.lqXhKjbsyjList.Any())
                        {
                            foreach (var ikjbs_tem in item.lqXhKjbsyjList)
                            {
                                allKjbsyjEntities.Add(
                                    new LqXhKjbsyjEntity
                                    {
                                        Id = YitIdHelper.NextId().ToString(),
                                        Glkdbh = input.id,
                                        Kjbls = ikjbs_tem.kjbls,
                                        Kjblsxm = ikjbs_tem.kjblsxm,
                                        Kjblszh = ikjbs_tem.kjblszh,
                                        Kjblsyj = ikjbs_tem.kjblsyj,
                                        Yjsj = DateTime.Now,
                                        Hkpxid = lqXhPxmxEntity.Id,
                                        LaborCost = ikjbs_tem.laborCost,
                                        HdpxNumber = ikjbs_tem.hdpxNumber,
                                    }
                                );
                            }
                        }
                    }
                }
                // 批量插入品项明细
                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)
            {
                //回滚事务
                _db.RollbackTran();
                throw NCCException.Oh(ErrorCode.COM1001);
            }
        }
        #endregion
        #region 删除会员耗卡
        /// <summary>
        /// 删除会员耗卡
        /// </summary>
        /// <returns></returns>
        [HttpDelete("{id}")]
        public async Task Delete(string id)
        {
            var entity = await _db.Queryable<LqXhHyhkEntity>().FirstAsync(p => p.Id == id);
            _ = entity ?? throw NCCException.Oh(ErrorCode.COM1005);
            try
            {
                //开启事务
                _db.BeginTran();
                //删除会员耗卡记录
                await _db.Deleteable<LqXhHyhkEntity>().Where(d => d.Id == id).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();
                //关闭事务
                _db.CommitTran();
            }
            catch (Exception)
            {
                //回滚事务
                _db.RollbackTran();
                throw NCCException.Oh(ErrorCode.COM1002);
            }
        }
        #endregion
        #region 查询健康师消耗业绩列表
        /// <summary>
        /// 查询健康师业绩列表
        /// </summary>
        /// <param name="input">查询参数</param>
        /// <returns>分页的健康师业绩列表</returns>
        /// <remarks>
        /// 查询健康师业绩记录，支持分页和时间筛选
        /// 
        /// 示例请求：
        /// ```json
        /// {
        ///   "glkdbh": "123456789",
        ///   "jksId": "健康师ID",
        ///   "startTime": "2025-01-01T00:00:00",
        ///   "endTime": "2025-01-31T23:59:59",
        ///   "currentPage": 1,
        ///   "pageSize": 10,
        ///   "sidx": "yjsj",
        ///   "sort": "desc"
        /// }
        /// ```
        /// 
        /// 参数说明：
        /// - glkdbh: 开单记录ID（可选）
        /// - jksId: 健康师ID（可选）
        /// - startTime: 查询开始时间（可选）
        /// - endTime: 查询结束时间（可选）
        /// - currentPage: 当前页码
        /// - pageSize: 每页大小
        /// </remarks>
        /// <response code="200">成功获取健康师业绩列表</response>
        /// <response code="400">请求参数错误</response>
        /// <response code="500">服务器内部错误</response>
        [HttpGet("GetJksyjList")]
        public async Task<dynamic> GetJksyjList([FromQuery] LqXhJksyjQueryInput input)
        {
            try
            {
                var sidx = string.IsNullOrEmpty(input.sidx) ? "yjsj" : input.sidx;
                var sort = string.IsNullOrEmpty(input.sort) ? "desc" : input.sort;
                var data = await _db.Queryable<LqXhJksyjEntity>()
                    .WhereIF(!string.IsNullOrEmpty(input.Glkdbh), w => w.Glkdbh == input.Glkdbh)
                    .WhereIF(!string.IsNullOrEmpty(input.JksId), w => w.Jks == input.JksId)
                    .WhereIF(input.StartTime.HasValue, w => w.Yjsj >= input.StartTime.Value)
                    .WhereIF(input.EndTime.HasValue, w => w.Yjsj <= input.EndTime.Value)
                    .Where(w => w.IsEffective == StatusEnum.有效.GetHashCode())
                    .Select(it => new LqXhJksyjInfoOutput
                    {
                        id = it.Id,
                        glkdbh = it.Glkdbh,
                        jks = it.Jks,
                        jksxm = it.Jksxm,
                        jkszh = it.Jkszh,
                        jksyj = it.Jksyj.ToString(),
                        yjsj = it.Yjsj,
                        jsjId = it.JsjId,
                        kdpxid = it.Kdpxid,
                        laborCost = it.LaborCost,
                        kdpxNumber = it.KdpxNumber,
                        storeName = SqlFunc.Subqueryable<LqXhHyhkEntity>().Where(w => w.Id == it.Glkdbh).Select(w => w.Mdmc),
                        memberId = SqlFunc.Subqueryable<LqXhHyhkEntity>().Where(w => w.Id == it.Glkdbh).Select(w => w.Hy),
                        memberName = SqlFunc.Subqueryable<LqXhHyhkEntity>().Where(w => w.Id == it.Glkdbh).Select(w => w.Hymc),
                    })
                    .MergeTable()
                    .OrderBy(sidx + " " + sort)
                    .ToPagedListAsync(input.currentPage, input.pageSize);
                return PageResult<LqXhJksyjInfoOutput>.SqlSugarPageResult(data);
            }
            catch (Exception ex)
            {
                throw NCCException.Oh($"获取健康师业绩列表失败: {ex.Message}");
            }
        }
        #endregion
        #region 耗卡记录作废
        /// <summary>
        /// 耗卡记录作废
        /// </summary>
        /// <param name="id">耗卡记录ID</param>
        /// <returns></returns>
        [HttpPut("CancelCardUsageRecord/{id}")]
        public async Task<dynamic> CancelCardUsageRecord(string id)
        {
            try
            {
                //开启事务
                _db.BeginTran();
                //查询消耗记录表信息
                var LqhyhkInfo = await _db.Queryable<LqXhHyhkEntity>().Where(p => p.Id == id && p.IsEffective == StatusEnum.有效.GetHashCode()).FirstAsync();
                if (LqhyhkInfo == null)
                {
                    throw NCCException.Oh(ErrorCode.COM1005, "耗卡记录不存在或已作废");
                }
                //更新耗卡记录状态
                LqhyhkInfo.IsEffective = StatusEnum.无效.GetHashCode();
                await _db.Updateable(LqhyhkInfo).ExecuteCommandAsync();
                //更新品项明细表状态
                await _db.Updateable<LqXhPxmxEntity>().SetColumns(it => new LqXhPxmxEntity { IsEffective = StatusEnum.无效.GetHashCode() }).Where(w => w.ConsumeInfoId == id).ExecuteCommandAsync();
                //更新健康师业绩表状态
                await _db.Updateable<LqXhJksyjEntity>().SetColumns(it => new LqXhJksyjEntity { IsEffective = StatusEnum.无效.GetHashCode() }).Where(w => w.Glkdbh == id).ExecuteCommandAsync();
                //更新科技部老师业绩表状态
                await _db.Updateable<LqXhKjbsyjEntity>().SetColumns(it => new LqXhKjbsyjEntity { IsEffective = StatusEnum.无效.GetHashCode() }).Where(w => w.Glkdbh == id).ExecuteCommandAsync();
                //关闭事务
                _db.CommitTran();
                return LqhyhkInfo;
            }
            catch (Exception)
            {
                //回滚事务
                _db.RollbackTran();
                throw NCCException.Oh(ErrorCode.COM1001);
            }
        }
        #endregion
        #region 获取某个会员的耗卡记录
        /// <summary>
        /// 获取某个会员的耗卡记录（分页）
        /// </summary>
        /// <param name="input">查询参数</param>
        /// <returns></returns>
        [HttpGet("GetMemberCardUsageRecord")]
        public async Task<dynamic> GetMemberCardUsageRecord([FromQuery] LqXhHyhkMemberCardUsageQueryInput input)
        {
            try
            {
                // 参数验证
                if (string.IsNullOrEmpty(input.MemberId))
                {
                    throw NCCException.Oh("会员ID不能为空");
                }
                // 分页查询会员耗卡记录
                var data = await _db.Queryable<LqXhHyhkEntity>()
                    .Where(p => p.Hy == input.MemberId && p.IsEffective == StatusEnum.有效.GetHashCode())
                    .WhereIF(!string.IsNullOrEmpty(input.StoreId), p => p.Md == input.StoreId)
                    .WhereIF(input.StartTime.HasValue, p => p.Hksj >= input.StartTime.Value)
                    .WhereIF(input.EndTime.HasValue, p => p.Hksj <= input.EndTime.Value)
                    .Select(it => new LqXhHyhkMemberCardUsageOutput
                    {
                        Id = it.Id,
                        MemberId = it.Hy,
                        MemberName = it.Hymc,
                        StoreId = it.Md,
                        StoreName = it.Mdmc,
                        UsageDate = it.Hksj,
                        TotalAmount = it.Xfje,
                        Remarks = it.SignatureFile,
                        CreateTime = it.CreateTime
                    })
                    .MergeTable()
                    .OrderBy((input.sidx == null ? "UsageDate" : input.sidx) + " " + (input.sort ?? "desc"))
                    .ToPagedListAsync(input.currentPage, input.pageSize);
                // 获取当前页耗卡记录ID，直接查询对应的品项明细
                if (data.list.Any())
                {
                    var recordIds = data.list.Select(r => r.Id).ToList();
                    // 批量查询当前页记录的所有品项明细
                    var itemDetails = await _db.Queryable<LqXhPxmxEntity>().Where(w => recordIds.Contains(w.ConsumeInfoId) && w.IsEffective == StatusEnum.有效.GetHashCode()).ToListAsync();
                    // 按耗卡记录ID分组明细
                    var detailsGrouped = itemDetails.GroupBy(d => d.ConsumeInfoId).ToDictionary(g => g.Key, g => g.ToList());
                    // 为每个记录添加品项明细
                    foreach (var record in data.list)
                    {
                        if (detailsGrouped.ContainsKey(record.Id))
                        {
                            record.ItemDetails = detailsGrouped[record.Id].Select(detail => new LqXhHyhkMemberCardUsageItemDetail
                            {
                                Id = detail.Id,
                                ItemId = detail.Px,
                                ItemName = detail.Pxmc,
                                UnitPrice = detail.Pxjg,
                                ProjectNumber = detail.ProjectNumber,
                                TotalPrice = detail.TotalPrice,
                                SourceType = detail.SourceType,
                                CreateTime = detail.CreateTIme
                            }).ToList();
                        }
                    }
                }
                return PageResult<LqXhHyhkMemberCardUsageOutput>.SqlSugarPageResult(data);
            }
            catch (Exception ex)
            {
                throw NCCException.Oh($"获取会员耗卡记录失败: {ex.Message}");
            }
        }
        #endregion
    }
}