feats

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

@@ -3,8 +3,12 @@ package com.huiju.estateagents.common;
 import java.io.UnsupportedEncodingException;
 import java.net.URLEncoder;
 import java.util.Random;
+import java.util.regex.Matcher;
+import java.util.regex.Pattern;
 
 public class StringUtils {
+    private static Pattern humpPattern = Pattern.compile("[A-Z]");
+
     public static boolean isEmpty(String str) {
         return null == str || "".equals(str.trim()) || "null".equals(str) || "undefined".equals(str);
     }
@@ -44,4 +48,25 @@ public class StringUtils {
             return str;
         }
     }
+
+    public static String humpToLine(String str) {
+        if (null == str || "".equals(str)) return "";
+
+        Matcher matcher = humpPattern.matcher(str);
+        StringBuffer sb = new StringBuffer();
+        while (matcher.find()) {
+            matcher.appendReplacement(sb, "_" + matcher.group(0).toLowerCase());
+        }
+        matcher.appendTail(sb);
+        return sb.toString();
+    }
+
+    public static String strToUnicode(String str) {
+        char[] chars = str.toCharArray();
+        String returnStr = "";
+        for (int i = 0; i < chars.length; i++) {
+            returnStr += "\\u" + Integer.toString(chars[i], 16);
+        }
+        return returnStr;
+    }
 }

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

@@ -0,0 +1,453 @@
+package com.huiju.estateagents.controller;
+
+import com.alibaba.excel.EasyExcel;
+import com.alibaba.excel.ExcelWriter;
+import com.alibaba.excel.write.metadata.WriteSheet;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.huiju.estateagents.base.BaseController;
+import com.huiju.estateagents.base.ResponseBean;
+import com.huiju.estateagents.common.DateUtils;
+import com.huiju.estateagents.common.StringUtils;
+import com.huiju.estateagents.entity.*;
+import com.huiju.estateagents.excel.ConsultantKPIExport;
+import com.huiju.estateagents.excel.TaActivityDynamicEnlistExport;
+import com.huiju.estateagents.excel.handler.CustomCellWriteHandler;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+import com.huiju.estateagents.service.ITsConsultantKpiService;
+
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.time.LocalDateTime;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+
+/**
+ * <p>
+    * 置业顾问KPI  前端控制器
+    * </p>
+ *
+ * @author yansen
+ * @since 2020-04-14
+ */
+@RestController
+@RequestMapping("/api/admin/stats")
+public class TsConsultantKpiController extends BaseController {
+
+    private final Logger logger = LoggerFactory.getLogger(TsConsultantKpiController.class);
+
+    @Autowired
+    public ITsConsultantKpiService iTsConsultantKpiService;
+
+    /**
+     * 分页查询列表
+     * @param pageNum
+     * @param pageSize
+     * @param startDate
+     * @param endDate
+     * @param buildingId
+     * @param asc
+     * @param desc
+     * @param request
+     * @return
+     */
+    @RequestMapping(value="/consultant/kpi",method= RequestMethod.GET)
+    public ResponseBean tsConsultantKpiList(@RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
+                                            @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
+                                            // startDate 默认格式 YYYYMMDD
+                                            @RequestParam(value ="startDate", required = false) String startDate,
+                                            @RequestParam(value ="endDate", required = false) String endDate,
+                                            @RequestParam(value ="buildingId", required = false) String buildingId,
+                                            @RequestParam(value ="asc", required = false) String asc,
+                                            @RequestParam(value ="desc", required = false) String desc,
+                                            HttpServletRequest request
+        ){
+        if (null == startDate || "".equals(startDate)) {
+            return ResponseBean.error("开始日期不能为空", ResponseBean.ERROR_ILLEGAL_PARAMS);
+        }
+        if (null == endDate || "".equals(endDate)) {
+            endDate = DateUtils.today();
+        }
+
+        Integer orgId = getOrgId(request);
+        try {
+            // 汇总明细
+            IPage<TsConsultantKpi> result = iTsConsultantKpiService.stsKPIDaily(pageNum, pageSize, orgId, buildingId, startDate, endDate, StringUtils.humpToLine(asc), StringUtils.humpToLine(desc));
+            // 汇总
+            TsConsultantKpi total = iTsConsultantKpiService.stsKPITotalByOrg(orgId, buildingId, startDate, endDate);
+            return ResponseBean.success(new HashMap<String, Object>(){{
+                put("paged", result);
+                put("total", total);
+            }});
+        }catch (Exception e){
+//            e.printStackTrace();
+            return ResponseBean.error("查询出错, 请重试 : " + e.getMessage(), ResponseBean.ERROR_UNAVAILABLE);
+        }
+    }
+
+
+    /**
+     * 导出
+     * @param startDate
+     * @param endDate
+     * @param buildingId
+     * @param request
+     * @return
+     */
+    @RequestMapping(value="/consultant/kpi",method= RequestMethod.POST)
+    public ResponseBean tsConsultantKpiList(// startDate 默认格式 YYYYMMDD
+                                            @RequestParam(value ="startDate", required = false) String startDate,
+                                            @RequestParam(value ="endDate", required = false) String endDate,
+                                            @RequestParam(value ="buildingId", required = false) String buildingId,
+                                            HttpServletRequest request,
+                                            HttpServletResponse response
+    ){
+        if (null == startDate || "".equals(startDate)) {
+            return ResponseBean.error("开始日期不能为空", ResponseBean.ERROR_ILLEGAL_PARAMS);
+        }
+        if (null == endDate || "".equals(endDate)) {
+            endDate = DateUtils.today();
+        }
+
+        Integer orgId = getOrgId(request);
+        try {
+            response.setContentType("application/octet-stream");
+            response.setCharacterEncoding("utf-8");
+            response.setHeader("Content-disposition", "attachment;filename="+StringUtils.strToUnicode("置业顾问KPI统计")+DateUtils.today()+".xlsx");
+
+            // 汇总明细
+            List<ConsultantKPIExport> result = iTsConsultantKpiService.stsKPIDailyExport(orgId, buildingId, startDate, endDate);
+            ExcelWriter excelWriter = EasyExcel.write(response.getOutputStream(), ConsultantKPIExport.class).registerWriteHandler(new CustomCellWriteHandler()).build();
+            WriteSheet sheet1 = EasyExcel.writerSheet("sheet1").build();
+            excelWriter.write(result, sheet1);
+            excelWriter.finish();
+        } catch (Exception e){
+//            e.printStackTrace();
+            return ResponseBean.error("查询出错, 请重试 : " + e.getMessage(), ResponseBean.ERROR_UNAVAILABLE);
+        }
+
+        return null;
+    }
+
+    private LocalDateTime[] getLocalTimeRangeBy(String startDate, String endDate) throws Exception {
+        LocalDateTime startTime = null;
+        LocalDateTime endTime = null;
+
+        if (!StringUtils.isEmpty(startDate) && !StringUtils.isEmpty(endDate)) {
+            if (startDate.length() != 8 && endDate.length() != 8) {
+                throw new Exception("日期格式必须为YYYYMMDD");
+            }
+
+            startTime = DateUtils.day2LocalDateime(startDate.substring(0,4) + "-" + startDate.substring(4, 6) + "-" + startDate.substring(6, 8));
+            endTime = DateUtils.day2LocalDateime(endDate.substring(0,4) + "-" + endDate.substring(4, 6) + "-" + endDate.substring(6, 8));
+        }
+
+        return new LocalDateTime[]{startTime, endTime};
+    }
+
+    /**
+     * 查询置业的客户
+     * startDate 存在则统计新增客户, 不存在则统计所有
+     * @param pageNum
+     * @param pageSize
+     * @param buildingId
+     * @param userId
+     * @param startDate
+     * @param endDate
+     * @param request
+     * @return
+     */
+    @GetMapping("/consultant/customer")
+    public ResponseBean tsConsultantKpiList(@RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
+                                            @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
+                                            @RequestParam(value ="buildingId", required = false) String buildingId,
+                                            @RequestParam(value ="userId") String userId,
+                                            @RequestParam(value ="startDate", required = false) String startDate,
+                                            @RequestParam(value ="endDate", required = false) String endDate,
+                                            HttpServletRequest request
+    ){
+        LocalDateTime[] dateRange = {null, null};
+        try {
+            dateRange = getLocalTimeRangeBy(startDate, endDate);
+        } catch (Exception e) {
+            return ResponseBean.error(e.getMessage(), ResponseBean.ERROR_ILLEGAL_PARAMS);
+        }
+
+        Integer orgId = getOrgId(request);
+        IPage<TaRecommendCustomer> page = new Page<>(pageNum, pageSize);
+        IPage<TaRecommendCustomer> result = iTsConsultantKpiService.getCustomerListOfConsultant(page, orgId, userId, buildingId, dateRange[0], dateRange[1]);
+        return ResponseBean.success(result);
+    }
+
+    /**
+     * 置业分享拓客
+     * @param pageNum
+     * @param pageSize
+     * @param buildingId
+     * @param userId
+     * @param startDate
+     * @param endDate
+     * @param request
+     * @return
+     */
+    @GetMapping("/consultant/share/customer")
+    public ResponseBean getConsultantShareCustomers(@RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
+                                                    @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
+                                                    @RequestParam(value ="buildingId", required = false) String buildingId,
+                                                    @RequestParam(value ="userId") String userId,
+                                                    @RequestParam(value ="startDate", required = false) String startDate,
+                                                    @RequestParam(value ="endDate", required = false) String endDate,
+                                                    HttpServletRequest request) {
+
+        LocalDateTime[] dateRange = {null, null};
+        try {
+            dateRange = getLocalTimeRangeBy(startDate, endDate);
+        } catch (Exception e) {
+            return ResponseBean.error(e.getMessage(), ResponseBean.ERROR_ILLEGAL_PARAMS);
+        }
+
+        Integer orgId = getOrgId(request);
+        IPage<TaPerson> page = new Page<>(pageNum, pageSize);
+        IPage<TaPerson> result = iTsConsultantKpiService.getConsultantShareCustomers(page, orgId, userId, buildingId, dateRange[0], dateRange[1]);
+        return ResponseBean.success(result);
+    }
+
+    /**
+     * 置业首页访问人数
+     * @param pageNum
+     * @param pageSize
+     * @param buildingId
+     * @param userId
+     * @param startDate
+     * @param endDate
+     * @param request
+     * @return
+     */
+    @GetMapping("/consultant/homepage/persons")
+    public ResponseBean getConsultantHomePagePersons(@RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
+                                                     @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
+                                                     @RequestParam(value ="buildingId", required = false) String buildingId,
+                                                     @RequestParam(value ="userId") String userId,
+                                                     @RequestParam(value ="startDate", required = false) String startDate,
+                                                     @RequestParam(value ="endDate", required = false) String endDate,
+                                                     HttpServletRequest request) {
+        LocalDateTime[] dateRange = {null, null};
+        try {
+            dateRange = getLocalTimeRangeBy(startDate, endDate);
+        } catch (Exception e) {
+            return ResponseBean.error(e.getMessage(), ResponseBean.ERROR_ILLEGAL_PARAMS);
+        }
+
+        Integer orgId = getOrgId(request);
+        IPage<TaPerson> page = new Page<>(pageNum, pageSize);
+        IPage<TaPerson> result = iTsConsultantKpiService.getConsultantHomePagePersons(page, orgId, userId, buildingId, dateRange[0], dateRange[1]);
+        return ResponseBean.success(result);
+    }
+
+    /**
+     * 置业首页访问次数
+     * @param pageNum
+     * @param pageSize
+     * @param buildingId
+     * @param userId
+     * @param startDate
+     * @param endDate
+     * @param request
+     * @return
+     */
+    @GetMapping("/consultant/homepage/times")
+    public ResponseBean getConsultantHomePageTimes(@RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
+                                                     @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
+                                                     @RequestParam(value ="buildingId", required = false) String buildingId,
+                                                     @RequestParam(value ="userId") String userId,
+                                                     @RequestParam(value ="startDate", required = false) String startDate,
+                                                     @RequestParam(value ="endDate", required = false) String endDate,
+                                                     HttpServletRequest request) {
+        LocalDateTime[] dateRange = {null, null};
+        try {
+            dateRange = getLocalTimeRangeBy(startDate, endDate);
+        } catch (Exception e) {
+            return ResponseBean.error(e.getMessage(), ResponseBean.ERROR_ILLEGAL_PARAMS);
+        }
+
+        Integer orgId = getOrgId(request);
+        IPage<TaPerson> page = new Page<>(pageNum, pageSize);
+        IPage<TaPerson> result = iTsConsultantKpiService.getConsultantHomePageTimes(page, orgId, userId, buildingId, dateRange[0], dateRange[1]);
+        return ResponseBean.success(result);
+    }
+
+    /**
+     * 咨询置业次数
+     * @param pageNum
+     * @param pageSize
+     * @param buildingId
+     * @param userId
+     * @param startDate
+     * @param endDate
+     * @param request
+     * @return
+     */
+    @GetMapping("/consultant/chat/persons")
+    public ResponseBean getConsultantChatPersons(@RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
+                                                 @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
+                                                 @RequestParam(value ="buildingId", required = false) String buildingId,
+                                                 @RequestParam(value ="userId") String userId,
+                                                 @RequestParam(value ="startDate", required = false) String startDate,
+                                                 @RequestParam(value ="endDate", required = false) String endDate,
+                                                 HttpServletRequest request) {
+        LocalDateTime[] dateRange = {null, null};
+        try {
+            dateRange = getLocalTimeRangeBy(startDate, endDate);
+        } catch (Exception e) {
+            return ResponseBean.error(e.getMessage(), ResponseBean.ERROR_ILLEGAL_PARAMS);
+        }
+
+        Integer orgId = getOrgId(request);
+        IPage<TaPerson> page = new Page<>(pageNum, pageSize);
+        IPage<TaPerson> result = iTsConsultantKpiService.getConsultantChatPersons(page, orgId, userId, buildingId, dateRange[0], dateRange[1]);
+        return ResponseBean.success(result);
+    }
+
+    /**
+     * 点赞详情
+     * @param pageNum
+     * @param pageSize
+     * @param buildingId
+     * @param userId
+     * @param startDate
+     * @param endDate
+     * @param request
+     * @return
+     */
+    @GetMapping("/consultant/favor")
+    public ResponseBean getConsultantFavor(@RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
+                                                 @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
+                                                 @RequestParam(value ="buildingId", required = false) String buildingId,
+                                                 @RequestParam(value ="userId") String userId,
+                                                 @RequestParam(value ="startDate", required = false) String startDate,
+                                                 @RequestParam(value ="endDate", required = false) String endDate,
+                                                 HttpServletRequest request) {
+        LocalDateTime[] dateRange = {null, null};
+        try {
+            dateRange = getLocalTimeRangeBy(startDate, endDate);
+        } catch (Exception e) {
+            return ResponseBean.error(e.getMessage(), ResponseBean.ERROR_ILLEGAL_PARAMS);
+        }
+
+        Integer orgId = getOrgId(request);
+        IPage<TaPerson> page = new Page<>(pageNum, pageSize);
+        IPage<TaPerson> result = iTsConsultantKpiService.getConsultantFavor(page, orgId, userId, buildingId, dateRange[0], dateRange[1]);
+        return ResponseBean.success(result);
+    }
+
+    /**
+     * 置业分享次数
+     * @param pageNum
+     * @param pageSize
+     * @param buildingId
+     * @param userId
+     * @param startDate
+     * @param endDate
+     * @param targetType
+     * @param targetName
+     * @param request
+     * @return
+     */
+    @GetMapping("/consultant/share/targets")
+    public ResponseBean getConsultantShareTargets(@RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
+                                                   @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
+                                                   @RequestParam(value ="buildingId", required = false) String buildingId,
+                                                   @RequestParam(value ="userId") String userId,
+                                                   @RequestParam(value ="startDate", required = false) String startDate,
+                                                   @RequestParam(value ="endDate", required = false) String endDate,
+                                                  @RequestParam(value ="targetType", required = false) String targetType,
+                                                  @RequestParam(value ="targetName", required = false) String targetName,
+                                                   HttpServletRequest request) {
+        LocalDateTime[] dateRange = {null, null};
+        try {
+            dateRange = getLocalTimeRangeBy(startDate, endDate);
+        } catch (Exception e) {
+            return ResponseBean.error(e.getMessage(), ResponseBean.ERROR_ILLEGAL_PARAMS);
+        }
+
+        Integer orgId = getOrgId(request);
+        IPage<TaPerson> page = new Page<>(pageNum, pageSize);
+        IPage<TaPerson> result = iTsConsultantKpiService.getConsultantShareTargets(page, orgId, userId, buildingId, dateRange[0], dateRange[1], targetType, targetName);
+        return ResponseBean.success(result);
+    }
+
+    /**
+     * 置业分享访问人数
+     * @param pageNum
+     * @param pageSize
+     * @param buildingId
+     * @param userId
+     * @param startDate
+     * @param endDate
+     * @param request
+     * @return
+     */
+    @GetMapping("/consultant/share/persons")
+    public ResponseBean getConsultantSharePersons(@RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
+                                                  @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
+                                                  @RequestParam(value ="buildingId", required = false) String buildingId,
+                                                  @RequestParam(value ="userId") String userId,
+                                                  @RequestParam(value ="startDate", required = false) String startDate,
+                                                  @RequestParam(value ="endDate", required = false) String endDate,
+                                                  HttpServletRequest request) {
+        LocalDateTime[] dateRange = {null, null};
+        try {
+            dateRange = getLocalTimeRangeBy(startDate, endDate);
+        } catch (Exception e) {
+            return ResponseBean.error(e.getMessage(), ResponseBean.ERROR_ILLEGAL_PARAMS);
+        }
+
+        Integer orgId = getOrgId(request);
+        IPage<TaPerson> page = new Page<>(pageNum, pageSize);
+        IPage<TaPerson> result = iTsConsultantKpiService.getConsultantSharePersons(page, orgId, userId, buildingId, dateRange[0], dateRange[1]);
+        return ResponseBean.success(result);
+    }
+
+    /**
+     * 置业分享访问次数
+     * @param pageNum
+     * @param pageSize
+     * @param buildingId
+     * @param userId
+     * @param startDate
+     * @param endDate
+     * @param targetType
+     * @param targetName
+     * @param request
+     * @return
+     */
+    @GetMapping("/consultant/share/times")
+    public ResponseBean getConsultantShareTimes(@RequestParam(value ="pageNum",defaultValue = "1") Integer pageNum,
+                                                  @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
+                                                  @RequestParam(value ="buildingId", required = false) String buildingId,
+                                                  @RequestParam(value ="userId") String userId,
+                                                  @RequestParam(value ="startDate", required = false) String startDate,
+                                                  @RequestParam(value ="endDate", required = false) String endDate,
+                                                  @RequestParam(value ="targetType", required = false) String targetType,
+                                                  @RequestParam(value ="targetName", required = false) String targetName,
+                                                  HttpServletRequest request) {
+        LocalDateTime[] dateRange = {null, null};
+        try {
+            dateRange = getLocalTimeRangeBy(startDate, endDate);
+        } catch (Exception e) {
+            return ResponseBean.error(e.getMessage(), ResponseBean.ERROR_ILLEGAL_PARAMS);
+        }
+
+        Integer orgId = getOrgId(request);
+        IPage<TaPerson> page = new Page<>(pageNum, pageSize);
+        IPage<TaPerson> result = iTsConsultantKpiService.getConsultantShareTimes(page, orgId, userId, buildingId, dateRange[0], dateRange[1], targetType, targetName);
+        return ResponseBean.success(result);
+    }
+
+
+}

src/main/java/com/huiju/estateagents/entity/TaPerson.java

@@ -312,4 +312,19 @@ public class TaPerson implements Serializable {
      */
     @TableField(exist = false)
     private String sceneAlias;
+
+    /**
+     * 访问内容类型
+     */
+    private String targetType;
+
+    /**
+     * 访问内容ID
+     */
+    private String targetId;
+
+    /**
+     * 访问内容名称
+     */
+    private String targetName;
 }

src/main/java/com/huiju/estateagents/entity/TaShareCount.java

@@ -43,11 +43,21 @@ public class TaShareCount implements Serializable {
      */
     private String tagertType;
 
+    /**
+     * 对象名称
+     */
+    private String targetName;
+
     /**
      * 创建时间
      */
     private LocalDateTime createDate;
 
+    /**
+     * orgId
+     */
+    private Integer orgId;
+
     @TableField(exist = false)
     private String shareTitle;
 

src/main/java/com/huiju/estateagents/entity/TaSharePersonFrom.java

@@ -56,6 +56,11 @@ public class TaSharePersonFrom implements Serializable {
      */
     private String targetId;
 
+    /**
+     * 目标名称
+     */
+    private String targetName;
+
     /**
      * 创建时间
      */

src/main/java/com/huiju/estateagents/entity/TsConsultantKpi.java

@@ -0,0 +1,117 @@
+package com.huiju.estateagents.entity;
+
+import com.baomidou.mybatisplus.annotation.IdType;
+import com.baomidou.mybatisplus.annotation.TableField;
+import com.baomidou.mybatisplus.annotation.TableId;
+import java.io.Serializable;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.experimental.Accessors;
+
+/**
+ * <p>
+ * 置业顾问KPI 
+ * </p>
+ *
+ * @author yansen
+ * @since 2020-04-14
+ */
+@Data
+@EqualsAndHashCode(callSuper = false)
+@Accessors(chain = true)
+public class TsConsultantKpi implements Serializable {
+
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * 序号
+     */
+    @TableId(value = "serial_no", type = IdType.AUTO)
+    private Integer serialNo;
+
+    /**
+     * 统计日期 格式YYYYMMDD
+     */
+    private String statisDate;
+
+    /**
+     * 公司id
+     */
+    private Integer orgId;
+
+    /**
+     * 楼盘id
+     */
+    private String buildingId;
+
+    /**
+     * 楼盘名称
+     */
+    private String buildingName;
+
+    /**
+     * 置业顾问ID
+     */
+    private Integer userId;
+
+    /**
+     * 置业顾问名称
+     */
+    private String userName;
+
+    /**
+     * 置业顾问手机号
+     */
+    private String phone;
+
+    /**
+     * 新增客户
+     */
+    private Integer newPersons;
+
+    /**
+     * 分享次数
+     */
+    private Integer shareNum;
+
+    /**
+     * 分享访问人数
+     */
+    private Integer visitPersons;
+
+    /**
+     * 分享访问次数
+     */
+    private Integer visitNum;
+
+    /**
+     * 分享拓客
+     */
+    private Integer sharePersons;
+
+    /**
+     * 主页访问人数
+     */
+    private Integer homePagePersons;
+
+    /**
+     * 主页访问次数
+     */
+    private Integer homePageNums;
+
+    /**
+     * 咨询数
+     */
+    private Integer chatPersons;
+
+    /**
+     * 点赞数
+     */
+    private Integer favorNum;
+
+    /**
+     * 客户总计
+     */
+    @TableField(exist = false)
+    private Integer totalPersons;
+}

src/main/java/com/huiju/estateagents/excel/ConsultantKPIExport.java

@@ -0,0 +1,84 @@
+package com.huiju.estateagents.excel;
+
+import com.alibaba.excel.annotation.ExcelProperty;
+import lombok.Data;
+
+@Data
+public class ConsultantKPIExport {
+
+    /**
+     * 楼盘名称
+     */
+    @ExcelProperty(value = "项目", index = 0)
+    private String buildingName;
+
+
+    /**
+     * 置业顾问名称
+     */
+    @ExcelProperty(value = "置业顾问名称", index = 1)
+    private String userName;
+
+    /**
+     * 置业顾问手机号
+     */
+    @ExcelProperty(value = "置业顾问电话", index = 2)
+    private String phone;
+
+    @ExcelProperty(value = "客户总计", index = 3)
+    private Integer totalPersons;
+
+    /**
+     * 新增客户
+     */
+    @ExcelProperty(value = "新增客户数", index = 4)
+    private Integer newPersons;
+
+    /**
+     * 分享次数
+     */
+    @ExcelProperty(value = "分享次数", index = 5)
+    private Integer shareNum;
+
+    /**
+     * 分享访问人数
+     */
+    @ExcelProperty(value = "访问人数", index = 6)
+    private Integer visitPersons;
+
+    /**
+     * 分享访问次数
+     */
+    @ExcelProperty(value = "访问次数", index = 7)
+    private Integer visitNum;
+
+    /**
+     * 分享拓客
+     */
+    @ExcelProperty(value = "分享拓客数", index = 8)
+    private Integer sharePersons;
+
+    /**
+     * 主页访问人数
+     */
+    @ExcelProperty(value = "访问主页人数", index = 9)
+    private Integer homePagePersons;
+
+    /**
+     * 主页访问次数
+     */
+    @ExcelProperty(value = "访问主页次数", index = 10)
+    private Integer homePageNums;
+
+    /**
+     * 咨询数
+     */
+    @ExcelProperty(value = "咨询数", index = 11)
+    private Integer chatPersons;
+
+    /**
+     * 点赞数
+     */
+    @ExcelProperty(value = "点赞数", index = 12)
+    private Integer favorNum;
+}

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

@@ -191,4 +191,12 @@ public interface TaRecommendCustomerMapper extends BaseMapper<TaRecommendCustome
     List<PersonIntention> getCustomerIntentions(@Param("personId")String personId,@Param("personBuildingList") List<TaPersonBuilding> personBuildingList);
 
     IPage<TaRecommendCustomer>getCustomersIRecommended(IPage<TaRecommendCustomer> page,@Param("customerId")String customerId,@Param("status")Integer status,@Param("orgId") Integer orgId,@Param("personBuildingList") List<TaPersonBuilding> personBuildingList);
+
+    IPage<TaRecommendCustomer> getCustomerListOfConsultant(IPage<TaRecommendCustomer> page,
+                                                           @Param("orgId") Integer orgId,
+                                                           @Param("userId") String userId,
+                                                           @Param("buildingId") String buildingId,
+                                                           @Param("startDate") LocalDateTime startDate,
+                                                           @Param("endDate") LocalDateTime endDate
+                                                            );
 }

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

@@ -0,0 +1,194 @@
+package com.huiju.estateagents.mapper;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.huiju.estateagents.entity.TaPerson;
+import com.huiju.estateagents.entity.TaShareCount;
+import com.huiju.estateagents.entity.TsConsultantKpi;
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.huiju.estateagents.excel.ConsultantKPIExport;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+
+import java.time.LocalDateTime;
+import java.util.List;
+
+/**
+ * <p>
+ * 置业顾问KPI  Mapper 接口
+ * </p>
+ *
+ * @author yansen
+ * @since 2020-04-14
+ */
+@Mapper
+public interface TsConsultantKpiMapper extends BaseMapper<TsConsultantKpi> {
+
+    IPage<TsConsultantKpi> stsKPIDaily(IPage<TsConsultantKpi> page,
+                                       @Param("orgId") Integer orgId,
+                                       @Param("buildingId") String buildingId,
+                                       @Param("startDate") String startDate,
+                                       @Param("endDate") String endDate,
+                                       @Param("asc") String asc,
+                                       @Param("desc") String desc);
+
+    TsConsultantKpi stsKPITotalByOrg(@Param("orgId") Integer orgId, @Param("buildingId") String buildingId, @Param("startDate") String startDate, @Param("endDate") String endDate);
+
+    List<ConsultantKPIExport> stsKPIDailyExport(@Param("orgId") Integer orgId, @Param("buildingId") String buildingId, @Param("startDate") String startDate, @Param("endDate") String endDate);
+
+    /**
+     * 统计当前时间段内的, 已经固化的置业数据的所有客户
+     * @param orgId
+     * @param buildingId
+     * @param startDate
+     * @param endDate
+     * @return
+     */
+    Integer stsAllCustomersByOrg(@Param("orgId") Integer orgId, @Param("buildingId") String buildingId, @Param("startDate") String startDate, @Param("endDate") String endDate);
+
+
+    /**
+     * 获取置业分享拓客
+     * buildingId 暂时没有用到
+     * @param page
+     * @param orgId
+     * @param userId
+     * @param buildingId
+     * @param startDate
+     * @param endDate
+     * @return
+     */
+    IPage<TaPerson> getConsultantShareCustomers(IPage<TaPerson> page,
+                                              @Param("orgId") Integer orgId,
+                                              @Param("userId") String userId,
+                                              @Param("buildingId") String buildingId,
+                                              @Param("startDate") LocalDateTime startDate,
+                                              @Param("endDate") LocalDateTime endDate);
+
+    /**
+     * 置业卡片访问人数明细
+     * @param page
+     * @param orgId
+     * @param userId
+     * @param buildingId
+     * @param startDate
+     * @param endDate
+     * @return
+     */
+    IPage<TaPerson> getConsultantHomePagePersons(IPage<TaPerson> page,
+                                                 @Param("orgId") Integer orgId,
+                                                 @Param("userId") String userId,
+                                                 @Param("buildingId") String buildingId,
+                                                 @Param("startDate") LocalDateTime startDate,
+                                                 @Param("endDate") LocalDateTime endDate);
+
+    /**
+     * 置业卡片访问次数明细
+     * @param page
+     * @param orgId
+     * @param userId
+     * @param buildingId
+     * @param startDate
+     * @param endDate
+     * @return
+     */
+    IPage<TaPerson> getConsultantHomePageTimes(IPage<TaPerson> page,
+                                               @Param("orgId") Integer orgId,
+                                               @Param("userId") String userId,
+                                               @Param("buildingId") String buildingId,
+                                               @Param("startDate") LocalDateTime startDate,
+                                               @Param("endDate") LocalDateTime endDate);
+
+    /**
+     * 咨询置业人员
+     * @param page
+     * @param orgId
+     * @param userId
+     * @param buildingId
+     * @param startDate
+     * @param endDate
+     * @return
+     */
+    IPage<TaPerson> getConsultantChatPersons(IPage<TaPerson> page,
+                                             @Param("orgId") Integer orgId,
+                                             @Param("userId") String userId,
+                                             @Param("buildingId") String buildingId,
+                                             @Param("startDate") LocalDateTime startDate,
+                                             @Param("endDate") LocalDateTime endDate);
+
+    /**
+     * 点赞详情
+     * @param page
+     * @param orgId
+     * @param userId
+     * @param buildingId
+     * @param startDate
+     * @param endDate
+     * @return
+     */
+    IPage<TaPerson> getConsultantFavor(IPage<TaPerson> page,
+                                       @Param("orgId") Integer orgId,
+                                       @Param("userId") String userId,
+                                       @Param("buildingId") String buildingId,
+                                       @Param("startDate") LocalDateTime startDate,
+                                       @Param("endDate") LocalDateTime endDate);
+
+
+    /**
+     * 置业分享记录
+     * @param page
+     * @param orgId
+     * @param userId
+     * @param buildingId
+     * @param startDate
+     * @param endDate
+     * @param targetType
+     * @param targetName
+     * @return
+     */
+    IPage<TaPerson> getConsultantShareTargets(IPage<TaPerson> page,
+                                                  @Param("orgId") Integer orgId,
+                                                  @Param("userId") String userId,
+                                                  @Param("buildingId") String buildingId,
+                                                  @Param("startDate") LocalDateTime startDate,
+                                                  @Param("endDate") LocalDateTime endDate,
+                                                  @Param("targetType") String targetType,
+                                                  @Param("targetName") String targetName);
+
+    /**
+     * 置业分享访问人
+     * @param page
+     * @param orgId
+     * @param userId
+     * @param buildingId
+     * @param startDate
+     * @param endDate
+     * @return
+     */
+    IPage<TaPerson> getConsultantSharePersons(IPage<TaPerson> page,
+                                              @Param("orgId") Integer orgId,
+                                              @Param("userId") String userId,
+                                              @Param("buildingId") String buildingId,
+                                              @Param("startDate") LocalDateTime startDate,
+                                              @Param("endDate") LocalDateTime endDate);
+
+    /**
+     * 置业分享访问明细
+     * @param page
+     * @param orgId
+     * @param userId
+     * @param buildingId
+     * @param startDate
+     * @param endDate
+     * @param targetType
+     * @param targetName
+     * @return
+     */
+    IPage<TaPerson> getConsultantShareTimes(IPage<TaPerson> page,
+                                            @Param("orgId") Integer orgId,
+                                            @Param("userId") String userId,
+                                            @Param("buildingId") String buildingId,
+                                            @Param("startDate") LocalDateTime startDate,
+                                            @Param("endDate") LocalDateTime endDate,
+                                            @Param("targetType") String targetType,
+                                            @Param("targetName") String targetName);
+}

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

@@ -0,0 +1,44 @@
+package com.huiju.estateagents.service;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.huiju.estateagents.entity.*;
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.huiju.estateagents.excel.ConsultantKPIExport;
+
+import java.time.LocalDateTime;
+import java.util.List;
+
+/**
+ * <p>
+ * 置业顾问KPI  服务类
+ * </p>
+ *
+ * @author yansen
+ * @since 2020-04-14
+ */
+public interface ITsConsultantKpiService extends IService<TsConsultantKpi> {
+
+    IPage<TsConsultantKpi> stsKPIDaily(Integer pageNum, Integer pageSize, Integer orgId, String buildingId, String startDate, String endDate, String asc, String desc);
+
+    TsConsultantKpi stsKPITotalByOrg(Integer orgId, String buildingId, String startDate, String endDate);
+
+    List<ConsultantKPIExport> stsKPIDailyExport(Integer orgId, String buildingId, String startDate, String endDate);
+
+    IPage<TaRecommendCustomer> getCustomerListOfConsultant(IPage<TaRecommendCustomer> page, Integer orgId, String userId, String buildingId, LocalDateTime startDate, LocalDateTime endDate);
+
+    IPage<TaPerson> getConsultantShareCustomers(IPage<TaPerson> page, Integer orgId, String userId, String buildingId, LocalDateTime startDate, LocalDateTime endDate);
+
+    IPage<TaPerson> getConsultantHomePagePersons(IPage<TaPerson> page, Integer orgId, String userId, String buildingId, LocalDateTime startDate, LocalDateTime endDate);
+
+    IPage<TaPerson> getConsultantHomePageTimes(IPage<TaPerson> page, Integer orgId, String userId, String buildingId, LocalDateTime startDate, LocalDateTime endDate);
+
+    IPage<TaPerson> getConsultantChatPersons(IPage<TaPerson> page, Integer orgId, String userId, String buildingId, LocalDateTime startDate, LocalDateTime endDate);
+
+    IPage<TaPerson> getConsultantFavor(IPage<TaPerson> page, Integer orgId, String userId, String buildingId, LocalDateTime startDate, LocalDateTime endDate);
+
+    IPage<TaPerson> getConsultantShareTargets(IPage<TaPerson> page, Integer orgId, String userId, String buildingId, LocalDateTime startDate, LocalDateTime endDate, String targetType, String targetName);
+
+    IPage<TaPerson> getConsultantSharePersons(IPage<TaPerson> page, Integer orgId, String userId, String buildingId, LocalDateTime startDate, LocalDateTime endDate);
+
+    IPage<TaPerson> getConsultantShareTimes(IPage<TaPerson> page, Integer orgId, String userId, String buildingId, LocalDateTime startDate, LocalDateTime endDate, String targetType, String targetName);
+}

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

@@ -79,6 +79,7 @@ public class TaShareServiceImpl extends ServiceImpl<TaShareMapper, TaShare> impl
         taShareCount.setCreateDate(LocalDateTime.now());
         taShareCount.setPersonId(taPerson.getPersonId());
         taShareCount.setTagertType(typeOf);
+        taShareCount.setOrgId(taPerson.getOrgId());
         int countRow = taShareCountMapper.insert(taShareCount);
         if (countRow < 1) {
             return ResponseBean.error("分享增加失败", ResponseBean.ERROR_UNAVAILABLE);

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

@@ -0,0 +1,111 @@
+package com.huiju.estateagents.service.impl;
+
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.huiju.estateagents.common.StringUtils;
+import com.huiju.estateagents.entity.*;
+import com.huiju.estateagents.excel.ConsultantKPIExport;
+import com.huiju.estateagents.mapper.TaRecommendCustomerMapper;
+import com.huiju.estateagents.mapper.TsConsultantKpiMapper;
+import com.huiju.estateagents.service.ITsConsultantKpiService;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.time.LocalDateTime;
+import java.util.List;
+
+/**
+ * <p>
+ * 置业顾问KPI  服务实现类
+ * </p>
+ *
+ * @author yansen
+ * @since 2020-04-14
+ */
+@Service
+public class TsConsultantKpiServiceImpl extends ServiceImpl<TsConsultantKpiMapper, TsConsultantKpi> implements ITsConsultantKpiService {
+    @Autowired
+    TsConsultantKpiMapper tsConsultantKpiMapper;
+
+    @Autowired
+    TaRecommendCustomerMapper taRecommendCustomerMapper;
+
+    @Override
+    public IPage<TsConsultantKpi> stsKPIDaily(Integer pageNum, Integer pageSize, Integer orgId, String buildingId, String startDate, String endDate, String asc, String desc) {
+        if (StringUtils.isEmpty(asc) && StringUtils.isEmpty(desc)) {
+            desc = "new_persons";
+        }
+
+        IPage<TsConsultantKpi> page = new Page<>(pageNum, pageSize);
+        return tsConsultantKpiMapper.stsKPIDaily(page, orgId, buildingId, startDate, endDate, asc, desc);
+    }
+
+    @Override
+    public TsConsultantKpi stsKPITotalByOrg(Integer orgId, String buildingId, String startDate, String endDate) {
+        // 合计数据, 但是不包含 客户总计 列
+        TsConsultantKpi result = tsConsultantKpiMapper.stsKPITotalByOrg(orgId, buildingId, startDate, endDate);
+
+        // 统计当前时间段内的已经固化的置业的客户
+        Integer totalPersons = tsConsultantKpiMapper.stsAllCustomersByOrg(orgId, buildingId, startDate, endDate);
+        result.setTotalPersons(totalPersons);
+
+        return result;
+    }
+
+    @Override
+    public List<ConsultantKPIExport> stsKPIDailyExport(Integer orgId, String buildingId, String startDate, String endDate) {
+        return tsConsultantKpiMapper.stsKPIDailyExport(orgId, buildingId, startDate, endDate);
+    }
+
+    @Override
+    public IPage<TaRecommendCustomer> getCustomerListOfConsultant(IPage<TaRecommendCustomer> page, Integer orgId, String userId, String buildingId, LocalDateTime startDate, LocalDateTime endDate) {
+        return taRecommendCustomerMapper.getCustomerListOfConsultant(page, orgId, userId, buildingId, startDate, endDate);
+    }
+
+    @Override
+    public IPage<TaPerson> getConsultantShareCustomers(IPage<TaPerson> page, Integer orgId, String userId, String buildingId, LocalDateTime startDate, LocalDateTime endDate) {
+        // buildingId 在表里不一定有数据, 实际执行 SQL 中没有这个条件
+        return tsConsultantKpiMapper.getConsultantShareCustomers(page, orgId, userId, buildingId, startDate, endDate);
+    }
+
+    @Override
+    public IPage<TaPerson> getConsultantHomePagePersons(IPage<TaPerson> page, Integer orgId, String userId, String buildingId, LocalDateTime startDate, LocalDateTime endDate) {
+        return tsConsultantKpiMapper.getConsultantHomePagePersons(page, orgId, userId, buildingId, startDate, endDate);
+    }
+
+    @Override
+    public IPage<TaPerson> getConsultantHomePageTimes(IPage<TaPerson> page, Integer orgId, String userId, String buildingId, LocalDateTime startDate, LocalDateTime endDate) {
+        return tsConsultantKpiMapper.getConsultantHomePageTimes(page, orgId, userId, buildingId, startDate, endDate);
+    }
+
+    @Override
+    public IPage<TaPerson> getConsultantChatPersons(IPage<TaPerson> page, Integer orgId, String userId, String buildingId, LocalDateTime startDate, LocalDateTime endDate) {
+        // buildingId 在聊天表不存在, 因此没有用到这个字段
+        return tsConsultantKpiMapper.getConsultantChatPersons(page, orgId, userId, buildingId, startDate, endDate);
+    }
+
+    @Override
+    public IPage<TaPerson> getConsultantFavor(IPage<TaPerson> page, Integer orgId, String userId, String buildingId, LocalDateTime startDate, LocalDateTime endDate) {
+        // buildingId 在点赞表不存在, 因此没有用到这个字段
+        return tsConsultantKpiMapper.getConsultantFavor(page, orgId, userId, buildingId, startDate, endDate);
+    }
+
+    @Override
+    public IPage<TaPerson> getConsultantShareTargets(IPage<TaPerson> page, Integer orgId, String userId, String buildingId, LocalDateTime startDate, LocalDateTime endDate, String targetType, String targetName) {
+        return tsConsultantKpiMapper.getConsultantShareTargets(page, orgId, userId, buildingId, startDate, endDate, targetType, targetName);
+    }
+
+    @Override
+    public IPage<TaPerson> getConsultantSharePersons(IPage<TaPerson> page, Integer orgId, String userId, String buildingId, LocalDateTime startDate, LocalDateTime endDate) {
+        // buildingId 在表里不一定有数据, 实际执行 SQL 中没有这个条件
+        return tsConsultantKpiMapper.getConsultantSharePersons(page, orgId, userId, buildingId, startDate, endDate);
+    }
+
+    @Override
+    public IPage<TaPerson> getConsultantShareTimes(IPage<TaPerson> page, Integer orgId, String userId, String buildingId, LocalDateTime startDate, LocalDateTime endDate, String targetType, String targetName) {
+        // buildingId 在表里不一定有数据, 实际执行 SQL 中没有这个条件
+        return tsConsultantKpiMapper.getConsultantShareTimes(page, orgId, userId, buildingId, startDate, endDate, targetType, targetName);
+    }
+
+}

src/main/resources/mapper/TaRecommendCustomerMapper.xml

@@ -823,4 +823,21 @@ FROM
         </if>
     </select>
 
+    <select id="getCustomerListOfConsultant" resultType="com.huiju.estateagents.entity.TaRecommendCustomer">
+        select s.*, t.avatarurl
+        from ta_recommend_customer s
+        left join ta_person t on t.person_id = s.person_id
+        where s.org_id = #{orgId}
+        and s.realty_consultant = #{userId}
+        <if test="startDate != null">
+            and s.create_date BETWEEN #{startDate} and #{endDate}
+        </if>
+        <if test="buildingId != null and buildingId !=''">
+        and s.building_id = #{buildingId}
+        </if>
+        and s.status &gt; 0
+        order by s.report_date desc
+    </select>
+
+
 </mapper>

src/main/resources/mapper/TsConsultantKpiMapper.xml

@@ -0,0 +1,344 @@
+<?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.huiju.estateagents.mapper.TsConsultantKpiMapper">
+
+    <!-- 按照项目, 置业分组统计, 注意查询与分组条件, 必须与下面的汇总，导出一致 -->
+    <select id="stsKPIDaily" resultType="com.huiju.estateagents.entity.TsConsultantKpi">
+        SELECT * FROM (
+            SELECT
+                1 AS serial_no,
+                '2020' AS statis_date,
+                t.org_id,
+                t.building_id,
+                t.building_name,
+                t.user_id,
+                t.user_name,
+                IFNULL(sum( t.new_persons ),0) AS new_persons,
+                IFNULL(sum( t.share_num ),0) AS share_num,
+                IFNULL(sum( t.visit_persons ),0) AS visit_persons,
+                IFNULL(sum( t.visit_num ),0) AS visit_num,
+                IFNULL(sum( t.share_persons ),0) AS share_persons,
+                IFNULL(sum( t.home_page_persons ),0) AS home_page_persons,
+                IFNULL(sum( t.home_page_nums ),0) AS home_page_nums,
+                IFNULL(sum( t.chat_persons ),0) AS chat_persons,
+                IFNULL(sum( t.favor_num ),0) AS favor_num,
+                (select count(DISTINCT s.customer_id) from ta_recommend_customer s
+                 where s.org_id = t.org_id and (s.realty_consultant = t.user_id or s.realty_consultant = m.person_id) and (s.building_id = t.building_id or IFNULL(t.building_id, '') = '') and s.status > 0) as total_persons
+            FROM
+                ts_consultant_kpi t
+            LEFT JOIN ta_person m on m.org_id = #{orgId} and m.user_id = t.user_id
+            WHERE
+                t.org_id = #{orgId}
+                AND t.statis_date BETWEEN #{startDate} AND #{endDate}
+            <if test="buildingId != null and buildingId != ''">
+                AND t.building_id = #{buildingId}
+            </if>
+            GROUP BY
+                t.user_id,
+                t.building_id
+        ) a
+
+        <if test="asc != null and asc != ''">
+            ORDER BY ${asc} asc
+        </if>
+        <if test="desc != null and desc != ''">
+            ORDER BY ${desc} desc
+        </if>
+    </select>
+
+    <!-- 按照小程序分组统计, 注意查询与分组条件, 必须与之前的汇总，导出一致 -->
+    <select id="stsKPITotalByOrg" resultType="com.huiju.estateagents.entity.TsConsultantKpi">
+        SELECT
+            1 AS serial_no,
+            '2020' AS statis_date,
+            t.org_id,
+            '' as building_id,
+            '-' as building_name,
+            0 as user_id,
+            '-' as user_name,
+            IFNULL(sum( t.new_persons ),0) AS new_persons,
+            IFNULL(sum( t.share_num ),0) AS share_num,
+            IFNULL(sum( t.visit_persons ),0) AS visit_persons,
+            IFNULL(sum( t.visit_num ),0) AS visit_num,
+            IFNULL(sum( t.share_persons ),0) AS share_persons,
+            IFNULL(sum( t.home_page_persons ),0) AS home_page_persons,
+            IFNULL(sum( t.home_page_nums ),0) AS home_page_nums,
+            IFNULL(sum( t.chat_persons ),0) AS chat_persons,
+            IFNULL(sum( t.favor_num ),0) AS favor_num,
+
+            <!-- 这一列单独统计 -->
+            0 as total_persons
+        FROM
+            ts_consultant_kpi t
+        WHERE
+            t.org_id = #{orgId}
+            AND t.statis_date BETWEEN #{startDate} AND #{endDate}
+        <if test="buildingId != null and buildingId != ''">
+            AND t.building_id = #{buildingId}
+        </if>
+    </select>
+
+    <!-- 导出 -->
+    <select id="stsKPIDailyExport" resultType="com.huiju.estateagents.excel.ConsultantKPIExport">
+        SELECT
+            1 AS serial_no,
+            '2020' AS statis_date,
+            t.org_id,
+            t.building_id,
+            t.building_name,
+            t.user_id,
+            t.user_name,
+            t.phone,
+            IFNULL(sum( t.new_persons ),0) AS new_persons,
+            IFNULL(sum( t.share_num ),0) AS share_num,
+            IFNULL(sum( t.visit_persons ),0) AS visit_persons,
+            IFNULL(sum( t.visit_num ),0) AS visit_num,
+            IFNULL(sum( t.share_persons ),0) AS share_persons,
+            IFNULL(sum( t.home_page_persons ),0) AS home_page_persons,
+            IFNULL(sum( t.home_page_nums ),0) AS home_page_nums,
+            IFNULL(sum( t.chat_persons ),0) AS chat_persons,
+            IFNULL(sum( t.favor_num ),0) AS favor_num,
+            (select count(DISTINCT s.customer_id) from ta_recommend_customer s
+             where s.org_id = t.org_id and (s.realty_consultant = t.user_id or s.realty_consultant = m.person_id) and (s.building_id = t.building_id or IFNULL(t.building_id, '') = '') and s.status > 0) as total_persons
+        FROM
+            ts_consultant_kpi t
+        LEFT JOIN ta_person m on m.org_id = #{orgId} and m.user_id = t.user_id
+        WHERE
+            t.org_id = #{orgId}
+        AND t.statis_date BETWEEN #{startDate} AND #{endDate}
+        <if test="buildingId != null and buildingId != ''">
+            AND t.building_id = #{buildingId}
+        </if>
+        GROUP BY
+            t.user_id,
+            t.building_id
+        ORDER BY sum( new_persons ) desc
+    </select>
+
+    <select id="stsAllCustomersByOrg" resultType="java.lang.Integer">
+        SELECT
+            count(DISTINCT p.customer_id)
+        FROM
+            ta_recommend_customer p
+        INNER JOIN ta_person s ON s.org_id = p.org_id
+            AND ( p.realty_consultant = s.user_id OR p.realty_consultant = s.person_id )
+        INNER JOIN ts_consultant_kpi t ON t.org_id = s.org_id
+            AND t.user_id = s.user_id
+            AND ( t.building_id = p.building_id OR IFNULL( t.building_id, '' ) = '' )
+        WHERE
+            p.org_id = #{orgId}
+            AND p.`status` > 0
+            AND t.statis_date BETWEEN #{startDate} AND #{endDate}
+        <if test="buildingId != null and buildingId != ''">
+            AND t.building_id = #{buildingId}
+        </if>
+    </select>
+
+    <select id="getConsultantShareCustomers" resultType="com.huiju.estateagents.entity.TaPerson">
+        SELECT
+        t.*
+        FROM ta_share_person_from e
+        INNER JOIN ta_person t ON t.person_id = e.person_id
+        WHERE e.org_id = #{orgId}
+        AND e.share_person = #{userId}
+        AND e.create_date BETWEEN #{startDate} and #{endDate}
+        <!-- building_id 字段数据不全
+        <if test="buildingId != null and buildingId !=''">
+            AND e.building_id = #{buildingId}
+        </if>
+        -->
+        AND e.is_first_time = 1
+        AND t.phone is not null
+
+<!--        为了与存储过程一致 -->
+<!--        AND t.`status` = 1-->
+        ORDER BY e.create_date DESC;
+    </select>
+
+    <select id="getConsultantHomePagePersons" resultType="com.huiju.estateagents.entity.TaPerson">
+        SELECT
+            t.*,
+            count( * ) as visit_times,
+            MAX(f.visit_time) as visit_time
+        FROM
+            ta_person t
+        INNER JOIN ta_person_visit_record f ON f.org_id = #{orgId} AND f.person_id = t.person_id
+        INNER JOIN ta_person s on s.person_id = f.target_id
+        WHERE t.org_id = #{orgId}
+
+<!--        为了与存储过程一致 -->
+<!--            AND t.`status` = 1-->
+        <if test="buildingId != null and buildingId !=''">
+            AND f.building_id = #{buildingId}
+        </if>
+            AND f.event_type = 'card'
+            AND f.visit_time BETWEEN #{startDate} and #{endDate}
+            AND s.user_id = #{userId}
+
+<!--        为了与存储过程一致 -->
+<!--            AND s.`status` = 1-->
+        GROUP BY t.person_id
+        ORDER BY t.create_date DESC;
+    </select>
+
+    <select id="getConsultantHomePageTimes" resultType="com.huiju.estateagents.entity.TaPerson">
+        SELECT
+            t.*,
+            f.visit_time as visit_time
+        FROM
+            ta_person t
+        INNER JOIN ta_person_visit_record f ON f.org_id = #{orgId} AND f.person_id = t.person_id
+        INNER JOIN ta_person s on s.person_id = f.target_id
+        WHERE t.org_id = #{orgId}
+
+<!--        为了与存储过程一致 -->
+<!--            AND t.`status` = 1-->
+        <if test="buildingId != null and buildingId !=''">
+            AND f.building_id = #{buildingId}
+        </if>
+            AND f.event_type = 'card'
+            AND f.visit_time BETWEEN #{startDate} and #{endDate}
+            AND s.user_id = #{userId}
+
+<!--        为了与存储过程一致 -->
+<!--            AND s.`status` = 1-->
+        ORDER BY t.create_date DESC;
+    </select>
+
+    <select id="getConsultantChatPersons" resultType="com.huiju.estateagents.entity.TaPerson">
+        SELECT
+            t.*,
+            max( h.create_date ) AS visit_time
+        FROM
+            ta_person t
+        INNER JOIN ta_chat h ON h.send_person = t.person_id
+        INNER JOIN ta_person s ON s.person_id = h.receive_person
+        WHERE t.org_id = #{orgId}
+
+<!--        为了与存储过程一致 -->
+<!--            AND t.`status` = 1-->
+            AND h.create_date BETWEEN #{startDate} and #{endDate}
+            AND s.user_id = #{userId}
+
+<!--        为了与存储过程一致 -->
+<!--            AND s.`status` = 1-->
+        GROUP BY
+            t.person_id
+        ORDER BY
+            h.create_date DESC
+    </select>
+
+    <select id="getConsultantFavor" resultType="com.huiju.estateagents.entity.TaPerson">
+        SELECT
+            t.*,
+            max( i.create_date ) AS visit_time
+        FROM
+            ta_person t
+        INNER JOIN ta_favor i ON i.person_id = t.person_id
+        INNER JOIN ta_person s ON s.person_id = i.be_favor
+        WHERE t.org_id = #{orgId}
+
+<!--        为了与存储过程一致 -->
+<!--            AND t.`status` = 1-->
+            AND i.tagert_type = 'consultant'
+            AND i.create_date BETWEEN #{startDate} and #{endDate}
+            AND s.user_id = #{userId}
+
+<!--        为了与存储过程一致 -->
+<!--            AND s.`status` = 1-->
+        ORDER BY
+            i.create_date DESC
+    </select>
+
+    <select id="getConsultantShareTargets" resultType="com.huiju.estateagents.entity.TaPerson">
+        SELECT
+            s.*,
+            t.tagert_type as target_type,
+            t.target_name,
+            t.be_share as target_id,
+            t.create_date as visit_time
+        FROM
+            ta_share_count t
+        INNER JOIN ta_person s ON s.person_id = t.person_id
+        WHERE
+            t.org_id = #{orgId}
+
+        <!-- 没有设置 targetType 查询条件, 则只查询固定的几个 -->
+        <if test="targetType == null or targetType ==''">
+            AND (
+            t.tagert_type IN ( 'project', 'activity', 'group', 'h5', 'help', 'news', 'main' )
+            OR t.tagert_type like 'house%'
+            OR t.tagert_type like 'live%'
+            )
+        </if>
+        <if test="targetType != null and targetType !=''">
+            AND t.tagert_type like concat(#{targetType}, '%')
+        </if>
+
+            AND t.create_date BETWEEN #{startDate} and #{endDate}
+        <if test="targetName != null and targetName !=''">
+            AND t.target_name LIKE concat('%', #{targetName}, '%')
+        </if>
+            AND s.user_id = #{userId}
+
+<!--        为了与存储过程一致 -->
+<!--            AND s.`status` = 1-->
+        ORDER BY t.create_date DESC
+    </select>
+
+    <select id="getConsultantSharePersons" resultType="com.huiju.estateagents.entity.TaPerson">
+        SELECT
+            t.*,
+            count(*) as visit_times,
+            max(e.create_date) as visit_time
+        FROM ta_share_person_from e
+        INNER JOIN ta_person t ON t.person_id = e.person_id
+        WHERE e.org_id = #{orgId}
+            AND e.share_person = #{userId}
+            AND e.create_date BETWEEN #{startDate} and #{endDate}
+            <!-- building_id 字段数据不全
+            <if test="buildingId != null and buildingId !=''">
+                AND e.building_id = #{buildingId}
+            </if>
+            -->
+<!--            AND t.`status` = 1-->
+        GROUP BY t.person_id
+        ORDER BY e.create_date DESC
+    </select>
+
+    <select id="getConsultantShareTimes" resultType="com.huiju.estateagents.entity.TaPerson">
+        SELECT
+            t.*,
+            e.create_date as visit_times,
+            e.target_type,
+            e.target_id,
+            e.target_name
+        FROM ta_share_person_from e
+        INNER JOIN ta_person t ON t.person_id = e.person_id
+        WHERE e.org_id = #{orgId}
+            AND e.share_person = #{userId}
+
+        <!-- 没有设置 targetType 查询条件, 则只查询固定的几个 -->
+        <if test="targetType == null or targetType ==''">
+            AND (
+            e.target_type IN ( 'building_share', 'dynamic_share', 'group_share', 'h5_share', 'help_share', 'house_share', 'live_share', 'news_share' )
+            OR ( e.target_type = 'share' AND e.target_id = 'index' )
+            )
+        </if>
+        <if test="targetType != null and targetType !=''">
+            AND e.target_type = 'share'
+        </if>
+        <if test="targetType != null and targetType =='share'">
+            AND e.target_id = 'index'
+        </if>
+
+            AND e.create_date BETWEEN #{startDate} and #{endDate}
+            <!-- building_id 字段数据不全
+            <if test="buildingId != null and buildingId !=''">
+                AND e.building_id = #{buildingId}
+            </if>
+            -->
+            <!--            AND t.`status` = 1-->
+        ORDER BY e.create_date DESC
+    </select>
+</mapper>