数据统计

src/main/java/com/huiju/estateagents/job/CustomerStatisticTimeJob.java

 import com.huiju.estateagents.service.ITaShareRecordService;
 import com.huiju.estateagents.statistic.service.ITaCustomerGenderStatisticService;
 import com.huiju.estateagents.statistic.service.ITaCustomerStatisticDailyService;
+import com.huiju.estateagents.statistic.service.ITaCustomerStatisticMonthlyService;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
     
     @Autowired
     private ITaCustomerGenderStatisticService taCustomerGenderStatisticService;
+    
+    @Autowired
+    private ITaCustomerStatisticMonthlyService customerStatisticMonthlyService;
 
     /**
      *
     
         //每天的到访客户性别统计并入表
         taCustomerGenderStatisticService.visiteSexStatisticDaily(nowDate);
+    
+        //每月的新增客户统计并入表,但是每天都更新
+        customerStatisticMonthlyService.newCustomerStatisticMonthly(nowDate);
+    
+        //每月的跟进客户统计并入表,但是每天都更新
+        customerStatisticMonthlyService.followUpStatisticMonthly(nowDate);
+    
+        //每月的到访客户统计并入表,但是每天都更新
+        customerStatisticMonthlyService.visiteStatisticMonthly(nowDate);
     }
 
 }

src/main/java/com/huiju/estateagents/statistic/mapper/TaCustomerStatisticMonthlyMapper.java

 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.huiju.estateagents.statistic.entity.TaCustomerStatisticMonthly;
 import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.time.LocalDateTime;
+import java.util.List;
 
 /**
  * <p>
  */
 @Mapper
 public interface TaCustomerStatisticMonthlyMapper extends BaseMapper<TaCustomerStatisticMonthly> {
-
+	
+	/**
+	 * 获取一个月新增客户的数据插入
+	 * @param nowDate
+	 * @param status
+	 * @return
+	 */
+	List<TaCustomerStatisticMonthly> getNewCustomerStatisticMonthly(@Param("nowDate") LocalDateTime nowDate,@Param("status") int status);
+	
+	/**
+	 * 获取一个月跟进客户数据插入
+	 * @param nowDate
+	 * @return
+	 */
+	List<TaCustomerStatisticMonthly> getFollowUpStatisticMonthly(@Param("nowDate") LocalDateTime nowDate);
+	
+	/**
+	 * 获取一个月访问客户数据插入
+	 * @param nowDate
+	 * @param checkin
+	 * @return
+	 */
+	List<TaCustomerStatisticMonthly> getVisiteStatisticMonthly(@Param("nowDate") LocalDateTime nowDate,@Param("checkin") int checkin);
 }

src/main/java/com/huiju/estateagents/statistic/service/ITaCustomerStatisticMonthlyService.java

 import com.baomidou.mybatisplus.extension.service.IService;
 import com.huiju.estateagents.statistic.entity.TaCustomerStatisticMonthly;
 
+import java.time.LocalDateTime;
+
 /**
  * <p>
  * 客户分析月统计表 小程序盘客工具客户分析 服务类
  * @since 2019-11-08
  */
 public interface ITaCustomerStatisticMonthlyService extends IService<TaCustomerStatisticMonthly> {
-
+	
+	/**
+	 * 每月新增客户统计，每天都更新
+	 * @param nowDate
+	 */
+	void newCustomerStatisticMonthly(LocalDateTime nowDate);
+	
+	/**
+	 * 每月跟进客户统计，每天都更新
+	 * @param nowDate
+	 */
+	void followUpStatisticMonthly(LocalDateTime nowDate);
+	
+	/**
+	 * 每月访客客户统计，每天都更新
+	 * @param nowDate
+	 */
+	void visiteStatisticMonthly(LocalDateTime nowDate);
 }

src/main/java/com/huiju/estateagents/statistic/service/impl/TaCustomerGenderStatisticServiceImpl.java

 package com.huiju.estateagents.statistic.service.impl;
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
 import com.huiju.estateagents.common.CommConstant;
 import com.huiju.estateagents.statistic.entity.GenderStatistic;
 		//获取新增客户的男女性别比和性别数
 		List<GenderStatistic> newCustomerSexList = customerGenderStatisticMapper.getNewCustomerSexCount();
 		//批量保存
-		saveBatchCustomerSexData(newCustomerSexList,nowDate);
+		saveBatchCustomerSexData(newCustomerSexList,nowDate,CommConstant.CUSTOMER_TYPE_NEW);
 	}
 	
 	/**
 		//获取跟进客户的男女性别比和性别数
 		List<GenderStatistic> followUpSexList = customerGenderStatisticMapper.getFollowUpSexCount();
 		//批量保存
-		saveBatchCustomerSexData(followUpSexList,nowDate);
+		saveBatchCustomerSexData(followUpSexList,nowDate,CommConstant.CUSTOMER_TYPE_FOLLOW);
 	}
 	
 	/**
 			}
 		});
 		//批量保存
-		saveBatchCustomerSexData(newVisiteSexList,nowDate);
+		saveBatchCustomerSexData(newVisiteSexList,nowDate,CommConstant.CUSTOMER_TYPE_VISITE);
 	}
 	
 	/**
 	 * @param customerSexList
 	 * @param nowDate
 	 */
-	private void saveBatchCustomerSexData(List<GenderStatistic> customerSexList, LocalDateTime nowDate) {
+	private void saveBatchCustomerSexData(List<GenderStatistic> customerSexList, LocalDateTime nowDate,String customerType) {
+		//先删除在添加
+		QueryWrapper<TaCustomerGenderStatistic> queryWrapper = new QueryWrapper<>();
+		queryWrapper.eq("customer_type",customerType);
+		customerGenderStatisticMapper.delete(queryWrapper);
+		
 		List<TaCustomerGenderStatistic> list = new ArrayList<>();
 		//划分男女未知三条数据
 		customerSexList.forEach(e -> {
 			TaCustomerGenderStatistic maleCustomer = new TaCustomerGenderStatistic();
 			maleCustomer.setCreateDate(nowDate);
 			maleCustomer.setGenderType(CommConstant.SEX_MALE);
-			maleCustomer.setCustomerType(CommConstant.CUSTOMER_TYPE_NEW);
+			maleCustomer.setCustomerType(customerType);
 			maleCustomer.setCustomerNum(e.getManSum());
 			maleCustomer.setPercentage(e.getManPct());
 			maleCustomer.setOrgId(e.getOrgId());
 			TaCustomerGenderStatistic femaleCustomer = new TaCustomerGenderStatistic();
 			femaleCustomer.setCreateDate(nowDate);
 			femaleCustomer.setGenderType(CommConstant.SEX_FEMALE);
-			femaleCustomer.setCustomerType(CommConstant.CUSTOMER_TYPE_NEW);
+			femaleCustomer.setCustomerType(customerType);
 			femaleCustomer.setCustomerNum(e.getWomanSum());
 			femaleCustomer.setPercentage(e.getWomanPct());
 			femaleCustomer.setOrgId(e.getOrgId());
 			TaCustomerGenderStatistic unknownCustomer = new TaCustomerGenderStatistic();
 			unknownCustomer.setCreateDate(nowDate);
 			unknownCustomer.setGenderType(CommConstant.SEX_UNKNOWN);
-			unknownCustomer.setCustomerType(CommConstant.CUSTOMER_TYPE_NEW);
+			unknownCustomer.setCustomerType(customerType);
 			unknownCustomer.setCustomerNum(e.getUnknownSum());
 			unknownCustomer.setPercentage(e.getUnknownPct());
 			unknownCustomer.setOrgId(e.getOrgId());

src/main/java/com/huiju/estateagents/statistic/service/impl/TaCustomerStatisticMonthlyServiceImpl.java

 package com.huiju.estateagents.statistic.service.impl;
 
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.huiju.estateagents.common.CommConstant;
 import com.huiju.estateagents.statistic.entity.TaCustomerStatisticMonthly;
 import com.huiju.estateagents.statistic.mapper.TaCustomerStatisticMonthlyMapper;
 import com.huiju.estateagents.statistic.service.ITaCustomerStatisticMonthlyService;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
+import java.util.ArrayList;
+import java.util.List;
+
 /**
  * <p>
  * 客户分析月统计表 小程序盘客工具客户分析 服务实现类
  */
 @Service
 public class TaCustomerStatisticMonthlyServiceImpl extends ServiceImpl<TaCustomerStatisticMonthlyMapper, TaCustomerStatisticMonthly> implements ITaCustomerStatisticMonthlyService {
-
+	
+	@Autowired
+	private TaCustomerStatisticMonthlyMapper customerStatisticMonthlyMapper;
+	
+	/**
+	 * 每月新增客户统计，每天都更新
+	 *
+	 * @param nowDate
+	 */
+	@Override
+	public void newCustomerStatisticMonthly(LocalDateTime nowDate) {
+		//获取当月新增客户总数
+		List<TaCustomerStatisticMonthly> newCustomerMonthList = customerStatisticMonthlyMapper.getNewCustomerStatisticMonthly(nowDate,CommConstant.STATUS_NORMAL);
+		//批量插入
+		statisticMonthlySaveBatch(newCustomerMonthList,nowDate, CommConstant.CUSTOMER_TYPE_NEW);
+	}
+	
+	/**
+	 * 每月跟进客户统计，每天都更新
+	 *
+	 * @param nowDate
+	 */
+	@Override
+	public void followUpStatisticMonthly(LocalDateTime nowDate) {
+		//获取当月跟进客户总数
+		List<TaCustomerStatisticMonthly> followUpMonthList = customerStatisticMonthlyMapper.getFollowUpStatisticMonthly(nowDate);
+		statisticMonthlySaveBatch(followUpMonthList,nowDate, CommConstant.CUSTOMER_TYPE_FOLLOW);
+	}
+	
+	/**
+	 * 每月访客客户统计，每天都更新
+	 *
+	 * @param nowDate
+	 */
+	@Override
+	public void visiteStatisticMonthly(LocalDateTime nowDate) {
+		//获取当月访问客户总数
+		List<TaCustomerStatisticMonthly> visiteMonthList = customerStatisticMonthlyMapper.getVisiteStatisticMonthly(nowDate,CommConstant.STATUS_NORMAL);
+		List<TaCustomerStatisticMonthly> newVisiteMonthList = new ArrayList<>();
+		visiteMonthList.forEach(e -> {
+			if (null != e.getOrgId() && !e.getOrgId().equals("null")){
+				newVisiteMonthList.add(e);
+			}
+		});
+		statisticMonthlySaveBatch(newVisiteMonthList,nowDate, CommConstant.CUSTOMER_TYPE_FOLLOW);
+	}
+	
+	/**
+	 * 批量保存当月的统计数据
+	 * @param list
+	 * @param nowDate
+	 * @param customerType
+	 */
+	private void statisticMonthlySaveBatch(List<TaCustomerStatisticMonthly> list, LocalDateTime nowDate, String customerType) {
+		//格式化年月日
+		DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyyMM");
+		String todayDate = nowDate.format(formatter);
+		
+		//先删除在添加
+		QueryWrapper<TaCustomerStatisticMonthly> queryWrapper = new QueryWrapper<>();
+		queryWrapper.eq("customer_type",customerType);
+		queryWrapper.eq("month",todayDate);
+		customerStatisticMonthlyMapper.delete(queryWrapper);
+		
+		list.forEach(e -> {
+			e.setCreateDate(nowDate);
+			e.setCustomerType(customerType);
+			e.setMonth(todayDate);
+		});
+		//批量保存
+		this.saveBatch(list);
+	}
 }

src/main/resources/mapper/statistic/TaCustomerStatisticMonthlyMapper.xml

 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
 <mapper namespace="com.huiju.estateagents.statistic.mapper.TaCustomerStatisticMonthlyMapper">
 
+    <select id="getNewCustomerStatisticMonthly"
+            resultType="com.huiju.estateagents.statistic.entity.TaCustomerStatisticMonthly">
+        SELECT
+            org_id,
+            count( customer_id ) as customer_num
+        FROM
+            ta_recommend_customer
+        WHERE
+            `STATUS` = #{status}
+            AND date_format( create_date, '%Y-%m' ) = date_format( #{nowDate}, '%Y-%m' )
+        GROUP BY
+            org_id
+    </select>
+
+    <select id="getFollowUpStatisticMonthly"
+            resultType="com.huiju.estateagents.statistic.entity.TaCustomerStatisticMonthly">
+        SELECT
+            org_id,
+            count( DISTINCT ( customer_id ) ) as customer_num
+        FROM
+            ta_customer_follow_up_record
+        WHERE
+            date_format( create_date, '%Y-%m' ) = date_format( #{nowDate}, '%Y-%m' )
+        GROUP BY
+            org_id
+    </select>
+    <select id="getVisiteStatisticMonthly"
+            resultType="com.huiju.estateagents.statistic.entity.TaCustomerStatisticMonthly">
+        SELECT
+            count( DISTINCT ( c.customer_id ) ) as customer_num,
+            c.org_id
+        FROM
+            ta_activity_dynamic_enlist t
+            LEFT JOIN ta_recommend_customer c ON t.person_id = c.person_id
+            AND t.building_id = c.building_id
+            AND t.org_id = c.org_id
+        WHERE
+            t.is_checkin = #{checkin}
+            AND date_format( t.create_date, '%Y-%m' ) = date_format( #{nowDate}, '%Y-%m' )
+        GROUP BY
+            c.org_id
+    </select>
 </mapper>