✨ feat(im): 管理后台新增通话记录只读查询（列表 / 详情 / 参与者）；im_rtc_participant 增加 call_id 关联 im_rtc_call.id

✨ feat(im): 管理后台新增通话记录页面（列表 + 详情抽屉 + 参与者表），消息预览补 RTC_CALL_START / END 文案

✨ feat(im): 管理后台新增通话记录只读查询（列表 / 详情 / 参与者）；im_rtc_participant 增加 call_id 关联 im_rtc_call.id
✨ feat(im): 管理后台新增通话记录页面（列表 + 详情抽屉 + 参与者表），消息预览补 RTC_CALL_START / END 文案
YunaiV
1 parent 2fd201bf
Showing 10 changed files with 319 additions and 4 deletions
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/controller/admin/manager/rtc/ImRtcCallManagerController.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/controller/admin/manager/rtc/vo/ImRtcCallManagerPageReqVO.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/controller/admin/manager/rtc/vo/ImRtcCallManagerRespVO.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/controller/admin/manager/rtc/vo/ImRtcParticipantManagerRespVO.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/dal/dataobject/rtc/ImRtcParticipantDO.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/dal/mysql/rtc/ImRtcCallMapper.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/dal/mysql/rtc/ImRtcParticipantMapper.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/service/rtc/ImRtcCallService.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/service/rtc/ImRtcCallServiceImpl.java
yudao-module-im/src/test/resources/sql/create_tables.sql
+package cn.iocoder.yudao.module.im.controller.admin.manager.rtc;
+
+import cn.hutool.core.collection.CollUtil;
+import cn.iocoder.yudao.framework.common.pojo.CommonResult;
+import cn.iocoder.yudao.framework.common.pojo.PageResult;
+import cn.iocoder.yudao.framework.common.util.collection.MapUtils;
+import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
+import cn.iocoder.yudao.module.im.controller.admin.manager.rtc.vo.ImRtcCallManagerPageReqVO;
+import cn.iocoder.yudao.module.im.controller.admin.manager.rtc.vo.ImRtcCallManagerRespVO;
+import cn.iocoder.yudao.module.im.controller.admin.manager.rtc.vo.ImRtcParticipantManagerRespVO;
+import cn.iocoder.yudao.module.im.dal.dataobject.group.ImGroupDO;
+import cn.iocoder.yudao.module.im.dal.dataobject.rtc.ImRtcCallDO;
+import cn.iocoder.yudao.module.im.dal.dataobject.rtc.ImRtcParticipantDO;
+import cn.iocoder.yudao.module.im.service.group.ImGroupService;
+import cn.iocoder.yudao.module.im.service.rtc.ImRtcCallService;
+import cn.iocoder.yudao.module.system.api.user.AdminUserApi;
+import cn.iocoder.yudao.module.system.api.user.dto.AdminUserRespDTO;
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.Parameter;
+import io.swagger.v3.oas.annotations.tags.Tag;
+import jakarta.annotation.Resource;
+import jakarta.validation.Valid;
+import org.springframework.security.access.prepost.PreAuthorize;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.Collections;
+import java.util.List;
+import java.util.Map;
+
+import static cn.iocoder.yudao.framework.common.pojo.CommonResult.success;
+import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.convertSet;
+
+@Tag(name = "管理后台 - IM 通话记录")
+@RestController
+@RequestMapping("/im/manager/rtc")
+@Validated
+public class ImRtcCallManagerController {
+
+    @Resource
+    private ImRtcCallService rtcCallService;
+    @Resource
+    private ImGroupService groupService;
+
+    @Resource
+    private AdminUserApi adminUserApi;
+
+    @GetMapping("/page")
+    @Operation(summary = "获得通话记录分页")
+    @PreAuthorize("@ss.hasPermission('im:manager:rtc:query')")
+    public CommonResult<PageResult<ImRtcCallManagerRespVO>> getCallPage(@Valid ImRtcCallManagerPageReqVO pageReqVO) {
+        PageResult<ImRtcCallDO> pageResult = rtcCallService.getCallPage(pageReqVO);
+        return success(buildCallRespVOPage(pageResult));
+    }
+
+    @GetMapping("/get")
+    @Operation(summary = "获得通话记录详情")
+    @Parameter(name = "id", description = "通话编号", required = true, example = "1024")
+    @PreAuthorize("@ss.hasPermission('im:manager:rtc:query')")
+    public CommonResult<ImRtcCallManagerRespVO> getCall(@RequestParam("id") Long id) {
+        ImRtcCallDO call = rtcCallService.getCall(id);
+        if (call == null) {
+            return success(null);
+        }
+        return success(CollUtil.getFirst(buildCallRespVOList(Collections.singletonList(call))));
+    }
+
+    @GetMapping("/participant-list")
+    @Operation(summary = "获得通话参与者列表")
+    @Parameter(name = "id", description = "通话编号", required = true, example = "1024")
+    @PreAuthorize("@ss.hasPermission('im:manager:rtc:query')")
+    public CommonResult<List<ImRtcParticipantManagerRespVO>> getCallParticipantList(@RequestParam("id") Long id) {
+        List<ImRtcParticipantDO> participants = rtcCallService.getCallParticipantListByCallId(id);
+        if (CollUtil.isEmpty(participants)) {
+            return success(Collections.emptyList());
+        }
+        // 查询用户信息
+        Map<Long, AdminUserRespDTO> userMap = adminUserApi.getUserMap(
+                convertSet(participants, ImRtcParticipantDO::getUserId));
+        // 组装返回
+        return success(BeanUtils.toBean(participants, ImRtcParticipantManagerRespVO.class, vo ->
+                MapUtils.findAndThen(userMap, vo.getUserId(),
+                        user -> vo.setUserNickname(user.getNickname()))));
+    }
+
+    // ========== 私有方法：VO 组装 ==========
+
+    private PageResult<ImRtcCallManagerRespVO> buildCallRespVOPage(PageResult<ImRtcCallDO> pageResult) {
+        if (CollUtil.isEmpty(pageResult.getList())) {
+            return PageResult.empty(pageResult.getTotal());
+        }
+        return new PageResult<>(buildCallRespVOList(pageResult.getList()), pageResult.getTotal());
+    }
+
+    private List<ImRtcCallManagerRespVO> buildCallRespVOList(List<ImRtcCallDO> calls) {
+        // 查询用户信息
+        Map<Long, AdminUserRespDTO> userMap = adminUserApi.getUserMap(
+                convertSet(calls, ImRtcCallDO::getInviterUserId));
+        Map<Long, ImGroupDO> groupMap = groupService.getGroupMap(
+                convertSet(calls, ImRtcCallDO::getGroupId));
+        // 组装返回
+        return BeanUtils.toBean(calls, ImRtcCallManagerRespVO.class, vo -> {
+            MapUtils.findAndThen(userMap, vo.getInviterUserId(),
+                    user -> vo.setInviterNickname(user.getNickname()));
+            MapUtils.findAndThen(groupMap, vo.getGroupId(),
+                    group -> vo.setGroupName(group.getName()));
+        });
+    }
+
+}
+package cn.iocoder.yudao.module.im.controller.admin.manager.rtc.vo;
+
+import cn.iocoder.yudao.framework.common.pojo.PageParam;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import org.springframework.format.annotation.DateTimeFormat;
+
+import java.time.LocalDateTime;
+
+import static cn.iocoder.yudao.framework.common.util.date.DateUtils.FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND;
+
+@Schema(description = "管理后台 - IM 通话记录分页 Request VO")
+@Data
+@EqualsAndHashCode(callSuper = true)
+public class ImRtcCallManagerPageReqVO extends PageParam {
+
+    @Schema(description = "发起人用户编号", example = "1024")
+    private Long inviterUserId;
+
+    @Schema(description = "会话类型", example = "1")
+    private Integer conversationType; // 参见 ImConversationTypeEnum 枚举类
+
+    @Schema(description = "媒体类型", example = "1")
+    private Integer mediaType; // 参见 ImRtcCallMediaTypeEnum 枚举类
+
+    @Schema(description = "通话状态", example = "10")
+    private Integer status; // 参见 ImRtcCallStatusEnum 枚举类
+
+    @Schema(description = "结束原因", example = "1")
+    private Integer endReason; // 参见 ImRtcCallEndReasonEnum 枚举类
+
+    @Schema(description = "发起时间", example = "[2026-04-01 00:00:00, 2026-04-30 23:59:59]")
+    @DateTimeFormat(pattern = FORMAT_YEAR_MONTH_DAY_HOUR_MINUTE_SECOND)
+    private LocalDateTime[] startTime;
+
+}
+package cn.iocoder.yudao.module.im.controller.admin.manager.rtc.vo;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+import java.time.LocalDateTime;
+
+@Schema(description = "管理后台 - IM 通话记录 Response VO")
+@Data
+public class ImRtcCallManagerRespVO {
+
+    @Schema(description = "编号", requiredMode = Schema.RequiredMode.REQUIRED, example = "1024")
+    private Long id;
+
+    @Schema(description = "业务通话编号", requiredMode = Schema.RequiredMode.REQUIRED, example = "uuid-xxx")
+    private String room;
+
+    @Schema(description = "会话类型", requiredMode = Schema.RequiredMode.REQUIRED, example = "1")
+    private Integer conversationType; // 参见 ImConversationTypeEnum 枚举类
+
+    @Schema(description = "媒体类型", requiredMode = Schema.RequiredMode.REQUIRED, example = "1")
+    private Integer mediaType; // 参见 ImRtcCallMediaTypeEnum 枚举类
+
+    @Schema(description = "发起人用户编号", requiredMode = Schema.RequiredMode.REQUIRED, example = "1024")
+    private Long inviterUserId;
+
+    @Schema(description = "发起人昵称", example = "张三")
+    private String inviterNickname;
+
+    @Schema(description = "群编号；私聊为空", example = "999")
+    private Long groupId;
+
+    @Schema(description = "群名称；私聊为空", example = "测试群")
+    private String groupName;
+
+    @Schema(description = "通话状态", requiredMode = Schema.RequiredMode.REQUIRED, example = "10")
+    private Integer status; // 参见 ImRtcCallStatusEnum 枚举类
+
+    @Schema(description = "结束原因", example = "1")
+    private Integer endReason; // 参见 ImRtcCallEndReasonEnum 枚举类
+
+    @Schema(description = "发起时间", requiredMode = Schema.RequiredMode.REQUIRED)
+    private LocalDateTime startTime;
+
+    @Schema(description = "接通时间；未接通为空")
+    private LocalDateTime acceptTime;
+
+    @Schema(description = "结束时间；未结束为空")
+    private LocalDateTime endTime;
+
+    @Schema(description = "创建时间", requiredMode = Schema.RequiredMode.REQUIRED)
+    private LocalDateTime createTime;
+
+}
+package cn.iocoder.yudao.module.im.controller.admin.manager.rtc.vo;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+import java.time.LocalDateTime;
+
+@Schema(description = "管理后台 - IM 通话参与者 Response VO")
+@Data
+public class ImRtcParticipantManagerRespVO {
+
+    @Schema(description = "编号", requiredMode = Schema.RequiredMode.REQUIRED, example = "1024")
+    private Long id;
+
+    @Schema(description = "通话编号", requiredMode = Schema.RequiredMode.REQUIRED, example = "2048")
+    private Long callId;
+
+    @Schema(description = "参与者用户编号", requiredMode = Schema.RequiredMode.REQUIRED, example = "1024")
+    private Long userId;
+
+    @Schema(description = "参与者昵称", example = "张三")
+    private String userNickname;
+
+    @Schema(description = "参与角色", requiredMode = Schema.RequiredMode.REQUIRED, example = "1")
+    private Integer role; // 参见 ImRtcParticipantRoleEnum 枚举类
+
+    @Schema(description = "参与状态", requiredMode = Schema.RequiredMode.REQUIRED, example = "20")
+    private Integer status; // 参见 ImRtcParticipantStatusEnum 枚举类
+
+    @Schema(description = "被邀请时间", requiredMode = Schema.RequiredMode.REQUIRED)
+    private LocalDateTime inviteTime;
+
+    @Schema(description = "接听时间；未接听为空")
+    private LocalDateTime acceptTime;
+
+    @Schema(description = "离开时间；未加入为空")
+    private LocalDateTime leaveTime;
+
+}
@@ -35,6 +35,12 @@ public class ImRtcParticipantDO extends BaseDO {
     @TableId
     private Long id;
     /**
+     * 通话编号
+     * <p>
+     * 关联 {@link ImRtcCallDO#getId()}
+     */
+    private Long callId;
+    /**
      * 业务通话编号
      * <p>
      * 关联 {@link ImRtcCallDO#getRoom()}
 package cn.iocoder.yudao.module.im.dal.mysql.rtc;
+import cn.iocoder.yudao.framework.common.pojo.PageResult;
 import cn.iocoder.yudao.framework.mybatis.core.mapper.BaseMapperX;
 import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX;
+import cn.iocoder.yudao.module.im.controller.admin.manager.rtc.vo.ImRtcCallManagerPageReqVO;
 import cn.iocoder.yudao.module.im.dal.dataobject.rtc.ImRtcCallDO;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import org.apache.ibatis.annotations.Mapper;
@@ -48,4 +50,15 @@ public interface ImRtcCallMapper extends BaseMapperX&lt;ImRtcCallDO&gt; {
                 .lt(ImRtcCallDO::getStartTime, startTimeBefore));
     }
+    default PageResult<ImRtcCallDO> selectPage(ImRtcCallManagerPageReqVO reqVO) {
+        return selectPage(reqVO, new LambdaQueryWrapperX<ImRtcCallDO>()
+                .eqIfPresent(ImRtcCallDO::getInviterUserId, reqVO.getInviterUserId())
+                .eqIfPresent(ImRtcCallDO::getConversationType, reqVO.getConversationType())
+                .eqIfPresent(ImRtcCallDO::getMediaType, reqVO.getMediaType())
+                .eqIfPresent(ImRtcCallDO::getStatus, reqVO.getStatus())
+                .eqIfPresent(ImRtcCallDO::getEndReason, reqVO.getEndReason())
+                .betweenIfPresent(ImRtcCallDO::getStartTime, reqVO.getStartTime())
+                .orderByDesc(ImRtcCallDO::getId));
+    }
+
 }
@@ -28,6 +28,10 @@ public interface ImRtcParticipantMapper extends BaseMapperX&lt;ImRtcParticipantDO&gt; 
         return selectList(ImRtcParticipantDO::getRoom, room);
     }
+    default List<ImRtcParticipantDO> selectListByCallId(Long callId) {
+        return selectList(ImRtcParticipantDO::getCallId, callId);
+    }
+
     default List<ImRtcParticipantDO> selectListByStatusAndInviteTimeBefore(Integer status, LocalDateTime threshold) {
         return selectList(new LambdaQueryWrapperX<ImRtcParticipantDO>()
                 .eq(ImRtcParticipantDO::getStatus, status)
 package cn.iocoder.yudao.module.im.service.rtc;
+import cn.iocoder.yudao.framework.common.pojo.PageResult;
+import cn.iocoder.yudao.module.im.controller.admin.manager.rtc.vo.ImRtcCallManagerPageReqVO;
 import cn.iocoder.yudao.module.im.controller.admin.rtc.vo.ImRtcCallCreateReqVO;
 import cn.iocoder.yudao.module.im.controller.admin.rtc.vo.ImRtcCallInviteReqVO;
 import cn.iocoder.yudao.module.im.dal.dataobject.rtc.ImRtcCallDO;
@@ -138,4 +140,30 @@ public interface ImRtcCallService {
      */
     void noAnswerCallCheck(Long userId, String room);
+    // ==================== 管理后台 ====================
+
+    /**
+     * 【管理后台】获得通话记录分页
+     *
+     * @param reqVO 分页查询条件
+     * @return 通话记录分页
+     */
+    PageResult<ImRtcCallDO> getCallPage(ImRtcCallManagerPageReqVO reqVO);
+
+    /**
+     * 【管理后台】获得通话记录
+     *
+     * @param id 通话编号
+     * @return 通话记录
+     */
+    ImRtcCallDO getCall(Long id);
+
+    /**
+     * 【管理后台】按通话编号查询参与者明细
+     *
+     * @param id 通话编号
+     * @return 参与者明细列表；通话不存在时返回空集合
+     */
+    List<ImRtcParticipantDO> getCallParticipantListByCallId(Long id);
+
 }
@@ -4,7 +4,9 @@ import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.util.IdUtil;
 import cn.hutool.core.util.ObjUtil;
 import cn.hutool.core.util.StrUtil;
+import cn.iocoder.yudao.framework.common.pojo.PageResult;
 import cn.iocoder.yudao.framework.common.util.collection.CollectionUtils;
+import cn.iocoder.yudao.module.im.controller.admin.manager.rtc.vo.ImRtcCallManagerPageReqVO;
 import cn.iocoder.yudao.module.im.controller.admin.rtc.vo.ImRtcCallCreateReqVO;
 import cn.iocoder.yudao.module.im.controller.admin.rtc.vo.ImRtcCallInviteReqVO;
 import cn.iocoder.yudao.module.im.dal.dataobject.rtc.ImRtcCallDO;
@@ -215,13 +217,13 @@ public class ImRtcCallServiceImpl implements ImRtcCallService {
         rtcCallMapper.insert(call);
         // 2.2 批量 INSERT 参与表：发起人即时 JOINED，被邀请人 INVITING 等接通
         List<ImRtcParticipantDO> participants = new ArrayList<>(invitees.size() + 1);
-        participants.add(new ImRtcParticipantDO().setRoom(room).setUserId(inviterId)
+        participants.add(new ImRtcParticipantDO().setCallId(call.getId()).setRoom(room).setUserId(inviterId)
                 .setRole(ImRtcParticipantRoleEnum.INVITER.getRole())
                 .setStatus(ImRtcParticipantStatusEnum.JOINED.getStatus())
                 .setInviteTime(now).setAcceptTime(now));
         for (Long inviteeId : invitees) {
             participants.add(new ImRtcParticipantDO()
-                    .setRoom(room).setUserId(inviteeId)
+                    .setCallId(call.getId()).setRoom(room).setUserId(inviteeId)
                     .setRole(ImRtcParticipantRoleEnum.INVITEE.getRole())
                     .setStatus(ImRtcParticipantStatusEnum.INVITING.getStatus())
                     .setInviteTime(now));
@@ -260,7 +262,8 @@ public class ImRtcCallServiceImpl implements ImRtcCallService {
             }
         } else {
             // 旁观者主动加入：INSERT role=ACTIVE_JOIN
-            rtcParticipantMapper.insert(new ImRtcParticipantDO().setRoom(call.getRoom())
+            rtcParticipantMapper.insert(new ImRtcParticipantDO()
+                    .setCallId(call.getId()).setRoom(call.getRoom())
                     .setUserId(userId).setRole(ImRtcParticipantRoleEnum.ACTIVE_JOIN.getRole())
                     .setStatus(ImRtcParticipantStatusEnum.JOINED.getStatus()).setInviteTime(now).setAcceptTime(now));
         }
@@ -292,7 +295,7 @@ public class ImRtcCallServiceImpl implements ImRtcCallService {
         // 2. 批量 INSERT 新邀请人
         LocalDateTime now = LocalDateTime.now();
         List<ImRtcParticipantDO> participants = CollectionUtils.convertList(incomingUserIds, inviteeId ->
-                new ImRtcParticipantDO().setRoom(call.getRoom()).setUserId(inviteeId)
+                new ImRtcParticipantDO().setCallId(call.getId()).setRoom(call.getRoom()).setUserId(inviteeId)
                         .setRole(ImRtcParticipantRoleEnum.INVITEE.getRole())
                         .setStatus(ImRtcParticipantStatusEnum.INVITING.getStatus()).setInviteTime(now));
         rtcParticipantMapper.insertBatch(participants);
@@ -1071,4 +1074,21 @@ public class ImRtcCallServiceImpl implements ImRtcCallService {
                 user == null ? null : user.getNickname(), String.valueOf(userId));
     }
+    // ==================== 管理后台 ====================
+
+    @Override
+    public PageResult<ImRtcCallDO> getCallPage(ImRtcCallManagerPageReqVO reqVO) {
+        return rtcCallMapper.selectPage(reqVO);
+    }
+
+    @Override
+    public ImRtcCallDO getCall(Long id) {
+        return rtcCallMapper.selectById(id);
+    }
+
+    @Override
+    public List<ImRtcParticipantDO> getCallParticipantListByCallId(Long id) {
+        return rtcParticipantMapper.selectListByCallId(id);
+    }
+
 }
@@ -202,6 +202,7 @@ CREATE TABLE IF NOT EXISTS &quot;im_rtc_call&quot; (
 CREATE TABLE IF NOT EXISTS "im_rtc_participant" (
     "id" bigint NOT NULL GENERATED BY DEFAULT AS IDENTITY COMMENT '编号',
+    "call_id" bigint NOT NULL COMMENT '通话编号',
     "room" varchar(64) NOT NULL COMMENT '业务通话编号',
     "user_id" bigint NOT NULL COMMENT '参与者用户编号',
     "role" tinyint NOT NULL COMMENT '参与角色',