fix(im)：加固管理端入参和统计边界

- 校验敏感词、表情包、表情项状态枚举和批量删除数量上限 - 限制私聊、群聊增量拉取 size 最小值 - 收紧表情包项 Mapper 的 in 查询并在 Service 层处理空好友集合 - 兼容统计聚合数值类型并明确当前有效群总数口径 - 固定 LiveKit token 签名编码和 IM web 包说明 - 修正群禁言权限错误码顺序并补充封禁、踢人、禁言回归测试 - 流转 IM bug 文档并记录本轮不修项语义

fix(im)：加固管理端入参和统计边界
- 校验敏感词、表情包、表情项状态枚举和批量删除数量上限 - 限制私聊、群聊增量拉取 size 最小值 - 收紧表情包项 Mapper 的 in 查询并在 Service 层处理空好友集合 - 兼容统计聚合数值类型并明确当前有效群总数口径 - 固定 LiveKit token 签名编码和 IM web 包说明 - 修正群禁言权限错误码顺序并补充封禁、踢人、禁言回归测试 - 流转 IM bug 文档并记录本轮不修项语义
YunaiV
1 parent bb9a2b53
Showing 21 changed files with 147 additions and 31 deletions
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/controller/admin/manager/face/ImFacePackItemManagerController.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/controller/admin/manager/face/ImFacePackManagerController.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/controller/admin/manager/face/vo/item/ImFacePackItemPageReqVO.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/controller/admin/manager/face/vo/item/ImFacePackItemSaveReqVO.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/controller/admin/manager/face/vo/pack/ImFacePackPageReqVO.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/controller/admin/manager/face/vo/pack/ImFacePackSaveReqVO.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/controller/admin/manager/sensitiveword/ImSensitiveWordManagerController.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/controller/admin/manager/sensitiveword/vo/ImSensitiveWordPageReqVO.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/controller/admin/manager/sensitiveword/vo/ImSensitiveWordSaveReqVO.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/controller/admin/message/ImGroupMessageController.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/controller/admin/message/ImPrivateMessageController.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/dal/mysql/face/ImFacePackItemMapper.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/dal/mysql/statistics/ImStatisticsManagerMapper.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/framework/rtc/core/LiveKitClient.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/framework/web/package-info.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/service/friend/ImFriendServiceImpl.java
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/statistics/ImStatisticsManagerServiceImpl.java
yudao-module-im/src/test/java/cn/iocoder/yudao/module/im/service/friend/ImFriendServiceImplTest.java
yudao-module-im/src/test/java/cn/iocoder/yudao/module/im/service/group/ImGroupServiceImplTest.java
@@ -13,6 +13,7 @@ import io.swagger.v3.oas.annotations.Parameter;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import jakarta.annotation.Resource;
 import jakarta.validation.Valid;
+import jakarta.validation.constraints.Size;
 import org.springframework.security.access.prepost.PreAuthorize;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
@@ -58,7 +59,8 @@ public class ImFacePackItemManagerController {
     @Operation(summary = "批量删除表情")
     @Parameter(name = "ids", description = "编号列表", required = true)
     @PreAuthorize("@ss.hasPermission('im:manager:face-pack-item:delete')")
-    public CommonResult<Boolean> deleteFacePackItemList(@RequestParam("ids") List<Long> ids) {
+    public CommonResult<Boolean> deleteFacePackItemList(@RequestParam("ids")
+                                                        @Size(max = 100, message = "批量删除最多 100 条") List<Long> ids) {
         facePackItemService.deleteFacePackItemList(ids);
         return success(true);
     }
@@ -13,6 +13,7 @@ import io.swagger.v3.oas.annotations.Parameter;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import jakarta.annotation.Resource;
 import jakarta.validation.Valid;
+import jakarta.validation.constraints.Size;
 import org.springframework.security.access.prepost.PreAuthorize;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
@@ -58,7 +59,8 @@ public class ImFacePackManagerController {
     @Operation(summary = "批量删除表情包")
     @Parameter(name = "ids", description = "编号列表", required = true)
     @PreAuthorize("@ss.hasPermission('im:manager:face-pack:delete')")
-    public CommonResult<Boolean> deleteFacePackList(@RequestParam("ids") List<Long> ids) {
+    public CommonResult<Boolean> deleteFacePackList(@RequestParam("ids")
+                                                    @Size(max = 100, message = "批量删除最多 100 条") List<Long> ids) {
         facePackService.deleteFacePackList(ids);
         return success(true);
     }
 package cn.iocoder.yudao.module.im.controller.admin.manager.face.vo.item;
  
+import cn.iocoder.yudao.framework.common.enums.CommonStatusEnum;
 import cn.iocoder.yudao.framework.common.pojo.PageParam;
+import cn.iocoder.yudao.framework.common.validation.InEnum;
 import io.swagger.v3.oas.annotations.media.Schema;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
@@ -17,6 +19,7 @@ public class ImFacePackItemPageReqVO extends PageParam {
     private String name;
  
     @Schema(description = "状态", example = "0")
+    @InEnum(value = CommonStatusEnum.class, message = "状态必须是 {value}")
     private Integer status; // 参见 CommonStatusEnum 枚举类
  
 }
 package cn.iocoder.yudao.module.im.controller.admin.manager.face.vo.item;
  
+import cn.iocoder.yudao.framework.common.enums.CommonStatusEnum;
+import cn.iocoder.yudao.framework.common.validation.InEnum;
 import io.swagger.v3.oas.annotations.media.Schema;
 import jakarta.validation.constraints.Max;
 import jakarta.validation.constraints.Min;
@@ -47,6 +49,7 @@ public class ImFacePackItemSaveReqVO {
  
     @Schema(description = "状态", requiredMode = Schema.RequiredMode.REQUIRED, example = "0")
     @NotNull(message = "状态不能为空")
+    @InEnum(value = CommonStatusEnum.class, message = "状态必须是 {value}")
     private Integer status; // 参见 CommonStatusEnum 枚举类（0 启用 / 1 禁用）
  
 }
 package cn.iocoder.yudao.module.im.controller.admin.manager.face.vo.pack;
  
+import cn.iocoder.yudao.framework.common.enums.CommonStatusEnum;
 import cn.iocoder.yudao.framework.common.pojo.PageParam;
+import cn.iocoder.yudao.framework.common.validation.InEnum;
 import io.swagger.v3.oas.annotations.media.Schema;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
@@ -19,6 +21,7 @@ public class ImFacePackPageReqVO extends PageParam {
     private String name;
  
     @Schema(description = "状态", example = "0")
+    @InEnum(value = CommonStatusEnum.class, message = "状态必须是 {value}")
     private Integer status; // 参见 CommonStatusEnum 枚举类
  
     @Schema(description = "创建时间", example = "[2026-04-01 00:00:00, 2026-04-30 23:59:59]")
 package cn.iocoder.yudao.module.im.controller.admin.manager.face.vo.pack;
  
+import cn.iocoder.yudao.framework.common.enums.CommonStatusEnum;
+import cn.iocoder.yudao.framework.common.validation.InEnum;
 import io.swagger.v3.oas.annotations.media.Schema;
 import jakarta.validation.constraints.NotBlank;
 import jakarta.validation.constraints.NotNull;
@@ -28,6 +30,7 @@ public class ImFacePackSaveReqVO {
  
     @Schema(description = "状态", requiredMode = Schema.RequiredMode.REQUIRED, example = "0")
     @NotNull(message = "状态不能为空")
+    @InEnum(value = CommonStatusEnum.class, message = "状态必须是 {value}")
     private Integer status; // 参见 CommonStatusEnum 枚举类（0 启用 / 1 禁用）
  
 }
@@ -18,6 +18,7 @@ import io.swagger.v3.oas.annotations.Parameter;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import jakarta.annotation.Resource;
 import jakarta.validation.Valid;
+import jakarta.validation.constraints.Size;
 import org.springframework.security.access.prepost.PreAuthorize;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
@@ -67,7 +68,9 @@ public class ImSensitiveWordManagerController {
     @Operation(summary = "批量删除敏感词")
     @Parameter(name = "ids", description = "编号列表", required = true)
     @PreAuthorize("@ss.hasPermission('im:manager:sensitive-word:delete')")
-    public CommonResult<Boolean> deleteSensitiveWordList(@RequestParam("ids") List<Long> ids) {
+    public CommonResult<Boolean> deleteSensitiveWordList(
+            @RequestParam("ids")
+            @Size(max = 100, message = "批量删除最多 100 条") List<Long> ids) {
         sensitiveWordService.deleteSensitiveWordList(ids);
         return success(true);
     }
 package cn.iocoder.yudao.module.im.controller.admin.manager.sensitiveword.vo;
  
+import cn.iocoder.yudao.framework.common.enums.CommonStatusEnum;
 import cn.iocoder.yudao.framework.common.pojo.PageParam;
+import cn.iocoder.yudao.framework.common.validation.InEnum;
 import io.swagger.v3.oas.annotations.media.Schema;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
@@ -19,6 +21,7 @@ public class ImSensitiveWordPageReqVO extends PageParam {
     private String word;
  
     @Schema(description = "状态", example = "0")
+    @InEnum(value = CommonStatusEnum.class, message = "状态必须是 {value}")
     private Integer status; // 参见 CommonStatusEnum 枚举类（0 启用 / 1 禁用）
  
     @Schema(description = "创建时间", example = "[2026-04-01 00:00:00, 2026-04-30 23:59:59]")
 package cn.iocoder.yudao.module.im.controller.admin.manager.sensitiveword.vo;
  
+import cn.iocoder.yudao.framework.common.enums.CommonStatusEnum;
+import cn.iocoder.yudao.framework.common.validation.InEnum;
 import io.swagger.v3.oas.annotations.media.Schema;
 import jakarta.validation.constraints.NotBlank;
 import jakarta.validation.constraints.NotNull;
@@ -20,6 +22,7 @@ public class ImSensitiveWordSaveReqVO {
  
     @Schema(description = "状态", requiredMode = Schema.RequiredMode.REQUIRED, example = "0")
     @NotNull(message = "状态不能为空")
+    @InEnum(value = CommonStatusEnum.class, message = "状态必须是 {value}")
     private Integer status; // 参见 CommonStatusEnum 枚举类（0 启用 / 1 禁用）
  
 }
@@ -12,6 +12,7 @@ import io.swagger.v3.oas.annotations.Parameter;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import jakarta.annotation.Resource;
 import jakarta.validation.Valid;
+import jakarta.validation.constraints.Min;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
  
@@ -40,8 +41,9 @@ public class ImGroupMessageController {
     @Operation(summary = "拉取群聊消息（增量）")
     @Parameter(name = "minId", description = "最小消息 id", required = true, example = "0")
     @Parameter(name = "size", description = "拉取数量", required = true, example = "100")
-    public CommonResult<List<ImGroupMessageRespVO>> pullGroupMessageList(@RequestParam("minId") Long minId,
-                                                                         @RequestParam("size") Integer size) {
+    public CommonResult<List<ImGroupMessageRespVO>> pullGroupMessageList(
+            @RequestParam("minId") Long minId,
+            @RequestParam("size") @Min(value = 1, message = "拉取数量最小值为 1") Integer size) {
         List<ImGroupMessageDO> messages = groupMessageService.pullGroupMessageList(getLoginUserId(), minId, size);
         return success(BeanUtils.toBean(messages, ImGroupMessageRespVO.class));
     }
@@ -12,6 +12,7 @@ import io.swagger.v3.oas.annotations.Parameter;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import jakarta.annotation.Resource;
 import jakarta.validation.Valid;
+import jakarta.validation.constraints.Min;
 import org.springframework.validation.annotation.Validated;
 import org.springframework.web.bind.annotation.*;
  
@@ -41,8 +42,9 @@ public class ImPrivateMessageController {
     @Operation(summary = "拉取私聊消息（增量）")
     @Parameter(name = "minId", description = "最小消息 id", required = true, example = "0")
     @Parameter(name = "size", description = "拉取数量", required = true, example = "100")
-    public CommonResult<List<ImPrivateMessageRespVO>> pullPrivateMessageList(@RequestParam("minId") Long minId,
-                                                                             @RequestParam("size") Integer size) {
+    public CommonResult<List<ImPrivateMessageRespVO>> pullPrivateMessageList(
+            @RequestParam("minId") Long minId,
+            @RequestParam("size") @Min(value = 1, message = "拉取数量最小值为 1") Integer size) {
         List<ImPrivateMessageDO> messages = privateMessageService.pullPrivateMessageList(getLoginUserId(), minId, size);
         return success(BeanUtils.toBean(messages, ImPrivateMessageRespVO.class));
     }
@@ -20,7 +20,7 @@ public interface ImFacePackItemMapper extends BaseMapperX&lt;ImFacePackItemDO&gt; {
  
     default List<ImFacePackItemDO> selectListByPackIdsAndStatus(Collection<Long> packIds, Integer status) {
         return selectList(new LambdaQueryWrapperX<ImFacePackItemDO>()
-                .inIfPresent(ImFacePackItemDO::getPackId, packIds)
+                .in(ImFacePackItemDO::getPackId, packIds)
                 .eq(ImFacePackItemDO::getStatus, status)
                 .orderByAsc(ImFacePackItemDO::getPackId)
                 .orderByAsc(ImFacePackItemDO::getSort)
@@ -73,7 +73,7 @@ public interface ImStatisticsManagerMapper {
     // ==================== 群 ====================
  
     /**
-     * 群总数（im_group）
+     * 当前有效群总数
      */
     @Select("SELECT COUNT(*) FROM im_group WHERE deleted = 0 AND status = 0")
     Long selectTotalGroupCount();
@@ -90,7 +90,7 @@ public class LiveKitClient {
                 .setNotBefore(new Date(nowSec * 1000))
                 .setExpiresAt(new Date((nowSec + ttlSec) * 1000))
                 .setPayload("video", video)
-                .setSigner(JWTSignerUtil.hs256(cfg.getApiSecret().getBytes()));
+                .setSigner(JWTSignerUtil.hs256(cfg.getApiSecret().getBytes(StandardCharsets.UTF_8)));
         if (StrUtil.isNotEmpty(displayName)) {
             jwt.setPayload("name", displayName);
         }
@@ -219,7 +219,7 @@ public class LiveKitClient {
                 .setNotBefore(new Date(nowSec * 1000))
                 .setExpiresAt(new Date((nowSec + ADMIN_TOKEN_TTL.getSeconds()) * 1000))
                 .setPayload("video", MapUtil.of("roomAdmin", true))
-                .setSigner(JWTSignerUtil.hs256(cfg.getApiSecret().getBytes()))
+                .setSigner(JWTSignerUtil.hs256(cfg.getApiSecret().getBytes(StandardCharsets.UTF_8)))
                 .sign();
     }
  
 /**
- * trade 模块的 web 配置
+ * IM 模块的 web 配置
  */
 package cn.iocoder.yudao.module.im.framework.web;
 package cn.iocoder.yudao.module.im.service.friend;
  
+import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.util.BooleanUtil;
 import cn.hutool.extra.spring.SpringUtil;
 import cn.iocoder.yudao.framework.common.enums.CommonStatusEnum;
@@ -28,6 +29,7 @@ import org.springframework.validation.annotation.Validated;
  
 import java.time.LocalDateTime;
 import java.util.Collection;
+import java.util.Collections;
 import java.util.List;
  
 import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
@@ -100,6 +102,9 @@ public class ImFriendServiceImpl implements ImFriendService {
  
     @Override
     public List<ImFriendDO> getActiveFriendList(Long userId, Collection<Long> friendUserIds) {
+        if (CollUtil.isEmpty(friendUserIds)) {
+            return Collections.emptyList();
+        }
         return friendMapper.selectListByUserIdAndFriendUserIdsAndStatus(userId, friendUserIds,
                 CommonStatusEnum.ENABLE.getStatus());
     }
@@ -669,6 +669,10 @@ public class ImGroupServiceImpl implements ImGroupService {
      * 三档分层禁言权限校验
      */
     private void validateMutePermission(ImGroupMemberDO operator, ImGroupMemberDO target) {
+        // 普通成员不能禁言任何人
+        if (!ImGroupMemberRoleEnum.isOwnerOrAdmin(operator.getRole())) {
+            throw exception(GROUP_NOT_OWNER_OR_ADMIN);
+        }
         // 群主不可被禁言
         if (ImGroupMemberRoleEnum.isOwner(target.getRole())) {
             throw exception(GROUP_MUTE_OWNER_DENIED);
@@ -677,10 +681,6 @@ public class ImGroupServiceImpl implements ImGroupService {
         if (ImGroupMemberRoleEnum.isAdmin(target.getRole()) && !ImGroupMemberRoleEnum.isOwner(operator.getRole())) {
             throw exception(GROUP_MUTE_ADMIN_DENIED);
         }
-        // 普通成员不能禁言任何人
-        if (!ImGroupMemberRoleEnum.isOwnerOrAdmin(operator.getRole())) {
-            throw exception(GROUP_NOT_OWNER_OR_ADMIN);
-        }
     }
  
     private ImGroupServiceImpl getSelf() {
@@ -71,7 +71,7 @@ public class ImStatisticsManagerServiceImpl implements ImStatisticsManagerServic
         List<Map<String, Object>> rows = statisticsMapper.selectGroupSizeDistribution();
         return convertMap(rows,
                 row -> (String) row.get("range"),
-                row -> (Long) row.get("count"));
+                row -> Convert.toLong(row.get("count")));
     }
  
     // ==================== 消息 ====================
@@ -102,16 +102,16 @@ public class ImStatisticsManagerServiceImpl implements ImStatisticsManagerServic
     public Map<Integer, Long> getMessageTypeCountMap(LocalDateTime beginTime, LocalDateTime endTime) {
         List<Map<String, Object>> rows = statisticsMapper.selectMessageTypeDistribution(beginTime, endTime);
         return convertMap(rows,
-                row -> (Integer) row.get("type"),
-                row -> (Long) row.get("count"));
+                row -> Convert.toInt(row.get("type")),
+                row -> Convert.toLong(row.get("count")));
     }
  
     @Override
     public Map<Long, Long> getTopSenderCountMap(LocalDateTime beginTime, LocalDateTime endTime, int limit) {
         List<Map<String, Object>> rows = statisticsMapper.selectTopSenders(beginTime, endTime, limit);
         return convertMap(rows,
-                row -> (Long) row.get("userId"),
-                row -> (Long) row.get("messageCount"));
+                row -> Convert.toLong(row.get("userId")),
+                row -> Convert.toLong(row.get("messageCount")));
     }
  
     /**
@@ -120,7 +120,7 @@ public class ImStatisticsManagerServiceImpl implements ImStatisticsManagerServic
     private static Map<LocalDateTime, Long> toDailyCountMap(List<Map<String, Object>> rows) {
         return convertMap(rows,
                 row -> Convert.convert(LocalDate.class, row.get("date")).atStartOfDay(),
-                row -> (Long) row.get("count"));
+                row -> Convert.toLong(row.get("count")));
     }
  
 }
@@ -17,6 +17,7 @@ import org.mockito.Mock;
 import org.springframework.dao.DuplicateKeyException;
  
 import java.time.LocalDateTime;
+import java.util.Collections;
 import java.util.List;
  
 import static cn.iocoder.yudao.module.im.enums.ErrorCodeConstants.FRIEND_NOT_FRIEND;
@@ -213,4 +214,12 @@ public class ImFriendServiceImplTest extends BaseMockitoUnitTest {
         assertEquals(2, result.size());
     }
  
+    @Test
+    public void testGetActiveFriendList_emptySkip() {
+        List<ImFriendDO> result = friendService.getActiveFriendList(1L, Collections.emptyList());
+
+        assertTrue(result.isEmpty());
+        verify(imFriendMapper, never()).selectListByUserIdAndFriendUserIdsAndStatus(anyLong(), anyCollection(), anyInt());
+    }
+
 }
@@ -7,10 +7,12 @@ import cn.iocoder.yudao.framework.test.core.ut.BaseMockitoUnitTest;
 import cn.iocoder.yudao.module.im.controller.admin.group.vo.ImGroupAdminAddReqVO;
 import cn.iocoder.yudao.module.im.controller.admin.group.vo.ImGroupAdminRemoveReqVO;
 import cn.iocoder.yudao.module.im.controller.admin.group.vo.ImGroupCreateReqVO;
+import cn.iocoder.yudao.module.im.controller.admin.group.vo.ImGroupMuteMemberReqVO;
 import cn.iocoder.yudao.module.im.controller.admin.group.vo.ImGroupTransferOwnerReqVO;
 import cn.iocoder.yudao.module.im.controller.admin.group.vo.ImGroupUpdateReqVO;
 import cn.iocoder.yudao.module.im.controller.admin.group.vo.member.ImGroupMemberInviteReqVO;
 import cn.iocoder.yudao.module.im.controller.admin.group.vo.member.ImGroupMemberRemoveReqVO;
+import cn.iocoder.yudao.module.im.controller.admin.manager.group.vo.ImGroupManagerBanReqVO;
 import cn.iocoder.yudao.module.im.dal.dataobject.friend.ImFriendDO;
 import cn.iocoder.yudao.module.im.dal.dataobject.group.ImGroupDO;
 import cn.iocoder.yudao.module.im.dal.dataobject.group.ImGroupMemberDO;
@@ -932,6 +934,76 @@ public class ImGroupServiceImplTest extends BaseMockitoUnitTest {
         }
     }
  
+    // ========== banGroup ==========
+
+    @Test
+    public void testBanGroup_dissolved() {
+        try (MockedStatic<SpringUtil> springUtilMockedStatic = mockStatic(SpringUtil.class)) {
+            springUtilMockedStatic.when(() -> SpringUtil.getBean(eq(ImGroupServiceImpl.class)))
+                    .thenReturn(groupService);
+
+            ImGroupDO group = ImGroupDO.builder().id(10L).status(CommonStatusEnum.DISABLE.getStatus()).build();
+            when(groupMapper.selectById(10L)).thenReturn(group);
+
+            ImGroupManagerBanReqVO reqVO = new ImGroupManagerBanReqVO();
+            reqVO.setId(10L).setReason("违规");
+
+            ServiceException exception = assertThrows(ServiceException.class,
+                    () -> groupService.banGroup(1L, reqVO));
+            assertEquals(GROUP_DISSOLVED.getCode(), exception.getCode());
+            verify(groupMapper, never()).updateById(any(ImGroupDO.class));
+            verify(groupMessageService, never()).sendGroupMessage(anyLong(), any(ImGroupMessageSendDTO.class));
+        }
+    }
+
+    @Test
+    public void testBanGroup_alreadyBannedSkip() {
+        try (MockedStatic<SpringUtil> springUtilMockedStatic = mockStatic(SpringUtil.class)) {
+            springUtilMockedStatic.when(() -> SpringUtil.getBean(eq(ImGroupServiceImpl.class)))
+                    .thenReturn(groupService);
+
+            ImGroupDO group = ImGroupDO.builder().id(10L).banned(true)
+                    .status(CommonStatusEnum.ENABLE.getStatus()).build();
+            when(groupMapper.selectById(10L)).thenReturn(group);
+
+            ImGroupManagerBanReqVO reqVO = new ImGroupManagerBanReqVO();
+            reqVO.setId(10L).setReason("违规");
+
+            groupService.banGroup(1L, reqVO);
+
+            verify(groupMapper, never()).updateById(any(ImGroupDO.class));
+            verify(groupMessageService, never()).sendGroupMessage(anyLong(), any(ImGroupMessageSendDTO.class));
+        }
+    }
+
+    // ========== muteMember ==========
+
+    @Test
+    public void testMuteMember_normalCannotMuteAdmin() {
+        try (MockedStatic<SpringUtil> springUtilMockedStatic = mockStatic(SpringUtil.class)) {
+            springUtilMockedStatic.when(() -> SpringUtil.getBean(eq(ImGroupServiceImpl.class)))
+                    .thenReturn(groupService);
+
+            ImGroupDO group = ImGroupDO.builder().id(10L).status(CommonStatusEnum.ENABLE.getStatus()).build();
+            when(groupMapper.selectById(10L)).thenReturn(group);
+            when(groupMemberService.validateMemberInGroup(10L, 1L)).thenReturn(
+                    ImGroupMemberDO.builder().groupId(10L).userId(1L)
+                            .role(ImGroupMemberRoleEnum.NORMAL.getRole()).build());
+            when(groupMemberService.validateMemberInGroup(10L, 2L)).thenReturn(
+                    ImGroupMemberDO.builder().groupId(10L).userId(2L)
+                            .role(ImGroupMemberRoleEnum.ADMIN.getRole()).build());
+
+            ImGroupMuteMemberReqVO reqVO = new ImGroupMuteMemberReqVO();
+            reqVO.setGroupId(10L).setUserId(2L).setMutedSeconds(60);
+
+            ServiceException exception = assertThrows(ServiceException.class,
+                    () -> groupService.muteMember(1L, reqVO));
+            assertEquals(GROUP_NOT_OWNER_OR_ADMIN.getCode(), exception.getCode());
+            verify(groupMemberService, never()).updateGroupMemberMuteEndTime(anyLong(), anyLong(), any());
+            verify(groupMessageService, never()).sendGroupMessage(anyLong(), any(ImGroupMessageSendDTO.class));
+        }
+    }
+
     // ========== validateGroupExists ==========
  
     @Test
@@ -6,6 +6,7 @@ import org.junit.jupiter.api.Test;
 import org.mockito.InjectMocks;
 import org.mockito.Mock;
  
+import java.math.BigInteger;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
 import java.util.Arrays;
@@ -75,10 +76,10 @@ public class ImStatisticsManagerServiceImplTest extends BaseMockitoUnitTest {
  
     @Test
     public void testGetNewUserDailyCountMap_dateConvert() {
-        // 准备：date 字段以 SQL Date / String 混入，count 为 Long
+        // 准备：date 字段以 SQL Date / String 混入，count 混入多种 Number
         when(statisticsMapper.selectNewUserDailyCount(eq(BEGIN), eq(END))).thenReturn(Arrays.asList(
-                row("date", java.sql.Date.valueOf("2026-01-10"), "count", 5L),
-                row("date", "2026-01-11", "count", 8L)));
+                row("date", java.sql.Date.valueOf("2026-01-10"), "count", BigInteger.valueOf(5)),
+                row("date", "2026-01-11", "count", 8)));
  
         // 调用
         Map<LocalDateTime, Long> result = service.getNewUserDailyCountMap(BEGIN, END);
@@ -119,8 +120,8 @@ public class ImStatisticsManagerServiceImplTest extends BaseMockitoUnitTest {
     @Test
     public void testGetGroupSizeCountMap() {
         when(statisticsMapper.selectGroupSizeDistribution()).thenReturn(Arrays.asList(
-                row("range", "1-9 人", "count", 3L),
-                row("range", "10-49 人", "count", 2L)));
+                row("range", "1-9 人", "count", BigInteger.valueOf(3)),
+                row("range", "10-49 人", "count", 2)));
  
         Map<String, Long> result = service.getGroupSizeCountMap();
         assertEquals(3L, result.get("1-9 人"));
@@ -130,8 +131,8 @@ public class ImStatisticsManagerServiceImplTest extends BaseMockitoUnitTest {
     @Test
     public void testGetMessageTypeCountMap() {
         when(statisticsMapper.selectMessageTypeDistribution(BEGIN, END)).thenReturn(Arrays.asList(
-                row("type", 101, "count", 8L),
-                row("type", 102, "count", 1L)));
+                row("type", 101L, "count", BigInteger.valueOf(8)),
+                row("type", 102, "count", 1)));
  
         Map<Integer, Long> result = service.getMessageTypeCountMap(BEGIN, END);
         assertEquals(8L, result.get(101));
@@ -141,8 +142,8 @@ public class ImStatisticsManagerServiceImplTest extends BaseMockitoUnitTest {
     @Test
     public void testGetTopSenderCountMap_passesLimit() {
         when(statisticsMapper.selectTopSenders(BEGIN, END, 3)).thenReturn(Arrays.asList(
-                row("userId", 1L, "messageCount", 10L),
-                row("userId", 2L, "messageCount", 5L)));
+                row("userId", 1, "messageCount", BigInteger.valueOf(10)),
+                row("userId", 2L, "messageCount", 5)));
  
         Map<Long, Long> result = service.getTopSenderCountMap(BEGIN, END, 3);
         assertEquals(10L, result.get(1L));