diff --git a/im-platform/src/main/java/com/bx/implatform/service/impl/GroupMessageServiceImpl.java b/im-platform/src/main/java/com/bx/implatform/service/impl/GroupMessageServiceImpl.java index a47dfba..e3ecbaa 100644 --- a/im-platform/src/main/java/com/bx/implatform/service/impl/GroupMessageServiceImpl.java +++ b/im-platform/src/main/java/com/bx/implatform/service/impl/GroupMessageServiceImpl.java @@ -1,7 +1,7 @@ package com.bx.implatform.service.impl; -import cn.hutool.core.collection.CollUtil; -import cn.hutool.core.text.CharSequenceUtil; +import cn.hutool.core.collection.CollectionUtil; +import cn.hutool.core.util.StrUtil; import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.toolkit.Wrappers; @@ -73,8 +73,8 @@ public class GroupMessageServiceImpl extends ServiceImpl members = groupMemberService.findByUserId(session.getUserId()); List ids = members.stream().map(GroupMember::getGroupId).collect(Collectors.toList()); - if (CollUtil.isEmpty(ids)) { + if (CollectionUtil.isEmpty(ids)) { return new ArrayList<>(); } // 只能拉取最近1个月的 @@ -158,7 +158,6 @@ public class GroupMessageServiceImpl extends ServiceImpl messages = this.list(wrapper); // 转成vo List vos = messages.stream().map(m -> { - m.setContent(sensitiveFilterUtil.filter(m.getContent())); GroupMessageVO vo = BeanUtils.copyProperties(m, GroupMessageVO.class); // 被@用户列表 if (StringUtils.isNotBlank(m.getAtUserIds())) { @@ -212,7 +211,7 @@ public class GroupMessageServiceImpl extends ServiceImpl messages = this.list(wrapper); List messageInfos = - messages.stream().map(m -> { - m.setContent(sensitiveFilterUtil.filter(m.getContent())); - return BeanUtils.copyProperties(m, GroupMessageVO.class); - }).collect(Collectors.toList()); + messages.stream().map(m -> BeanUtils.copyProperties(m, GroupMessageVO.class)).collect(Collectors.toList()); log.info("拉取群聊记录,用户id:{},群聊id:{},数量:{}", userId, groupId, messageInfos.size()); return messageInfos; } diff --git a/im-platform/src/main/java/com/bx/implatform/service/impl/PrivateMessageServiceImpl.java b/im-platform/src/main/java/com/bx/implatform/service/impl/PrivateMessageServiceImpl.java index 8c2cfa6..01a2fd8 100644 --- a/im-platform/src/main/java/com/bx/implatform/service/impl/PrivateMessageServiceImpl.java +++ b/im-platform/src/main/java/com/bx/implatform/service/impl/PrivateMessageServiceImpl.java @@ -74,7 +74,7 @@ public class PrivateMessageServiceImpl extends ServiceImpl messages = this.list(wrapper); - List messageInfos = messages.stream().map(m -> { - m.setContent(sensitiveFilterUtil.filter(m.getContent())); - return BeanUtils.copyProperties(m, PrivateMessageVO.class); - }).collect(Collectors.toList()); + List messageInfos = messages.stream().map(m -> BeanUtils.copyProperties(m, PrivateMessageVO.class)).collect(Collectors.toList()); log.info("拉取聊天记录,用户id:{},好友id:{},数量:{}", userId, friendId, messageInfos.size()); return messageInfos; } @@ -171,10 +168,7 @@ public class PrivateMessageServiceImpl extends ServiceImpl { - m.setContent(sensitiveFilterUtil.filter(m.getContent())); - return BeanUtils.copyProperties(m, PrivateMessageVO.class); - }).collect(Collectors.toList()); + return messages.stream().map(m -> BeanUtils.copyProperties(m, PrivateMessageVO.class)).collect(Collectors.toList()); } diff --git a/im-platform/src/main/java/com/bx/implatform/util/SensitiveFilterUtil.java b/im-platform/src/main/java/com/bx/implatform/util/SensitiveFilterUtil.java index 66377b4..78158c2 100644 --- a/im-platform/src/main/java/com/bx/implatform/util/SensitiveFilterUtil.java +++ b/im-platform/src/main/java/com/bx/implatform/util/SensitiveFilterUtil.java @@ -1,5 +1,6 @@ package com.bx.implatform.util; +import lombok.NoArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.CharUtils; import org.apache.commons.lang3.StringUtils; @@ -22,11 +23,9 @@ import java.util.Map; */ @Slf4j @Component +@NoArgsConstructor public final class SensitiveFilterUtil { - private SensitiveFilterUtil() { - } - /** * 替换符 */