组织机构调整

src/main/java/com/yunzhi/marketing/base/BaseController.java

     /**
      * 获取组织机构id
      *
-     * @param request
+     * @param
      * @return
      */
-    public String getInstitutionId(HttpServletRequest request) {
-        TaUser taUser = taUserService.getById(getUserId(request));
-        return taUser.getInstitutionId();
+    public String getInstitutionId(String buildingId) {
+        TaBuilding building = taBuildingService.getById(buildingId);
+        return building.getInstitutionId();
     }
 
     /**
      * @param request
      * @return
      */
-    public List<String> getInstitutionCodes(HttpServletRequest request) {
+    public List<String> getInstitutionIds(HttpServletRequest request) {
         TaUser taUser = taUserService.getById(getUserId(request));
-        Institution institution = iInstitutionService.getById(taUser.getInstitutionId());
-        LambdaQueryWrapper<Institution> queryWrapper = new LambdaQueryWrapper<>();
-        queryWrapper.likeRight(Institution::getInstitutionCode,institution.getInstitutionCode());
-        List<Institution> list = iInstitutionService.list(queryWrapper);
+        List<Institution> list = iInstitutionService.getAllByUser(taUser);
         return list.stream().map(Institution::getInstitutionId).collect(Collectors.toList());
     }
 
         List<TaPersonBuilding> taPersonBuildingList = new ArrayList<>();
 
         // 新的过滤条件组织机构
-        List<TaBuilding> list = taBuildingService.selectByUserId(taUser.getUserId());
-        for (TaBuilding taBuilding: list) {
-            TaPersonBuilding taPersonBuilding = new TaPersonBuilding();
-            taPersonBuilding.setBuildingId(taBuilding.getBuildingId());
-            taPersonBuilding.setUserId(taUser.getUserId());
-            taPersonBuildingList.add(taPersonBuilding);
-        }
+//        List<TaBuilding> list = taBuildingService.selectByUserId(taUser.getUserId());
+//        for (TaBuilding taBuilding: list) {
+//            TaPersonBuilding taPersonBuilding = new TaPersonBuilding();
+//            taPersonBuilding.setBuildingId(taBuilding.getBuildingId());
+//            taPersonBuilding.setUserId(taUser.getUserId());
+//            taPersonBuildingList.add(taPersonBuilding);
+//        }
 
-        if (null != taUser.getIsAdmin() && taUser.getIsAdmin()) {
-            taPersonBuildingList = new ArrayList<>();
-        }
         return taPersonBuildingList;
     }
 }

src/main/java/com/yunzhi/marketing/controller/ExtendContentController.java

             extendContent.setContentType("nothing");
         }
         extendContent.setCreateUser(getUserId(request));
-        extendContent.setInstitutionId(getInstitutionId(request));
+        extendContent.setInstitutionId(getInstitutionId(extendContent.getBuildingId()));
         responseBean = iExtendContentService.extendContentAdd(extendContent);
         responseBean.addSuccess(extendContent);
         return responseBean;

src/main/java/com/yunzhi/marketing/controller/TaBuildingController.java

                                      @RequestParam(value = "cityId", required = false) Integer cityId,
                                      @RequestParam(value = "isMain", required = false) Integer isMain,
                                      HttpServletRequest request) {
-        return taBuildingService.buildingList(pageNum, pageSize, name, code, startDate, buildingStatus, marketStatus, cityId, isMain, getOrgId(request), getTaPersonBuildingListByUserId(request));
+        return taBuildingService.buildingList(pageNum, pageSize, name, code, startDate, buildingStatus, marketStatus, cityId, isMain, getOrgId(request), getTaPersonBuildingListByUserId(request), getInstitutionIds(request));
     }
 
     /**

src/main/java/com/yunzhi/marketing/controller/TaBuildingDynamicController.java

                                              @RequestParam(required = false)String isEnlist,
                                              @RequestParam(required = false) @DateTimeFormat(iso = DateTimeFormat.ISO.DATE_TIME) LocalDateTime time,
                                              @RequestParam(required = false)String activityStatus, HttpServletRequest request){
-        ResponseBean  responseBean = iBuildingDynamicService.iBuildingDynamicList(pageNum,pageSize,name,buildingId,cityId,isEnlist,time,title,getOrgId(request),activityStatus,getTaPersonBuildingListByUserId(request),type);
+        ResponseBean  responseBean = iBuildingDynamicService.iBuildingDynamicList(pageNum,pageSize,name,buildingId,cityId,isEnlist,time,title,getOrgId(request),activityStatus,getTaPersonBuildingListByUserId(request),type,getInstitutionIds(request));
         return responseBean;
     }
 
 //        }
         dynamic.setPublishDate(LocalDateTime.now());
         dynamic.setCreateDate(LocalDateTime.now());
-        dynamic.setInstitutionId(getInstitutionId(request));
+        dynamic.setInstitutionId(getInstitutionId(dynamic.getBuildingId()));
         //判断报名时间是否在活动时间之内
         if (dynamic.getEndDate().isBefore(dynamic.getEnlistEnd())){
             responseBean.addError("报名时间应在活动结束时间之前");

src/main/java/com/yunzhi/marketing/controller/TaChannelController.java

                                     HttpServletRequest request){
         ResponseBean responseBean = new ResponseBean();
         Integer orgId = getOrgId(request);
-        Institution institution = iInstitutionService.getById(getInstitutionId(request));
 
         try {
             //使用分页插件
 		    IPage<TaChannel> pg = new Page<>(pageNum, pageSize);
-            IPage<TaChannel> result = taChannelMapper.pageTaChannel(pg,orgId,channelId,institution.getInstitutionCode());
-            List<TaChannel> recommendCount = taChannelMapper.recommendCount(orgId, channelId, institution.getInstitutionCode());
+            IPage<TaChannel> result = taChannelMapper.pageTaChannel(pg,orgId,channelId,getInstitutionIds(request));
+            List<TaChannel> recommendCount = taChannelMapper.recommendCount(orgId, channelId, getInstitutionIds(request));
 
             result.getRecords().stream().forEach(e -> {
                 for(TaChannel channel : recommendCount){
             int channelCode= taChannelMapper.channelCode();
             channel.setChannelCode(String.valueOf(channelCode));
             channel.setOrgId(orgId);
-            channel.setInstitutionId(getInstitutionId(request));
+            channel.setInstitutionId(getInstitutionId(channel.getBuildingId()));
             if (taChannelService.save(channel)){
                 responseBean.addSuccess(channel);
             }else {

src/main/java/com/yunzhi/marketing/controller/TaLiveActivityController.java

      * @param liveActivityTitle 直播活动标题
      * @param cityId            所属城市
      * @param buildingId        所属楼盘
-     * @param liveDetailType    详情类型 0是模板，1是自定义
+     * @param
      * @param status            状态
      * @param source            查询来源，1:直播等活动，2:开屏广告
      * @param request
         ResponseBean responseBean = new ResponseBean();
         try {
             IPage<TaLiveActivity> result = iTaLiveActivityService.listLiveActivityByCondition(pageNum, pageSize, getOrgId(request),
-                    liveActivityTitle, cityId, buildingId, status, getTaPersonBuildingListByUserId(request), getUserId(request), source);
+                    liveActivityTitle, cityId, buildingId, status, getTaPersonBuildingListByUserId(request), getUserId(request), source, getInstitutionIds(request));
             responseBean.addSuccess(result);
 
         } catch (Exception e) {
             taLiveActivity.setOrgId(orgId);
             taLiveActivity.setCreateUser(userId.toString());
             taLiveActivity.setUpdateUser(userId.toString());
-            taLiveActivity.setInstitutionId(getInstitutionId(request));
+            taLiveActivity.setInstitutionId(getInstitutionId(taLiveActivity.getBuildingId()));
             responseBean = iTaLiveActivityService.taLiveActivityAdd(taLiveActivity);
         } catch (Exception e) {
             e.printStackTrace();

src/main/java/com/yunzhi/marketing/controller/TaNewsController.java

 
     /**
      * 微信 分页查询列表
-     * @param pageNum
+     * @param
      * @param pageSize
      * @return
      */
         Integer cityId = iTaBuildingService.getCityById(taNews.getBuildingId());
         taNews.setCityId(cityId);
         taNews.setOrgId(getOrgId(request));
-        taNews.setInstitutionId(getInstitutionId(request));
         ResponseBean responseBean = iTaNewsService.addTaNews(taNews);
         return responseBean;
     }

src/main/java/com/yunzhi/marketing/controller/TaNewsTypeController.java

     })
     @RequestMapping(value="/admin/taNewsType",method= RequestMethod.POST)
     public ResponseBean taNewsTypeAdd(@RequestBody TaNewsType taNewsType, HttpServletRequest request){
-        taNewsType.setInstitutionId(getInstitutionId(request));
         ResponseBean responseBean = iTaNewsTypeService.addTaNewsType(taNewsType, getOrgId(request));
         return responseBean;
     }

src/main/java/com/yunzhi/marketing/controller/TaPolicyController.java

             queryWrapper.orderByDesc("weight", "create_date");
             queryWrapper.eq("status", CommConstant.STATUS_NORMAL);
             queryWrapper.eq("org_id", getOrgId(request));
-            queryWrapper.in("institution_id",getInstitutionCodes(request));
+            queryWrapper.in("institution_id",getInstitutionIds(request));
 
             IPage<TaPolicy> result = iTaPolicyService.page(pg, queryWrapper);
             List<TaPolicy> records = result.getRecords();
             taPolicy.setStatus(1);
             taPolicy.setCreateDate(LocalDateTime.now());
             taPolicy.setOrgId(getOrgId(request));
-            taPolicy.setInstitutionId(getInstitutionId(request));
+            taPolicy.setInstitutionId(getInstitutionId(taPolicy.getBuildingId()));
             if (iTaPolicyService.save(taPolicy)){
                 responseBean.addSuccess(taPolicy);
             }else {

src/main/java/com/yunzhi/marketing/controller/TaRecommendCustomerController.java

 //            }
             return ResponseBean.success(taRecommendCustomerService.getCustomerList(status, pageNumber, pageSize, buildingId, name, tel, consultName,
                     consultTel, entryType, verifyStatus, sex, customerType, getOrgId(request), getTaPersonBuildingListByUserId(request), sceneType,
-                    startCreateDate, endCreateDate, sharePersonName, belongStatus));
+                    startCreateDate, endCreateDate, sharePersonName, belongStatus, getInstitutionIds(request)));
         } catch (Exception e) {
             e.printStackTrace();
             return ResponseBean.error(e.getMessage(), ResponseBean.ERROR_UNAVAILABLE);

src/main/java/com/yunzhi/marketing/controller/TdBuildingTypeController.java

             queryWrapper.eq("status", 1);
             queryWrapper.orderByDesc("create_date");
             queryWrapper.eq("org_id", getOrgId(request));
-            queryWrapper.in("institution_id",getInstitutionCodes(request));
 
             IPage<TdBuildingType> result = iTdBuildingTypeService.page(pg, queryWrapper);
             responseBean.addSuccess(result);

src/main/java/com/yunzhi/marketing/entity/TaNewsType.java

      * 状态
      */
     private Integer status;
-
-    /**
-     * 组织结构id
-     */
-    private String institutionId;
-
-
 }

src/main/java/com/yunzhi/marketing/mapper/TaBuildingDynamicMapper.java

     /**
      * 会员列列表
      * @param page
-     * @param selected
+     * @param
      * @return
      */
-    IPage<TaBuildingDynamic> buildingDynamicList(Page page, @Param("name") String name, @Param("buildingId") String buildingId, @Param("cityId") Integer cityId, @Param("isEnlist") String isEnlist, @Param("time") LocalDateTime time, @Param("title") String title, @Param("orgId") Integer orgId, @Param("activityStatus") String activityStatus,@Param("personBuildingList") List<TaPersonBuilding> personBuildingList,@Param("type") String type);
+    IPage<TaBuildingDynamic> buildingDynamicList(Page page, @Param("name") String name, @Param("buildingId") String buildingId, @Param("cityId") Integer cityId, @Param("isEnlist") String isEnlist, @Param("time") LocalDateTime time, @Param("title") String title, @Param("orgId") Integer orgId, @Param("activityStatus") String activityStatus,@Param("personBuildingList") List<TaPersonBuilding> personBuildingList,@Param("type") String type,@Param("institutionIds") List<String> institutions);
 
     /**
      * 详情

src/main/java/com/yunzhi/marketing/mapper/TaBuildingMapper.java

      * @param page
      * @return
      */
-    List<TaBuilding> buildingList(IPage<TaBuilding> page, @Param("Name") String name, @Param("Code")String code,@Param("startDate")LocalDateTime startDate, @Param("buildingStatus")String buildingStatus, @Param("marketStatus")String marketStatus, @Param("cityId")Integer cityId, @Param("isMain")Integer isMain, @Param("orgId") Integer orgId,@Param("personBuildingList") List<TaPersonBuilding> personBuildingList);
+    List<TaBuilding> buildingList(IPage<TaBuilding> page, @Param("Name") String name, @Param("Code")String code,@Param("startDate")LocalDateTime startDate, @Param("buildingStatus")String buildingStatus, @Param("marketStatus")String marketStatus, @Param("cityId")Integer cityId, @Param("isMain")Integer isMain, @Param("orgId") Integer orgId,@Param("personBuildingList") List<TaPersonBuilding> personBuildingList,@Param("institutionIds") List<String> institutionIds);
 
     /**
      * 楼盘列表

src/main/java/com/yunzhi/marketing/mapper/TaChannelMapper.java

      * @param pg
      * @return
      */
-    IPage<TaChannel> pageTaChannel(IPage<TaChannel> pg,@Param("orgId")Integer orgId,@Param("channelId")Integer channelId,@Param("institutionCode") String institutionCode);
+    IPage<TaChannel> pageTaChannel(IPage<TaChannel> pg,@Param("orgId")Integer orgId,@Param("channelId")Integer channelId,@Param("institutionIds") List<String> institutionIds);
 
-    List<TaChannel> recommendCount(@Param("orgId")Integer orgId,@Param("channelId")Integer channelId,@Param("institutionCode") String institutionCode);
+    List<TaChannel> recommendCount(@Param("orgId")Integer orgId,@Param("channelId")Integer channelId,@Param("institutionIds") List<String> institutionIds);
 
     /**
      * 渠道引进客户统计

src/main/java/com/yunzhi/marketing/mapper/TaLiveActivityMapper.java

                                                     @Param("orgId") Integer orgId,
                                                     @Param("personBuildingList") List<TaPersonBuilding> personBuildingList,
                                                     @Param("userId") Integer userId,
-                                                    @Param("source") Integer source);
+                                                    @Param("source") Integer source,
+                                                    @Param("institutionIds") List<String> institutions);
     /**
      * 批量更新直播活动状态
      *

src/main/java/com/yunzhi/marketing/mapper/TaRecommendCustomerMapper.java

 
     TaRecommendCustomer getCustomerById(@Param("customerId") String customerId);
 
-    IPage<TaRecommendCustomer> getCustomerList(IPage<TaRecommendCustomer> page, @Param("building") String building, @Param("name") String name, @Param("tel") String tel, @Param("consultName") String consultName, @Param("consultTel") String consultTel, @Param("entryType") String entryType, @Param("verifyStatus") String verifyStatus, @Param("sex") Integer sex, @Param("orgId") Integer orgId, @Param("status") Integer status, @Param("personBuildingList") List<TaPersonBuilding> personBuildingList, @Param("sceneType") String sceneType, @Param("startCreateDate") String startCreateDate, @Param("endCreateDate") String endCreateDate, @Param("sharePersonName") String sharePersonName);
+    IPage<TaRecommendCustomer> getCustomerList(IPage<TaRecommendCustomer> page, @Param("building") String building, @Param("name") String name, @Param("tel") String tel, @Param("consultName") String consultName, @Param("consultTel") String consultTel, @Param("entryType") String entryType, @Param("verifyStatus") String verifyStatus, @Param("sex") Integer sex, @Param("orgId") Integer orgId, @Param("status") Integer status, @Param("personBuildingList") List<TaPersonBuilding> personBuildingList, @Param("sceneType") String sceneType, @Param("startCreateDate") String startCreateDate, @Param("endCreateDate") String endCreateDate, @Param("sharePersonName") String sharePersonName,@Param("institutionIds") List<String> institutionIds);
 
     IPage<TaRecommendCustomer> getRecCustomerList(IPage<TaRecommendCustomer> page, @Param("building") String building, @Param("name") String name, @Param("tel") String tel, @Param("consultName") String consultName, @Param("consultTel") String consultTel, @Param("entryType") String entryType, @Param("verifyStatus") String verifyStatus, @Param("sex") Integer sex, @Param("orgId") Integer orgId, @Param("personBuildingList") List<TaPersonBuilding> personBuildingList);
 
                                           @Param("startCreateDate") String startCreateDate,
                                           @Param("endCreateDate") String endCreateDate,
                                           @Param("sharePersonName") String sharePersonName,
-                                          @Param("belongStatus") Integer belongStatus);
+                                          @Param("belongStatus") Integer belongStatus,
+                                          @Param("institutionIds") List<String> institutionIds);
 
     /**
      * 导出数据 获取推荐用户数据

src/main/java/com/yunzhi/marketing/service/ITaBuildingDynamicService.java

      * 项目动态管理列表
      * @return
      */
-    ResponseBean iBuildingDynamicList(Integer pageNum, Integer pageSize, String name, String buildingId, Integer cityId, String isEnlist, LocalDateTime time, String title, Integer orgId, String activityStatus, List<TaPersonBuilding> personBuildingList,String type);
+    ResponseBean iBuildingDynamicList(Integer pageNum, Integer pageSize, String name, String buildingId, Integer cityId, String isEnlist, LocalDateTime time, String title, Integer orgId, String activityStatus, List<TaPersonBuilding> personBuildingList,String type,List<String> institutions);
 
     /**
      * 项目详情

src/main/java/com/yunzhi/marketing/service/ITaBuildingService.java

      * @param pageSize
      * @return
      */
-    ResponseBean buildingList(Integer pageNum, Integer pageSize, String name, String code, LocalDateTime startDate, String buildingStatus, String marketStatus, Integer cityId, Integer isMain, Integer orgId, List<TaPersonBuilding> taPersonBuildingList);
+    ResponseBean buildingList(Integer pageNum, Integer pageSize, String name, String code, LocalDateTime startDate, String buildingStatus, String marketStatus, Integer cityId, Integer isMain, Integer orgId, List<TaPersonBuilding> taPersonBuildingList, List<String> InstitutionIds);
 
     /**
      * 楼盘列表

src/main/java/com/yunzhi/marketing/service/ITaLiveActivityService.java

      */
     IPage<TaLiveActivity> listLiveActivityByCondition(Integer pageNum, Integer pageSize, Integer orgId, String liveActivityTitle,
                                                       String cityId, String buildingId, Integer status, List<TaPersonBuilding> taPersonBuildingListByUserId,
-                                                      Integer userId,Integer source);
+                                                      Integer userId,Integer source,List<String> institutions);
 
     /**
      * 访问量自增

src/main/java/com/yunzhi/marketing/service/ITaRecommendCustomerService.java

     IPage getCustomerList(Integer status, int pageNumber, int pageSize, String building, String name, String tel, String consultName,
                           String consultTel, String entryType, String verifyStatus, Integer sex, String customerType, Integer orgId,
                           List<TaPersonBuilding> taPersonBuildingList, String sceneType, String startCreateDate, String endCreateDate,
-                          String sharePersonName, Integer belongStatus);
+                          String sharePersonName, Integer belongStatus,List<String> institutionIds);
 
     IPage<TaRecommendCustomer> getRecCustomerList(int pageNumber, int pageSize, String building, String name, String tel, String consultName, String consultTel, String entryType, String verifyStatus, Integer sex, Integer orgId, List<TaPersonBuilding> taPersonBuildingList);
 

src/main/java/com/yunzhi/marketing/service/impl/TaBuildingDynamicServiceImpl.java

     @Override
     public ResponseBean iBuildingDynamicList(Integer pageNum, Integer pageSize, String name, String buildingId, Integer cityId, String isEnlist,
                                              LocalDateTime time, String title, Integer orgId, String activityStatus, List<TaPersonBuilding> personBuildingList,
-                                             String type) {
+                                             String type,List<String> institutions) {
         Page<TaBuildingDynamic> page = new Page<>();
         page.setSize(pageSize == null ? 10 : pageSize);
         page.setCurrent(pageNum == null ? 1 : pageNum);
 
-        IPage<TaBuildingDynamic> buildingDynamic = buildingDynamicMapper.buildingDynamicList(page, name, buildingId,cityId,isEnlist,time,title,orgId,activityStatus,personBuildingList,type);
+        IPage<TaBuildingDynamic> buildingDynamic = buildingDynamicMapper.buildingDynamicList(page, name, buildingId,cityId,isEnlist,time,title,orgId,activityStatus,personBuildingList,type,institutions);
 
         HashMap hashMap= new HashMap<>();
         hashMap.put("list",buildingDynamic.getRecords());

src/main/java/com/yunzhi/marketing/service/impl/TaBuildingServiceImpl.java

 
     private String MARKETING_CODE;
     @Override
-    public ResponseBean buildingList(Integer pageNum, Integer pageSize, String name, String code, LocalDateTime startDate, String buildingStatus, String marketStatus, Integer cityId, Integer isMain, Integer orgId, List<TaPersonBuilding> taPersonBuildingList) {
+    public ResponseBean buildingList(Integer pageNum, Integer pageSize, String name, String code, LocalDateTime startDate, String buildingStatus, String marketStatus, Integer cityId, Integer isMain, Integer orgId, List<TaPersonBuilding> taPersonBuildingList, List<String> InstitutionIds) {
         if (pageNum == null) {
             pageNum = 1;
         }
         }
 
         Page<TaBuilding> page = new Page<>(pageNum, pageSize);
-        List<TaBuilding> buildings = taBuildingMapper.buildingList(page, name, code, startDate, buildingStatus, marketStatus, cityId, isMain, orgId, taPersonBuildingList);
+        List<TaBuilding> buildings = taBuildingMapper.buildingList(page, name, code, startDate, buildingStatus, marketStatus, cityId, isMain, orgId, taPersonBuildingList, InstitutionIds);
 
         if (null != buildings) {
             for (TaBuilding taBuilding : buildings) {

src/main/java/com/yunzhi/marketing/service/impl/TaLiveActivityServiceImpl.java

     @Override
     public IPage<TaLiveActivity> listLiveActivityByCondition(Integer pageNum, Integer pageSize, Integer orgId, String liveActivityTitle,
                                                              String cityId, String buildingId, Integer status, List<TaPersonBuilding> taPersonBuildingListByUserId,
-                                                             Integer userId, Integer source) {
+                                                             Integer userId, Integer source, List<String> institutions) {
         logger.info("TaLiveActivityServiceImpl.listLiveActivityByCondition 接收参数：pageNum:{},pageSize:{},orgId:{},iveActivityTitle:{},cityId:{},buildingId:{},liveDetailType:{},status:{},source:{}",
                 pageNum, pageSize, liveActivityTitle, cityId, buildingId, status, source);
 
         IPage<TaLiveActivity> pg = new Page<>(pageNum, pageSize);
-        return taLiveActivityMapper.selectLiveListByCondition(pg, liveActivityTitle, cityId, buildingId, status, orgId, taPersonBuildingListByUserId, userId, source);
+        return taLiveActivityMapper.selectLiveListByCondition(pg, liveActivityTitle, cityId, buildingId, status, orgId, taPersonBuildingListByUserId, userId, source, institutions);
     }
 
     @Override

src/main/java/com/yunzhi/marketing/service/impl/TaRecommendCustomerServiceImpl.java

         channelCustomer.setOrgId(channelReportDTO.getOrgId());
         channelCustomer.setRemark(channelReportDTO.getRemark());
         channelCustomer.setRealtyConsultant(channelReportDTO.getRealtyConsultant());
+        channelCustomer.setInstitutionId(getInstitutionId(channelReportDTO.getBuildingId()));
         channelCustomerMapper.insert(channelCustomer);
 
         // 插入客户来源逻辑, 防止下面 if 里面的 return
             recommendCustomer.setStatus(CommConstant.CUSTOMER_REPORT);
             recommendCustomer.setRecommendPerson(consultant.getPersonId());
             recommendCustomer.setCirculationTime(LocalDateTime.now());
+            recommendCustomer.setInstitutionId(building.getInstitutionId());
             customerFrom.setIsProjectFirst(true);
             customerFrom.setIsOrgFirst(true);
         }
         channelCustomer.setCreateDate(LocalDateTime.now());
         channelCustomer.setStatus("1");
         channelCustomer.setOrgId(averageReportDTO.getOrgId());
+        channelCustomer.setInstitutionId(getInstitutionId(averageReportDTO.getBuildingId()));
         channelCustomerMapper.insert(channelCustomer);
         return ResponseBean.success(channelCustomer);
     }
 
+    /**
+     * 获取组织机构id
+     *
+     * @param
+     * @return
+     */
+    public String getInstitutionId(String buildingId) {
+        TaBuilding building = taBuildingMapper.selectById(buildingId);
+        return building.getInstitutionId();
+    }
+
     private void fillSomeFieldsOfCustomer(TaRecommendCustomer customer, TaPerson recommender, LocalDateTime now) {
         customer.setVerifyStatus(CommConstant.VERIFY_AGREE);
         customer.setStatus(CommConstant.CUSTOMER_REPORT);
         taRecommendCustomer.setCreateDate(LocalDateTime.now());
         taRecommendCustomer.setReportDate(LocalDateTime.now());
         taRecommendCustomer.setPersonId(taPerson.getPersonId());
+        taRecommendCustomer.setInstitutionId(getInstitutionId(params.getString("buildingId")));
 
         // 时间格式 yyyy-MM-dd
 //        String at = params.getString("appointmentTime");
     }
 
     @Override
-    public IPage getCustomerList(Integer status, int pageNumber, int pageSize, String building, String name, String tel, String consultName, String consultTel, String entryType, String verifyStatus, Integer sex, String customerType, Integer orgId, List<TaPersonBuilding> taPersonBuildingList, String sceneType, String startCreateDate, String endCreateDate, String sharePersonName, Integer belongStatus) {
+    public IPage getCustomerList(Integer status, int pageNumber, int pageSize, String building, String name, String tel, String consultName, String consultTel, String entryType, String verifyStatus, Integer sex, String customerType, Integer orgId,
+                                 List<TaPersonBuilding> taPersonBuildingList, String sceneType, String startCreateDate, String endCreateDate, String sharePersonName, Integer belongStatus,
+                                 List<String> institutionIds) {
 
         if (CommConstant.CUTOMER_TYPE_PUBLIC.equals(customerType)) {
             // 公客
             IPage<TaPerson> page = new Page<>(pageNumber, pageSize);
             // 公客就不用 buildingId 进行查询
-            return taRecommendCustomerMapper.getPublicCustomerList(page, name, tel, entryType, verifyStatus, sex, orgId, consultTel, sceneType, taPersonBuildingList, building, startCreateDate, endCreateDate, sharePersonName, belongStatus);
+            return taRecommendCustomerMapper.getPublicCustomerList(page, name, tel, entryType, verifyStatus, sex, orgId, consultTel, sceneType, taPersonBuildingList, building, startCreateDate, endCreateDate, sharePersonName, belongStatus, institutionIds);
         } else {
             // 私客
             IPage<TaRecommendCustomer> page = new Page<>(pageNumber, pageSize);
-            return taRecommendCustomerMapper.getCustomerList(page, building, name, tel, consultName, consultTel, entryType, verifyStatus, sex, orgId, status, taPersonBuildingList, sceneType, startCreateDate, endCreateDate, sharePersonName);
+            return taRecommendCustomerMapper.getCustomerList(page, building, name, tel, consultName, consultTel, entryType, verifyStatus, sex, orgId, status, taPersonBuildingList, sceneType, startCreateDate, endCreateDate, sharePersonName,institutionIds);
         }
 
     }

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

             queryWrapper.eq(Brand::getOrgId,getOrgId(request));
             queryWrapper.like(!StringUtils.isEmpty(brandName),Brand::getBrandName,brandName);
             queryWrapper.orderByDesc(Brand::getCreatedTime);
-            if ("admin".equals(plat)) {
-                queryWrapper.in(Brand::getInstitutionId,getInstitutionCodes(request));
-            }
 
             IPage<Brand> result = iBrandService.page(pg, queryWrapper);
             responseBean.addSuccess(result);
             brand.setCreatedTime(LocalDateTime.now());
             brand.setCreatedBy(getUserId(request));
             brand.setOrgId(getOrgId(request));
-            brand.setInstitutionId(getInstitutionId(request));
             if (iBrandService.save(brand)){
                 responseBean.addSuccess(brand);
             }else {

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

                     phone,
                     recommendPersonName,
                     recommendPhone,
-                    status,type,getUserId(request));
+                    status,type,getUserId(request),getInstitutionIds(request));
             responseBean.addSuccess(result);
         }catch (Exception e){
             e.printStackTrace();

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

             queryWrapper.eq(Curriculum::getOrgId,getOrgId(request));
             queryWrapper.like(!StringUtils.isEmpty(name),Curriculum::getName,'%'+name+'%');
             queryWrapper.eq(null != roleId,Curriculum::getRoleId,roleId);
-            queryWrapper.in(Curriculum::getInstitutionId,getInstitutionCodes(request));
+            queryWrapper.in(Curriculum::getInstitutionId,getInstitutionIds(request));
             queryWrapper.orderByDesc(Curriculum::getWeight);
             queryWrapper.orderByDesc(Curriculum::getCreatedTime);
 
             curriculum.setCreatedTime(LocalDateTime.now());
             curriculum.setCreatedBy(getUserId(request));
             curriculum.setOrgId(getOrgId(request));
-            curriculum.setInstitutionId(getInstitutionId(request));
             if (iCurriculumService.save(curriculum)){
                 responseBean.addSuccess(curriculum);
             }else {

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

 		    IPage<TaPolicyType> pg = new Page<>(pageNum, pageSize);
             LambdaQueryWrapper<TaPolicyType> queryWrapper = new LambdaQueryWrapper<>();
             queryWrapper.eq(TaPolicyType::getOrgId,getOrgId(request));
-            if ("admin".equals(plat)) {
-                queryWrapper.in(TaPolicyType::getInstitutionId,getInstitutionCodes(request));
-            }
             queryWrapper.orderByDesc(TaPolicyType::getSort);
 
             IPage<TaPolicyType> result = iTaPolicyTypeService.page(pg, queryWrapper);
         try {
             taPolicyType.setOrgId(getOrgId(request));
             taPolicyType.setCreateDate(LocalDateTime.now());
-            taPolicyType.setInstitutionId(getInstitutionId(request));
             if (iTaPolicyTypeService.save(taPolicyType)){
                 responseBean.addSuccess(taPolicyType);
             }else {

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

             LambdaQueryWrapper<Video> queryWrapper = new LambdaQueryWrapper<>();
             queryWrapper.eq(!StringUtils.isEmpty(name),Video::getName,name);
             queryWrapper.eq(Video::getOrgId,getOrgId(request));
-            queryWrapper.in(Video::getInstitutionId,getInstitutionCodes(request));
+            queryWrapper.in(Video::getInstitutionId,getInstitutionIds(request));
             queryWrapper.orderByDesc(Video::getWeight);
             queryWrapper.orderByDesc(Video::getCreatedTime);
 
             video.setCreatedTime(LocalDateTime.now());
             video.setCreatedBy(getUserId(request));
             video.setOrgId(getOrgId(request));
-            video.setInstitutionId(getInstitutionId(request));
+            video.setInstitutionId(getInstitutionId(video.getBuildingId()));
             if (iVideoService.save(video)){
                 responseBean.addSuccess(video);
             }else {

src/main/java/com/yunzhi/marketing/xlk/entity/Brand.java

      * 公司id
      */
     private Integer orgId;
-
-    /**
-     * 组织结构id
-     */
-    private String institutionId;
 }

src/main/java/com/yunzhi/marketing/xlk/entity/ChannelCustomer.java

      */
     private Integer channelId;
 
+    /**
+     * 组织结构id
+     */
+    private String institutionId;
+
     @TableField(exist = false)
     private String channelName;
 

src/main/java/com/yunzhi/marketing/xlk/entity/TaPolicyType.java

     /** 颜色 */
     private String color ;
 
-    /**
-     * 组织机构code
-     */
-    private String institutionId;
-
 }

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

                                           @Param("recommendPersonName") String recommendPersonName,
                                           @Param("recommendPhone") String recommendPhone,
                                           @Param("status") String status,@Param("type") String type,
-                                          @Param("institutionCode") String institutionCode);
+                                          @Param("institutionIds") List<String> institutions);
 
     List<CustomerRankListVO> getRanklist(@Param("params") StatisticsDTO statisticsDTo);
 

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

 import com.yunzhi.marketing.xlk.dto.*;
 import com.yunzhi.marketing.xlk.entity.ChannelCustomer;
 
+import java.util.List;
+
 /**
  * <p>
  * 渠道报备客户表  服务类
                                           String recommendPhone,
                                           String status,
                                           String type,
-                                          Integer userId);
+                                          Integer userId,
+                                          List<String> institutions);
 
     /**
      * 驻场认筹

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

 import org.springframework.stereotype.Service;
 
 import java.time.LocalDateTime;
+import java.util.List;
 
 /**
  * <p>
             taRecommendCustomer.setStatus(CommConstant.CUSTOMER_VISITE);
             taRecommendCustomer.setRealtyConsultant(channelCustomerDTO.getRealtyConsultant());
             taRecommendCustomer.setCirculationTime(LocalDateTime.now());
+            taRecommendCustomer.setInstitutionId(customer.getInstitutionId());
             taRecommendCustomerMapper.insert(taRecommendCustomer);
             // 审核通过
             customer.setStatus("2");
                 taRecommendCustomer.setStatus(CommConstant.CUSTOMER_VISITE);
                 taRecommendCustomer.setRealtyConsultant(params.getRealtyConsultant());
                 taRecommendCustomer.setCirculationTime(LocalDateTime.now());
+                taRecommendCustomer.setInstitutionId(customer.getInstitutionId());
                 taRecommendCustomerMapper.insert(taRecommendCustomer);
 
                 // 审核通过
                                                  String phone,
                                                  String recommendPersonName,
                                                  String recommendPhone,
-                                                 String status,String type, Integer userId) {
-        TaUser taUser = taUserMapper.selectById(userId);
-        Institution institution = institutionMapper.selectById(taUser.getInstitutionId());
-        return channelCustomerMapper.getProfileList(pg, orgId, buildingId, name, phone, recommendPersonName, recommendPhone, status, type, institution.getInstitutionCode());
+                                                 String status, String type, Integer userId,
+                                                 List<String> institutions) {
+        return channelCustomerMapper.getProfileList(pg, orgId, buildingId, name, phone, recommendPersonName, recommendPhone, status, type, institutions);
     }
 
     /**

src/main/resources/mapper/TaBuildingDynamicMapper.xml

         <if test="time != null">
             and TO_DAYS(tbd.create_date) = TO_DAYS(#{time})
         </if>
+        <if test="institutionIds != null and institutionIds.size > 0">
+            AND tbd.institution_id in
+            <foreach collection="institutionIds" item="item" open="(" close=")" separator=",">
+                #{item}
+            </foreach>
+        </if>
         <if test="personBuildingList != null and personBuildingList.size > 0">
             AND tbd.building_id in
             <foreach collection="personBuildingList" item="personBuilding" open="(" close=")" separator=",">

src/main/resources/mapper/TaBuildingMapper.xml

             <if test="orgId != null">
                 and  ta_building.org_id = #{orgId}
             </if>
+            <if test="institutionIds != null and institutionIds.size > 0">
+                AND ta_building.institution_id in
+                <foreach collection="institutionIds" item="item" open="(" close=")" separator=",">
+                    #{item}
+                </foreach>
+            </if>
             <if test="personBuildingList != null and personBuildingList.size > 0">
                 AND ta_building.building_id in
                 <foreach collection="personBuildingList" item="personBuilding" open="(" close=")" separator=",">
         i.institution_id
         FROM
         xlk_institution i
-        INNER JOIN ( SELECT x.institution_code FROM xlk_user_institution t LEFT JOIN xlk_institution x ON t.institution_id = x.institution_id WHERE t.user_id = #{userId}) g ON i.institution_code LIKE g.institution_code
+        INNER JOIN ( SELECT x.institution_code FROM xlk_user_institution t LEFT JOIN xlk_institution x ON t.institution_id = x.institution_id WHERE t.user_id = #{userId}) g ON i.institution_code LIKE CONCAT(g.institution_code ,"%")
         )
     </select>
     <select id="getBuilidngsOfPerson" resultType="com.yunzhi.marketing.entity.TaBuilding">

src/main/resources/mapper/TaChannelMapper.xml

             </if>
             and c.org_id = #{orgId}
             and c.status = 1
-            AND i.institution_code like CONCAT(#{institutionCode}, '%')
+
+            <if test="institutionIds != null and institutionIds.size > 0">
+                AND c.institution_id in
+                <foreach collection="institutionIds" item="item" open="(" close=")" separator=",">
+                    #{item}
+                </foreach>
+            </if>
         </where>
         GROUP BY c.channel_id
     </select>
         ta_channel c
         LEFT JOIN ta_channel_person cp ON c.channel_id = cp.channel_id and cp.`status` = 1
         LEFT JOIN ta_person t on cp.person_id = t.person_id and t.person_type in ('estate agent','channel agent')
-        LEFT JOIN xlk_institution i ON c.institution_id = i.institution_id
         LEFT JOIN ta_recommend_customer rc ON t.person_id = rc.recommend_person AND rc.verify_status = 1
         <where>
             <if test="channelId != null and channelId != ''">
                 c.channel_id = #{channelId}
             </if>
             and c.org_id = #{orgId}
-            AND i.institution_code like CONCAT(#{institutionCode}, '%')
+            <if test="institutionIds != null and institutionIds.size > 0">
+                AND c.institution_id in
+                <foreach collection="institutionIds" item="item" open="(" close=")" separator=",">
+                    #{item}
+                </foreach>
+            </if>
         </where>
         GROUP BY c.channel_id
     </select>

src/main/resources/mapper/TaLiveActivityMapper.xml

                 #{personBuilding.buildingId}
             </foreach>
             or t.create_user = #{userId})
+        </if>
+        <if test="institutionIds != null and institutionIds.size > 0">
+            AND t.institution_id in
+            <foreach collection="institutionIds" item="item" open="(" close=")" separator=",">
+                #{item}
+            </foreach>
         </if>
             order by t.weight desc
     </select>

src/main/resources/mapper/TaRecommendCustomerMapper.xml

                 and (c.nickName like CONCAT('%',#{sharePersonName}, '%') or c.name like CONCAT('%',#{sharePersonName},
                 '%'))
             </if>
+            <if test="institutionIds != null and institutionIds.size > 0">
+                AND a.institution_id in
+                <foreach collection="institutionIds" item="item" open="(" close=")" separator=",">
+                    #{item}
+                </foreach>
+            </if>
             <if test="personBuildingList != null and personBuildingList.size > 0">
                 AND a.building_id in
                 <foreach collection="personBuildingList" item="personBuilding" open="(" close=")" separator=",">
                 and (t3.nickName like CONCAT('%',#{sharePersonName}, '%') or t3.name like CONCAT('%',#{sharePersonName},
                 '%'))
             </if>
+            <if test="institutionIds != null and institutionIds.size > 0">
+                AND t.institution_id in
+                <foreach collection="institutionIds" item="item" open="(" close=")" separator=",">
+                    #{item}
+                </foreach>
+            </if>
             <if test="personBuildingList != null and personBuildingList.size > 0">
                 AND t.building_id in
                 <foreach collection="personBuildingList" item="personBuilding" open="(" close=")" separator=",">

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

         FROM
             xlk_channel_customer t
                 LEFT JOIN ta_building s ON t.building_id = s.building_id
-        LEFT JOIN xlk_institution i ON s.institution_id = i.institution_id
                 INNER JOIN ta_person m ON t.recommend_person = m.person_id
         WHERE
             t.org_id = #{orgId}
-            AND i.institution_code like CONCAT(#{institutionCode}, '%')
+        <if test="institutionIds != null and institutionIds.size > 0">
+            AND t.institution_id in
+            <foreach collection="institutionIds" item="item" open="(" close=")" separator=",">
+                #{item}
+            </foreach>
+        </if>
           <if test="buildingId != null and buildingId != ''">
               AND t.building_id = #{buildingId}
           </if>