bug fix

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

         ResponseBean responseBean = new ResponseBean();
         try {
             IPage<TaLiveActivity> result = iTaLiveActivityService.listLiveActivityByCondition(pageNum, pageSize, getOrgId(request),
-                    liveActivityTitle, cityId, buildingId, status, getTaPersonBuildingListByUserId(request));
+                    liveActivityTitle, cityId, buildingId, status, getTaPersonBuildingListByUserId(request), getUserId(request));
             responseBean.addSuccess(result);
 
         } catch (Exception e) {
             status = status == null ? 1 : status;
             Integer orgId = getOrgId(request);
             IPage<TaLiveActivity> result = iTaLiveActivityService.listLiveActivityByCondition(pageNum, pageSize, orgId,
-                    liveActivityTitle, cityId, buildingId, status, null);
+                    liveActivityTitle, cityId, buildingId, status, null, null);
             responseBean.addSuccess(result);
 
         } catch (Exception e) {

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

      */
     Boolean addVisitNum(@Param("id") String id);
 
-    IPage<TaLiveActivity> selectLiveListByCondition(IPage<TaLiveActivity> pg, @Param("liveActivityTitle") String liveActivityTitle, @Param("cityId") String cityId, @Param("buildingId") String buildingId, @Param("status") Integer status, @Param("orgId") Integer orgId,@Param("personBuildingList") List<TaPersonBuilding> personBuildingList);
+    IPage<TaLiveActivity> selectLiveListByCondition(IPage<TaLiveActivity> pg, @Param("liveActivityTitle") String liveActivityTitle, @Param("cityId") String cityId, @Param("buildingId") String buildingId, @Param("status") Integer status, @Param("orgId") Integer orgId,@Param("personBuildingList") List<TaPersonBuilding> personBuildingList, @Param("userId") Integer userId);
     /**
      * 批量更新直播活动状态
      *

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

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

src/main/java/com/huiju/estateagents/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) {
+                                                             String cityId, String buildingId, Integer status, List<TaPersonBuilding> taPersonBuildingListByUserId, Integer userId) {
         logger.info("TaLiveActivityServiceImpl.listLiveActivityByCondition 接收参数：pageNum:{},pageSize:{},orgId:{}," +
                     "liveActivityTitle:{},cityId:{},buildingId:{},liveDetailType:{},status:{}", pageNum, pageSize,
                 liveActivityTitle, cityId, buildingId, status);
 
         IPage<TaLiveActivity> pg = new Page<>(pageNum, pageSize);
-        return taLiveActivityMapper.selectLiveListByCondition(pg, liveActivityTitle, cityId, buildingId, status, orgId,taPersonBuildingListByUserId);
+        return taLiveActivityMapper.selectLiveListByCondition(pg, liveActivityTitle, cityId, buildingId, status, orgId,taPersonBuildingListByUserId, userId);
     }
 
     @Override

src/main/java/com/huiju/estateagents/statistic/controller/ActivityStatisticController.java

                                                @RequestParam(value = "activityId", required = false)String activityId,
                                                @RequestParam(value = "activityType", required = false)String activityType,
                                                @RequestParam(value = "buildingId", required = false)String buildingId,
+                                               @RequestParam(value = "province", required = false)String province,
                                                HttpServletRequest request) {
-        return taActivityStaticService.selectActivityAddRegistNum(pageNum, pageSize, getOrgId(request), startDate, endDate, personFrom, activityId, activityType, buildingId, getTaPersonBuildingListByUserId(request), getUserId(request));
+        return taActivityStaticService.selectActivityAddRegistNum(pageNum, pageSize, getOrgId(request), startDate, endDate, personFrom, activityId, activityType, buildingId, province, getTaPersonBuildingListByUserId(request), getUserId(request));
     }
 
     /**
                                                                @RequestParam(value = "activityId", required = false)String activityId,
                                                                @RequestParam(value = "activityType", required = false)String activityType,
                                                                @RequestParam(value = "buildingId", required = false)String buildingId,
+                                                               @RequestParam(value = "province", required = false)String province,
                                                                HttpServletRequest request, HttpServletResponse response) throws IOException {
         response.setContentType("application/octet-stream");
         response.setCharacterEncoding("utf-8");
         ExcelWriter excelWriter = EasyExcel.write(response.getOutputStream(), AddRegistNum.class).registerWriteHandler(new CustomCellWriteHandler()).build();
         // 设置 sheet, 同一个sheet只需要设置一次
         WriteSheet writeSheet = EasyExcel.writerSheet("活动统计").build();
-        List<AddRegistNum> data = taActivityStaticService.selectActivityAddRegistNumExport(getOrgId(request), startDate, endDate, personFrom, activityId, activityType, buildingId, getTaPersonBuildingListByUserId(request), getUserId(request));
+        List<AddRegistNum> data = taActivityStaticService.selectActivityAddRegistNumExport(getOrgId(request), startDate, endDate, personFrom, activityId, activityType, buildingId, province, getTaPersonBuildingListByUserId(request), getUserId(request));
         excelWriter.write(data, writeSheet);
         // finish 会帮忙关闭流
         excelWriter.finish();

src/main/java/com/huiju/estateagents/statistic/mapper/TaActicityStaticMapper.java

             @Param("activityId") String activityId,
             @Param("activityType") String activityType,
             @Param("buildingId") String buildingId,
+            @Param("province") String province,
             @Param("taPersonBuildings") List<TaPersonBuilding> taPersonBuildings,
             @Param("userId") Integer userId
     );
             @Param("activityId") String activityId,
             @Param("activityType") String activityType,
             @Param("buildingId") String buildingId,
+            @Param("province") String province,
             @Param("taPersonBuildings") List<TaPersonBuilding> taPersonBuildings,
             @Param("userId") Integer userId
     );

src/main/java/com/huiju/estateagents/statistic/service/impl/TaActivityStaticServiceImpl.java

         return taActicityStaticMapper.selectActivityShareNumExport( orgId, LocalDateTime.of(startDate, LocalTime.MAX), LocalDateTime.of(endDate, LocalTime.MAX), sharePersonType, sharePersonName, sharePhone, activityId, activityType, personId, buildingId, sortType, colKey, taPersonBuildings, userId);
     }
 
-    public ResponseBean selectActivityAddRegistNum(Integer pageNum, Integer pageSize, Integer orgId, LocalDate startDate, LocalDate endDate, String personFrom, String activityId, String activityType, String buildingId, List<TaPersonBuilding> taPersonBuildings, Integer userId){
+    public ResponseBean selectActivityAddRegistNum(Integer pageNum, Integer pageSize, Integer orgId, LocalDate startDate, LocalDate endDate, String personFrom, String activityId, String activityType, String buildingId, String province, List<TaPersonBuilding> taPersonBuildings, Integer userId){
         IPage<AddRegistNum> iPage = new Page<>(pageNum, pageSize);
-        IPage<AddRegistNum> data = taActicityStaticMapper.selectActivityAddRegistNum(iPage, orgId, LocalDateTime.of(startDate, LocalTime.MAX), LocalDateTime.of(endDate, LocalTime.MAX), personFrom, activityId, activityType, buildingId, taPersonBuildings, userId);
+        IPage<AddRegistNum> data = taActicityStaticMapper.selectActivityAddRegistNum(iPage, orgId, LocalDateTime.of(startDate, LocalTime.MAX), LocalDateTime.of(endDate, LocalTime.MAX), personFrom, activityId, activityType, buildingId, province, taPersonBuildings, userId);
         return ResponseBean.success(data);
     }
 
-    public List<AddRegistNum> selectActivityAddRegistNumExport(Integer orgId, LocalDate startDate, LocalDate endDate, String personFrom, String activityId, String activityType, String buildingId, List<TaPersonBuilding> taPersonBuildings, Integer userId){
-        return taActicityStaticMapper.selectActivityAddRegistNumExport(orgId, LocalDateTime.of(startDate, LocalTime.MAX), LocalDateTime.of(endDate, LocalTime.MAX), personFrom, activityId, activityType, buildingId, taPersonBuildings, userId);
+    public List<AddRegistNum> selectActivityAddRegistNumExport(Integer orgId, LocalDate startDate, LocalDate endDate, String personFrom, String activityId, String activityType, String buildingId, String province, List<TaPersonBuilding> taPersonBuildings, Integer userId){
+        return taActicityStaticMapper.selectActivityAddRegistNumExport(orgId, LocalDateTime.of(startDate, LocalTime.MAX), LocalDateTime.of(endDate, LocalTime.MAX), personFrom, activityId, activityType, buildingId, province, taPersonBuildings, userId);
     }
 
     public ResponseBean selectActivityVisitNum(Integer pageNum, Integer pageSize, Integer orgId, LocalDate startDate, LocalDate endDate, String personFrom, String provice, String realtyConsultant, String realtyConsultantPhone, String activityId, String activityType, String personId, String buildingId){

src/main/resources/mapper/TaLiveActivityMapper.xml

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

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

         sequence a
         <trim prefix="where">
             <if test="startDate != null or endDate != null">
-                a.rownum <![CDATA[ <= ]]> datediff(#{endDate}, #{startDate})
+                a.rownum <![CDATA[ < ]]> datediff(#{endDate}, #{startDate})
             </if>
         </trim>
         ) AS temp_date
         sequence a
         <trim prefix="where">
             <if test="startDate != null or endDate != null">
-                a.rownum <![CDATA[ <= ]]> datediff(#{endDate}, #{startDate})
+                a.rownum <![CDATA[ < ]]> datediff(#{endDate}, #{startDate})
             </if>
         </trim>
         ) AS temp_date
         sequence a
         <trim prefix="where">
             <if test="startDate != null or endDate != null">
-                a.rownum <![CDATA[ <= ]]> datediff(#{endDate}, #{startDate})
+                a.rownum <![CDATA[ < ]]> datediff(#{endDate}, #{startDate})
             </if>
         </trim>
         ) AS temp_date
         sequence a
         <trim prefix="where">
             <if test="startDate != null or endDate != null">
-                a.rownum <![CDATA[ <= ]]> datediff(#{endDate}, #{startDate})
+                a.rownum <![CDATA[ < ]]> datediff(#{endDate}, #{startDate})
             </if>
         </trim>
         ) AS temp_date
         sequence a
         <trim prefix="where">
             <if test="startDate != null or endDate != null">
-                a.rownum <![CDATA[ <= ]]> datediff(#{endDate}, #{startDate})
+                a.rownum <![CDATA[ < ]]> datediff(#{endDate}, #{startDate})
             </if>
         </trim>
         ) AS temp_date
         sequence a
         <trim prefix="where">
             <if test="startDate != null or endDate != null">
-                a.rownum <![CDATA[ <= ]]> datediff(#{endDate}, #{startDate})
+                a.rownum <![CDATA[ < ]]> datediff(#{endDate}, #{startDate})
             </if>
         </trim>
         ) AS temp_date
         sequence a
         <trim prefix="where">
             <if test="startDate != null or endDate != null">
-                a.rownum <![CDATA[ <= ]]> datediff(#{endDate}, #{startDate})
+                a.rownum <![CDATA[ < ]]> datediff(#{endDate}, #{startDate})
             </if>
         </trim>
         ) AS temp_date
             and d.name like concat('%', #{activityName}, '%')
         </if>
         <if test="taPersonBuildings != null and taPersonBuildings.size > 0">
-            and d.building_id in
+            and (d.building_id in
             <foreach collection="taPersonBuildings" item="taPersonBuilding" open="(" close=")" separator=",">
                 #{taPersonBuilding.buildingId}
             </foreach>
+            or d.create_user = #{userId}
+            )
         </if>
         union all
         select e.live_activity_id as activityId, e.live_activity_title as activityName, "live" as activityType From
             and e.live_activity_title like concat('%', #{activityName}, '%')
         </if>
         <if test="taPersonBuildings != null and taPersonBuildings.size > 0">
-            and e.building_id in
+            and (e.building_id in
             <foreach collection="taPersonBuildings" item="taPersonBuilding" open="(" close=")" separator=",">
                 #{taPersonBuilding.buildingId}
             </foreach>
+            or e.create_user = #{userId}
+            )
         </if>
         ) as activity
 
             and d.name = #{activityName}
         </if>
         <if test="taPersonBuildings != null and taPersonBuildings.size > 0">
-            and c.building_id in
+            and (d.building_id in
             <foreach collection="taPersonBuildings" item="taPersonBuilding" open="(" close=")" separator=",">
                 #{taPersonBuilding.buildingId}
             </foreach>
+            or d.create_user = #{userId}
+            )
         </if>
         union all
         select e.live_activity_id as activityId, e.live_activity_title as activityName, "live" as activityType From
             and e.live_activity_title = #{activityName}
         </if>
         <if test="taPersonBuildings != null and taPersonBuildings.size > 0">
-            and e.building_id in
+            and (e.building_id in
             <foreach collection="taPersonBuildings" item="taPersonBuilding" open="(" close=")" separator=",">
                 #{taPersonBuilding.buildingId}
             </foreach>
+            or e.create_user = #{userId}
+            )
         </if>
         ) as activity
 
         <if test="activityType != null and activityType != ''">
             and t.target_type = concat(REPLACE(#{activityType}, 'activity', 'dynamic'), '_share')
         </if>
-        and t.org_id = #{orgId} group by t.share_person ) t
+        and t.org_id = #{orgId} ) t
         left join ta_person a on t.share_person = a.person_id
         left join ta_person b on t.share_person = b.user_id
         ) as visitNum on visitNum.person_id = person.person_id
         left join ta_person a on t.share_person = a.person_id
         left join ta_person b on t.share_person = b.user_id
         ) as visitPersonNum on visitPersonNum.person_id = person.person_id
+        group by person.person_id
         <if test="colKey == null or colKey == ''">
             order by person.create_date desc
         </if>
         <if test="activityType != null and activityType != ''">
             and t.target_type = concat(REPLACE(#{activityType}, 'activity', 'dynamic'), '_share')
         </if>
-        and t.org_id = #{orgId} group by t.share_person ) t
+        and t.org_id = #{orgId} ) t
         left join ta_person a on t.share_person = a.person_id
         left join ta_person b on t.share_person = b.user_id
         ) as visitNum on visitNum.person_id = person.person_id
         left join ta_person a on t.share_person = a.person_id
         left join ta_person b on t.share_person = b.user_id
         ) as visitPersonNum on visitPersonNum.person_id = person.person_id
+        group by person.person_id
         <if test="colKey == null or colKey == ''">
             order by person.create_date desc
         </if>
         a.nickname, a.phone,
         if(a.gender = '1', '男', if(a.gender = '2', '女','未知') ) as gender,
         a.province,
-        b1.scene_name as personFrom,
+        b1.scene_alias as personFrom,
         GROUP_CONCAT(c.name) as realtyConsultant,
         ifnull(d.phone, d.tel) as realtyConsultantPhone,
         ifnull(e.nickname, f.user_name) as sharePersonName,
         ifnull(e.phone, e.tel) as sharePersonPhone
         FROM ta_share_person_from t
         left join ta_person a on t.person_id = a.person_id
-        left join ta_person_from_record b on a.person_id = b.person_id and b.org_id = 84 and b.is_first_time =1
+        left join ta_person_from_record b on a.person_id = b.person_id and b.org_id = #{orgId} and b.is_first_time =1
         left join td_wx_dict b1 on b.scene_id = b1.scene_id
         left join ta_recommend_customer c on c.person_id = t.person_id
         left join ta_person d on c.recommend_person = d.person_id
         <if test="activityType != null and activityType != ''">
             and t.target_type = concat(#{activityType}, '_share')
         </if>
+        <if test="province != null and province != ''">
+            and a.province like concat('%', #{province}, '%')
+        </if>
         <if test="personFrom != null and personFrom != ''">
             and b.scene_type = #{personFrom}
         </if>
         a.nickname, a.phone,
         if(a.gender = '1', '男', if(a.gender = '2', '女','未知') ) as gender,
         a.province,
-        b1.scene_name as personFrom,
+        b1.scene_alias as personFrom,
         GROUP_CONCAT(c.name) as realtyConsultant,
         ifnull(d.phone, d.tel) as realtyConsultantPhone,
         ifnull(e.nickname, f.user_name) as sharePersonName,
         ifnull(e.phone, e.tel) as sharePersonPhone
         FROM ta_share_person_from t
         left join ta_person a on t.person_id = a.person_id
-        left join ta_person_from_record b on a.person_id = b.person_id and b.org_id = 84 and b.is_first_time =1
+        left join ta_person_from_record b on a.person_id = b.person_id and b.org_id = #{orgId} and b.is_first_time =1
         left join td_wx_dict b1 on b.scene_id = b1.scene_id
         left join ta_recommend_customer c on c.person_id = t.person_id
         left join ta_person d on c.recommend_person = d.person_id
         <if test="activityType != null and activityType != ''">
             and t.target_type = concat(#{activityType}, '_share')
         </if>
+        <if test="province != null and province != ''">
+            and a.province like concat('%', #{province}, '%')
+        </if>
         <if test="personFrom != null and personFrom != ''">
             and b.scene_type = #{personFrom}
         </if>