♻️ refactor(im)：好友模块清理——删 ImFriendServiceImpl 无效的 getSelf 自代理 + Controller 回调参数命…

…名展开 + Consumer 补日志 + silent re-add 注释补充

♻️ refactor(im)：好友模块清理——删 ImFriendServiceImpl 无效的 getSelf 自代理 + Controller 回调参数命…
…名展开 + Consumer 补日志 + silent re-add 注释补充
YunaiV
1 parent b51ca455
Showing 4 changed files with 19 additions and 17 deletions
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/controller/admin/friend/ImFriendController.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/controller/admin/friend/ImFriendRequestController.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/mq/consumer/friend/AdminUserProfileUpdateConsumer.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/service/friend/ImFriendServiceImpl.java
@@ -100,9 +100,9 @@ public class ImFriendController {
         // 批量聚合 AdminUser 信息（昵称 / 头像），避免 N+1
         Map<Long, AdminUserRespDTO> userMap = adminUserApi.getUserMap(
                 convertList(friends, ImFriendDO::getFriendUserId));
-        return convertList(friends, f -> {
-            ImFriendRespVO vo = BeanUtils.toBean(f, ImFriendRespVO.class);
-            MapUtils.findAndThen(userMap, f.getFriendUserId(), user ->
+        return convertList(friends, friend -> {
+            ImFriendRespVO vo = BeanUtils.toBean(friend, ImFriendRespVO.class);
+            MapUtils.findAndThen(userMap, friend.getFriendUserId(), user ->
                     vo.setNickname(user.getNickname()).setAvatar(user.getAvatar()));
             // 备注 / 昵称的拼音，给前端做字母分桶 + 拼音搜索
             vo.setDisplayNamePinyin(StrUtils.toPinyin(vo.getDisplayName()))
@@ -87,13 +87,15 @@ public class ImFriendRequestController {
         if (CollUtil.isEmpty(list)) {
             return Collections.emptyList();
         }
-        Set<Long> userIds = convertSetByFlatMap(list, r -> Stream.of(r.getFromUserId(), r.getToUserId()));
+        // 双向 OR 列表，userIds 取 from + to 两组并集
+        Set<Long> userIds = convertSetByFlatMap(list,
+                request -> Stream.of(request.getFromUserId(), request.getToUserId()));
         Map<Long, AdminUserRespDTO> userMap = adminUserApi.getUserMap(userIds);
-        return convertList(list, r -> {
-            ImFriendRequestRespVO vo = BeanUtils.toBean(r, ImFriendRequestRespVO.class);
-            MapUtils.findAndThen(userMap, r.getFromUserId(), user ->
+        return convertList(list, request -> {
+            ImFriendRequestRespVO vo = BeanUtils.toBean(request, ImFriendRequestRespVO.class);
+            MapUtils.findAndThen(userMap, request.getFromUserId(), user ->
                     vo.setFromNickname(user.getNickname()).setFromAvatar(user.getAvatar()));
-            MapUtils.findAndThen(userMap, r.getToUserId(), user ->
+            MapUtils.findAndThen(userMap, request.getToUserId(), user ->
                     vo.setToNickname(user.getNickname()).setToAvatar(user.getAvatar()));
             return vo;
         });
@@ -33,6 +33,7 @@ public class AdminUserProfileUpdateConsumer {
     @EventListener
     @Async // Spring Event 默认在 Producer 发送的线程，通过 @Async 实现异步
     public void onMessage(AdminUserProfileUpdateMessage message) {
+        log.info("[onMessage][消息内容({})]", message);
         Long userId = message.getUserId();
         // 1. 找当前用户的所有有效好友（DISABLE 已删的不推）
         List<ImFriendDO> friends = friendService.getFriendList(userId);
@@ -41,6 +42,7 @@ public class AdminUserProfileUpdateConsumer {
         }
         // 2. 给每个好友的多端推 FRIEND_INFO_UPDATED；payload 里 operatorUserId / friendUserId 都是「资料被改的人」
+        int notifyCount = 0;
         for (ImFriendDO friend : friends) {
             if (CommonStatusEnum.isDisable(friend.getStatus())) {
                 continue;
@@ -49,7 +51,9 @@ public class AdminUserProfileUpdateConsumer {
                     .setOperatorUserId(userId).setFriendUserId(userId);
             websocketService.sendPrivateMessageAsync(friend.getFriendUserId(), ImPrivateMessageDTO.ofFriendNotification(
                     ImMessageTypeEnum.FRIEND_INFO_UPDATED.getType(), userId, friend.getFriendUserId(), payload));
+            notifyCount++;
         }
+        log.info("[onMessage][userId({}) 推送 FRIEND_INFO_UPDATED 给 {} 位好友]", userId, notifyCount);
     }
 }
 package cn.iocoder.yudao.module.im.service.friend;
 import cn.hutool.core.util.BooleanUtil;
-import cn.hutool.extra.spring.SpringUtil;
 import cn.iocoder.yudao.framework.common.enums.CommonStatusEnum;
 import cn.iocoder.yudao.framework.common.pojo.PageResult;
 import cn.iocoder.yudao.module.im.controller.admin.friend.vo.ImFriendUpdateReqVO;
@@ -124,8 +123,8 @@ public class ImFriendServiceImpl implements ImFriendService {
         Long toUserId = request.getToUserId();
         // 1. 双向建立关系：A 侧带申请的 displayName / addSource；B 侧 displayName 为空、addSource 同来源
         //    FRIEND_STATE 双向失效由方法上的 @Caching 注解处理；framework 已开 transactionAware 自动延迟到 afterCommit
-        getSelf().addFriend0(fromUserId, toUserId, request.getDisplayName(), request.getAddSource());
-        getSelf().addFriend0(toUserId, fromUserId, null, request.getAddSource());
+        addFriend0(fromUserId, toUserId, request.getDisplayName(), request.getAddSource());
+        addFriend0(toUserId, fromUserId, null, request.getAddSource());
         // 2.1 推 TIP 系统消息（双方私聊会话里看到「你们已成为好友」）；TIP 走会话入库，FRIEND_ADD 走事件通知
         privateMessageService.sendTipPrivateMessage(fromUserId, toUserId, FRIEND_ADD_TIP_MESSAGE);
@@ -150,7 +149,8 @@ public class ImFriendServiceImpl implements ImFriendService {
     @Transactional(rollbackFor = Exception.class)
     public void silentReAddFriend(Long userId, Long friendUserId, String displayName, Integer addSource) {
         // 1. 单边重新启用我侧好友关系
-        getSelf().addFriend0(userId, friendUserId, displayName, addSource);
+        //    不推 TIP 系统消息：sendPrivateMessage 是 (sender, receiver) 单条入库 + 双向可见，无法仅 userId 单边可见；对方不应感知 silent 重启，TIP 整体省略
+        addFriend0(userId, friendUserId, displayName, addSource);
         // 2. 仅推 FRIEND_ADD 给 userId 多端（不通知对方，保持「对方一直把我当好友」的错觉）
         //    operatorUserId 填 friendUserId（对方）：让 userId 多端 UI 呈现「对方加了我」的视觉效果，与 silent 语义对齐
@@ -169,7 +169,7 @@ public class ImFriendServiceImpl implements ImFriendService {
     public void deleteFriend(Long userId, Long friendUserId) {
         // 1. 单边软删：仅 userId 视角的关系置 DISABLE；friendUserId 视角不动
         //    不推 TIP 系统消息：单边删除语义下对方不应感知；userId 端反馈由前端 toast 承担，多端同步靠下面的 FRIEND_DELETE
-        getSelf().deleteFriend0(userId, friendUserId);
+        deleteFriend0(userId, friendUserId);
         // 2. 推 FRIEND_DELETE 给 userId 多端做同步（friendUserId 不感知）
         FriendDeleteNotification payload = (FriendDeleteNotification) new FriendDeleteNotification()
@@ -287,8 +287,4 @@ public class ImFriendServiceImpl implements ImFriendService {
         return friendMapper.selectPage(reqVO);
     }
-    private ImFriendServiceImpl getSelf() {
-        return SpringUtil.getBean(getClass());
-    }
-
 }