From 5850a6056175c61c20395bbdafae22f41b50b7f4 Mon Sep 17 00:00:00 2001
From: claude_dev <claude-dev@sanguo.local>
Date: Fri, 14 Aug 2026 08:29:20 +0800
Subject: [PATCH] =?UTF-8?q?feat(api+web):=20=E4=BB=BB=E5=8A=A1=E5=88=97?=
 =?UTF-8?q?=E8=A1=A8=E7=AE=A1=E7=90=86(=E9=AA=8C=E6=94=B6=E5=9B=9B?=
 =?UTF-8?q?=E8=BD=AE=E6=89=B91):=E5=8E=86=E5=8F=B2=E4=BB=BB=E5=8A=A1?=
 =?UTF-8?q?=E2=86=92=E4=BB=BB=E5=8A=A1=E5=88=97=E8=A1=A8=E6=94=B9=E5=90=8D?=
 =?UTF-8?q?;DELETE=20/task/{id}=E5=8D=95/=E6=89=B9=E5=88=A0=E9=99=A4(?=
 =?UTF-8?q?=E8=BF=9B=E8=A1=8C=E4=B8=AD=E6=8B=92=E5=88=A0);GET=20/task/{id}?=
 =?UTF-8?q?/params=E5=8F=82=E6=95=B0=E5=9B=9E=E6=94=BE+=E7=82=B9=E4=BB=BB?=
 =?UTF-8?q?=E5=8A=A1ID=E8=B7=B3=E5=8F=82=E6=95=B0=E9=A1=B5=E9=A2=84?=
 =?UTF-8?q?=E5=A1=AB;=E7=9C=9F=E5=88=9B=E5=BB=BA=E6=97=B6=E9=97=B4+?=
 =?UTF-8?q?=E8=80=97=E6=97=B6=E5=88=97(=E6=8F=90=E4=BA=A4=E5=8D=B3?=
 =?UTF-8?q?=E8=AE=B0,=E8=BF=9B=E8=A1=8C=E4=B8=AD=E6=B4=BB=E8=AE=A1?=
 =?UTF-8?q?=E6=97=B6);=E8=BF=9B=E8=A1=8C=E4=B8=AD=E7=A6=81=E6=9F=A5?=
 =?UTF-8?q?=E7=9C=8B;=E7=BB=84=E5=90=88=E4=BB=BB=E5=8A=A1params=E5=85=A8?=
 =?UTF-8?q?=E9=87=8F=E5=AD=98=20[nas]?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 frontend/src/api/backtest.ts                  |  24 +++
 frontend/src/views/Dashboard.vue              |   2 +-
 frontend/src/views/Layout.vue                 |   6 +-
 frontend/src/views/backtest/History.vue       | 154 ++++++++++++++--
 frontend/src/views/backtest/New.vue           |  19 +-
 .../src/views/backtest/PortfolioBacktest.vue  |  28 ++-
 sanguo_api/routes.py                          |  93 +++++++++-
 sanguo_orchestrator/portfolio_worker.py       |  12 +-
 sanguo_orchestrator/runner.py                 |  14 ++
 tests/api/test_task_list_management.py        | 174 ++++++++++++++++++
 10 files changed, 499 insertions(+), 27 deletions(-)
 create mode 100644 tests/api/test_task_list_management.py

diff --git a/frontend/src/api/backtest.ts b/frontend/src/api/backtest.ts
index 725b92d..82a77f8 100644
--- a/frontend/src/api/backtest.ts
+++ b/frontend/src/api/backtest.ts
@@ -105,6 +105,9 @@ export interface TaskListItem {
   start: string
   end: string
   instance?: string
+  created_at?: string
+  finished_at?: string
+  duration_s?: number | null
 }
 
 export async function getTasks(type?: string): Promise<TaskListItem[]> {
@@ -112,6 +115,27 @@ export async function getTasks(type?: string): Promise<TaskListItem[]> {
   return data.tasks
 }
 
+export interface TaskParamsInfo {
+  task_id: string
+  type: string
+  status: string
+  strategy: string
+  symbol: string
+  params: Record<string, unknown>
+  start: string
+  end: string
+}
+
+export async function getTaskParams(taskId: string): Promise<TaskParamsInfo> {
+  const { data } = await apiClient.get<TaskParamsInfo>(`/task/${taskId}/params`)
+  return data
+}
+
+export async function deleteTask(taskId: string): Promise<{ deleted: number }> {
+  const { data } = await apiClient.delete<{ deleted: number }>(`/task/${taskId}`)
+  return data
+}
+
 export interface OptimizeSubmit {
   symbol: string
   strategy: string
diff --git a/frontend/src/views/Dashboard.vue b/frontend/src/views/Dashboard.vue
index f26d5ad..78179b6 100644
--- a/frontend/src/views/Dashboard.vue
+++ b/frontend/src/views/Dashboard.vue
@@ -33,7 +33,7 @@ const quickActions = [
   { label: '新建回测', desc: 'CTA 策略历史回测', path: '/backtest/new', mark: 'BT' },
   { label: '因子分析', desc: 'IC / 分层回测', path: '/factor/new', mark: 'FA' },
   { label: '新建模拟盘', desc: '回放 / 实盘模式', path: '/paper/new', mark: 'PA' },
-  { label: '历史任务', desc: '全部回测记录', path: '/backtest/history', mark: 'HI' },
+  { label: '任务列表', desc: '全部回测记录', path: '/backtest/history', mark: 'HI' },
 ] as const
 
 function go(path: string): void {
diff --git a/frontend/src/views/Layout.vue b/frontend/src/views/Layout.vue
index 3ae0122..5cc6cad 100644
--- a/frontend/src/views/Layout.vue
+++ b/frontend/src/views/Layout.vue
@@ -25,7 +25,7 @@ const PAGE_TITLE: Array<{ match: RegExp; group: string; title: string }> = [
   { match: /^\/backtest\/new$/, group: '回测', title: '个股回测' },
   { match: /^\/backtest\/portfolio$/, group: '回测', title: '组合回测' },
   { match: /^\/backtest\/optimize$/, group: '回测', title: '参数优化' },
-  { match: /^\/backtest\/history$/, group: '回测', title: '历史任务' },
+  { match: /^\/backtest\/history$/, group: '回测', title: '任务列表' },
   { match: /^\/backtest\/progress\//, group: '回测', title: '任务进度' },
   { match: /^\/backtest\/result\//, group: '回测', title: '回测结果' },
   { match: /^\/factor\/new$/, group: '投研', title: '因子分析' },
@@ -64,7 +64,7 @@ const CMD_ITEMS: CmdItem[] = [
   { label: '个股回测', group: '回测', path: '/backtest/new' },
   { label: '组合回测', group: '回测', path: '/backtest/portfolio' },
   { label: '参数优化', group: '回测', path: '/backtest/optimize' },
-  { label: '历史任务', group: '回测', path: '/backtest/history' },
+  { label: '任务列表', group: '回测', path: '/backtest/history' },
   { label: '因子分析', group: '投研', path: '/factor/new' },
   { label: '模拟盘列表', group: '模拟', path: '/paper' },
   { label: '新建模拟盘', group: '模拟', path: '/paper/new' },
@@ -164,7 +164,7 @@ function onLogout(): void {
           <el-menu-item index="/backtest/new">个股回测</el-menu-item>
           <el-menu-item index="/backtest/portfolio">组合回测</el-menu-item>
           <el-menu-item index="/backtest/optimize">参数优化</el-menu-item>
-          <el-menu-item index="/backtest/history">历史任务</el-menu-item>
+          <el-menu-item index="/backtest/history">任务列表</el-menu-item>
         </el-sub-menu>
         <el-sub-menu index="factor">
           <template #title><span class="nav-label">投研</span></template>
diff --git a/frontend/src/views/backtest/History.vue b/frontend/src/views/backtest/History.vue
index f457d70..2ec6fee 100644
--- a/frontend/src/views/backtest/History.vue
+++ b/frontend/src/views/backtest/History.vue
@@ -1,20 +1,25 @@
 <script setup lang="ts">
 import { ref, computed, watch, onMounted, onUnmounted } from 'vue'
 import { useRouter } from 'vue-router'
-import { ElMessage } from 'element-plus'
-import { getTasks, type TaskListItem } from '@/api/backtest'
+import { ElMessage, ElMessageBox } from 'element-plus'
+import { getTasks, getTaskParams, deleteTask, type TaskListItem } from '@/api/backtest'
 
 const router = useRouter()
 const tasks = ref<TaskListItem[]>([])
 const loading = ref(false)
+const deleting = ref(false)
+const selection = ref<TaskListItem[]>([])
 
 // 筛选
 const typeFilter = ref<'all' | 'cta' | 'portfolio' | 'optimize' | 'factor'>('all')
-const statusFilter = ref<'all' | 'done' | 'failed'>('all')
+const statusFilter = ref<'all' | 'done' | 'failed' | 'all-active'>('all')
 const keyword = ref('')
 // 分页
 const page = ref(1)
 const pageSize = 20
+// 耗时列的活秒表(进行中任务实时计时)
+const nowTick = ref(Date.now())
+let tickTimer: ReturnType<typeof setInterval> | null = null
 
 const typeOptions = [
   { key: 'all', label: '全部' },
@@ -28,12 +33,14 @@ const statusOptions = [
   { key: 'all', label: '全部状态' },
   { key: 'done', label: '完成' },
   { key: 'failed', label: '失败' },
+  { key: 'all-active', label: '进行中' },
 ] as const
 
 const filtered = computed(() => {
   let list = tasks.value
   if (typeFilter.value !== 'all') list = list.filter((t) => t.type === typeFilter.value)
-  if (statusFilter.value !== 'all') list = list.filter((t) => t.status === statusFilter.value)
+  if (statusFilter.value === 'all-active') list = list.filter((t) => isActive(t))
+  else if (statusFilter.value !== 'all') list = list.filter((t) => t.status === statusFilter.value)
   const kw = keyword.value.trim().toLowerCase()
   if (kw) {
     list = list.filter(
@@ -57,6 +64,18 @@ const counts = computed(() => ({
   failed: tasks.value.filter((t) => t.status === 'failed').length,
 }))
 
+function isActive(t: TaskListItem): boolean {
+  return t.status === 'running' || t.status === 'pending'
+}
+// 可跳参数页回放的类型(其余类型无对应表单)
+function canReplay(t: TaskListItem): boolean {
+  return !isActive(t) && (t.type === 'cta' || t.type === 'portfolio')
+}
+// 终态(可删/可看结果)
+function isTerminal(t: TaskListItem): boolean {
+  return t.status === 'done' || t.status === 'failed'
+}
+
 // 筛选变化回到第一页
 watch([typeFilter, statusFilter, keyword], () => {
   page.value = 1
@@ -64,16 +83,18 @@ watch([typeFilter, statusFilter, keyword], () => {
 
 onMounted(async () => {
   await load()
-  startAutoRefresh()
 })
-onUnmounted(stopAutoRefresh)
+onUnmounted(() => {
+  stopAutoRefresh()
+  stopTick()
+})
 
 async function load(): Promise<void> {
   loading.value = true
   try {
     tasks.value = await getTasks()
   } catch {
-    ElMessage.error('历史加载失败')
+    ElMessage.error('任务列表加载失败')
   } finally {
     loading.value = false
     startAutoRefresh()
@@ -83,7 +104,7 @@ async function load(): Promise<void> {
 // 自动刷新:有 running/pending 任务时每 3s 静默拉取,全部终态后停(GitHub Actions 模式)
 let refreshTimer: ReturnType<typeof setInterval> | null = null
 function hasActive(): boolean {
-  return tasks.value.some((t) => t.status === 'running' || t.status === 'pending')
+  return tasks.value.some((t) => isActive(t))
 }
 async function silentRefresh(): Promise<void> {
   try {
@@ -91,12 +112,20 @@ async function silentRefresh(): Promise<void> {
   } catch {
     /* ignore */
   }
-  if (!hasActive()) stopAutoRefresh()
+  if (!hasActive()) {
+    stopAutoRefresh()
+    stopTick()
+  }
 }
 function startAutoRefresh(): void {
   stopAutoRefresh()
   if (hasActive()) {
     refreshTimer = setInterval(silentRefresh, 3000)
+    // 耗时列活计时(1s 一跳,仅视觉)
+    nowTick.value = Date.now()
+    tickTimer = setInterval(() => {
+      nowTick.value = Date.now()
+    }, 1000)
   }
 }
 function stopAutoRefresh(): void {
@@ -105,14 +134,65 @@ function stopAutoRefresh(): void {
     refreshTimer = null
   }
 }
+function stopTick(): void {
+  if (tickTimer) {
+    clearInterval(tickTimer)
+    tickTimer = null
+  }
+}
 
 function open(row: TaskListItem): void {
+  if (!isTerminal(row)) {
+    ElMessage.info('任务进行中，完成后可查看结果')
+    return
+  }
   if (row.type === 'factor') router.push(`/factor/result/${row.task_id}`)
   else if (row.type === 'optimize') router.push(`/backtest/optimize-result/${row.task_id}`)
   else if (row.type === 'portfolio') router.push(`/backtest/portfolio?task_id=${row.task_id}`)
   else router.push(`/backtest/result/${row.task_id}`)
 }
 
+// 点任务 ID → 跳对应参数页并预填该任务的参数
+async function replayParams(row: TaskListItem): Promise<void> {
+  if (!canReplay(row)) return
+  try {
+    await getTaskParams(row.task_id)
+  } catch {
+    ElMessage.error('读取任务参数失败')
+    return
+  }
+  if (row.type === 'portfolio') router.push(`/backtest/portfolio?from_task=${row.task_id}`)
+  else router.push(`/backtest/new?from_task=${row.task_id}`)
+}
+
+// ===== 删除(单个/批量) =====
+function onSelectionChange(rows: TaskListItem[]): void {
+  selection.value = rows
+}
+async function doDelete(rows: TaskListItem[]): Promise<void> {
+  if (!rows.length) return
+  const label = rows.length === 1 ? rows[0].task_id : `${rows.length} 个任务`
+  try {
+    await ElMessageBox.confirm(`删除 ${label}？结果数据与曲线文件将一并清除,不可恢复。`, '删除确认', {
+      type: 'warning',
+      confirmButtonText: '删除',
+      cancelButtonText: '取消',
+    })
+  } catch {
+    return
+  }
+  deleting.value = true
+  const ids = rows.map((r) => r.task_id)
+  const results = await Promise.allSettled(ids.map((id) => deleteTask(id)))
+  const failed = results.filter((r) => r.status === 'rejected').length
+  if (failed) ElMessage.warning(`${ids.length - failed} 个已删除,${failed} 个删除失败`)
+  else ElMessage.success(`已删除 ${ids.length} 个任务`)
+  deleting.value = false
+  selection.value = []
+  await load()
+}
+
+// ===== 展示 =====
 const typeLabelMap: Record<string, string> = { cta: '个股回测', portfolio: '组合回测', optimize: '参数优化', factor: '因子分析' }
 function typeLabel(t: string): string {
   return typeLabelMap[t] || t
@@ -121,6 +201,21 @@ const statusLabelMap: Record<string, string> = { done: '完成', failed: '失败
 function statusLabel(s: string): string {
   return statusLabelMap[s] || s
 }
+function fmtDuration(s: number): string {
+  if (s < 60) return `${s}s`
+  if (s < 3600) return `${Math.floor(s / 60)}m${s % 60 ? ` ${Math.round(s % 60)}s` : ''}`
+  if (s < 86400) return `${Math.floor(s / 3600)}h${Math.round((s % 3600) / 60) ? ` ${Math.round((s % 3600) / 60)}m` : ''}`
+  return `${Math.floor(s / 86400)}d${Math.round((s % 86400) / 3600) ? ` ${Math.round((s % 86400) / 3600)}h` : ''}`
+}
+function durationText(row: TaskListItem): string {
+  // 终态:后端算好的耗时;进行中:从创建时间活计时
+  if (row.duration_s != null) return fmtDuration(row.duration_s)
+  if (isActive(row) && row.created_at) {
+    const start = new Date(row.created_at.replace(' ', 'T')).getTime()
+    if (!Number.isNaN(start) && start <= nowTick.value) return fmtDuration(Math.max(0, Math.floor((nowTick.value - start) / 1000)))
+  }
+  return '—'
+}
 </script>
 
 <template>
@@ -128,11 +223,14 @@ function statusLabel(s: string): string {
     <div class="page-head">
       <div>
         <h2 class="page-title">
-          历史任务<span class="count-badge">{{ counts.total }}</span>
+          任务列表<span class="count-badge">{{ counts.total }}</span>
         </h2>
         <p class="page-subtitle">回测 / 参数优化 / 因子分析 的全部任务 · 完成 {{ counts.done }} · 失败 {{ counts.failed }}</p>
       </div>
       <div class="head-actions">
+        <el-button type="danger" plain :disabled="!selection.length" :loading="deleting" @click="doDelete(selection)">
+          删除选中({{ selection.length }})
+        </el-button>
         <el-button type="primary" @click="router.push('/backtest/portfolio')">发起新回测</el-button>
         <el-button :loading="loading" :icon="'Refresh'" @click="load">刷新</el-button>
       </div>
@@ -150,9 +248,13 @@ function statusLabel(s: string): string {
     </div>
 
     <el-card v-loading="loading" class="table-card" shadow="never">
-      <el-table :data="paged" size="small" empty-text="暂无符合条件的任务">
+      <el-table :data="paged" size="small" empty-text="暂无符合条件的任务" @selection-change="onSelectionChange">
+        <el-table-column type="selection" width="42" :selectable="isTerminal" />
         <el-table-column label="任务 ID" min-width="170">
-          <template #default="{ row }"><span class="mono">{{ row.task_id }}</span></template>
+          <template #default="{ row }">
+            <span v-if="canReplay(row)" class="mono task-link" title="点击跳到参数页(预填该任务参数)" @click="replayParams(row)">{{ row.task_id }}</span>
+            <span v-else class="mono">{{ row.task_id }}</span>
+          </template>
         </el-table-column>
         <el-table-column label="类型" width="96">
           <template #default="{ row }"><span class="chip" :class="`chip-${row.type}`">{{ typeLabel(row.type) }}</span></template>
@@ -165,12 +267,20 @@ function statusLabel(s: string): string {
         <el-table-column label="回测区间" min-width="150">
           <template #default="{ row }"><span class="mono muted">{{ row.start }} ~ {{ row.end }}</span></template>
         </el-table-column>
-        <el-table-column label="创建时间" width="150">
+        <el-table-column label="创建时间" width="140">
           <template #default="{ row }"><span class="mono muted">{{ row.created_at ? row.created_at.slice(0, 16) : '—' }}</span></template>
         </el-table-column>
-        <el-table-column label="操作" width="76" fixed="right">
+        <el-table-column label="耗时" width="90">
+          <template #default="{ row }"><span class="mono muted">{{ durationText(row) }}</span></template>
+        </el-table-column>
+        <el-table-column label="操作" width="104" fixed="right">
           <template #default="{ row }">
-            <el-button link type="primary" @click="open(row)">查看</el-button>
+            <el-tooltip :disabled="isTerminal(row)" content="任务进行中,完成后可查看" placement="top">
+              <span class="op-wrap">
+                <el-button link type="primary" :disabled="!isTerminal(row)" @click="open(row)">查看</el-button>
+              </span>
+            </el-tooltip>
+            <el-button v-if="isTerminal(row)" link type="danger" @click="doDelete([row])">删除</el-button>
           </template>
         </el-table-column>
       </el-table>
@@ -191,6 +301,9 @@ function statusLabel(s: string): string {
 <style scoped>
 .head-actions {
   margin-left: auto;
+  display: flex;
+  gap: 0;
+  align-items: center;
 }
 .filter-bar {
   display: flex;
@@ -213,4 +326,15 @@ function statusLabel(s: string): string {
   display: flex;
   justify-content: flex-end;
 }
+.task-link {
+  color: var(--accent, #4b7bce);
+  cursor: pointer;
+}
+.task-link:hover {
+  text-decoration: underline;
+}
+/* disabled 链接按钮在 tooltip 的 span 内,占位保持行内 */
+.op-wrap {
+  margin-right: 8px;
+}
 </style>
diff --git a/frontend/src/views/backtest/New.vue b/frontend/src/views/backtest/New.vue
index b36c9a7..2778ed4 100644
--- a/frontend/src/views/backtest/New.vue
+++ b/frontend/src/views/backtest/New.vue
@@ -3,7 +3,7 @@ import { ref, reactive, watch, onMounted } from 'vue'
 import { useRoute, useRouter } from 'vue-router'
 import { ElMessage } from 'element-plus'
 import { getStrategies, getParams, type StrategyItem } from '@/api/strategy'
-import { submitCta } from '@/api/backtest'
+import { submitCta, getTaskParams } from '@/api/backtest'
 import { apiClient } from '@/api/client'
 
 interface InstLike {
@@ -110,11 +110,24 @@ onMounted(async () => {
     if (!form.strategy && route.query.class) {
       form.strategy = String(route.query.class)
     }
+    // 从任务列表「点任务ID」跳转：按该任务参数完整预填
+    if (route.query.from_task) {
+      try {
+        const tp = await getTaskParams(String(route.query.from_task))
+        form.strategy = tp.strategy || form.strategy
+        form.symbol = tp.symbol || form.symbol
+        if (tp.start) form.start = tp.start
+        if (tp.end) form.end = tp.end
+        await loadParams(form.strategy, tp.params)
+      } catch {
+        /* 预填失败,走默认 */
+      }
+    }
     if (!form.strategy && strategies.value.length) {
       form.strategy = strategies.value[0].name
     }
     inited = true
-    if (!route.query.instance) await loadParams(form.strategy, null)
+    if (!route.query.instance && !route.query.from_task) await loadParams(form.strategy, null)
   } catch {
     ElMessage.error('策略列表加载失败')
   } finally {
@@ -170,7 +183,7 @@ async function onSubmit(): Promise<void> {
     <div class="page-head">
       <div>
         <h2 class="page-title">个股回测</h2>
-        <p class="page-subtitle">CTA 策略历史回测 · 提交后可在「历史任务」跟踪进度与结果</p>
+        <p class="page-subtitle">CTA 策略历史回测 · 提交后可在「任务列表」跟踪进度与结果</p>
       </div>
     </div>
 
diff --git a/frontend/src/views/backtest/PortfolioBacktest.vue b/frontend/src/views/backtest/PortfolioBacktest.vue
index f391d39..8d98f17 100644
--- a/frontend/src/views/backtest/PortfolioBacktest.vue
+++ b/frontend/src/views/backtest/PortfolioBacktest.vue
@@ -5,6 +5,7 @@ import { ElMessage } from 'element-plus'
 import type { EChartsCoreOption } from 'echarts'
 import { useChart } from '@/composables/useChart'
 import { darkTitle, darkTooltip, darkGrid, darkAxis } from '@/utils/echartsDark'
+import { getTaskParams } from '@/api/backtest'
 import {
   postPortfolioBacktest,
   getPortfolioResult,
@@ -368,14 +369,39 @@ async function onSubmit(): Promise<void> {
   }
 }
 
+const fromTaskId = computed(() => (route.query.from_task as string) || '')
+
 onMounted(() => {
   if (viewTaskId.value) {
     loadResult(viewTaskId.value)
   } else if (route.query.strategy) {
     // 从代码编辑页「运行回测」跳转：按策略预填
     form.strategy = String(route.query.strategy)
+  } else if (fromTaskId.value) {
+    // 从任务列表「点任务ID」跳转：按该任务参数完整预填
+    void prefillFromTask(fromTaskId.value)
   }
 })
+
+async function prefillFromTask(tid: string): Promise<void> {
+  try {
+    const tp = await getTaskParams(tid)
+    if (tp.strategy) form.strategy = tp.strategy
+    if (tp.start) form.start = tp.start
+    if (tp.end) form.end = tp.end
+    if (tp.symbol) form.benchmark = tp.symbol
+    const p = tp.params || {}
+    if (p.max_pool != null) form.max_pool = Number(p.max_pool)
+    if (p.cash != null) form.cash = Number(p.cash)
+    if (p.benchmark != null) form.benchmark = String(p.benchmark)
+    if (p.commission_rate != null) form.commission_rate = Number(p.commission_rate)
+    if (p.stamp_duty_rate != null) form.stamp_duty_rate = Number(p.stamp_duty_rate)
+    if (p.min_commission != null) form.min_commission = Number(p.min_commission)
+    if (p.slippage != null) form.slippage = Number(p.slippage)
+  } catch {
+    /* 预填失败,走默认 */
+  }
+}
 watch(equityCurve, renderEquity, { deep: true, flush: 'post' })
 watch(drawdownCurve, renderDrawdown, { deep: true, flush: 'post' })
 
@@ -466,7 +492,7 @@ function fmtNum(v: number | null | undefined, digits = 2): string {
 
       <div class="submit-bar">
         <el-button type="primary" size="large" @click="onSubmit">开始回测</el-button>
-        <span class="muted form-hint">提交后跳转「历史任务」看进度,可继续发起多个回测</span>
+        <span class="muted form-hint">提交后跳转「任务列表」看进度,可继续发起多个回测</span>
       </div>
 
       <el-alert v-if="errorMsg" type="error" :title="`提交失败:${errorMsg}`" :closable="false" show-icon class="blk" />
diff --git a/sanguo_api/routes.py b/sanguo_api/routes.py
index bf983b7..a5bd2bb 100644
--- a/sanguo_api/routes.py
+++ b/sanguo_api/routes.py
@@ -340,9 +340,19 @@ def list_tasks(type: str | None = None, status: str | None = None):
 
     running/pending 任务还没存 DB(done 才 save_result),光查 DB 看不到刚提交的
     → 任务中心(GitHub Actions 模式)必须合并内存 active + DB 已完成。
+
+    时间口径:created_at = 提交时间(task_submissions,真创建时间);
+    finished_at = 结果落库时间;duration_s = 两者差(秒)。旧任务无提交记录时
+    created_at 退化为落库时间(即旧行为)、duration_s 为 None。
     """
-    from sanguo_backtest.result_store import list_results
+    from datetime import datetime
+    from sanguo_backtest.result_store import list_results, load_submissions
     orch = get_orchestrator()
+    submissions: dict[str, str] = {}
+    try:
+        submissions = load_submissions(orch.db_path)
+    except Exception:
+        pass  # 旧库无表/读失败 → 退化为旧行为
     active: list[dict] = []
     seen: set[str] = set()
 
@@ -369,17 +379,29 @@ def list_tasks(type: str | None = None, status: str | None = None):
             "symbol": spec.get("symbol", "") or spec.get("benchmark", ""),
             "start": spec.get("start", ""),
             "end": spec.get("end", ""),
-            "created_at": "",
+            "created_at": _to_bj(submissions.get(tid)),
+            "finished_at": "",
+            "duration_s": None,
         })
         seen.add(tid)
 
     # 2) DB 已持久化任务 (done/failed)
+    def _duration_s(submitted: str | None, finished: str | None) -> int | None:
+        if not submitted or not finished:
+            return None
+        try:
+            fmt = "%Y-%m-%d %H:%M:%S"
+            return int((datetime.strptime(finished, fmt) - datetime.strptime(submitted, fmt)).total_seconds())
+        except (ValueError, TypeError):
+            return None
+
     db_items: list[dict] = []
     for r in list_results(type_filter=type, db_path=orch.db_path):
         if r.task_id in seen:
             continue
         if status and r.status != status:
             continue
+        submitted = submissions.get(r.task_id)
         db_items.append({
             "id": r.id,
             "task_id": r.task_id,
@@ -389,7 +411,9 @@ def list_tasks(type: str | None = None, status: str | None = None):
             "symbol": r.symbol,
             "start": r.start,
             "end": r.end,
-            "created_at": _to_bj(r.created_at),
+            "created_at": _to_bj(submitted) or _to_bj(r.created_at),
+            "finished_at": _to_bj(r.created_at),
+            "duration_s": _duration_s(submitted, r.created_at),
         })
 
     active.reverse()      # 最新提交的 running 在最上
@@ -397,6 +421,69 @@ def list_tasks(type: str | None = None, status: str | None = None):
     return {"tasks": active + db_items}
 
 
+@router.delete("/task/{task_id}", dependencies=[Depends(verify_token)])
+def delete_task(task_id: str):
+    """Delete a task's persisted traces: DB rows + equity/trades files +
+    submission record. Running/pending tasks refuse deletion."""
+    orch = get_orchestrator()
+    task = orch.pool.get_task(task_id)
+    if task is not None:
+        st = task.status.value if hasattr(task.status, "value") else str(task.status)
+        if st in ("running", "pending"):
+            raise HTTPException(status_code=400, detail="任务进行中，完成后才能删除")
+        orch.pool._tasks.pop(task_id, None)  # 终态内存残留一并清
+
+    from sanguo_backtest.result_store import delete_result_by_task_id
+    deleted = delete_result_by_task_id(task_id, orch.db_path)
+    if deleted == 0 and task is None:
+        raise HTTPException(status_code=404, detail="task not found")
+    return {"deleted": deleted}
+
+
+@router.get("/task/{task_id}/params", dependencies=[Depends(verify_token)])
+def task_params(task_id: str):
+    """轻量参数回放(点任务ID跳参数页预填用):只回参数元数据,不带曲线。
+
+    运行中任务读内存 _pending spec;已完成任务读 DB。都没有 → 404。
+    """
+    orch = get_orchestrator()
+
+    # 1) 内存运行中任务
+    spec = getattr(orch, "_pending", {}).get(task_id)
+    task = orch.pool.get_task(task_id)
+    st = task.status.value if task is not None and hasattr(task.status, "value") else ""
+    if spec is not None and st in ("running", "pending"):
+        strat = spec.get("strategy", "")
+        if not strat and spec.get("strategy_class"):
+            strat = getattr(spec["strategy_class"], "__name__", str(spec["strategy_class"]))
+        return {
+            "task_id": task_id,
+            "type": getattr(task, "task_type", "") or "",
+            "status": st,
+            "strategy": strat,
+            "symbol": spec.get("symbol", "") or spec.get("benchmark", ""),
+            "params": spec.get("params") or spec.get("grid") or {},
+            "start": spec.get("start", ""),
+            "end": spec.get("end", ""),
+        }
+
+    # 2) DB 已完成任务
+    from sanguo_backtest.result_store import load_result_by_task_id
+    r = load_result_by_task_id(task_id, orch.db_path)
+    if r is None:
+        raise HTTPException(status_code=404, detail="task not found")
+    return {
+        "task_id": task_id,
+        "type": r.type,
+        "status": r.status,
+        "strategy": r.strategy,
+        "symbol": r.symbol,
+        "params": r.params or {},
+        "start": r.start,
+        "end": r.end,
+    }
+
+
 @router.get("/task/{task_id}/optimization-results", dependencies=[Depends(verify_token)])
 def optimization_results(task_id: str):
     """Optimization results: list of {params, statistics} per parameter combo.
diff --git a/sanguo_orchestrator/portfolio_worker.py b/sanguo_orchestrator/portfolio_worker.py
index 4f4f7f6..0f6301c 100644
--- a/sanguo_orchestrator/portfolio_worker.py
+++ b/sanguo_orchestrator/portfolio_worker.py
@@ -109,7 +109,17 @@ def run_portfolio_task(spec: dict) -> Any:
         status="done",
         strategy=data.get("strategy", ""),
         symbol=benchmark,
-        params={"benchmark": benchmark, "max_pool": max_pool},
+        # params 全量存任务参数(含资金/费用),供任务列表「点ID跳参数页」完整预填
+        params={
+            "benchmark": benchmark,
+            "max_pool": max_pool,
+            "strategy": strategy,
+            "cash": cash,
+            "commission_rate": spec.get("commission_rate", 0.0003),
+            "stamp_duty_rate": spec.get("stamp_duty_rate", 0.001),
+            "min_commission": spec.get("min_commission", 5.0),
+            "slippage": spec.get("slippage", 0.0),
+        },
         start=period.get("start", ""),
         end=period.get("end", ""),
         statistics={
diff --git a/sanguo_orchestrator/runner.py b/sanguo_orchestrator/runner.py
index e1eb7af..bbc3c1a 100644
--- a/sanguo_orchestrator/runner.py
+++ b/sanguo_orchestrator/runner.py
@@ -25,6 +25,16 @@ class Orchestrator:
         """Set callback for stage updates (async callable)"""
         self._on_stage = cb
 
+    def _record_submit(self, task_id: str) -> None:
+        """提交即记提交时间(真创建时间)。失败静默——缺失只影响耗时展示。"""
+        if not self.db_path:
+            return
+        try:
+            from sanguo_backtest.result_store import record_submission
+            record_submission(task_id, self.db_path)
+        except Exception:
+            pass
+
     async def _notify_stage(self, task_id: str, stage: str) -> None:
         """Update task stage and fire callback if set"""
         self.pool.update_stage(task_id, stage)
@@ -39,6 +49,7 @@ class Orchestrator:
         # Stable uuid up front → reused as the persisted DB task_id, so runner-id ==
         # DB task_id (durable across restarts; previously used id(params) memory addr).
         task_id = f"cta_{uuid.uuid4().hex[:8]}"
+        self._record_submit(task_id)
         self.pool.submit(task_id, "cta")
         self._pending[task_id] = dict(
             strategy_class=strategy_class,
@@ -71,6 +82,7 @@ class Orchestrator:
                            start: str, end: str, cfg) -> str:
         """Submit a CTA optimization task asynchronously"""
         task_id = f"opt_{uuid.uuid4().hex[:8]}"
+        self._record_submit(task_id)
         self.pool.submit(task_id, "optimize")
         self._pending[task_id] = dict(
             strategy_class=strategy_class,
@@ -98,6 +110,7 @@ class Orchestrator:
                           start: str, end: str, cfg, output_dir: str) -> str:
         """Submit a factor analysis task asynchronously"""
         task_id = f"factor_{uuid.uuid4().hex[:8]}"
+        self._record_submit(task_id)
         self.pool.submit(task_id, "factor")
         self._pending[task_id] = dict(
             symbols=symbols,
@@ -136,6 +149,7 @@ class Orchestrator:
         CTA/optimize/factor.
         """
         task_id = f"portfolio_{uuid.uuid4().hex[:8]}"
+        self._record_submit(task_id)
         self.pool.submit(task_id, "portfolio")
         file_dir = os.path.dirname(os.path.abspath(self.db_path)) if self.db_path else None
         self._pending[task_id] = dict(
diff --git a/tests/api/test_task_list_management.py b/tests/api/test_task_list_management.py
new file mode 100644
index 0000000..cd9819d
--- /dev/null
+++ b/tests/api/test_task_list_management.py
@@ -0,0 +1,174 @@
+"""任务列表管理:删除 + 真创建时间/耗时 + 参数回放 (验收第四轮 批1)。
+
+Direct route-call 风格与 test_portfolio_live.py 一致(不打 JWT)。
+"""
+import os
+import sqlite3
+import tempfile
+from unittest.mock import Mock, patch
+
+import pandas as pd
+import pytest
+from fastapi.testclient import TestClient
+
+from sanguo_api.app import create_app
+from sanguo_api.auth import set_jwt_config, create_token
+from sanguo_backtest.result_store import (
+    BacktestResult,
+    record_submission,
+    save_result,
+)
+
+
+@pytest.fixture()
+def client_env():
+    """Temp DB + app + token + mock orchestrator(真实 dict 注册表)。"""
+    set_jwt_config(secret="test", expire_minutes=60)
+    with tempfile.TemporaryDirectory() as tmp:
+        db_path = os.path.join(tmp, "test.db")
+        app = create_app(db_path=db_path, file_dir=tmp)
+        token = create_token("admin")
+        orch = Mock()
+        orch.db_path = db_path
+        orch.pool._tasks = {}
+        orch.pool.get_task.return_value = None  # Mock 默认非 None 会挡 404 分支
+        orch._pending = {}
+        with patch("sanguo_api.routes.get_orchestrator", return_value=orch):
+            yield TestClient(app), token, orch, db_path, tmp
+
+
+def _save_done_result(task_id: str, db_path: str, file_dir: str) -> None:
+    save_result(BacktestResult(
+        task_id=task_id, type="cta", status="done",
+        strategy="AShareDoubleMaStrategy", symbol="600000",
+        params={"fast_window": 10, "slow_window": 30},
+        start="2024-01-01", end="2024-06-30",
+        statistics={"total_return": 0.1},
+        equity_curve=pd.DataFrame([{"date": "2024-01-02", "balance": 1_000_000}]),
+        trades=pd.DataFrame([{"datetime": "2024-01-05", "price": 10.0, "volume": 100}]),
+    ), db_path=db_path, file_dir=file_dir)
+
+
+# ===== 真创建时间 + 耗时 =====
+
+def test_list_tasks_uses_submission_time_and_duration(client_env):
+    client, token, orch, db_path, tmp = client_env
+    # 提交时间 = 2 小时前(直接写表,避免 sleep)
+    _save_done_result("cta_abcd1234", db_path, tmp)
+    conn = sqlite3.connect(db_path)
+    conn.execute(
+        "INSERT OR REPLACE INTO task_submissions (task_id, submitted_at) "
+        "VALUES ('cta_abcd1234', '2024-01-01 06:00:00')"
+    )
+    # backtest_stats.created_at 固定为结果插入时间 → 手动改成 08:00 模拟耗时 2h
+    conn.execute("UPDATE backtest_stats SET created_at='2024-01-01 08:00:00'")
+    conn.commit()
+    conn.close()
+
+    resp = client.get("/api/v1/task", headers={"Authorization": f"Bearer {token}"})
+    assert resp.status_code == 200
+    row = next(t for t in resp.json()["tasks"] if t["task_id"] == "cta_abcd1234")
+    assert row["created_at"].startswith("2024-01-01 14:00")  # UTC+8
+    assert row["finished_at"].startswith("2024-01-01 16:00")
+    assert row["duration_s"] == 7200
+
+
+def test_list_tasks_old_row_without_submission_degrades(client_env):
+    client, token, orch, db_path, tmp = client_env
+    _save_done_result("cta_old9999", db_path, tmp)
+    resp = client.get("/api/v1/task", headers={"Authorization": f"Bearer {token}"})
+    row = next(t for t in resp.json()["tasks"] if t["task_id"] == "cta_old9999")
+    # 旧行为:created_at=落库时间,duration 缺失
+    assert row["created_at"] == row["finished_at"]
+    assert row["duration_s"] is None
+
+
+def test_record_submission_writes_utc_row(client_env):
+    client, token, orch, db_path, tmp = client_env
+    ts = record_submission("cta_new0001", db_path)
+    conn = sqlite3.connect(db_path)
+    row = conn.execute(
+        "SELECT submitted_at FROM task_submissions WHERE task_id='cta_new0001'"
+    ).fetchone()
+    conn.close()
+    assert row is not None
+    assert row[0] == ts
+
+
+# ===== 删除 =====
+
+def test_delete_task_removes_row_and_files(client_env):
+    client, token, orch, db_path, tmp = client_env
+    _save_done_result("cta_del0001", db_path, tmp)
+    conn = sqlite3.connect(db_path)
+    eq_path, tr_path = conn.execute(
+        "SELECT equity_path, trades_path FROM backtest_stats WHERE task_id='cta_del0001'"
+    ).fetchone()
+    conn.close()
+    assert eq_path and os.path.exists(eq_path)
+    assert tr_path and os.path.exists(tr_path)
+
+    resp = client.delete("/api/v1/task/cta_del0001", headers={"Authorization": f"Bearer {token}"})
+    assert resp.status_code == 200
+    assert resp.json()["deleted"] == 1
+    assert not os.path.exists(eq_path)
+    assert not os.path.exists(tr_path)
+
+    # 列表里也没了
+    resp = client.get("/api/v1/task", headers={"Authorization": f"Bearer {token}"})
+    assert all(t["task_id"] != "cta_del0001" for t in resp.json()["tasks"])
+
+
+def test_delete_running_task_refused(client_env):
+    client, token, orch, db_path, tmp = client_env
+    task = Mock()
+    task.status.value = "running"
+    orch.pool.get_task.return_value = task
+    resp = client.delete("/api/v1/task/cta_run0001", headers={"Authorization": f"Bearer {token}"})
+    assert resp.status_code == 400
+    assert "进行中" in resp.json()["detail"]
+
+
+def test_delete_unknown_task_404(client_env):
+    client, token, orch, db_path, tmp = client_env
+    resp = client.delete("/api/v1/task/cta_none001", headers={"Authorization": f"Bearer {token}"})
+    assert resp.status_code == 404
+
+
+# ===== 参数回放 =====
+
+def test_task_params_returns_saved_params(client_env):
+    client, token, orch, db_path, tmp = client_env
+    _save_done_result("cta_par0001", db_path, tmp)
+    resp = client.get("/api/v1/task/cta_par0001/params", headers={"Authorization": f"Bearer {token}"})
+    assert resp.status_code == 200
+    data = resp.json()
+    assert data["type"] == "cta"
+    assert data["strategy"] == "AShareDoubleMaStrategy"
+    assert data["symbol"] == "600000"
+    assert data["params"] == {"fast_window": 10, "slow_window": 30}
+    assert data["start"] == "2024-01-01"
+
+
+def test_task_params_running_reads_pending_spec(client_env):
+    client, token, orch, db_path, tmp = client_env
+    task = Mock()
+    task.status.value = "running"
+    task.task_type = "portfolio"
+    orch.pool.get_task.return_value = task
+    orch._pending["portfolio_run01"] = {
+        "strategy": "all_weather", "benchmark": "000300.XSHG",
+        "start": "2024-01-01", "end": "2024-12-31", "max_pool": 30,
+    }
+    resp = client.get("/api/v1/task/portfolio_run01/params", headers={"Authorization": f"Bearer {token}"})
+    assert resp.status_code == 200
+    data = resp.json()
+    assert data["strategy"] == "all_weather"
+    assert data["symbol"] == "000300.XSHG"  # portfolio spec 用 benchmark 兜底
+    assert data["status"] == "running"
+
+
+def test_task_params_unknown_404(client_env):
+    client, token, orch, db_path, tmp = client_env
+    resp = client.get("/api/v1/task/cta_none002/params", headers={"Authorization": f"Bearer {token}"})
+    assert resp.status_code == 404