数据统计

src/main/java/com/huiju/estateagents/common/CommConstant.java

@@ -375,6 +375,7 @@ public class CommConstant {
     // ------- 性别 start -------
     public static final Integer SEX_MALE = 1;
     public static final Integer SEX_FEMALE = 2;
+    public static final Integer SEX_UNKNOWN = 3;
     // ------- 性别 end -------
 
     // ------- 推荐客户状态 start -------

src/main/java/com/huiju/estateagents/statistic/entity/GenderStatistic.java

@@ -0,0 +1,27 @@
+package com.huiju.estateagents.statistic.entity;
+
+import lombok.Data;
+
+import java.math.BigDecimal;
+
+/**
+ * @author FXF
+ * @date 2019-11-08
+ */
+@Data
+public class GenderStatistic {
+
+	private Integer orgId;
+	
+	private Integer manSum;
+	
+	private BigDecimal manPct;
+	
+	private Integer womanSum;
+	
+	private BigDecimal womanPct;
+	
+	private Integer unknownSum;
+	
+	private BigDecimal unknownPct;
+}

src/main/java/com/huiju/estateagents/statistic/entity/TaCustomerFollowUpRecord.java

@@ -59,4 +59,9 @@ public class TaCustomerFollowUpRecord implements Serializable {
      * 跟进人ID
      */
     private Integer followerId;
+    
+    /**
+     * 客户性别
+     */
+    private Integer customerSex;
 }

src/main/java/com/huiju/estateagents/statistic/entity/TaCustomerGenderStatistic.java

@@ -7,6 +7,7 @@ import lombok.EqualsAndHashCode;
 import lombok.experimental.Accessors;
 
 import java.io.Serializable;
+import java.math.BigDecimal;
 import java.time.LocalDateTime;
 
 /**
@@ -48,7 +49,7 @@ public class TaCustomerGenderStatistic implements Serializable {
     /**
      * 百分比 百分比
      */
-    private Integer percentage;
+    private BigDecimal percentage;
 
     /**
      * 创建时间

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

@@ -1,9 +1,13 @@
 package com.huiju.estateagents.statistic.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.huiju.estateagents.statistic.entity.GenderStatistic;
 import com.huiju.estateagents.statistic.entity.TaCustomerGenderStatistic;
 import org.apache.ibatis.annotations.Mapper;
 
+import java.util.List;
+import java.util.Map;
+
 /**
  * <p>
  * 客户分析性别统计表 小程序盘客工具客户分析 Mapper 接口
@@ -14,5 +18,22 @@ import org.apache.ibatis.annotations.Mapper;
  */
 @Mapper
 public interface TaCustomerGenderStatisticMapper extends BaseMapper<TaCustomerGenderStatistic> {
-
+	
+	/**
+	 * 获取新增客户的男女性别比
+	 * @return
+	 */
+	List<GenderStatistic> getNewCustomerSexCount();
+	
+	/**
+	 * 获取跟进客户的男女性别比
+	 * @return
+	 */
+	List<GenderStatistic> getFollowUpSexCount();
+	
+	/**
+	 * 获取到访客户的男女性别比
+	 * @return
+	 */
+	List<GenderStatistic> getVisiteSexCount();
 }

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

@@ -17,18 +17,21 @@ public interface ITaCustomerGenderStatisticService extends IService<TaCustomerGe
 	
 	/**
 	 * 每天的新增客户性别统计
+	 *
 	 * @param nowDate
 	 */
 	void newCustomerSexStatisticDaily(LocalDateTime nowDate);
 	
 	/**
 	 * 每天的跟进客户性别统计
+	 *
 	 * @param nowDate
 	 */
 	void followUpSexStatisticDaily(LocalDateTime nowDate);
 	
 	/**
 	 * 每天的到访客户性别统计
+	 *
 	 * @param nowDate
 	 */
 	void visiteSexStatisticDaily(LocalDateTime nowDate);

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

@@ -1,6 +1,8 @@
 package com.huiju.estateagents.statistic.service.impl;
 
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.huiju.estateagents.common.CommConstant;
+import com.huiju.estateagents.statistic.entity.GenderStatistic;
 import com.huiju.estateagents.statistic.entity.TaCustomerGenderStatistic;
 import com.huiju.estateagents.statistic.mapper.TaCustomerGenderStatisticMapper;
 import com.huiju.estateagents.statistic.service.ITaCustomerGenderStatisticService;
@@ -8,6 +10,8 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 
 import java.time.LocalDateTime;
+import java.util.ArrayList;
+import java.util.List;
 
 /**
  * <p>
@@ -30,7 +34,10 @@ public class TaCustomerGenderStatisticServiceImpl extends ServiceImpl<TaCustomer
 	 */
 	@Override
 	public void newCustomerSexStatisticDaily(LocalDateTime nowDate) {
-	
+		//获取新增客户的男女性别比和性别数
+		List<GenderStatistic> newCustomerSexList = customerGenderStatisticMapper.getNewCustomerSexCount();
+		//批量保存
+		saveBatchCustomerSexData(newCustomerSexList,nowDate);
 	}
 	
 	/**
@@ -40,7 +47,10 @@ public class TaCustomerGenderStatisticServiceImpl extends ServiceImpl<TaCustomer
 	 */
 	@Override
 	public void followUpSexStatisticDaily(LocalDateTime nowDate) {
-	
+		//获取跟进客户的男女性别比和性别数
+		List<GenderStatistic> followUpSexList = customerGenderStatisticMapper.getFollowUpSexCount();
+		//批量保存
+		saveBatchCustomerSexData(followUpSexList,nowDate);
 	}
 	
 	/**
@@ -50,6 +60,55 @@ public class TaCustomerGenderStatisticServiceImpl extends ServiceImpl<TaCustomer
 	 */
 	@Override
 	public void visiteSexStatisticDaily(LocalDateTime nowDate) {
+		//获取到访客户的男女性别比和性别数
+		List<GenderStatistic> visiteSexList = customerGenderStatisticMapper.getVisiteSexCount();
+		List<GenderStatistic> newVisiteSexList = new ArrayList<>();
+		visiteSexList.forEach(e -> {
+			if (null != e.getOrgId() && !e.getOrgId().equals("null")){
+				newVisiteSexList.add(e);
+			}
+		});
+		//批量保存
+		saveBatchCustomerSexData(newVisiteSexList,nowDate);
+	}
 	
+	/**
+	 * 批量保存性别数据
+	 * @param customerSexList
+	 * @param nowDate
+	 */
+	private void saveBatchCustomerSexData(List<GenderStatistic> customerSexList, LocalDateTime nowDate) {
+		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.setCustomerNum(e.getManSum());
+			maleCustomer.setPercentage(e.getManPct());
+			maleCustomer.setOrgId(e.getOrgId());
+			list.add(maleCustomer);
+			
+			TaCustomerGenderStatistic femaleCustomer = new TaCustomerGenderStatistic();
+			femaleCustomer.setCreateDate(nowDate);
+			femaleCustomer.setGenderType(CommConstant.SEX_FEMALE);
+			femaleCustomer.setCustomerType(CommConstant.CUSTOMER_TYPE_NEW);
+			femaleCustomer.setCustomerNum(e.getWomanSum());
+			femaleCustomer.setPercentage(e.getWomanPct());
+			femaleCustomer.setOrgId(e.getOrgId());
+			list.add(femaleCustomer);
+			
+			TaCustomerGenderStatistic unknownCustomer = new TaCustomerGenderStatistic();
+			unknownCustomer.setCreateDate(nowDate);
+			unknownCustomer.setGenderType(CommConstant.SEX_UNKNOWN);
+			unknownCustomer.setCustomerType(CommConstant.CUSTOMER_TYPE_NEW);
+			unknownCustomer.setCustomerNum(e.getUnknownSum());
+			unknownCustomer.setPercentage(e.getUnknownPct());
+			unknownCustomer.setOrgId(e.getOrgId());
+			list.add(unknownCustomer);
+		});
+		//批量插入
+		this.saveBatch(list);
 	}
 }

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

@@ -2,4 +2,60 @@
 <!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.TaCustomerGenderStatisticMapper">
 
+    <select id="getNewCustomerSexCount" resultType="com.huiju.estateagents.statistic.entity.GenderStatistic">
+        SELECT
+            org_id,
+            sum(if(sex = 1,1,0)) as man_sum,
+            sum(if(sex = 1,1,0))/count(*) as man_pct,
+            sum(if(sex = 2,1,0)) as woman_sum,
+            sum(if(sex = 2,1,0))/count(*) as woman_pct,
+            sum(if(sex != 1 and sex != 2,1,0)) as unknown_sum,
+            sum(if(sex != 1 and sex != 2,1,0))/count(*) as unknown_pct
+        FROM
+            ta_recommend_customer
+        WHERE
+            `STATUS` = 1
+            GROUP BY org_id
+    </select>
+    <select id="getFollowUpSexCount" resultType="com.huiju.estateagents.statistic.entity.GenderStatistic">
+        SELECT
+            t.org_id,
+            sum( IF ( t.customer_sex = 1, 1, 0 ) ) AS manSum,
+            sum( IF ( t.customer_sex = 1, 1, 0 ) ) / count( * ) AS manPct,
+            sum( IF ( t.customer_sex = 2, 1, 0 ) ) AS womanSum,
+            sum( IF ( t.customer_sex = 2, 1, 0 ) ) / count( * ) AS womanPct,
+            sum( IF ( t.customer_sex != 1 AND t.customer_sex != 2, 1, 0 ) ) AS unknownSum,
+            sum( IF ( t.customer_sex != 1 AND t.customer_sex != 2, 1, 0 ) ) / count( * ) AS unknownPct
+        FROM
+            ( SELECT * FROM ta_customer_follow_up_record GROUP BY customer_id ) t
+        GROUP BY
+            t.org_id
+    </select>
+    <select id="getVisiteSexCount" resultType="com.huiju.estateagents.statistic.entity.GenderStatistic">
+        SELECT
+            d.org_id,
+            sum( IF ( d.sex = 1, 1, 0 ) ) AS manSum,
+            sum( IF ( d.sex = 1, 1, 0 ) ) / count( * ) AS manPct,
+            sum( IF ( d.sex = 2, 1, 0 ) ) AS womanSum,
+            sum( IF ( d.sex = 2, 1, 0 ) ) / count( * ) AS womanPct,
+            sum( IF ( d.sex != 1 AND d.sex != 2, 1, 0 ) ) AS unknownSum,
+            sum( IF ( d.sex != 1 AND d.sex != 2, 1, 0 ) ) / count( * ) AS unknownPct
+        FROM
+            (
+                SELECT
+                    t.enlist_id,
+                    c.*
+                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 = 1
+                GROUP BY
+                    c.customer_id
+            ) d
+        GROUP BY
+            d.org_id
+    </select>
 </mapper>