活动分享接口

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

@@ -11,6 +11,7 @@ import com.huiju.estateagents.common.JWTUtils;
 import com.huiju.estateagents.common.StringUtils;
 import com.huiju.estateagents.entity.*;
 import com.huiju.estateagents.service.*;
+import org.apache.commons.collections.map.HashedMap;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -20,6 +21,7 @@ import javax.servlet.http.HttpServletRequest;
 import java.time.LocalDateTime;
 import java.time.ZoneOffset;
 import java.util.List;
+import java.util.Map;
 
 
 /**
@@ -291,4 +293,44 @@ public class TaPersonVisitRecordController extends BaseController {
             return ResponseBean.error(e.getMessage(),ResponseBean.ERROR_UNAVAILABLE);
         }
     }
+
+    /**
+     * 置业顾问分享项目、活动、资讯、助力、拼团信息
+     * @param pageNumber
+     * @param pageSize
+     * @param userId
+     * @param request
+     * @return
+     */
+    @RequestMapping(value = "/wx/shareRecords")
+    public ResponseBean wxShareRecordsByUserId(@RequestParam(value ="pageNumber",defaultValue = "1") Integer pageNumber,
+                                              @RequestParam(value ="pageSize",defaultValue = "10") Integer pageSize,
+                                              @RequestParam(value = "userId") Integer userId,
+                                              HttpServletRequest request){
+        ResponseBean responseBean = new ResponseBean();
+        if (userId == null){
+            return responseBean;
+        }
+        //使用分页插件
+        IPage<TaConsultantInfo> pg = new Page<>(pageNumber, pageSize);
+        IPage<TaConsultantInfo> result = iTaPersonVisitRecordService.getConsultantShareInfoList(pg, userId, 26);
+
+        List<TaConsultantInfo> taConsultantInfos = result.getRecords();
+        taConsultantInfos.forEach(e ->{
+            Integer activityNum = iTaPersonVisitRecordService.countShareNumByEventType(e.getTargetId(), getOrgId(request), userId, CommConstant.POSTER_CONTENT_TYPE_ACTIVITY);
+            e.setActivityShareNum(activityNum);
+            Integer helpActivityNum = iTaPersonVisitRecordService.countShareNumByEventType(e.getTargetId(), getOrgId(request), userId, CommConstant.POINTS_CHANGE_HELP);
+            e.setHelpActivityShareNum(helpActivityNum);
+            Integer groupActivityNum = iTaPersonVisitRecordService.countShareNumByEventType(e.getTargetId(), getOrgId(request), userId, CommConstant.POINTS_CHANGE_GROUP);
+            e.setGroupActivityShareNum(groupActivityNum);
+            Integer newsNum = iTaPersonVisitRecordService.countShareNumByEventType(e.getTargetId(), getOrgId(request), userId, CommConstant.CAROUSEL_NEWS);
+            e.setNewsNum(newsNum);
+            Integer buildingNum = iTaPersonVisitRecordService.countShareNumByEventType(e.getTargetId(), getOrgId(request), userId, CommConstant.POSTER_CONTENT_TYPE_BUILDING);
+            e.setBuildingNum(buildingNum);
+            Integer drainageNum = iTaPersonVisitRecordService.countShareNumByEventType(e.getTargetId(), getOrgId(request), userId, CommConstant.TARGET_TYPE_H5);
+            e.setDrainageShareNum(drainageNum);
+        });
+        result.setRecords(taConsultantInfos);
+        return ResponseBean.success(result);
+    }
 }

src/main/java/com/huiju/estateagents/entity/TaConsultantInfo.java

@@ -0,0 +1,50 @@
+package com.huiju.estateagents.entity;
+
+import lombok.Data;
+
+@Data
+public class TaConsultantInfo {
+    private Integer targetId;
+
+    private String shareType;
+
+    private String buildingUrl;
+
+    private String buildingName;
+
+    private Integer buildingNum;
+
+    private String address;
+
+    private String price;
+
+    private String activityImg;
+
+    private String activityName;
+
+    private Integer activityShareNum;
+
+    private String helpActivityName;
+
+    private String helpActivityImg;
+
+    private Integer helpActivityShareNum;
+
+    private String groupActivityImg;
+
+    private String groupActivityName;
+
+    private Integer groupActivityShareNum;
+
+    private String newImg;
+
+    private String newName;
+
+    private Integer newsNum;
+
+    private String drainageImg;
+
+    private String drainageName;
+
+    private Integer drainageShareNum;
+}

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

@@ -3,6 +3,7 @@ package com.huiju.estateagents.mapper;
 
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.huiju.estateagents.entity.TaConsultantInfo;
 import com.huiju.estateagents.entity.TaPersonBuilding;
 import com.huiju.estateagents.entity.TaPersonVisitRecord;
 import org.apache.ibatis.annotations.Mapper;
@@ -74,4 +75,8 @@ public interface TaPersonVisitRecordMapper extends BaseMapper<TaPersonVisitRecor
     IPage<TaPersonVisitRecord> getWxVisitRecordList(IPage<TaPersonVisitRecord> pg, @Param("userId") Integer userId, @Param("orgId") Integer orgId, @Param("eventType") String eventType,@Param("personId") String personId);
 
     IPage<TaPersonVisitRecord> getWxVisitRecordActivityList(IPage<TaPersonVisitRecord> pg, @Param("userId") Integer userId,@Param("personId") String personId,@Param("orgId") Integer orgId,@Param("eventType") String eventType);
+
+    IPage<TaConsultantInfo> getConsultantShareInfoList(IPage<TaConsultantInfo> pg, @Param("userId") Integer userId, @Param("orgId") Integer orgId);
+
+    Integer countShareNumByEventType(@Param("targetId") Integer targetId, @Param("orgId")Integer orgId, @Param("userId")Integer userId, @Param("eventType")String eventType);
 }

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

@@ -3,9 +3,11 @@ package com.huiju.estateagents.service;
 
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.service.IService;
+import com.huiju.estateagents.entity.TaConsultantInfo;
 import com.huiju.estateagents.entity.TaPerson;
 import com.huiju.estateagents.entity.TaPersonBuilding;
 import com.huiju.estateagents.entity.TaPersonVisitRecord;
+import io.swagger.models.auth.In;
 
 import java.util.List;
 
@@ -48,4 +50,8 @@ public interface ITaPersonVisitRecordService extends IService<TaPersonVisitRecor
 //    TaPerson customerInfo(String personId);
 
 	IPage<TaPersonVisitRecord> getDrainageVisitRecord(IPage<TaPersonVisitRecord> pg, Integer orgId, String activityName, Integer drainageId, String shareName, String shareTel, List<TaPersonBuilding> taPersonBuildingList);
+
+	IPage<TaConsultantInfo> getConsultantShareInfoList(IPage<TaConsultantInfo> pg, Integer userId, Integer orgId);
+
+	Integer countShareNumByEventType(Integer targetId, Integer orgId, Integer userId, String eventType);
 }

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

@@ -138,6 +138,18 @@ public class TaPersonVisitRecordServiceImpl extends ServiceImpl<TaPersonVisitRec
 		taPersonVisitRecordIPage.setRecords(taPersonVisitRecords);
 		return taPersonVisitRecordIPage;
 	}
+
+	@Override
+	public IPage<TaConsultantInfo> getConsultantShareInfoList(IPage<TaConsultantInfo> pg, Integer userId, Integer orgId) {
+		IPage<TaConsultantInfo> result = personVisitRecordMapper.getConsultantShareInfoList(pg,userId,orgId);
+		return result;
+	}
+
+	@Override
+	public Integer countShareNumByEventType(Integer targetId, Integer orgId, Integer userId, String eventType) {
+		return personVisitRecordMapper.countShareNumByEventType(targetId, orgId, userId, eventType);
+	}
+
 	/**
 	 * 分页获取个人中心访客记录
 	 *

src/main/resources/mapper/TaPersonVisitRecordMapper.xml

@@ -160,4 +160,45 @@
         order by t.visit_time desc
     </select>
 
+    <select id="getConsultantShareInfoList" resultType="com.huiju.estateagents.entity.TaConsultantInfo">
+        select
+            t.event_type as share_type,
+            a.url as building_img,
+            a.building_name,
+            a.address,
+            a.price,
+            b.list_img_url as activity_img,
+            b.title as activity_name,
+            c.list_img as help_activity_img,
+            c.title as help_activity_name,
+            d.list_img as group_activity_img,
+            d.activity_name as group_activity_name,
+            e.news_img,
+            e.news_name,
+            f.share_img as drainage_img,
+            f.`name` as drainage_name
+        From ta_person_visit_record t
+        left join (select b.url, a.building_name,a.address,a.price,a.building_id from ta_building a left join ta_building_img b on a.building_id = b.building_id where b.img_type = 'list') a on t.target_id = a.building_id
+        left join ta_building_dynamic b on t.target_id = b.dynamic_id
+        left join ta_help_activity c on t.target_id = c.help_activity_id
+        left join ta_share_activity d on t.target_id = d.group_activity_id
+        left join ta_news e on t.target_id = e.news_id
+        left join ta_drainage f on t.target_id = f.drainage_id
+        where
+        t.consultant_id = #{userId}
+        and t.org_id = #{orgId}
+        and t.`event` = 'share'
+        order by t.visit_time desc
+    </select>
+    <select id="countShareNumByEventType" resultType="java.lang.Integer">
+        select count(1) from ta_person_visit_record t
+        where
+        t.consultant_id = #{userId}
+        and t.org_id = #{orgId}
+        and t.event_type = #{eventType}
+        and t.target_id = #{targetId}
+        and t.person_id != t.share_person_id
+        group by t.event_type, person_id
+    </select>
+
 </mapper>