✨ feat(im): 通话事件接入会话列表预览（私聊补 START 入消息流）；文案统一「语音通话」

YunaiV
1 parent dc081cfd
Showing 4 changed files with 44 additions and 29 deletions
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/enums/message/ImMessageTypeEnum.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/service/rtc/ImRtcCallServiceImpl.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/service/websocket/dto/notification/rtc/ImRtcCallEndNotification.java
yudao-module-im/src/main/java/cn/iocoder/yudao/module/im/service/websocket/dto/notification/rtc/ImRtcCallStartNotification.java
@@ -101,7 +101,8 @@ public enum ImMessageTypeEnum implements ArrayValuable&lt;Integer&gt; {
     /**
      * 对应 OpenIM：无（自有扩展，OpenIM 通话事件不入消息流）
      * 对应自己的类：ImRtcCallStartNotification
-     * 场景：群通话开始；入 im_group_message + 全群广播；前端渲染聊天 tip「{inviterNickname} 发起了{voice/video}通话」
+     * 场景：通话开始；群聊入 im_group_message 全群广播，前端渲染聊天 tip「{inviterNickname} 发起了语音通话」；
+     * 私聊入 im_private_message 定向给被叫，仅用于会话列表预览展示「[语音通话]」（不渲染聊天 tip）
      * <p>
      * 与 RTC_CALL_END(1611) 两段式配对：START 一定先于 END 入库（START 在 invite 接口事务里、END 在 cancel/leave 接口事务里，自然按请求顺序串行）
      */
@@ -109,9 +110,9 @@ public enum ImMessageTypeEnum implements ArrayValuable&lt;Integer&gt; {
     /**
      * 对应 OpenIM：无（自有扩展，OpenIM 通话事件不入消息流）
      * 对应自己的类：ImRtcCallEndNotification
-     * 场景：通话结束；入 im_private_message / im_group_message；私聊渲染准气泡，群聊渲染 tip「{voice/video}通话已结束 [时长 X]」
+     * 场景：通话结束；入 im_private_message / im_group_message；私聊渲染准气泡，群聊渲染 tip「语音通话已经结束」
      * <p>
-     * 群通话两段式配对前导是 RTC_CALL_START(1610)；私聊场景没有 START，单 END 准气泡承载完整生命周期
+     * 与 RTC_CALL_START(1610) 两段式配对
      */
     RTC_CALL_END(1611, "通话结束", true, false),
@@ -234,10 +234,8 @@ public class ImRtcCallServiceImpl implements ImRtcCallService {
         for (Long inviteeId : invitees) {
             pushCallInviteNotification(call, inviterUser, inviteeId, inviteeMap.get(inviteeId), invitees);
         }
-        // 3.2 群通话再向全群广播 RTC_CALL_START 入聊天流
-        if (ImConversationTypeEnum.isGroup(reqVO.getConversationType())) {
-            pushCallStartNotification(call, inviterUser);
-        }
+        // 3.2 向消息流写入 RTC_CALL_START；群聊全群广播，私聊定向给被叫，作为会话列表预览的依据
+        pushCallStartNotification(call, inviterUser, invitees);
         return call;
     }
@@ -891,16 +889,18 @@ public class ImRtcCallServiceImpl implements ImRtcCallService {
     }
     /**
-     * RTC_CALL_START：仅群通话场景；走 imGroupMessageService.send，入 im_group_message 全群广播；与 RTC_CALL_END 两段式配对
+     * RTC_CALL_START：群聊走 imGroupMessageService.send 全群广播；私聊走 imPrivateMessageService.send 定向给被叫
+     * <p>
+     * 私聊 peer 直接复用 createCall 解析好的 invitees，避免再查参与表；用于会话列表预览展示「[语音通话]」
      *
-     * @param call    通话主表
-     * @param inviter 发起人；可空
+     * @param call     通话主表
+     * @param inviter  发起人；可空
+     * @param invitees 本次邀请池；私聊场景取首个作为 peer
      */
-    private void pushCallStartNotification(ImRtcCallDO call, AdminUserRespDTO inviter) {
+    private void pushCallStartNotification(ImRtcCallDO call, AdminUserRespDTO inviter, Set<Long> invitees) {
         ImRtcCallStartNotification payload = ImRtcCallStartNotification.of(call, inviter);
-        ImGroupMessageSendDTO dto = new ImGroupMessageSendDTO().setGroupId(call.getGroupId())
-                .setType(ImMessageTypeEnum.RTC_CALL_START.getType()).setContent(payload);
-        groupMessageService.sendGroupMessage(call.getInviterUserId(), dto);
+        Long peerUserId = ImConversationTypeEnum.isGroup(call.getConversationType()) ? null : CollUtil.getFirst(invitees);
+        pushCallChatMessage(call, ImMessageTypeEnum.RTC_CALL_START, payload, peerUserId);
     }
     /**
@@ -917,23 +917,37 @@ public class ImRtcCallServiceImpl implements ImRtcCallService {
                              Long durationSeconds) {
         AdminUserRespDTO operator = operatorId != null ? adminUserApi.getUser(operatorId) : null;
         ImRtcCallEndNotification payload = ImRtcCallEndNotification.of(call, reason, durationSeconds, operatorId, operator);
-        Long senderId = call.getInviterUserId();
+        Long peerUserId = null;
+        if (!ImConversationTypeEnum.isGroup(call.getConversationType())) {
+            ImRtcParticipantDO peer = CollUtil.findOne(
+                    rtcParticipantMapper.selectListByRoom(call.getRoom()),
+                    p -> ObjUtil.notEqual(p.getUserId(), call.getInviterUserId()));
+            peerUserId = peer != null ? peer.getUserId() : null;
+        }
+        pushCallChatMessage(call, ImMessageTypeEnum.RTC_CALL_END, payload, peerUserId);
+    }
-        // 群聊：发起人总是 sender；receiver = 全群；走 imGroupMessageService.send 全群广播
+    /**
+     * RTC 通话事件入消息流：群聊走 groupMessageService 全群广播，私聊走 privateMessageService 定向给 peer
+     * <p>
+     * senderId 固定取 inviterUserId，让前端按「谁发起」决定气泡左右；私聊 peer 缺失时降级为发给自己作兜底
+     *
+     * @param call       通话主表
+     * @param type       消息类型；RTC_CALL_START / RTC_CALL_END
+     * @param payload    推送 payload
+     * @param peerUserId 私聊对端用户编号；群聊忽略，私聊缺失时回退为 senderId
+     */
+    private void pushCallChatMessage(ImRtcCallDO call, ImMessageTypeEnum type, Object payload, Long peerUserId) {
+        Long senderId = call.getInviterUserId();
         if (ImConversationTypeEnum.isGroup(call.getConversationType())) {
             ImGroupMessageSendDTO dto = new ImGroupMessageSendDTO().setGroupId(call.getGroupId())
-                    .setType(ImMessageTypeEnum.RTC_CALL_END.getType()).setContent(payload);
+                    .setType(type.getType()).setContent(payload);
             groupMessageService.sendGroupMessage(senderId, dto);
             return;
         }
-
-        // 私聊：发起人总是 sender；receiver = 通话另一方
-        ImRtcParticipantDO peer = CollUtil.findOne(
-                rtcParticipantMapper.selectListByRoom(call.getRoom()),
-                p -> ObjUtil.notEqual(p.getUserId(), senderId));
-        Long receiverId = peer != null ? peer.getUserId() : senderId;
+        Long receiverId = peerUserId != null ? peerUserId : senderId;
         ImPrivateMessageSendDTO dto = new ImPrivateMessageSendDTO().setReceiverId(receiverId)
-                .setType(ImMessageTypeEnum.RTC_CALL_END.getType()).setContent(payload);
+                .setType(type.getType()).setContent(payload);
         privateMessageService.sendPrivateMessage(senderId, dto);
     }
@@ -11,10 +11,10 @@ import lombok.Data;
  * 入 im_private_message / im_group_message；接收方关闭通话窗 + 渲染聊天 tip
  * <p>
  * 文案分场景：
- * 群聊：「{voice/video}通话已结束 [时长 X]」；发起人信息走配对的 {@link ImRtcCallStartNotification}
+ * 群聊：「语音通话已经结束」；发起人信息走配对的 {@link ImRtcCallStartNotification}
  * 私聊：仿微信准气泡，按 endReason × selfSend 视角转换文案（HANGUP / CANCEL / REJECT / BUSY / ERROR）
  * <p>
- * 与 {@link ImRtcCallStartNotification} 两段式配对（仅群通话）：START 在 invite 事务里 INSERT，END 在 cancel / leave 事务里 INSERT；
+ * 与 {@link ImRtcCallStartNotification} 两段式配对：START 在 invite 事务里 INSERT，END 在 cancel / leave 事务里 INSERT；
  * 两段位于不同请求 / 事务，自增 id 保证聊天流顺序
  *
  * @author 芋道源码
@@ -7,13 +7,13 @@ import lombok.Data;
 /**
  * RTC_CALL_START 通话开始通知
  * <p>
- * 仅群通话场景；入 im_group_message + 全群广播；前端渲染聊天 tip「{inviterNickname} 发起了{voice/video}通话」
+ * 群聊入 im_group_message 全群广播；前端渲染聊天 tip「{inviterNickname} 发起了语音通话」
+ * <p>
+ * 私聊入 im_private_message 定向给被叫；前端不渲染聊天 tip，仅用于会话列表预览展示「[语音通话]」（刷新后仍可见）
  * <p>
  * 与 {@link ImRtcCallEndNotification} 两段式配对：
  * START 在 invite 接口事务里 INSERT，END 在 cancel / leave 接口事务里 INSERT，
  * 两段位于不同请求 / 事务，自增 id 保证聊天流顺序；后续如果合并到同一事务里 push，需要额外保证 START 先于 END
- * <p>
- * 私聊场景没有 START（单 END 准气泡足够），本通知不会用于 conversationType=PRIVATE
  *
  * @author 芋道源码
  */