123213

“wangming”
1 parent e298ca84
Showing 13 changed files with 1218 additions and 37 deletions
netcore/src/Modularity/Extend/NCC.Extend.Entitys/Dto/LqKdKdjlb/HealthCoachStatisticsOutput.cs
netcore/src/Modularity/Extend/NCC.Extend.Entitys/Dto/LqKdKdjlb/HealthCoachStatisticsQueryInput.cs
netcore/src/Modularity/Extend/NCC.Extend.Entitys/Dto/LqReport/BusinessStatisticsInput.cs
netcore/src/Modularity/Extend/NCC.Extend.Entitys/Dto/LqReport/BusinessStatisticsOutput.cs
netcore/src/Modularity/Extend/NCC.Extend.Entitys/Dto/LqReport/CustomerTypeStatisticsInput.cs
netcore/src/Modularity/Extend/NCC.Extend.Entitys/Dto/LqReport/CustomerTypeStatisticsOutput.cs
netcore/src/Modularity/Extend/NCC.Extend.Entitys/Dto/LqReport/ItemStatisticsInput.cs
netcore/src/Modularity/Extend/NCC.Extend.Entitys/Dto/LqReport/ItemStatisticsOutput.cs
netcore/src/Modularity/Extend/NCC.Extend.Entitys/Dto/LqReport/StorePerformanceComparisonInput.cs
netcore/src/Modularity/Extend/NCC.Extend.Entitys/Dto/LqReport/StorePerformanceComparisonOutput.cs
netcore/src/Modularity/Extend/NCC.Extend/LqKdKdjlbService.cs
netcore/src/Modularity/Extend/NCC.Extend/LqReportService.cs
netcore/src/Modularity/Extend/NCC.Extend/LqTkjlbService.cs
+namespace NCC.Extend.Entitys.Dto.LqKdKdjlb
+{
+    /// <summary>
+    /// 健康师统计输出
+    /// </summary>
+    public class HealthCoachStatisticsOutput
+    {
+        /// <summary>
+        /// 健康师ID
+        /// </summary>
+        public string employeeId { get; set; }
+
+        /// <summary>
+        /// 健康师姓名
+        /// </summary>
+        public string employeeName { get; set; }
+
+        /// <summary>
+        /// 门店ID
+        /// </summary>
+        public string storeId { get; set; }
+
+        /// <summary>
+        /// 门店名称
+        /// </summary>
+        public string storeName { get; set; }
+
+        /// <summary>
+        /// 事业部ID
+        /// </summary>
+        public string departmentId { get; set; }
+
+        /// <summary>
+        /// 事业部名称
+        /// </summary>
+        public string departmentName { get; set; }
+
+        /// <summary>
+        /// 邀约人数 - 统计该健康师在指定时间周期内邀约的客户数量（按客户去重）
+        /// </summary>
+        public int inviteCount { get; set; }
+
+        /// <summary>
+        /// 预约人数 - 统计该健康师在指定时间周期内预约的客户数量（按客户去重，无论预约状态）
+        /// </summary>
+        public int appointmentCount { get; set; }
+
+        /// <summary>
+        /// 到店人数 - 统计该健康师在指定时间周期内已确认到店的客户数量（按客户去重，仅统计状态为'已确认'的预约）
+        /// </summary>
+        public int visitCount { get; set; }
+
+        /// <summary>
+        /// 开单人数 - 统计该健康师在指定时间周期内开单的客户数量（按开单记录去重）
+        /// </summary>
+        public int billingCount { get; set; }
+
+        /// <summary>
+        /// 开单金额 - 统计该健康师在指定时间周期内的开单业绩总金额
+        /// </summary>
+        public decimal billingAmount { get; set; }
+
+        /// <summary>
+        /// 消耗金额 - 统计该健康师在指定时间周期内的消耗业绩总金额
+        /// </summary>
+        public decimal consumeAmount { get; set; }
+
+        /// <summary>
+        /// 人头 - 统计该健康师在指定时间周期内服务的唯一客户数量（按客户去重）
+        /// </summary>
+        public int headCount { get; set; }
+
+        /// <summary>
+        /// 人次 - 统计该健康师在指定时间周期内服务的客户人次（按客户+日期去重，同一客户不同天算多次）
+        /// </summary>
+        public int personCount { get; set; }
+
+        /// <summary>
+        /// 消耗项目数 - 统计该健康师在指定时间周期内消耗的项目总次数
+        /// </summary>
+        public int projectCount { get; set; }
+    }
+}
+using NCC.Common.Filter;
+using System;
+
+namespace NCC.Extend.Entitys.Dto.LqKdKdjlb
+{
+    /// <summary>
+    /// 健康师统计查询输入
+    /// </summary>
+    public class HealthCoachStatisticsQueryInput : PageInputBase
+    {
+        /// <summary>
+        /// 开始时间
+        /// </summary>
+        public DateTime? StartTime { get; set; }
+
+        /// <summary>
+        /// 结束时间
+        /// </summary>
+        public DateTime? EndTime { get; set; }
+
+        /// <summary>
+        /// 事业部ID
+        /// </summary>
+        public string DepartmentId { get; set; }
+
+        /// <summary>
+        /// 门店ID
+        /// </summary>
+        public string StoreId { get; set; }
+
+        /// <summary>
+        /// 健康师姓名
+        /// </summary>
+        public string EmployeeName { get; set; }
+    }
+}
+using System;
+
+namespace NCC.Extend.Entitys.Dto.LqReport
+{
+    /// <summary>
+    /// 业务统计查询输入
+    /// </summary>
+    public class BusinessStatisticsInput
+    {
+        /// <summary>
+        /// 开始时间
+        /// </summary>
+        public DateTime? StartTime { get; set; }
+
+        /// <summary>
+        /// 结束时间
+        /// </summary>
+        public DateTime? EndTime { get; set; }
+
+        /// <summary>
+        /// 门店ID列表
+        /// </summary>
+        public string[] StoreIds { get; set; }
+    }
+}
+namespace NCC.Extend.Entitys.Dto.LqReport
+{
+    /// <summary>
+    /// 业务统计输出
+    /// </summary>
+    public class BusinessStatisticsOutput
+    {
+        /// <summary>
+        /// 开单总金额
+        /// </summary>
+        public decimal TotalBillingAmount { get; set; }
+
+        /// <summary>
+        /// 耗卡总金额
+        /// </summary>
+        public decimal TotalConsumeAmount { get; set; }
+
+        /// <summary>
+        /// 退卡总金额
+        /// </summary>
+        public decimal TotalRefundAmount { get; set; }
+
+        /// <summary>
+        /// 开单人数
+        /// </summary>
+        public int BillingCount { get; set; }
+
+        /// <summary>
+        /// 耗卡人数
+        /// </summary>
+        public int ConsumeCount { get; set; }
+
+        /// <summary>
+        /// 退卡人数
+        /// </summary>
+        public int RefundCount { get; set; }
+    }
+}
+using System;
+
+namespace NCC.Extend.Entitys.Dto.LqReport
+{
+    /// <summary>
+    /// 客户类型统计查询输入
+    /// </summary>
+    public class CustomerTypeStatisticsInput
+    {
+        /// <summary>
+        /// 开始时间
+        /// </summary>
+        public DateTime? StartTime { get; set; }
+
+        /// <summary>
+        /// 结束时间
+        /// </summary>
+        public DateTime? EndTime { get; set; }
+
+        /// <summary>
+        /// 门店ID列表
+        /// </summary>
+        public string[] StoreIds { get; set; }
+    }
+}
+namespace NCC.Extend.Entitys.Dto.LqReport
+{
+    /// <summary>
+    /// 客户类型统计输出
+    /// </summary>
+    public class CustomerTypeStatisticsOutput
+    {
+        /// <summary>
+        /// 线索客户数量
+        /// </summary>
+        public int LeadCount { get; set; }
+
+        /// <summary>
+        /// 新客数量
+        /// </summary>
+        public int NewCustomerCount { get; set; }
+
+        /// <summary>
+        /// 散客数量
+        /// </summary>
+        public int CasualCustomerCount { get; set; }
+
+        /// <summary>
+        /// 会员数量
+        /// </summary>
+        public int MemberCount { get; set; }
+
+        /// <summary>
+        /// 拓客总人数
+        /// </summary>
+        public int TotalInviteCount { get; set; }
+
+        /// <summary>
+        /// 消耗人数（有消耗金额的）
+        /// </summary>
+        public int ConsumeCount { get; set; }
+
+        /// <summary>
+        /// 转化率（消耗人数/拓客人数）
+        /// </summary>
+        public decimal ConversionRate { get; set; }
+    }
+}
+using System;
+
+namespace NCC.Extend.Entitys.Dto.LqReport
+{
+    /// <summary>
+    /// 品项统计查询输入
+    /// </summary>
+    public class ItemStatisticsInput
+    {
+        /// <summary>
+        /// 开始时间
+        /// </summary>
+        public DateTime? StartTime { get; set; }
+
+        /// <summary>
+        /// 结束时间
+        /// </summary>
+        public DateTime? EndTime { get; set; }
+
+        /// <summary>
+        /// 门店ID列表
+        /// </summary>
+        public string[] StoreIds { get; set; }
+    }
+}
+namespace NCC.Extend.Entitys.Dto.LqReport
+{
+    /// <summary>
+    /// 品项统计输出
+    /// </summary>
+    public class ItemStatisticsOutput
+    {
+        /// <summary>
+        /// 品项ID
+        /// </summary>
+        public string ItemId { get; set; }
+
+        /// <summary>
+        /// 品项名称
+        /// </summary>
+        public string ItemName { get; set; }
+
+        /// <summary>
+        /// 品项编号
+        /// </summary>
+        public string ItemNumber { get; set; }
+
+        /// <summary>
+        /// 开单数量
+        /// </summary>
+        public int BillingCount { get; set; }
+
+        /// <summary>
+        /// 开单金额
+        /// </summary>
+        public decimal BillingAmount { get; set; }
+
+        /// <summary>
+        /// 消耗数量
+        /// </summary>
+        public int ConsumeCount { get; set; }
+
+        /// <summary>
+        /// 消耗金额
+        /// </summary>
+        public decimal ConsumeAmount { get; set; }
+
+        /// <summary>
+        /// 退卡数量
+        /// </summary>
+        public int RefundCount { get; set; }
+
+        /// <summary>
+        /// 退卡金额
+        /// </summary>
+        public decimal RefundAmount { get; set; }
+    }
+}
+using System;
+
+namespace NCC.Extend.Entitys.Dto.LqReport
+{
+    /// <summary>
+    /// 门店业绩对比统计查询输入
+    /// </summary>
+    public class StorePerformanceComparisonInput
+    {
+        /// <summary>
+        /// 开始时间
+        /// </summary>
+        public DateTime? StartTime { get; set; }
+
+        /// <summary>
+        /// 结束时间
+        /// </summary>
+        public DateTime? EndTime { get; set; }
+
+        /// <summary>
+        /// 门店ID列表
+        /// </summary>
+        public string[] StoreIds { get; set; }
+    }
+}
+namespace NCC.Extend.Entitys.Dto.LqReport
+{
+    /// <summary>
+    /// 门店业绩对比统计输出
+    /// </summary>
+    public class StorePerformanceComparisonOutput
+    {
+        /// <summary>
+        /// 门店ID
+        /// </summary>
+        public string StoreId { get; set; }
+
+        /// <summary>
+        /// 门店名称
+        /// </summary>
+        public string StoreName { get; set; }
+
+        /// <summary>
+        /// 目标业绩
+        /// </summary>
+        public decimal TargetPerformance { get; set; }
+
+        /// <summary>
+        /// 实际开单业绩
+        /// </summary>
+        public decimal ActualPerformance { get; set; }
+
+        /// <summary>
+        /// 完成率（实际业绩/目标业绩）
+        /// </summary>
+        public decimal CompletionRate { get; set; }
+
+        /// <summary>
+        /// 差额（实际业绩-目标业绩）
+        /// </summary>
+        public decimal Difference { get; set; }
+
+        /// <summary>
+        /// 是否达标（实际业绩 >= 目标业绩）
+        /// </summary>
+        public bool IsTargetAchieved { get; set; }
+    }
+}
@@ -2728,5 +2728,230 @@ namespace NCC.Extend.LqKdKdjlb
             }
         }
         #endregion
+
+        #region 门店整体统计表
+        /// <summary>
+        /// 门店整体统计表
+        /// </summary>
+        /// <remarks>
+        /// 统计每个健康师在指定时间周期内的各项数据指标
+        /// 包括：邀约人数、预约人数、到店人数、开单人数、开单金额、消耗金额、人头、人次、消耗项目数
+        /// 
+        /// 示例请求：
+        /// ```json
+        /// {
+        ///   "startTime": "2025-10-01",
+        ///   "endTime": "2025-10-31",
+        ///   "departmentId": "部门ID",
+        ///   "storeId": "门店ID",
+        ///   "employeeName": "健康师姓名"
+        /// }
+        /// ```
+        /// 
+        /// 参数说明：
+        /// - startTime: 开始时间（可选，默认为当月1号）
+        /// - endTime: 结束时间（可选，默认为当前时间）
+        /// - departmentId: 事业部ID（可选）
+        /// - storeId: 门店ID（可选）
+        /// - employeeName: 健康师姓名（可选）
+        /// 
+        /// 返回字段说明：
+        /// - EmployeeId: 健康师ID
+        /// - EmployeeName: 健康师姓名
+        /// - StoreId: 门店ID
+        /// - StoreName: 门店名称
+        /// - DepartmentId: 事业部ID
+        /// - DepartmentName: 事业部名称
+        /// - InviteCount: 邀约人数（按客户去重）
+        /// - AppointmentCount: 预约人数（按客户去重，无论预约状态）
+        /// - VisitCount: 到店人数（按客户去重，仅统计状态为'已确认'的预约）
+        /// - BillingCount: 开单人数（按开单记录去重）
+        /// - BillingAmount: 开单金额（开单业绩总金额）
+        /// - ConsumeAmount: 消耗金额（消耗业绩总金额）
+        /// - HeadCount: 人头（按客户去重）
+        /// - PersonCount: 人次（按客户+日期去重，同一客户不同天算多次）
+        /// - ProjectCount: 消耗项目数（项目总次数）
+        /// </remarks>
+        /// <param name="input">查询参数</param>
+        /// <returns>健康师统计数据列表</returns>
+        /// <response code="200">成功返回统计数据</response>
+        /// <response code="400">参数错误</response>
+        /// <response code="500">服务器错误</response>
+        [HttpGet("get-health-coach-statistics")]
+        public async Task<dynamic> GetHealthCoachStatistics([FromQuery] HealthCoachStatisticsQueryInput input)
+        {
+            try
+            {
+                // 设置默认时间范围（如果未提供，默认为当月）
+                var startTime = input.StartTime ?? new DateTime(DateTime.Now.Year, DateTime.Now.Month, 1);
+                var endTime = input.EndTime ?? DateTime.Now;
+
+                // 构建SQL查询
+                var sql = $@"
+                    SELECT 
+                        u.F_Id as EmployeeId,
+                        u.F_REALNAME as EmployeeName,
+                        u.F_MDID as StoreId,
+                        md.dm as StoreName,
+                        md.syb as DepartmentId,
+                        dept.F_FullName as DepartmentName,
+                        
+                        -- 邀约人数
+                        COALESCE(invite_stats.InviteCount, 0) as InviteCount,
+                        
+                        -- 预约人数（无论状态）
+                        COALESCE(appointment_stats.AppointmentCount, 0) as AppointmentCount,
+                        
+                        -- 到店人数（已确认状态）
+                        COALESCE(visit_stats.VisitCount, 0) as VisitCount,
+                        
+                        -- 开单人数和金额
+                        COALESCE(billing_stats.BillingCount, 0) as BillingCount,
+                        COALESCE(billing_stats.BillingAmount, 0) as BillingAmount,
+                        
+                        -- 消耗相关统计
+                        COALESCE(consume_stats.ConsumeAmount, 0) as ConsumeAmount,
+                        COALESCE(consume_stats.HeadCount, 0) as HeadCount,
+                        COALESCE(consume_stats.PersonCount, 0) as PersonCount,
+                        COALESCE(consume_stats.ProjectCount, 0) as ProjectCount
+
+                    FROM BASE_USER u
+                    LEFT JOIN lq_mdxx md ON u.F_MDID = md.F_Id
+                    LEFT JOIN base_organize dept ON md.syb = dept.F_Id
+
+                    -- 邀约统计子查询
+                    LEFT JOIN (
+                        SELECT 
+                            yyr as EmployeeId,
+                            COUNT(DISTINCT yykh) as InviteCount
+                        FROM lq_yaoyjl
+                        WHERE yyr IS NOT NULL
+                            AND F_CreateTime >= @startTime
+                            AND F_CreateTime <= @endTime
+                        GROUP BY yyr
+                    ) invite_stats ON u.F_Id = invite_stats.EmployeeId
+
+                    -- 预约统计子查询
+                    LEFT JOIN (
+                        SELECT 
+                            yyr as EmployeeId,
+                            COUNT(DISTINCT gk) as AppointmentCount
+                        FROM lq_yyjl
+                        WHERE yyr IS NOT NULL
+                            AND F_CreateTime >= @startTime
+                            AND F_CreateTime <= @endTime
+                        GROUP BY yyr
+                    ) appointment_stats ON u.F_Id = appointment_stats.EmployeeId
+
+                    -- 到店统计子查询
+                    LEFT JOIN (
+                        SELECT 
+                            yyr as EmployeeId,
+                            COUNT(DISTINCT gk) as VisitCount
+                        FROM lq_yyjl
+                        WHERE yyr IS NOT NULL
+                            AND F_Status = '已确认'
+                            AND F_CreateTime >= @startTime
+                            AND F_CreateTime <= @endTime
+                        GROUP BY yyr
+                    ) visit_stats ON u.F_Id = visit_stats.EmployeeId
+
+                    -- 开单统计子查询
+                    LEFT JOIN (
+                        SELECT 
+                            jkszh as EmployeeId,
+                            COUNT(DISTINCT glkdbh) as BillingCount,
+                            SUM(CAST(jksyj AS DECIMAL(18,2))) as BillingAmount
+                        FROM lq_kd_jksyj
+                        WHERE jkszh IS NOT NULL
+                            AND F_IsEffective = 1
+                            AND yjsj >= @startTime
+                            AND yjsj <= @endTime
+                        GROUP BY jkszh
+                    ) billing_stats ON u.F_Id = billing_stats.EmployeeId
+
+                    -- 消耗统计子查询
+                    LEFT JOIN (
+                        SELECT 
+                            jksyj.jkszh as EmployeeId,
+                            SUM(jksyj.jksyj) as ConsumeAmount,
+                            COUNT(DISTINCT hyhk.hy) as HeadCount,
+                            COUNT(DISTINCT CONCAT(jksyj.jkszh, '_', hyhk.hy, '_', DATE(hyhk.hksj))) as PersonCount,
+                            SUM(jksyj.F_kdpxNumber) as ProjectCount
+                        FROM lq_xh_jksyj jksyj
+                        INNER JOIN lq_xh_hyhk hyhk ON jksyj.glkdbh = hyhk.F_Id
+                        WHERE jksyj.jkszh IS NOT NULL
+                            AND jksyj.F_IsEffective = 1
+                            AND hyhk.F_IsEffective = 1
+                            AND hyhk.hksj >= @startTime
+                            AND hyhk.hksj <= @endTime
+                        GROUP BY jksyj.jkszh
+                    ) consume_stats ON u.F_Id = consume_stats.EmployeeId
+
+                    WHERE u.F_GW = '健康师'
+                ";
+
+                // 添加条件过滤
+                var conditions = new List<string>();
+                var parameters = new List<SugarParameter>
+                {
+                    new SugarParameter("@startTime", startTime),
+                    new SugarParameter("@endTime", endTime)
+                };
+
+                if (!string.IsNullOrEmpty(input.DepartmentId))
+                {
+                    conditions.Add("md.syb = @departmentId");
+                    parameters.Add(new SugarParameter("@departmentId", input.DepartmentId));
+                }
+
+                if (!string.IsNullOrEmpty(input.StoreId))
+                {
+                    conditions.Add("u.F_MDID = @storeId");
+                    parameters.Add(new SugarParameter("@storeId", input.StoreId));
+                }
+
+                if (!string.IsNullOrEmpty(input.EmployeeName))
+                {
+                    conditions.Add("u.F_REALNAME LIKE @employeeName");
+                    parameters.Add(new SugarParameter("@employeeName", $"%{input.EmployeeName}%"));
+                }
+
+                if (conditions.Any())
+                {
+                    sql += " AND " + string.Join(" AND ", conditions);
+                }
+
+                sql += " ORDER BY u.F_REALNAME";
+
+                // 执行查询
+                var allData = await _db.Ado.SqlQueryAsync<HealthCoachStatisticsOutput>(sql, parameters);
+
+                // 手动分页
+                var totalCount = allData.Count;
+                var pagedData = allData
+                    .Skip((input.currentPage - 1) * input.pageSize)
+                    .Take(input.pageSize)
+                    .ToList();
+
+                // 直接返回分页结果
+                return new
+                {
+                    list = pagedData,
+                    pagination = new
+                    {
+                        pageIndex = input.currentPage,
+                        pageSize = input.pageSize,
+                        totalCount = totalCount
+                    }
+                };
+            }
+            catch (Exception ex)
+            {
+                _logger.LogError(ex, "获取健康师统计数据失败");
+                throw NCCException.Oh($"获取健康师统计数据失败：{ex.Message}");
+            }
+        }
+        #endregion
     }
 }
@@ -25,6 +25,8 @@ using NCC.Extend.Entitys.lq_jinsanjiao_user;
 using NCC.Extend.Entitys.lq_kd_kdjlb;
 using NCC.Extend.Entitys.lq_xh_hyhk;
 using NCC.Extend.Entitys.lq_khxx;
+using NCC.Extend.Entitys.Dto.LqReport;
+using NCC.Extend.Entitys.Enum;
 using SqlSugar;
 namespace NCC.Extend
@@ -40,6 +42,12 @@ namespace NCC.Extend
         private readonly IUserManager _userManager;
         private readonly ILogger<LqReportService> _logger;
+        /// <summary>
+        /// 构造函数
+        /// </summary>
+        /// <param name="db">数据库客户端</param>
+        /// <param name="userManager">用户管理器</param>
+        /// <param name="logger">日志记录器</param>
         public LqReportService(ISqlSugarClient db, IUserManager userManager, ILogger<LqReportService> logger)
         {
             _db = db;
@@ -47,6 +55,8 @@ namespace NCC.Extend
             _logger = logger;
         }
+
+
         #region 门店业绩报表
         /// <summary>
@@ -681,6 +691,522 @@ namespace NCC.Extend
             }
         }
+        /// <summary>
+        /// 获取业务统计数据
+        /// </summary>
+        /// <remarks>
+        /// 统计指定时间范围内的开单、耗卡、退卡相关数据
+        /// 包括：开单总金额、耗卡总金额、退卡总金额、开单人数、耗卡人数、退卡人数
+        /// 
+        /// 示例请求：
+        /// ```json
+        /// {
+        ///   "startTime": "2025-10-01",
+        ///   "endTime": "2025-10-31",
+        ///   "storeIds": ["门店ID1", "门店ID2"]
+        /// }
+        /// ```
+        /// 
+        /// 参数说明：
+        /// - startTime: 开始时间（可选，默认为当月1号）
+        /// - endTime: 结束时间（可选，默认为当前时间）
+        /// - storeIds: 门店ID列表（可选）
+        /// 
+        /// 返回字段说明：
+        /// - TotalBillingAmount: 开单总金额
+        /// - TotalConsumeAmount: 耗卡总金额
+        /// - TotalRefundAmount: 退卡总金额
+        /// - BillingCount: 开单人数（按客户去重）
+        /// - ConsumeCount: 耗卡人数（按客户去重）
+        /// - RefundCount: 退卡人数（按客户去重）
+        /// </remarks>
+        /// <param name="input">查询参数</param>
+        /// <returns>业务统计数据</returns>
+        /// <response code="200">成功返回统计数据</response>
+        /// <response code="400">参数错误</response>
+        /// <response code="500">服务器错误</response>
+        [HttpPost("get-business-statistics")]
+        public async Task<object> GetBusinessStatistics(BusinessStatisticsInput input)
+        {
+            try
+            {
+                // 设置默认时间范围（如果未提供，默认为当月）
+                var startTime = input.StartTime ?? new DateTime(DateTime.Now.Year, DateTime.Now.Month, 1);
+                var endTime = input.EndTime ?? DateTime.Now;
+
+                // 第一步：获取开单统计数据
+                var billingSql = @"
+                    SELECT 
+                        COUNT(DISTINCT kd.kdhy) as billing_count,
+                        COALESCE(SUM(CAST(kd.sfyj AS DECIMAL(18,2))), 0) as billing_amount
+                    FROM lq_kd_kdjlb kd
+                    WHERE kd.F_IsEffective = 1
+                        AND kd.kdrq >= @startTime
+                        AND kd.kdrq <= @endTime";
+
+                object billingParameters;
+                if (input.StoreIds != null && input.StoreIds.Any())
+                {
+                    billingSql += " AND kd.F_StoreId IN @storeIds";
+                    billingParameters = new { startTime, endTime, storeIds = input.StoreIds };
+                }
+                else
+                {
+                    billingParameters = new { startTime, endTime };
+                }
+
+                var billingResult = await _db.Ado.SqlQueryAsync<dynamic>(billingSql, billingParameters);
+                var billingCount = Convert.ToInt32(billingResult?.FirstOrDefault()?.billing_count ?? 0);
+                var billingAmount = Convert.ToDecimal(billingResult?.FirstOrDefault()?.billing_amount ?? 0m);
+
+                // 第二步：获取耗卡统计数据
+                var consumeSql = @"
+                    SELECT 
+                        COUNT(DISTINCT xh.hy) as consume_count,
+                        COALESCE(SUM(CAST(xh.xfje AS DECIMAL(18,2))), 0) as consume_amount
+                    FROM lq_xh_hyhk xh
+                    WHERE xh.F_IsEffective = 1
+                        AND xh.hksj >= @startTime
+                        AND xh.hksj <= @endTime";
+
+                object consumeParameters;
+                if (input.StoreIds != null && input.StoreIds.Any())
+                {
+                    consumeSql += " AND xh.F_StoreId IN @storeIds";
+                    consumeParameters = new { startTime, endTime, storeIds = input.StoreIds };
+                }
+                else
+                {
+                    consumeParameters = new { startTime, endTime };
+                }
+
+                var consumeResult = await _db.Ado.SqlQueryAsync<dynamic>(consumeSql, consumeParameters);
+                var consumeCount = Convert.ToInt32(consumeResult?.FirstOrDefault()?.consume_count ?? 0);
+                var consumeAmount = Convert.ToDecimal(consumeResult?.FirstOrDefault()?.consume_amount ?? 0m);
+
+                // 第三步：获取退卡统计数据
+                var refundSql = @"
+                    SELECT 
+                        COUNT(DISTINCT hytk.hy) as refund_count,
+                        COALESCE(SUM(CAST(hytk.tkje AS DECIMAL(18,2))), 0) as refund_amount
+                    FROM lq_hytk_hytk hytk
+                    WHERE hytk.F_IsEffective = 1
+                        AND hytk.tksj >= @startTime
+                        AND hytk.tksj <= @endTime";
+
+                object refundParameters;
+                if (input.StoreIds != null && input.StoreIds.Any())
+                {
+                    refundSql += " AND hytk.F_StoreId IN @storeIds";
+                    refundParameters = new { startTime, endTime, storeIds = input.StoreIds };
+                }
+                else
+                {
+                    refundParameters = new { startTime, endTime };
+                }
+
+                var refundResult = await _db.Ado.SqlQueryAsync<dynamic>(refundSql, refundParameters);
+                var refundCount = Convert.ToInt32(refundResult?.FirstOrDefault()?.refund_count ?? 0);
+                var refundAmount = Convert.ToDecimal(refundResult?.FirstOrDefault()?.refund_amount ?? 0m);
+
+                var result = new BusinessStatisticsOutput
+                {
+                    TotalBillingAmount = billingAmount,
+                    TotalConsumeAmount = consumeAmount,
+                    TotalRefundAmount = refundAmount,
+                    BillingCount = billingCount,
+                    ConsumeCount = consumeCount,
+                    RefundCount = refundCount
+                };
+
+                return result;
+            }
+            catch (Exception ex)
+            {
+                _logger.LogError(ex, $"获取业务统计数据失败 - 开始时间: {input?.StartTime}, 结束时间: {input?.EndTime}");
+                throw NCCException.Oh($"获取业务统计数据失败: {ex.Message}");
+            }
+        }
+
+        /// <summary>
+        /// 获取客户类型统计数据
+        /// </summary>
+        /// <remarks>
+        /// 统计指定时间范围内不同类型的客户数量和转化率
+        /// 包括：线索、新客、散客、会员数量，以及拓客人数、消耗人数、转化率
+        /// 
+        /// 示例请求：
+        /// ```json
+        /// {
+        ///   "startTime": "2025-10-01",
+        ///   "endTime": "2025-10-31",
+        ///   "storeIds": ["门店ID1", "门店ID2"]
+        /// }
+        /// ```
+        /// 
+        /// 参数说明：
+        /// - startTime: 开始时间（可选，默认为当月1号）
+        /// - endTime: 结束时间（可选，默认为当前时间）
+        /// - storeIds: 门店ID列表（可选）
+        /// 
+        /// 返回字段说明：
+        /// - LeadCount: 线索客户数量
+        /// - NewCustomerCount: 新客数量
+        /// - CasualCustomerCount: 散客数量
+        /// - MemberCount: 会员数量
+        /// - TotalInviteCount: 拓客总人数
+        /// - ConsumeCount: 消耗人数（有消耗金额的）
+        /// - ConversionRate: 转化率（消耗人数/拓客人数）
+        /// </remarks>
+        /// <param name="input">查询参数</param>
+        /// <returns>客户类型统计数据</returns>
+        /// <response code="200">成功返回统计数据</response>
+        /// <response code="400">参数错误</response>
+        /// <response code="500">服务器错误</response>
+        [HttpPost("get-customer-type-statistics")]
+        public async Task<object> GetCustomerTypeStatistics(CustomerTypeStatisticsInput input)
+        {
+            try
+            {
+                // 设置默认时间范围（如果未提供，默认为当月）
+                var startTime = input.StartTime ?? new DateTime(DateTime.Now.Year, DateTime.Now.Month, 1);
+                var endTime = input.EndTime ?? DateTime.Now;
+
+                // 第一步：获取客户类型统计
+                var customerTypeSql = $@"
+                    SELECT 
+                        SUM(CASE WHEN kh.khlx = '{MemberTypeEnum.线索.GetHashCode()}' THEN 1 ELSE 0 END) as lead_count,
+                        SUM(CASE WHEN kh.khlx = '{MemberTypeEnum.新客.GetHashCode()}' THEN 1 ELSE 0 END) as new_customer_count,
+                        SUM(CASE WHEN kh.khlx = '{MemberTypeEnum.散客.GetHashCode()}' THEN 1 ELSE 0 END) as casual_customer_count,
+                        SUM(CASE WHEN kh.khlx = '{MemberTypeEnum.会员.GetHashCode()}' THEN 1 ELSE 0 END) as member_count
+                    FROM lq_khxx kh
+                    WHERE kh.F_CreateTime >= @startTime
+                        AND kh.F_CreateTime <= @endTime";
+
+                object customerTypeParameters;
+                if (input.StoreIds != null && input.StoreIds.Any())
+                {
+                    customerTypeSql += " AND kh.F_StoreId IN @storeIds";
+                    customerTypeParameters = new { startTime, endTime, storeIds = input.StoreIds };
+                }
+                else
+                {
+                    customerTypeParameters = new { startTime, endTime };
+                }
+
+                var customerTypeResult = await _db.Ado.SqlQueryAsync<dynamic>(customerTypeSql, customerTypeParameters);
+                var leadCount = Convert.ToInt32(customerTypeResult?.FirstOrDefault()?.lead_count ?? 0);
+                var newCustomerCount = Convert.ToInt32(customerTypeResult?.FirstOrDefault()?.new_customer_count ?? 0);
+                var casualCustomerCount = Convert.ToInt32(customerTypeResult?.FirstOrDefault()?.casual_customer_count ?? 0);
+                var memberCount = Convert.ToInt32(customerTypeResult?.FirstOrDefault()?.member_count ?? 0);
+
+                // 第二步：获取拓客总人数（按客户去重）
+                var inviteSql = @"
+                    SELECT COUNT(DISTINCT tk.F_MemberId) as invite_count
+                    FROM lq_tkjlb tk
+                    WHERE tk.F_CreateTime >= @startTime
+                        AND tk.F_CreateTime <= @endTime";
+
+                object inviteParameters;
+                if (input.StoreIds != null && input.StoreIds.Any())
+                {
+                    inviteSql += " AND tk.F_StoreId IN @storeIds";
+                    inviteParameters = new { startTime, endTime, storeIds = input.StoreIds };
+                }
+                else
+                {
+                    inviteParameters = new { startTime, endTime };
+                }
+
+                var inviteResult = await _db.Ado.SqlQueryAsync<dynamic>(inviteSql, inviteParameters);
+                var totalInviteCount = Convert.ToInt32(inviteResult?.FirstOrDefault()?.invite_count ?? 0);
+
+                // 第三步：获取消耗人数（有消耗金额的，按客户去重）
+                var consumeSql = @"
+                    SELECT COUNT(DISTINCT xh.hy) as consume_count
+                    FROM lq_xh_hyhk xh
+                    WHERE xh.F_IsEffective = 1
+                        AND xh.hksj >= @startTime
+                        AND xh.hksj <= @endTime
+                        AND xh.xfje > 0";
+
+                object consumeParameters;
+                if (input.StoreIds != null && input.StoreIds.Any())
+                {
+                    consumeSql += " AND xh.F_StoreId IN @storeIds";
+                    consumeParameters = new { startTime, endTime, storeIds = input.StoreIds };
+                }
+                else
+                {
+                    consumeParameters = new { startTime, endTime };
+                }
+
+                var consumeResult = await _db.Ado.SqlQueryAsync<dynamic>(consumeSql, consumeParameters);
+                var consumeCount = Convert.ToInt32(consumeResult?.FirstOrDefault()?.consume_count ?? 0);
+
+                // 计算转化率
+                var conversionRate = totalInviteCount > 0 ? Math.Round(consumeCount * 100.0m / totalInviteCount, 2) : 0;
+
+                var result = new CustomerTypeStatisticsOutput
+                {
+                    LeadCount = leadCount,
+                    NewCustomerCount = newCustomerCount,
+                    CasualCustomerCount = casualCustomerCount,
+                    MemberCount = memberCount,
+                    TotalInviteCount = totalInviteCount,
+                    ConsumeCount = consumeCount,
+                    ConversionRate = conversionRate
+                };
+
+                return result;
+            }
+            catch (Exception ex)
+            {
+                _logger.LogError(ex, $"获取客户类型统计数据失败 - 开始时间: {input?.StartTime}, 结束时间: {input?.EndTime}");
+                throw NCCException.Oh($"获取客户类型统计数据失败: {ex.Message}");
+            }
+        }
+
+        /// <summary>
+        /// 获取门店业绩对比统计数据
+        /// </summary>
+        /// <remarks>
+        /// 统计指定时间范围内各门店的开单业绩与目标业绩的对比情况
+        /// 包括：目标业绩、实际开单业绩、完成率、差额、是否达标
+        /// 
+        /// 示例请求：
+        /// ```json
+        /// {
+        ///   "startTime": "2025-10-01",
+        ///   "endTime": "2025-10-31",
+        ///   "storeIds": ["门店ID1", "门店ID2"]
+        /// }
+        /// ```
+        /// 
+        /// 参数说明：
+        /// - startTime: 开始时间（可选，默认为当月1号）
+        /// - endTime: 结束时间（可选，默认为当前时间）
+        /// - storeIds: 门店ID列表（可选）
+        /// 
+        /// 返回字段说明：
+        /// - StoreId: 门店ID
+        /// - StoreName: 门店名称
+        /// - TargetPerformance: 目标业绩（来自门店资料表xsyj字段）
+        /// - ActualPerformance: 实际开单业绩（统计期间内的开单业绩总和）
+        /// - CompletionRate: 完成率（实际业绩/目标业绩 × 100%）
+        /// - Difference: 差额（实际业绩-目标业绩）
+        /// - IsTargetAchieved: 是否达标（实际业绩 >= 目标业绩）
+        /// </remarks>
+        /// <param name="input">查询参数</param>
+        /// <returns>门店业绩对比统计数据</returns>
+        /// <response code="200">成功返回统计数据</response>
+        /// <response code="400">参数错误</response>
+        /// <response code="500">服务器错误</response>
+        [HttpPost("get-store-performance-comparison")]
+        public async Task<object> GetStorePerformanceComparison(StorePerformanceComparisonInput input)
+        {
+            try
+            {
+                // 设置默认时间范围（如果未提供，默认为当月）
+                var startTime = input.StartTime ?? new DateTime(DateTime.Now.Year, DateTime.Now.Month, 1);
+                var endTime = input.EndTime ?? DateTime.Now;
+
+                // 构建SQL查询
+                var sql = @"
+                    SELECT 
+                        md.F_Id as store_id,
+                        md.dm as store_name,
+                        COALESCE(CAST(md.xsyj AS DECIMAL(18,2)), 0) as target_performance,
+                        COALESCE(SUM(CAST(kd.sfyj AS DECIMAL(18,2))), 0) as actual_performance
+                    FROM lq_mdxx md
+                    LEFT JOIN lq_kd_kdjlb kd ON md.F_Id = kd.djmd 
+                        AND kd.F_IsEffective = 1
+                        AND kd.kdrq >= @startTime
+                        AND kd.kdrq <= @endTime";
+
+                object parameters;
+                if (input.StoreIds != null && input.StoreIds.Any())
+                {
+                    sql += " AND md.F_Id IN @storeIds";
+                    parameters = new { startTime, endTime, storeIds = input.StoreIds };
+                }
+                else
+                {
+                    parameters = new { startTime, endTime };
+                }
+
+                sql += " GROUP BY md.F_Id, md.dm, md.xsyj ORDER BY actual_performance DESC";
+
+                var results = await _db.Ado.SqlQueryAsync<dynamic>(sql, parameters);
+
+                var storePerformanceList = new List<StorePerformanceComparisonOutput>();
+
+                foreach (var item in results)
+                {
+                    var storeId = item.store_id?.ToString();
+                    var storeName = item.store_name?.ToString();
+                    var targetPerformance = Convert.ToDecimal(item.target_performance ?? 0);
+                    var actualPerformance = Convert.ToDecimal(item.actual_performance ?? 0);
+
+                    // 计算完成率
+                    var completionRate = targetPerformance > 0
+                        ? Math.Round(actualPerformance * 100.0m / targetPerformance, 2)
+                        : 0;
+
+                    // 计算差额
+                    var difference = actualPerformance - targetPerformance;
+
+                    // 判断是否达标
+                    var isTargetAchieved = actualPerformance >= targetPerformance;
+
+                    storePerformanceList.Add(new StorePerformanceComparisonOutput
+                    {
+                        StoreId = storeId,
+                        StoreName = storeName,
+                        TargetPerformance = targetPerformance,
+                        ActualPerformance = actualPerformance,
+                        CompletionRate = completionRate,
+                        Difference = difference,
+                        IsTargetAchieved = isTargetAchieved
+                    });
+                }
+
+                return storePerformanceList;
+            }
+            catch (Exception ex)
+            {
+                _logger.LogError(ex, $"获取门店业绩对比统计数据失败 - 开始时间: {input?.StartTime}, 结束时间: {input?.EndTime}");
+                throw NCCException.Oh($"获取门店业绩对比统计数据失败: {ex.Message}");
+            }
+        }
+
+        /// <summary>
+        /// 获取品项统计数据
+        /// </summary>
+        /// <remarks>
+        /// 统计指定时间范围内各品项的开单、消耗、退卡相关数据
+        /// 包括：开单数量、开单金额、消耗数量、消耗金额、退卡数量、退卡金额
+        /// 
+        /// 示例请求：
+        /// ```json
+        /// {
+        ///   "startTime": "2025-10-01",
+        ///   "endTime": "2025-10-31",
+        ///   "storeIds": ["门店ID1", "门店ID2"]
+        /// }
+        /// ```
+        /// 
+        /// 参数说明：
+        /// - startTime: 开始时间（可选，默认为当月1号）
+        /// - endTime: 结束时间（可选，默认为当前时间）
+        /// - storeIds: 门店ID列表（可选）
+        /// 
+        /// 返回字段说明：
+        /// - ItemId: 品项ID
+        /// - ItemName: 品项名称
+        /// - ItemNumber: 品项编号
+        /// - BillingCount: 开单数量
+        /// - BillingAmount: 开单金额
+        /// - ConsumeCount: 消耗数量
+        /// - ConsumeAmount: 消耗金额
+        /// - RefundCount: 退卡数量
+        /// - RefundAmount: 退卡金额
+        /// </remarks>
+        /// <param name="input">查询参数</param>
+        /// <returns>品项统计数据列表（按开单金额降序排列）</returns>
+        /// <response code="200">成功返回统计数据</response>
+        /// <response code="400">参数错误</response>
+        /// <response code="500">服务器错误</response>
+        [HttpPost("get-item-statistics")]
+        public async Task<object> GetItemStatistics(ItemStatisticsInput input)
+        {
+            try
+            {
+                // 设置默认时间范围（如果未提供，默认为当月）
+                var startTime = input.StartTime ?? new DateTime(DateTime.Now.Year, DateTime.Now.Month, 1);
+                var endTime = input.EndTime ?? DateTime.Now;
+
+                // 构建SQL查询
+                var sql = @"
+                    SELECT 
+                        xm.F_Id as item_id,
+                        xm.xmmc as item_name,
+                        xm.xmbh as item_number,
+                        
+                        -- 开单统计
+                        COALESCE(SUM(CASE WHEN px.F_IsEffective = 1 AND px.yjsj >= @startTime AND px.yjsj <= @endTime THEN px.F_ProjectNumber ELSE 0 END), 0) as billing_count,
+                        COALESCE(SUM(CASE WHEN px.F_IsEffective = 1 AND px.yjsj >= @startTime AND px.yjsj <= @endTime THEN CAST(px.F_ActualPrice AS DECIMAL(18,2)) ELSE 0 END), 0) as billing_amount,
+                        
+                        -- 消耗统计
+                        COALESCE(SUM(CASE WHEN xh.F_IsEffective = 1 AND xhhyhk.hksj >= @startTime AND xhhyhk.hksj <= @endTime THEN xh.F_ProjectNumber ELSE 0 END), 0) as consume_count,
+                        COALESCE(SUM(CASE WHEN xh.F_IsEffective = 1 AND xhhyhk.hksj >= @startTime AND xhhyhk.hksj <= @endTime THEN CAST(xh.F_TotalPrice AS DECIMAL(18,2)) ELSE 0 END), 0) as consume_amount,
+                        
+                        -- 退卡统计
+                        COALESCE(SUM(CASE WHEN hytkmx.F_IsEffective = 1 AND hytkmx.tksj >= @startTime AND hytkmx.tksj <= @endTime THEN hytkmx.F_ProjectNumber ELSE 0 END), 0) as refund_count,
+                        COALESCE(SUM(CASE WHEN hytkmx.F_IsEffective = 1 AND hytkmx.tksj >= @startTime AND hytkmx.tksj <= @endTime THEN CAST(hytkmx.tkje AS DECIMAL(18,2)) ELSE 0 END), 0) as refund_amount
+                        
+                    FROM lq_xmzl xm
+                    
+                    -- 开单品项明细
+                    LEFT JOIN lq_kd_pxmx px ON xm.F_Id = px.px
+                    
+                    -- 消耗品项明细
+                    LEFT JOIN lq_xh_pxmx xh ON xm.F_Id = xh.px
+                    LEFT JOIN lq_xh_hyhk xhhyhk ON xh.F_ConsumeInfoId = xhhyhk.F_Id
+                    
+                    -- 退卡品项明细
+                    LEFT JOIN lq_hytk_mx hytkmx ON xm.F_Id = hytkmx.px
+                    
+                    WHERE xm.F_IsEffective = 1";
+
+                object parameters;
+                if (input.StoreIds != null && input.StoreIds.Any())
+                {
+                    sql += @" AND (
+                        (px.glkdbh IN (SELECT F_Id FROM lq_kd_kdjlb WHERE djmd IN @storeIds)) OR 
+                        (xhhyhk.F_StoreId IN @storeIds) OR 
+                        (hytkmx.F_RefundInfoId IN (SELECT F_Id FROM lq_hytk_hytk WHERE F_StoreId IN @storeIds))
+                    )";
+                    parameters = new { startTime, endTime, storeIds = input.StoreIds };
+                }
+                else
+                {
+                    parameters = new { startTime, endTime };
+                }
+
+                sql += @" GROUP BY xm.F_Id, xm.xmmc, xm.xmbh
+                    HAVING (billing_count > 0 OR consume_count > 0 OR refund_count > 0)
+                    ORDER BY billing_amount DESC";
+
+                var results = await _db.Ado.SqlQueryAsync<dynamic>(sql, parameters);
+
+                var itemStatisticsList = new List<ItemStatisticsOutput>();
+
+                foreach (var item in results)
+                {
+                    itemStatisticsList.Add(new ItemStatisticsOutput
+                    {
+                        ItemId = item.item_id?.ToString(),
+                        ItemName = item.item_name?.ToString(),
+                        ItemNumber = item.item_number?.ToString(),
+                        BillingCount = Convert.ToInt32(item.billing_count ?? 0),
+                        BillingAmount = Convert.ToDecimal(item.billing_amount ?? 0),
+                        ConsumeCount = Convert.ToInt32(item.consume_count ?? 0),
+                        ConsumeAmount = Convert.ToDecimal(item.consume_amount ?? 0),
+                        RefundCount = Convert.ToInt32(item.refund_count ?? 0),
+                        RefundAmount = Convert.ToDecimal(item.refund_amount ?? 0)
+                    });
+                }
+
+                return itemStatisticsList;
+            }
+            catch (Exception ex)
+            {
+                _logger.LogError(ex, $"获取品项统计数据失败 - 开始时间: {input?.StartTime}, 结束时间: {input?.EndTime}");
+                throw NCCException.Oh($"获取品项统计数据失败: {ex.Message}");
+            }
+        }
+
         #endregion
     }
 }
@@ -609,49 +609,83 @@ namespace NCC.Extend.LqTkjlb
         {
             try
             {
-                var sql = @"
+                // 第一步：获取拓客总数
+                var tkSql = @"
+                    SELECT COUNT(DISTINCT F_Id) as tk_count
+                    FROM lq_tkjlb 
+                    WHERE F_EventId = @eventId";
+
+                var tkResult = await _db.Ado.SqlQueryAsync<dynamic>(tkSql, new { eventId });
+                var tkCount = tkResult?.FirstOrDefault()?.tk_count ?? 0;
+
+                // 第二步：获取邀约总数（按会员ID去重）
+                var yaoySql = @"
+                    SELECT COUNT(DISTINCT tk.F_MemberId) as yaoy_count
+                    FROM lq_tkjlb tk
+                    LEFT JOIN lq_yaoyjl yy ON tk.F_MemberId = yy.yykh AND yy.F_StoreId = tk.F_StoreId
+                    WHERE tk.F_EventId = @eventId AND yy.F_Id IS NOT NULL";
+
+                var yaoyResult = await _db.Ado.SqlQueryAsync<dynamic>(yaoySql, new { eventId });
+                var yaoyCount = yaoyResult?.FirstOrDefault()?.yaoy_count ?? 0;
+
+                // 第三步：获取预约总数（按会员ID去重）
+                var yySql = @"
+                    SELECT COUNT(DISTINCT tk.F_MemberId) as yy_count
+                    FROM lq_tkjlb tk
+                    LEFT JOIN lq_yyjl yyjl ON tk.F_MemberId = yyjl.gk AND yyjl.F_Status = '已确认'
+                    WHERE tk.F_EventId = @eventId AND yyjl.F_Id IS NOT NULL";
+
+                var yyResult = await _db.Ado.SqlQueryAsync<dynamic>(yySql, new { eventId });
+                var yyCount = yyResult?.FirstOrDefault()?.yy_count ?? 0;
+
+                // 第四步：获取耗卡总数和金额（按会员ID去重，但金额不去重）
+                var hkSql = @"
                     SELECT 
-                        SUM(tk_count) as total_tk_count,
-                        SUM(yaoy_count) as total_yaoy_count,
-                        SUM(yy_count) as total_yy_count,
-                        SUM(hk_count) as total_hk_count,
-                        SUM(kd_count) as total_kd_count,
-                        SUM(hk_amount) as total_hk_amount,
-                        SUM(kd_amount) as total_kd_amount,
-                        CASE 
-                            WHEN SUM(tk_count) > 0 
-                            THEN ROUND(SUM(yy_count) * 100.0 / SUM(tk_count), 2)
-                            ELSE 0 
-                        END as overall_yy_conversion_rate,
-                        CASE 
-                            WHEN SUM(yy_count) > 0 
-                            THEN ROUND(SUM(hk_count) * 100.0 / SUM(yy_count), 2)
-                            ELSE 0 
-                        END as overall_hk_conversion_rate
-                    FROM (
-                        SELECT 
-                            COUNT(DISTINCT tk.F_Id) as tk_count,
-                            COUNT(DISTINCT yy.F_Id) as yaoy_count,
-                            COUNT(DISTINCT yyjl.F_Id) as yy_count,
-                            COUNT(DISTINCT xh.F_Id) as hk_count,
-                            COUNT(DISTINCT kd.F_Id) as kd_count,
-                            COALESCE(SUM(xh.xfje), 0) as hk_amount,
-                            COALESCE(SUM(kd.sfyj), 0) as kd_amount
-                        FROM lq_tkjlb tk
-                        LEFT JOIN lq_yaoyjl yy ON tk.F_MemberId = yy.yykh AND yy.F_StoreId = tk.F_StoreId
-                        LEFT JOIN lq_yyjl yyjl ON tk.F_MemberId = yyjl.gk AND yyjl.F_Status = '已确认'
-                        LEFT JOIN lq_xh_hyhk xh ON tk.F_MemberId = xh.hy AND xh.F_IsEffective = 1
-                        LEFT JOIN lq_kd_kdjlb kd ON tk.F_MemberId = kd.kdhy AND kd.F_IsEffective = 1
-                        WHERE tk.F_EventId = @eventId
-                    ) stats";
+                        COUNT(DISTINCT tk.F_MemberId) as hk_count,
+                        COALESCE(SUM(xh.xfje), 0) as hk_amount
+                    FROM lq_tkjlb tk
+                    LEFT JOIN lq_xh_hyhk xh ON tk.F_MemberId = xh.hy AND xh.F_IsEffective = 1
+                    WHERE tk.F_EventId = @eventId AND xh.F_Id IS NOT NULL";
-                var result = await _db.Ado.SqlQueryAsync<dynamic>(sql, new { eventId });
+                var hkResult = await _db.Ado.SqlQueryAsync<dynamic>(hkSql, new { eventId });
+                var hkCount = hkResult?.FirstOrDefault()?.hk_count ?? 0;
+                var hkAmount = hkResult?.FirstOrDefault()?.hk_amount ?? 0m;
+
+                // 第五步：获取开单总数和金额（按会员ID去重，但金额不去重）
+                var kdSql = @"
+                    SELECT 
+                        COUNT(DISTINCT tk.F_MemberId) as kd_count,
+                        COALESCE(SUM(kd.sfyj), 0) as kd_amount
+                    FROM lq_tkjlb tk
+                    LEFT JOIN lq_kd_kdjlb kd ON tk.F_MemberId = kd.kdhy AND kd.F_IsEffective = 1
+                    WHERE tk.F_EventId = @eventId AND kd.F_Id IS NOT NULL";
+
+                var kdResult = await _db.Ado.SqlQueryAsync<dynamic>(kdSql, new { eventId });
+                var kdCount = kdResult?.FirstOrDefault()?.kd_count ?? 0;
+                var kdAmount = kdResult?.FirstOrDefault()?.kd_amount ?? 0m;
+
+                // 计算转化率
+                var yyConversionRate = tkCount > 0 ? Math.Round(yyCount * 100.0 / tkCount, 2) : 0;
+                var hkConversionRate = yyCount > 0 ? Math.Round(hkCount * 100.0 / yyCount, 2) : 0;
+
+                var result = new
+                {
+                    total_tk_count = tkCount,
+                    total_yaoy_count = yaoyCount,
+                    total_yy_count = yyCount,
+                    total_hk_count = hkCount,
+                    total_kd_count = kdCount,
+                    total_hk_amount = hkAmount,
+                    total_kd_amount = kdAmount,
+                    overall_yy_conversion_rate = yyConversionRate,
+                    overall_hk_conversion_rate = hkConversionRate
+                };
                 return new
                 {
                     success = true,
-                    data = result?.FirstOrDefault(),
-                    message = "获取总体漏斗统计数据成功"
+                    data = result,
+                    message = "获取总体漏斗统计数据成功（高性能版本）"
                 };
             }
             catch (Exception ex)