修改bug数据统计相关

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

     public List<String> getInstitutionIds(HttpServletRequest request) {
         TaUser taUser = taUserService.getById(getUserId(request));
         List<Institution> list = iInstitutionService.getAllByUser(taUser);
-        return list.stream().map(Institution::getInstitutionId).collect(Collectors.toList());
+        List<String> institutions = list.stream().map(Institution::getInstitutionId).collect(Collectors.toList());
+        if (institutions.contains("01")) {
+            return null;
+        }
+        return institutions;
     }
 
     /**

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

     public ResponseBean changeNewsUserCount(@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,
                                             HttpServletRequest request) {
-        return iStatisticalService.changeNewsUserCount(getOrgId(request), startDate, endDate);
+        return iStatisticalService.changeNewsUserCount(getOrgId(request), startDate, endDate,getInstitutionIds(request));
     }
 
     /**
                                             @RequestParam(value = "pageSize", defaultValue = "2") Integer pageSize,
                                             @RequestParam(value = "buildingId", required = false) String buildingId,
                                             HttpServletRequest request) {
-        return iStatisticalService.selectIntentionUser(pageNum, pageSize, getOrgId(request), buildingId, getTaPersonBuildingListByUserId(request));
+        return iStatisticalService.selectIntentionUser(pageNum, pageSize, getOrgId(request), buildingId, getTaPersonBuildingListByUserId(request), getInstitutionIds(request));
     }
 
     /**
     public ResponseBean selectPersonFrom(@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,
                                             HttpServletRequest request) {
-        return iStatisticalService.selectPersonFrom(getOrgId(request), startDate,endDate);
+        return iStatisticalService.selectPersonFrom(getOrgId(request), startDate,endDate,getInstitutionIds(request));
     }
 
     /**
         response.setContentType("application/octet-stream");
         response.setCharacterEncoding("utf-8");
         response.setHeader("Content-disposition", "attachment;filename=新增用户.xlsx");
-        ResponseBean responseBean = iStatisticalService.selectPersonFrom(getOrgId(request), startDate, endDate);
+        ResponseBean responseBean = iStatisticalService.selectPersonFrom(getOrgId(request), startDate, endDate,getInstitutionIds(request));
         List<List<String>> headerList = headerList(responseBean.getData());
         List<List<String>> dataList = dataList(responseBean.getData(),userType);
         EasyExcel.write(response.getOutputStream()).head(headerList).sheet("新增用户").doWrite(dataList);

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

     IPage<Map<String, Object>> selectIntentionUser(IPage<Map<String, Object>> page,
                                                    @Param("orgId") Integer orgId,
                                                    @Param("buildingId") String buildingId,
-                                                   @Param("personBuildingList") List<TaPersonBuilding> personBuildingList);
+                                                   @Param("personBuildingList") List<TaPersonBuilding> personBuildingList,
+                                                   @Param("institutionIds") List<String> institutions);
 
     List<IntentionUser> selectExportIntentionUser(@Param("orgId") Integer orgId,@Param("buildingId") String buildingId,@Param("personBuildingList") List<TaPersonBuilding> taPersonBuildingListByUserId);
 }

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

      * @param buildingId
      * @return
      */
-    ResponseBean selectIntentionUser(Integer pageNum, Integer pageSize, Integer orgId, String buildingId, List<TaPersonBuilding> taPersonBuildingListByUserId);
+    ResponseBean selectIntentionUser(Integer pageNum, Integer pageSize, Integer orgId, String buildingId, List<TaPersonBuilding> taPersonBuildingListByUserId,List<String> institutions);
 
     /**
      * 用户来源数据 首页
      * @param endDate
      * @return
      */
-    ResponseBean selectPersonFrom(Integer orgId, LocalDate startDate, LocalDate endDate);
+    ResponseBean selectPersonFrom(Integer orgId, LocalDate startDate, LocalDate endDate,List<String> institutions);
 
     /**
      * 用户来源数据统计折线图
      * @param endDate
      * @return
      */
-    ResponseBean changeNewsUserCount(Integer orgId, LocalDate startDate, LocalDate endDate);
+    ResponseBean changeNewsUserCount(Integer orgId, LocalDate startDate, LocalDate endDate,List<String> institutions);
 
     /**
      * 人员城市分布

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

     }
 
     @Override
-    public ResponseBean selectIntentionUser(Integer pageNum, Integer pageSize, Integer orgId, String buildingId, List<TaPersonBuilding> taPersonBuildingListByUserId) {
+    public ResponseBean selectIntentionUser(Integer pageNum, Integer pageSize, Integer orgId, String buildingId, List<TaPersonBuilding> taPersonBuildingListByUserId,List<String> institutions) {
         ResponseBean responseBean = new ResponseBean();
 
         IPage<Map<String, Object>> pg = new Page<>(pageNum, pageSize);
-        IPage<Map<String, Object>> page = taPersonIntentionRecordMapper.selectIntentionUser(pg, orgId, buildingId, taPersonBuildingListByUserId);
+        IPage<Map<String, Object>> page = taPersonIntentionRecordMapper.selectIntentionUser(pg, orgId, buildingId, taPersonBuildingListByUserId,institutions);
 
         responseBean.addSuccess(page);
         return responseBean;
      * @return
      */
     @Override
-    public ResponseBean selectPersonFrom(Integer orgId, LocalDate startDate, LocalDate endDate) {
+    public ResponseBean selectPersonFrom(Integer orgId, LocalDate startDate, LocalDate endDate,List<String> institutions) {
         ResponseBean responseBean = new ResponseBean();
-        List<TsPersonFromStatistic> list = tsPersonFromStatisticMapper.selectPersonFrom(orgId, startDate, endDate);
+        List<TsPersonFromStatistic> list = tsPersonFromStatisticMapper.selectPersonFrom(orgId, startDate, endDate,institutions);
         QueryWrapper<TdWxDict> tdWxDictQueryWrapper = new QueryWrapper<>();
         tdWxDictQueryWrapper.groupBy("scene_type");
         List<TdWxDict> tdWxDicts = tdWxDictMapper.selectList(tdWxDictQueryWrapper);
         });
         Map<String, Object> map = new HashMap<>();
         map.put("tdWxDicts", tdWxDicts);
-        List<TsPersonFromStatistic> tableList = tsPersonFromStatisticMapper.selectPersonFromGroupByData(orgId, startDate, endDate);
+        List<TsPersonFromStatistic> tableList = tsPersonFromStatisticMapper.selectPersonFromGroupByData(orgId, startDate, endDate,institutions);
         map.put("list", tableList);
         responseBean.addSuccess(map);
         return responseBean;
      * @return
      */
     @Override
-    public ResponseBean changeNewsUserCount(Integer orgId, LocalDate startDate, LocalDate endDate) {
-        List<TsPersonFromStatistic> tableList = tsPersonFromStatisticMapper.selectNewLinePersonFromGroupByData(orgId, startDate, endDate);
+    public ResponseBean changeNewsUserCount(Integer orgId, LocalDate startDate, LocalDate endDate,List<String> institutions) {
+        List<TsPersonFromStatistic> tableList = tsPersonFromStatisticMapper.selectNewLinePersonFromGroupByData(orgId, startDate, endDate,institutions);
         return ResponseBean.success(tableList);
     }
 

src/main/java/com/yunzhi/marketing/statistic/controller/TsUserBehaviorStatisticController.java

                                            @RequestParam(value = "org", required = false) String org,
                                            HttpServletRequest request) {
         Integer orgId = StringUtils.isEmpty(org) ? getOrgId(request) : Integer.valueOf(org);
-        return iTsUserBehaviorStatisticService.selectUserBehavior(orgId, startDate, endDate, buildingId);
+        return iTsUserBehaviorStatisticService.selectUserBehavior(orgId, startDate, endDate, buildingId,getInstitutionIds(request));
     }
 }

src/main/java/com/yunzhi/marketing/statistic/entity/TsPersonFromStatistic.java

      */
     @TableField(exist = false)
     private String createTime;
+
+    /**
+     * 组织机构id
+     */
+    private String institutionId;
 }

src/main/java/com/yunzhi/marketing/statistic/entity/TsUserBehaviorStatistic.java

      */
     private LocalDateTime createDate;
 
-
+    /**
+     * 组织机构id
+     */
+    private String institutionId;
 }

src/main/java/com/yunzhi/marketing/statistic/mapper/TsPersonFromStatisticMapper.java

 
     void insertStatisticList(List<TsPersonFromStatistic> list);
 
-    List<TsPersonFromStatistic> selectPersonFrom(@Param("orgId") Integer orgId, @Param("startDate") LocalDate startDate, @Param("endDate") LocalDate endDate);
+    List<TsPersonFromStatistic> selectPersonFrom(@Param("orgId") Integer orgId, @Param("startDate") LocalDate startDate, @Param("endDate") LocalDate endDate,@Param("institutionIds") List<String> institutions);
 
     List<TsPersonFromStatistic> selectPersonFromGroupByDay(@Param("orgId") Integer orgId, @Param("startDate") LocalDate startDate, @Param("endDate") LocalDate endDate);
 
-    List<TsPersonFromStatistic> selectPersonFromGroupByData(@Param("orgId") Integer orgId, @Param("startDate") LocalDate startDate, @Param("endDate") LocalDate endDate);
+    List<TsPersonFromStatistic> selectPersonFromGroupByData(@Param("orgId") Integer orgId, @Param("startDate") LocalDate startDate, @Param("endDate") LocalDate endDate,@Param("institutionIds") List<String> institutions);
 
     void deleteByData();
 
-    List<TsPersonFromStatistic> selectNewLinePersonFromGroupByData(@Param("orgId") Integer orgId,@Param("startDate") LocalDate startDate,@Param("endDate") LocalDate endDate);
+    List<TsPersonFromStatistic> selectNewLinePersonFromGroupByData(@Param("orgId") Integer orgId,@Param("startDate") LocalDate startDate,@Param("endDate") LocalDate endDate,@Param("institutionIds") List<String> institutions);
 }

src/main/java/com/yunzhi/marketing/statistic/mapper/TsUserBehaviorStatisticMapper.java

 
     int deleteByDate();
 
-    List<PersonPO>  seleBehaviorListByDate(@Param("orgId") Integer orgId, @Param("startDate") LocalDate startDate, @Param("endDate") LocalDate endDate, @Param("buildingId") String buildingId);
+    List<PersonPO>  seleBehaviorListByDate(@Param("orgId") Integer orgId, @Param("startDate") LocalDate startDate, @Param("endDate") LocalDate endDate, @Param("buildingId") String buildingId,@Param("institutionIds") List<String> institutions);
 }

src/main/java/com/yunzhi/marketing/statistic/service/ITsUserBehaviorStatisticService.java

 import com.yunzhi.marketing.statistic.entity.TsUserBehaviorStatistic;
 
 import java.time.LocalDate;
+import java.util.List;
 
 /**
  * <p>
      * @param buildingId
      * @return
      */
-    ResponseBean selectUserBehavior(Integer orgId, LocalDate startDate, LocalDate endDate, String buildingId);
+    ResponseBean selectUserBehavior(Integer orgId, LocalDate startDate, LocalDate endDate, String buildingId, List<String> institutionIds);
 }

src/main/java/com/yunzhi/marketing/statistic/service/impl/TsUserBehaviorStatisticServiceImpl.java

      * @return
      */
     @Override
-    public ResponseBean selectUserBehavior(Integer orgId, LocalDate startDate, LocalDate endDate, String buildingId) {
+    public ResponseBean selectUserBehavior(Integer orgId, LocalDate startDate, LocalDate endDate, String buildingId, List<String> institutionIds) {
         ResponseBean responseBean = new ResponseBean();
-        List<PersonPO> tsUserBehaviorStatistics = tsUserBehaviorStatisticMapper.seleBehaviorListByDate(orgId, startDate, endDate, buildingId);
+        List<PersonPO> tsUserBehaviorStatistics = tsUserBehaviorStatisticMapper.seleBehaviorListByDate(orgId, startDate, endDate, buildingId,institutionIds);
         Map<String, Object> map = new HashMap<>();
         map.put("selectUserBehavior", tsUserBehaviorStatistics);
         responseBean.addSuccess(map);

src/main/resources/mapper/TaPersonFromRecordMapper.xml

             t.event_type,
             t.org_id,
             t.create_date,
-            sum( IF ( p.phone IS NOT NULL OR p.tel IS NOT NULL, 1, 0 ) ) AS registered_num
+            sum( IF ( p.phone IS NOT NULL OR p.tel IS NOT NULL, 1, 0 ) ) AS registered_num,
+            b.institution_id
         FROM
             ta_person_from_record t
             LEFT JOIN ta_person p ON t.person_id = p.person_id
+            LEFT JOIN ta_building b on t.building_id = b.building_id
         WHERE
             t.is_first_time = 1
             AND DATE_FORMAT( t.create_date, '%Y-%m-%d' ) = DATE_FORMAT( NOW( ), '%Y-%m-%d' )
         GROUP BY
             t.scene_type,
             t.event_type,
-            t.org_id
+            t.org_id,
+            b.institution_id
     </select>
 </mapper>

src/main/resources/mapper/TaPersonIntentionRecordMapper.xml

         FROM
             ta_person_intention_record tpir
             LEFT JOIN ta_person tp on tpir.person_id = tp.person_id
+            Left join ta_building tb on tpir.building_id = tb.building_id
             <trim prefix="where" prefixOverrides="and | or">
                 <if test="buildingId != null and buildingId != ''">
                     tpir.building_id = #{buildingId}
                         #{personBuilding.buildingId}
                     </foreach>
                 </if>
+                <if test="institutionIds != null and institutionIds.size > 0">
+                    AND tb.institution_id in
+                    <foreach collection="institutionIds" item="item" open="(" close=")" separator=",">
+                        #{item}
+                    </foreach>
+                </if>
             </trim>
         GROUP BY
             tpir.person_id, tpir.building_id

src/main/resources/mapper/statistic/TsPersonFromStatisticMapper.xml

 <mapper namespace="com.yunzhi.marketing.statistic.mapper.TsPersonFromStatisticMapper">
 
     <insert id="insertStatisticList">
-        INSERT INTO ts_person_from_statistic(scene_type,event_type,from_num,org_id,create_date,registered_num)
+        INSERT INTO ts_person_from_statistic(scene_type,event_type,from_num,org_id,create_date,registered_num,institution_id)
         VALUES
         <foreach collection="list" item="item" separator=",">
-            (#{item.sceneType},#{item.eventType},#{item.fromNum},#{item.orgId},#{item.createDate},#{item.registeredNum})
+            (#{item.sceneType},#{item.eventType},#{item.fromNum},#{item.orgId},#{item.createDate},#{item.registeredNum},#{item.institutionId})
         </foreach>
     </insert>
     <delete id="deleteByData">
         <if test="startDate == null or endDate == null">
             AND DATE_FORMAT( tp.create_date, '%Y-%m-%d' ) BETWEEN DATE_SUB(now(),INTERVAL 7 DAY) and now()
         </if>
-
+        <if test="institutionIds != null and institutionIds.size > 0">
+            AND tp.institution_id in
+            <foreach collection="institutionIds" item="item" open="(" close=")" separator=",">
+                #{item}
+            </foreach>
+        </if>
     </select>
     <select id="selectPersonFromGroupByDay"
             resultType="com.yunzhi.marketing.statistic.entity.TsPersonFromStatistic">
         <if test="startDate == null or endDate == null">
             AND DATE_FORMAT( tp.create_date, '%Y-%m-%d' ) BETWEEN DATE_SUB(now(),INTERVAL 7 DAY) and now()
         </if>
+        <if test="institutionIds != null and institutionIds.size > 0">
+            AND tp.institution_id in
+            <foreach collection="institutionIds" item="item" open="(" close=")" separator=",">
+                #{item}
+            </foreach>
+        </if>
         GROUP BY DATE_FORMAT( tp.create_date, '%Y-%m-%d' ), tp.scene_type ORDER BY tp.create_date
         ) as tp on date.date = tp.create_time
 
         <if test="startDate == null or endDate == null">
             AND DATE_FORMAT( tp.create_date, '%Y-%m-%d' ) BETWEEN DATE_SUB(now(),INTERVAL 7 DAY) and now()
         </if>
+        <if test="institutionIds != null and institutionIds.size > 0">
+            AND tp.institution_id in
+            <foreach collection="institutionIds" item="item" open="(" close=")" separator=",">
+                #{item}
+            </foreach>
+        </if>
         GROUP BY
         DATE_FORMAT( tp.create_date, '%Y-%m-%d' )
         ORDER BY tp.create_date

src/main/resources/mapper/statistic/TsUserBehaviorStatisticMapper.xml

 
     <select id="seleUserBehaviorList"
             resultType="com.yunzhi.marketing.statistic.entity.TsUserBehaviorStatistic">
-                SELECT
+        SELECT
             temp_date.date AS create_date,
             temp_date.type_name AS event_name,
             temp_date.type_id AS event_type,
             temp.activityCount AS behavior_num,
             temp.building_id,
-            temp.org_id
+            temp.org_id,
+            temp.institution_id
         FROM
-            (
+        (
         SELECT
             DATE_FORMAT( DATE_SUB( now( ), INTERVAL a.rownum DAY ), '%Y-%m-%d' ) AS date,
             b.type_id,
         FROM
             sequence a,
             td_biz_event_type b
-            ) AS temp_date
-            LEFT JOIN (
-        SELECT
-            COUNT( 1 ) AS activityCount,
-            tpvr.event_type,
-            DATE_FORMAT( tpvr.visit_time, '%Y-%m-%d' ) AS date,
-            tpvr.building_id,
-            tp.org_id
-        FROM
-            ta_person tp
+        ) AS temp_date
+        LEFT JOIN (
+            SELECT
+                COUNT( 1 ) AS activityCount,
+                tpvr.event_type,
+                DATE_FORMAT( tpvr.visit_time, '%Y-%m-%d' ) AS date,
+                tpvr.building_id,
+                tp.org_id,
+                tb.institution_id
+            FROM
+                ta_person tp
             INNER JOIN ta_person_visit_record tpvr ON tp.person_id = tpvr.person_id
+            LEFT JOIN ta_building tb on tpvr.building_id = tb.building_id
+            WHERE
+                tp.person_type IN ( 'customer', 'drift', 'estate agent' )
+            GROUP BY
+                tpvr.event_type,
+                DATE_FORMAT( tpvr.visit_time, '%Y-%m-%d' ),
+                tp.org_id,
+                tpvr.building_id
+        ) AS temp ON temp_date.date = temp.date
+        AND temp_date.type_id = temp.event_type
         WHERE
-            tp.person_type IN ( 'customer', 'drift', 'estate agent' )
-        GROUP BY
-            tpvr.event_type,
-            DATE_FORMAT( tpvr.visit_time, '%Y-%m-%d' ),
-            tp.org_id,
-            tpvr.building_id
-            ) AS temp ON temp_date.date = temp.date
-            AND temp_date.type_id = temp.event_type where temp_date.date = DATE_FORMAT( now( ), '%Y-%m-%d' )
+        temp_date.date = DATE_FORMAT( now( ), '%Y-%m-%d' )
     </select>
     <select id="seleBehaviorListByDate"
             resultType="com.yunzhi.marketing.po.PersonPO">
             <if test="buildingId != null and buildingId != ''">
                 and tp.building_id = #{buildingId}
             </if>
+            <if test="institutionIds != null and institutionIds.size > 0">
+                AND tp.institution_id in
+                <foreach collection="institutionIds" item="item" open="(" close=")" separator=",">
+                    #{item}
+                </foreach>
+            </if>
             GROUP BY
             DATE_FORMAT( tp.create_date, '%Y-%m-%d' ),
             tp.event_type