84 lines
3.5 KiB
Java
84 lines
3.5 KiB
Java
package com.rj.mapper;
|
||
|
||
import com.rj.entity.CustomerManagementStatistics;
|
||
import com.baomidou.mybatisplus.annotation.InterceptorIgnore;
|
||
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
|
||
import org.apache.ibatis.annotations.Mapper;
|
||
import org.apache.ibatis.annotations.Param;
|
||
import org.apache.ibatis.annotations.Select;
|
||
|
||
import java.time.LocalDate;
|
||
import java.util.List;
|
||
import java.util.Map;
|
||
|
||
/**
|
||
* <p>
|
||
* 客户统计表 Mapper 接口
|
||
* </p>
|
||
*
|
||
* @author 李中华 ,spllzh
|
||
* @since 2025-08-07
|
||
*/
|
||
@Mapper
|
||
public interface CustomerManagementStatisticsMapper extends BaseMapper<CustomerManagementStatistics> {
|
||
|
||
/**
|
||
* 按租户、经销商、项目、销售统计指定日期的客户数据
|
||
* 每天生成一条记录（按租户、经销商、项目、销售分组）
|
||
*
|
||
* <p>注意：此方法需要跳过多租户拦截器，因为SQL中已经手动通过 cm2.tenant_id = cm.tenant_id 等条件
|
||
* 处理了租户关联，不需要拦截器再自动添加 tenant_id 条件。</p>
|
||
*
|
||
* @param date 统计日期
|
||
* @return 统计结果列表，包含tenant_id, dealership_id, dealership_name, project_id, project_name, sales_id, sales_name, count_by_dealership, count_by_sales, count_by_project
|
||
*/
|
||
@InterceptorIgnore(tenantLine = "true")
|
||
@Select("SELECT " +
|
||
"cm.tenant_id, " +
|
||
"cm.dealership_id, " +
|
||
"cm.dealership_name, " +
|
||
"COALESCE(sm.project_id, '') as project_id, " +
|
||
"COALESCE(sm.project_name, '') as project_name, " +
|
||
"cm.sales_id, " +
|
||
"cm.sales_name, " +
|
||
"(SELECT COUNT(*) FROM customer_management cm2 " +
|
||
" WHERE cm2.dealership_id = cm.dealership_id " +
|
||
" AND DATE(cm2.create_time) = #{date} " +
|
||
" AND cm2.tenant_id = cm.tenant_id) as count_by_dealership, " +
|
||
"(SELECT COUNT(*) FROM customer_management cm3 " +
|
||
" WHERE cm3.sales_id = cm.sales_id " +
|
||
" AND DATE(cm3.create_time) = #{date} " +
|
||
" AND cm3.tenant_id = cm.tenant_id) as count_by_sales, " +
|
||
"(SELECT COUNT(*) FROM customer_management cm4 " +
|
||
" LEFT JOIN sales_management sm4 ON cm4.sales_id = sm4.id " +
|
||
" WHERE sm4.project_id = COALESCE(sm.project_id, '') " +
|
||
" AND DATE(cm4.create_time) = #{date} " +
|
||
" AND cm4.tenant_id = cm.tenant_id " +
|
||
" AND COALESCE(sm.project_id, '') != '') as count_by_project " +
|
||
"FROM customer_management cm " +
|
||
"LEFT JOIN sales_management sm ON cm.sales_id = sm.id " +
|
||
"WHERE DATE(cm.create_time) = #{date} " +
|
||
"AND cm.dealership_id IS NOT NULL " +
|
||
"AND cm.dealership_id != '' " +
|
||
"AND cm.sales_id IS NOT NULL " +
|
||
"AND cm.sales_id != '' " +
|
||
"GROUP BY cm.tenant_id, cm.dealership_id, cm.dealership_name, sm.project_id, sm.project_name, cm.sales_id, cm.sales_name")
|
||
List<Map<String, Object>> getStatisticsByDate(@Param("date") LocalDate date);
|
||
|
||
/**
|
||
* 检查指定日期的统计数据是否已存在
|
||
* @param date 统计日期
|
||
* @return 统计记录数量
|
||
*/
|
||
@Select("SELECT COUNT(*) FROM customer_management_statistics WHERE statistics_date = #{date}")
|
||
int countByStatisticsDate(@Param("date") LocalDate date);
|
||
|
||
/**
|
||
* 删除指定日期的统计数据
|
||
* @param date 统计日期
|
||
* @return 删除的记录数
|
||
*/
|
||
int deleteByStatisticsDate(@Param("date") LocalDate date);
|
||
}
|
||
|