```

✨ feat(im): RTC 通话逻辑收口（displayName / inviteeIds 校验 / 配置化阈值） - fix: pushCallInviteNotification 给被邀请人签 token 时 displayName 改用 invitee 自己的昵称（原来错用 inviter） - feat: 群通话发起 / 追加邀请均强制 inviteeIds 非空，对齐微信交互；超量改抛 RTC_GROUP_INVITEE_OVER_LIMIT，不再静默截断 - refactor: ImGroupMemberService 抽 validateMembersInGroup(groupId, ids) 批量校验，inviteMoreCall / resolveInvitees 复用 - refactor: 僵尸通话清理阈值从 ImRtcCallCleanupJob 静态常量挪到 ImProperties.rtc.cleanupZombieThresholdMinutes - perf: createCall / inviteMoreCall 推 INVITE 前一次 getUserMap 批量拉用户，省 N 次 RPC - refactor: inviteMoreCall 参与者构造改 CollectionUtils.convertList；trim 多余注释 - docs: 补齐 RTC service / controller / job / LiveKitClient 私有方法的 @param / @return - chore: 错误码新增 RTC_GROUP_INVITEE_REQUIRED / RTC_GROUP_INVITEE_OVER_LIMIT ```

```
✨ feat(im): RTC 通话逻辑收口（displayName / inviteeIds 校验 / 配置化阈值） - fix: pushCallInviteNotification 给被邀请人签 token 时 displayName 改用 invitee 自己的昵称（原来错用 inviter） - feat: 群通话发起 / 追加邀请均强制 inviteeIds 非空，对齐微信交互；超量改抛 RTC_GROUP_INVITEE_OVER_LIMIT，不再静默截断 - refactor: ImGroupMemberService 抽 validateMembersInGroup(groupId, ids) 批量校验，inviteMoreCall / resolveInvitees 复用 - refactor: 僵尸通话清理阈值从 ImRtcCallCleanupJob 静态常量挪到 ImProperties.rtc.cleanupZombieThresholdMinutes - perf: createCall / inviteMoreCall 推 INVITE 前一次 getUserMap 批量拉用户，省 N 次 RPC - refactor: inviteMoreCall 参与者构造改 CollectionUtils.convertList；trim 多余注释 - docs: 补齐 RTC service / controller / job / LiveKitClient 私有方法的 @param / @return - chore: 错误码新增 RTC_GROUP_INVITEE_REQUIRED / RTC_GROUP_INVITEE_OVER_LIMIT ```
YunaiV
1 parent 27685b99
Showing 3 changed files with 27 additions and 0 deletions
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/controller/admin/rtc/ImRtcCallController.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/controller/admin/rtc/ImRtcLiveKitController.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/framework/rtc/core/LiveKitClient.java
@@ -109,6 +109,13 @@ public class ImRtcCallController {
     // ========== VO 拼装 ==========
+    /**
+     * 拼装 invite / join / accept / refresh-token 的响应 VO；含 token + 参与者分桶
+     *
+     * @param call   通话主表
+     * @param userId 当前用户编号；token 按该用户签发
+     * @return 响应 VO；call 为空返回 null
+     */
     private ImRtcCallRespVO buildCallResp(ImRtcCallDO call, Long userId) {
         if (call == null) {
             return null;
@@ -125,6 +132,12 @@ public class ImRtcCallController {
                 .setJoinedUserIds(filterUserIds(participants, ImRtcParticipantStatusEnum.JOINED));
     }
+    /**
+     * 拼装 get-active-call 的响应 VO；只用于群聊胶囊条，不含 token
+     *
+     * @param call 通话主表
+     * @return 响应 VO；call 为空返回 null
+     */
     private ImRtcGroupCallRespVO buildGroupActiveResp(ImRtcCallDO call) {
         if (call == null) {
             return null;
@@ -140,6 +153,10 @@ public class ImRtcCallController {
     /**
      * 按状态过滤参与者 userId；用 LinkedHashSet 保留前端展示顺序
+     *
+     * @param participants 参与者列表
+     * @param status       目标状态
+     * @return userId 集合
      */
     private static Set<Long> filterUserIds(List<ImRtcParticipantDO> participants,
                                            ImRtcParticipantStatusEnum status) {
@@ -39,6 +39,13 @@ public class ImRtcLiveKitController {
     @Resource
     private ImRtcCallService rtcCallService;
+    /**
+     * LiveKit Webhook 回调入口
+     *
+     * @param request HTTP 请求；用于取 Authorization 头做签名校验
+     * @param rawBody 原始 JSON body；签名校验需要原始字节
+     * @return 是否处理成功；伪造 / 非法事件返回 false
+     */
     @PostMapping(value = "/webhook", consumes = MediaType.APPLICATION_JSON_VALUE)
     @Operation(summary = "LiveKit Webhook 回调；接收成员离开 / 房间结束等事件做业务态兜底清理")
     @PermitAll
@@ -54,6 +54,9 @@ public class LiveKitClient {
     private final ImProperties imProperties;
+    /**
+     * @param imProperties IM 全局配置；从中读 livekitUrl / apiKey / apiSecret / tokenTtlHours
+     */
     public LiveKitClient(ImProperties imProperties) {
         this.imProperties = imProperties;
     }