antissoft / lvqianmeiye_ERP

Commit d57a2bdf42b401bf2c97a5f549f1ae3c951fec88

Authored by 李宇
2 parents d29c3bb1 65262a36

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

Inline Side-by-side
Showing 14 changed files with 1160 additions and 303 deletions
.DS_Store
View file @d57a2bd
No preview for this file type
[已用]创建科技部老师业绩统计视图.sql 0 → 100644
  View file @d57a2bd
  1 +-- 创建科技部老师业绩流水视图
  2 +-- 包含所有业务类型的流水记录，并包含对应的信息表ID和品项次数
  3 +
  4 +CREATE OR REPLACE VIEW v_tech_teacher_flow AS
  5 +SELECT
  6 + teacher_id,
  7 + teacher_name,
  8 + teacher_account,
  9 + business_type,
  10 + achievement,
  11 + labor_cost,
  12 + project_count,
  13 + customer_id,
  14 + customer_name,
  15 + business_date,
  16 + source_id,
  17 + source_table,
  18 + item_count
  19 +FROM (
  20 + -- 开卡流水
  21 + SELECT
  22 + k.kjbls as teacher_id,
  23 + k.kjblsxm as teacher_name,
  24 + k.kjblszh as teacher_account,
  25 + '开卡' as business_type,
  26 + CAST(COALESCE(k.kjblsyj, 0) AS DECIMAL(10,2)) as achievement,
  27 + CAST(COALESCE(k.F_LaborCost, 0) AS DECIMAL(10,2)) as labor_cost,
  28 + CAST(COALESCE(pm.F_ProjectNumber, 0) AS DECIMAL(10,2)) as project_count,
  29 + o.kdhy as customer_id,
  30 + o.kdhyc as customer_name,
  31 + k.yjsj as business_date,
  32 + k.F_kdpxid as source_id,
  33 + 'lq_kd_pxmx' as source_table,
  34 + COALESCE(pm.F_ProjectNumber, 0) as item_count
  35 + FROM lq_kd_kjbsyj k
  36 + LEFT JOIN lq_kd_kdjlb o ON k.glkdbh = o.F_Id
  37 + LEFT JOIN lq_kd_pxmx pm ON k.F_kdpxid = pm.F_Id
  38 + WHERE k.kjbls IS NOT NULL AND k.kjblsxm IS NOT NULL
  39 +
  40 + UNION ALL
  41 +
  42 + -- 耗卡流水
  43 + SELECT
  44 + x.kjbls as teacher_id,
  45 + x.kjblsxm as teacher_name,
  46 + x.kjblszh as teacher_account,
  47 + '耗卡' as business_type,
  48 + CAST(COALESCE(x.kjblsyj, 0) AS DECIMAL(10,2)) as achievement,
  49 + CAST(COALESCE(x.F_LaborCost, 0) AS DECIMAL(10,2)) as labor_cost,
  50 + CAST(COALESCE(pm.F_ProjectNumber, 0) AS DECIMAL(10,2)) as project_count,
  51 + h.hy as customer_id,
  52 + h.hymc as customer_name,
  53 + x.yjsj as business_date,
  54 + x.F_hkpxid as source_id,
  55 + 'lq_xh_pxmx' as source_table,
  56 + COALESCE(pm.F_ProjectNumber, 0) as item_count
  57 + FROM lq_xh_kjbsyj x
  58 + LEFT JOIN lq_xh_hyhk h ON x.glkdbh = h.F_Id
  59 + LEFT JOIN lq_xh_pxmx pm ON x.F_hkpxid = pm.F_Id
  60 + WHERE x.kjbls IS NOT NULL AND x.kjblsxm IS NOT NULL
  61 +
  62 + UNION ALL
  63 +
  64 + -- 退卡流水
  65 + SELECT
  66 + r.kjbls as teacher_id,
  67 + r.kjblsxm as teacher_name,
  68 + r.kjblszh as teacher_account,
  69 + '退卡' as business_type,
  70 + CAST(COALESCE(r.kjblsyj, 0) AS DECIMAL(10,2)) as achievement,
  71 + CAST(COALESCE(r.F_LaborCost, 0) AS DECIMAL(10,2)) as labor_cost,
  72 + CAST(COALESCE(r.F_tkpxNumber, 0) AS DECIMAL(10,2)) as project_count,
  73 + t.hy as customer_id,
  74 + t.hymc as customer_name,
  75 + r.tksj as business_date,
  76 + r.F_Id as source_id,
  77 + 'lq_hytk_kjbsyj' as source_table,
  78 + 0 as item_count
  79 + FROM lq_hytk_kjbsyj r
  80 + LEFT JOIN lq_hytk_hytk t ON r.gltkbh = t.F_Id
  81 + WHERE r.kjbls IS NOT NULL AND r.kjblsxm IS NOT NULL AND (r.F_DeleteMark IS NULL OR r.F_DeleteMark = 0)
  82 +) t;
  83 +
  84 +
[已用]创建门店耗卡业绩统计视图.sql 0 → 100644
  View file @d57a2bd
  1 +-- =============================================
  2 +-- 门店耗卡业绩统计视图创建脚本
  3 +-- 功能：统计所有门店的目标业绩、耗卡业绩、完成率等关键指标
  4 +-- 作者：系统自动生成
  5 +-- 创建时间：2025年
  6 +-- =============================================
  7 +
  8 +-- 先删除视图（如果存在）
  9 +DROP VIEW IF EXISTS v_store_consume_performance_simple;
  10 +
  11 +-- =============================================
  12 +-- 创建门店耗卡业绩统计视图（当月数据）
  13 +-- =============================================
  14 +CREATE VIEW v_store_consume_performance_simple AS
  15 +SELECT
  16 + `md`.`F_Id` AS `store_id`,
  17 + `md`.`djmd` AS `store_code`,
  18 + `md`.`dm` AS `store_name`,
  19 + COALESCE(`md`.`xsyj`, 0) AS `target_performance`,
  20 + COALESCE(`consume`.`consume_performance`, 0) AS `actual_performance`,
  21 + (
  22 + CASE
  23 + WHEN (COALESCE(`md`.`xsyj`, 0) > 0) THEN
  24 + round(
  25 + (
  26 + (
  27 + COALESCE(`consume`.`consume_performance`, 0) / `md`.`xsyj`
  28 + ) * 100
  29 + ),
  30 + 2
  31 + ) ELSE 0
  32 + END
  33 + ) AS `completion_rate`,
  34 + COALESCE(`consume`.`consume_count`, 0) AS `order_count`
  35 + FROM
  36 + (
  37 + `lqerp`.`lq_mdxx` `md`
  38 + LEFT JOIN (
  39 + SELECT
  40 + `hk`.`md` AS `md`,
  41 + sum(COALESCE(`px`.`F_TotalPrice`, 0)) AS `consume_performance`,
  42 + count(DISTINCT `hk`.`F_Id`) AS `consume_count`
  43 + FROM
  44 + (
  45 + `lqerp`.`lq_xh_hyhk` `hk`
  46 + LEFT JOIN `lqerp`.`lq_xh_pxmx` `px` ON ((`hk`.`F_Id` = `px`.`glkdbh`))
  47 + )
  48 + WHERE
  49 + (
  50 + (
  51 + YEAR(`hk`.`hksj`) = YEAR(curdate())
  52 + )
  53 + AND (
  54 + MONTH(`hk`.`hksj`) = MONTH(curdate())
  55 + )
  56 + AND (
  57 + isnull(`px`.`F_CreateTIme`)
  58 + OR (
  59 + (
  60 + YEAR(`px`.`F_CreateTIme`) = YEAR(curdate())
  61 + )
  62 + AND (
  63 + MONTH(`px`.`F_CreateTIme`) = MONTH(curdate())
  64 + )
  65 + )
  66 + )
  67 + )
  68 + GROUP BY
  69 + `hk`.`md`
  70 + ) `consume` ON ((`md`.`F_Id` = `consume`.`md`))
  71 + )
  72 + ORDER BY
  73 + COALESCE(`consume`.`consume_performance`, 0) DESC;
  74 +
  75 +-- =============================================
  76 +-- 添加视图注释
  77 +-- =============================================
  78 +ALTER VIEW v_store_consume_performance_simple COMMENT = '门店耗卡业绩统计视图（当月数据）- 统计所有门店的目标业绩、耗卡业绩、完成率等关键指标';
  79 +
  80 +-- =============================================
  81 +-- 视图字段说明
  82 +-- =============================================
  83 +/*
  84 +字段说明：
  85 +- store_id: 门店ID（来自lq_mdxx.F_Id）
  86 +- store_code: 门店编码（来自lq_mdxx.djmd）
  87 +- store_name: 店名（来自lq_mdxx.dm）
  88 +- target_performance: 目标业绩/生命线（来自lq_mdxx.xsyj）
  89 +- actual_performance: 耗卡业绩（来自lq_xh_pxmx.F_TotalPrice的汇总）
  90 +- completion_rate: 完成率百分比（actual_performance / target_performance * 100）
  91 +- order_count: 耗卡记录数（有效耗卡记录数）
  92 +
  93 +关联说明：
  94 +- 主表：lq_mdxx（门店信息表）
  95 +- 关联表：lq_xh_hyhk（耗卡记录表）+ lq_xh_pxmx（耗卡品项表）
  96 +- 关联条件：lq_mdxx.F_Id = lq_xh_hyhk.md, lq_xh_hyhk.F_Id = lq_xh_pxmx.glkdbh
  97 +- 关联方式：LEFT JOIN（确保所有门店都显示，包括没有耗卡记录的门店）
  98 +
  99 +数据来源：
  100 +- 目标业绩：lq_mdxx.xsyj（目标-门店生命线）
  101 +- 耗卡业绩：lq_xh_pxmx.F_TotalPrice（金额合计）
  102 +- 耗卡记录数：lq_xh_hyhk表记录数统计
  103 +
  104 +时间过滤：
  105 +- 耗卡日期：lq_xh_hyhk.hksj（当月）
  106 +- 品项创建时间：lq_xh_pxmx.F_CreateTIme（当月）
  107 +
  108 +注意事项：
  109 +1. 使用金额合计（F_TotalPrice）而不是品项价格（pxjg）
  110 +2. 只统计当月的数据（耗卡日期和品项创建时间都是当月）
  111 +3. 即使目标业绩、耗卡业绩为0的门店也会显示
  112 +4. 完成率计算时，目标业绩为0的门店显示0%完成率
  113 +5. 按耗卡业绩降序排列，便于查看业绩排名
  114 +6. 确保耗卡品项也是当月创建的，避免历史数据干扰
  115 +*/
  116 +
  117 +-- =============================================
  118 +-- 使用示例
  119 +-- =============================================
  120 +/*
  121 +-- 查看所有门店当月耗卡业绩
  122 +SELECT * FROM v_store_consume_performance_simple;
  123 +
  124 +-- 查看华润店当月耗卡业绩
  125 +SELECT * FROM v_store_consume_performance_simple WHERE store_name LIKE '%华润%';
  126 +
  127 +-- 查看已完成目标的门店（当月耗卡）
  128 +SELECT * FROM v_store_consume_performance_simple WHERE completion_rate >= 100;
  129 +
  130 +-- 查看零耗卡业绩的门店（当月）
  131 +SELECT * FROM v_store_consume_performance_simple WHERE actual_performance = 0;
  132 +
  133 +-- 按完成率排名（当月耗卡）
  134 +SELECT * FROM v_store_consume_performance_simple WHERE target_performance > 0 ORDER BY completion_rate DESC;
  135 +
  136 +-- 查看当月耗卡业绩前10名门店
  137 +SELECT * FROM v_store_consume_performance_simple ORDER BY actual_performance DESC LIMIT 10;
  138 +
  139 +-- 查看当月完成率低于50%的门店
  140 +SELECT * FROM v_store_consume_performance_simple WHERE completion_rate < 50 AND target_performance > 0;
  141 +*/
netcore/src/Modularity/Extend/NCC.Extend.Entitys/Dto/LqStatistics/TechTeacherSimpleStatisticsOutput.cs 0 → 100644
  View file @d57a2bd
  1 +using System;
  2 +
  3 +namespace NCC.Extend.Entitys.Dto.LqStatistics
  4 +{
  5 + /// <summary>
  6 + /// 科技部老师简化统计输出
  7 + /// </summary>
  8 + public class TechTeacherSimpleStatisticsOutput
  9 + {
  10 + /// <summary>
  11 + /// 部门名称
  12 + /// </summary>
  13 + public string DepartmentName { get; set; }
  14 +
  15 + /// <summary>
  16 + /// 老师姓名
  17 + /// </summary>
  18 + public string TeacherName { get; set; }
  19 +
  20 + /// <summary>
  21 + /// 消耗项目数
  22 + /// </summary>
  23 + public int ConsumeProjectCount { get; set; }
  24 +
  25 + /// <summary>
  26 + /// 消耗业绩
  27 + /// </summary>
  28 + public decimal ConsumeAchievement { get; set; }
  29 +
  30 + /// <summary>
  31 + /// 开卡业绩
  32 + /// </summary>
  33 + public decimal OrderAchievement { get; set; }
  34 +
  35 + /// <summary>
  36 + /// 开卡品项次数
  37 + /// </summary>
  38 + public int OrderItemCount { get; set; }
  39 +
  40 + /// <summary>
  41 + /// 耗卡品项次数
  42 + /// </summary>
  43 + public int ConsumeItemCount { get; set; }
  44 + }
  45 +}
netcore/src/Modularity/Extend/NCC.Extend.Entitys/Dto/LqStatistics/TechTeacherStatisticsInput.cs 0 → 100644
  View file @d57a2bd
  1 +using System;
  2 +
  3 +namespace NCC.Extend.Entitys.Dto.LqStatistics
  4 +{
  5 + /// <summary>
  6 + /// 科技部老师统计查询参数
  7 + /// </summary>
  8 + public class TechTeacherStatisticsInput
  9 + {
  10 + /// <summary>
  11 + /// 开始日期
  12 + /// </summary>
  13 + public DateTime? StartDate { get; set; }
  14 +
  15 + /// <summary>
  16 + /// 结束日期
  17 + /// </summary>
  18 + public DateTime? EndDate { get; set; }
  19 +
  20 + /// <summary>
  21 + /// 科技部老师ID
  22 + /// </summary>
  23 + public string TeacherId { get; set; }
  24 +
  25 + /// <summary>
  26 + /// 科技部老师姓名
  27 + /// </summary>
  28 + public string TeacherName { get; set; }
  29 +
  30 + /// <summary>
  31 + /// 部门ID
  32 + /// </summary>
  33 + public string DepartmentId { get; set; }
  34 + }
  35 +}
netcore/src/Modularity/Extend/NCC.Extend.Entitys/Dto/LqStatistics/TechTeacherStatisticsOutput.cs 0 → 100644
  View file @d57a2bd
  1 +using System;
  2 +using System.Collections.Generic;
  3 +
  4 +namespace NCC.Extend.Entitys.Dto.LqStatistics
  5 +{
  6 + /// <summary>
  7 + /// 科技部老师统计输出结果
  8 + /// </summary>
  9 + public class TechTeacherStatisticsOutput
  10 + {
  11 + /// <summary>
  12 + /// 科技部老师ID
  13 + /// </summary>
  14 + public string TeacherId { get; set; }
  15 +
  16 + /// <summary>
  17 + /// 科技部老师姓名
  18 + /// </summary>
  19 + public string TeacherName { get; set; }
  20 +
  21 + /// <summary>
  22 + /// 科技部老师账号
  23 + /// </summary>
  24 + public string TeacherAccount { get; set; }
  25 +
  26 + /// <summary>
  27 + /// 开卡业绩
  28 + /// </summary>
  29 + public decimal OrderAchievement { get; set; }
  30 +
  31 + /// <summary>
  32 + /// 消耗业绩
  33 + /// </summary>
  34 + public decimal ConsumeAchievement { get; set; }
  35 +
  36 + /// <summary>
  37 + /// 退卡业绩
  38 + /// </summary>
  39 + public decimal RefundAchievement { get; set; }
  40 +
  41 + /// <summary>
  42 + /// 总业绩
  43 + /// </summary>
  44 + public decimal TotalAchievement { get; set; }
  45 +
  46 + /// <summary>
  47 + /// 见客数
  48 + /// </summary>
  49 + public int CustomerCount { get; set; }
  50 +
  51 + /// <summary>
  52 + /// 项目数
  53 + /// </summary>
  54 + public int ProjectCount { get; set; }
  55 +
  56 + /// <summary>
  57 + /// 手工费
  58 + /// </summary>
  59 + public decimal LaborCost { get; set; }
  60 +
  61 + /// <summary>
  62 + /// 统计时间
  63 + /// </summary>
  64 + public DateTime StatisticsTime { get; set; }
  65 + }
  66 +
  67 + /// <summary>
  68 + /// 科技部老师统计列表输出结果
  69 + /// </summary>
  70 + public class TechTeacherStatisticsListOutput
  71 + {
  72 + /// <summary>
  73 + /// 科技部老师统计列表
  74 + /// </summary>
  75 + public List<TechTeacherStatisticsOutput> Teachers { get; set; } = new List<TechTeacherStatisticsOutput>();
  76 +
  77 + /// <summary>
  78 + /// 总记录数
  79 + /// </summary>
  80 + public int TotalCount { get; set; }
  81 +
  82 + /// <summary>
  83 + /// 总开卡业绩
  84 + /// </summary>
  85 + public decimal TotalOrderAchievement { get; set; }
  86 +
  87 + /// <summary>
  88 + /// 总消耗业绩
  89 + /// </summary>
  90 + public decimal TotalConsumeAchievement { get; set; }
  91 +
  92 + /// <summary>
  93 + /// 总退卡业绩
  94 + /// </summary>
  95 + public decimal TotalRefundAchievement { get; set; }
  96 +
  97 + /// <summary>
  98 + /// 总业绩
  99 + /// </summary>
  100 + public decimal TotalAchievement { get; set; }
  101 +
  102 + /// <summary>
  103 + /// 总见客数
  104 + /// </summary>
  105 + public int TotalCustomerCount { get; set; }
  106 +
  107 + /// <summary>
  108 + /// 总项目数
  109 + /// </summary>
  110 + public int TotalProjectCount { get; set; }
  111 +
  112 + /// <summary>
  113 + /// 总手工费
  114 + /// </summary>
  115 + public decimal TotalLaborCost { get; set; }
  116 + }
  117 +}
netcore/src/Modularity/Extend/NCC.Extend.Entitys/Entity/lq_kd_kjbsyj/LqKdKjbsyjEntity.cs
  View file @d57a2bd
1 -using NCC.Common.Const; 1 +using System;
  2 +using NCC.Common.Const;
2 using SqlSugar; 3 using SqlSugar;
3 -using System;  
4 4
5 namespace NCC.Extend.Entitys.lq_kd_kjbsyj 5 namespace NCC.Extend.Entitys.lq_kd_kjbsyj
6 { 6 {
@@ -59,5 +59,10 @@ namespace NCC.Extend.Entitys.lq_kd_kjbsyj @@ -59,5 +59,10 @@ namespace NCC.Extend.Entitys.lq_kd_kjbsyj
59 [SugarColumn(ColumnName = "F_kdpxid")] 59 [SugarColumn(ColumnName = "F_kdpxid")]
60 public string Kdpxid { get; set; } 60 public string Kdpxid { get; set; }
61 61
  62 + /// <summary>
  63 + /// 手工费
  64 + /// </summary>
  65 + [SugarColumn(ColumnName = "F_LaborCost")]
  66 + public decimal? LaborCost { get; set; }
62 } 67 }
63 -}  
64 \ No newline at end of file 68 \ No newline at end of file
  69 +}
netcore/src/Modularity/Extend/NCC.Extend.Entitys/Entity/v_tech_teacher_flow/VTechTeacherFlowEntity.cs 0 → 100644
  View file @d57a2bd
  1 +using System;
  2 +using NCC.Common.Const;
  3 +using SqlSugar;
  4 +
  5 +namespace NCC.Extend.Entitys.v_tech_teacher_flow
  6 +{
  7 + /// <summary>
  8 + /// 科技部老师业绩流水视图
  9 + /// </summary>
  10 + [SugarTable("v_tech_teacher_flow")]
  11 + [Tenant(ClaimConst.TENANT_ID)]
  12 + public class VTechTeacherFlowEntity
  13 + {
  14 + /// <summary>
  15 + /// 老师ID
  16 + /// </summary>
  17 + [SugarColumn(ColumnName = "teacher_id")]
  18 + public string TeacherId { get; set; }
  19 +
  20 + /// <summary>
  21 + /// 老师姓名
  22 + /// </summary>
  23 + [SugarColumn(ColumnName = "teacher_name")]
  24 + public string TeacherName { get; set; }
  25 +
  26 + /// <summary>
  27 + /// 老师账号
  28 + /// </summary>
  29 + [SugarColumn(ColumnName = "teacher_account")]
  30 + public string TeacherAccount { get; set; }
  31 +
  32 + /// <summary>
  33 + /// 业务类型（开卡、耗卡、退卡）
  34 + /// </summary>
  35 + [SugarColumn(ColumnName = "business_type")]
  36 + public string BusinessType { get; set; }
  37 +
  38 + /// <summary>
  39 + /// 业绩金额
  40 + /// </summary>
  41 + [SugarColumn(ColumnName = "achievement")]
  42 + public decimal Achievement { get; set; }
  43 +
  44 + /// <summary>
  45 + /// 手工费
  46 + /// </summary>
  47 + [SugarColumn(ColumnName = "labor_cost")]
  48 + public decimal LaborCost { get; set; }
  49 +
  50 + /// <summary>
  51 + /// 项目数
  52 + /// </summary>
  53 + [SugarColumn(ColumnName = "project_count")]
  54 + public decimal ProjectCount { get; set; }
  55 +
  56 + /// <summary>
  57 + /// 客户ID
  58 + /// </summary>
  59 + [SugarColumn(ColumnName = "customer_id")]
  60 + public string CustomerId { get; set; }
  61 +
  62 + /// <summary>
  63 + /// 客户姓名
  64 + /// </summary>
  65 + [SugarColumn(ColumnName = "customer_name")]
  66 + public string CustomerName { get; set; }
  67 +
  68 + /// <summary>
  69 + /// 业务日期
  70 + /// </summary>
  71 + [SugarColumn(ColumnName = "business_date")]
  72 + public DateTime? BusinessDate { get; set; }
  73 +
  74 + /// <summary>
  75 + /// 源记录ID
  76 + /// </summary>
  77 + [SugarColumn(ColumnName = "source_id")]
  78 + public string SourceId { get; set; }
  79 +
  80 + /// <summary>
  81 + /// 源表名
  82 + /// </summary>
  83 + [SugarColumn(ColumnName = "source_table")]
  84 + public string SourceTable { get; set; }
  85 +
  86 + /// <summary>
  87 + /// 品项次数
  88 + /// </summary>
  89 + [SugarColumn(ColumnName = "item_count")]
  90 + public int ItemCount { get; set; }
  91 + }
  92 +}
netcore/src/Modularity/Extend/NCC.Extend.Entitys/Entity/v_tech_teacher_summary/VTechTeacherSummaryEntity.cs 0 → 100644
  View file @d57a2bd
  1 +using NCC.Common.Const;
  2 +using SqlSugar;
  3 +
  4 +namespace NCC.Extend.Entitys.v_tech_teacher_summary
  5 +{
  6 + /// <summary>
  7 + /// 科技部老师业绩汇总视图（简化版）
  8 + /// </summary>
  9 + [SugarTable("v_tech_teacher_summary")]
  10 + [Tenant(ClaimConst.TENANT_ID)]
  11 + public class VTechTeacherSummaryEntity
  12 + {
  13 + /// <summary>
  14 + /// 老师ID
  15 + /// </summary>
  16 + [SugarColumn(ColumnName = "teacher_id")]
  17 + public string TeacherId { get; set; }
  18 +
  19 + /// <summary>
  20 + /// 老师姓名
  21 + /// </summary>
  22 + [SugarColumn(ColumnName = "teacher_name")]
  23 + public string TeacherName { get; set; }
  24 +
  25 + /// <summary>
  26 + /// 老师账号
  27 + /// </summary>
  28 + [SugarColumn(ColumnName = "teacher_account")]
  29 + public string TeacherAccount { get; set; }
  30 +
  31 + /// <summary>
  32 + /// 开卡业绩
  33 + /// </summary>
  34 + [SugarColumn(ColumnName = "order_achievement")]
  35 + public decimal OrderAchievement { get; set; }
  36 +
  37 + /// <summary>
  38 + /// 消耗业绩
  39 + /// </summary>
  40 + [SugarColumn(ColumnName = "consume_achievement")]
  41 + public decimal ConsumeAchievement { get; set; }
  42 +
  43 + /// <summary>
  44 + /// 退卡业绩
  45 + /// </summary>
  46 + [SugarColumn(ColumnName = "refund_achievement")]
  47 + public decimal RefundAchievement { get; set; }
  48 +
  49 + /// <summary>
  50 + /// 总业绩
  51 + /// </summary>
  52 + [SugarColumn(ColumnName = "total_achievement")]
  53 + public decimal TotalAchievement { get; set; }
  54 +
  55 + /// <summary>
  56 + /// 手工费
  57 + /// </summary>
  58 + [SugarColumn(ColumnName = "labor_cost")]
  59 + public decimal LaborCost { get; set; }
  60 +
  61 + /// <summary>
  62 + /// 项目数
  63 + /// </summary>
  64 + [SugarColumn(ColumnName = "project_count")]
  65 + public decimal ProjectCount { get; set; }
  66 +
  67 + /// <summary>
  68 + /// 见客数
  69 + /// </summary>
  70 + [SugarColumn(ColumnName = "customer_count")]
  71 + public int CustomerCount { get; set; }
  72 + }
  73 +}
netcore/src/Modularity/Extend/NCC.Extend.Interfaces/LqStatistics/ILqStatisticsService.cs
  View file @d57a2bd
@@ -2,6 +2,7 @@ using System.Collections.Generic; @@ -2,6 +2,7 @@ using System.Collections.Generic;
2 using System.Threading.Tasks; 2 using System.Threading.Tasks;
3 using NCC.Extend.Entitys.Dto.LqMdxx; 3 using NCC.Extend.Entitys.Dto.LqMdxx;
4 using NCC.Extend.Entitys.Dto.LqStatistics; 4 using NCC.Extend.Entitys.Dto.LqStatistics;
  5 +using NCC.Extend.Entitys.v_tech_teacher_flow;
5 6
6 namespace NCC.Extend.Interfaces.LqStatistics 7 namespace NCC.Extend.Interfaces.LqStatistics
7 { 8 {
@@ -17,6 +18,12 @@ namespace NCC.Extend.Interfaces.LqStatistics @@ -17,6 +18,12 @@ namespace NCC.Extend.Interfaces.LqStatistics
17 Task<List<StorePerformanceOutput>> GetStorePerformanceList(); 18 Task<List<StorePerformanceOutput>> GetStorePerformanceList();
18 19
19 /// <summary> 20 /// <summary>
  21 + /// 获取门店开单业绩统计列表
  22 + /// </summary>
  23 + /// <returns>门店开单业绩统计列表</returns>
  24 + Task<List<StorePerformanceOutput>> GetStoreOrderPerformanceList();
  25 +
  26 + /// <summary>
20 /// 获取门店统计信息 27 /// 获取门店统计信息
21 /// </summary> 28 /// </summary>
22 /// <param name="input">查询参数</param> 29 /// <param name="input">查询参数</param>
@@ -50,5 +57,12 @@ namespace NCC.Extend.Interfaces.LqStatistics @@ -50,5 +57,12 @@ namespace NCC.Extend.Interfaces.LqStatistics
50 /// <param name="input">查询参数</param> 57 /// <param name="input">查询参数</param>
51 /// <returns>经理业绩汇总统计结果</returns> 58 /// <returns>经理业绩汇总统计结果</returns>
52 Task<ManagerSummaryStatisticsOutput> GetManagerSummaryStatistics(ManagerStatisticsInput input); 59 Task<ManagerSummaryStatisticsOutput> GetManagerSummaryStatistics(ManagerStatisticsInput input);
  60 +
  61 + /// <summary>
  62 + /// 获取科技部老师业绩统计
  63 + /// </summary>
  64 + /// <param name="input">查询参数</param>
  65 + /// <returns>科技部老师业绩统计结果</returns>
  66 + Task<List<TechTeacherSimpleStatisticsOutput>> GetTechTeacherStatistics(TechTeacherStatisticsInput input);
53 } 67 }
54 } 68 }
netcore/src/Modularity/Extend/NCC.Extend/LqStatisticsService.cs
  View file @d57a2bd
@@ -2,6 +2,7 @@ using System; @@ -2,6 +2,7 @@ using System;
2 using System.Collections.Generic; 2 using System.Collections.Generic;
3 using System.Linq; 3 using System.Linq;
4 using System.Threading.Tasks; 4 using System.Threading.Tasks;
  5 +using Microsoft.AspNetCore.Authorization;
5 using Microsoft.AspNetCore.Mvc; 6 using Microsoft.AspNetCore.Mvc;
6 using Microsoft.Extensions.Logging; 7 using Microsoft.Extensions.Logging;
7 using NCC.Common.Core.Manager; 8 using NCC.Common.Core.Manager;
@@ -12,9 +13,15 @@ using NCC.Dependency; @@ -12,9 +13,15 @@ using NCC.Dependency;
12 using NCC.DynamicApiController; 13 using NCC.DynamicApiController;
13 using NCC.Extend.Entitys.Dto.LqMdxx; 14 using NCC.Extend.Entitys.Dto.LqMdxx;
14 using NCC.Extend.Entitys.Dto.LqStatistics; 15 using NCC.Extend.Entitys.Dto.LqStatistics;
  16 +using NCC.Extend.Entitys.lq_hytk_kjbsyj;
  17 +using NCC.Extend.Entitys.lq_kd_kdjlb;
  18 +using NCC.Extend.Entitys.lq_kd_kjbsyj;
15 using NCC.Extend.Entitys.lq_mdxx; 19 using NCC.Extend.Entitys.lq_mdxx;
  20 +using NCC.Extend.Entitys.lq_xh_kjbsyj;
16 using NCC.Extend.Entitys.lq_yjmxb; 21 using NCC.Extend.Entitys.lq_yjmxb;
  22 +using NCC.Extend.Entitys.v_tech_teacher_flow;
17 using NCC.Extend.Interfaces.LqStatistics; 23 using NCC.Extend.Interfaces.LqStatistics;
  24 +using NCC.Extend.Utils;
18 using NCC.FriendlyException; 25 using NCC.FriendlyException;
19 using NCC.System.Entitys.Permission; 26 using NCC.System.Entitys.Permission;
20 using SqlSugar; 27 using SqlSugar;
@@ -32,45 +39,66 @@ namespace NCC.Extend.LqStatistics @@ -32,45 +39,66 @@ namespace NCC.Extend.LqStatistics
32 private readonly SqlSugarScope _db; 39 private readonly SqlSugarScope _db;
33 private readonly IUserManager _userManager; 40 private readonly IUserManager _userManager;
34 private readonly ILogger<LqStatisticsService> _logger; 41 private readonly ILogger<LqStatisticsService> _logger;
  42 + private readonly WeChatBotService _weChatBotService;
35 43
36 /// <summary> 44 /// <summary>
37 /// 初始化一个<see cref="LqStatisticsService"/>类型的新实例 45 /// 初始化一个<see cref="LqStatisticsService"/>类型的新实例
38 /// </summary> 46 /// </summary>
39 - public LqStatisticsService(ISqlSugarRepository<LqMdxxEntity> lqMdxxRepository, IUserManager userManager, ILogger<LqStatisticsService> logger) 47 + public LqStatisticsService(ISqlSugarRepository<LqMdxxEntity> lqMdxxRepository, IUserManager userManager, ILogger<LqStatisticsService> logger, WeChatBotService weChatBotService)
40 { 48 {
41 _lqMdxxRepository = lqMdxxRepository; 49 _lqMdxxRepository = lqMdxxRepository;
42 _db = _lqMdxxRepository.Context; 50 _db = _lqMdxxRepository.Context;
43 _userManager = userManager; 51 _userManager = userManager;
44 _logger = logger; 52 _logger = logger;
  53 + _weChatBotService = weChatBotService;
45 } 54 }
46 55
47 - #region 获取门店业绩统计列表 56 + #region 获取门店耗卡业绩统计列表
48 /// <summary> 57 /// <summary>
49 /// 获取门店业绩统计列表 58 /// 获取门店业绩统计列表
50 /// </summary> 59 /// </summary>
  60 + /// <remarks>
  61 + /// 获取所有门店的耗卡业绩统计信息，包括门店ID、名称、编码、目标业绩、耗卡业绩、完成率等关键指标
  62 + ///
  63 + /// 返回数据说明：
  64 + /// - StoreId: 门店ID
  65 + /// - StoreName: 门店名称
  66 + /// - StoreCode: 门店编码
  67 + /// - BusinessUnitId: 事业部ID（暂未关联）
  68 + /// - BusinessUnitName: 事业部名称（暂未关联）
  69 + /// - TargetPerformance: 目标业绩（门店生命线）
  70 + /// - ActualPerformance: 耗卡业绩（当月耗卡金额汇总）
  71 + /// - CompletionRate: 完成率（耗卡业绩/目标业绩*100）
  72 + /// - OrderCount: 耗卡记录数（当月耗卡记录数）
  73 + ///
  74 + /// 数据来源：v_store_consume_performance_simple 视图
  75 + /// </remarks>
51 /// <returns>门店业绩统计列表</returns> 76 /// <returns>门店业绩统计列表</returns>
52 - [HttpGet] 77 + /// <response code="200">成功返回门店业绩统计列表</response>
  78 + /// <response code="500">服务器内部错误</response>
  79 + [HttpGet("GetStorePerformanceList")]
  80 + [AllowAnonymous]
53 public async Task<List<StorePerformanceOutput>> GetStorePerformanceList() 81 public async Task<List<StorePerformanceOutput>> GetStorePerformanceList()
54 { 82 {
55 try 83 try
56 { 84 {
57 _logger.LogInformation("开始查询门店业绩统计列表"); 85 _logger.LogInformation("开始查询门店业绩统计列表");
58 86
59 - var storeList = await _lqMdxxRepository  
60 - .AsQueryable()  
61 - .Where(x => x.Status == 1)  
62 - .Select(x => new StorePerformanceOutput  
63 - {  
64 - StoreId = x.Id,  
65 - StoreName = x.Dm,  
66 - StoreCode = x.Mdbm,  
67 - BusinessUnitId = x.Syb,  
68 - BusinessUnitName = x.Syb,  
69 - TargetPerformance = x.Xsyj ?? 0,  
70 - ActualPerformance = 0,  
71 - CompletionRate = 0,  
72 - })  
73 - .ToListAsync(); 87 + // 使用耗卡业绩统计视图
  88 + var storeList = await _db.Ado.SqlQueryAsync<StorePerformanceOutput>(
  89 + "SELECT "
  90 + + "store_id AS StoreId, "
  91 + + "store_code AS StoreCode, "
  92 + + "store_name AS StoreName, "
  93 + + "'' AS BusinessUnitId, "
  94 + + "'' AS BusinessUnitName, "
  95 + + "target_performance AS TargetPerformance, "
  96 + + "actual_performance AS ActualPerformance, "
  97 + + "completion_rate AS CompletionRate, "
  98 + + "order_count AS OrderCount "
  99 + + "FROM v_store_consume_performance_simple "
  100 + + "ORDER BY actual_performance DESC"
  101 + );
74 102
75 _logger.LogInformation("门店业绩统计列表查询完成，返回{Count}条记录", storeList.Count); 103 _logger.LogInformation("门店业绩统计列表查询完成，返回{Count}条记录", storeList.Count);
76 104
@@ -84,13 +112,104 @@ namespace NCC.Extend.LqStatistics @@ -84,13 +112,104 @@ namespace NCC.Extend.LqStatistics
84 } 112 }
85 #endregion 113 #endregion
86 114
  115 + #region 获取门店开单业绩统计列表
  116 + /// <summary>
  117 + /// 获取门店开单业绩统计列表
  118 + /// </summary>
  119 + /// <remarks>
  120 + /// 获取所有门店的开单业绩统计信息，包括门店ID、名称、编码、目标业绩、开单业绩、完成率等关键指标
  121 + ///
  122 + /// 返回数据说明：
  123 + /// - StoreId: 门店ID
  124 + /// - StoreName: 门店名称
  125 + /// - StoreCode: 门店编码
  126 + /// - BusinessUnitId: 事业部ID（暂未关联）
  127 + /// - BusinessUnitName: 事业部名称（暂未关联）
  128 + /// - TargetPerformance: 目标业绩（门店生命线）
  129 + /// - ActualPerformance: 开单业绩（当月开单金额汇总）
  130 + /// - CompletionRate: 完成率（开单业绩/目标业绩*100）
  131 + /// - OrderCount: 开单记录数（当月开单记录数）
  132 + ///
  133 + /// 数据来源：v_store_performance_simple 视图
  134 + /// </remarks>
  135 + /// <returns>门店开单业绩统计列表</returns>
  136 + /// <response code="200">成功返回门店开单业绩统计列表</response>
  137 + /// <response code="500">服务器内部错误</response>
  138 + [HttpGet("GetStoreOrderPerformanceList")]
  139 + [AllowAnonymous]
  140 + public async Task<List<StorePerformanceOutput>> GetStoreOrderPerformanceList()
  141 + {
  142 + try
  143 + {
  144 + _logger.LogInformation("开始查询门店开单业绩统计列表");
  145 +
  146 + // 使用开单业绩统计视图
  147 + var storeList = await _db.Ado.SqlQueryAsync<StorePerformanceOutput>(
  148 + "SELECT "
  149 + + "store_id AS StoreId, "
  150 + + "store_code AS StoreCode, "
  151 + + "store_name AS StoreName, "
  152 + + "'' AS BusinessUnitId, "
  153 + + "'' AS BusinessUnitName, "
  154 + + "target_performance AS TargetPerformance, "
  155 + + "actual_performance AS ActualPerformance, "
  156 + + "completion_rate AS CompletionRate, "
  157 + + "order_count AS OrderCount "
  158 + + "FROM v_store_performance_simple "
  159 + + "ORDER BY actual_performance DESC"
  160 + );
  161 +
  162 + _logger.LogInformation("门店开单业绩统计列表查询完成，返回{Count}条记录", storeList.Count);
  163 +
  164 + return storeList ?? new List<StorePerformanceOutput>();
  165 + }
  166 + catch (Exception ex)
  167 + {
  168 + _logger.LogError(ex, "查询门店开单业绩统计列表时发生错误");
  169 + throw NCCException.Oh("查询门店开单业绩统计列表失败", ex);
  170 + }
  171 + }
  172 + #endregion
  173 +
87 #region 获取门店统计信息 174 #region 获取门店统计信息
88 /// <summary> 175 /// <summary>
89 /// 获取门店统计信息 176 /// 获取门店统计信息
90 /// </summary> 177 /// </summary>
  178 + /// <remarks>
  179 + /// 根据指定日期范围和门店ID查询门店的详细业绩统计信息，包括目标业绩、完成业绩、完成率等
  180 + ///
  181 + /// 示例请求：
  182 + /// ```json
  183 + /// {
  184 + /// "startDate": "2025-01-01T00:00:00",
  185 + /// "endDate": "2025-01-31T23:59:59",
  186 + /// "storeId": "门店ID（可选）"
  187 + /// }
  188 + /// ```
  189 + ///
  190 + /// 参数说明：
  191 + /// - startDate: 开始日期，格式：yyyy-MM-ddTHH:mm:ss
  192 + /// - endDate: 结束日期，格式：yyyy-MM-ddTHH:mm:ss
  193 + /// - storeId: 门店ID，可选参数，不传则查询所有门店
  194 + ///
  195 + /// 返回数据说明：
  196 + /// - StoreId: 门店ID
  197 + /// - StoreName: 门店名称
  198 + /// - StoreCode: 门店编码
  199 + /// - BusinessUnitId: 事业部ID
  200 + /// - BusinessUnitName: 事业部名称
  201 + /// - TargetPerformance: 目标业绩
  202 + /// - ActualPerformance: 完成业绩
  203 + /// - OrderCount: 开单数量
  204 + /// - CompletionRate: 完成率（%）
  205 + /// </remarks>
91 /// <param name="input">查询参数</param> 206 /// <param name="input">查询参数</param>
92 /// <returns>门店统计结果</returns> 207 /// <returns>门店统计结果</returns>
  208 + /// <response code="200">成功返回门店统计数据</response>
  209 + /// <response code="400">请求参数错误</response>
  210 + /// <response code="500">服务器内部错误</response>
93 [HttpPost("StoreStatistics")] 211 [HttpPost("StoreStatistics")]
  212 + [AllowAnonymous]
94 public async Task<StoreStatisticsOutput> GetStoreStatistics(StoreStatisticsInput input) 213 public async Task<StoreStatisticsOutput> GetStoreStatistics(StoreStatisticsInput input)
95 { 214 {
96 try 215 try
@@ -101,41 +220,29 @@ namespace NCC.Extend.LqStatistics @@ -101,41 +220,29 @@ namespace NCC.Extend.LqStatistics
101 var parameters = new Dictionary<string, object> { { "@startDate", input.StartDate.ToString("yyyy-MM-dd 00:00:00") }, { "@endDate", input.EndDate.ToString("yyyy-MM-dd 23:59:59") } }; 220 var parameters = new Dictionary<string, object> { { "@startDate", input.StartDate.ToString("yyyy-MM-dd 00:00:00") }, { "@endDate", input.EndDate.ToString("yyyy-MM-dd 23:59:59") } };
102 221
103 // 构建WHERE条件 222 // 构建WHERE条件
104 - var whereClause = "WHERE (order_date >= @startDate AND order_date <= @endDate OR order_date IS NULL)";  
105 - 223 + var whereClause = "WHERE 1=1";
106 if (!string.IsNullOrEmpty(input.StoreId)) 224 if (!string.IsNullOrEmpty(input.StoreId))
107 { 225 {
108 whereClause += " AND store_id = @storeId"; 226 whereClause += " AND store_id = @storeId";
109 parameters.Add("@storeId", input.StoreId); 227 parameters.Add("@storeId", input.StoreId);
110 } 228 }
111 229
112 - // 构建SQL查询 230 + // 使用SQL查询门店统计信息，包含日期范围过滤
113 var sql = 231 var sql =
114 $@" 232 $@"
115 SELECT 233 SELECT
116 store_id AS StoreId, 234 store_id AS StoreId,
117 - store_name AS StoreName,  
118 store_code AS StoreCode, 235 store_code AS StoreCode,
119 - business_unit_id AS BusinessUnitId,  
120 - business_unit_name AS BusinessUnitName, 236 + store_name AS StoreName,
  237 + '' AS BusinessUnitId,
  238 + '' AS BusinessUnitName,
121 target_performance AS TargetPerformance, 239 target_performance AS TargetPerformance,
122 - SUM(COALESCE(actual_amount, 0)) AS ActualPerformance,  
123 - COUNT(order_id) AS OrderCount,  
124 - CASE  
125 - WHEN target_performance > 0  
126 - THEN ROUND((SUM(COALESCE(actual_amount, 0)) / target_performance) * 100, 2)  
127 - ELSE 0  
128 - END AS CompletionRate  
129 - FROM v_store_daily_consume_stats 240 + actual_performance AS ActualPerformance,
  241 + completion_rate AS CompletionRate,
  242 + order_count AS OrderCount
  243 + FROM v_store_performance_simple
130 {whereClause} 244 {whereClause}
131 - GROUP BY  
132 - store_id,  
133 - store_name,  
134 - store_code,  
135 - business_unit_id,  
136 - business_unit_name,  
137 - target_performance  
138 - ORDER BY ActualPerformance DESC"; 245 + ORDER BY actual_performance DESC";
139 246
140 _logger.LogInformation("执行SQL查询：{Sql}", sql); 247 _logger.LogInformation("执行SQL查询：{Sql}", sql);
141 _logger.LogInformation("查询参数：{Parameters}", string.Join(", ", parameters.Select(p => $"{p.Key}={p.Value}"))); 248 _logger.LogInformation("查询参数：{Parameters}", string.Join(", ", parameters.Select(p => $"{p.Key}={p.Value}")));
@@ -176,9 +283,40 @@ namespace NCC.Extend.LqStatistics @@ -176,9 +283,40 @@ namespace NCC.Extend.LqStatistics
176 /// <summary> 283 /// <summary>
177 /// 获取事业部业绩统计 284 /// 获取事业部业绩统计
178 /// </summary> 285 /// </summary>
  286 + /// <remarks>
  287 + /// 根据指定日期范围和事业部ID查询事业部的业绩统计信息，包括目标业绩总和、完成业绩总和、完成率等
  288 + ///
  289 + /// 示例请求：
  290 + /// ```json
  291 + /// {
  292 + /// "startDate": "2025-01-01T00:00:00",
  293 + /// "endDate": "2025-01-31T23:59:59",
  294 + /// "businessUnitId": "事业部ID（可选）"
  295 + /// }
  296 + /// ```
  297 + ///
  298 + /// 参数说明：
  299 + /// - startDate: 开始日期，格式：yyyy-MM-ddTHH:mm:ss
  300 + /// - endDate: 结束日期，格式：yyyy-MM-ddTHH:mm:ss
  301 + /// - businessUnitId: 事业部ID，可选参数，不传则查询所有事业部
  302 + ///
  303 + /// 返回数据说明：
  304 + /// - DepartmentId: 部门ID
  305 + /// - DepartmentName: 部门名称
  306 + /// - ParentId: 父部门ID
  307 + /// - ParentName: 父部门名称
  308 + /// - TotalTargetAmount: 目标业绩总和
  309 + /// - TotalActualAmount: 完成业绩总和
  310 + /// - TotalOrderCount: 开单总数量
  311 + /// - CompletionRate: 完成率（%）
  312 + /// </remarks>
179 /// <param name="input">查询参数</param> 313 /// <param name="input">查询参数</param>
180 /// <returns>事业部业绩统计结果</returns> 314 /// <returns>事业部业绩统计结果</returns>
  315 + /// <response code="200">成功返回事业部业绩统计数据</response>
  316 + /// <response code="400">请求参数错误</response>
  317 + /// <response code="500">服务器内部错误</response>
181 [HttpPost("BusinessUnitStatistics")] 318 [HttpPost("BusinessUnitStatistics")]
  319 + [AllowAnonymous]
182 public async Task<BusinessUnitStatisticsOutput> GetBusinessUnitStatistics(BusinessUnitStatisticsInput input) 320 public async Task<BusinessUnitStatisticsOutput> GetBusinessUnitStatistics(BusinessUnitStatisticsInput input)
183 { 321 {
184 try 322 try
@@ -189,37 +327,41 @@ namespace NCC.Extend.LqStatistics @@ -189,37 +327,41 @@ namespace NCC.Extend.LqStatistics
189 var parameters = new Dictionary<string, object> { { "@startDate", input.StartDate.ToString("yyyy-MM-dd 00:00:00") }, { "@endDate", input.EndDate.ToString("yyyy-MM-dd 23:59:59") } }; 327 var parameters = new Dictionary<string, object> { { "@startDate", input.StartDate.ToString("yyyy-MM-dd 00:00:00") }, { "@endDate", input.EndDate.ToString("yyyy-MM-dd 23:59:59") } };
190 328
191 // 构建WHERE条件 329 // 构建WHERE条件
192 - var whereClause = "WHERE (order_date >= @startDate AND order_date <= @endDate OR order_date IS NULL)";  
193 - 330 + var whereClause = "WHERE 1=1";
194 if (!string.IsNullOrEmpty(input.BusinessUnitId)) 331 if (!string.IsNullOrEmpty(input.BusinessUnitId))
195 { 332 {
196 - whereClause += " AND department_id = @businessUnitId"; 333 + whereClause += " AND dept.F_Id = @businessUnitId";
197 parameters.Add("@businessUnitId", input.BusinessUnitId); 334 parameters.Add("@businessUnitId", input.BusinessUnitId);
198 } 335 }
199 336
200 - // 构建SQL查询 337 + // 构建SQL查询 - 先查询所有事业部，然后左连接业绩数据
201 var sql = 338 var sql =
202 $@" 339 $@"
203 SELECT 340 SELECT
204 - department_id AS DepartmentId,  
205 - department_name AS DepartmentName,  
206 - parent_id AS ParentId,  
207 - parent_name AS ParentName,  
208 - SUM(COALESCE(target_amount, 0)) AS TotalTargetAmount,  
209 - SUM(COALESCE(actual_amount, 0)) AS TotalActualAmount,  
210 - COUNT(order_id) AS TotalOrderCount, 341 + dept.F_Id AS DepartmentId,
  342 + dept.F_FullName AS DepartmentName,
  343 + dept.F_ParentId AS ParentId,
  344 + parent.F_FullName AS ParentName,
  345 + COALESCE(SUM(flow.actual_amount), 0) AS TotalActualAmount,
  346 + COALESCE(COUNT(flow.order_id), 0) AS TotalOrderCount,
211 CASE 347 CASE
212 - WHEN SUM(COALESCE(target_amount, 0)) > 0  
213 - THEN ROUND((SUM(COALESCE(actual_amount, 0)) / SUM(COALESCE(target_amount, 0))) * 100, 2) 348 + WHEN COALESCE(SUM(flow.actual_amount), 0) > 0
  349 + THEN ROUND((COALESCE(SUM(flow.actual_amount), 0) / 100000) * 100, 2)
214 ELSE 0 350 ELSE 0
215 END AS CompletionRate 351 END AS CompletionRate
216 - FROM v_department_performance_flow  
217 - {whereClause} 352 + FROM base_organize dept
  353 + LEFT JOIN base_organize parent ON dept.F_ParentId = parent.F_Id
  354 + LEFT JOIN v_department_performance_flow flow ON dept.F_Id = flow.department_id
  355 + AND (flow.order_date >= @startDate AND flow.order_date <= @endDate OR flow.order_date IS NULL)
  356 + WHERE dept.F_ParentId = (SELECT F_Id FROM base_organize WHERE F_FullName = '事业部')
  357 + AND dept.F_EnabledMark = 1
  358 + AND dept.F_DeleteMark IS NULL
  359 + {whereClause.Replace("WHERE 1=1", "")}
218 GROUP BY 360 GROUP BY
219 - department_id,  
220 - department_name,  
221 - parent_id,  
222 - parent_name 361 + dept.F_Id,
  362 + dept.F_FullName,
  363 + dept.F_ParentId,
  364 + parent.F_FullName
223 ORDER BY TotalActualAmount DESC"; 365 ORDER BY TotalActualAmount DESC";
224 366
225 _logger.LogInformation("执行SQL查询：{Sql}", sql); 367 _logger.LogInformation("执行SQL查询：{Sql}", sql);
@@ -237,7 +379,7 @@ namespace NCC.Extend.LqStatistics @@ -237,7 +379,7 @@ namespace NCC.Extend.LqStatistics
237 DepartmentName = r.DepartmentName?.ToString() ?? "", 379 DepartmentName = r.DepartmentName?.ToString() ?? "",
238 ParentId = r.ParentId?.ToString() ?? "", 380 ParentId = r.ParentId?.ToString() ?? "",
239 ParentName = r.ParentName?.ToString() ?? "", 381 ParentName = r.ParentName?.ToString() ?? "",
240 - TotalTargetAmount = Convert.ToDecimal(r.TotalTargetAmount ?? 0), 382 + TotalTargetAmount = 100000, // 默认目标业绩10万
241 TotalActualAmount = Convert.ToDecimal(r.TotalActualAmount ?? 0), 383 TotalActualAmount = Convert.ToDecimal(r.TotalActualAmount ?? 0),
242 TotalOrderCount = Convert.ToInt32(r.TotalOrderCount ?? 0), 384 TotalOrderCount = Convert.ToInt32(r.TotalOrderCount ?? 0),
243 CompletionRate = Convert.ToDecimal(r.CompletionRate ?? 0), 385 CompletionRate = Convert.ToDecimal(r.CompletionRate ?? 0),
@@ -260,9 +402,40 @@ namespace NCC.Extend.LqStatistics @@ -260,9 +402,40 @@ namespace NCC.Extend.LqStatistics
260 /// <summary> 402 /// <summary>
261 /// 获取其他部门业绩统计 403 /// 获取其他部门业绩统计
262 /// </summary> 404 /// </summary>
  405 + /// <remarks>
  406 + /// 根据指定日期范围和部门ID查询其他部门（教育部、科技部、大项目部）的业绩统计信息
  407 + ///
  408 + /// 示例请求：
  409 + /// ```json
  410 + /// {
  411 + /// "startDate": "2025-01-01T00:00:00",
  412 + /// "endDate": "2025-01-31T23:59:59",
  413 + /// "departmentId": "部门ID（可选）"
  414 + /// }
  415 + /// ```
  416 + ///
  417 + /// 参数说明：
  418 + /// - startDate: 开始日期，格式：yyyy-MM-ddTHH:mm:ss
  419 + /// - endDate: 结束日期，格式：yyyy-MM-ddTHH:mm:ss
  420 + /// - departmentId: 部门ID，可选参数，不传则查询所有其他部门
  421 + ///
  422 + /// 返回数据说明：
  423 + /// - DepartmentId: 部门ID
  424 + /// - DepartmentName: 部门名称
  425 + /// - ParentId: 父部门ID
  426 + /// - ParentName: 父部门名称
  427 + /// - TotalTargetAmount: 目标业绩总和
  428 + /// - TotalActualAmount: 完成业绩总和
  429 + /// - TotalOrderCount: 开单总数量
  430 + /// - CompletionRate: 完成率（%）
  431 + /// </remarks>
263 /// <param name="input">查询参数</param> 432 /// <param name="input">查询参数</param>
264 /// <returns>其他部门业绩统计结果</returns> 433 /// <returns>其他部门业绩统计结果</returns>
  434 + /// <response code="200">成功返回其他部门业绩统计数据</response>
  435 + /// <response code="400">请求参数错误</response>
  436 + /// <response code="500">服务器内部错误</response>
265 [HttpPost("OtherDepartmentStatistics")] 437 [HttpPost("OtherDepartmentStatistics")]
  438 + [AllowAnonymous]
266 public async Task<OtherDepartmentStatisticsOutput> GetOtherDepartmentStatistics(OtherDepartmentStatisticsInput input) 439 public async Task<OtherDepartmentStatisticsOutput> GetOtherDepartmentStatistics(OtherDepartmentStatisticsInput input)
267 { 440 {
268 try 441 try
@@ -273,37 +446,41 @@ namespace NCC.Extend.LqStatistics @@ -273,37 +446,41 @@ namespace NCC.Extend.LqStatistics
273 var parameters = new Dictionary<string, object> { { "@startDate", input.StartDate.ToString("yyyy-MM-dd 00:00:00") }, { "@endDate", input.EndDate.ToString("yyyy-MM-dd 23:59:59") } }; 446 var parameters = new Dictionary<string, object> { { "@startDate", input.StartDate.ToString("yyyy-MM-dd 00:00:00") }, { "@endDate", input.EndDate.ToString("yyyy-MM-dd 23:59:59") } };
274 447
275 // 构建WHERE条件 448 // 构建WHERE条件
276 - var whereClause = "WHERE (order_date >= @startDate AND order_date <= @endDate OR order_date IS NULL)";  
277 - 449 + var whereClause = "WHERE 1=1";
278 if (!string.IsNullOrEmpty(input.DepartmentId)) 450 if (!string.IsNullOrEmpty(input.DepartmentId))
279 { 451 {
280 - whereClause += " AND department_id = @departmentId"; 452 + whereClause += " AND dept.F_Id = @departmentId";
281 parameters.Add("@departmentId", input.DepartmentId); 453 parameters.Add("@departmentId", input.DepartmentId);
282 } 454 }
283 455
284 - // 构建SQL查询 456 + // 构建SQL查询 - 先查询所有其他部门的子部门，然后左连接业绩数据
285 var sql = 457 var sql =
286 $@" 458 $@"
287 SELECT 459 SELECT
288 - department_id AS DepartmentId,  
289 - department_name AS DepartmentName,  
290 - parent_id AS ParentId,  
291 - parent_name AS ParentName,  
292 - SUM(COALESCE(target_amount, 0)) AS TotalTargetAmount,  
293 - SUM(COALESCE(actual_amount, 0)) AS TotalActualAmount,  
294 - COUNT(order_id) AS TotalOrderCount, 460 + dept.F_Id AS DepartmentId,
  461 + dept.F_FullName AS DepartmentName,
  462 + dept.F_ParentId AS ParentId,
  463 + parent.F_FullName AS ParentName,
  464 + COALESCE(SUM(flow.actual_amount), 0) AS TotalActualAmount,
  465 + COALESCE(COUNT(flow.order_id), 0) AS TotalOrderCount,
295 CASE 466 CASE
296 - WHEN SUM(COALESCE(target_amount, 0)) > 0  
297 - THEN ROUND((SUM(COALESCE(actual_amount, 0)) / SUM(COALESCE(target_amount, 0))) * 100, 2) 467 + WHEN COALESCE(SUM(flow.actual_amount), 0) > 0
  468 + THEN ROUND((COALESCE(SUM(flow.actual_amount), 0) / 50000) * 100, 2)
298 ELSE 0 469 ELSE 0
299 END AS CompletionRate 470 END AS CompletionRate
300 - FROM v_other_department_performance_flow  
301 - {whereClause} 471 + FROM base_organize dept
  472 + LEFT JOIN base_organize parent ON dept.F_ParentId = parent.F_Id
  473 + LEFT JOIN v_other_department_performance_flow flow ON dept.F_Id = flow.department_id
  474 + AND (flow.order_date >= @startDate AND flow.order_date <= @endDate OR flow.order_date IS NULL)
  475 + WHERE dept.F_ParentId IN (SELECT F_Id FROM base_organize WHERE F_FullName IN ('教育部', '科技部', '大项目部'))
  476 + AND dept.F_EnabledMark = 1
  477 + AND dept.F_DeleteMark IS NULL
  478 + {whereClause.Replace("WHERE 1=1", "")}
302 GROUP BY 479 GROUP BY
303 - department_id,  
304 - department_name,  
305 - parent_id,  
306 - parent_name 480 + dept.F_Id,
  481 + dept.F_FullName,
  482 + dept.F_ParentId,
  483 + parent.F_FullName
307 ORDER BY TotalActualAmount DESC"; 484 ORDER BY TotalActualAmount DESC";
308 485
309 _logger.LogInformation("执行SQL查询：{Sql}", sql); 486 _logger.LogInformation("执行SQL查询：{Sql}", sql);
@@ -321,7 +498,7 @@ namespace NCC.Extend.LqStatistics @@ -321,7 +498,7 @@ namespace NCC.Extend.LqStatistics
321 DepartmentName = r.DepartmentName?.ToString() ?? "", 498 DepartmentName = r.DepartmentName?.ToString() ?? "",
322 ParentId = r.ParentId?.ToString() ?? "", 499 ParentId = r.ParentId?.ToString() ?? "",
323 ParentName = r.ParentName?.ToString() ?? "", 500 ParentName = r.ParentName?.ToString() ?? "",
324 - TotalTargetAmount = Convert.ToDecimal(r.TotalTargetAmount ?? 0), 501 + TotalTargetAmount = 50000, // 默认目标业绩5万
325 TotalActualAmount = Convert.ToDecimal(r.TotalActualAmount ?? 0), 502 TotalActualAmount = Convert.ToDecimal(r.TotalActualAmount ?? 0),
326 TotalOrderCount = Convert.ToInt32(r.TotalOrderCount ?? 0), 503 TotalOrderCount = Convert.ToInt32(r.TotalOrderCount ?? 0),
327 CompletionRate = Convert.ToDecimal(r.CompletionRate ?? 0), 504 CompletionRate = Convert.ToDecimal(r.CompletionRate ?? 0),
@@ -344,9 +521,42 @@ namespace NCC.Extend.LqStatistics @@ -344,9 +521,42 @@ namespace NCC.Extend.LqStatistics
344 /// <summary> 521 /// <summary>
345 /// 获取经理业绩统计 522 /// 获取经理业绩统计
346 /// </summary> 523 /// </summary>
  524 + /// <remarks>
  525 + /// 根据指定日期范围和事业部ID查询经理的业绩统计信息，按经理和门店维度进行统计
  526 + ///
  527 + /// 示例请求：
  528 + /// ```json
  529 + /// {
  530 + /// "startDate": "2025-01-01T00:00:00",
  531 + /// "endDate": "2025-01-31T23:59:59",
  532 + /// "businessUnitId": "事业部ID（可选）"
  533 + /// }
  534 + /// ```
  535 + ///
  536 + /// 参数说明：
  537 + /// - startDate: 开始日期，格式：yyyy-MM-ddTHH:mm:ss
  538 + /// - endDate: 结束日期，格式：yyyy-MM-ddTHH:mm:ss
  539 + /// - businessUnitId: 事业部ID，可选参数，不传则查询所有事业部
  540 + ///
  541 + /// 返回数据说明：
  542 + /// - ManagerName: 经理姓名
  543 + /// - ManagerUserId: 经理用户ID
  544 + /// - BusinessUnitName: 事业部名称
  545 + /// - BusinessUnitId: 事业部ID
  546 + /// - StoreName: 门店名称
  547 + /// - StoreId: 门店ID
  548 + /// - TargetPerformance: 目标业绩
  549 + /// - ActualPerformance: 完成业绩
  550 + /// - OrderCount: 开单数量
  551 + /// - CompletionRate: 完成率（%）
  552 + /// </remarks>
347 /// <param name="input">查询参数</param> 553 /// <param name="input">查询参数</param>
348 /// <returns>经理业绩统计结果</returns> 554 /// <returns>经理业绩统计结果</returns>
  555 + /// <response code="200">成功返回经理业绩统计数据</response>
  556 + /// <response code="400">请求参数错误</response>
  557 + /// <response code="500">服务器内部错误</response>
349 [HttpPost("ManagerStatistics")] 558 [HttpPost("ManagerStatistics")]
  559 + [AllowAnonymous]
350 public async Task<ManagerStatisticsOutput> GetManagerStatistics(ManagerStatisticsInput input) 560 public async Task<ManagerStatisticsOutput> GetManagerStatistics(ManagerStatisticsInput input)
351 { 561 {
352 try 562 try
@@ -471,6 +681,7 @@ namespace NCC.Extend.LqStatistics @@ -471,6 +681,7 @@ namespace NCC.Extend.LqStatistics
471 /// <response code="400">请求参数错误</response> 681 /// <response code="400">请求参数错误</response>
472 /// <response code="500">服务器内部错误</response> 682 /// <response code="500">服务器内部错误</response>
473 [HttpPost("ManagerSummaryStatistics")] 683 [HttpPost("ManagerSummaryStatistics")]
  684 + [AllowAnonymous]
474 public async Task<ManagerSummaryStatisticsOutput> GetManagerSummaryStatistics(ManagerStatisticsInput input) 685 public async Task<ManagerSummaryStatisticsOutput> GetManagerSummaryStatistics(ManagerStatisticsInput input)
475 { 686 {
476 try 687 try
@@ -593,6 +804,243 @@ namespace NCC.Extend.LqStatistics @@ -593,6 +804,243 @@ namespace NCC.Extend.LqStatistics
593 } 804 }
594 } 805 }
595 #endregion 806 #endregion
  807 +
  808 + #region 科技部老师业绩统计
  809 + /// <summary>
  810 + /// 获取科技部老师业绩统计
  811 + /// </summary>
  812 + /// <param name="input">查询参数</param>
  813 + /// <returns>科技部老师业绩统计结果</returns>
  814 + [HttpPost("GetTechTeacherStatistics")]
  815 + [AllowAnonymous]
  816 + public async Task<List<TechTeacherSimpleStatisticsOutput>> GetTechTeacherStatistics(TechTeacherStatisticsInput input)
  817 + {
  818 + try
  819 + { // 1. 从用户表获取所有科技部老师
  820 + var allTeachers = await _db.Queryable<UserEntity>()
  821 + .Where(x => x.Gw == "科技老师")
  822 + .Select(x => new
  823 + {
  824 + TeacherId = x.Id,
  825 + TeacherName = x.RealName,
  826 + TeacherAccount = x.Account,
  827 + })
  828 + .ToListAsync();
  829 +
  830 + // 2. 获取业绩流水数据
  831 + var flowQuery = _db.Queryable<VTechTeacherFlowEntity>();
  832 +
  833 + // 老师过滤
  834 + if (!string.IsNullOrEmpty(input.TeacherId))
  835 + {
  836 + flowQuery = flowQuery.Where(x => x.TeacherId == input.TeacherId);
  837 + }
  838 +
  839 + if (!string.IsNullOrEmpty(input.TeacherName))
  840 + {
  841 + flowQuery = flowQuery.Where(x => x.TeacherName.Contains(input.TeacherName));
  842 + }
  843 +
  844 + // 日期过滤
  845 + if (input.StartDate.HasValue)
  846 + {
  847 + flowQuery = flowQuery.Where(x => x.BusinessDate >= input.StartDate.Value);
  848 + }
  849 +
  850 + if (input.EndDate.HasValue)
  851 + {
  852 + flowQuery = flowQuery.Where(x => x.BusinessDate <= input.EndDate.Value);
  853 + }
  854 +
  855 + var flowRecords = await flowQuery.ToListAsync();
  856 +
  857 + // 3. 按老师分组统计业绩数据
  858 + var teacherStatsDict = flowRecords
  859 + .GroupBy(x => new
  860 + {
  861 + x.TeacherId,
  862 + x.TeacherName,
  863 + x.TeacherAccount,
  864 + })
  865 + .ToDictionary(
  866 + g => g.Key,
  867 + g => new
  868 + {
  869 + ConsumeProjectCount = (int)g.Where(x => x.BusinessType == "耗卡").Sum(x => x.ProjectCount),
  870 + ConsumeAchievement = g.Where(x => x.BusinessType == "耗卡").Sum(x => x.Achievement),
  871 + OrderAchievement = g.Where(x => x.BusinessType == "开卡").Sum(x => x.Achievement),
  872 + OrderItemCount = g.Where(x => x.BusinessType == "开卡").Sum(x => x.ItemCount),
  873 + ConsumeItemCount = g.Where(x => x.BusinessType == "耗卡").Sum(x => x.ItemCount),
  874 + }
  875 + );
  876 +
  877 + // 4. 构建结果，包含所有老师
  878 + var result = new List<TechTeacherSimpleStatisticsOutput>();
  879 +
  880 + foreach (var teacher in allTeachers)
  881 + {
  882 + // 应用过滤条件
  883 + if (!string.IsNullOrEmpty(input.TeacherId) && teacher.TeacherId != input.TeacherId)
  884 + continue;
  885 +
  886 + if (!string.IsNullOrEmpty(input.TeacherName) && !teacher.TeacherName.Contains(input.TeacherName))
  887 + continue;
  888 +
  889 + var stats = teacherStatsDict.GetValueOrDefault(
  890 + new
  891 + {
  892 + TeacherId = teacher.TeacherId,
  893 + TeacherName = teacher.TeacherName,
  894 + TeacherAccount = teacher.TeacherAccount,
  895 + },
  896 + new
  897 + {
  898 + ConsumeProjectCount = 0,
  899 + ConsumeAchievement = 0m,
  900 + OrderAchievement = 0m,
  901 + OrderItemCount = 0,
  902 + ConsumeItemCount = 0,
  903 + }
  904 + );
  905 +
  906 + var teacherStats = new TechTeacherSimpleStatisticsOutput
  907 + {
  908 + DepartmentName = "科技部", // 固定为科技部
  909 + TeacherName = teacher.TeacherName,
  910 + ConsumeProjectCount = stats.ConsumeProjectCount,
  911 + ConsumeAchievement = stats.ConsumeAchievement,
  912 + OrderAchievement = stats.OrderAchievement,
  913 + OrderItemCount = stats.OrderItemCount,
  914 + ConsumeItemCount = stats.ConsumeItemCount,
  915 + };
  916 +
  917 + result.Add(teacherStats);
  918 + }
  919 +
  920 + return result;
  921 + }
  922 + catch (Exception ex)
  923 + {
  924 + _logger.LogError(ex, "获取科技部老师业绩统计时发生错误");
  925 + throw NCCException.Oh("获取科技部老师业绩统计失败", ex);
  926 + }
  927 + }
  928 +
  929 + #endregion
  930 +
  931 + #region 匿名接口
  932 +
  933 + /// <summary>
  934 + /// 发送每日统计消息（匿名接口）
  935 + /// </summary>
  936 + /// <returns>发送结果</returns>
  937 + [HttpPost("SendDailyReportMessage")]
  938 + [AllowAnonymous]
  939 + public async Task<object> SendDailyReportMessage()
  940 + {
  941 + try
  942 + {
  943 + // 获取本月全门店统计数据
  944 + var monthlyStats = await GetMonthlyStoreStatistics();
  945 +
  946 + // 构建包含统计数据的消息
  947 + var messageContent =
  948 + $"📊 今日日报已生成，点击链接查看\n\n"
  949 + + $"本月全门店目标业绩：{monthlyStats.TargetPerformance:N0}元\n"
  950 + + $"本月已完成业绩：{monthlyStats.ActualPerformance:N0}元\n"
  951 + + $"完成率：{monthlyStats.CompletionRate:F2}%\n\n"
  952 + + $"http://lvqian.antissoft.com/html/dailyReportnew.html";
  953 +
  954 + var result = await _weChatBotService.SendTextMessage(messageContent);
  955 + return new
  956 + {
  957 + success = result,
  958 + message = result ? "每日统计消息发送成功" : "每日统计消息发送失败",
  959 + timestamp = DateTime.Now,
  960 + statistics = monthlyStats,
  961 + };
  962 + }
  963 + catch (Exception ex)
  964 + {
  965 + _logger.LogError(ex, "发送每日统计消息时发生错误");
  966 + return new
  967 + {
  968 + success = false,
  969 + message = "发送每日统计消息时发生错误: " + ex.Message,
  970 + timestamp = DateTime.Now,
  971 + };
  972 + }
  973 + }
  974 +
  975 + /// <summary>
  976 + /// 获取本月全门店统计数据
  977 + /// </summary>
  978 + /// <returns>本月统计数据</returns>
  979 + private async Task<dynamic> GetMonthlyStoreStatistics()
  980 + {
  981 + try
  982 + {
  983 + // 获取本月开始和结束日期
  984 + var now = DateTime.Now;
  985 + var startDate = new DateTime(now.Year, now.Month, 1);
  986 + var endDate = startDate.AddMonths(1).AddDays(-1);
  987 +
  988 + // 构建查询参数
  989 + var parameters = new Dictionary<string, object> { { "@startDate", startDate.ToString("yyyy-MM-dd 00:00:00") }, { "@endDate", endDate.ToString("yyyy-MM-dd 23:59:59") } };
  990 +
  991 + // 查询本月全门店统计数据
  992 + var sql =
  993 + @"
  994 + SELECT
  995 + SUM(target_performance) AS TotalTargetPerformance,
  996 + SUM(actual_performance) AS TotalActualPerformance,
  997 + CASE
  998 + WHEN SUM(target_performance) > 0
  999 + THEN (SUM(actual_performance) / SUM(target_performance)) * 100
  1000 + ELSE 0
  1001 + END AS TotalCompletionRate
  1002 + FROM v_store_performance_simple";
  1003 +
  1004 + var result = await _db.Ado.SqlQueryAsync<dynamic>(sql, parameters);
  1005 + var stats = result.FirstOrDefault();
  1006 +
  1007 + if (stats != null)
  1008 + {
  1009 + var targetPerformance = Convert.ToDecimal(stats.TotalTargetPerformance ?? 0);
  1010 + var actualPerformance = Convert.ToDecimal(stats.TotalActualPerformance ?? 0);
  1011 + var completionRate = Convert.ToDecimal(stats.TotalCompletionRate ?? 0);
  1012 +
  1013 + return new
  1014 + {
  1015 + TargetPerformance = targetPerformance,
  1016 + ActualPerformance = actualPerformance,
  1017 + CompletionRate = completionRate,
  1018 + Month = now.ToString("yyyy年MM月"),
  1019 + };
  1020 + }
  1021 +
  1022 + return new
  1023 + {
  1024 + TargetPerformance = 0m,
  1025 + ActualPerformance = 0m,
  1026 + CompletionRate = 0m,
  1027 + Month = now.ToString("yyyy年MM月"),
  1028 + };
  1029 + }
  1030 + catch (Exception ex)
  1031 + {
  1032 + _logger.LogError(ex, "获取本月全门店统计数据时发生错误");
  1033 + return new
  1034 + {
  1035 + TargetPerformance = 0m,
  1036 + ActualPerformance = 0m,
  1037 + CompletionRate = 0m,
  1038 + Month = DateTime.Now.ToString("yyyy年MM月"),
  1039 + };
  1040 + }
  1041 + }
  1042 +
  1043 + #endregion
596 } 1044 }
597 1045
598 /// <summary> 1046 /// <summary>
netcore/src/Modularity/Extend/NCC.Extend/Utils/WeChatBotService.cs
  View file @d57a2bd
@@ -34,14 +34,14 @@ namespace NCC.Extend.Utils @@ -34,14 +34,14 @@ namespace NCC.Extend.Utils
34 webhookUrl = WEBHOOK_URL, 34 webhookUrl = WEBHOOK_URL,
35 content = content, 35 content = content,
36 mentionedList = (string)null, 36 mentionedList = (string)null,
37 - mentionedMobileList = (string)null 37 + mentionedMobileList = (string)null,
38 }; 38 };
39 39
40 var json = JsonConvert.SerializeObject(requestData); 40 var json = JsonConvert.SerializeObject(requestData);
41 var httpContent = new StringContent(json, Encoding.UTF8, "application/json"); 41 var httpContent = new StringContent(json, Encoding.UTF8, "application/json");
42 42
43 var response = await _httpClient.PostAsync(BOT_API_URL, httpContent); 43 var response = await _httpClient.PostAsync(BOT_API_URL, httpContent);
44 - 44 +
45 if (response.IsSuccessStatusCode) 45 if (response.IsSuccessStatusCode)
46 { 46 {
47 var responseContent = await response.Content.ReadAsStringAsync(); 47 var responseContent = await response.Content.ReadAsStringAsync();
@@ -77,8 +77,28 @@ namespace NCC.Extend.Utils @@ -77,8 +77,28 @@ namespace NCC.Extend.Utils
77 77
78 // 添加标题和格式化 78 // 添加标题和格式化
79 var messageContent = $"🎉 新开单记录\n\n{orderRecordString}"; 79 var messageContent = $"🎉 新开单记录\n\n{orderRecordString}";
80 -  
81 return await SendTextMessage(messageContent); 80 return await SendTextMessage(messageContent);
82 } 81 }
  82 +
  83 + /// <summary>
  84 + /// 发送每日统计消息
  85 + /// </summary>
  86 + /// <returns>发送结果</returns>
  87 + public async Task<bool> SendDailyReportMessage()
  88 + {
  89 + try
  90 + {
  91 + var reportUrl = "http://lvqian.antissoft.com/html/dailyReportnew.html";
  92 + var messageContent = $"📊 今日日报已生成，点击链接查看\n\n{reportUrl}";
  93 +
  94 + Console.WriteLine("发送每日统计消息...");
  95 + return await SendTextMessage(messageContent);
  96 + }
  97 + catch (Exception ex)
  98 + {
  99 + Console.WriteLine($"发送每日统计消息异常: {ex.Message}");
  100 + return false;
  101 + }
  102 + }
83 } 103 }
84 } 104 }
创建经理门店业绩统计视图.sql deleted
View file @d29c3bb
1 --- 创建经理门店业绩统计视图  
2 --- 融合经理信息、管理门店、生命线设置、业绩流水数据  
3 -  
4 -DROP VIEW IF EXISTS `v_manager_store_performance`;  
5 -  
6 -CREATE VIEW `v_manager_store_performance` AS  
7 -SELECT  
8 - -- 经理基础信息  
9 - u.F_Id AS manager_user_id, -- 经理用户ID  
10 - u.F_REALNAME AS manager_name, -- 经理姓名  
11 - u.F_GW AS manager_position, -- 经理岗位  
12 - u.F_ORGANIZEID AS manager_organize_id, -- 经理组织ID  
13 -  
14 - -- 事业部信息  
15 - o.F_Id AS business_unit_id, -- 事业部ID  
16 - o.F_FullName AS business_unit_name, -- 事业部名称  
17 - o.F_ParentId AS parent_organize_id, -- 上级组织ID  
18 - parent.F_FullName AS parent_organize_name, -- 上级组织名称  
19 -  
20 - -- 门店信息  
21 - md.F_Id AS store_id, -- 门店ID  
22 - md.mdbm AS store_code, -- 门店编号  
23 - md.dm AS store_name, -- 门店名称  
24 - md.syb AS store_business_unit_id, -- 门店所属事业部ID  
25 -  
26 - -- 生命线设置信息  
27 - COALESCE(zjl.smx1, 0) AS target_performance, -- 目标业绩（生命线1）  
28 - zjl.tcbl1 AS commission_rate1, -- 生命线1提成比例  
29 - zjl.smx2 AS target_performance2, -- 目标业绩2（生命线2）  
30 - zjl.tcbl2 AS commission_rate2, -- 生命线2提成比例  
31 - zjl.smx3 AS target_performance3, -- 目标业绩3（生命线3）  
32 - zjl.tcbl3 AS commission_rate3, -- 生命线3提成比例  
33 -  
34 - -- 业绩流水信息（从现有视图获取）  
35 - flow.order_id, -- 开单ID  
36 - flow.order_date, -- 开单时间  
37 - flow.completed_amount, -- 完成业绩（整单业绩）  
38 - flow.actual_amount, -- 实付业绩  
39 - flow.debt_amount, -- 欠款  
40 - flow.completion_rate, -- 完成率  
41 - flow.golden_triangle, -- 金三角  
42 - flow.member_id, -- 开单会员ID  
43 - flow.member_name, -- 开单会员名称  
44 - flow.member_phone, -- 开单会员手机号  
45 - flow.customer_type, -- 顾客类型  
46 - flow.payment_method, -- 付款方式  
47 - flow.customer_source, -- 客户来源  
48 -  
49 - -- 时间维度  
50 - flow.order_year, -- 开单年份  
51 - flow.order_month, -- 开单月份  
52 - flow.order_quarter, -- 开单季度  
53 - flow.order_date_only, -- 开单日期（不含时间）  
54 -  
55 - -- 统计标识  
56 - CASE  
57 - WHEN flow.order_id IS NOT NULL THEN 1  
58 - ELSE 0  
59 - END AS has_performance, -- 是否有业绩记录  
60 -  
61 - -- 创建时间  
62 - COALESCE(flow.create_time, NOW()) AS create_time,  
63 - COALESCE(flow.modify_time, NOW()) AS modify_time  
64 -  
65 -FROM base_user u  
66 --- 关联组织信息  
67 -LEFT JOIN base_organize o ON u.F_ORGANIZEID = o.F_Id  
68 -LEFT JOIN base_organize parent ON o.F_ParentId = parent.F_Id  
69 --- 关联门店信息（通过事业部关联）  
70 -LEFT JOIN lq_mdxx md ON md.syb = o.F_Id  
71 --- 关联生命线设置  
72 -LEFT JOIN lq_zjl_mdsmxsz zjl ON zjl.zjl_userid = u.F_Id  
73 - AND zjl.md_id = md.F_Id  
74 - AND zjl.deletemark = 0  
75 --- 关联业绩流水（从现有视图）  
76 -LEFT JOIN v_department_performance_flow flow ON flow.store_id = md.F_Id  
77 - AND flow.department_id = o.F_Id  
78 -  
79 -WHERE u.F_DELETEMARK IS NULL -- 用户未删除  
80 - AND u.F_GW IS NOT NULL -- 有岗位信息  
81 - AND (u.F_GW LIKE '%经理%' OR u.F_GW LIKE '%总经理%' OR u.F_GW LIKE '%主管%') -- 经理岗位  
82 - AND o.F_Category = 'department' -- 部门类型  
83 - AND (o.F_DeleteMark IS NULL OR o.F_DeleteMark != 1) -- 组织未删除  
84 - AND md.F_Id IS NOT NULL; -- 有门店信息  
85 -  
86 --- 添加视图注释  
87 ---ALTER VIEW `v_manager_store_performance` COMMENT = '经理门店业绩统计视图 - 融合经理信息、管理门店、生命线设置、业绩流水数据';  
创建退卡相关表.sql deleted
View file @d29c3bb
1 --- =============================================  
2 --- 绿纤美业ERP系统 - 退卡相关表创建脚本  
3 --- 创建时间: 2025-01-27  
4 --- 说明: 创建会员退卡主表、明细表、业绩表  
5 --- =============================================  
6 -  
7 --- 1. 创建会员退卡主表  
8 -DROP TABLE IF EXISTS `lq_hytk_hytk`;  
9 -CREATE TABLE `lq_hytk_hytk` (  
10 - `F_Id` varchar(50) NOT NULL COMMENT '退卡编号',  
11 - `md` varchar(50) DEFAULT NULL COMMENT '门店',  
12 - `mdbh` varchar(50) DEFAULT NULL COMMENT '门店编号',  
13 - `mdmc` varchar(50) DEFAULT NULL COMMENT '门店名称',  
14 - `hy` varchar(50) DEFAULT NULL COMMENT '会员',  
15 - `hyzh` varchar(50) DEFAULT NULL COMMENT '会员账号',  
16 - `hymc` varchar(50) DEFAULT NULL COMMENT '会员名称',  
17 - `gklx` varchar(50) DEFAULT NULL COMMENT '顾客类型',  
18 - `tkje` decimal(15,2) DEFAULT NULL COMMENT '退卡总金额',  
19 - `sgfy` decimal(15,2) DEFAULT NULL COMMENT '手工费用',  
20 - `bz` text COMMENT '备注',  
21 - `tksj` datetime DEFAULT NULL COMMENT '退卡时间',  
22 - `czry` varchar(50) DEFAULT NULL COMMENT '操作人员',  
23 - `tkzt` varchar(20) DEFAULT NULL COMMENT '退卡状态',  
24 - `tkyy` varchar(200) DEFAULT NULL COMMENT '退卡原因',  
25 - `F_CreateTime` datetime DEFAULT NULL COMMENT '创建时间',  
26 - `F_CreateUser` varchar(50) DEFAULT NULL COMMENT '创建用户',  
27 - `F_ModifyTime` datetime DEFAULT NULL COMMENT '修改时间',  
28 - `F_ModifyUser` varchar(50) DEFAULT NULL COMMENT '修改用户',  
29 - `F_DeleteMark` int(1) DEFAULT NULL COMMENT '删除标记',  
30 - PRIMARY KEY (`F_Id`),  
31 - KEY `idx_md` (`md`),  
32 - KEY `idx_hy` (`hy`),  
33 - KEY `idx_tksj` (`tksj`),  
34 - KEY `idx_tkzt` (`tkzt`)  
35 -) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='退卡_信息表';  
36 -  
37 --- 2. 创建会员退卡明细表  
38 -DROP TABLE IF EXISTS `lq_hytk_mx`;  
39 -CREATE TABLE `lq_hytk_mx` (  
40 - `F_Id` varchar(50) NOT NULL COMMENT '明细编号',  
41 - `gltkbh` varchar(50) DEFAULT NULL COMMENT '关联退卡编号',  
42 - `px` varchar(50) DEFAULT NULL COMMENT '品项',  
43 - `pxmc` varchar(100) DEFAULT NULL COMMENT '品项名称',  
44 - `pxjg` decimal(15,2) DEFAULT NULL COMMENT '品项价格',  
45 - `tkje` decimal(15,2) DEFAULT NULL COMMENT '退款金额',  
46 - `F_ProjectNumber` int DEFAULT NULL COMMENT '项目次数',  
47 - `F_IsEnabled` int(1) DEFAULT NULL COMMENT '是否有效',  
48 - `F_SourceType` varchar(20) DEFAULT NULL COMMENT '来源类型',  
49 - `F_TotalPrice` decimal(15,2) DEFAULT NULL COMMENT '合计金额',  
50 - `F_CreateTime` datetime DEFAULT NULL COMMENT '创建时间',  
51 - `F_CreateUser` varchar(50) DEFAULT NULL COMMENT '创建用户',  
52 - `F_ModifyTime` datetime DEFAULT NULL COMMENT '修改时间',  
53 - `F_ModifyUser` varchar(50) DEFAULT NULL COMMENT '修改用户',  
54 - `F_DeleteMark` int(1) DEFAULT NULL COMMENT '删除标记',  
55 - PRIMARY KEY (`F_Id`),  
56 - KEY `idx_gltkbh` (`gltkbh`),  
57 - KEY `idx_px` (`px`),  
58 - KEY `idx_F_SourceType` (`F_SourceType`)  
59 -) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='退卡_品项明细表';  
60 -  
61 --- 3. 创建退卡健康师业绩表  
62 -DROP TABLE IF EXISTS `lq_hytk_jksyj`;  
63 -CREATE TABLE `lq_hytk_jksyj` (  
64 - `F_Id` varchar(50) NOT NULL COMMENT '业绩编号',  
65 - `gltkbh` varchar(50) DEFAULT NULL COMMENT '关联退卡编号',  
66 - `jks` varchar(50) DEFAULT NULL COMMENT '健康师',  
67 - `jksxm` varchar(50) DEFAULT NULL COMMENT '健康师姓名',  
68 - `jkszh` varchar(50) DEFAULT NULL COMMENT '健康师账号',  
69 - `jksyj` decimal(15,2) DEFAULT NULL COMMENT '健康师业绩',  
70 - `tksj` datetime DEFAULT NULL COMMENT '退卡时间',  
71 - `F_jsjid` varchar(50) DEFAULT NULL COMMENT '金三角id',  
72 - `F_tkpxid` varchar(50) DEFAULT NULL COMMENT '关联项目资料表ID',  
73 - `F_LaborCost` decimal(15,2) DEFAULT NULL COMMENT '手工费',  
74 - `F_tkpxNumber` decimal(15,2) DEFAULT NULL COMMENT '退卡品项次数',  
75 - `F_CreateTime` datetime DEFAULT NULL COMMENT '创建时间',  
76 - `F_CreateUser` varchar(50) DEFAULT NULL COMMENT '创建用户',  
77 - `F_ModifyTime` datetime DEFAULT NULL COMMENT '修改时间',  
78 - `F_ModifyUser` varchar(50) DEFAULT NULL COMMENT '修改用户',  
79 - `F_DeleteMark` int(1) DEFAULT NULL COMMENT '删除标记',  
80 - PRIMARY KEY (`F_Id`),  
81 - KEY `idx_gltkbh` (`gltkbh`),  
82 - KEY `idx_jks` (`jks`),  
83 - KEY `idx_F_tkpxid` (`F_tkpxid`),  
84 - KEY `idx_tksj` (`tksj`)  
85 -) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='退卡_健康师业绩表';  
86 -  
87 --- 4. 创建退卡科技部老师业绩表  
88 -DROP TABLE IF EXISTS `lq_hytk_kjbsyj`;  
89 -CREATE TABLE `lq_hytk_kjbsyj` (  
90 - `F_Id` varchar(50) NOT NULL COMMENT '业绩编号',  
91 - `gltkbh` varchar(50) DEFAULT NULL COMMENT '关联退卡编号',  
92 - `kjbls` varchar(50) DEFAULT NULL COMMENT '科技部老师',  
93 - `kjblsxm` varchar(50) DEFAULT NULL COMMENT '科技部老师姓名',  
94 - `kjblszh` varchar(50) DEFAULT NULL COMMENT '科技部老师账号',  
95 - `kjblsyj` decimal(15,2) DEFAULT NULL COMMENT '科技部老师业绩',  
96 - `tksj` datetime DEFAULT NULL COMMENT '退卡时间',  
97 - `F_tkpxid` varchar(50) DEFAULT NULL COMMENT '关联项目资料表ID',  
98 - `F_LaborCost` decimal(15,2) DEFAULT NULL COMMENT '手工费',  
99 - `F_tkpxNumber` decimal(15,2) DEFAULT NULL COMMENT '退卡品项次数',  
100 - `F_CreateTime` datetime DEFAULT NULL COMMENT '创建时间',  
101 - `F_CreateUser` varchar(50) DEFAULT NULL COMMENT '创建用户',  
102 - `F_ModifyTime` datetime DEFAULT NULL COMMENT '修改时间',  
103 - `F_ModifyUser` varchar(50) DEFAULT NULL COMMENT '修改用户',  
104 - `F_DeleteMark` int(1) DEFAULT NULL COMMENT '删除标记',  
105 - PRIMARY KEY (`F_Id`),  
106 - KEY `idx_gltkbh` (`gltkbh`),  
107 - KEY `idx_kjbls` (`kjbls`),  
108 - KEY `idx_F_tkpxid` (`F_tkpxid`),  
109 - KEY `idx_tksj` (`tksj`)  
110 -) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='退卡_科技部老师业绩表';  
111 -  
112 --- =============================================  
113 --- 添加外键约束（可选）  
114 --- =============================================  
115 -  
116 --- 退卡明细表外键约束  
117 --- ALTER TABLE `lq_hytk_mx` ADD CONSTRAINT `fk_hytk_mx_gltkbh` FOREIGN KEY (`gltkbh`) REFERENCES `lq_hytk_hytk` (`F_Id`) ON DELETE CASCADE ON UPDATE CASCADE;  
118 -  
119 --- 退卡健康师业绩表外键约束  
120 --- ALTER TABLE `lq_hytk_jksyj` ADD CONSTRAINT `fk_hytk_jksyj_gltkbh` FOREIGN KEY (`gltkbh`) REFERENCES `lq_hytk_hytk` (`F_Id`) ON DELETE CASCADE ON UPDATE CASCADE;  
121 --- ALTER TABLE `lq_hytk_jksyj` ADD CONSTRAINT `fk_hytk_jksyj_tkpxid` FOREIGN KEY (`F_tkpxid`) REFERENCES `lq_xmzl` (`F_Id`) ON DELETE CASCADE ON UPDATE CASCADE;  
122 -  
123 --- 退卡科技部老师业绩表外键约束  
124 --- ALTER TABLE `lq_hytk_kjbsyj` ADD CONSTRAINT `fk_hytk_kjbsyj_gltkbh` FOREIGN KEY (`gltkbh`) REFERENCES `lq_hytk_hytk` (`F_Id`) ON DELETE CASCADE ON UPDATE CASCADE;  
125 --- ALTER TABLE `lq_hytk_kjbsyj` ADD CONSTRAINT `fk_hytk_kjbsyj_tkpxid` FOREIGN KEY (`F_tkpxid`) REFERENCES `lq_xmzl` (`F_Id`) ON DELETE CASCADE ON UPDATE CASCADE;  
126 -  
127 --- =============================================  
128 --- 创建完成提示  
129 --- =============================================  
130 -SELECT '退卡相关表创建完成！' AS '创建结果';