* bug修复

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

                                             @RequestParam(value = "pageSize", defaultValue = "2") Integer pageSize,
                                             @RequestParam(value = "buildingId", required = false) String buildingId,
                                             HttpServletRequest request) {
-        return iStatisticalService.selectIntentionUser(pageNum, pageSize, getOrgId(request), buildingId);
+        Integer userId = getUserId(request);
+        return iStatisticalService.selectIntentionUser(pageNum, pageSize, getOrgId(request), buildingId, userId);
     }
 
     /**

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

      * @param buildingId
      * @return
      */
-    IPage<Map<String, Object>> selectIntentionUser(IPage<Map<String, Object>> page, @Param("orgId") Integer orgId, @Param("buildingId") String buildingId);
+    IPage<Map<String, Object>> selectIntentionUser(IPage<Map<String, Object>> page,
+                                                   @Param("orgId") Integer orgId,
+                                                   @Param("buildingId") String buildingId,
+                                                   @Param("userId") Integer userId);
 }

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

      * @param buildingId
      * @return
      */
-    ResponseBean selectIntentionUser(Integer pageNum, Integer pageSize, Integer orgId, String buildingId);
+    ResponseBean selectIntentionUser(Integer pageNum, Integer pageSize, Integer orgId, String buildingId, Integer userId);
 
     /**
      * 用户来源数据 首页

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

     public ResponseBean indexStatistical(Integer orgId) {
 
         ResponseBean responseBean = new ResponseBean();
-        Map<String,Object> map = new HashMap<>();
+        Map<String, Object> map = new HashMap<>();
 
         // 总用户数
         Integer selectUserCount = taPersonMapper.selectUserCount(orgId);
                 result.put("data_count", selectBuildingStatisticalSave);
                 break;
             case CommConstant.BUILDING_SHARE:
-                Map<String, Object> selectBuildingStatisticalShare = taBuildingMapper.selectBuildingStatistical(orgId,"share");
+                Map<String, Object> selectBuildingStatisticalShare = taBuildingMapper.selectBuildingStatistical(orgId, "share");
                 result.put("data_count", selectBuildingStatisticalShare);
                 break;
             case CommConstant.ACTIVITY_SAVE:
 
         // 用户来源饼状
         // 来源置业顾问, 来源客户，其他
-        Integer total = taPersonMapper.selectFromNum(orgId, null) ;
+        Integer total = taPersonMapper.selectFromNum(orgId, null);
         Integer person_realty_consultant = taPersonMapper.selectFromNum(orgId, CommConstant.PERSON_REALTY_CONSULTANT);
         Integer person_estate_agent = taPersonMapper.selectFromNum(orgId, CommConstant.PERSON_ESTATE_CUSTOMER);
         Integer person_null = total - person_realty_consultant - person_estate_agent;
         List<Map<String, Object>> selectUserSourceData = taPersonMapper.selectUserSourceData(orgId, CommConstant.PERSON_ESTATE_AGENT, startDate, endDate);
 
         Map<String, Object> result = new HashMap<>();
-        result.put("columnar", new ArrayList<Map<String,Object>>());
+        result.put("columnar", new ArrayList<Map<String, Object>>());
         result.put("pie", map);
         result.put("data", selectUserSourceData);
 
     }
 
     @Override
-    public ResponseBean selectIntentionUser(Integer pageNum, Integer pageSize, Integer orgId, String buildingId) {
+    public ResponseBean selectIntentionUser(Integer pageNum, Integer pageSize, Integer orgId, String buildingId, Integer userId) {
         ResponseBean responseBean = new ResponseBean();
 
-        IPage<Map<String,Object>> pg = new Page<>(pageNum, pageSize);
-        IPage<Map<String, Object>> page = taPersonIntentionRecordMapper.selectIntentionUser(pg, orgId, buildingId);
+        IPage<Map<String, Object>> pg = new Page<>(pageNum, pageSize);
+        IPage<Map<String, Object>> page = taPersonIntentionRecordMapper.selectIntentionUser(pg, orgId, buildingId, userId);
 
         responseBean.addSuccess(page);
         return responseBean;
     @Override
     public ResponseBean selectPersonFrom(Integer orgId, LocalDate startDate, LocalDate endDate) {
         ResponseBean responseBean = new ResponseBean();
-        List<TsPersonFromStatistic> list = tsPersonFromStatisticMapper.selectPersonFrom(orgId,startDate,endDate);
+        List<TsPersonFromStatistic> list = tsPersonFromStatisticMapper.selectPersonFrom(orgId, startDate, endDate);
         QueryWrapper<TdWxDict> tdWxDictQueryWrapper = new QueryWrapper<>();
         tdWxDictQueryWrapper.groupBy("scene_type");
         List<TdWxDict> tdWxDicts = tdWxDictMapper.selectList(tdWxDictQueryWrapper);
             e.setFromData(fromSum);
             e.setRegisterSum(registerSum);
         });
-        Map<String,Object> map = new HashMap<>();
-        map.put("tdWxDicts",tdWxDicts);
-        List<TsPersonFromStatistic> tableList = tsPersonFromStatisticMapper.selectPersonFromGroupByData(orgId,startDate,endDate);
-        map.put("list",tableList);
+        Map<String, Object> map = new HashMap<>();
+        map.put("tdWxDicts", tdWxDicts);
+        List<TsPersonFromStatistic> tableList = tsPersonFromStatisticMapper.selectPersonFromGroupByData(orgId, startDate, endDate);
+        map.put("list", tableList);
         responseBean.addSuccess(map);
         return responseBean;
     }
     @Override
     public ResponseBean selectPersonFromGroupByDay(Integer orgId, LocalDate startDate, LocalDate endDate) {
         List<TsPersonFromStatistic> dayList = getDayList(startDate, endDate);
-        List<TsPersonFromStatistic> list = tsPersonFromStatisticMapper.selectPersonFromGroupByDay(orgId,startDate,endDate);
+        List<TsPersonFromStatistic> list = tsPersonFromStatisticMapper.selectPersonFromGroupByDay(orgId, startDate, endDate);
         dayList.forEach(e -> {
             list.forEach(l -> {
-                if (e.getCreateTime().equals(l.getCreateTime())){
+                if (e.getCreateTime().equals(l.getCreateTime())) {
                     e.setFromNum(l.getFromNum());
                     e.setRegisteredNum(l.getRegisteredNum());
                 }
 
     /**
      * 返回时间区间格式
+     *
      * @param startDate
      * @param endDate
      * @return
      */
     private List<TsPersonFromStatistic> getDayList(LocalDate startDate, LocalDate endDate) {
-        if (null == startDate || null == endDate){
+        if (null == startDate || null == endDate) {
             endDate = LocalDate.now();
             startDate = LocalDate.now().plusDays(-7);
         }

src/main/resources/mapper/TaPersonIntentionRecordMapper.xml

                     AND tpir.org_id = #{orgId}
                     AND tp.org_id = #{orgId}
                 </if>
+                <if test="userId != null">
+                    AND tpir.building_id IN ( SELECT t3.building_id FROM ta_person_building t3 WHERE t3.user_id = #{userId} )
+                </if>
             </trim>
         GROUP BY
             tpir.person_id, tpir.building_id