From 9cc03ee7498518b2b86bca97e18f19600ec76bf2 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=90=B4=E6=96=87=E5=B3=B0?= <kevin@lmve.net>
Date: Fri, 10 Apr 2026 15:21:56 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E5=88=B7=E7=9B=98=E6=98=BE?=
 =?UTF-8?q?=E7=A4=BA?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/api.js              |  7 +++++++
 src/views/Dashboard.vue | 10 ++++++++--
 2 files changed, 15 insertions(+), 2 deletions(-)

diff --git a/src/api.js b/src/api.js
index e3f24c3..ae2b42a 100644
--- a/src/api.js
+++ b/src/api.js
@@ -47,6 +47,13 @@ export async function flushIndex() {
   return data
 }
 
+export async function fetchFlushStatus() {
+  const { data } = await axios.get(`${BASE}/admin/flush/status`, {
+    timeout: 5000,
+  })
+  return data
+}
+
 export async function fetchWorkers() {
   const { data } = await axios.get(`${BASE}/admin/workers`, {
     timeout: 10000,
diff --git a/src/views/Dashboard.vue b/src/views/Dashboard.vue
index e235afc..76a30da 100644
--- a/src/views/Dashboard.vue
+++ b/src/views/Dashboard.vue
@@ -1,6 +1,6 @@
 <script setup>
 import { ref, onMounted, onUnmounted } from 'vue'
-import { fetchStats, flushIndex, fetchWorkers, setWorkers, fetchBacklink, triggerBacklink, fetchPriorityStatus } from '../api.js'
+import { fetchStats, flushIndex, fetchFlushStatus, fetchWorkers, setWorkers, fetchBacklink, triggerBacklink, fetchPriorityStatus } from '../api.js'
 
 const stats = ref(null)
 const loading = ref(true)
@@ -131,7 +131,13 @@ async function doFlush() {
   flushing.value = true
   try {
     await flushIndex()
-    // 重新拉取 stats，pending 应该归零
+    // 轮询刷盘状态，直到完成
+    while (true) {
+      await new Promise(r => setTimeout(r, 500)) // 等待 500ms
+      const status = await fetchFlushStatus()
+      if (!status.flushing) break
+    }
+    // 刷盘完成，重新拉取 stats
     stats.value = await fetchStats()
   } catch (e) {
     error.value = '刷盘失败: ' + e.message