topdog/supersonic
1
0
Fork 0
mirror of https://github.com/tencentmusic/supersonic.git synced 2025-12-12 04:27:39 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

[fix][chat]修复对话丢失问题 (#1539)

Browse Source
This commit is contained in:
yudong
2024-08-08 18:05:38 +08:00
committed by GitHub
parent cdb67650c5
commit 1608317ab3
1 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
chat/server/src/main/java/com/tencent/supersonic/chat/server/persistence/repository/impl/ChatQueryRepositoryImpl.java
View File

@@ -61,7 +61,8 @@ public class ChatQueryRepositoryImpl implements ChatQueryRepository {
if (!CollectionUtils.isEmpty(pageQueryInfoReq.getIds())) { if (!CollectionUtils.isEmpty(pageQueryInfoReq.getIds())) {
queryWrapper.lambda().in(ChatQueryDO::getQuestionId, pageQueryInfoReq.getIds()); queryWrapper.lambda().in(ChatQueryDO::getQuestionId, pageQueryInfoReq.getIds());
} }
queryWrapper.lambda().isNotNull(ChatQueryDO::getQueryResult);
queryWrapper.lambda().ne(ChatQueryDO::getQueryResult, "");
queryWrapper.lambda().orderByDesc(ChatQueryDO::getQuestionId); queryWrapper.lambda().orderByDesc(ChatQueryDO::getQuestionId);
PageInfo<ChatQueryDO> pageInfo = PageHelper.startPage(pageQueryInfoReq.getCurrent(), PageInfo<ChatQueryDO> pageInfo = PageHelper.startPage(pageQueryInfoReq.getCurrent(),
@@ -70,8 +71,9 @@ public class ChatQueryRepositoryImpl implements ChatQueryRepository {
PageInfo<QueryResp> chatQueryVOPageInfo = PageUtils.pageInfo2PageInfoVo(pageInfo); PageInfo<QueryResp> chatQueryVOPageInfo = PageUtils.pageInfo2PageInfoVo(pageInfo);
chatQueryVOPageInfo.setList( chatQueryVOPageInfo.setList(
pageInfo.getList().stream().filter(o -> !StringUtils.isEmpty(o.getQueryResult())).map(this::convertTo) pageInfo.getList().stream()
.sorted(Comparator.comparingInt(o -> o.getQuestionId().intValue())) .sorted(Comparator.comparingInt(o -> o.getQuestionId().intValue()))
.map(this::convertTo)
.collect(Collectors.toList())); .collect(Collectors.toList()));
return chatQueryVOPageInfo; return chatQueryVOPageInfo;
} }