From 9d212b54be58027f544b5a1b45d9b8954aa976f2 Mon Sep 17 00:00:00 2001
From: meijiali <你的邮箱@xxx.com>
Date: Mon, 6 Jul 2026 14:57:59 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E9=9A=90=E8=97=8F=20Demo=20=E6=A0=87?=
 =?UTF-8?q?=E8=AF=86=E5=B9=B6=E4=BF=AE=E6=AD=A3=E6=97=B6=E9=97=B4=E5=B1=95?=
 =?UTF-8?q?=E7=A4=BA?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/services/task_service.py          |  4 ++-
 app/templates/index.html              |  2 +-
 app/templates/partials/task_rows.html |  3 ---
 app/templates/tasks/detail.html       |  2 +-
 tests/integration/test_routes.py      | 38 ++++++++++++++++++++++++---
 5 files changed, 40 insertions(+), 9 deletions(-)

diff --git a/app/services/task_service.py b/app/services/task_service.py
index ad12a18..42809ad 100644
--- a/app/services/task_service.py
+++ b/app/services/task_service.py
@@ -3,6 +3,7 @@ import json
 from concurrent.futures import ThreadPoolExecutor
 from collections.abc import Callable
 from datetime import UTC, datetime
+from zoneinfo import ZoneInfo
 
 from sqlalchemy import func, select
 from sqlalchemy.orm import Session, sessionmaker
@@ -22,6 +23,7 @@ RUNNING_TASK_MESSAGE = "当前有正在运行的任务，请稍后再试"
 RESTART_ERROR_MESSAGE = "系统重启，任务被中断"
 STALE_PROGRESS_THRESHOLD_SECONDS = 10 * 60
 STALE_PROGRESS_ERROR_TYPE = "stale_progress_timeout"
+DISPLAY_TIMEZONE = ZoneInfo("Asia/Shanghai")
 task_executor = ThreadPoolExecutor(max_workers=1)
 
 
@@ -227,7 +229,7 @@ def calculate_task_display_number(session: Session, task: Task) -> int:
 
 def format_datetime_minute(value: datetime | None) -> str:
     value = ensure_utc_datetime(value)
-    return value.strftime("%Y-%m-%d %H:%M") if value else ""
+    return value.astimezone(DISPLAY_TIMEZONE).strftime("%Y-%m-%d %H:%M") if value else ""
 
 
 def build_task_error_summary(task: Task) -> str | None:
diff --git a/app/templates/index.html b/app/templates/index.html
index 1d7ac51..481fdf3 100644
--- a/app/templates/index.html
+++ b/app/templates/index.html
@@ -56,7 +56,7 @@
   <div class="section-heading">
     <div>
       <p class="section-kicker">任务历史</p>
-      <h2>最近任务与 Demo 数据</h2>
+      <h2>最近任务</h2>
     </div>
     {% if has_running_tasks %}<span class="badge text-bg-warning">自动更新中</span>{% endif %}
   </div>
diff --git a/app/templates/partials/task_rows.html b/app/templates/partials/task_rows.html
index 6fe1cb6..efd1832 100644
--- a/app/templates/partials/task_rows.html
+++ b/app/templates/partials/task_rows.html
@@ -5,9 +5,6 @@
   <tr>
     <td>
       <span class="task-number">{{ task.display_id or loop.index }}</span>
-      {% if task.is_demo %}
-        <br><span class="badge text-bg-info">Demo 数据</span>
-      {% endif %}
     </td>
     <td>{{ task.platform | platform_label }}</td>
     <td>{{ task.created_at_label }}</td>
diff --git a/app/templates/tasks/detail.html b/app/templates/tasks/detail.html
index 09bbe2a..2744221 100644
--- a/app/templates/tasks/detail.html
+++ b/app/templates/tasks/detail.html
@@ -20,7 +20,7 @@
   {% set ai_percent = rate_percent(task.analysis_success_rate) %}
   {% set target_comments = task.hotspot_limit * task.item_limit_per_hotspot * task.comment_limit_per_item %}
   <div class="d-flex flex-wrap justify-content-between gap-3 mb-3">
-    <p class="mb-0">平台：{{ task.platform | platform_label }}{% if task.is_demo %}<span class="badge text-bg-info ms-2">Demo 数据</span>{% endif %}</p>
+    <p class="mb-0">平台：{{ task.platform | platform_label }}</p>
     <p class="mb-0 text-muted">创建时间 {{ task.created_at_label }} · 阶段 {{ task.current_stage_label or "等待启动" }}</p>
   </div>
   <div class="mb-3">
diff --git a/tests/integration/test_routes.py b/tests/integration/test_routes.py
index 76f44a2..6bc3e7b 100644
--- a/tests/integration/test_routes.py
+++ b/tests/integration/test_routes.py
@@ -107,8 +107,9 @@ def test_index_page_uses_short_task_numbers_compact_fields_and_friendly_error_co
     assert "#" not in visible_text
     assert first_id not in visible_text
     assert second_id not in visible_text
-    assert "2026-07-03 10:30" in visible_text
-    assert "2026-07-03 10:35" in visible_text
+    assert "2026-07-03 18:30" in visible_text
+    assert "2026-07-03 18:35" in visible_text
+    assert "Demo 数据" not in visible_text
     assert "5热点 × 5内容 × 50评论" in visible_text
     assert "1热点 × 1内容 × 10评论" in visible_text
     assert "小红书 · 5热点" not in visible_text
@@ -207,7 +208,38 @@ def test_task_detail_uses_short_number_title_and_hides_full_uuid():
     assert task_id not in visible_text
     assert "任务 #33333333-3333-4333-8333-333333333333" not in visible_text
     assert "#" not in visible_text
-    assert "创建时间 2026-07-03 10:30" in visible_text
+    assert "创建时间 2026-07-03 18:30" in visible_text
+    assert "Demo 数据" not in visible_text
+
+
+def test_demo_task_flag_is_kept_but_demo_copy_is_hidden_from_pages():
+    with make_test_client() as (client, engine):
+        from sqlalchemy.orm import Session
+
+        with Session(engine) as session:
+            session.add(
+                Task(
+                    id="demo-task-hidden-copy",
+                    platform="xiaohongshu",
+                    status="success",
+                    created_at=datetime(2026, 7, 3, 10, 30, tzinfo=UTC),
+                    hotspot_limit=1,
+                    item_limit_per_hotspot=1,
+                    comment_limit_per_item=10,
+                )
+            )
+            session.commit()
+
+        index_response = client.get("/")
+        detail_response = client.get("/tasks/demo-task-hidden-copy")
+        api_response = client.get("/api/tasks/demo-task-hidden-copy")
+
+    assert index_response.status_code == 200
+    assert detail_response.status_code == 200
+    assert api_response.status_code == 200
+    assert api_response.json()["is_demo"] is True
+    assert "Demo 数据" not in BeautifulSoup(index_response.text, "html.parser").get_text(" ")
+    assert "Demo 数据" not in BeautifulSoup(detail_response.text, "html.parser").get_text(" ")
 
 
 def test_running_task_detail_page_keeps_polling_after_hotspots_exist():