From 8329a6a885351e6ac9ba3191151f3d62b2c25499 Mon Sep 17 00:00:00 2001
From: YunaiV <zhijiantianya@gmail.com>
Date: Mon, 18 May 2026 09:45:32 +0800
Subject: [PATCH] =?UTF-8?q?=E2=9C=A8=20feat(im):=20=E6=8C=AF=E9=93=83?=
 =?UTF-8?q?=E8=B6=85=E6=97=B6=20Job=20=E5=8D=95=E4=BA=BA=E7=B2=92=E5=BA=A6?=
 =?UTF-8?q?=E6=A0=87=20NO=5FANSWER=20+=20=E7=8B=AC=E7=AB=8B=20NO=5FANSWER?=
 =?UTF-8?q?=20=E4=BF=A1=E4=BB=A4=E6=8E=A8=E9=80=81=20=E2=9C=A8=20feat(im):?=
 =?UTF-8?q?=20=E5=A4=84=E7=90=86=20RTC=5FCALL(NO=5FANSWER)=20=E4=BF=A1?=
 =?UTF-8?q?=E4=BB=A4=EF=BC=9B=E7=A7=81=E8=81=8A=E6=B0=94=E6=B3=A1=E6=98=BE?=
 =?UTF-8?q?=E7=A4=BA=E3=80=8C=E6=9C=AA=E6=8E=A5=E5=90=AC=E3=80=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/api/im/home/rtc/index.ts                  |  6 +--
 .../home/components/rtc/RtcCallContainer.vue  | 41 +++++++++++++++++--
 src/views/im/utils/config.ts                  |  8 ++++
 3 files changed, 48 insertions(+), 7 deletions(-)

diff --git a/src/api/im/home/rtc/index.ts b/src/api/im/home/rtc/index.ts
index 91989fa5a..61b56c923 100644
--- a/src/api/im/home/rtc/index.ts
+++ b/src/api/im/home/rtc/index.ts
@@ -74,9 +74,9 @@ export const leaveCall = (room: string) => {
   return request.post<boolean>({ url: '/im/rtc/leave', params: { room } })
 }
 
-// 重新签发 Token；客户端重连或 Token 过期续期
-export const refreshCallToken = (room: string) => {
-  return request.get<ImRtcCallRespVO>({ url: '/im/rtc/refresh-token', params: { room } })
+// 振铃超时检查；RUNNING 端 timer 兜底，触发后端立即扫描该 room 的超时 INVITING（接口静默）
+export const noAnswerCallCheck = (room: string) => {
+  return request.post<boolean>({ url: '/im/rtc/no-answer-call-check', params: { room } })
 }
 
 // 查询当前进行中的通话；目前仅群聊场景（胶囊条），返回 null 表示无活跃通话
diff --git a/src/views/im/home/components/rtc/RtcCallContainer.vue b/src/views/im/home/components/rtc/RtcCallContainer.vue
index 90d636216..de6c430af 100644
--- a/src/views/im/home/components/rtc/RtcCallContainer.vue
+++ b/src/views/im/home/components/rtc/RtcCallContainer.vue
@@ -56,6 +56,7 @@
 
 <script lang="ts" setup>
 import { computed, ref, watch } from 'vue'
+import { useIntervalFn } from '@vueuse/core'
 import { useMessage } from '@/hooks/web/useMessage'
 import { useRtcStore } from '../../store/rtcStore'
 import { useLiveKitRoom } from '../../composables/useLiveKitRoom'
@@ -64,13 +65,15 @@ import {
   rejectCall,
   acceptCall,
   leaveCall,
-  inviteCall
+  inviteCall,
+  noAnswerCallCheck
 } from '@/api/im/home/rtc'
 import {
   ImRtcCallMediaType,
   ImRtcCallStage,
   ImConversationType
 } from '@/views/im/utils/constants'
+import { RTC_NO_ANSWER_CALL_CHECK_INTERVAL_MS } from '@/views/im/utils/config'
 import { getCurrentUserId } from '@/views/im/utils/storage'
 import { getSenderAvatar, getSenderDisplayName } from '@/views/im/utils/user'
 import { Track } from 'livekit-client'
@@ -363,9 +366,39 @@ async function handleHangup() {
 
 /** LiveKit Room 异常断开；多见于网络中断 */
 function handlePeerDisconnected() {
-  if (!rtcStore.isActive) return
-  message.warning('通话已断开')
-  rtcStore.reset()
+  if (!rtcStore.isActive) {
+    return
+  }
+  // 给 RTC_CALL_END WebSocket 推送一个小窗口；私聊超时 / 主动挂断等场景下，后端 endSession 会先推 RTC_CALL_END，
+  // 让前端按业务语义（"对方未接听" / "已取消" 等）reset，避免错把业务断开 toast 成「通话已断开」
+  setTimeout(() => {
+    if (!rtcStore.isActive) {
+      return
+    }
+    message.warning('通话已断开')
+    rtcStore.reset()
+  }, 100)
+}
+
+// ==================== 振铃超时兜底 ====================
+
+/** 通话存活期间（INVITING / INCOMING / RUNNING）周期性触发后端扫该 room 的超时 INVITING；保持 timer 是为了 inviteCall 追加新人后也能覆盖；阈值由后端配置决定，前端只负责 trigger */
+const { resume: resumeNoAnswerTimer, pause: pauseNoAnswerTimer } = useIntervalFn(
+  triggerNoAnswerCallCheck, RTC_NO_ANSWER_CALL_CHECK_INTERVAL_MS, { immediate: false }
+)
+watch(
+  () => rtcStore.isActive,
+  (active) => (active ? resumeNoAnswerTimer() : pauseNoAnswerTimer()),
+  { immediate: true }
+)
+
+/** 本地仍有 pending 才调；INVITING / RUNNING 取 call、INCOMING 取 incomingPayload；接口静默错误 fire-and-forget */
+function triggerNoAnswerCallCheck() {
+  const source = rtcStore.call ?? rtcStore.incomingPayload
+  if (!source?.room || !source.inviteeIds?.length) {
+    return
+  }
+  noAnswerCallCheck(source.room).catch(() => undefined)
 }
 
 // ==================== 设备控制 ====================
diff --git a/src/views/im/utils/config.ts b/src/views/im/utils/config.ts
index 62c424afc..c74359d8b 100644
--- a/src/views/im/utils/config.ts
+++ b/src/views/im/utils/config.ts
@@ -75,3 +75,11 @@ export const MESSAGE_MERGE_PREVIEW_LINES = 3
 
 /** 最近转发会话 key 列表的最大保留数量（对齐微信 PC 横向头像区可见容量） */
 export const CONVERSATION_RECENT_FORWARD_MAX = 12
+
+// ==================== 前端独有：RTC 通话兜底 ====================
+
+/**
+ * 振铃超时兜底；通话存活期间 timer 调用 noAnswerCallCheck 接口的间隔；
+ * 实际超时阈值由后端 yudao.im.rtc.invite-timeout-minutes 决定，前端仅决定触发频率
+ */
+export const RTC_NO_ANSWER_CALL_CHECK_INTERVAL_MS = 60 * 1000