diff --git a/chat/server/src/main/java/com/tencent/supersonic/chat/server/persistence/repository/impl/ChatQueryRepositoryImpl.java b/chat/server/src/main/java/com/tencent/supersonic/chat/server/persistence/repository/impl/ChatQueryRepositoryImpl.java index 2f481197a..85e350bd5 100644 --- a/chat/server/src/main/java/com/tencent/supersonic/chat/server/persistence/repository/impl/ChatQueryRepositoryImpl.java +++ b/chat/server/src/main/java/com/tencent/supersonic/chat/server/persistence/repository/impl/ChatQueryRepositoryImpl.java @@ -61,7 +61,8 @@ public class ChatQueryRepositoryImpl implements ChatQueryRepository { if (!CollectionUtils.isEmpty(pageQueryInfoReq.getIds())) { queryWrapper.lambda().in(ChatQueryDO::getQuestionId, pageQueryInfoReq.getIds()); } - + queryWrapper.lambda().isNotNull(ChatQueryDO::getQueryResult); + queryWrapper.lambda().ne(ChatQueryDO::getQueryResult, ""); queryWrapper.lambda().orderByDesc(ChatQueryDO::getQuestionId); PageInfo pageInfo = PageHelper.startPage(pageQueryInfoReq.getCurrent(), @@ -70,8 +71,9 @@ public class ChatQueryRepositoryImpl implements ChatQueryRepository { PageInfo chatQueryVOPageInfo = PageUtils.pageInfo2PageInfoVo(pageInfo); chatQueryVOPageInfo.setList( - pageInfo.getList().stream().filter(o -> !StringUtils.isEmpty(o.getQueryResult())).map(this::convertTo) + pageInfo.getList().stream() .sorted(Comparator.comparingInt(o -> o.getQuestionId().intValue())) + .map(this::convertTo) .collect(Collectors.toList())); return chatQueryVOPageInfo; }