tongji

src/main/java/com/yunzhi/marketing/center/taUser/entity/TaUser.java

      */
     private String jobNumber;
 
+    /**
+     * 组织结构id
+     */
+    private String institutionId;
+
     /**
      * 组织机构编号
      */

src/main/java/com/yunzhi/marketing/xlk/controller/PcIndexStatisticsController.java

+package com.yunzhi.marketing.xlk.controller;
+
+import com.yunzhi.marketing.base.BaseController;
+import com.yunzhi.marketing.base.ResponseBean;
+import com.yunzhi.marketing.center.taUser.entity.TaUser;
+import com.yunzhi.marketing.center.taUser.service.ITaUserService;
+import com.yunzhi.marketing.xlk.dto.ChannelCustomerDTO;
+import com.yunzhi.marketing.xlk.service.IPcStatisticsService;
+import io.swagger.annotations.Api;
+import io.swagger.annotations.ApiOperation;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestHeader;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestMethod;
+import org.springframework.web.bind.annotation.RestController;
+
+import javax.servlet.http.HttpServletRequest;
+
+@RestController
+@RequestMapping("/api")
+@Api(value = "xlk-pc端首页统计接口", tags = "xlk-pc端首页统计接口")
+public class PcIndexStatisticsController extends BaseController {
+
+    @Autowired
+    private IPcStatisticsService pcStatisticsService;
+    @Autowired
+    public ITaUserService iTaUserService;
+
+    /**
+     * 首页六个用户数统计
+     * @return
+     */
+    @ApiOperation(value = "admin-首页六个用户数统计", notes = "admin-首页六个用户数统计")
+    @GetMapping(value="/admin/statistics/user")
+    public ResponseBean getUserStatistics(@RequestHeader("authorization") String token, HttpServletRequest request){
+        Integer userId = getUserId(request);
+        TaUser taUser = iTaUserService.getById(userId);
+        return pcStatisticsService.getUserStatistics(taUser);
+    }
+
+    /**
+     * 首页用户来源
+     * @return
+     */
+    @ApiOperation(value = "admin-首页用户来源统计", notes = "admin-首页用户来源统计")
+    @GetMapping(value="/admin/statistics/userOrigin")
+    public ResponseBean getUserOriginStatistics(@RequestHeader("authorization") String token, HttpServletRequest request){
+        Integer userId = getUserId(request);
+        TaUser taUser = iTaUserService.getById(userId);
+        return pcStatisticsService.getUserOriginStatistics(taUser);
+    }
+
+    /**
+     * 首页性别比例
+     * @return
+     */
+    @ApiOperation(value = "admin-首页性别比例统计", notes = "admin-首页性别比例统计")
+    @GetMapping(value="/admin/statistics/userGender")
+    public ResponseBean getuserGenderStatistics(@RequestHeader("authorization") String token, HttpServletRequest request){
+        Integer userId = getUserId(request);
+        TaUser taUser = iTaUserService.getById(userId);
+        return pcStatisticsService.getuserGenderStatistics(taUser);
+    }
+}

src/main/java/com/yunzhi/marketing/xlk/dto/PcStatisticsDTO.java

+package com.yunzhi.marketing.xlk.dto;
+
+import lombok.Data;
+
+import java.time.LocalDateTime;
+
+@Data
+public class PcStatisticsDTO {
+
+    private Integer orgId;
+
+    /**
+     * 当天日期
+     */
+    private LocalDateTime todayTime;
+
+    /**
+     * 组织机构code
+     */
+    private String institutionCode;
+}

src/main/java/com/yunzhi/marketing/xlk/mapper/PcStatisticsMapper.java

+package com.yunzhi.marketing.xlk.mapper;
+
+import com.yunzhi.marketing.center.taUser.entity.TaUser;
+import com.yunzhi.marketing.xlk.dto.PcStatisticsDTO;
+import com.yunzhi.marketing.xlk.vo.PcStatisticsGenderVO;
+import com.yunzhi.marketing.xlk.vo.PcStatisticsVO;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+@Mapper
+public interface PcStatisticsMapper {
+    /**
+     * 总用户数
+     * @return
+     */
+    int selectAllPerson(@Param("params") PcStatisticsDTO taUser);
+
+    /**
+     * 注册用户数
+     * @return
+     */
+    int selectRegisterPerson(@Param("params") PcStatisticsDTO taUser);
+
+    /**
+     * 今日访问次数
+     * @return
+     */
+    int selectTodayVisitNum(@Param("params") PcStatisticsDTO statisticsDTO);
+
+    /**
+     * 今日新增客户
+     * @param statisticsDTO
+     * @return
+     */
+    int selectTodayAddPerson(@Param("params") PcStatisticsDTO statisticsDTO);
+
+    /**
+     * 渠道数量
+     * @param statisticsDTO
+     * @return
+     */
+    int selectChannelNum(@Param("params") PcStatisticsDTO statisticsDTO);
+
+    /**
+     * 经纪人数量
+     * @param statisticsDTO
+     * @return
+     */
+    int selectEstateAgentNum(@Param("params") PcStatisticsDTO statisticsDTO);
+
+    /**
+     * 来源统计
+     * @param statisticsDTO
+     * @return
+     */
+    PcStatisticsVO getUserOriginStatistics(@Param("params") PcStatisticsDTO statisticsDTO);
+
+    /**
+     * 性别统计
+     * @param statisticsDTO
+     * @return
+     */
+    PcStatisticsGenderVO getuserGenderStatistics(@Param("params") PcStatisticsDTO statisticsDTO);
+}

src/main/java/com/yunzhi/marketing/xlk/service/IPcStatisticsService.java

+package com.yunzhi.marketing.xlk.service;
+
+import com.yunzhi.marketing.base.ResponseBean;
+import com.yunzhi.marketing.center.taUser.entity.TaUser;
+
+public interface IPcStatisticsService {
+
+    /**
+     * 获取首页六个卡片的数值
+     * @param taUser
+     * @return
+     */
+    ResponseBean getUserStatistics(TaUser taUser);
+
+    /**
+     * 首页用户来源统计
+     * @param taUser
+     * @return
+     */
+    ResponseBean getUserOriginStatistics(TaUser taUser);
+
+    /**
+     * 性别比例
+     * @param taUser
+     * @return
+     */
+    ResponseBean getuserGenderStatistics(TaUser taUser);
+}

src/main/java/com/yunzhi/marketing/xlk/service/impl/IPcStatisticsServiceimpl.java

+package com.yunzhi.marketing.xlk.service.impl;
+
+import com.yunzhi.marketing.base.ResponseBean;
+import com.yunzhi.marketing.center.taUser.entity.TaUser;
+import com.yunzhi.marketing.common.CommConstant;
+import com.yunzhi.marketing.dto.StatisticsDTO;
+import com.yunzhi.marketing.xlk.dto.PcStatisticsDTO;
+import com.yunzhi.marketing.xlk.entity.Institution;
+import com.yunzhi.marketing.xlk.mapper.InstitutionMapper;
+import com.yunzhi.marketing.xlk.mapper.PcStatisticsMapper;
+import com.yunzhi.marketing.xlk.service.IInstitutionService;
+import com.yunzhi.marketing.xlk.service.IPcStatisticsService;
+import com.yunzhi.marketing.xlk.vo.PcStatisticsGenderVO;
+import com.yunzhi.marketing.xlk.vo.PcStatisticsVO;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.time.LocalDateTime;
+import java.util.HashMap;
+import java.util.Map;
+
+@Service
+public class IPcStatisticsServiceimpl implements IPcStatisticsService {
+
+    @Autowired
+    private PcStatisticsMapper pcStatisticsMapper;
+
+    @Autowired
+    private InstitutionMapper institutionMapper;
+
+    /**
+     * 获取首页六个卡片的数值
+     *
+     * @param taUser
+     * @return
+     */
+    @Override
+    public ResponseBean getUserStatistics(TaUser taUser) {
+        // 获取当前人员的渠道code
+        Institution institution = institutionMapper.selectById(taUser.getInstitutionId());
+
+        PcStatisticsDTO statisticsDTO = new PcStatisticsDTO();
+        statisticsDTO.setOrgId(taUser.getOrgId());
+        statisticsDTO.setTodayTime(LocalDateTime.now());
+        statisticsDTO.setInstitutionCode(institution.getInstitutionCode());
+        // 总用户
+        int allPersonNum = pcStatisticsMapper.selectAllPerson(statisticsDTO);
+        // 总注册用户
+        int registerPersonNum = pcStatisticsMapper.selectRegisterPerson(statisticsDTO);
+        // 今日访问次数
+        int todayVisitNum = pcStatisticsMapper.selectTodayVisitNum(statisticsDTO);
+        // 今日新增用户
+        int todayAddPersonNum = pcStatisticsMapper.selectTodayAddPerson(statisticsDTO);
+        // 渠道数量
+        int channelNum = pcStatisticsMapper.selectChannelNum(statisticsDTO);
+        // 经济人数量
+        int estateAgentNum = pcStatisticsMapper.selectEstateAgentNum(statisticsDTO);
+
+        Map<String,Object> map = new HashMap<>();
+        map.put("allPersonNum",allPersonNum);
+        map.put("registerPersonNum",registerPersonNum);
+        map.put("todayVisitNum",todayVisitNum);
+        map.put("todayAddPersonNum",todayAddPersonNum);
+        map.put("channelNum",channelNum);
+        map.put("estateAgentNum",estateAgentNum);
+        return ResponseBean.success(map);
+    }
+
+    /**
+     * 首页用户来源统计
+     *
+     * @param taUser
+     * @return
+     */
+    @Override
+    public ResponseBean getUserOriginStatistics(TaUser taUser) {
+        PcStatisticsDTO statisticsDTO = new PcStatisticsDTO();
+        statisticsDTO.setOrgId(taUser.getOrgId());
+        PcStatisticsVO userOriginStatistics = pcStatisticsMapper.getUserOriginStatistics(statisticsDTO);
+        Integer otherNum = userOriginStatistics.getAllPersonNum() - userOriginStatistics.getConsultantNum() - userOriginStatistics.getCustomerNum() -userOriginStatistics.getEstageNum();
+        userOriginStatistics.setOrherNum(otherNum);
+        return ResponseBean.success(userOriginStatistics);
+    }
+
+    /**
+     * 性别比例
+     *
+     * @param taUser
+     * @return
+     */
+    @Override
+    public ResponseBean getuserGenderStatistics(TaUser taUser) {
+        PcStatisticsDTO statisticsDTO = new PcStatisticsDTO();
+        statisticsDTO.setOrgId(taUser.getOrgId());
+        PcStatisticsGenderVO pcStatisticsGenderVO = pcStatisticsMapper.getuserGenderStatistics(statisticsDTO);
+        return ResponseBean.success(pcStatisticsGenderVO);
+    }
+}

src/main/java/com/yunzhi/marketing/xlk/vo/PcStatisticsGenderVO.java

+package com.yunzhi.marketing.xlk.vo;
+
+import lombok.Data;
+
+@Data
+public class PcStatisticsGenderVO {
+
+    /**
+     * 男
+     */
+    private Integer maleNum;
+
+    /**
+     * 女
+     */
+    private Integer femaleNum;
+}

src/main/java/com/yunzhi/marketing/xlk/vo/PcStatisticsVO.java

+package com.yunzhi.marketing.xlk.vo;
+
+import lombok.Data;
+
+@Data
+public class PcStatisticsVO {
+
+    /**
+     * 来源置业
+     */
+    private Integer consultantNum;
+
+    /**
+     * 来源客户
+     */
+    private Integer customerNum;
+
+    /**
+     * 来源经纪人
+     */
+    private Integer estageNum;
+
+    /**
+     * 全部人员
+     */
+    private Integer allPersonNum;
+
+    /**
+     * 来源其他
+     */
+    private Integer orherNum;
+}

src/main/resources/mapper/xlk/PcStatisticsMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.yunzhi.marketing.xlk.mapper.PcStatisticsMapper">
+    <select id="selectAllPerson" resultType="java.lang.Integer">
+        select count(1) from ta_person where org_id = #{params.orgId}
+    </select>
+
+    <select id="selectRegisterPerson" resultType="java.lang.Integer">
+        select count(1) from ta_person where  org_id = #{params.orgId} and phone is not null
+    </select>
+    <select id="selectTodayVisitNum" resultType="java.lang.Integer">
+        SELECT
+            COUNT(1)
+        FROM
+            ta_person_visit_record tp
+        where tp.org_id = #{params.orgId} AND
+            tp.event  = 'start'
+        AND DATE_FORMAT(tp.visit_time,'%Y-%m-%d') = DATE_FORMAT(#{params.todayTime},'%Y-%m-%d')
+    </select>
+    <select id="selectTodayAddPerson" resultType="java.lang.Integer">
+        SELECT
+            COUNT(1)
+        FROM
+        ta_person tp
+        where tp.org_id = #{params.orgId}
+        AND DATE_FORMAT(tp.create_date,'%Y-%m-%d') = DATE_FORMAT(#{params.todayTime},'%Y-%m-%d')
+    </select>
+    <select id="selectChannelNum" resultType="java.lang.Integer">
+        SELECT
+            COUNT(1)
+        FROM
+            ta_channel t
+            LEFT JOIN xlk_institution i ON t.institution_id = i.institution_id
+        WHERE
+            t.org_id = #{params.orgId}
+            AND i.institution_code like CONCAT(#{params.institutionCode}, '%')
+    </select>
+    <select id="selectEstateAgentNum" resultType="java.lang.Integer">
+        SELECT
+            COUNT(1)
+        FROM
+        ta_person tp
+        where tp.org_id = #{params.orgId}
+        and tp.person_type = 'estate agent'
+    </select>
+    <select id="getUserOriginStatistics" resultType="com.yunzhi.marketing.xlk.vo.PcStatisticsVO">
+        SELECT
+            sum(if(recommend_person_type = 'Realty Consultant', 1, 0)) as consultant_num,
+            sum(if(recommend_person_type = 'customer', 1, 0)) as customer_num,
+            sum(if(recommend_person_type in ('estate agent','channel agent'), 1, 0)) as estage_num,
+            count(1) as all_person_num
+        from ta_person
+        where org_id = #{params.orgId}
+    </select>
+    <select id="getuserGenderStatistics" resultType="com.yunzhi.marketing.xlk.vo.PcStatisticsGenderVO">
+        SELECT
+            sum(if(gender = '1', 1, 0)) as male_num,
+            sum(if(gender = '2', 1, 0)) as female_num
+        from ta_person
+    </select>
+</mapper>