✨ feat(im): 对齐微信的通话，模拟手机拨打电话。每次都一定有记录

YunaiV
1 parent c69e20d6
Showing 4 changed files with 46 additions and 30 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/vo/ImRtcCallRespVO.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/enums/rtc/ImRtcCallEndReasonEnum.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/service/rtc/ImRtcCallServiceImpl.java
@@ -8,6 +8,7 @@ import cn.iocoder.yudao.module.im.controller.admin.rtc.vo.ImRtcCallRespVO;
 import cn.iocoder.yudao.module.im.controller.admin.rtc.vo.ImRtcGroupCallRespVO;
 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.enums.rtc.ImRtcCallStatusEnum;
 import cn.iocoder.yudao.module.im.enums.rtc.ImRtcParticipantStatusEnum;
 import cn.iocoder.yudao.module.im.framework.config.ImProperties;
 import cn.iocoder.yudao.module.im.service.rtc.ImRtcCallService;
@@ -123,13 +124,15 @@ public class ImRtcCallController {
             return null;
         }
         List<ImRtcParticipantDO> participants = rtcCallService.getCallParticipantList(call.getRoom());
+        boolean ended = ImRtcCallStatusEnum.isEnded(call.getStatus());
         return new ImRtcCallRespVO()
                 .setRoom(call.getRoom())
                 .setLivekitUrl(imProperties.getRtc().getLivekitUrl())
-                .setToken(rtcCallService.signCallToken(userId, call.getRoom()))
+                // 仅非 ENDED 场景才签 token，ENDED 场景不签，前端根据 token 是否存在，来判断是否展示「通话已结束」的提示
+                .setToken(ended ? null : rtcCallService.signCallToken(userId, call.getRoom()))
                 .setConversationType(call.getConversationType()).setMediaType(call.getMediaType())
-                .setStatus(call.getStatus()).setInviterId(call.getInviterUserId())
-                .setGroupId(call.getGroupId())
+                .setStatus(call.getStatus()).setEndReason(call.getEndReason())
+                .setInviterId(call.getInviterUserId()).setGroupId(call.getGroupId())
                 .setInviteeIds(filterUserIds(participants, ImRtcParticipantStatusEnum.INVITING))
                 .setJoinedUserIds(filterUserIds(participants, ImRtcParticipantStatusEnum.JOINED));
     }
@@ -27,6 +27,9 @@ public class ImRtcCallRespVO {
     @Schema(description = "状态")
     private Integer status; // 参见 ImCallStatusEnum 枚举类
+    @Schema(description = "结束原因；仅 status=ENDED 时有值")
+    private Integer endReason; // 参见 ImRtcCallEndReasonEnum 枚举类
+
     @Schema(description = "发起人编号")
     private Long inviterId;
@@ -20,7 +20,6 @@ public enum ImRtcCallEndReasonEnum implements ArrayValuable&lt;Integer&gt; {
     HANGUP(1, "通话结束"), // 接通后任一方主动挂断
     REJECT(2, "已拒绝"), // 被叫接通前点拒接
     CANCEL(3, "已取消"), // 主叫接通前主动取消
-    // TODO @AI：思考时，会看到一条，【对方正忙】；目的是：私聊后续会看到这个通话，从而去回去联系。类似未接电话一样的味道。
     BUSY(5, "对方正忙"), // 私聊呼叫时对方在另一通话
     ERROR(9, "通话异常"); // 网络中断、设备失败等
@@ -112,55 +112,64 @@ public class ImRtcCallServiceImpl implements ImRtcCallService {
     }
     /**
-     * 群通话创建锁内主体：群有活跃通话引导走 inviteCall / joinCall；无则兜底自身忙线后新建
+     * 群通话创建锁内主体：群有活跃通话直接抛（引导走 inviteCall / joinCall）；
+     * 否则走完整生命周期，若发起人自身忙线立即 end(BUSY) 留下通话记录
      *
      * @param userId 发起人编号
      * @param reqVO  创建请求
-     * @return 通话主表
+     * @return 通话主表（可能 status=ENDED 表示自身忙线）
      */
     private ImRtcCallDO createGroupCall(Long userId, ImRtcCallCreateReqVO reqVO) {
+        // 1.1 同群有活跃通话 → 直接抛异常（UI 应已拦截），引导用户走 inviteCall / joinCall；避免重复开通
         ImRtcCallDO active = rtcCallMapper.selectLastOneByGroupIdAndStatusIn(
                 reqVO.getGroupId(), ImRtcCallStatusEnum.ACTIVE_STATUSES);
         if (active != null) {
             throw exception(RTC_GROUP_CALL_ACTIVE);
         }
-        // 兜底校验发起人不在另一通通话中（跨群 / 跨好友）
-        ImRtcParticipantDO selfActive = rtcParticipantMapper.selectLastOneByUserIdAndStatus(
-                userId, ImRtcParticipantStatusEnum.ACTIVE_STATUSES);
-        if (selfActive != null) {
-            throw exception(RTC_SELF_BUSY);
+        // 1.2 先检测发起人忙线状态；不抛，留给下方 end 决定
+        boolean selfBusy = rtcParticipantMapper.selectLastOneByUserIdAndStatus(
+                userId, ImRtcParticipantStatusEnum.ACTIVE_STATUSES) != null;
+
+        // 2. 完整生命周期：INSERT + INVITE × N + START 全推
+        ImRtcCallDO call = createCall0(userId, reqVO);
+
+        // 3. 自身忙线立即 end(BUSY)；END 推送给群，群成员看到完整 START + END
+        if (selfBusy) {
+            endSession(call, userId, ImRtcCallEndReasonEnum.BUSY);
         }
-        return createCall0(userId, reqVO);
+        return call;
     }
     /**
-     * 私聊创建锁内主体：检查双方忙线后新建
+     * 私聊创建锁内主体：双方忙线时仍走完整生命周期（create + 立即 end(BUSY)），
+     * 同一对正在通话视作数据异常直接抛
      *
      * @param userId     发起人编号
      * @param reqVO      创建请求
      * @param peerUserId 对端编号；来自 reqVO.inviteeIds 的唯一元素
-     * @return 通话主表
+     * @return 通话主表（可能 status=ENDED 表示忙线）
      */
     private ImRtcCallDO createPrivateCall(Long userId, ImRtcCallCreateReqVO reqVO, Long peerUserId) {
-        // 1.1 发起人 & 对端已在同一通话 → 视为自身忙线
-        ImRtcCallDO active = getActivePrivateCallByPair(userId, peerUserId);
-        if (active != null) {
+        // 1.1 双方已在同一通话 → 数据异常（UI 应已拦截），直接抛
+        if (getActivePrivateCallByPair(userId, peerUserId) != null) {
             throw exception(RTC_SELF_BUSY);
         }
-        // 1.2 对端忙线
-        ImRtcParticipantDO peerActive = rtcParticipantMapper.selectLastOneByUserIdAndStatus(
-                peerUserId, ImRtcParticipantStatusEnum.ACTIVE_STATUSES);
-        if (peerActive != null) {
-            throw exception(RTC_PEER_BUSY);
-        }
-        // 1.3 发起人在另一通通话（跨好友 / 跨群兜底）
-        ImRtcParticipantDO selfActive = rtcParticipantMapper.selectLastOneByUserIdAndStatus(
-                userId, ImRtcParticipantStatusEnum.ACTIVE_STATUSES);
-        if (selfActive != null) {
-            throw exception(RTC_SELF_BUSY);
+        // 1.2 忙线检测：self 优先（更可执行的提示）；不抛，留给下方 end 决定
+        boolean selfBusy = rtcParticipantMapper.selectLastOneByUserIdAndStatus(
+                userId, ImRtcParticipantStatusEnum.ACTIVE_STATUSES) != null;
+        boolean peerBusy = !selfBusy && rtcParticipantMapper.selectLastOneByUserIdAndStatus(
+                peerUserId, ImRtcParticipantStatusEnum.ACTIVE_STATUSES) != null;
+
+        // 2. 完整生命周期：INSERT + INVITE 全推
+        ImRtcCallDO call = createCall0(userId, reqVO);
+
+        // 3. 忙线立即 end(BUSY)；operator 决定两端看到的文案（self busy → operator=自己；peer busy → operator=对端）
+        if (selfBusy) {
+            endSession(call, userId, ImRtcCallEndReasonEnum.BUSY);
+        } else if (peerBusy) {
+            endSession(call, peerUserId, ImRtcCallEndReasonEnum.BUSY);
         }
-        // 2. 新建通话
-        return createCall0(userId, reqVO);
+        return call;
     }
     @Override
@@ -769,6 +778,8 @@ public class ImRtcCallServiceImpl implements ImRtcCallService {
                     call.getRoom(), operatorId, reason);
             return;
         }
+        // 【特殊】同步内存 call：让 createCall 这类调用方拿到的 DO 立即反映 ENDED 终态，Controller 拼 RespVO 能直接用
+        call.setStatus(ImRtcCallStatusEnum.ENDED.getStatus()).setEndReason(reason.getReason()).setEndTime(now);
         // 1.2 更新参与表为已结束：残留 INVITING 改 NO_ANSWER；残留 JOINED 改 LEFT 并写 leaveTime
         rtcParticipantMapper.updateByRoomAndStatus(call.getRoom(), ImRtcParticipantStatusEnum.INVITING.getStatus(),
                 new ImRtcParticipantDO().setStatus(ImRtcParticipantStatusEnum.NO_ANSWER.getStatus()));