Merge branch 'master' of http://39.98.150.180/antissoft/lvqianmeiye_ERP

李宇
2 parents 5b6e99a5 7855bf04
Showing 28 changed files with 1703 additions and 65 deletions
antis-ncc-admin/src/views/lqInventory/InventoryInfoDialog.vue
antis-ncc-admin/src/views/personalPerformanceStatistics/index.vue
antis-ncc-admin/src/views/storeTotalPerformanceStatistics/index.vue
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/LqMdxx/LqMdxxInfoOutput.cs
netcore/src/Modularity/Extend/NCC.Extend.Entitys/Dto/LqMdxx/LqMdxxListOutput.cs
netcore/src/Modularity/Extend/NCC.Extend.Entitys/Dto/LqPackageInfo/ActivityStatisticsInput.cs
netcore/src/Modularity/Extend/NCC.Extend.Entitys/Dto/LqPackageInfo/ActivityStatisticsOutput.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.Entitys/Dto/LqStatistics/LqStoreTotalPerformanceStatisticsListOutput.cs
netcore/src/Modularity/Extend/NCC.Extend.Entitys/Dto/LqStatisticsPersonalPerformance/LqStatisticsPersonalPerformanceListOutput.cs
netcore/src/Modularity/Extend/NCC.Extend.Entitys/Dto/LqStatisticsStoreTotalPerformance/LqStatisticsStoreTotalPerformanceListOutput.cs
@@ -191,4 +191,3 @@ export default {
     text-align: right;
 }
 </style>
-
@@ -50,7 +50,7 @@
                     <el-table-column prop="EmployeeName" label="员工姓名" width="120" fixed="left"></el-table-column>
                     <el-table-column prop="StoreName" label="门店名称" width="150" fixed="left"></el-table-column>
                     <el-table-column prop="Position" label="岗位" width="100" fixed="left"></el-table-column>
-                    <el-table-column prop="GoldTriangleTeam" label="金三角战队" width="120" fixed="left"></el-table-column>
+                    <el-table-column prop="GoldTriangleName" label="金三角战队" width="120" fixed="left"></el-table-column>
                     <el-table-column prop="TotalPerformance" label="总业绩" width="100" align="right">
                         <template slot-scope="scope">
                             {{ formatMoney(scope.row.TotalPerformance) }}
@@ -66,6 +66,22 @@
                             {{ formatMoney(scope.row.UpgradeOrderPerformance) }}
                         </template>
                     </el-table-column>
+                    <el-table-column prop="RefundPerformance" label="退单业绩" width="100" align="right">
+                        <template slot-scope="scope">
+                            <span style="color: #F56C6C;">{{ formatMoney(scope.row.RefundPerformance) }}</span>
+                        </template>
+                    </el-table-column>
+                    <el-table-column prop="RefundCount" label="退单次数" width="100" align="right">
+                        <template slot-scope="scope">
+                            <span style="color: #F56C6C;">{{ scope.row.RefundCount || 0 }}</span>
+                        </template>
+                    </el-table-column>
+                    <el-table-column prop="ActualPerformance" label="实际业绩" width="100" align="right">
+                        <template slot-scope="scope">
+                            <span style="color: #67C23A; font-weight: bold;">{{ formatMoney(scope.row.ActualPerformance)
+                            }}</span>
+                        </template>
+                    </el-table-column>
                     <el-table-column prop="FirstOrderCount" label="首开单数量" width="100" align="right"></el-table-column>
                     <el-table-column prop="UpgradeOrderCount" label="升单数量" width="100" align="right"></el-table-column>
                     <el-table-column prop="OrderCount" label="订单总数" width="100" align="right"></el-table-column>
@@ -81,6 +81,12 @@
                             <span style="color: #F56C6C;">{{ scope.row.RefundCount || 0 }}</span>
                         </template>
                     </el-table-column>
+                    <el-table-column prop="ActualPerformance" label="实际业绩" width="120" align="right">
+                        <template slot-scope="scope">
+                            <span style="color: #67C23A; font-weight: bold;">{{ formatMoney(scope.row.ActualPerformance)
+                                }}</span>
+                        </template>
+                    </el-table-column>
                     <el-table-column prop="CreateTime" label="创建时间" width="150" align="center">
                         <template slot-scope="scope">
                             {{ formatDateTime(scope.row.CreateTime) }}
+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; }
+    }
+}
@@ -123,21 +123,21 @@ namespace NCC.Extend.Entitys.Dto.LqMdxx
         /// <summary>
         /// 门店类别
         /// </summary>
-        public int? StoreCategory { get; set; }
+        public int? storeCategory { get; set; }
         /// <summary>
         /// 门店类别名称
         /// </summary>
-        public string StoreCategoryName => StoreCategory.HasValue ? EnumHelper.GetEnumDesc<StoreCategoryEnum>(StoreCategory.Value) : string.Empty;
+        public string storeCategoryName => storeCategory.HasValue ? EnumHelper.GetEnumDesc<StoreCategoryEnum>(storeCategory.Value) : string.Empty;
         /// <summary>
         /// 门店类型
         /// </summary>
-        public int? StoreType { get; set; }
+        public int? storeType { get; set; }
         /// <summary>
         /// 门店类型名称
         /// </summary>
-        public string StoreTypeName => StoreType.HasValue ? EnumHelper.GetEnumDesc<StoreTypeEnum>(StoreType.Value) : string.Empty;
+        public string storeTypeName => storeType.HasValue ? EnumHelper.GetEnumDesc<StoreTypeEnum>(storeType.Value) : string.Empty;
     }
 }
@@ -152,21 +152,21 @@ namespace NCC.Extend.Entitys.Dto.LqMdxx
         /// <summary>
         /// 门店类别
         /// </summary>
-        public int? StoreCategory { get; set; }
+        public int? storeCategory { get; set; }
         /// <summary>
         /// 门店类别名称
         /// </summary>
-        public string StoreCategoryName => StoreCategory.HasValue ? EnumHelper.GetEnumDesc<StoreCategoryEnum>(StoreCategory.Value) : string.Empty;
+        public string storeCategoryName => storeCategory.HasValue ? EnumHelper.GetEnumDesc<StoreCategoryEnum>(storeCategory.Value) : string.Empty;
         /// <summary>
         /// 门店类型
         /// </summary>
-        public int? StoreType { get; set; }
+        public int? storeType { get; set; }
         /// <summary>
         /// 门店类型名称
         /// </summary>
-        public string StoreTypeName => StoreType.HasValue ? EnumHelper.GetEnumDesc<StoreTypeEnum>(StoreType.Value) : string.Empty;
+        public string storeTypeName => storeType.HasValue ? EnumHelper.GetEnumDesc<StoreTypeEnum>(storeType.Value) : string.Empty;
     }
 }
+using System;
+using System.ComponentModel.DataAnnotations;
+
+namespace NCC.Extend.Entitys.Dto.LqPackageInfo
+{
+    /// <summary>
+    /// 营销活动统计查询输入参数
+    /// </summary>
+    public class ActivityStatisticsInput
+    {
+        /// <summary>
+        /// 营销活动ID
+        /// </summary>
+        [Required(ErrorMessage = "营销活动ID不能为空")]
+        public string ActivityId { get; set; }
+
+        /// <summary>
+        /// 开始时间（可选，默认为活动开始时间）
+        /// </summary>
+        public DateTime? StartTime { get; set; }
+
+        /// <summary>
+        /// 结束时间（可选，默认为活动结束时间）
+        /// </summary>
+        public DateTime? EndTime { get; set; }
+
+        /// <summary>
+        /// 门店ID列表（可选）
+        /// </summary>
+        public string[] StoreIds { get; set; }
+    }
+}
+using System;
+
+namespace NCC.Extend.Entitys.Dto.LqPackageInfo
+{
+    /// <summary>
+    /// 营销活动统计输出结果
+    /// </summary>
+    public class ActivityStatisticsOutput
+    {
+        /// <summary>
+        /// 营销活动ID
+        /// </summary>
+        public string ActivityId { get; set; }
+
+        /// <summary>
+        /// 营销活动名称
+        /// </summary>
+        public string ActivityName { get; set; }
+
+        /// <summary>
+        /// 开单数量
+        /// </summary>
+        public int BillingCount { get; set; }
+
+        /// <summary>
+        /// 开单金额
+        /// </summary>
+        public decimal BillingAmount { get; set; }
+
+        /// <summary>
+        /// 退卡数量
+        /// </summary>
+        public int RefundCount { get; set; }
+
+        /// <summary>
+        /// 退卡金额
+        /// </summary>
+        public decimal RefundAmount { get; set; }
+
+        /// <summary>
+        /// 净开单数量（开单数量 - 退卡数量）
+        /// </summary>
+        public int NetBillingCount { get; set; }
+
+        /// <summary>
+        /// 净开单金额（开单金额 - 退卡金额）
+        /// </summary>
+        public decimal NetBillingAmount { get; set; }
+
+        /// <summary>
+        /// 退卡率（退卡数量 / 开单数量）
+        /// </summary>
+        public decimal RefundRate { 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; }
+    }
+}
@@ -73,6 +73,11 @@ namespace NCC.Extend.Entitys.Dto.LqStatistics
         public int RefundCount { get; set; }
         /// <summary>
+        /// 实际业绩
+        /// </summary>
+        public decimal ActualPerformance { get; set; }
+
+        /// <summary>
         /// 创建时间
         /// </summary>
         public DateTime CreateTime { get; set; }
@@ -93,6 +93,21 @@ namespace NCC.Extend.Entitys.Dto.LqStatisticsPersonalPerformance
         public decimal UpgradeOrderPerformance { get; set; }
         /// <summary>
+        /// 退单业绩
+        /// </summary>
+        public decimal RefundPerformance { get; set; }
+
+        /// <summary>
+        /// 退单次数
+        /// </summary>
+        public int RefundCount { get; set; }
+
+        /// <summary>
+        /// 实际业绩
+        /// </summary>
+        public decimal ActualPerformance { get; set; }
+
+        /// <summary>
         /// 最后订单日期
         /// </summary>
         public DateTime? LastOrderDate { get; set; }
@@ -86,5 +86,10 @@ namespace NCC.Extend.Entitys.Dto.LqStatisticsStoreTotalPerformance
         /// 创建时间
         /// </summary>
         public DateTime? createTime { get; set; }
+
+        /// <summary>
+        /// 实际业绩
+        /// </summary>
+        public decimal actualPerformance { get; set; }
     }
 }
@@ -114,6 +114,24 @@ namespace NCC.Extend.Entitys.lq_statistics_personal_performance
         public decimal UpgradeOrderPerformance { get; set; }
         /// <summary>
+        /// 退单业绩
+        /// </summary>
+        [SugarColumn(ColumnName = "F_RefundPerformance")]
+        public decimal RefundPerformance { get; set; }
+
+        /// <summary>
+        /// 退单次数
+        /// </summary>
+        [SugarColumn(ColumnName = "F_RefundCount")]
+        public int RefundCount { get; set; }
+
+        /// <summary>
+        /// 实际业绩
+        /// </summary>
+        [SugarColumn(ColumnName = "F_ActualPerformance")]
+        public decimal ActualPerformance { get; set; }
+
+        /// <summary>
         /// 最后订单日期
         /// </summary>
         [SugarColumn(ColumnName = "F_LastOrderDate")]
@@ -102,6 +102,12 @@ namespace NCC.Extend.Entitys.lq_statistics_store_total_performance
         public int RefundCount { get; set; }
         /// <summary>
+        /// 实际业绩
+        /// </summary>
+        [SugarColumn(ColumnName = "F_ActualPerformance")]
+        public decimal ActualPerformance { get; set; }
+
+        /// <summary>
         /// 创建时间
         /// </summary>
         [SugarColumn(ColumnName = "F_CreateTime")]
@@ -1179,6 +1179,25 @@ namespace NCC.Extend.LqKdKdjlb
         }
         #endregion
+        #region 获取状态枚举内容（所有的状态通用）
+        /// <summary>
+        /// 获取状态枚举内容
+        /// </summary>
+        /// <returns>状态枚举列表</returns>
+        [HttpGet("status-enum")]
+        public List<EnumOutput> GetStatusEnum()
+        {
+            return Enum.GetValues<StatusEnum>()
+                .Select(e => new EnumOutput
+                {
+                    Value = (int)e,
+                    Name = e.ToString(),
+                    Description = e.GetDescription(),
+                })
+                .ToList();
+        }
+        #endregion
+
         #region 修改开单记录
         /// <summary>
         /// 修改开单记录
@@ -2486,7 +2505,7 @@ namespace NCC.Extend.LqKdKdjlb
                         {
                             Id = YitIdHelper.NextId().ToString(),
                             Gltkbh = refundId,
-                            Jks = jks.Jks,
+                            Jks = jks.Jkszh,
                             Jksxm = jks.Jksxm,
                             Jkszh = jks.Jkszh,
                             Jksyj = (totalItemDeduction / refundKdyjEntities.Count()),
@@ -2588,7 +2607,7 @@ namespace NCC.Extend.LqKdKdjlb
                         {
                             Id = YitIdHelper.NextId().ToString(),
                             Glkdbh = billingId,
-                            Jks = jks.Jks,
+                            Jks = jks.Jkszh,
                             Jksxm = jks.Jksxm,
                             Jkszh = jks.Jkszh,
                             Jksyj = jks.Jksyj.ToString(),
@@ -2710,6 +2729,229 @@ 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
     }
 }
@@ -24,6 +24,7 @@ using NCC.DataEncryption;
 using NCC.ClayObject;
 using NCC.Extend.Entitys.Enum;
 using NCC.Code;
+using NCC.Extend.Entitys.Dto.Common;
 namespace NCC.Extend.LqMdxx
 {
@@ -120,8 +121,8 @@ namespace NCC.Extend.LqMdxx
                     rt1 = it.Rt1,
                     rt2 = it.Rt2,
                     rc = it.Rc,
-                    StoreCategory = it.StoreCategory,
-                    StoreType = it.StoreType,
+                    storeCategory = it.StoreCategory,
+                    storeType = it.StoreType,
                 }).MergeTable().OrderBy(sidx + " " + input.sort).ToPagedListAsync(input.currentPage, input.pageSize);
             return PageResult<LqMdxxListOutput>.SqlSugarPageResult(data);
         }
@@ -191,8 +192,21 @@ namespace NCC.Extend.LqMdxx
                     gsmc = it.Gsmc,
                     fr = it.Fr,
                     ywsb = it.Ywsb,
-                    StoreCategory = it.StoreCategory,
-                    StoreType = it.StoreType,
+                    jyb = it.Jyb,
+                    kjb = it.Kjb,
+                    dxmb = it.Dxmb,
+                    syb = it.Syb,
+                    gsqssj = it.Gsqssj,
+                    gszzsj = it.Gszzsj,
+                    status = it.Status,
+                    xsyj = it.Xsyj,
+                    xhyj = it.Xhyj,
+                    xms = it.Xms,
+                    rt1 = it.Rt1,
+                    rt2 = it.Rt2,
+                    rc = it.Rc,
+                    storeCategory = it.StoreCategory,
+                    storeType = it.StoreType,
                 }).MergeTable().OrderBy(sidx + " " + input.sort).ToListAsync();
             return data;
         }
@@ -359,11 +373,14 @@ namespace NCC.Extend.LqMdxx
         /// </summary>
         /// <returns></returns>
         [HttpGet("Selector/StoreCategory")]
-        public async Task<dynamic> GetStoreCategorySelector()
+        public List<EnumOutput> GetStoreCategorySelector()
         {
-            //从Enum中获取门店类别
-            var storeCategoryEnum = EnumExtensions.GetEnumDescDictionary(typeof(StoreCategoryEnum));
-            return new { list = storeCategoryEnum };
+            return Enum.GetValues<StoreCategoryEnum>().Select(e => new EnumOutput
+            {
+                Value = (int)e,
+                Name = e.ToString(),
+                Description = e.GetDescription(),
+            }).ToList();
         }
         #endregion
@@ -373,11 +390,18 @@ namespace NCC.Extend.LqMdxx
         /// </summary>
         /// <returns></returns>
         [HttpGet("Selector/StoreType")]
-        public async Task<dynamic> GetStoreTypeSelector()
+        public List<EnumOutput> GetStoreTypeSelector()
         {
             //从Enum中获取门店类型
-            var storeTypeEnum = EnumExtensions.GetEnumDescDictionary(typeof(StoreTypeEnum));
-            return new { list = storeTypeEnum };
+            var storeTypeEnum = Enum.GetValues<StoreTypeEnum>()
+                .Select(e => new EnumOutput
+                {
+                    Value = (int)e,
+                    Name = e.ToString(),
+                    Description = e.GetDescription(),
+                })
+                .ToList();
+            return storeTypeEnum;
         }
         #endregion
     }
@@ -551,5 +551,163 @@ namespace NCC.Extend.LqPackageInfo
             return output;
         }
         #endregion
+
+        #region 营销活动统计
+        /// <summary>
+        /// 获取营销活动统计数据
+        /// </summary>
+        /// <remarks>
+        /// 统计指定营销活动的开单、退卡相关数据
+        /// 包括：开单数量、开单金额、退卡数量、退卡金额、净开单数量、净开单金额、退卡率
+        /// 
+        /// 示例请求：
+        /// ```json
+        /// {
+        ///   "activityId": "营销活动ID",
+        ///   "startTime": "2025-10-01",
+        ///   "endTime": "2025-10-31",
+        ///   "storeIds": ["门店ID1", "门店ID2"]
+        /// }
+        /// ```
+        /// 
+        /// 参数说明：
+        /// - activityId: 营销活动ID（必填）
+        /// - startTime: 开始时间（可选，默认为活动开始时间）
+        /// - endTime: 结束时间（可选，默认为活动结束时间）
+        /// - storeIds: 门店ID列表（可选）
+        /// 
+        /// 返回字段说明：
+        /// - ActivityId: 营销活动ID
+        /// - ActivityName: 营销活动名称
+        /// - BillingCount: 开单数量
+        /// - BillingAmount: 开单金额
+        /// - RefundCount: 退卡数量
+        /// - RefundAmount: 退卡金额
+        /// - NetBillingCount: 净开单数量（开单数量 - 退卡数量）
+        /// - NetBillingAmount: 净开单金额（开单金额 - 退卡金额）
+        /// - RefundRate: 退卡率（退卡数量 / 开单数量）
+        /// </remarks>
+        /// <param name="input">查询参数</param>
+        /// <returns>营销活动统计数据</returns>
+        /// <response code="200">成功返回统计数据</response>
+        /// <response code="400">参数错误</response>
+        /// <response code="500">服务器错误</response>
+        [HttpPost("get-activity-statistics")]
+        public async Task<object> GetActivityStatistics(ActivityStatisticsInput input)
+        {
+            try
+            {
+                // 1. 获取营销活动信息
+                var activity = await _db.Queryable<LqPackageInfoEntity>()
+                    .Where(x => x.Id == input.ActivityId && x.IsEffective == StatusEnum.有效.GetHashCode())
+                    .FirstAsync();
+
+                if (activity == null)
+                {
+                    throw NCCException.Oh("营销活动不存在或已失效");
+                }
+
+                // 2. 设置时间范围（如果未提供，使用活动时间范围）
+                var startTime = input.StartTime ?? activity.StartTime;
+                var endTime = input.EndTime ?? activity.EndTime;
+
+                // 3. 获取营销活动关联的品项ID列表
+                var itemIds = await _db.Queryable<LqPackageItemDetailEntity>()
+                    .Where(x => x.ActivityId == input.ActivityId && x.IsEffective == StatusEnum.有效.GetHashCode())
+                    .Select(x => x.ItemId)
+                    .ToListAsync();
+
+                if (!itemIds.Any())
+                {
+                    return new ActivityStatisticsOutput
+                    {
+                        ActivityId = input.ActivityId,
+                        ActivityName = activity.ActivityName,
+                        BillingCount = 0,
+                        BillingAmount = 0,
+                        RefundCount = 0,
+                        RefundAmount = 0,
+                        NetBillingCount = 0,
+                        NetBillingAmount = 0,
+                        RefundRate = 0
+                    };
+                }
+
+                // 4. 构建品项ID过滤条件
+                var itemIdsStr = string.Join("','", itemIds);
+                var itemIdsFilter = $"AND px.px IN ('{itemIdsStr}')";
+                var itemIdsFilterRefund = $"AND hytkmx.px IN ('{itemIdsStr}')";
+
+                // 5. 构建门店过滤条件
+                string storeFilter = "";
+                string storeFilterRefund = "";
+
+                if (input.StoreIds != null && input.StoreIds.Any())
+                {
+                    var storeIdsStr = string.Join("','", input.StoreIds);
+                    storeFilter = $"AND kd.djmd IN ('{storeIdsStr}')";
+                    storeFilterRefund = $"AND hytk.md IN ('{storeIdsStr}')";
+                }
+
+                // 6. 开单统计
+                var billingSql = $@"
+                    SELECT 
+                        COUNT(DISTINCT kd.F_Id) as billing_count,
+                        SUM(CAST(px.F_ActualPrice AS DECIMAL(18,2))) as billing_amount
+                    FROM lq_kd_pxmx px
+                    LEFT JOIN lq_kd_kdjlb kd ON px.glkdbh = kd.F_Id
+                    WHERE px.F_IsEffective = 1 
+                        {itemIdsFilter}
+                        AND px.yjsj >= '{startTime:yyyy-MM-dd HH:mm:ss}' 
+                        AND px.yjsj <= '{endTime:yyyy-MM-dd HH:mm:ss}'
+                        {storeFilter}";
+
+                var billingData = await _db.Ado.SqlQueryAsync<dynamic>(billingSql);
+                var billingCount = Convert.ToInt32(billingData.FirstOrDefault()?.billing_count ?? 0);
+                var billingAmount = Convert.ToDecimal(billingData.FirstOrDefault()?.billing_amount ?? 0);
+
+                // 7. 退卡统计
+                var refundSql = $@"
+                    SELECT 
+                        COUNT(DISTINCT hytk.F_Id) as refund_count,
+                        SUM(CAST(hytkmx.tkje AS DECIMAL(18,2))) as refund_amount
+                    FROM lq_hytk_mx hytkmx
+                    LEFT JOIN lq_hytk_hytk hytk ON hytkmx.F_RefundInfoId = hytk.F_Id
+                    WHERE hytkmx.F_IsEffective = 1 
+                        {itemIdsFilterRefund}
+                        AND hytkmx.tksj >= '{startTime:yyyy-MM-dd HH:mm:ss}' 
+                        AND hytkmx.tksj <= '{endTime:yyyy-MM-dd HH:mm:ss}'
+                        {storeFilterRefund}";
+
+                var refundData = await _db.Ado.SqlQueryAsync<dynamic>(refundSql);
+                var refundCount = Convert.ToInt32(refundData.FirstOrDefault()?.refund_count ?? 0);
+                var refundAmount = Convert.ToDecimal(refundData.FirstOrDefault()?.refund_amount ?? 0);
+
+                // 8. 计算净值和退卡率
+                var netBillingCount = billingCount - refundCount;
+                var netBillingAmount = billingAmount - refundAmount;
+                var refundRate = billingCount > 0 ? Math.Round((decimal)refundCount / billingCount * 100, 2) : 0;
+
+                // 9. 返回统计结果
+                return new ActivityStatisticsOutput
+                {
+                    ActivityId = input.ActivityId,
+                    ActivityName = activity.ActivityName,
+                    BillingCount = billingCount,
+                    BillingAmount = billingAmount,
+                    RefundCount = refundCount,
+                    RefundAmount = refundAmount,
+                    NetBillingCount = netBillingCount,
+                    NetBillingAmount = netBillingAmount,
+                    RefundRate = refundRate
+                };
+            }
+            catch (Exception 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;
@@ -548,7 +556,7 @@ namespace NCC.Extend
         #endregion
-        #region 综合仪表盘
+        #region 获取综合仪表盘数据
         /// <summary>
         /// 获取综合仪表盘数据
@@ -682,5 +690,594 @@ namespace NCC.Extend
         }
         #endregion
+
+        #region 获取业务统计数据
+
+        /// <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}");
+            }
+        }
+
+        #endregion
+
+        #region 获取客户类型统计数据
+        /// <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}");
+            }
+        }
+
+        #endregion
+
+        #region 获取门店业绩对比统计数据
+        /// <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}");
+            }
+        }
+        #endregion
+
+        #region 获取品项统计数据
+
+        /// <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;
+
+                // 构建门店过滤条件
+                string storeCondition = "";
+                if (input.StoreIds != null && input.StoreIds.Any())
+                {
+                    var storeIdsStr = string.Join("','", input.StoreIds);
+                    storeCondition = $@"
+                        AND (
+                            kd.djmd IN ('{storeIdsStr}') OR 
+                            xhhyhk.F_StoreId IN ('{storeIdsStr}') OR 
+                            hytk.md IN ('{storeIdsStr}')
+                        )";
+                }
+
+                // 使用最激进的优化：分步查询，避免复杂JOIN
+                var itemStatisticsDict = new Dictionary<string, ItemStatisticsOutput>();
+
+                // 1. 先获取品项基础信息
+                var itemSql = @"
+                    SELECT F_Id, xmmc, xmbh 
+                    FROM lq_xmzl 
+                    WHERE F_IsEffective = 1";
+
+                var itemData = await _db.Ado.SqlQueryAsync<dynamic>(itemSql);
+
+                // 初始化品项字典
+                foreach (var item in itemData)
+                {
+                    var itemId = item.F_Id?.ToString();
+                    if (!string.IsNullOrEmpty(itemId))
+                    {
+                        itemStatisticsDict[itemId] = new ItemStatisticsOutput
+                        {
+                            ItemId = itemId,
+                            ItemName = item.xmmc?.ToString() ?? "未知品项",
+                            ItemNumber = item.xmbh?.ToString() ?? "",
+                            BillingCount = 0,
+                            BillingAmount = 0,
+                            ConsumeCount = 0,
+                            ConsumeAmount = 0,
+                            RefundCount = 0,
+                            RefundAmount = 0
+                        };
+                    }
+                }
+
+                // 2. 开单统计 - 直接查询，避免JOIN
+                var billingSql = $@"
+                    SELECT 
+                        px.px as item_id,
+                        SUM(px.F_ProjectNumber) as billing_count,
+                        SUM(CAST(px.F_ActualPrice AS DECIMAL(18,2))) as billing_amount
+                    FROM lq_kd_pxmx px
+                    WHERE px.F_IsEffective = 1 
+                        AND px.yjsj >= '{startTime:yyyy-MM-dd HH:mm:ss}' 
+                        AND px.yjsj <= '{endTime:yyyy-MM-dd HH:mm:ss}'
+                        {(input.StoreIds != null && input.StoreIds.Any() ? $"AND px.glkdbh IN (SELECT F_Id FROM lq_kd_kdjlb WHERE djmd IN ('{string.Join("','", input.StoreIds)}'))" : "")}
+                    GROUP BY px.px";
+
+                var billingData = await _db.Ado.SqlQueryAsync<dynamic>(billingSql);
+
+                // 合并开单数据
+                foreach (var billing in billingData)
+                {
+                    var itemId = billing.item_id?.ToString();
+                    if (!string.IsNullOrEmpty(itemId) && itemStatisticsDict.ContainsKey(itemId))
+                    {
+                        itemStatisticsDict[itemId].BillingCount = Convert.ToInt32(billing.billing_count ?? 0);
+                        itemStatisticsDict[itemId].BillingAmount = Convert.ToDecimal(billing.billing_amount ?? 0);
+                    }
+                }
+
+                // 3. 消耗统计 - 直接查询，避免JOIN
+                var consumeSql = $@"
+                    SELECT 
+                        xh.px as item_id,
+                        SUM(xh.F_ProjectNumber) as consume_count,
+                        SUM(CAST(xh.F_TotalPrice AS DECIMAL(18,2))) as consume_amount
+                    FROM lq_xh_pxmx xh
+                    WHERE xh.F_IsEffective = 1 
+                        AND xh.F_ConsumeInfoId IN (
+                            SELECT F_Id FROM lq_xh_hyhk 
+                            WHERE hksj >= '{startTime:yyyy-MM-dd HH:mm:ss}' 
+                                AND hksj <= '{endTime:yyyy-MM-dd HH:mm:ss}'
+                                {(input.StoreIds != null && input.StoreIds.Any() ? $"AND F_StoreId IN ('{string.Join("','", input.StoreIds)}')" : "")}
+                        )
+                    GROUP BY xh.px";
+
+                var consumeData = await _db.Ado.SqlQueryAsync<dynamic>(consumeSql);
+
+                // 合并消耗数据
+                foreach (var consume in consumeData)
+                {
+                    var itemId = consume.item_id?.ToString();
+                    if (!string.IsNullOrEmpty(itemId) && itemStatisticsDict.ContainsKey(itemId))
+                    {
+                        itemStatisticsDict[itemId].ConsumeCount = Convert.ToInt32(consume.consume_count ?? 0);
+                        itemStatisticsDict[itemId].ConsumeAmount = Convert.ToDecimal(consume.consume_amount ?? 0);
+                    }
+                }
+
+                // 4. 退卡统计 - 直接查询，避免JOIN
+                var refundSql = $@"
+                    SELECT 
+                        hytkmx.px as item_id,
+                        SUM(hytkmx.F_ProjectNumber) as refund_count,
+                        SUM(CAST(hytkmx.tkje AS DECIMAL(18,2))) as refund_amount
+                    FROM lq_hytk_mx hytkmx
+                    WHERE hytkmx.F_IsEffective = 1 
+                        AND hytkmx.tksj >= '{startTime:yyyy-MM-dd HH:mm:ss}' 
+                        AND hytkmx.tksj <= '{endTime:yyyy-MM-dd HH:mm:ss}'
+                        {(input.StoreIds != null && input.StoreIds.Any() ? $"AND hytkmx.F_RefundInfoId IN (SELECT F_Id FROM lq_hytk_hytk WHERE md IN ('{string.Join("','", input.StoreIds)}'))" : "")}
+                    GROUP BY hytkmx.px";
+
+                var refundData = await _db.Ado.SqlQueryAsync<dynamic>(refundSql);
+
+                // 合并退卡数据
+                foreach (var refund in refundData)
+                {
+                    var itemId = refund.item_id?.ToString();
+                    if (!string.IsNullOrEmpty(itemId) && itemStatisticsDict.ContainsKey(itemId))
+                    {
+                        itemStatisticsDict[itemId].RefundCount = Convert.ToInt32(refund.refund_count ?? 0);
+                        itemStatisticsDict[itemId].RefundAmount = Convert.ToDecimal(refund.refund_amount ?? 0);
+                    }
+                }
+
+                // 5. 过滤并排序
+                var itemStatisticsList = itemStatisticsDict.Values
+                    .Where(x => x.BillingCount > 0 || x.ConsumeCount > 0 || x.RefundCount > 0)
+                    .OrderByDescending(x => x.BillingAmount)
+                    .ToList();
+
+                return itemStatisticsList;
+            }
+            catch (Exception ex)
+            {
+                _logger.LogError(ex, $"获取品项统计数据失败 - 开始时间: {input?.StartTime}, 结束时间: {input?.EndTime}");
+                throw NCCException.Oh($"获取品项统计数据失败: {ex.Message}");
+            }
+        }
+
+        #endregion
     }
 }
@@ -1432,6 +1432,8 @@ namespace NCC.Extend.LqStatistics
                         order_stats.FirstOrderDate,
                         COALESCE(coop_stats.CooperationPerformance, 0) AS CooperationPerformance,
                         COALESCE(base_stats.BasePerformance, 0) AS BasePerformance,
+                        COALESCE(refund_stats.RefundPerformance, 0) AS RefundPerformance,
+                        COALESCE(refund_stats.RefundCount, 0) AS RefundCount,
                         order_stats.TotalPerformance
                     FROM (
                         -- 按开单记录统计基础数据，避免重复计算
@@ -1541,6 +1543,23 @@ namespace NCC.Extend.LqStatistics
                             AND (xmzl.fl3 IS NULL OR xmzl.fl3 != '合作业绩')
                         GROUP BY jksyj.jkszh
                     ) base_stats ON order_stats.EmployeeId = base_stats.EmployeeId
+                    LEFT JOIN (
+                        -- 退单业绩统计
+                        SELECT 
+                            hytk_jksyj.jkszh AS EmployeeId,
+                            SUM(CAST(hytk_jksyj.jksyj AS DECIMAL(18,2))) AS RefundPerformance,
+                            COUNT(*) AS RefundCount
+                        FROM lq_hytk_jksyj hytk_jksyj
+                        INNER JOIN lq_hytk_hytk hytk ON hytk_jksyj.gltkbh = hytk.F_Id
+                        WHERE hytk_jksyj.jksyj IS NOT NULL
+                            AND hytk_jksyj.jksyj != ''
+                            AND hytk_jksyj.jksyj != '0'
+                            AND hytk_jksyj.F_IsEffective = 1
+                            AND hytk.F_IsEffective = 1
+                            AND YEAR(hytk_jksyj.tksj) = @year
+                            AND MONTH(hytk_jksyj.tksj) = @month
+                        GROUP BY hytk_jksyj.jks
+                    ) refund_stats ON order_stats.EmployeeId = refund_stats.EmployeeId
                     ORDER BY order_stats.TotalPerformance DESC";
                 // 解析统计月份
@@ -1582,9 +1601,12 @@ namespace NCC.Extend.LqStatistics
                     Position = stats.Position?.ToString() ?? "",
                     EmployeeId = stats.EmployeeId?.ToString() ?? "",
                     EmployeeName = stats.EmployeeName?.ToString() ?? "",
-                    TotalPerformance = Convert.ToDecimal(stats.TotalPerformance ?? 0),
+                    TotalPerformance = Convert.ToDecimal(stats.TotalPerformance ?? 0) - Convert.ToDecimal(stats.RefundPerformance ?? 0),
                     BasePerformance = Convert.ToDecimal(stats.BasePerformance ?? 0),
                     CooperationPerformance = Convert.ToDecimal(stats.CooperationPerformance ?? 0),
+                    RefundPerformance = Convert.ToDecimal(stats.RefundPerformance ?? 0),
+                    RefundCount = Convert.ToInt32(stats.RefundCount ?? 0),
+                    ActualPerformance = Convert.ToDecimal(stats.TotalPerformance ?? 0) - Convert.ToDecimal(stats.RefundPerformance ?? 0),
                     OrderCount = Convert.ToInt32(stats.OrderCount ?? 0),
                     FirstOrderCount = Convert.ToInt32(stats.FirstOrderCount ?? 0),
                     UpgradeOrderCount = Convert.ToInt32(stats.UpgradeOrderCount ?? 0),
@@ -1665,7 +1687,7 @@ namespace NCC.Extend.LqStatistics
         }
         /// <summary>
-        /// 分页查询个人开单业绩统计数据
+        /// 分页查询个人开单业绩统计数据（在用）
         /// </summary>
         /// <remarks>
         /// 分页查询个人业绩统计数据，支持多条件筛选
@@ -1727,7 +1749,10 @@ namespace NCC.Extend.LqStatistics
                     UpgradeOrderPerformance = it.UpgradeOrderPerformance,
                     LastOrderDate = it.LastOrderDate,
                     FirstOrderDate = it.FirstOrderDate,
-                    CreateTime = it.CreateTime
+                    CreateTime = it.CreateTime,
+                    RefundPerformance = it.RefundPerformance,
+                    RefundCount = it.RefundCount,
+                    ActualPerformance = it.ActualPerformance
                 }).ToPagedListAsync(input.currentPage, input.pageSize);
                 return new
@@ -2588,6 +2613,7 @@ namespace NCC.Extend.LqStatistics
                     UpgradeOrderPerformance = Convert.ToDecimal(data.F_UpgradeOrderPerformance ?? 0),
                     RefundAmount = Convert.ToDecimal(data.F_RefundAmount ?? 0),
                     RefundCount = Convert.ToInt32(data.F_RefundCount ?? 0),
+                    ActualPerformance = Convert.ToDecimal(data.F_TotalOrderPerformance ?? 0) - Convert.ToDecimal(data.F_RefundAmount ?? 0),
                     CreateTime = DateTime.Now
                 }).ToList();
@@ -2671,6 +2697,9 @@ namespace NCC.Extend.LqStatistics
                         upgradeOrderCount = it.UpgradeOrderCount,
                         firstOrderPerformance = it.FirstOrderPerformance,
                         upgradeOrderPerformance = it.UpgradeOrderPerformance,
+                        refundAmount = it.RefundAmount,
+                        refundCount = it.RefundCount,
+                        actualPerformance = it.ActualPerformance,
                         createTime = it.CreateTime
                     })
                     .OrderBy(sidx + " " + input.sort)
@@ -3329,7 +3358,8 @@ namespace NCC.Extend.LqStatistics
                     UpgradeOrderCount = it.UpgradeOrderCount,
                     RefundAmount = it.RefundAmount,
                     RefundCount = it.RefundCount,
-                    CreateTime = it.CreateTime.HasValue ? it.CreateTime.Value : DateTime.Now
+                    CreateTime = it.CreateTime.HasValue ? it.CreateTime.Value : DateTime.Now,
+                    ActualPerformance = it.ActualPerformance
                 }).ToList();
                 return new
@@ -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)