From 02f9b49d4d3e47f32a115c420fd0b0b3dca848ff Mon Sep 17 00:00:00 2001
From: OoO <ooo@MacBook-Pro.local>
Date: Tue, 19 May 2026 14:55:56 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=AD=A3=E5=B8=82=E5=A0=B4=E6=83=85?=
 =?UTF-8?q?=E5=A0=B1=20operator=20drill=20API=20gate?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 routes/market_intel_review_routes.py | 80 ++--------------------------
 1 file changed, 4 insertions(+), 76 deletions(-)

diff --git a/routes/market_intel_review_routes.py b/routes/market_intel_review_routes.py
index 020d606..e2afc7d 100644
--- a/routes/market_intel_review_routes.py
+++ b/routes/market_intel_review_routes.py
@@ -241,80 +241,6 @@ def _build_review_decision_transaction_stack(
     )
 
 
-def _live_inventory_from_postwrite_smoke(postwrite_smoke_result):
-    postwrite_smoke_result = (
-        postwrite_smoke_result if isinstance(postwrite_smoke_result, dict) else {}
-    )
-    row_summaries = postwrite_smoke_result.get("row_summaries") or []
-    return {
-        "mode": "live_db_inventory_from_postwrite_smoke_preview",
-        "summary_ready": bool(postwrite_smoke_result.get("postwrite_smoke_passed")),
-        "read_only_query_executed": bool(
-            postwrite_smoke_result.get("read_only_query_executed")
-        ),
-        "database_connection_opened": False,
-        "database_session_created": False,
-        "database_write_executed": False,
-        "database_commit_executed": False,
-        "external_network_executed": False,
-        "scheduler_attached": False,
-        "writes_executed": False,
-        "would_write_database": False,
-        "total_rows": postwrite_smoke_result.get("found_count"),
-        "alert_review_state_breakdown": [],
-        "table_statuses": [
-            {
-                "table": "market_alert_review_queue",
-                "exists": bool(row_summaries),
-                "row_count": len(row_summaries),
-                "status": "from_postwrite_smoke_result",
-            }
-        ],
-    }
-
-
-def _build_review_decision_transaction_stack_from_postwrite_evidence(
-    *,
-    service,
-    sample_result,
-    payload_error,
-    operator_evidence,
-    writer_output,
-    postwrite_smoke_result,
-    limit,
-):
-    transaction_preview, handoff = _build_closeout_stack(
-        service=service,
-        sample_result=sample_result,
-        payload_error=payload_error,
-        operator_evidence=operator_evidence,
-        writer_output=writer_output,
-        postwrite_smoke_result=postwrite_smoke_result,
-        limit=limit,
-    )
-    inventory = build_candidate_queue_review_inventory(
-        review_handoff=handoff,
-        postwrite_smoke=postwrite_smoke_result,
-        live_db_inventory=_live_inventory_from_postwrite_smoke(
-            postwrite_smoke_result
-        ),
-        operator_evidence=operator_evidence,
-        execute_requested=False,
-    )
-    decision = build_candidate_queue_review_decision(
-        review_inventory=inventory,
-        operator_evidence=operator_evidence,
-    )
-    approval = build_candidate_queue_review_decision_approval(
-        review_decision=decision,
-        operator_evidence=operator_evidence,
-    )
-    return build_candidate_queue_review_decision_transaction(
-        decision_approval=approval,
-        operator_evidence=operator_evidence,
-    )
-
-
 @market_intel_review_bp.route(
     "/api/market_intel/manual_sample_review/candidate_queue_review_inventory",
     methods=["POST"],
@@ -525,7 +451,7 @@ def market_intel_manual_sample_candidate_queue_review_decision_writer_postwrite_
     sample_result, operator_evidence, writer_output, smoke_result, payload_error, limit = (
         _extract_run_payload()
     )
-    transaction = _build_review_decision_transaction_stack_from_postwrite_evidence(
+    transaction = _build_review_decision_transaction_stack(
         service=service,
         sample_result=sample_result,
         payload_error=payload_error,
@@ -533,6 +459,7 @@ def market_intel_manual_sample_candidate_queue_review_decision_writer_postwrite_
         writer_output=writer_output,
         postwrite_smoke_result=smoke_result,
         limit=limit,
+        execute_requested=False,
     )
     data = build_candidate_queue_review_decision_writer_postwrite_smoke(
         transaction_preview=transaction,
@@ -553,7 +480,7 @@ def market_intel_manual_sample_candidate_queue_review_decision_writer_operator_d
     sample_result, operator_evidence, writer_output, smoke_result, payload_error, limit = (
         _extract_run_payload()
     )
-    transaction = _build_review_decision_transaction_stack_from_postwrite_evidence(
+    transaction = _build_review_decision_transaction_stack(
         service=service,
         sample_result=sample_result,
         payload_error=payload_error,
@@ -561,6 +488,7 @@ def market_intel_manual_sample_candidate_queue_review_decision_writer_operator_d
         writer_output=writer_output,
         postwrite_smoke_result=smoke_result,
         limit=limit,
+        execute_requested=False,
     )
     writer_status = build_candidate_queue_review_decision_writer_cli_plan(
         transaction_preview=transaction,