提交

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

@@ -239,4 +239,15 @@ public class CommConstant {
      * 注册经纪人积分规则
      */
     public static final Integer POINTS_RULE_SIGNUP_AGENT = 4;
+
+
+    // ----   用户活跃数  查询条件 start ------
+
+    public static final String DAY = "day";
+
+    public static final String WEEK = "week";
+
+    public static final String MONTH = "month";
+
+    // ----     查询条件 end ------
 }

src/main/java/com/huiju/estateagents/controller/StatisticalController.java

@@ -0,0 +1,31 @@
+package com.huiju.estateagents.controller;
+
+import com.huiju.estateagents.base.ResponseBean;
+import com.huiju.estateagents.service.IStatisticalService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * 数据统计
+ */
+@RestController
+@RequestMapping("/")
+public class StatisticalController {
+
+    @Autowired
+    private IStatisticalService iStatisticalService;
+
+    /**
+     * 首页统计
+     * @return
+     */
+    @GetMapping(value = "/indexStatistical")
+    public ResponseBean indexStatistical() {
+        return iStatisticalService.indexStatistical();
+    }
+
+
+}

src/main/java/com/huiju/estateagents/mapper/TaPersonMapper.java

@@ -3,10 +3,13 @@ package com.huiju.estateagents.mapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.huiju.estateagents.entity.TaPerson;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.huiju.estateagents.po.PersonPO;
 import org.apache.ibatis.annotations.Mapper;
 import org.apache.ibatis.annotations.Param;
+import org.apache.ibatis.annotations.Select;
 
 import java.io.Serializable;
+import java.util.Date;
 import java.util.List;
 import java.util.Map;
 
@@ -45,4 +48,64 @@ public interface TaPersonMapper extends BaseMapper<TaPerson> {
 
     List<Map<String,Object>> selectCardListofMine(IPage<Map<String,Object>> page, @Param("personType") String personType, @Param("status") int status,@Param("personIds")List<String> personIds);
 
+    //---------- 用户总数 start ------------
+
+    /**
+     * 总用户数
+     * @param personType
+     * @return
+     */
+    @Select("select count(1) from ta_person where person_type = #{personType}")
+    Integer selectUserCount(@Param("personType") String personType);
+
+    /**
+     * 总注册数
+     * @param personType
+     * @return
+     */
+    @Select("select count(1) from ta_person where person_type = #{personType} and phone is not null")
+    Integer selectRegisteredCount(@Param("personType") String personType);
+
+    /**
+     * 根据时间段查询
+     * @param personType
+     * @return
+     */
+    Integer selectRecentlyCount(@Param("personType") String personType, @Param("startDate")Date startDate, @Param("endDate")Date endDate);
+
+    //---------- 用户总数 end ------------
+
+    /**
+     * 用户行为
+     * @param personType
+     * @param startDate
+     * @param endDate
+     * @return
+     */
+    List<PersonPO> selectUserBehavior(@Param("personType") String personType, @Param("startDate")Date startDate, @Param("endDate")Date endDate);
+
+    /**
+     * 活跃用户数 / 最近新增的用户数
+     * @param personType
+     * @param dateType
+     * @return
+     */
+    List<Map<String, Object>> selectActiveUserCount(@Param("personType") String personType, @Param("dateType") String dateType, @Param("startDate")Date startDate, @Param("endDate")Date endDate);
+
+
+    /**
+     * 性别比例
+     * @param personType
+     * @return
+     */
+    @Select("select sex, count(1) from ta_person where person_type = #{personType} GROUP BY sex")
+    List<Map<String, Object>> selectSexUser(@Param("personType") String personType);
+
+
+
+
+
+
+
+
 }

src/main/java/com/huiju/estateagents/po/PersonPO.java

@@ -0,0 +1,26 @@
+package com.huiju.estateagents.po;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.util.Date;
+
+/**
+ * 数据统计映射
+ *
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class PersonPO {
+
+    private Date date;
+
+    private Integer activityCount;
+
+    private Date visitTime;
+
+    private String activity;
+
+}

src/main/java/com/huiju/estateagents/service/IStatisticalService.java

@@ -0,0 +1,22 @@
+package com.huiju.estateagents.service;
+
+import com.huiju.estateagents.base.ResponseBean;
+
+/**
+ * 数据统计 接口
+ */
+public interface IStatisticalService {
+
+    /**
+     * 首页统计总数
+     * @return
+     */
+    ResponseBean indexStatistical();
+
+    /**
+     * 活跃用户数
+     * @return
+     */
+    ResponseBean selectActiveUserCount(String dateType);
+
+}

src/main/java/com/huiju/estateagents/service/impl/StatisticalServiceImpl.java

@@ -0,0 +1,87 @@
+package com.huiju.estateagents.service.impl;
+
+import com.huiju.estateagents.base.ResponseBean;
+import com.huiju.estateagents.common.CommConstant;
+import com.huiju.estateagents.exception.EstaException;
+import com.huiju.estateagents.mapper.TaPersonMapper;
+import com.huiju.estateagents.po.PersonPO;
+import com.huiju.estateagents.service.IStatisticalService;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.time.LocalDateTime;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 数据统计
+ */
+@Service
+@Slf4j
+public class StatisticalServiceImpl implements IStatisticalService {
+
+    @Autowired
+    private TaPersonMapper taPersonMapper;
+
+
+    @Override
+    public ResponseBean indexStatistical() {
+
+        ResponseBean responseBean = new ResponseBean();
+        Map<String,Object> map = new HashMap<>();
+
+        // 总用户数
+        Integer selectUserCount = taPersonMapper.selectUserCount(CommConstant.PERSON_REALTY_CONSULTANT);
+
+        // 注册数
+        Integer selectRegisteredCount = taPersonMapper.selectRegisteredCount(CommConstant.PERSON_REALTY_CONSULTANT);
+
+        // 最近七天
+        Integer selectRecentlyCount = taPersonMapper.selectRecentlyCount(CommConstant.PERSON_REALTY_CONSULTANT, null, null);
+
+        // 用户行为
+        List<PersonPO> selectUserBehavior = taPersonMapper.selectUserBehavior(CommConstant.PERSON_REALTY_CONSULTANT, null, null);
+
+        // 用户活跃数 / 新增用户数
+        List<Map<String, Object>> selectActiveUserCount = taPersonMapper.selectActiveUserCount(CommConstant.PERSON_REALTY_CONSULTANT, CommConstant.DAY, null, null);
+
+        // 性别比例
+        List<Map<String, Object>> selectSexUser = taPersonMapper.selectSexUser(CommConstant.PERSON_REALTY_CONSULTANT);
+
+        map.put("selectUserCount", selectUserCount);
+        map.put("selectRegisteredCount", selectRegisteredCount);
+        map.put("selectRecentlyCount", selectRecentlyCount);
+        map.put("selectUserBehavior", selectUserBehavior);
+        map.put("selectActiveUserCount", selectActiveUserCount);
+        map.put("selectSexUser", selectSexUser);
+
+        responseBean.addSuccess(map);
+
+        return responseBean;
+    }
+
+    @Override
+    public ResponseBean selectActiveUserCount(String dateType) {
+        ResponseBean responseBean = new ResponseBean();
+
+        String type = null;
+        if (CommConstant.DAY.equals(dateType)) {
+            type = CommConstant.DAY;
+        } else if (CommConstant.WEEK.equals(dateType)) {
+            type = CommConstant.WEEK;
+        } else if (CommConstant.MONTH.equals(dateType)) {
+            type = CommConstant.MONTH;
+        } else {
+            responseBean.addError("无此查询类型！");
+        }
+
+        // 用户活跃数
+        List<Map<String, Object>> selectActiveUserCount = taPersonMapper.selectActiveUserCount(CommConstant.PERSON_REALTY_CONSULTANT, type, null, null);
+        Map<String, Object> map = new HashMap<>();
+        map.put("selectActiveUserCount", selectActiveUserCount);
+        responseBean.addSuccess(map);
+        return responseBean;
+    }
+}

src/main/resources/mapper/TaPersonMapper.xml

@@ -138,4 +138,100 @@ FROM
         ORDER BY
         t.create_date DESC
     </select>
+
+
+    <select id="selectRecentlyCount" >
+        SELECT
+          SUM(activity_count)
+        FROM
+        (
+            SELECT
+              DATE_FORMAT( DATE_SUB( now( ), INTERVAL a.rownum DAY ), '%Y-%m-%d' ) AS date
+            FROM
+              sequence a
+            WHERE
+                <if test="startDate == null or endDate == null">
+                    a.rownum <![CDATA[ <= ]]> 7
+                </if>
+                <if test="startDate != null or endDate != null">
+                    a.rownum <![CDATA[ <= ]]> datediff(#{endDate}, #{startDate})
+                </if>
+        ) AS temp_date
+        LEFT JOIN (
+            SELECT
+            COUNT(1) as activity_count,
+            tpvr.visit_time AS visit_time
+            FROM
+            ta_person tp
+            INNER JOIN ta_person_visit_record tpvr ON tp.person_id = tpvr.person_id
+        ) AS temp ON temp_date.date = DATE_FORMAT( temp.visit_time , '%Y-%m-%d' )
+    </select>
+
+
+    <select id="selectUserBehavior" resultType="com.huiju.estateagents.po.PersonPO">
+        SELECT
+        *
+        FROM
+        (
+            SELECT
+            DATE_FORMAT( DATE_SUB( now( ), INTERVAL a.rownum DAY ), '%Y-%m-%d' ) AS date
+            FROM
+            sequence a
+            WHERE
+            <if test="startDate == null or endDate == null">
+                a.rownum <![CDATA[ <= ]]> 7
+            </if>
+            <if test="startDate != null or endDate != null">
+                a.rownum <![CDATA[ <= ]]> datediff(#{endDate}, #{startDate})
+            </if>
+        ) AS temp_date
+        LEFT JOIN (
+            SELECT
+            COUNT(1) as activityCount,
+            tpvr.visit_time AS visitTime,
+            tpvr.activity as activity
+            FROM
+            ta_person tp
+            INNER JOIN ta_person_visit_record tpvr ON tp.person_id = tpvr.person_id
+            where tp.person_type = #{personType}
+            GROUP BY tpvr.activity
+        ) AS temp ON temp_date.date = DATE_FORMAT( temp.visit_time , '%Y-%m-%d' )
+    </select>
+
+    <select id="selectActiveUserCount" resultType="map">
+        SELECT
+        *
+        FROM
+        (
+            SELECT
+              <if test="dateType === 'day'">
+                  DATE_FORMAT( DATE_SUB( now( ), INTERVAL a.rownum DAY ), '%Y-%m-%d' ) AS date
+              </if>
+              <if test="dateType === 'week'">
+                  DATE_FORMAT( DATE_SUB( now( ), INTERVAL a.rownum WEEK ), '%Y-%m-%d' ) AS date
+              </if>
+              <if test="dateType === 'month'">
+                  DATE_FORMAT( DATE_SUB( now( ), INTERVAL a.rownum MONTH ), '%Y-%m-%d' ) AS date
+              </if>
+            FROM
+              sequence a
+            WHERE
+              <if test="startDate == null or endDate == null">
+                  a.rownum <![CDATA[ <= ]]> 7
+              </if>
+              <if test="startDate != null or endDate != null">
+                  a.rownum <![CDATA[ <= ]]> datediff(#{endDate}, #{startDate})
+              </if>
+        ) AS temp_date
+        LEFT JOIN (
+            SELECT
+                COUNT(1) as activity_count,
+                tpvr.visit_time AS visit_time
+            FROM
+               ta_person tp
+            where tp.person_type = #{personType}
+            INNER JOIN ta_person_visit_record tpvr ON tp.person_id = tpvr.person_id
+        ) AS temp ON temp_date.date = DATE_FORMAT( temp.visit_time , '%Y-%m-%d' )
+    </select>
+
 </mapper>