关注更新条数

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

@@ -129,7 +129,7 @@ public class ThemeManager {
 
     public List<ThemeQo> searchThemes(ThemeSearchReq req, String userId) {
 
-        List<ThemeEntity> themeEntities= themeService.selectExcludeUser(userId,req.getLastId(), req.getPageSize());
+        List<ThemeEntity> themeEntities= themeService.search(req.getKeyword(),req.getLastId(), req.getPageSize());
         return convertEntityToQo(themeEntities, userId);
     }
 

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

@@ -174,6 +174,31 @@ public class ThemeService {
 
     }
 
+    /**
+     * 根据关键字搜索
+     * @param keyword
+     * @param lastId
+     * @param pageSize
+     * @return
+     */
+    public List<ThemeEntity> search(String keyword, String lastId, Integer pageSize) {
+        if (StringUtils.isEmpty(keyword)){
+            return Collections.emptyList();
+        }
+        LambdaQueryWrapper<ThemeEntity> queryWrapper = new LambdaQueryWrapper<ThemeEntity>()
+                .like(ThemeEntity::getTitle, keyword);
+        if (StringUtils.isNotEmpty(lastId)) {
+            ThemeEntity lastEntity = queryByThemeId(lastId);
+            if (lastEntity == null) throw new BizException("主题未找到，id：" + lastId);
+            queryWrapper.lt(ThemeEntity::getUpdateTime, lastEntity.getCreateTime());
+        }
+        queryWrapper.last("limit " + pageSize);
+        queryWrapper.orderByDesc(ThemeEntity::getCreateTime);
+        queryWrapper.eq(ThemeEntity::getDeleteTag, DeleteTagEnum.NOT_DELETED.getCode());
+        return themeMapper.selectList(queryWrapper);
+
+    }
+
 
     //查询对应话题的发表用户集合
     public Set<String> getPostUserCount(List<String> themeIds) {
@@ -224,4 +249,6 @@ public class ThemeService {
         }
         return themeMapper.selectCount(queryWrapper);
     }
+
+
 }