diff --git a/km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/impl/GroupServiceImpl.java b/km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/impl/GroupServiceImpl.java index 184ea1dd..da12bf95 100644 --- a/km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/impl/GroupServiceImpl.java +++ b/km-core/src/main/java/com/xiaojukeji/know/streaming/km/core/service/group/impl/GroupServiceImpl.java @@ -151,12 +151,12 @@ public class GroupServiceImpl extends BaseVersionControlService implements Group lambdaQueryWrapper.eq(GroupMemberPO::getClusterPhyId, clusterPhyId); lambdaQueryWrapper.eq(!ValidateUtils.isBlank(topicName), GroupMemberPO::getTopicName, topicName); lambdaQueryWrapper.eq(!ValidateUtils.isBlank(groupName), GroupMemberPO::getGroupName, groupName); - lambdaQueryWrapper.eq(GroupMemberPO::getClusterPhyId, clusterPhyId); lambdaQueryWrapper.like(!ValidateUtils.isBlank(searchTopicKeyword), GroupMemberPO::getTopicName, searchTopicKeyword); lambdaQueryWrapper.like(!ValidateUtils.isBlank(searchGroupKeyword), GroupMemberPO::getGroupName, searchGroupKeyword); + lambdaQueryWrapper.orderByDesc(GroupMemberPO::getClusterPhyId, GroupMemberPO::getTopicName); IPage iPage = new Page<>(); - iPage.setPages(dto.getPageNo()); + iPage.setCurrent(dto.getPageNo()); iPage.setSize(dto.getPageSize()); iPage = groupMemberDAO.selectPage(iPage, lambdaQueryWrapper);