From b9291f9011923c68242ac8bdcb6f4d1a60bf796b Mon Sep 17 00:00:00 2001
From: meijiali <你的邮箱@xxx.com>
Date: Fri, 3 Jul 2026 12:35:35 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E5=A2=9E=E5=8A=A0=E4=BB=BB=E5=8A=A1?=
 =?UTF-8?q?=E8=AF=A6=E6=83=85=E8=87=AA=E5=8A=A8=E5=88=B7=E6=96=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/static/app.js                | 20 ++++++++++++++++++++
 app/templates/tasks/detail.html  |  5 +++--
 tests/integration/test_routes.py | 27 ++++++++++++++++++++++++++-
 3 files changed, 49 insertions(+), 3 deletions(-)

diff --git a/app/static/app.js b/app/static/app.js
index e515c97..97f6824 100644
--- a/app/static/app.js
+++ b/app/static/app.js
@@ -71,6 +71,26 @@ document.addEventListener("DOMContentLoaded", () => {
   updateScaleHint();
 });
 
+function pollTaskDetailStatus(taskId) {
+  if (!taskId) return;
+  const intervalMs = 3000;
+  const poll = async () => {
+    try {
+      const resp = await fetch(`/api/tasks/${taskId}`, { cache: "no-store" });
+      if (!resp.ok) return;
+      const task = await resp.json();
+      if (task.status !== "running") {
+        window.location.reload();
+        return;
+      }
+    } catch (_error) {
+      return;
+    }
+    window.setTimeout(poll, intervalMs);
+  };
+  window.setTimeout(poll, intervalMs);
+}
+
 async function downloadExport(url, defaultFilename, event) {
   if (event) event.preventDefault();
   const resp = await fetch(url);
diff --git a/app/templates/tasks/detail.html b/app/templates/tasks/detail.html
index 32f2e9a..65ea078 100644
--- a/app/templates/tasks/detail.html
+++ b/app/templates/tasks/detail.html
@@ -9,9 +9,9 @@
 {% block content %}
 <div class="d-flex justify-content-between align-items-center mb-3">
   <h1 class="h3 mb-0">任务 #{{ task.id }}</h1>
-  <button class="btn btn-outline-secondary btn-sm" onclick="window.location.href='/'">手动刷新</button>
+  <button class="btn btn-outline-secondary btn-sm" onclick="window.location.reload()">手动刷新</button>
 </div>
-<section class="card mb-4"><div class="card-body">
+<section class="card mb-4" {% if task.status == "running" %}data-task-id="{{ task.id }}" data-auto-poll="true"{% endif %}><div class="card-body">
   {% set label, cls = status_badge_config(task.status) %}
   <p>平台：{{ task.platform | platform_label }} <span class="badge {{ cls }}">{{ label }}</span></p>
   <p>成功 {{ task.successful_items_count }} / 共 {{ task.total_items_count }} 条内容</p>
@@ -19,6 +19,7 @@
 </div></section>
 {% if task.status == "running" and not hotspots %}
 <div class="text-center text-muted py-5"><div class="spinner-border text-warning mb-3"></div><p>正在抓取热点数据，请稍候...</p></div>
+<script>pollTaskDetailStatus("{{ task.id }}");</script>
 {% endif %}
 <div class="accordion" id="hotspot-list">
 {% for hotspot in hotspots %}
diff --git a/tests/integration/test_routes.py b/tests/integration/test_routes.py
index 6883455..d92c652 100644
--- a/tests/integration/test_routes.py
+++ b/tests/integration/test_routes.py
@@ -42,6 +42,31 @@ def test_index_page_lists_existing_tasks():
     assert "运行中" in response.text
 
 
+def test_running_task_detail_page_auto_polls_current_task():
+    with make_test_client() as (client, engine):
+        from sqlalchemy.orm import Session
+
+        with Session(engine) as session:
+            session.add(
+                Task(
+                    id="task-running",
+                    platform="xiaohongshu",
+                    status="running",
+                    hotspot_limit=1,
+                    item_limit_per_hotspot=1,
+                    comment_limit_per_item=10,
+                )
+            )
+            session.commit()
+
+        response = client.get("/tasks/task-running")
+
+    assert response.status_code == 200
+    assert 'data-task-id="task-running"' in response.text
+    assert "pollTaskDetailStatus" in response.text
+    assert 'onclick="window.location.reload()"' in response.text
+
+
 def seed_result_data(engine):
     from sqlalchemy.orm import Session
 
@@ -119,7 +144,7 @@ def test_result_pages_render_seeded_data():
 
     assert task_response.status_code == 200
     assert "热点标题" in task_response.text
-    assert 'onclick="window.location.href=\'/\'"' in task_response.text
+    assert 'onclick="window.location.reload()"' in task_response.text
     assert hotspot_response.status_code == 200
     assert "热点总结" in hotspot_response.text
     assert item_response.status_code == 200