主题推荐算法重设计

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

@@ -178,7 +178,7 @@ public class ThemeManager {
         if (ThemeListTypeEnum.RECOMMEND.getCode().equals(req.getType())) {
             //推荐
             List<String> recommendThemeIds = recommendService.getRecommendThemes(req.getLastId(), req.getPageSize(), userId);
-            themeEntities = themeService.queryByThemeIdsExcludeUser(recommendThemeIds, null, req.getLastId(), req.getPageSize());
+            themeEntities = themeService.queryByThemeIds(recommendThemeIds);
             themeEntities = RankUtils.sortThemeEntityByIds(themeEntities, recommendThemeIds);
 
         } else if (ThemeListTypeEnum.FOLLOW.getCode().equals(req.getType())) {

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

@@ -67,8 +67,8 @@ public class RecommendService {
         List<String> result = new ArrayList<>();
         getResultList(hotThemeIds, 0, newThemeIds, 0, recThemeIds, 0, returnedIds, result, pageSize);
 
-
-        return result;
+        returnedIdsMap.put(userId,returnedIds);
+        return result.stream().limit(pageSize).collect(Collectors.toList());
     }
 
     public List<ThemeAnalysDO> getRecentThemeList() {

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

@@ -7,7 +7,6 @@ import com.tanpu.common.redis.RedisHelper;
 import com.tanpu.common.uuid.UuidGenHelper;
 import com.tanpu.community.api.enums.DeleteTagEnum;
 import com.tanpu.community.api.enums.ReportStatusEnum;
-import com.tanpu.community.cache.RedisCache;
 import com.tanpu.community.dao.entity.community.ThemeEntity;
 import com.tanpu.community.dao.mapper.community.ThemeMapper;
 import com.tanpu.community.util.TimeUtils;
@@ -19,14 +18,11 @@ import org.springframework.transaction.annotation.Transactional;
 
 import javax.annotation.Resource;
 import java.time.LocalDateTime;
-import java.util.Collection;
 import java.util.Collections;
 import java.util.List;
 import java.util.Set;
 import java.util.stream.Collectors;
 
-import static com.tanpu.community.api.constants.RedisKeyConstant.THEME_APPEAR_IN_SEARCH_LIST;
-
 @Service
 public class ThemeService {
 
@@ -200,6 +196,9 @@ public class ThemeService {
         return themeMapper.selectList(queryWrapper);
     }
 
+
+
+
     /**
      * 根据话题查询最新主题（可分页）
      *