diff --git a/apps/api/src/services/report_generation_service.py b/apps/api/src/services/report_generation_service.py
index 7a8b83f4..828632ae 100644
--- a/apps/api/src/services/report_generation_service.py
+++ b/apps/api/src/services/report_generation_service.py
@@ -219,33 +219,29 @@ class ReportGenerationService:
 
     async def _collect_repair_stats(self, since: datetime) -> dict:
         """
-        收集自動修復統計（IncidentRecord.outcome JSON）
+        收集自動修復統計
 
-        2026-04-14 Claude Sonnet 4.6 修復 — 原本引用不存在的 ApprovalRequestRecord，
-        實際 execution_success 儲存在 IncidentRecord.outcome JSON 欄位。
+        2026-04-22 Claude Sonnet 4.6 修復 — incidents.outcome JSON 在執行鏈路中從未被寫入
+        execution_success，導致永遠查詢到 0。改查 approval_records.status 作為 source of truth
+        （approval_execution.py 每次執行後都會寫入 EXECUTION_SUCCESS / EXECUTION_FAILED）。
         """
-        from sqlalchemy import func, select, text
+        from sqlalchemy import text
 
         from src.db.base import get_db_context
-        from src.db.models import IncidentRecord
 
         async with get_db_context() as db:
-            # PostgreSQL JSON 路徑查詢：outcome->>'execution_success'
-            success = await db.scalar(
-                select(func.count()).select_from(IncidentRecord).where(
-                    IncidentRecord.created_at >= since,
-                    text("outcome->>'execution_success' = 'true'"),
-                )
-            ) or 0
-
-            failed = await db.scalar(
-                select(func.count()).select_from(IncidentRecord).where(
-                    IncidentRecord.created_at >= since,
-                    text("outcome->>'execution_success' = 'false'"),
-                )
-            ) or 0
-
-            return {"success": success, "failed": failed}
+            row = await db.execute(
+                text("""
+                    SELECT
+                        COUNT(*) FILTER (WHERE status = 'execution_success') AS success,
+                        COUNT(*) FILTER (WHERE status = 'execution_failed')  AS failed
+                    FROM approval_records
+                    WHERE created_at >= :since
+                """),
+                {"since": since},
+            )
+            r = row.one()
+            return {"success": int(r.success or 0), "failed": int(r.failed or 0)}
 
     async def _collect_km_stats(self, since: datetime) -> int:
         """收集新增 KM 條目數"""
@@ -559,6 +555,12 @@ async def run_daily_report_loop() -> None:
         )
         await asyncio.sleep(sleep_seconds)
 
+        # 2026-04-22 Claude Sonnet 4.6: 多 Pod 競速保護 — 只有搶到 Redis SETNX 的 Pod 才發報告
+        from src.services.ai_advisory_helpers import try_acquire_daily_lock
+        if not await try_acquire_daily_lock("daily_report"):
+            logger.info("daily_report_skipped_other_pod")
+            continue
+
         logger.info("daily_report_triggered")
         await service.send_daily_report()