lcj/xinnengyuan
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

09-12-netty优化

Browse Source
This commit is contained in:
青云
2025-09-12 19:15:00 +08:00
parent 9afda7305c
commit d77e12ee4e
1 changed files with 16 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
xinnengyuan/ruoyi-modules/ruoyi-system/src/main/java/org/dromara/websocket/controller/ChatGroupController.java
View File

@ -96,18 +96,29 @@ public class ChatGroupController {
*/
// @SaCheckPermission("chatGroup:list:getList")
@GetMapping("/list")
public R<List<ChatGroup>> listChatGroup() {
public R<List<ChatGroup>> listChatGroup(ChatGroup searchObject,PageQuery pageQuery) {
Long userId = LoginHelper.getLoginUser().getUserId();
LambdaQueryWrapper<ChatGroup> queryWrapper = new LambdaQueryWrapper<>();
//无论单群聊 群聊 成员都会有自己
queryWrapper.like(ChatGroup::getMembers,userId+",").or().like(ChatGroup::getMembers,userId+"]");//.eq(ChatGroup::getOwerId,userId).or()
// queryWrapper.like(searchObject.getName() != null && !searchObject.getName().isEmpty(),ChatGroup::getName,searchObject.getName());
//按最后聊天时间排序
queryWrapper.orderByDesc(ChatGroup::getLastMessageTime);
List<ChatGroup> list = chatGroupService.list(queryWrapper);
List<ChatGroup> list = chatGroupService.page(pageQuery.build(),queryWrapper).getRecords();
List<ChatGroup> searchTemp = new ArrayList<>();
if (!list.isEmpty()) {
for (ChatGroup chatGroup : list) {
setValue(chatGroup,userId);
setValue(chatGroup, userId);
if (!searchObject.getName().isEmpty()) {
if (chatGroup.getName().contains(searchObject.getName())) {
searchTemp.add(chatGroup);
}
return R.ok(list);
} else {
searchTemp.add(chatGroup);
}
}
}
return R.ok(searchTemp);
}
/**