From 7614696e61268c5feedf7490f5b2c4de6d7efb7d Mon Sep 17 00:00:00 2001
From: jxxghp <jxxghp@gmail.com>
Date: Wed, 20 May 2026 12:36:41 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E5=A4=8D=E6=99=BA=E8=83=BD?=
 =?UTF-8?q?=E6=8E=A8=E8=8D=90=E6=8C=89=E9=92=AE=E5=88=9D=E5=A7=8B=E4=B8=8D?=
 =?UTF-8?q?=E5=8F=AF=E7=94=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/pages/resource.vue | 20 +++++++++++++++++---
 1 file changed, 17 insertions(+), 3 deletions(-)

diff --git a/src/pages/resource.vue b/src/pages/resource.vue
index 281747a5..25fb6626 100644
--- a/src/pages/resource.vue
+++ b/src/pages/resource.vue
@@ -294,6 +294,7 @@ const streamPreviewLimit = 24
 const streamUiFlushDelay = 1000
 const streamPreviewBufferLimit = streamPreviewLimit * 4
 const searchStreamIdleTimeout = 90_000
+const searchStreamDoneCloseDelay = 1500
 
 const streamTotalCount = ref(0)
 const streamPreviewDataList = ref<Array<Context>>([])
@@ -663,6 +664,7 @@ function searchByStream(params: SearchParams, requestToken?: string) {
     closeSearchEventSource()
 
     let settled = false
+    let receivedDone = false
     const source = new EventSource(buildSearchStreamUrl(params, requestToken))
     searchEventSource = source
 
@@ -697,7 +699,12 @@ function searchByStream(params: SearchParams, requestToken?: string) {
         }
 
         if (eventData.type === 'done') {
-          settleSearchStream(resolve)
+          // 收到 done 后给后端留出收尾时间，避免过早关闭连接中断搜索结果缓存写入
+          receivedDone = true
+          clearSearchStreamIdleTimer()
+          searchStreamIdleTimer = setTimeout(() => {
+            settleSearchStream(resolve)
+          }, searchStreamDoneCloseDelay)
         }
       } catch (error) {
         settleSearchStream(() => reject(error))
@@ -707,6 +714,11 @@ function searchByStream(params: SearchParams, requestToken?: string) {
     source.onerror = () => {
       if (source !== searchEventSource || settled) return
 
+      if (receivedDone) {
+        settleSearchStream(resolve)
+        return
+      }
+
       settleSearchStream(() => reject(new Error(t('resource.noResourceFound'))))
     }
   })
@@ -1014,8 +1026,8 @@ async function checkAiRecommendStatus() {
     const { success, data } = result
     const status = data?.status
 
-    // 只要有数据且状态不是disabled，就标记已检查（允许重试）
-    if (data && status !== 'disabled') {
+    // 状态检查只是初始化已有推荐结果，非禁用状态下即使后端暂无历史状态也不应锁住按钮
+    if (status !== 'disabled') {
       aiStatusChecked.value = true
     }
 
@@ -1035,6 +1047,8 @@ async function checkAiRecommendStatus() {
     }
   } catch (error) {
     console.error('检查AI状态失败:', error)
+    // 检查失败不影响用户手动发起智能推荐，避免按钮永久不可用
+    aiStatusChecked.value = true
   }
 }