feat(im)：优化已读上报、群详情缓存与 RTC 通话状态

- 已读上报增加本地读位置覆盖判断，避免切换会话和当前会话自动已读时重复调用 read 接口 - 标记会话已读时同步推进本地 read 游标并写入 IndexedDB，接口失败仅记录日志 - 缓存私聊对方 maxReadMessageId，并在状态补拉、回执更新和退出 IM 时维护缓存 - 增加群详情 infoLoaded 内存标记，减少切群时重复拉取群详情，手动刷新和关键通知仍强制刷新 - 同步 GROUP_INFO_UPDATE 的 joinApproval，避免群审批配置在前端缓存中陈旧 - 优化群通话胶囊条状态，记录 participantsLoaded，按需补齐参与者并在通话无人时移除胶囊 - RTC_CALL_START 生成群通话最小胶囊条，后续由参与者事件和 getActiveCall 补齐 - 退出 IM 时清理 RTC 状态和群通话缓存 - Vben antd/antd-next 调整媒体元素为函数 ref，修复 MediaStream 与元素挂载时序问题 - 修复 Vben 消息历史弹窗回调类型标注

feat(im)：优化已读上报、群详情缓存与 RTC 通话状态
- 已读上报增加本地读位置覆盖判断，避免切换会话和当前会话自动已读时重复调用 read 接口 - 标记会话已读时同步推进本地 read 游标并写入 IndexedDB，接口失败仅记录日志 - 缓存私聊对方 maxReadMessageId，并在状态补拉、回执更新和退出 IM 时维护缓存 - 增加群详情 infoLoaded 内存标记，减少切群时重复拉取群详情，手动刷新和关键通知仍强制刷新 - 同步 GROUP_INFO_UPDATE 的 joinApproval，避免群审批配置在前端缓存中陈旧 - 优化群通话胶囊条状态，记录 participantsLoaded，按需补齐参与者并在通话无人时移除胶囊 - RTC_CALL_START 生成群通话最小胶囊条，后续由参与者事件和 getActiveCall 补齐 - 退出 IM 时清理 RTC 状态和群通话缓存 - Vben antd/antd-next 调整媒体元素为函数 ref，修复 MediaStream 与元素挂载时序问题 - 修复 Vben 消息历史弹窗回调类型标注
YunaiV
1 parent 79de9233
Showing 4 changed files with 74 additions and 4 deletions
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/service/group/ImGroupServiceImpl.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/service/message/dto/ImGroupMessageSendDTO.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/service/websocket/notification/group/GroupInfoUpdateNotification.java
yudao-module-im/src/test/java/cn/iocoder/yudao/module/im/service/group/ImGroupServiceImplTest.java
@@ -149,7 +149,9 @@ public class ImGroupServiceImpl implements ImGroupService {
         boolean nameChanged = StrUtil.isNotEmpty(updateReqVO.getName());
         boolean noticeChanged = updateReqVO.getNotice() != null;
         boolean avatarChanged = StrUtil.isNotEmpty(updateReqVO.getAvatar());
-        if (nameChanged || noticeChanged || avatarChanged) {
+        boolean joinApprovalChanged = updateReqVO.getJoinApproval() != null
+                && ObjUtil.notEqual(group.getJoinApproval(), updateReqVO.getJoinApproval());
+        if (nameChanged || noticeChanged || avatarChanged || joinApprovalChanged) {
             List<Long> memberUserIds = groupMemberService.getActiveGroupMemberUserIdsByGroupId(groupId);
             if (nameChanged) {
                 groupMessageService.sendGroupMessage(userId, memberUserIds, ImGroupMessageSendDTO.ofGroupNameUpdate(
@@ -161,7 +163,11 @@ public class ImGroupServiceImpl implements ImGroupService {
             }
             if (avatarChanged) {
                 groupMessageService.sendGroupMessage(userId, memberUserIds, ImGroupMessageSendDTO.ofGroupInfoUpdate(
-                        groupId, userId, group.getAvatar(), updateReqVO.getAvatar()));
+                        groupId, userId, group.getAvatar(), updateReqVO.getAvatar(), null, null));
+            }
+            if (joinApprovalChanged) {
+                groupMessageService.sendGroupMessage(userId, memberUserIds, ImGroupMessageSendDTO.ofGroupInfoUpdate(
+                        groupId, userId, null, null, group.getJoinApproval(), updateReqVO.getJoinApproval()));
             }
         }
  
@@ -63,11 +63,15 @@ public class ImGroupMessageSendDTO {
                 .setType(ImContentTypeEnum.GROUP_CREATE.getType()).setContent(notification);
     }
  
-    public static ImGroupMessageSendDTO ofGroupInfoUpdate(Long groupId, Long operatorUserId, String oldAvatar, String newAvatar) {
+    public static ImGroupMessageSendDTO ofGroupInfoUpdate(Long groupId, Long operatorUserId,
+                                                          String oldAvatar, String newAvatar,
+                                                          Boolean oldJoinApproval, Boolean newJoinApproval) {
         GroupInfoUpdateNotification notification = new GroupInfoUpdateNotification();
         notification.setOperatorUserId(operatorUserId);
         notification.setOldAvatar(oldAvatar);
         notification.setNewAvatar(newAvatar);
+        notification.setOldJoinApproval(oldJoinApproval);
+        notification.setNewJoinApproval(newJoinApproval);
         return new ImGroupMessageSendDTO().setGroupId(groupId)
                 .setType(ImContentTypeEnum.GROUP_INFO_UPDATE.getType()).setContent(notification);
     }
@@ -3,7 +3,7 @@ package cn.iocoder.yudao.module.im.service.websocket.notification.group;
 import lombok.Data;
  
 /**
- * 群信息变更事件通知（当前承载头像变更，NAME / NOTICE 走独立事件）
+ * 群信息变更事件通知（NAME / NOTICE 走独立事件）
  */
 @Data
 public class GroupInfoUpdateNotification extends BaseGroupNotification {
@@ -16,5 +16,13 @@ public class GroupInfoUpdateNotification extends BaseGroupNotification {
      * 新群头像
      */
     private String newAvatar;
+    /**
+     * 旧进群审批开关
+     */
+    private Boolean oldJoinApproval;
+    /**
+     * 新进群审批开关
+     */
+    private Boolean newJoinApproval;
  
 }
@@ -209,6 +209,58 @@ public class ImGroupServiceImplTest extends BaseMockitoUnitTest {
         }
     }
  
+    @Test
+    public void testUpdateGroup_joinApprovalChanged() {
+        try (MockedStatic<SpringUtil> springUtilMockedStatic = mockStatic(SpringUtil.class)) {
+            springUtilMockedStatic.when(() -> SpringUtil.getBean(eq(ImGroupServiceImpl.class)))
+                    .thenReturn(groupService);
+
+            // 准备
+            ImGroupDO group = ImGroupDO.builder().id(10L).name("群").ownerUserId(1L)
+                    .joinApproval(false).status(CommonStatusEnum.ENABLE.getStatus()).build();
+            when(groupMapper.selectById(10L)).thenReturn(group);
+
+            ImGroupUpdateReqVO reqVO = new ImGroupUpdateReqVO();
+            reqVO.setId(10L);
+            reqVO.setJoinApproval(true);
+
+            // 调用
+            ImGroupDO result = groupService.updateGroup(reqVO, 1L);
+
+            // 断言
+            verify(groupMapper).updateById(any(ImGroupDO.class));
+            assertTrue(result.getJoinApproval());
+            ArgumentCaptor<ImGroupMessageSendDTO> dtoCaptor = ArgumentCaptor.forClass(ImGroupMessageSendDTO.class);
+            verify(groupMessageService).sendGroupMessage(eq(1L), anyCollection(), dtoCaptor.capture());
+            assertEquals(ImContentTypeEnum.GROUP_INFO_UPDATE.getType(), dtoCaptor.getValue().getType());
+        }
+    }
+
+    @Test
+    public void testUpdateGroup_joinApprovalSame() {
+        try (MockedStatic<SpringUtil> springUtilMockedStatic = mockStatic(SpringUtil.class)) {
+            springUtilMockedStatic.when(() -> SpringUtil.getBean(eq(ImGroupServiceImpl.class)))
+                    .thenReturn(groupService);
+
+            // 准备
+            ImGroupDO group = ImGroupDO.builder().id(10L).name("群").ownerUserId(1L)
+                    .joinApproval(true).status(CommonStatusEnum.ENABLE.getStatus()).build();
+            when(groupMapper.selectById(10L)).thenReturn(group);
+
+            ImGroupUpdateReqVO reqVO = new ImGroupUpdateReqVO();
+            reqVO.setId(10L);
+            reqVO.setJoinApproval(true);
+
+            // 调用
+            ImGroupDO result = groupService.updateGroup(reqVO, 1L);
+
+            // 断言
+            verify(groupMapper).updateById(any(ImGroupDO.class));
+            assertTrue(result.getJoinApproval());
+            verify(groupMessageService, never()).sendGroupMessage(anyLong(), anyCollection(), any());
+        }
+    }
+
     // ========== dissolveGroup ==========
  
     @Test