feats

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

 package com.huiju.estateagents.controller;
 
+import com.huiju.estateagents.base.BaseController;
 import com.huiju.estateagents.base.ResponseBean;
 import com.huiju.estateagents.service.IStatisticalService;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.format.annotation.DateTimeFormat;
 import org.springframework.web.bind.annotation.*;
 
+import javax.servlet.http.HttpServletRequest;
 import java.time.LocalDate;
-import java.util.Date;
 
 /**
  * 数据统计
  */
 @RestController
 @RequestMapping("/api")
-public class StatisticalController {
+public class StatisticalController extends BaseController {
 
     @Autowired
     private IStatisticalService iStatisticalService;
      * @return
      */
     @GetMapping(value = "/admin/indexStatistical")
-    public ResponseBean indexStatistical() {
-        return iStatisticalService.indexStatistical();
+    public ResponseBean indexStatistical(HttpServletRequest request) {
+        return iStatisticalService.indexStatistical(getOrgId(request));
     }
 
     /**
     @GetMapping(value = "/admin/selectActiveUserCount")
     public ResponseBean selectActiveUserCount(@RequestParam String dateType,
                                               @RequestParam(value = "startDate", required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME) LocalDate startDate,
-                                              @RequestParam(value = "endDate", required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME)  LocalDate endDate) {
-        return iStatisticalService.selectActiveUserCount(dateType, startDate,endDate);
+                                              @RequestParam(value = "endDate", required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME)  LocalDate endDate,
+                                              HttpServletRequest request) {
+        return iStatisticalService.selectActiveUserCount(getOrgId(request), dateType, startDate,endDate);
     }
 
     /**
      */
     @GetMapping(value = "/admin/selectNewsUserCount")
     public ResponseBean selectNewsUserCount(@RequestParam(value = "startDate", required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME) LocalDate startDate,
-                                            @RequestParam(value = "endDate", required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME)  LocalDate endDate) {
-        return iStatisticalService.selectNewsUserCount(startDate, endDate);
+                                            @RequestParam(value = "endDate", required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME)  LocalDate endDate,
+                                            HttpServletRequest request) {
+        return iStatisticalService.selectNewsUserCount(getOrgId(request), startDate, endDate);
     }
 
     /**
      * @return
      */
     @GetMapping(value = "/admin/selectConversion")
-    public ResponseBean selectConversion(@RequestParam("conversion") String conversion) {
-        return iStatisticalService.selectConversion(conversion);
+    public ResponseBean selectConversion(@RequestParam("conversion") String conversion,
+                                         HttpServletRequest request) {
+        return iStatisticalService.selectConversion(getOrgId(request), conversion);
     }
 
     /**
                                            @RequestParam(value = "buildingId", required = false) String buildingId,
                                            @RequestParam(value = "eventType", required = false) String eventType,
                                            @RequestParam(value = "event", required = false) String event,
-                                           @RequestParam(value = "activity", required = false) String activity) {
-        return iStatisticalService.selectUserBehavior(pageNum, pageSize, startDate, endDate, buildingId, eventType, event, activity);
+                                           @RequestParam(value = "activity", required = false) String activity,
+                                           HttpServletRequest request) {
+        return iStatisticalService.selectUserBehavior(pageNum, pageSize, getOrgId(request), startDate, endDate, buildingId, eventType, event, activity);
     }
 
     /**
      */
     @GetMapping(value = "/admin/selectEventAll")
     public ResponseBean selectEventAll(@RequestParam(required = false) String event,
-                                              @RequestParam(required = false) String personId) {
-        return iStatisticalService.selectEventAll(event, personId);
+                                       @RequestParam(required = false) String personId,
+                                       HttpServletRequest request) {
+        return iStatisticalService.selectEventAll(getOrgId(request), event, personId);
     }
 
 
      */
     @GetMapping(value = "/admin/selectUserResource")
     public ResponseBean selectUserResource(@RequestParam(value = "startDate", required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME) LocalDate startDate,
-                                           @RequestParam(value = "endDate", required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME)  LocalDate endDate) {
-        return iStatisticalService.selectUserResource(startDate, endDate);
+                                           @RequestParam(value = "endDate", required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME)  LocalDate endDate,
+                                           HttpServletRequest request) {
+        return iStatisticalService.selectUserResource(getOrgId(request), startDate, endDate);
     }
 
 
      * @return
      */
     @GetMapping(value = "/admin/selectUserCount")
-    public ResponseBean selectUserResource() {
-        return iStatisticalService.selectUserCount();
+    public ResponseBean selectUserResource(HttpServletRequest request) {
+        return iStatisticalService.selectUserCount(getOrgId(request));
     }
 
     /**
      * @return
      */
     @GetMapping(value = "/admin/selectRegisteredCount")
-    public ResponseBean selectRegisteredCount() {
-        return iStatisticalService.selectRegisteredCount();
+    public ResponseBean selectRegisteredCount(HttpServletRequest request) {
+        return iStatisticalService.selectRegisteredCount(getOrgId(request));
     }
 
     /**
      */
     @GetMapping(value = "/admin/selectRecentlyCount")
     public ResponseBean selectRecentlyCount(@RequestParam(value = "startDate", required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME) LocalDate startDate,
-                                            @RequestParam(value = "endDate", required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME) LocalDate endDate) {
-        return iStatisticalService.selectRecentlyCount(startDate, endDate);
+                                            @RequestParam(value = "endDate", required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME) LocalDate endDate,
+                                            HttpServletRequest request) {
+        return iStatisticalService.selectRecentlyCount(getOrgId(request), startDate, endDate);
     }
 
     /**
      * @return
      */
     @GetMapping(value = "/admin/selectSexUser")
-    public ResponseBean selectSexUser() {
-        return iStatisticalService.selectSexUser();
+    public ResponseBean selectSexUser(HttpServletRequest request) {
+        return iStatisticalService.selectSexUser(getOrgId(request));
     }
 
     /**
      * @return
      */
     @GetMapping(value = "/admin/selectCityUser")
-    public ResponseBean selectCityUser() {
-        return iStatisticalService.selectCityUser();
+    public ResponseBean selectCityUser(HttpServletRequest request) {
+        Integer orgId = getOrgId(request);
+        return iStatisticalService.selectCityUser(orgId);
     }
 
     /**
     @GetMapping(value = "/admin/selectIntentionUser")
     public ResponseBean selectIntentionUser(@RequestParam(value = "pageNum", defaultValue = "1") Integer pageNum,
                                             @RequestParam(value = "pageSize", defaultValue = "2") Integer pageSize,
-                                            @RequestParam(value = "buildingId", required = false) String buildingId) {
-        return iStatisticalService.selectIntentionUser(pageNum, pageSize, buildingId);
+                                            @RequestParam(value = "buildingId", required = false) String buildingId,
+                                            HttpServletRequest request) {
+        return iStatisticalService.selectIntentionUser(pageNum, pageSize, getOrgId(request), buildingId);
     }
 
 }

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

      * 转化率 活动收藏 / 活动分享
      * @return
      */
-    Map<String, Object> selectBuildingDynamicStatistical(@Param("saveOrShare") String saveOrShare);
+    Map<String, Object> selectBuildingDynamicStatistical(@Param("orgId") Integer orgId, @Param("saveOrShare") String saveOrShare);
 
     /**
      * 转化率 活动报名
      * @return
      */
-    Map<String, Object> selectBuildingDynamicEnlistStatistical();
+    Map<String, Object> selectBuildingDynamicEnlistStatistical(@Param("orgId") Integer orgId);
 }

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

      * 转化率 项目收藏 / 项目分享
      * @return
      */
-    Map<String, Object> selectBuildingStatistical(@Param("saveOrShare") String saveOrShare);
+    Map<String, Object> selectBuildingStatistical(@Param("orgId")Integer orgId, @Param("saveOrShare") String saveOrShare);
 
     /**
      * 查询楼盘

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

      * 转化率 咨迅收藏 / 咨迅分享
      * @return
      */
-    Map<String, Object> selectNewsStatistical(@Param("saveOrShare") String saveOrShare);
+    Map<String, Object> selectNewsStatistical(@Param("orgId") Integer orgId, @Param("saveOrShare") String saveOrShare);
 
 }

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

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

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

      * @return
      */
     @ResultType(Integer.class)
-    @Select("select count(1) from ta_person where ifnull(person_type, '') != #{personType}")
-    Integer selectUserCount(@Param("personType") String personType);
+    @Select("select count(1) from ta_person where org_id = #{org} AND ifnull(person_type, '') != #{personType}")
+    Integer selectUserCount(@Param("org") Integer orgId, @Param("personType") String personType);
 
     /**
      * 总注册数
      * @return
      */
     @ResultType(Integer.class)
-    @Select("select count(1) from ta_person where ifnull(person_type, '') != #{personType} and phone is not null")
-    Integer selectRegisteredCount(@Param("personType") String personType);
+    @Select("select count(1) from ta_person where org_id = #{org} AND ifnull(person_type, '') != #{personType} and phone is not null")
+    Integer selectRegisteredCount(@Param("org") Integer orgId, @Param("personType") String personType);
 
     /**
      * 根据时间段查询
      * @param personType
      * @return
      */
-    Integer selectRecentlyCount(@Param("personType") String personType, @Param("startDate")LocalDate startDate, @Param("endDate")LocalDate endDate);
+    Integer selectRecentlyCount(@Param("org") Integer orgId, @Param("personType") String personType, @Param("startDate")LocalDate startDate, @Param("endDate")LocalDate endDate);
 
     //---------- 用户总数 end ------------
 
      * @param endDate
      * @return
      */
-    List<PersonPO> selectUserBehavior(@Param("personType") String personType,
+    List<PersonPO> selectUserBehavior(@Param("org") Integer orgId,
+                                      @Param("personType") String personType,
                                       @Param("startDate")LocalDate startDate,
                                       @Param("endDate")LocalDate endDate,
                                       @Param("buildingId") String buildingId,
      * @param dateType
      * @return
      */
-    List<Map<String, Object>> selectActiveUserCount(@Param("personType") String personType, @Param("dateType") String dateType, @Param("startDate")LocalDate startDate, @Param("endDate")LocalDate endDate);
+    List<Map<String, Object>> selectActiveUserCount(@Param("org") Integer orgId, @Param("personType") String personType, @Param("dateType") String dateType, @Param("startDate")LocalDate startDate, @Param("endDate")LocalDate endDate);
 
     /**
      * 新增用户数
      * @param endDate
      * @return
      */
-    List<Map<String, Object>> selectNewsUserCount(@Param("personType") String personType, @Param("startDate")LocalDate startDate, @Param("endDate")LocalDate endDate);
+    List<Map<String, Object>> selectNewsUserCount(@Param("org") Integer orgId, @Param("personType") String personType, @Param("startDate")LocalDate startDate, @Param("endDate")LocalDate endDate);
 
     /**
      * 性别比例
      * @param personType
      * @return
      */
-    @Select("select count(1) as sex_count from ta_person where ifnull(person_type, '') != #{personType} and gender = #{gender}")
-    Integer selectSexUser(@Param("personType") String personType, @Param("gender") Integer gender);
+    @Select("select count(1) as sex_count from ta_person where org_id = #{org} AND ifnull(person_type, '') != #{personType} and gender = #{gender}")
+    Integer selectSexUser(@Param("org") Integer orgId, @Param("personType") String personType, @Param("gender") Integer gender);
 
 
     /**
      */
     @ResultType(Map.class)
     @Select("SELECT " +
-            "ifnull(b.NAME, '其他') AS city, " +
-            "count(a.person_id) AS city_count " +
-            " FROM" +
-            " ta_person a" +
-            " LEFT JOIN ( select t.*, s.pinyin as province from td_city t JOIN td_city s on t.parentid = s.id) b ON a.city = b.pinyin and a.province = b.province where ifnull(a.person_type, '') != #{personType} and a.city is not null GROUP BY a.city")
-    List<Map<String, Object>> selectCityUser(@Param("personType") String personType);
+            " 	a.city as city, " +
+            "	b.shortname AS name, " +
+            "	b.lng, " +
+            "	b.lat, " +
+            "	count(a.person_id) AS cityCount " +
+            "FROM " +
+            "	ta_person a " +
+            "inner JOIN td_city b " +
+            "on a.city = b.id " +
+            "WHERE " +
+            "   a.org_id = #{org} " +
+            "	AND ifnull(a.person_type, '') != #{personType} " +
+            "GROUP BY " +
+            "	a.city ")
+    List<Map<String, Object>> selectCityUser(@Param("org") Integer orgId, @Param("personType") String personType);
 
 
     // ------------- 用户来源 start ------------
      * @param recommendPersonType
      * @return
      */
-    Integer selectUserSourcePie(@Param("recommendPersonType") String recommendPersonType, @Param("personType") String personType);
+    Integer selectUserSourcePie(@Param("org") Integer orgId, @Param("recommendPersonType") String recommendPersonType, @Param("personType") String personType);
 
     /**
      * 用户来源 柱状
      * @return
      */
-    List<Map<String, Object>> selectUserSourceColumnar(@Param("personType") String personType, @Param("startDate") LocalDate startDate, @Param("endDate")LocalDate endDate);
+    List<Map<String, Object>> selectUserSourceColumnar(@Param("org") Integer orgId, @Param("personType") String personType, @Param("startDate") LocalDate startDate, @Param("endDate")LocalDate endDate);
 
     /**
      * 用户来源 数据列表
      */
-    List<Map<String,Object>> selectUserSourceData(@Param("personType") String personType, @Param("startDate")LocalDate startDate, @Param("endDate")LocalDate endDate);
+    List<Map<String,Object>> selectUserSourceData(@Param("org") Integer orgId, @Param("personType") String personType, @Param("startDate")LocalDate startDate, @Param("endDate")LocalDate endDate);
 
     // ------------- 用户来源 end ------------
 

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

      * 首页统计总数
      * @return
      */
-    ResponseBean indexStatistical();
+    ResponseBean indexStatistical(Integer orgId);
 
     // ----------------   用户统计 start --------------
     /**
      * 用户总数
      * @return
      */
-    ResponseBean selectUserCount();
+    ResponseBean selectUserCount(Integer orgId);
 
     /**
      * 注册数
      * @return
      */
-    ResponseBean selectRegisteredCount();
+    ResponseBean selectRegisteredCount(Integer orgId);
 
     /**
      * 用户最近七天
      * @return
      */
-    ResponseBean selectRecentlyCount(LocalDate startDate, LocalDate endDate);
+    ResponseBean selectRecentlyCount(Integer orgId, LocalDate startDate, LocalDate endDate);
 
     // ----------------   用户统计 end --------------
 
      * 性别比例
      * @return
      */
-    ResponseBean selectSexUser();
+    ResponseBean selectSexUser(Integer orgId);
 
     /**
      * 城市比例
      * @return
      */
-    ResponseBean selectCityUser();
+    ResponseBean selectCityUser(Integer orgId);
 
     /**
      * 活跃用户数
      * @return
      */
-    ResponseBean selectActiveUserCount(String dateType, LocalDate startDate, LocalDate endDate);
+    ResponseBean selectActiveUserCount(Integer orgId, String dateType, LocalDate startDate, LocalDate endDate);
 
     /**
      * 新增用户数
      * @param endDate
      * @return
      */
-    ResponseBean selectNewsUserCount(LocalDate startDate,LocalDate endDate);
+    ResponseBean selectNewsUserCount(Integer orgId, LocalDate startDate,LocalDate endDate);
 
     /**
      * 用户行为
      */
     ResponseBean selectUserBehavior(Integer pageNum,
                                     Integer pageSize,
+                                    Integer orgId,
                                     LocalDate startDate,
                                     LocalDate endDate,
                                     String buildingId,
      * @param personId
      * @return
      */
-    ResponseBean selectEventAll(String event, String personId);
+    ResponseBean selectEventAll(Integer orgId, String event, String personId);
 
     /**
      * 转换率 统计
      * @param conversion
      * @return
      */
-    ResponseBean selectConversion(String conversion);
+    ResponseBean selectConversion(Integer orgId, String conversion);
 
     /**
      * 用户来源 首页
      * @return
      */
-    ResponseBean selectUserResource(LocalDate startDate, LocalDate endDate);
+    ResponseBean selectUserResource(Integer orgId, LocalDate startDate, LocalDate endDate);
 
     /**
      * 意向用户 首页
      * @param buildingId
      * @return
      */
-    ResponseBean selectIntentionUser(Integer pageNum, Integer pageSize, String buildingId);
+    ResponseBean selectIntentionUser(Integer pageNum, Integer pageSize, Integer orgId, String buildingId);
 }

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

 
 
     @Override
-    public ResponseBean indexStatistical() {
+    public ResponseBean indexStatistical(Integer orgId) {
 
         ResponseBean responseBean = new ResponseBean();
         Map<String,Object> map = new HashMap<>();
 
         // 总用户数
-        Integer selectUserCount = taPersonMapper.selectUserCount(CommConstant.PERSON_REALTY_CONSULTANT);
+        Integer selectUserCount = taPersonMapper.selectUserCount(orgId, CommConstant.PERSON_REALTY_CONSULTANT);
 
         // 注册数
-        Integer selectRegisteredCount = taPersonMapper.selectRegisteredCount(CommConstant.PERSON_REALTY_CONSULTANT);
+        Integer selectRegisteredCount = taPersonMapper.selectRegisteredCount(orgId, CommConstant.PERSON_REALTY_CONSULTANT);
 
         // 最近七天
-        Integer selectRecentlyCount = taPersonMapper.selectRecentlyCount(CommConstant.PERSON_REALTY_CONSULTANT, null, null);
+        Integer selectRecentlyCount = taPersonMapper.selectRecentlyCount(orgId, CommConstant.PERSON_REALTY_CONSULTANT, null, null);
 
         // 用户行为
-        List<PersonPO> selectUserBehavior = taPersonMapper.selectUserBehavior(CommConstant.PERSON_REALTY_CONSULTANT, null, null, null, null, null, null);
+        List<PersonPO> selectUserBehavior = taPersonMapper.selectUserBehavior(orgId, CommConstant.PERSON_REALTY_CONSULTANT, null, null, null, null, null, null);
 
         // 用户活跃数
-        List<Map<String, Object>> selectActiveUserCount = taPersonMapper.selectActiveUserCount(CommConstant.PERSON_REALTY_CONSULTANT, CommConstant.DAY, null, null);
+        List<Map<String, Object>> selectActiveUserCount = taPersonMapper.selectActiveUserCount(orgId, CommConstant.PERSON_REALTY_CONSULTANT, CommConstant.DAY, null, null);
 
         // 新增用户数
-        List<Map<String, Object>> selectNewsUserCount = taPersonMapper.selectNewsUserCount(CommConstant.PERSON_REALTY_CONSULTANT, null, null);
+        List<Map<String, Object>> selectNewsUserCount = taPersonMapper.selectNewsUserCount(orgId, CommConstant.PERSON_REALTY_CONSULTANT, null, null);
 
         // 性别比例
         // 1 男 2 女
-        Integer selectSexMale = taPersonMapper.selectSexUser(CommConstant.PERSON_REALTY_CONSULTANT, CommConstant.SEX_MALE);
-        Integer selectSexFemale = taPersonMapper.selectSexUser(CommConstant.PERSON_REALTY_CONSULTANT, CommConstant.SEX_FEMALE);
+        Integer selectSexMale = taPersonMapper.selectSexUser(orgId, CommConstant.PERSON_REALTY_CONSULTANT, CommConstant.SEX_MALE);
+        Integer selectSexFemale = taPersonMapper.selectSexUser(orgId, CommConstant.PERSON_REALTY_CONSULTANT, CommConstant.SEX_FEMALE);
         Map<String, Object> selectSexMaleMap = new HashMap<>();
         selectSexMaleMap.put("name", "男");
         selectSexMaleMap.put("value", selectSexMale);
         selectSexUser.add(selectSexFemaleMap);
 
         // 城市比例
-        List<Map<String, Object>> selectCityUser = taPersonMapper.selectCityUser(CommConstant.PERSON_REALTY_CONSULTANT);
+        List<Map<String, Object>> selectCityUser = taPersonMapper.selectCityUser(orgId, CommConstant.PERSON_REALTY_CONSULTANT);
 
         // 转化率, 当前 默认项目收藏
-        Map<String, Object> selectBuildingStatistical = taBuildingMapper.selectBuildingStatistical("save");
+        Map<String, Object> selectBuildingStatistical = taBuildingMapper.selectBuildingStatistical(orgId, "save");
 
         // -------  用户来源 start ------------
 
         // 用户来源 柱状
-        List<Map<String, Object>> mapList = taPersonMapper.selectUserSourceColumnar(CommConstant.PERSON_REALTY_CONSULTANT, null, null);
+        List<Map<String, Object>> mapList = taPersonMapper.selectUserSourceColumnar(orgId, CommConstant.PERSON_REALTY_CONSULTANT, null, null);
 
         // 用户来源 饼状
         // 来源置业顾问, 来源全民经纪人，自由进入
-        Integer person_realty_consultant = taPersonMapper.selectUserSourcePie(CommConstant.PERSON_REALTY_CONSULTANT, CommConstant.PERSON_REALTY_CONSULTANT);
-        Integer person_estate_agent = taPersonMapper.selectUserSourcePie(CommConstant.PERSON_ESTATE_AGENT, CommConstant.PERSON_REALTY_CONSULTANT);
-        Integer person_null = taPersonMapper.selectUserSourcePie(null, CommConstant.PERSON_REALTY_CONSULTANT);
+        Integer person_realty_consultant = taPersonMapper.selectUserSourcePie(orgId, CommConstant.PERSON_REALTY_CONSULTANT, CommConstant.PERSON_REALTY_CONSULTANT);
+        Integer person_estate_agent = taPersonMapper.selectUserSourcePie(orgId, CommConstant.PERSON_ESTATE_AGENT, CommConstant.PERSON_REALTY_CONSULTANT);
+        Integer person_null = taPersonMapper.selectUserSourcePie(orgId, null, CommConstant.PERSON_REALTY_CONSULTANT);
         Map<String, Object> pieMap = new HashMap<>();
         pieMap.put("person_realty_consultant", person_realty_consultant);
         pieMap.put("person_estate_agent", person_estate_agent);
     }
 
     @Override
-    public ResponseBean selectActiveUserCount(String dateType, LocalDate startDate, LocalDate endDate) {
+    public ResponseBean selectActiveUserCount(Integer orgId, String dateType, LocalDate startDate, LocalDate endDate) {
         ResponseBean responseBean = new ResponseBean();
 
         String type = null;
         }
 
         // 用户活跃数
-        List<Map<String, Object>> selectActiveUserCount = taPersonMapper.selectActiveUserCount(CommConstant.PERSON_REALTY_CONSULTANT, type, null, null);
+        List<Map<String, Object>> selectActiveUserCount = taPersonMapper.selectActiveUserCount(orgId, CommConstant.PERSON_REALTY_CONSULTANT, type, null, null);
         Map<String, Object> map = new HashMap<>();
         map.put("selectActiveUserCount", selectActiveUserCount);
         responseBean.addSuccess(map);
     }
 
     @Override
-    public ResponseBean selectNewsUserCount(LocalDate startDate, LocalDate endDate) {
+    public ResponseBean selectNewsUserCount(Integer orgId, LocalDate startDate, LocalDate endDate) {
         ResponseBean responseBean = new ResponseBean();
 
         // 新增用户数
-        List<Map<String, Object>> selectNewsUserCount = taPersonMapper.selectNewsUserCount(CommConstant.PERSON_REALTY_CONSULTANT, startDate, endDate);
+        List<Map<String, Object>> selectNewsUserCount = taPersonMapper.selectNewsUserCount(orgId, CommConstant.PERSON_REALTY_CONSULTANT, startDate, endDate);
 
         Map<String, Object> map = new HashMap<>();
         map.put("selectNewsUserCount", selectNewsUserCount);
     @Override
     public ResponseBean selectUserBehavior(Integer pageNum,
                                            Integer pageSize,
+                                           Integer orgId,
                                            LocalDate startDate,
                                            LocalDate endDate,
                                            String buildingId,
         ResponseBean responseBean = new ResponseBean();
 
         // 用户行为
-        List<PersonPO> selectUserBehavior = taPersonMapper.selectUserBehavior(CommConstant.PERSON_REALTY_CONSULTANT, startDate, endDate, buildingId, eventType, event, activity);
+        List<PersonPO> selectUserBehavior = taPersonMapper.selectUserBehavior(orgId, CommConstant.PERSON_REALTY_CONSULTANT, startDate, endDate, buildingId, eventType, event, activity);
 
         IPage<TaPersonVisitRecord> page = new Page<>(pageNum, pageSize);
         IPage<TaPersonVisitRecord> visitRecordIPage = taPersonVisitRecordMapper.selectAll(page, startDate, endDate, buildingId, eventType, event, activity);
     }
 
     @Override
-    public ResponseBean selectEventAll(String event, String personId) {
+    public ResponseBean selectEventAll(Integer orgId, String event, String personId) {
         ResponseBean responseBean = new ResponseBean();
 
         List<TaPersonVisitRecord> taPersonVisitRecords = taPersonVisitRecordMapper.selectEventAll(event, personId);
     }
 
     @Override
-    public ResponseBean selectConversion(String conversion) {
+    public ResponseBean selectConversion(Integer orgId, String conversion) {
         ResponseBean responseBean = new ResponseBean();
         Map<String, Object> result = new HashMap<>();
 
         switch (conversion) {
             case CommConstant.BUILDING_SAVE:
-                Map<String, Object> selectBuildingStatisticalSave = taBuildingMapper.selectBuildingStatistical("save");
+                Map<String, Object> selectBuildingStatisticalSave = taBuildingMapper.selectBuildingStatistical(orgId, "save");
                 result.put("data_count", selectBuildingStatisticalSave);
                 break;
             case CommConstant.BUILDING_SHARE:
-                Map<String, Object> selectBuildingStatisticalShare = taBuildingMapper.selectBuildingStatistical("share");
+                Map<String, Object> selectBuildingStatisticalShare = taBuildingMapper.selectBuildingStatistical(orgId,"share");
                 result.put("data_count", selectBuildingStatisticalShare);
                 break;
             case CommConstant.ACTIVITY_SAVE:
-                Map<String, Object> selectBuildingDynamicStatisticalSave = taBuildingDynamicMapper.selectBuildingDynamicStatistical("save");
+                Map<String, Object> selectBuildingDynamicStatisticalSave = taBuildingDynamicMapper.selectBuildingDynamicStatistical(orgId, "save");
                 result.put("data_count", selectBuildingDynamicStatisticalSave);
                 break;
             case CommConstant.ACTIVITY_SHARE:
-                Map<String, Object> selectBuildingDynamicStatisticalShare = taBuildingDynamicMapper.selectBuildingDynamicStatistical("share");
+                Map<String, Object> selectBuildingDynamicStatisticalShare = taBuildingDynamicMapper.selectBuildingDynamicStatistical(orgId, "share");
                 result.put("data_count", selectBuildingDynamicStatisticalShare);
                 break;
             case CommConstant.NEWS_SAVE:
-                Map<String, Object> selectNewsStatisticalSave = taNewsMapper.selectNewsStatistical("save");
+                Map<String, Object> selectNewsStatisticalSave = taNewsMapper.selectNewsStatistical(orgId, "save");
                 result.put("data_count", selectNewsStatisticalSave);
                 break;
 
             case CommConstant.NEWS_SHARE:
-                Map<String, Object> selectNewsStatisticalShare = taNewsMapper.selectNewsStatistical("share");
+                Map<String, Object> selectNewsStatisticalShare = taNewsMapper.selectNewsStatistical(orgId, "share");
                 result.put("data_count", selectNewsStatisticalShare);
                 break;
 
             case CommConstant.ACTIVITY_SIGN:
-                Map<String, Object> selectBuildingDynamicEnlistStatistical = taBuildingDynamicMapper.selectBuildingDynamicEnlistStatistical();
+                Map<String, Object> selectBuildingDynamicEnlistStatistical = taBuildingDynamicMapper.selectBuildingDynamicEnlistStatistical(orgId);
                 result.put("data_count", selectBuildingDynamicEnlistStatistical);
                 break;
 
             case CommConstant.AUTHORIZATION_PHONE:
                 // 总用户数
-                Integer selectUserCount = taPersonMapper.selectUserCount(CommConstant.PERSON_REALTY_CONSULTANT);
+                Integer selectUserCount = taPersonMapper.selectUserCount(orgId, CommConstant.PERSON_REALTY_CONSULTANT);
 
                 // 注册数
-                Integer selectRegisteredCount = taPersonMapper.selectRegisteredCount(CommConstant.PERSON_REALTY_CONSULTANT);
+                Integer selectRegisteredCount = taPersonMapper.selectRegisteredCount(orgId, CommConstant.PERSON_REALTY_CONSULTANT);
                 Map<String, Object> userMap = new HashMap<>();
                 userMap.put("pvNum", selectUserCount);
                 userMap.put("registeredCount", selectRegisteredCount);
 
 
     @Override
-    public ResponseBean selectUserResource(LocalDate startDate, LocalDate endDate) {
+    public ResponseBean selectUserResource(Integer orgId, LocalDate startDate, LocalDate endDate) {
         ResponseBean responseBean = new ResponseBean();
         // 用户来源 柱状
-        List<Map<String, Object>> mapList = taPersonMapper.selectUserSourceColumnar(CommConstant.PERSON_REALTY_CONSULTANT, startDate, endDate);
+        List<Map<String, Object>> mapList = taPersonMapper.selectUserSourceColumnar(orgId, CommConstant.PERSON_REALTY_CONSULTANT, startDate, endDate);
 
         // 用户来源饼状
         // 来源置业顾问, 来源全民经纪人，自由进入
-        Integer person_realty_consultant = taPersonMapper.selectUserSourcePie(CommConstant.PERSON_REALTY_CONSULTANT, CommConstant.PERSON_REALTY_CONSULTANT);
-        Integer person_estate_agent = taPersonMapper.selectUserSourcePie(CommConstant.PERSON_ESTATE_AGENT, CommConstant.PERSON_REALTY_CONSULTANT);
-        Integer person_null = taPersonMapper.selectUserSourcePie(null, CommConstant.PERSON_REALTY_CONSULTANT);
+        Integer person_realty_consultant = taPersonMapper.selectUserSourcePie(orgId, CommConstant.PERSON_REALTY_CONSULTANT, CommConstant.PERSON_REALTY_CONSULTANT);
+        Integer person_estate_agent = taPersonMapper.selectUserSourcePie(orgId, CommConstant.PERSON_ESTATE_AGENT, CommConstant.PERSON_REALTY_CONSULTANT);
+        Integer person_null = taPersonMapper.selectUserSourcePie(orgId, null, CommConstant.PERSON_REALTY_CONSULTANT);
         Map<String, Object> map = new HashMap<>();
         map.put("person_realty_consultant", person_realty_consultant);
         map.put("person_estate_agent", person_estate_agent);
         map.put("person_null", person_null);
 
         // 用户来源 数据列表
-        List<Map<String, Object>> selectUserSourceData = taPersonMapper.selectUserSourceData(CommConstant.PERSON_ESTATE_AGENT, startDate, endDate);
+        List<Map<String, Object>> selectUserSourceData = taPersonMapper.selectUserSourceData(orgId, CommConstant.PERSON_ESTATE_AGENT, startDate, endDate);
 
         Map<String, Object> result = new HashMap<>();
         result.put("columnar", mapList);
 
 
     @Override
-    public ResponseBean selectUserCount() {
+    public ResponseBean selectUserCount(Integer orgId) {
         ResponseBean responseBean = new ResponseBean();
         // 总用户数
-        Integer selectUserCount = taPersonMapper.selectUserCount(CommConstant.PERSON_REALTY_CONSULTANT);
+        Integer selectUserCount = taPersonMapper.selectUserCount(orgId, CommConstant.PERSON_REALTY_CONSULTANT);
         Map<String, Object> map = new HashMap<>();
         map.put("selectUserCount", selectUserCount);
         responseBean.addSuccess(map);
     }
 
     @Override
-    public ResponseBean selectRegisteredCount() {
+    public ResponseBean selectRegisteredCount(Integer orgId) {
         ResponseBean responseBean = new ResponseBean();
         // 注册数
-        Integer selectRegisteredCount = taPersonMapper.selectRegisteredCount(CommConstant.PERSON_REALTY_CONSULTANT);
+        Integer selectRegisteredCount = taPersonMapper.selectRegisteredCount(orgId, CommConstant.PERSON_REALTY_CONSULTANT);
         Map<String, Object> map = new HashMap<>();
         map.put("selectRegisteredCount", selectRegisteredCount);
         responseBean.addSuccess(map);
     }
 
     @Override
-    public ResponseBean selectRecentlyCount(LocalDate startDate, LocalDate endDate) {
+    public ResponseBean selectRecentlyCount(Integer orgId, LocalDate startDate, LocalDate endDate) {
         ResponseBean responseBean = new ResponseBean();
         // 最近七天
-        Integer selectRecentlyCount = taPersonMapper.selectRecentlyCount(CommConstant.PERSON_REALTY_CONSULTANT, startDate, endDate);
+        Integer selectRecentlyCount = taPersonMapper.selectRecentlyCount(orgId, CommConstant.PERSON_REALTY_CONSULTANT, startDate, endDate);
         Map<String, Object> map = new HashMap<>();
         map.put("selectRecentlyCount", selectRecentlyCount);
         responseBean.addSuccess(map);
     }
 
     @Override
-    public ResponseBean selectSexUser() {
+    public ResponseBean selectSexUser(Integer orgId) {
         ResponseBean responseBean = new ResponseBean();
 
         // 性别比例
         // 1 男 2 女
-        Integer selectSexMale = taPersonMapper.selectSexUser(CommConstant.PERSON_REALTY_CONSULTANT, CommConstant.SEX_MALE);
-        Integer selectSexFemale = taPersonMapper.selectSexUser(CommConstant.PERSON_REALTY_CONSULTANT, CommConstant.SEX_FEMALE);
+        Integer selectSexMale = taPersonMapper.selectSexUser(orgId, CommConstant.PERSON_REALTY_CONSULTANT, CommConstant.SEX_MALE);
+        Integer selectSexFemale = taPersonMapper.selectSexUser(orgId, CommConstant.PERSON_REALTY_CONSULTANT, CommConstant.SEX_FEMALE);
         Map<String, Object> selectSexMaleMap = new HashMap<>();
         selectSexMaleMap.put("name", "男");
         selectSexMaleMap.put("value", selectSexMale);
     }
 
     @Override
-    public ResponseBean selectCityUser() {
+    public ResponseBean selectCityUser(Integer orgId) {
         ResponseBean responseBean = new ResponseBean();
 
         // 城市比例
-        List<Map<String, Object>> selectCityUser = taPersonMapper.selectCityUser(CommConstant.PERSON_REALTY_CONSULTANT);
+        List<Map<String, Object>> selectCityUser = taPersonMapper.selectCityUser(orgId, CommConstant.PERSON_REALTY_CONSULTANT);
         Map<String, Object> map = new HashMap<>();
         map.put("selectCityUser", selectCityUser);
         responseBean.addSuccess(map);
     }
 
     @Override
-    public ResponseBean selectIntentionUser(Integer pageNum, Integer pageSize, String buildingId) {
+    public ResponseBean selectIntentionUser(Integer pageNum, Integer pageSize, Integer orgId, String buildingId) {
         ResponseBean responseBean = new ResponseBean();
 
         IPage<Map<String,Object>> pg = new Page<>(pageNum, pageSize);
-        IPage<Map<String, Object>> page = taPersonIntentionRecordMapper.selectIntentionUser(pg, buildingId);
+        IPage<Map<String, Object>> page = taPersonIntentionRecordMapper.selectIntentionUser(pg, orgId, buildingId);
 
         responseBean.addSuccess(page);
         return responseBean;

src/main/resources/mapper/TaBuildingDynamicMapper.xml

                 sum(share_num) as shareNum
             </if>
             from ta_building_dynamic
+        where org_id = #{orgId}
     </select>
 
     <select id="selectBuildingDynamicEnlistStatistical" resultType="map">
         sum(pv_num) as pvNum,
         IFNULL(sum(enlist_num),0) as enlistNum
         from ta_building_dynamic
+        where org_id = #{orgId}
     </select>
 
 </mapper>

src/main/resources/mapper/TaBuildingMapper.xml

               IFNULL(sum(share_num),0) as shareNum
           </if>
         from ta_building
+        where org_id = ${orgId}
     </select>
 
     <select id="selectBuildingPage" resultType="com.huiju.estateagents.entity.TaBuilding">

src/main/resources/mapper/TaNewsMapper.xml

             sum(share_num) as shareNum
         </if>
         from ta_news
+        where org_id = #{orgId}
     </select>
 
 </mapper>

src/main/resources/mapper/TaPersonIntentionRecordMapper.xml

             SUM(tpir.intention) as intention
         FROM
             ta_person_intention_record tpir
-            LEFT JOIN ta_person tp on tpir.person_id = tp.person_id
+            LEFT JOIN ta_person tp on tpir.person_id = tp.person_id AND tp.org_id = #{orgId}
             <where>
                 <if test="buildingId != null and buildingId != ''">
                     tpir.building_id = #{buildingId}

src/main/resources/mapper/TaPersonMapper.xml

             COUNT(1) as activity_count
         FROM
         ta_person tp
-        where ifnull(tp.person_type, '') != #{personType}
+        where tp.org_id = #{org} AND
+          ifnull(tp.person_type, '') != #{personType}
 
         <if test="startDate != null or endDate != null">
             AND  tp.create_date BETWEEN #{startDate} and #{endDate}
             FROM
               ta_person tp
             INNER JOIN ta_person_visit_record tpvr ON tp.person_id = tpvr.person_id
-            where ifnull(tp.person_type, '') != #{personType}
+            where tp.org_id = #{org} AND ifnull(tp.person_type, '') != #{personType}
             <if test="buildingId != null and buildingId != ''">
                 and tpvr.building_id = #{buildingId}
             </if>
              LEFT JOIN
             ( SELECT *, MAX(visit_time) as max_visit_time FROM ta_person_visit_record GROUP BY  person_id  ) as tpvr
             ON tp.person_id = tpvr.person_id
-             where ifnull(tp.person_type, '') != #{personType}
+             where tp.org_id = #{org} AND ifnull(tp.person_type, '') != #{personType}
              GROUP BY DATE_FORMAT( tpvr.max_visit_time , '%Y-%m-%d' )
         ) AS temp ON
         <if test="dateType == 'month'.toString()">
                     tp.create_date as create_date
                 FROM
                  ta_person tp
-                where ifnull(tp.person_type, '') != #{personType}
+                where tp.org_id = #{org} AND ifnull(tp.person_type, '') != #{personType}
                 <if test="startDate != null or endDate != null">
                     AND tp.create_date BETWEEN #{startDate} and #{endDate}
                 </if>
     <select id="selectUserSourcePie" resultType="integer">
         select count(1)
         FROM ta_person
-        WHERE ifnull(person_type, '') != #{personType}
+        WHERE org_id = #{org} AND
+          ifnull(person_type, '') != #{personType}
         <if test="recommendPersonType != null and recommendPersonType != ''">
             and recommend_person_type = #{recommendPersonType}
         </if>
             LEFT JOIN td_person_from tpfs
             ON tps.from_code = tpfs.from_code
             WHERE tpfs.from_code = tpf.from_code and tps.phone is NOT NULL
+            AND tps.org_id = #{org}
             and ifnull(tps.person_type, '') != #{personType}
             <if test="startDate != null or endDate != null">
                 and tps.create_date BETWEEN #{startDate} and #{endDate}
             LEFT JOIN td_person_from tpfs
             ON tps.from_code = tpfs.from_code
             WHERE tpfs.from_code = tpf.from_code
+            AND tps.org_id = #{org}
             and ifnull(tps.person_type, '') != #{personType}
             <if test="startDate != null or endDate != null">
                 and tps.create_date BETWEEN #{startDate} and #{endDate}
         FROM td_person_from tpf
         LEFT JOIN ta_person tp
         ON tp.from_code = tpf.from_code
-        where ifnull(tp.person_type, '') != #{personType}
+        where tp.org_id = #{org} AND ifnull(tp.person_type, '') != #{personType}
         GROUP BY tpf.from_code
     </select>
 
             LEFT JOIN td_person_from tpfs
             ON tps.from_code = tpfs.from_code
             WHERE tpfs.from_code = tps.from_code
+            AND tps.org_id = #{org}
             and ifnull(tps.person_type, '') != 'Realty Consultant'
             AND tps.create_date BETWEEN #{startDate} AND #{endDate}
 
             LEFT JOIN td_person_from tpfs
             ON tps.from_code = tpfs.from_code
             WHERE tpfs.from_code = tps.from_code
+                AND tps.org_id = #{org}
                 and ifnull(tps.person_type, '') != 'Realty Consultant'
                 AND tps.create_date BETWEEN #{startDate} AND #{endDate}
                 and tps.phone is not null