From 4e77f9f2737310a8f35ecf8ed1a48e495b99aee2 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=91=A8=E9=B9=8F?= <812968653@qq.com> Date: Sat, 15 Aug 2026 08:36:33 +0800 Subject: [PATCH] 1111 --- .../mysql/interaction/MemberInteractionMapper.java | 5 ++++- .../interaction/MemberInteractionServiceImpl.java | 12 ++++++++++-- 2 files changed, 14 insertions(+), 3 deletions(-) diff --git a/yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/dal/mysql/interaction/MemberInteractionMapper.java b/yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/dal/mysql/interaction/MemberInteractionMapper.java index c59afe5..fd81b16 100644 --- a/yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/dal/mysql/interaction/MemberInteractionMapper.java +++ b/yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/dal/mysql/interaction/MemberInteractionMapper.java @@ -8,6 +8,8 @@ import cn.iocoder.yudao.module.member.dal.dataobject.interaction.MemberInteracti import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper; import org.apache.ibatis.annotations.Mapper; +import java.util.List; + @Mapper public interface MemberInteractionMapper extends BaseMapperX { @@ -24,10 +26,11 @@ public interface MemberInteractionMapper extends BaseMapperX() + List list = selectList(new LambdaQueryWrapperX() .eq(MemberInteractionDO::getReceiverId, receiverId) .orderByDesc(MemberInteractionDO::getId) .last("LIMIT 1")); + return list.isEmpty() ? null : list.get(0); } default int markAllRead(Long receiverId) { diff --git a/yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/service/interaction/MemberInteractionServiceImpl.java b/yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/service/interaction/MemberInteractionServiceImpl.java index b7cb5b2..8cc0205 100644 --- a/yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/service/interaction/MemberInteractionServiceImpl.java +++ b/yudao-module-member/yudao-module-member-biz/src/main/java/cn/iocoder/yudao/module/member/service/interaction/MemberInteractionServiceImpl.java @@ -1,6 +1,6 @@ package cn.iocoder.yudao.module.member.service.interaction; -import cn.hutool.core.collection.IterUtil; +import cn.hutool.core.collection.CollUtil; import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.StrUtil; import cn.iocoder.yudao.framework.common.pojo.PageParam; @@ -18,6 +18,7 @@ import org.springframework.validation.annotation.Validated; import javax.annotation.Resource; import java.util.Arrays; import java.util.Collections; +import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.stream.Collectors; @@ -87,7 +88,14 @@ public class MemberInteractionServiceImpl implements MemberInteractionService { } List actorIds = rows.stream().map(MemberInteractionDO::getActorId).distinct().collect(Collectors.toList()); List members = memberUserService.getUserExtList(actorIds); - Map memberMap = IterUtil.toMap(members, MemberExtBO::getMemberId); + Map memberMap = new HashMap<>(); + if (CollUtil.isNotEmpty(members)) { + for (MemberExtBO member : members) { + if (member != null && member.getMemberId() != null) { + memberMap.put(member.getMemberId(), member); + } + } + } return rows.stream().map(row -> { AppInteractionRespVO vo = new AppInteractionRespVO();