新增市場情報候選審核佇列草案

TODO_NEXT_STEPS.txt

@@ -109,6 +109,7 @@
    - Phase 50 manual sample review evaluate：新增 `/api/market_intel/manual_sample_review/evaluate` POST 與 UI JSON 審核入口，允許操作員貼入單筆 sample result 即時回傳 PASS/BLOCK；不保存 payload、不回吐完整 HTML、不寫 DB、不建立候選活動、不允許候選導入、不掛 scheduler；版本同步至 V10.219。
    - V10.220 補 Phase 50 UI POST CSRF header：`manual_sample_review/evaluate` 保持 CSRF 保護，頁面 fetch 送出 `X-CSRFToken`，不豁免安全檢查。
    - Phase 51 manual sample candidate handoff：新增 `/api/market_intel/manual_sample_review/candidate_handoff` POST 與 UI handoff 按鈕，將已通過審核的 sample result 轉成只讀候選活動 preview payload；不保存 handoff、不建立 review queue、不寫 market_*、不允許候選導入、不掛 scheduler；版本同步至 V10.222。
+   - Phase 52 manual sample candidate queue draft：新增 `services/market_intel/manual_sample_candidate_queue.py`、`/api/market_intel/manual_sample_review/candidate_queue_draft` POST 與 UI queue 草案按鈕，將 handoff 候選轉成只讀人工審核 queue draft；不建立正式 queue、不保存草案、不寫 market_*、不自動核准候選、不掛 scheduler；版本同步至 V10.223。
    - Schema smoke：`tests/test_market_intel_skeleton.py` 檢查 `Base.metadata` 內含 ADR-035 八張 `market_*` tables。
    - Desktop UI QA：本機只註冊 `market_intel_bp` 的 Flask harness 載入 `/market_intel`，確認 Phase 15、候選預覽、writer preview、安全 flags、點陣暖紙視覺正常，console error 0。
    - API QA：`/api/market_intel/schema_smoke` 通過 7 張表與 `market_platforms` 必要欄位檢查；`/api/market_intel/platform_seed_writer_plan` 回傳 4 筆 dry-run upsert preview，`writes_executed=false`，四平台皆 `blocked_dry_run_only`。

config.py

@@ -320,7 +320,7 @@ YOUTUBE_API_KEY = os.getenv('YOUTUBE_API_KEY', '')
 # ==========================================
 # 系統版本與路徑
 # ==========================================
-SYSTEM_VERSION = "V10.222"
+SYSTEM_VERSION = "V10.223"
 LOG_FILE_PATH = os.path.join(BASE_DIR, 'logs/system.log')
 public_url = PUBLIC_URL  # 用於模板顯示
 

docs/adr/ADR-035-cross-platform-market-campaign-intelligence.md

@@ -177,6 +177,7 @@ EwoooC 目前已有 MOMO EDM / 節慶活動資料、`promo_products`、PChome
 - 2026-05-19 追加 manual sample result review：`services.market_intel.manual_sample_review` 與 `/api/market_intel/manual_sample_review` 以純函式評估操作員提供的 sample result 是否通過 Phase 48 驗收門檻並可進候選預覽。API/UI 預設不載入 sample result，不抓外站、不存檔、不寫 DB、不允許候選導入、不掛 scheduler；即使審核通過也只開 candidate preview gate，正式 market_* 寫入仍需後續獨立批准。
 - 2026-05-19 追加 manual sample review evaluate：`/api/market_intel/manual_sample_review/evaluate` 提供 POST-only 即時審核入口，操作員可貼入單筆 sample result JSON 取得 PASS/BLOCK 與 candidate preview readiness。此入口不保存 payload、不回吐完整 HTML、不連外、不寫 DB、不建立候選活動、不允許候選導入、不掛 scheduler；invalid JSON 只回診斷錯誤。
 - 2026-05-19 追加 manual sample candidate handoff：`/api/market_intel/manual_sample_review/candidate_handoff` 將已通過審核的 sample result 轉成只讀候選活動 handoff payload，包含 candidate key、平台、來源、URL、信心分級、排序與人工審核狀態。此入口保持 CSRF 保護，不保存 handoff、不建立 review queue、不寫 market_*、不允許候選導入、不掛 scheduler。
+- 2026-05-19 追加 manual sample candidate queue draft：`services.market_intel.manual_sample_candidate_queue` 與 `/api/market_intel/manual_sample_review/candidate_queue_draft` 將 handoff 候選轉成只讀人工審核 queue draft，包含 queue item key、review priority、review state 與 approval_required。此入口保持 CSRF 保護，不建立正式 queue、不保存草案、不寫 market_*、不自動核准候選、不掛 scheduler。
 
 ### Phase 4：Coupang / Shopee Adapter
 

docs/memory/code_modularization_inventory_20260430.md

@@ -11,7 +11,7 @@
 - 2026-05-05 追記：Phase 38→56 觀測台戰役讓 `routes/admin_observability_routes.py` 與 `run_scheduler.py` 進入大檔治理清單；後續觀測台功能應先抽 query/action service，不再把新 SQL 與 L2 mutation 直接塞回 route。
 - 2026-05-06 追記：跨平台市場情報模組啟動前，必須先把新增爬蟲、排程、DB schema、UI route 全部隔離在 `market_*` / `services/market_intel/` / `routes/market_intel_routes.py`，不可塞回既有大檔。
 - 2026-05-18 追記：Phase 42 市場情報只在 `app.py` 的 `EXPECTED_METADATA_TABLES` 補上 `market_alert_review_queue` 名稱，未新增 route / bootstrap 邏輯；後續仍應把 metadata verification 抽到 app factory 或 startup guard module，避免 `app.py` 繼續承接功能。
-- 2026-05-18 追記：同步治理測試盤點，新增 `services/code_review_pipeline_service.py`、`services/ppt_auto_generation_service.py`，並校正 `routes/admin_observability_routes.py`、`services/import_service.py` 行數。
+- 2026-05-19 追記：同步治理測試盤點，校正 `routes/admin_observability_routes.py` 行數；此處只更新 inventory，不變更觀測台功能。
 
 ## 達到或超過 800 行檔案清單
 
@@ -22,7 +22,7 @@
 | 3186 | `routes/sales_routes.py` | P0 巨型 Blueprint | page routes / API routes / chart query service / calendar service；分析頁新增功能先抽 `services/sales/` |
 | 2821 | `scheduler.py` | P0 排程總管 | task registry / crawler jobs / report jobs / notification jobs；市場情報只能透過獨立 job module 掛入 |
 | 2731 | `services/openclaw_strategist_service.py` | P0 OpenClaw service | prompt builders / report composer / strategy rules |
-| 3283 | `routes/admin_observability_routes.py` | P0 觀測台巨型 Blueprint | `services/observability_query_service.py` / `services/observability_action_service.py` / route glue |
+| 3681 | `routes/admin_observability_routes.py` | P0 觀測台巨型 Blueprint | `services/observability_query_service.py` / `services/observability_action_service.py` / route glue |
 | 1796 | `routes/ai_routes.py` | P1 AI Blueprint | route glue / AI orchestration service / prompt builders |
 | 1721 | `services/nemoton_dispatcher_service.py` | P1 NemoTron service | NIM client / tool-call parser / action dispatcher |
 | 1507 | `routes/dashboard_routes.py` | P1 Dashboard Blueprint | competitor decision overview / dashboard query service；首頁資料整併需抽 service |

routes/README.md

@@ -19,7 +19,7 @@
 | `edm_routes.py` | EDM 與節慶儀表板 | `/edm`, `/festival` |
 | `monthly_routes.py` | 月結分析 | `/monthly_summary_analysis`, `/api/monthly_summary_data` |
 | `daily_sales_routes.py` | 當日業績 | `/daily_sales`, `/daily_sales/export*` |
-| `market_intel_routes.py` | 市場情報 Phase 51 manual sample candidate handoff | `/market_intel`, `/market_intel/*`, `/api/market_intel/status`, `/api/market_intel/schema`, `/api/market_intel/schema_smoke`, `/api/market_intel/schema_db_probe`, `/api/market_intel/platform_seed_db_diff`, `/api/market_intel/legacy_source_bridge`, `/api/market_intel/mcp_readiness`, `/api/market_intel/mcp_tool_contract`, `/api/market_intel/mcp_deploy_preflight`, `/api/market_intel/mcp_activation_runbook`, `/api/market_intel/mcp_fetch_gate`, `/api/market_intel/scheduler_plan`, `/api/market_intel/manual_sample_plan`, `/api/market_intel/manual_sample_acceptance`, `/api/market_intel/manual_sample_review`, `/api/market_intel/manual_sample_review/evaluate`, `/api/market_intel/manual_sample_review/candidate_handoff`, `/api/market_intel/match_review_plan`, `/api/market_intel/opportunity_plan`, `/api/market_intel/opportunity_scoring_plan`, `/api/market_intel/opportunity_evidence_plan`, `/api/market_intel/opportunity_alert_plan`, `/api/market_intel/adapters`, `/api/market_intel/dry_run_plan`, `/api/market_intel/discovery_plan`, `/api/market_intel/manual_discovery`, `/api/market_intel/candidate_preview`, `/api/market_intel/platform_seed_plan`, `/api/market_intel/platform_seed_write_guard`, `/api/market_intel/platform_seed_writer_plan`, `/api/market_intel/migration_blueprint`, `/api/market_intel/migration_apply_drill`, `/api/market_intel/migration_catalog_review`, `/api/market_intel/migration_live_smoke`, `/api/market_intel/live_db_inventory`, `/api/market_intel/seed_writer_cli_status`, `/api/market_intel/write_approval_runbook`, `/api/market_intel/deployment_readiness` |
+| `market_intel_routes.py` | 市場情報 Phase 52 manual sample candidate queue draft | `/market_intel`, `/market_intel/*`, `/api/market_intel/status`, `/api/market_intel/schema`, `/api/market_intel/schema_smoke`, `/api/market_intel/schema_db_probe`, `/api/market_intel/platform_seed_db_diff`, `/api/market_intel/legacy_source_bridge`, `/api/market_intel/mcp_readiness`, `/api/market_intel/mcp_tool_contract`, `/api/market_intel/mcp_deploy_preflight`, `/api/market_intel/mcp_activation_runbook`, `/api/market_intel/mcp_fetch_gate`, `/api/market_intel/scheduler_plan`, `/api/market_intel/manual_sample_plan`, `/api/market_intel/manual_sample_acceptance`, `/api/market_intel/manual_sample_review`, `/api/market_intel/manual_sample_review/evaluate`, `/api/market_intel/manual_sample_review/candidate_handoff`, `/api/market_intel/manual_sample_review/candidate_queue_draft`, `/api/market_intel/match_review_plan`, `/api/market_intel/opportunity_plan`, `/api/market_intel/opportunity_scoring_plan`, `/api/market_intel/opportunity_evidence_plan`, `/api/market_intel/opportunity_alert_plan`, `/api/market_intel/adapters`, `/api/market_intel/dry_run_plan`, `/api/market_intel/discovery_plan`, `/api/market_intel/manual_discovery`, `/api/market_intel/candidate_preview`, `/api/market_intel/platform_seed_plan`, `/api/market_intel/platform_seed_write_guard`, `/api/market_intel/platform_seed_writer_plan`, `/api/market_intel/migration_blueprint`, `/api/market_intel/migration_apply_drill`, `/api/market_intel/migration_catalog_review`, `/api/market_intel/migration_live_smoke`, `/api/market_intel/live_db_inventory`, `/api/market_intel/seed_writer_cli_status`, `/api/market_intel/write_approval_runbook`, `/api/market_intel/deployment_readiness` |
 | `api_routes.py` | 通用任務與查詢 API | `/api/run_task`, `/api/history/*` |
 | `export_routes.py` | 匯出功能 | `/api/export/*` |
 | `import_routes.py` | 匯入功能 | `/api/import_excel`, `/api/import/monthly_summary` |

routes/market_intel_routes.py

@@ -217,6 +217,31 @@ def market_intel_manual_sample_candidate_handoff():
     )
 
 
+@market_intel_bp.route(
+    "/api/market_intel/manual_sample_review/candidate_queue_draft",
+    methods=["POST"],
+)
+@login_required
+def market_intel_manual_sample_candidate_queue_draft():
+    payload = request.get_json(silent=True)
+    limit = request.args.get("limit", default=20, type=int)
+    if not isinstance(payload, dict):
+        data = _service().build_manual_sample_candidate_queue_draft(
+            sample_result=None,
+            payload_error="invalid_json_object",
+            limit=limit,
+        )
+        return jsonify(data), 400
+
+    sample_result = payload.get("sample_result", payload)
+    return jsonify(
+        _service().build_manual_sample_candidate_queue_draft(
+            sample_result=sample_result,
+            limit=limit,
+        )
+    )
+
+
 @market_intel_bp.route("/api/market_intel/match_review_plan")
 @login_required
 def market_intel_match_review_plan():

services/market_intel/deployment_readiness.py

@@ -27,6 +27,9 @@ def build_deployment_readiness_preview(
     manual_sample_candidate_handoff = service.build_manual_sample_candidate_handoff(
         sample_result={}
     )
+    manual_sample_candidate_queue_draft = (
+        service.build_manual_sample_candidate_queue_draft(sample_result={})
+    )
     match_review_plan = service.build_match_review_plan()
     opportunity_plan = service.build_opportunity_plan()
     opportunity_scoring_plan = service.build_opportunity_scoring_plan()
@@ -136,6 +139,19 @@ def build_deployment_readiness_preview(
             and not manual_sample_candidate_handoff["database_commit_executed"]
             and not manual_sample_candidate_handoff["scheduler_attached"]
         ),
+        "manual_sample_candidate_queue_draft_post_safe": bool(
+            manual_sample_candidate_queue_draft["mode"]
+            == "manual_sample_candidate_queue_draft_preview"
+            and manual_sample_candidate_queue_draft["payload_received"]
+            and not manual_sample_candidate_queue_draft["payload_persisted"]
+            and not manual_sample_candidate_queue_draft["review_queue_created"]
+            and not manual_sample_candidate_queue_draft["review_queue_persisted"]
+            and not manual_sample_candidate_queue_draft["candidate_import_allowed"]
+            and not manual_sample_candidate_queue_draft["external_network_executed"]
+            and not manual_sample_candidate_queue_draft["database_write_executed"]
+            and not manual_sample_candidate_queue_draft["database_commit_executed"]
+            and not manual_sample_candidate_queue_draft["scheduler_attached"]
+        ),
         "match_review_plan_preview_safe": bool(
             match_review_plan["mode"] == "match_review_plan_preview"
             and not match_review_plan["review_queue_created"]
@@ -379,6 +395,7 @@ def build_deployment_readiness_preview(
         "manual_sample_review": manual_sample_review,
         "manual_sample_review_evaluation": manual_sample_review_evaluation,
         "manual_sample_candidate_handoff": manual_sample_candidate_handoff,
+        "manual_sample_candidate_queue_draft": manual_sample_candidate_queue_draft,
         "match_review_plan": match_review_plan,
         "opportunity_plan": opportunity_plan,
         "opportunity_scoring_plan": opportunity_scoring_plan,

services/market_intel/manual_sample_candidate_queue.py

@@ -0,0 +1,148 @@
+"""市場情報人工候選審核 queue 草案預覽。
+
+本模組只把 sample result handoff 轉成 review queue draft；
+不建立正式 queue、不寫 DB、不掛 scheduler、不連外。
+"""
+
+from services.market_intel.manual_sample_review import (
+    build_manual_sample_candidate_handoff_preview,
+)
+
+
+def _priority_for_candidate(candidate):
+    band = str(candidate.get("confidence_band") or "").lower()
+    if band == "high":
+        return 80
+    if band == "medium":
+        return 50
+    return 20
+
+
+def _build_queue_item(candidate, batch_id):
+    candidate_key = str(candidate.get("candidate_key") or "")
+    return {
+        "queue_item_key": f"review:{candidate_key}",
+        "candidate_key": candidate_key,
+        "platform_code": str(candidate.get("platform_code") or ""),
+        "candidate_url": str(candidate.get("candidate_url") or ""),
+        "candidate_text": str(candidate.get("candidate_text") or ""),
+        "confidence_band": str(candidate.get("confidence_band") or "unknown"),
+        "score": candidate.get("score") or 0,
+        "rank_position": candidate.get("rank_position") or 0,
+        "review_state": "needs_review",
+        "review_priority": _priority_for_candidate(candidate),
+        "created_from_batch_id": batch_id,
+        "write_status": "blocked_preview_only",
+        "approval_required": True,
+    }
+
+
+def build_manual_sample_candidate_queue_draft_preview(
+    *,
+    runtime_status,
+    acceptance_contract,
+    sample_result=None,
+    payload_error=None,
+    limit=20,
+):
+    """建立候選活動人工審核 queue 草案；只回 preview，不保存。"""
+    handoff = build_manual_sample_candidate_handoff_preview(
+        runtime_status=runtime_status,
+        acceptance_contract=acceptance_contract,
+        sample_result=sample_result,
+        payload_error=payload_error,
+        limit=limit,
+    )
+    batch_id = ""
+    if isinstance(sample_result, dict):
+        batch_id = str(sample_result.get("batch_id") or "")
+    queue_items = [
+        _build_queue_item(candidate, batch_id)
+        for candidate in handoff.get("candidates", [])
+    ]
+    queue_draft_ready = bool(handoff.get("handoff_ready") and queue_items)
+    blocked_reasons = list(handoff.get("blocked_reasons", []))
+    if not queue_draft_ready:
+        blocked_reasons.append("review_queue_draft_not_ready")
+    blocked_reasons.append("review_queue_persist_still_blocked")
+
+    return {
+        "mode": "manual_sample_candidate_queue_draft_preview",
+        "handoff": {
+            "mode": handoff["mode"],
+            "handoff_ready": handoff["handoff_ready"],
+            "candidate_handoff_created": handoff["candidate_handoff_created"],
+            "candidate_handoff_persisted": handoff["candidate_handoff_persisted"],
+            "handoff_summary": handoff["handoff_summary"],
+        },
+        "payload_received": handoff["payload_received"],
+        "payload_valid_json_object": handoff["payload_valid_json_object"],
+        "payload_error": handoff["payload_error"],
+        "payload_persisted": False,
+        "sample_result_persisted": False,
+        "handoff_ready": handoff["handoff_ready"],
+        "queue_draft_ready": queue_draft_ready,
+        "review_queue_draft_created": bool(queue_items),
+        "review_queue_created": False,
+        "review_queue_persisted": False,
+        "candidate_import_allowed": False,
+        "scheduler_attached": False,
+        "external_network_executed": False,
+        "database_connection_opened": False,
+        "database_session_created": False,
+        "database_write_executed": False,
+        "database_commit_executed": False,
+        "writes_executed": False,
+        "would_write_database": False,
+        "blocked_reasons": blocked_reasons,
+        "queue_summary": {
+            "queue_item_count": len(queue_items),
+            "review_queue_created": False,
+            "queue_persisted": False,
+            "import_allowed": False,
+        },
+        "queue_contract": {
+            "contract_type": "draft_contract_only",
+            "table_name": "market_campaign_candidate_review_queue",
+            "required_fields": [
+                "queue_item_key",
+                "candidate_key",
+                "platform_code",
+                "candidate_url",
+                "candidate_text",
+                "confidence_band",
+                "score",
+                "review_state",
+                "review_priority",
+                "created_from_batch_id",
+            ],
+            "forbidden_actions": [
+                "insert_review_queue_rows",
+                "auto_approve_candidates",
+                "insert_market_campaigns",
+                "attach_scheduler_jobs",
+            ],
+        },
+        "queue_items": queue_items,
+        "operator_next_actions": [
+            {
+                "key": "review_queue_draft_manually",
+                "label": "人工確認候選 URL、分數與優先序後，才可提出正式 queue 建立申請",
+                "write_status": "blocked",
+            },
+            {
+                "key": "approve_queue_persistence_later",
+                "label": "正式寫入候選審核 queue 需要另一次明確批准與 DB 備援檢查",
+                "write_status": "blocked",
+            },
+        ],
+        "safe_boundaries": [
+            *handoff["safe_boundaries"],
+            "do_not_create_candidate_review_queue_from_preview",
+            "do_not_persist_candidate_review_queue_draft",
+            "do_not_write_market_tables_from_queue_draft",
+            "do_not_auto_approve_candidates",
+            "do_not_attach_scheduler_from_queue_draft",
+            "do_not_touch_momo_db_lifecycle",
+        ],
+    }

services/market_intel/service.py

@@ -36,6 +36,9 @@ from services.market_intel.manual_sample_plan import (
 from services.market_intel.manual_sample_acceptance import (
     build_manual_sample_acceptance_preview,
 )
+from services.market_intel.manual_sample_candidate_queue import (
+    build_manual_sample_candidate_queue_draft_preview,
+)
 from services.market_intel.manual_sample_review import (
     build_manual_sample_candidate_handoff_preview,
     build_manual_sample_review_evaluation_preview,
@@ -103,7 +106,7 @@ class MarketIntelRuntimeStatus:
 class MarketIntelService:
     """市場情報入口服務，先集中 feature gate 與安全狀態。"""
 
-    phase = "phase_51_manual_sample_candidate_handoff"
+    phase = "phase_52_manual_sample_candidate_queue_draft"
 
     def get_runtime_status(self) -> MarketIntelRuntimeStatus:
         return MarketIntelRuntimeStatus(
@@ -494,6 +497,23 @@ class MarketIntelService:
         handoff["phase"] = self.phase
         return handoff
 
+    def build_manual_sample_candidate_queue_draft(
+        self,
+        sample_result=None,
+        payload_error=None,
+        limit=20,
+    ):
+        """回報人工候選活動審核 queue 草案；只產生 preview，不寫 DB。"""
+        queue_draft = build_manual_sample_candidate_queue_draft_preview(
+            runtime_status=self.get_runtime_status(),
+            acceptance_contract=self.build_manual_sample_acceptance(),
+            sample_result=sample_result,
+            payload_error=payload_error,
+            limit=limit,
+        )
+        queue_draft["phase"] = self.phase
+        return queue_draft
+
     def build_match_review_plan(self):
         """回報商品比對審核計畫；不建立 queue、不自動確認。"""
         schema_smoke = self.build_schema_smoke()

templates/market_intel/disabled.html

@@ -251,7 +251,7 @@
         align-items: stretch;
         display: grid;
         gap: 0.75rem;
-        grid-template-columns: minmax(0, 1fr) auto auto;
+        grid-template-columns: minmax(0, 1fr) auto auto auto;
         min-width: 0;
     }
 
@@ -579,6 +579,9 @@
             <button class="market-intel-icon-button" type="button" title="產生候選活動 handoff" data-market-intel-sample-candidate-handoff>
                 <i class="fas fa-arrow-right" aria-hidden="true"></i>
             </button>
+            <button class="market-intel-icon-button" type="button" title="產生候選審核 queue 草案" data-market-intel-sample-candidate-queue-draft>
+                <i class="fas fa-clipboard-list" aria-hidden="true"></i>
+            </button>
         </div>
     </div>
 
@@ -904,9 +907,11 @@
         const sampleReviewInput = sampleReviewRoot ? sampleReviewRoot.querySelector('[data-market-intel-sample-review-input]') : null;
         const sampleReviewEvaluate = sampleReviewRoot ? sampleReviewRoot.querySelector('[data-market-intel-sample-review-evaluate]') : null;
         const sampleCandidateHandoff = sampleReviewRoot ? sampleReviewRoot.querySelector('[data-market-intel-sample-candidate-handoff]') : null;
+        const sampleCandidateQueueDraft = sampleReviewRoot ? sampleReviewRoot.querySelector('[data-market-intel-sample-candidate-queue-draft]') : null;
         const sampleReviewEndpoint = "{{ url_for('market_intel.market_intel_manual_sample_review') }}";
         const sampleReviewEvaluateEndpoint = "{{ url_for('market_intel.market_intel_manual_sample_review_evaluate') }}";
         const sampleCandidateHandoffEndpoint = "{{ url_for('market_intel.market_intel_manual_sample_candidate_handoff') }}";
+        const sampleCandidateQueueDraftEndpoint = "{{ url_for('market_intel.market_intel_manual_sample_candidate_queue_draft') }}";
         const schedulerMeta = schedulerRoot ? schedulerRoot.querySelector('[data-market-intel-scheduler-meta]') : null;
         const schedulerBody = schedulerRoot ? schedulerRoot.querySelector('[data-market-intel-scheduler-body]') : null;
         const schedulerRefresh = schedulerRoot ? schedulerRoot.querySelector('[data-market-intel-scheduler-refresh]') : null;
@@ -2063,6 +2068,65 @@
             }
         };
 
+        const renderCandidateQueueDraft = data => {
+            const blockers = (data.blocked_reasons || []).join(' / ');
+            const summary = data.queue_summary || {};
+            const queueItems = data.queue_items || [];
+            sampleReviewMeta.innerHTML = [
+                `mode=${data.mode || 'unknown'}`,
+                `queue=${data.queue_draft_ready ? 'ready' : 'blocked'}`,
+                `items=${summary.queue_item_count || 0}`,
+                `persisted=${data.review_queue_persisted ? 'yes' : 'no'}`,
+                `import=${data.candidate_import_allowed ? 'open' : 'blocked'}`
+            ].map(item => `<span class="market-intel-pill">${escapeHtml(item)}</span>`).join('');
+            sampleReviewBody.innerHTML = `
+                <div class="market-intel-empty mb-3">此卡只產生候選審核 queue 草案；不建立正式 queue、不寫 DB、不自動核准候選。${blockers ? `阻擋：${escapeHtml(blockers)}` : ''}</div>
+                <div class="market-intel-operation-list">${
+                    queueItems.length
+                        ? queueItems.map(item => `
+                            <article class="market-intel-operation">
+                                <strong>${escapeHtml(item.candidate_text || item.candidate_url)}</strong>
+                                <small>${escapeHtml(item.platform_code)} / ${escapeHtml(item.confidence_band)} / score=${escapeHtml(item.score)} / priority=${escapeHtml(item.review_priority)} / ${escapeHtml(item.review_state)}</small>
+                                <small>${escapeHtml(item.write_status)} / approval=${item.approval_required ? 'required' : 'none'}</small>
+                                <small>${escapeHtml(item.candidate_url)}</small>
+                            </article>
+                        `).join('')
+                        : '<div class="market-intel-empty">目前沒有可建立草案的候選；請先產生通過審核的 handoff。</div>'
+                }</div>
+            `;
+        };
+
+        const loadCandidateQueueDraft = async () => {
+            if (!sampleReviewMeta || !sampleReviewBody || !sampleReviewInput) return;
+            let parsed;
+            try {
+                parsed = JSON.parse(sampleReviewInput.value || '{}');
+            } catch (error) {
+                sampleReviewMeta.innerHTML = '<span class="market-intel-pill">json_error</span>';
+                sampleReviewBody.innerHTML = `<div class="market-intel-empty">JSON 格式錯誤：${escapeHtml(error.message)}</div>`;
+                return;
+            }
+
+            sampleReviewBody.innerHTML = '<div class="market-intel-empty">產生候選審核 queue 草案中...</div>';
+            try {
+                const response = await fetch(sampleCandidateQueueDraftEndpoint, {
+                    method: 'POST',
+                    credentials: 'same-origin',
+                    headers: {
+                        'Content-Type': 'application/json',
+                        'X-CSRFToken': csrfToken
+                    },
+                    body: JSON.stringify({ sample_result: parsed })
+                });
+                const data = await response.json();
+                if (!response.ok && !data.mode) throw new Error(`HTTP ${response.status}`);
+                renderCandidateQueueDraft(data);
+            } catch (error) {
+                sampleReviewMeta.innerHTML = '<span class="market-intel-pill">error</span>';
+                sampleReviewBody.innerHTML = `<div class="market-intel-empty">候選審核 queue 草案產生失敗：${escapeHtml(error.message)}</div>`;
+            }
+        };
+
         const renderSchedulerMeta = data => {
             schedulerMeta.innerHTML = [
                 `mode=${data.mode || 'unknown'}`,
@@ -3560,6 +3624,9 @@
         if (sampleCandidateHandoff) {
             sampleCandidateHandoff.addEventListener('click', loadCandidateHandoff);
         }
+        if (sampleCandidateQueueDraft) {
+            sampleCandidateQueueDraft.addEventListener('click', loadCandidateQueueDraft);
+        }
         if (schedulerRefresh) {
             schedulerRefresh.addEventListener('click', loadScheduler);
         }

tests/test_market_intel_skeleton.py

@@ -519,6 +519,7 @@ def test_market_intel_preview_template_uses_safe_fetch_false_endpoint():
     assert "data-market-intel-sample-review-input" in template
     assert "data-market-intel-sample-review-evaluate" in template
     assert "data-market-intel-sample-candidate-handoff" in template
+    assert "data-market-intel-sample-candidate-queue-draft" in template
     assert "data-market-intel-approval" in template
     assert "data-market-intel-approval-gates" in template
     assert "data-market-intel-deploy" in template
@@ -539,6 +540,7 @@ def test_market_intel_preview_template_uses_safe_fetch_false_endpoint():
     assert "market_intel.market_intel_manual_sample_review" in template
     assert "market_intel.market_intel_manual_sample_review_evaluate" in template
     assert "market_intel.market_intel_manual_sample_candidate_handoff" in template
+    assert "market_intel.market_intel_manual_sample_candidate_queue_draft" in template
     assert "X-CSRFToken" in template
     assert "market_intel.market_intel_scheduler_plan" in template
     assert "market_intel.market_intel_match_review_plan" in template
@@ -575,7 +577,7 @@ def test_legacy_source_bridge_default_is_planned_only():
     bridge = MarketIntelService().build_legacy_source_bridge()
 
     assert bridge["mode"] == "legacy_source_bridge_planned"
-    assert bridge["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert bridge["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert bridge["execute_requested"] is False
     assert bridge["read_only_query_executed"] is False
     assert bridge["database_connection_opened"] is False
@@ -733,7 +735,7 @@ def test_mcp_tool_contract_preview_is_read_only_and_whitelisted():
     contract = MarketIntelService().build_mcp_tool_contract()
 
     assert contract["mode"] == "mcp_tool_contract_preview"
-    assert contract["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert contract["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert contract["caller"] == "market_intel"
     assert contract["contract_ready"] is True
     assert contract["blocked_reasons"] == []
@@ -866,7 +868,7 @@ def test_mcp_activation_runbook_route_is_preview_only():
 
     assert response.status_code == 200
     assert data["mode"] == "mcp_activation_runbook_preview"
-    assert data["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert data["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert data["deployment_actions_executed"] is False
     assert data["docker_command_executed"] is False
     assert data["ssh_command_executed"] is False
@@ -879,7 +881,7 @@ def test_mcp_fetch_gate_default_blocks_external_fetch():
     gate = MarketIntelService().build_mcp_fetch_gate(fetch_requested=True)
 
     assert gate["mode"] == "mcp_fetch_gate_planned"
-    assert gate["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert gate["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert gate["fetch_requested"] is True
     assert gate["manual_fetch_gate_open"] is False
     assert gate["network_request_allowed"] is False
@@ -949,7 +951,7 @@ def test_mcp_fetch_gate_route_is_preview_only():
 
     assert response.status_code == 200
     assert data["mode"] == "mcp_fetch_gate_planned"
-    assert data["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert data["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert data["fetch_requested"] is False
     assert data["network_request_allowed"] is False
     assert data["external_network_executed"] is False
@@ -961,7 +963,7 @@ def test_manual_sample_plan_preview_blocks_fetch_and_write():
     plan = MarketIntelService().build_manual_sample_plan()
 
     assert plan["mode"] == "manual_sample_fetch_plan_preview"
-    assert plan["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert plan["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert plan["ready_for_manual_sample_fetch"] is False
     assert plan["sample_fetch_executed"] is False
     assert plan["external_network_executed"] is False
@@ -1009,7 +1011,7 @@ def test_manual_sample_plan_route_is_preview_only():
 
     assert response.status_code == 200
     assert data["mode"] == "manual_sample_fetch_plan_preview"
-    assert data["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert data["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert data["sample_fetch_executed"] is False
     assert data["external_network_executed"] is False
     assert data["database_write_executed"] is False
@@ -1020,7 +1022,7 @@ def test_manual_sample_acceptance_preview_blocks_candidate_import():
     acceptance = MarketIntelService().build_manual_sample_acceptance()
 
     assert acceptance["mode"] == "manual_sample_acceptance_preview"
-    assert acceptance["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert acceptance["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert acceptance["contract_ready"] is True
     assert acceptance["sample_result_loaded"] is False
     assert acceptance["sample_result_accepted"] is False
@@ -1062,7 +1064,7 @@ def test_manual_sample_acceptance_route_is_preview_only():
 
     assert response.status_code == 200
     assert data["mode"] == "manual_sample_acceptance_preview"
-    assert data["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert data["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert data["sample_result_loaded"] is False
     assert data["candidate_import_allowed"] is False
     assert data["external_network_executed"] is False
@@ -1074,7 +1076,7 @@ def test_manual_sample_review_preview_is_planned_until_result_loaded():
     review = MarketIntelService().build_manual_sample_review()
 
     assert review["mode"] == "manual_sample_review_preview"
-    assert review["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert review["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert review["contract_ready"] is True
     assert review["sample_result_loaded"] is False
     assert review["sample_result_reviewed"] is False
@@ -1185,7 +1187,7 @@ def test_manual_sample_review_route_is_preview_only():
 
     assert response.status_code == 200
     assert data["mode"] == "manual_sample_review_preview"
-    assert data["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert data["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert data["sample_result_loaded"] is False
     assert data["sample_result_reviewed"] is False
     assert data["candidate_import_allowed"] is False
@@ -1224,7 +1226,7 @@ def test_manual_sample_review_evaluation_preview_accepts_payload_without_persist
     )
 
     assert review["mode"] == "manual_sample_review_evaluation_preview"
-    assert review["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert review["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert review["review_request_type"] == "operator_posted_json"
     assert review["payload_received"] is True
     assert review["payload_valid_json_object"] is True
@@ -1286,7 +1288,7 @@ def test_manual_sample_review_evaluate_route_is_post_only_and_no_write():
 
     assert response.status_code == 200
     assert data["mode"] == "manual_sample_review_evaluation_preview"
-    assert data["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert data["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert data["payload_received"] is True
     assert data["payload_valid_json_object"] is True
     assert data["payload_persisted"] is False
@@ -1366,7 +1368,7 @@ def test_manual_sample_candidate_handoff_preview_creates_candidates_without_pers
     )
 
     assert handoff["mode"] == "manual_sample_candidate_handoff_preview"
-    assert handoff["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert handoff["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert handoff["payload_received"] is True
     assert handoff["payload_valid_json_object"] is True
     assert handoff["payload_persisted"] is False
@@ -1430,7 +1432,7 @@ def test_manual_sample_candidate_handoff_route_is_post_only_and_no_write():
 
     assert response.status_code == 200
     assert data["mode"] == "manual_sample_candidate_handoff_preview"
-    assert data["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert data["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert data["payload_received"] is True
     assert data["handoff_ready"] is True
     assert data["candidate_handoff_created"] is True
@@ -1459,11 +1461,144 @@ def test_manual_sample_candidate_handoff_blocks_invalid_payload():
     assert "candidate_handoff_not_ready" in handoff["blocked_reasons"]
 
 
+def test_manual_sample_candidate_queue_draft_preview_builds_review_items_without_persisting():
+    sample_result = {
+        "batch_id": "sample-batch-7",
+        "platform_code": "coupang",
+        "source_key": "homepage",
+        "source_url": "https://www.tw.coupang.com/",
+        "status": "fetched",
+        "status_code": 200,
+        "content_length": 1800,
+        "page_hash": "a" * 64,
+        "title": "酷澎活動",
+        "diagnostics": {
+            "link_count": 3,
+            "same_host_link_count": 2,
+            "campaign_link_candidates": [
+                {
+                    "confidence_band": "high",
+                    "score": 95,
+                    "url": "https://www.tw.coupang.com/promotion/sample",
+                    "text": "限時活動",
+                }
+            ],
+        },
+    }
+
+    queue_draft = MarketIntelService().build_manual_sample_candidate_queue_draft(
+        sample_result=sample_result
+    )
+
+    assert queue_draft["mode"] == "manual_sample_candidate_queue_draft_preview"
+    assert queue_draft["phase"] == "phase_52_manual_sample_candidate_queue_draft"
+    assert queue_draft["payload_received"] is True
+    assert queue_draft["payload_valid_json_object"] is True
+    assert queue_draft["payload_persisted"] is False
+    assert queue_draft["sample_result_persisted"] is False
+    assert queue_draft["handoff_ready"] is True
+    assert queue_draft["queue_draft_ready"] is True
+    assert queue_draft["review_queue_draft_created"] is True
+    assert queue_draft["review_queue_created"] is False
+    assert queue_draft["review_queue_persisted"] is False
+    assert queue_draft["candidate_import_allowed"] is False
+    assert queue_draft["external_network_executed"] is False
+    assert queue_draft["database_connection_opened"] is False
+    assert queue_draft["database_session_created"] is False
+    assert queue_draft["database_write_executed"] is False
+    assert queue_draft["database_commit_executed"] is False
+    assert queue_draft["scheduler_attached"] is False
+    assert queue_draft["queue_summary"]["queue_item_count"] == 1
+    assert queue_draft["queue_items"][0]["review_state"] == "needs_review"
+    assert queue_draft["queue_items"][0]["review_priority"] == 80
+    assert queue_draft["queue_items"][0]["write_status"] == "blocked_preview_only"
+    assert queue_draft["queue_items"][0]["approval_required"] is True
+    assert (
+        "do_not_persist_candidate_review_queue_draft"
+        in queue_draft["safe_boundaries"]
+    )
+
+
+def test_manual_sample_candidate_queue_draft_route_is_post_only_and_no_write():
+    from routes.market_intel_routes import market_intel_bp
+
+    app = Flask(__name__)
+    app.secret_key = "test-secret"
+    app.register_blueprint(market_intel_bp)
+    client = app.test_client()
+    with client.session_transaction() as session:
+        session["logged_in"] = True
+
+    response = client.post(
+        "/api/market_intel/manual_sample_review/candidate_queue_draft",
+        json={
+            "sample_result": {
+                "batch_id": "sample-batch-8",
+                "platform_code": "shopee",
+                "source_key": "homepage",
+                "source_url": "https://shopee.tw/",
+                "status": "fetched",
+                "status_code": 200,
+                "content_length": 1900,
+                "page_hash": "b" * 64,
+                "title": "蝦皮活動",
+                "diagnostics": {
+                    "link_count": 2,
+                    "same_host_link_count": 2,
+                    "campaign_link_candidates": [
+                        {
+                            "confidence_band": "medium",
+                            "score": 72,
+                            "url": "https://shopee.tw/m/sample-campaign",
+                            "text": "商城活動",
+                        },
+                    ],
+                },
+            }
+        },
+    )
+    data = response.get_json()
+
+    assert response.status_code == 200
+    assert data["mode"] == "manual_sample_candidate_queue_draft_preview"
+    assert data["phase"] == "phase_52_manual_sample_candidate_queue_draft"
+    assert data["payload_received"] is True
+    assert data["handoff_ready"] is True
+    assert data["queue_draft_ready"] is True
+    assert data["review_queue_draft_created"] is True
+    assert data["review_queue_created"] is False
+    assert data["review_queue_persisted"] is False
+    assert data["candidate_import_allowed"] is False
+    assert data["external_network_executed"] is False
+    assert data["database_write_executed"] is False
+    assert data["scheduler_attached"] is False
+    assert data["queue_summary"]["queue_item_count"] == 1
+
+
+def test_manual_sample_candidate_queue_draft_blocks_invalid_payload():
+    queue_draft = MarketIntelService().build_manual_sample_candidate_queue_draft(
+        sample_result=None,
+        payload_error="invalid_json_object",
+    )
+
+    assert queue_draft["mode"] == "manual_sample_candidate_queue_draft_preview"
+    assert queue_draft["payload_received"] is False
+    assert queue_draft["payload_valid_json_object"] is False
+    assert queue_draft["handoff_ready"] is False
+    assert queue_draft["queue_draft_ready"] is False
+    assert queue_draft["review_queue_draft_created"] is False
+    assert queue_draft["review_queue_created"] is False
+    assert queue_draft["review_queue_persisted"] is False
+    assert queue_draft["candidate_import_allowed"] is False
+    assert queue_draft["database_write_executed"] is False
+    assert "review_queue_draft_not_ready" in queue_draft["blocked_reasons"]
+
+
 def test_scheduler_plan_preview_blocks_job_attachment():
     plan = MarketIntelService().build_scheduler_plan()
 
     assert plan["mode"] == "scheduler_attach_plan_preview"
-    assert plan["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert plan["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert plan["ready_to_attach_scheduler"] is False
     assert plan["scheduler_attached"] is False
     assert plan["scheduler_registration_executed"] is False
@@ -1501,7 +1636,7 @@ def test_scheduler_plan_route_is_preview_only():
 
     assert response.status_code == 200
     assert data["mode"] == "scheduler_attach_plan_preview"
-    assert data["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert data["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert data["scheduler_registration_executed"] is False
     assert data["crawler_job_started"] is False
     assert data["external_network_executed"] is False
@@ -1512,7 +1647,7 @@ def test_match_review_plan_preview_blocks_auto_confirm():
     plan = MarketIntelService().build_match_review_plan()
 
     assert plan["mode"] == "match_review_plan_preview"
-    assert plan["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert plan["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert plan["ready_for_review_queue"] is False
     assert plan["review_queue_created"] is False
     assert plan["auto_match_executed"] is False
@@ -1548,7 +1683,7 @@ def test_match_review_plan_route_is_preview_only():
 
     assert response.status_code == 200
     assert data["mode"] == "match_review_plan_preview"
-    assert data["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert data["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert data["review_queue_created"] is False
     assert data["auto_confirm_executed"] is False
     assert data["external_network_executed"] is False
@@ -1559,7 +1694,7 @@ def test_opportunity_plan_preview_blocks_alerts_and_ai_summary():
     plan = MarketIntelService().build_opportunity_plan()
 
     assert plan["mode"] == "opportunity_plan_preview"
-    assert plan["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert plan["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert plan["ready_for_opportunity_queue"] is False
     assert plan["opportunity_queue_created"] is False
     assert plan["threat_alert_dispatched"] is False
@@ -1600,7 +1735,7 @@ def test_opportunity_plan_route_is_preview_only():
 
     assert response.status_code == 200
     assert data["mode"] == "opportunity_plan_preview"
-    assert data["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert data["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert data["opportunity_queue_created"] is False
     assert data["threat_alert_dispatched"] is False
     assert data["ai_summary_generated"] is False
@@ -1611,7 +1746,7 @@ def test_opportunity_scoring_plan_preview_blocks_scoring_and_alerts():
     plan = MarketIntelService().build_opportunity_scoring_plan()
 
     assert plan["mode"] == "opportunity_scoring_plan_preview"
-    assert plan["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert plan["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert plan["ready_for_scoring_job"] is False
     assert plan["scoring_job_created"] is False
     assert plan["score_calculation_executed"] is False
@@ -1659,7 +1794,7 @@ def test_opportunity_scoring_plan_route_is_preview_only():
 
     assert response.status_code == 200
     assert data["mode"] == "opportunity_scoring_plan_preview"
-    assert data["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert data["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert data["scoring_job_created"] is False
     assert data["score_calculation_executed"] is False
     assert data["sample_scores_generated"] is False
@@ -1671,7 +1806,7 @@ def test_opportunity_evidence_plan_preview_blocks_queries_and_alerts():
     plan = MarketIntelService().build_opportunity_evidence_plan()
 
     assert plan["mode"] == "opportunity_evidence_plan_preview"
-    assert plan["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert plan["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert plan["ready_for_evidence_bundle"] is False
     assert plan["evidence_bundle_created"] is False
     assert plan["evidence_query_executed"] is False
@@ -1717,7 +1852,7 @@ def test_opportunity_evidence_plan_route_is_preview_only():
 
     assert response.status_code == 200
     assert data["mode"] == "opportunity_evidence_plan_preview"
-    assert data["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert data["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert data["evidence_bundle_created"] is False
     assert data["evidence_query_executed"] is False
     assert data["sample_evidence_generated"] is False
@@ -1730,7 +1865,7 @@ def test_opportunity_alert_plan_preview_blocks_dispatch_and_llm_calls():
     plan = MarketIntelService().build_opportunity_alert_plan()
 
     assert plan["mode"] == "opportunity_alert_plan_preview"
-    assert plan["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert plan["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert plan["ready_for_alert_candidates"] is False
     assert plan["alert_candidate_created"] is False
     assert plan["alert_queue_created"] is False
@@ -1815,7 +1950,7 @@ def test_opportunity_alert_plan_route_is_preview_only():
 
     assert response.status_code == 200
     assert data["mode"] == "opportunity_alert_plan_preview"
-    assert data["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert data["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert data["alert_candidate_created"] is False
     assert data["alert_queue_created"] is False
     assert data["review_queue_created"] is False
@@ -1893,7 +2028,7 @@ def test_mcp_deploy_preflight_route_is_preview_only():
 
     assert response.status_code == 200
     assert data["mode"] == "mcp_external_deploy_preflight_preview"
-    assert data["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert data["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert data["deployment_actions_executed"] is False
     assert data["docker_command_executed"] is False
     assert data["ssh_command_executed"] is False
@@ -1908,7 +2043,7 @@ def test_mcp_readiness_default_is_planned_only(monkeypatch):
     readiness = MarketIntelService().build_mcp_readiness()
 
     assert readiness["mode"] == "mcp_readiness_planned"
-    assert readiness["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert readiness["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert readiness["execute_requested"] is False
     assert readiness["router_enabled"] is False
     assert readiness["external_mcp_complete"] is False
@@ -2301,6 +2436,7 @@ def test_deployment_readiness_reports_app_only_release_gate():
     assert readiness["checks"]["manual_sample_review_preview_safe"] is True
     assert readiness["checks"]["manual_sample_review_evaluation_post_safe"] is True
     assert readiness["checks"]["manual_sample_candidate_handoff_post_safe"] is True
+    assert readiness["checks"]["manual_sample_candidate_queue_draft_post_safe"] is True
     assert readiness["checks"]["match_review_plan_preview_safe"] is True
     assert readiness["checks"]["opportunity_plan_preview_safe"] is True
     assert readiness["checks"]["opportunity_scoring_plan_preview_safe"] is True
@@ -2441,6 +2577,42 @@ def test_deployment_readiness_reports_app_only_release_gate():
         is False
     )
     assert readiness["manual_sample_candidate_handoff"]["scheduler_attached"] is False
+    assert (
+        readiness["manual_sample_candidate_queue_draft"]["mode"]
+        == "manual_sample_candidate_queue_draft_preview"
+    )
+    assert (
+        readiness["manual_sample_candidate_queue_draft"]["payload_received"]
+        is True
+    )
+    assert (
+        readiness["manual_sample_candidate_queue_draft"]["payload_persisted"]
+        is False
+    )
+    assert (
+        readiness["manual_sample_candidate_queue_draft"]["review_queue_created"]
+        is False
+    )
+    assert (
+        readiness["manual_sample_candidate_queue_draft"]["review_queue_persisted"]
+        is False
+    )
+    assert (
+        readiness["manual_sample_candidate_queue_draft"]["candidate_import_allowed"]
+        is False
+    )
+    assert (
+        readiness["manual_sample_candidate_queue_draft"]["external_network_executed"]
+        is False
+    )
+    assert (
+        readiness["manual_sample_candidate_queue_draft"]["database_write_executed"]
+        is False
+    )
+    assert (
+        readiness["manual_sample_candidate_queue_draft"]["scheduler_attached"]
+        is False
+    )
     assert readiness["scheduler_plan"]["scheduler_registration_executed"] is False
     assert readiness["scheduler_plan"]["crawler_job_started"] is False
     assert readiness["scheduler_plan"]["database_write_executed"] is False
@@ -2545,7 +2717,7 @@ def test_migration_apply_drill_planned_is_safe_and_manual_only():
     drill = MarketIntelService().build_migration_apply_drill()
 
     assert drill["mode"] == "migration_apply_drill_preview"
-    assert drill["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert drill["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert drill["execute_requested"] is False
     assert drill["schema_state"] == "planned_no_db_probe"
     assert drill["drill_ready_for_operator_review"] is True
@@ -2660,7 +2832,7 @@ def test_migration_apply_drill_route_is_preview_only():
 
     assert response.status_code == 200
     assert data["mode"] == "migration_apply_drill_preview"
-    assert data["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert data["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert data["execute_requested"] is False
     assert data["migration_executed"] is False
     assert data["rollback_executed"] is False
@@ -2672,7 +2844,7 @@ def test_migration_catalog_review_planned_is_safe_and_diagnostic():
     review = MarketIntelService().build_migration_catalog_review()
 
     assert review["mode"] == "migration_catalog_review_preview"
-    assert review["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert review["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert review["execute_requested"] is False
     assert review["catalog_state"] == "planned_no_probe"
     assert review["seed_state"] == "planned_no_probe"
@@ -2787,7 +2959,7 @@ def test_migration_catalog_review_route_is_preview_only():
 
     assert response.status_code == 200
     assert data["mode"] == "migration_catalog_review_preview"
-    assert data["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert data["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert data["execute_requested"] is False
     assert data["catalog_state"] == "planned_no_probe"
     assert data["migration_executed"] is False
@@ -2800,7 +2972,7 @@ def test_migration_live_smoke_planned_is_preview_only():
     smoke = MarketIntelService().build_migration_live_smoke()
 
     assert smoke["mode"] == "migration_live_smoke_preview"
-    assert smoke["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert smoke["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert smoke["execute_requested"] is False
     assert smoke["smoke_result"] == "planned_no_execution"
     assert smoke["live_smoke_passed"] is False
@@ -2862,7 +3034,7 @@ def test_migration_live_smoke_route_is_preview_only():
 
     assert response.status_code == 200
     assert data["mode"] == "migration_live_smoke_preview"
-    assert data["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert data["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert data["execute_requested"] is False
     assert data["smoke_result"] == "planned_no_execution"
     assert data["migration_executed"] is False
@@ -2875,7 +3047,7 @@ def test_live_db_inventory_planned_is_preview_only():
     inventory = MarketIntelService().build_live_db_inventory()
 
     assert inventory["mode"] == "live_db_inventory_planned"
-    assert inventory["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert inventory["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert inventory["execute_requested"] is False
     assert inventory["read_only_query_executed"] is False
     assert inventory["database_connection_opened"] is False
@@ -3019,7 +3191,7 @@ def test_live_db_inventory_route_is_preview_only():
 
     assert response.status_code == 200
     assert data["mode"] == "live_db_inventory_planned"
-    assert data["phase"] == "phase_51_manual_sample_candidate_handoff"
+    assert data["phase"] == "phase_52_manual_sample_candidate_queue_draft"
     assert data["execute_requested"] is False
     assert data["read_only_query_executed"] is False
     assert data["database_write_executed"] is False