diff --git a/backend/internal/database/sqlite.go b/backend/internal/database/sqlite.go
index 03cd12c..25832f1 100644
--- a/backend/internal/database/sqlite.go
+++ b/backend/internal/database/sqlite.go
@@ -612,13 +612,28 @@ func (d *DB) GetBatchRuns(limit int) ([]BatchRun, error) {
 	return runs, nil
 }
 
-// CleanupStuckBatchRuns 清理卡住的 running 状态批次记录
+// CleanupStuckBatchRuns 清理卡住的 running 状态批次记录，从子结果重新计算汇总
 func (d *DB) CleanupStuckBatchRuns() (int64, error) {
+	// 先从 batch_team_results 重新汇总数据，再标记为 completed
 	result, err := d.db.Exec(`
 		UPDATE batch_runs
 		SET status = 'completed',
 		    finished_at = COALESCE(finished_at, started_at),
-		    duration_seconds = 0
+		    total_registered = COALESCE((
+		        SELECT SUM(registered) FROM batch_team_results WHERE batch_id = batch_runs.id
+		    ), 0),
+		    total_added_to_s2a = COALESCE((
+		        SELECT SUM(added_to_s2a) FROM batch_team_results WHERE batch_id = batch_runs.id
+		    ), 0),
+		    success_rate = CASE
+		        WHEN total_owners > 0 THEN
+		            COALESCE((SELECT SUM(added_to_s2a) FROM batch_team_results WHERE batch_id = batch_runs.id), 0) * 100.0 / (total_owners * 4)
+		        ELSE 0
+		    END,
+		    duration_seconds = CASE
+		        WHEN finished_at IS NOT NULL THEN CAST((julianday(finished_at) - julianday(started_at)) * 86400 AS INTEGER)
+		        ELSE 0
+		    END
 		WHERE status = 'running'
 	`)
 	if err != nil {