添加圈子支持

community-service/src/main/java/com/tanpu/community/dao/mapper/community/VisitLogMapper.java

@@ -21,8 +21,8 @@ import java.util.List;
  * @since 2021-07-28
  */
 public interface VisitLogMapper extends BaseMapper<VisitLogEntity> {
-    @Select("select * from visit_log where ident=#{ident}")
-    VisitLogEntity selectByIdent(@Param("ident") String ident);
+    @Select("select * from visit_log where ident=#{ident} and ref_id=#{refId}")
+    VisitLogEntity selectByIdentAndRefId(@Param("ident") String ident, @Param("refId") String refId);
 
     @Update("update visit_log set duration=duration+#{duration} where ident=#{ident}")
     void updateDurByIdent(@Param("duration") Integer dur, @Param("ident") String ident);

community-service/src/main/java/com/tanpu/community/manager/VisitSummaryManager.java

 package com.tanpu.community.manager;
 
 import com.alibaba.fastjson.JSON;
+import com.tanpu.biz.common.enums.clue.PageEnum;
 import com.tanpu.community.api.beans.vo.KafkaDurationUptMsg;
 import com.tanpu.community.dao.entity.community.VisitLogEntity;
 import com.tanpu.community.service.VisitLogService;
@@ -11,6 +12,9 @@ import org.springframework.kafka.annotation.KafkaListener;
 import org.springframework.kafka.core.KafkaTemplate;
 import org.springframework.stereotype.Service;
 
+import java.util.Arrays;
+import java.util.List;
+
 @Slf4j
 @Service
 public class VisitSummaryManager {
@@ -24,11 +28,16 @@ public class VisitSummaryManager {
     private VisitLogService visitLogService;
 
 
+    List<String> PAGEID_NEED_SAVE = Arrays.asList(PageEnum.COMM_VISIT_HOME_PAGE.getId(), PageEnum.COMM_VISIT_THEME.getId());
     @KafkaListener(topics = kafakTopic)
     public void updateVisitSummary(String message) {
         // {"durMillsInc":10000,"ident":"AD7B8CE8-2DA4-4FB4-907F-C551B926BA5C","localDate":"2021-08-02","pageId":"p13503","refId":"88737580570230824","visitorId":"275321532031467520"}
         log.info("receive kafka msg: {}", message);
         KafkaDurationUptMsg msg = JSON.parseObject(message, KafkaDurationUptMsg.class);
+        // 做一个筛选
+        if (!PAGEID_NEED_SAVE.contains(msg.pageId)) {
+            return;
+        }
         // ident在每次进入新页面 & 回退 的时候都会随机生成一个，所以用ident做唯一key即可。
         VisitLogEntity vs = ConvertUtil.convertFromKafka(msg);
         visitLogService.insertOrUpdateDur(vs);

community-service/src/main/java/com/tanpu/community/service/VisitLogService.java

@@ -58,7 +58,7 @@ public class VisitLogService {
 
     @Transactional
     public void insertOrUpdateDur(VisitLogEntity vs) {
-        if (visitLogMapper.selectByIdent(vs.getIdent()) == null) {
+        if (visitLogMapper.selectByIdentAndRefId(vs.getIdent(), vs.getRefId()) == null) {
             visitLogMapper.insert(vs);
         } else {
             visitLogMapper.updateDurByIdent(vs.getDuration(), vs.getIdent());