V10.501 新增市場情報 writer post-closeout inventory review gate

TODO_NEXT_STEPS.txt

@@ -4,6 +4,7 @@
 ================================================================================
 
 【已完成】
+   - V10.501 新增市場情報 MCP Fetch Candidate Queue Writer Post-Closeout Inventory Review 安全預覽 gate：只審核 closeout review 後由操作員 shell 完成的 live inventory read-only 摘要，確認 closeout linkage、row count、inventory artifact、closeout review artifact、read-only query result、missing/duplicate rows 與 operator confirmation；API 不讀 token、不執行 CLI、不開 DB、不寫 queue、不做 inventory query、不掛 scheduler。
    - V10.500 新增市場情報 MCP Fetch Candidate Queue Writer Run Closeout Review 安全預覽 gate：只審核 receipt review 通過後的 operator closeout 摘要，確認 receipt linkage、closeout artifact、receipt review artifact、post-closeout inventory plan、writer output / post-write smoke / backup manifest、rollback note 與 operator confirmation；API 不讀 receipt 原文、不讀 token、不執行 CLI、不開 DB、不寫 queue、不做 post-closeout query、不掛 scheduler。
    - V10.499 新增市場情報 MCP Fetch Candidate Queue Writer Run Receipt Review 安全預覽 gate：只審核操作員 shell writer run 後貼回的 receipt 摘要，確認 readiness linkage、run package id、候選/dedupe keys、writer output、post-write smoke、backup path 與 operator confirmation；API 不讀 receipt 原文、不讀 token、不執行 CLI、不開 DB、不寫 queue、不做 post-write query、不掛 scheduler。
    - V10.498 新增市場情報 MCP Fetch Candidate Queue Writer Run Readiness 安全預覽 gate：只審核 run package review 後的操作員 readiness 證據，確認 run readiness artifact、reviewed sample、備份、read-only preflight 與 post-write smoke 路徑安全，以及 CLI-only / approval token shell-only 邊界；API 不產檔、不讀 token、不執行 CLI、不開 DB、不寫 queue、不掛 scheduler。

config.py

@@ -350,7 +350,7 @@ YOUTUBE_API_KEY = os.getenv('YOUTUBE_API_KEY', '')
 # ==========================================
 # 系統版本與路徑
 # ==========================================
-SYSTEM_VERSION = "V10.500"
+SYSTEM_VERSION = "V10.501"
 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

@@ -172,6 +172,7 @@ EwoooC 目前已有 MOMO EDM / 節慶活動資料、`promo_products`、PChome
 - 2026-05-31 追加 MCP fetch candidate queue writer run readiness gate：`services.market_intel.mcp_fetch_candidate_queue_writer_run_readiness` 與 `/api/market_intel/mcp_fetch_candidate_queue_writer_run_readiness` 在 run package review 通過後審核 operator readiness 證據，檢查 run readiness artifact、reviewed sample、備份、read-only preflight、post-write smoke 路徑、操作員覆核確認、CLI-only 與 approval token shell-only 邊界；API/UI 不產檔、不讀 approval token、不執行 CLI、不開 DB、不寫 queue、不掛 scheduler，只放行到後續 run receipt review。
 - 2026-05-31 追加 MCP fetch candidate queue writer run receipt review gate：`services.market_intel.mcp_fetch_candidate_queue_writer_run_receipt_review` 與 `/api/market_intel/mcp_fetch_candidate_queue_writer_run_receipt_review` 在 run readiness 通過後審核 operator shell writer run 的 receipt 摘要，檢查 readiness linkage、run package id、候選/dedupe keys、writer output artifact、post-write smoke artifact、backup path、operator confirmations 與 token redaction；API/UI 不讀 receipt 原文、不讀 approval token、不執行 CLI、不開 DB、不寫 queue、不做 post-write query、不掛 scheduler，只放行到 closeout review。
 - 2026-05-31 追加 MCP fetch candidate queue writer run closeout review gate：`services.market_intel.mcp_fetch_candidate_queue_writer_run_closeout_review` 與 `/api/market_intel/mcp_fetch_candidate_queue_writer_run_closeout_review` 在 receipt review 通過後審核 operator closeout 摘要，檢查 receipt linkage、closeout artifact、receipt review artifact、post-closeout inventory plan、writer output / post-write smoke / backup manifest、rollback note 與 operator confirmations；API/UI 不讀 receipt 原文、不讀 approval token、不執行 CLI、不開 DB、不寫 queue、不做 post-closeout query、不掛 scheduler，只放行到 read-only post-closeout inventory review。
+- 2026-05-31 追加 MCP fetch candidate queue writer post-closeout inventory review gate：`services.market_intel.mcp_fetch_candidate_queue_writer_post_closeout_inventory_review` 與 `/api/market_intel/mcp_fetch_candidate_queue_writer_post_closeout_inventory_review` 在 closeout review 通過後審核 operator live inventory read-only 摘要，檢查 closeout linkage、row count、inventory artifact、closeout review artifact、read-only query result、missing/duplicate rows 與 operator confirmations；API/UI 不讀 approval token、不執行 CLI、不開 DB、不寫 queue、不做 inventory query、不掛 scheduler，只放行到 candidate queue review handoff。
 - 2026-05-18 追加 scheduler attach plan preview：`services.market_intel.scheduler_plan` 與 `/api/market_intel/scheduler_plan` 描述未來 `campaign_discovery_daily`、`campaign_product_probe`、`product_match_review_seed` 三個 job 的 cadence、gate、fallback 與安全邊界。此階段不註冊 scheduler job、不啟動 crawler、不連外、不寫 DB；排程掛載必須等 migration、seed、MCP fetch gate、manual sample 與人工批准全過。
 - 2026-05-18 追加 match review plan preview：`services.market_intel.match_review_plan` 與 `/api/market_intel/match_review_plan` 定義商品比對訊號、分數門檻、`needs_review → confirmed/rejected` HITL 流程與安全邊界。此階段不建立 review queue、不自動 confirmed、不寫 `market_product_matches`、不呼叫 MCP；價格只能作為輔助訊號，不能單獨決定同品比對。
 - 2026-05-18 追加 opportunity plan preview：`services.market_intel.opportunity_plan` 與 `/api/market_intel/opportunity_plan` 定義競品低價威脅、促銷缺口、深折重疊、活動即將結束四類規則與分級策略。此階段不建立 opportunity queue、不派送 Telegram、不產生 AI 摘要、不寫 DB；高風險項必須先有 confirmed match 與 DB evidence 才能升級。

docs/memory/code_modularization_inventory_20260430.md

@@ -49,7 +49,8 @@
 - 2026-05-31 追記：同步市場情報 MCP fetch candidate queue writer run package review gate 後的 `services/market_intel/deployment_readiness.py` 行數；本次新增 `services/market_intel/mcp_fetch_candidate_queue_writer_run_package_review.py` 為 660 行，略過 600 行提醒門檻。暫不拆分的理由是 run package gate 需要把 CLI review linkage、artifact manifest、operator shell command sequence 與 side-effect blocklist 放在單一 preview module 便於安全審核；若下一段 run readiness review 重複相同 policy，應抽出 writer policy helper。
 - 2026-05-31 追記：同步市場情報 MCP fetch candidate queue writer run readiness gate 後的 `services/market_intel/deployment_readiness.py` 行數；本次新增 `services/market_intel/mcp_fetch_candidate_queue_writer_run_readiness.py` 為 640 行，略過 600 行提醒門檻。暫不拆分的理由是 readiness gate 需同時審核上一段 run package review linkage、operator artifact path policy、CLI-only/token-only confirmation 與 side-effect blocklist；若後續 run receipt gate 再重複 policy，應抽出 `mcp_fetch_candidate_queue_writer_policy.py`。
 - 2026-05-31 追記：同步市場情報 MCP fetch candidate queue writer run receipt review gate 後的 `services/market_intel/deployment_readiness.py` 行數；本次新增 `services/market_intel/mcp_fetch_candidate_queue_writer_run_receipt_review.py` 為 688 行，略過 600 行提醒門檻。暫不拆分的理由是 receipt gate 需同時審核 readiness linkage、receipt identity、artifact path policy、operator confirmation、token redaction 與 side-effect blocklist；若下一段 closeout gate 重複相同 path/side-effect policy，應抽出 `mcp_fetch_candidate_queue_writer_policy.py`。
-- 2026-05-31 追記：同步市場情報 MCP fetch candidate queue writer run closeout review gate 後的 `services/market_intel/deployment_readiness.py` 行數；本次新增 `services/market_intel/mcp_fetch_candidate_queue_writer_run_closeout_review.py` 為 651 行，略過 600 行提醒門檻。暫不拆分的理由是 closeout gate 需同時審核 receipt review linkage、artifact manifest preservation、rollback note、read-only inventory next-step 與 side-effect blocklist；若下一段 post-closeout inventory gate 重複 path/side-effect policy，應抽出 `mcp_fetch_candidate_queue_writer_policy.py`。
+- 2026-05-31 追記：同步市場情報 MCP fetch candidate queue writer run closeout review gate 後的 `services/market_intel/deployment_readiness.py` 行數；本次新增 `services/market_intel/mcp_fetch_candidate_queue_writer_run_closeout_review.py` 為 724 行，略過 600 行提醒門檻。暫不拆分的理由是 closeout gate 需同時審核 receipt review linkage、artifact manifest preservation、rollback note、read-only inventory next-step、lightweight preview sample 與 side-effect blocklist；若下一段 post-closeout inventory gate 重複 path/side-effect policy，應抽出 `mcp_fetch_candidate_queue_writer_policy.py`。
+- 2026-05-31 追記：同步市場情報 MCP fetch candidate queue writer post-closeout inventory review gate 後的 `services/market_intel/deployment_readiness.py` 行數；本次新增 `services/market_intel/mcp_fetch_candidate_queue_writer_post_closeout_inventory_review.py` 為 649 行，略過 600 行提醒門檻。暫不拆分的理由是 inventory gate 需同時審核 closeout linkage、read-only inventory 摘要、artifact path policy、operator boundary confirmation 與 side-effect blocklist；後續若 candidate queue review handoff 再複用同一套 path/side-effect policy，應抽出 `mcp_fetch_candidate_queue_writer_policy.py`。
 - 2026-05-24 追記：同步背景 Code Review 111 fallback 保護合併後的 `services/code_review_pipeline_service.py` 行數；此處只更新 inventory，不變更 Code Review 行為。
 - 2026-05-21 追記：同步 PChome/LUDEYA 商品線名稱漂移比對更新後的 `services/marketplace_product_matcher.py` 行數；此處只更新 inventory，不變更模組化決策。
 - 2026-05-21 追記：同步 MAC/Yuskin/AHC 名稱漂移與 bundle equivalent matcher 更新後的 `services/marketplace_product_matcher.py` 行數；此處只更新 inventory，不變更模組化決策。
@@ -102,7 +103,7 @@
 | 805 | `routes/bot_api_routes.py` | P2 Bot API Blueprint | route glue / bot action service |
 | 1319 | `routes/market_intel_review_report_routes.py` | P2 market intel review report Blueprint | review report route glue / export payload / phase handoff orchestration |
 | 917 | `routes/market_intel_routes.py` | P2 market intel Blueprint | page route / API route glue / MCP gate route registration helper |
-| 1512 | `services/market_intel/deployment_readiness.py` | P2 market intel deployment readiness | preflight gates / readiness payload / route contract helpers |
+| 1583 | `services/market_intel/deployment_readiness.py` | P2 market intel deployment readiness | preflight gates / readiness payload / route contract helpers |
 | 846 | `services/market_intel/candidate_queue_review_ai_summary_persistence_telegram_dispatch_report_catalog_record_run_receipt.py` | P2 market intel review receipt pipeline | AI summary / persistence / Telegram dispatch / report catalog run receipt orchestration |
 
 ## 市場情報開發前置禁區

docs/memory/current_execution_queue_20260524.md

@@ -96,6 +96,7 @@
 - 2026-05-31 起，`V10.498` 新增市場情報 MCP Fetch Candidate Queue Writer Run Readiness gate：在 run package review 通過後只審核 operator readiness 證據，要求 run readiness artifact、reviewed sample、備份、read-only preflight 與 post-write smoke 路徑安全，並確認 CLI-only、approval token shell-only、無 API/DB/file/scheduler 副作用；仍不產檔、不讀 token、不執行 CLI、不開 DB、不寫 queue、不掛 scheduler，只放行到後續 run receipt review。
 - 2026-05-31 起，`V10.499` 新增市場情報 MCP Fetch Candidate Queue Writer Run Receipt Review gate：在 run readiness 通過後只審核操作員 shell writer run 的 receipt 摘要，要求 readiness linkage、run package id、候選/dedupe keys、writer output、post-write smoke、backup path 與 operator confirmation 對齊；仍不讀 receipt 原文、不讀 token、不執行 CLI、不開 DB、不寫 queue、不做 post-write query、不掛 scheduler，只放行到 closeout review。
 - 2026-05-31 起，`V10.500` 新增市場情報 MCP Fetch Candidate Queue Writer Run Closeout Review gate：在 receipt review 通過後只審核 operator closeout 摘要，要求 receipt linkage、closeout artifact、receipt review artifact、post-closeout inventory plan、writer output / post-write smoke / backup manifest、rollback note 與 operator confirmation 對齊；仍不讀 receipt 原文、不讀 token、不執行 CLI、不開 DB、不寫 queue、不做 post-closeout query、不掛 scheduler，只放行到 read-only post-closeout inventory review。
+- 2026-05-31 起，`V10.501` 新增市場情報 MCP Fetch Candidate Queue Writer Post-Closeout Inventory Review gate：在 closeout review 通過後只審核 operator live inventory read-only 摘要，要求 closeout linkage、row count、inventory artifact、closeout review artifact、read-only query result、missing/duplicate rows 與 operator confirmation 對齊；仍不讀 token、不執行 CLI、不開 DB、不寫 queue、不做 inventory query、不掛 scheduler，只放行到 candidate queue review handoff。
 
 ## 3. 12 Agent 決策信封整合
 

docs/memory/history_logs.md

@@ -13,6 +13,7 @@
 ## 📅 詳細更新日誌 (考古存檔)
 
 ### 2026-05-24：PChome 近門檻身份回收第二輪
+- **V10.501 市場情報 MCP Fetch Candidate Queue Writer Post-Closeout Inventory Review gate**: 新增 `/api/market_intel/mcp_fetch_candidate_queue_writer_post_closeout_inventory_review` 與 UI preview，只審核 closeout review 通過後的 operator live inventory read-only 摘要；要求 closeout linkage、row count、inventory artifact、closeout review artifact、read-only query result、missing/duplicate rows 與 operator confirmation 對齊，且 API 不讀 token、不執行 CLI、不開 DB、不寫 queue、不做 inventory query、不掛 scheduler，只放行到 candidate queue review handoff。
 - **V10.500 市場情報 MCP Fetch Candidate Queue Writer Run Closeout Review gate**: 新增 `/api/market_intel/mcp_fetch_candidate_queue_writer_run_closeout_review` 與 UI preview，只審核 receipt review 通過後的 operator closeout 摘要；要求 receipt linkage、closeout artifact、receipt review artifact、post-closeout inventory plan、writer output / post-write smoke / backup manifest、rollback note 與 operator confirmation 對齊，且 API 不讀 receipt 原文、不讀 token、不執行 CLI、不開 DB、不寫 queue、不做 post-closeout query、不掛 scheduler，只放行到 read-only post-closeout inventory review。
 - **V10.499 市場情報 MCP Fetch Candidate Queue Writer Run Receipt Review gate**: 新增 `/api/market_intel/mcp_fetch_candidate_queue_writer_run_receipt_review` 與 UI preview，只審核操作員 shell writer run 後貼回的 receipt 摘要；要求 readiness linkage、run package id、候選/dedupe keys、writer output、post-write smoke、backup path 與 operator confirmation 對齊，且 API 不讀 receipt 原文、不讀 token、不執行 CLI、不開 DB、不寫 queue、不做 post-write query、不掛 scheduler，只放行到 closeout review。
 - **V10.498 市場情報 MCP Fetch Candidate Queue Writer Run Readiness gate**: 新增 `/api/market_intel/mcp_fetch_candidate_queue_writer_run_readiness` 與 UI preview，只審核 run package review 後的 operator readiness 證據；要求 run readiness artifact、reviewed sample、備份、read-only preflight 與 post-write smoke 路徑安全，並確認 CLI-only、approval token shell-only、無 API/DB/file/scheduler 副作用。API 不產檔、不讀 token、不執行 CLI、不開 DB、不寫 queue、不掛 scheduler，只放行到後續 run receipt review。

routes/market_intel_mcp_run_routes.py

@@ -43,6 +43,9 @@ from services.market_intel.mcp_fetch_candidate_queue_writer_run_receipt_review i
 from services.market_intel.mcp_fetch_candidate_queue_writer_run_closeout_review import (
     build_mcp_fetch_candidate_queue_writer_run_closeout_review_preview,
 )
+from services.market_intel.mcp_fetch_candidate_queue_writer_post_closeout_inventory_review import (
+    build_mcp_fetch_candidate_queue_writer_post_closeout_inventory_review_preview,
+)
 
 
 @market_intel_bp.route("/api/market_intel/mcp_fetch_run_package", methods=["GET", "POST"])
@@ -551,3 +554,51 @@ def market_intel_mcp_fetch_candidate_queue_writer_run_closeout_review():
             phase=service.phase,
         )
     )
+
+
+@market_intel_bp.route(
+    "/api/market_intel/mcp_fetch_candidate_queue_writer_post_closeout_inventory_review",
+    methods=["GET", "POST"],
+)
+@login_required
+def market_intel_mcp_fetch_candidate_queue_writer_post_closeout_inventory_review():
+    writer_run_closeout_review_package = {}
+    writer_run_closeout_review_result = None
+    operator_inventory = None
+    if request.method == "POST":
+        payload = request.get_json(silent=True) or {}
+        package = (
+            payload.get("writer_post_closeout_inventory_review_package")
+            or payload.get("candidate_queue_writer_post_closeout_inventory_review")
+            or payload.get("post_closeout_inventory_review")
+            or payload.get("operator_inventory_review")
+            or payload
+        )
+        writer_run_closeout_review_package = (
+            package.get("writer_run_closeout_review_package")
+            or package.get("candidate_queue_writer_run_closeout_review")
+            or package.get("writer_run_closeout_review")
+            or package.get("run_closeout_review_package")
+            or {}
+        )
+        writer_run_closeout_review_result = (
+            package.get("writer_run_closeout_review_result")
+            or package.get("mcp_fetch_candidate_queue_writer_run_closeout_review")
+        )
+        operator_inventory = (
+            package.get("operator_inventory")
+            or package.get("post_closeout_inventory")
+            or package.get("writer_post_closeout_inventory")
+            or package.get("inventory_payload")
+            or package.get("inventory")
+        )
+
+    service = MarketIntelService()
+    return jsonify(
+        build_mcp_fetch_candidate_queue_writer_post_closeout_inventory_review_preview(
+            writer_run_closeout_review_package=writer_run_closeout_review_package,
+            writer_run_closeout_review_result=writer_run_closeout_review_result,
+            operator_inventory=operator_inventory,
+            phase=service.phase,
+        )
+    )

services/market_intel/deployment_readiness.py

@@ -99,6 +99,9 @@ from services.market_intel.mcp_fetch_candidate_queue_writer_run_receipt_review i
 from services.market_intel.mcp_fetch_candidate_queue_writer_run_closeout_review import (
     build_mcp_fetch_candidate_queue_writer_run_closeout_review_preview,
 )
+from services.market_intel.mcp_fetch_candidate_queue_writer_post_closeout_inventory_review import (
+    build_mcp_fetch_candidate_queue_writer_post_closeout_inventory_review_preview,
+)
 from services.market_intel.mcp_manual_fetch_handoff import (
     build_mcp_manual_fetch_handoff_preview,
 )
@@ -261,6 +264,13 @@ PRODUCTION_SMOKE_TARGETS = (
     + ("/api/market_intel/mcp_fetch_candidate_queue_writer_run_closeout_review",)
     + PRODUCTION_SMOKE_TARGETS[-1:]
 )
+PRODUCTION_SMOKE_TARGETS = (
+    PRODUCTION_SMOKE_TARGETS[:-1]
+    + (
+        "/api/market_intel/mcp_fetch_candidate_queue_writer_post_closeout_inventory_review",
+    )
+    + PRODUCTION_SMOKE_TARGETS[-1:]
+)
 def _run_review_preview_safe(payload, mode):
     return bool(payload["mode"] == mode and all(not payload.get(key) for key in BLOCKED_RUN_REVIEW_KEYS))
 def build_deployment_readiness_preview(*, service, market_intel_tables, schema_smoke_builder):
@@ -340,6 +350,11 @@ def build_deployment_readiness_preview(*, service, market_intel_tables, schema_s
             phase=service.phase,
         )
     )
+    mcp_fetch_candidate_queue_writer_post_closeout_inventory_review = (
+        build_mcp_fetch_candidate_queue_writer_post_closeout_inventory_review_preview(
+            phase=service.phase,
+        )
+    )
     scheduler_plan = service.build_scheduler_plan()
     manual_sample_plan = service.build_manual_sample_plan()
     manual_sample_acceptance = service.build_manual_sample_acceptance()
@@ -1110,6 +1125,61 @@ def build_deployment_readiness_preview(*, service, market_intel_tables, schema_s
                 "scheduler_attached"
             ]
         ),
+        "mcp_fetch_candidate_queue_writer_post_closeout_inventory_review_preview_safe": bool(
+            mcp_fetch_candidate_queue_writer_post_closeout_inventory_review["mode"]
+            == "mcp_fetch_candidate_queue_writer_post_closeout_inventory_review_preview"
+            and not mcp_fetch_candidate_queue_writer_post_closeout_inventory_review[
+                "payload_persisted"
+            ]
+            and not mcp_fetch_candidate_queue_writer_post_closeout_inventory_review[
+                "post_closeout_inventory_persisted"
+            ]
+            and not mcp_fetch_candidate_queue_writer_post_closeout_inventory_review[
+                "post_closeout_inventory_file_written"
+            ]
+            and not mcp_fetch_candidate_queue_writer_post_closeout_inventory_review[
+                "inventory_file_written"
+            ]
+            and not mcp_fetch_candidate_queue_writer_post_closeout_inventory_review[
+                "package_artifact_created"
+            ]
+            and not mcp_fetch_candidate_queue_writer_post_closeout_inventory_review[
+                "api_writes_file"
+            ]
+            and not mcp_fetch_candidate_queue_writer_post_closeout_inventory_review[
+                "api_executes_cli"
+            ]
+            and not mcp_fetch_candidate_queue_writer_post_closeout_inventory_review[
+                "api_reads_approval_token"
+            ]
+            and not mcp_fetch_candidate_queue_writer_post_closeout_inventory_review[
+                "api_opens_database_connection"
+            ]
+            and not mcp_fetch_candidate_queue_writer_post_closeout_inventory_review[
+                "api_writes_database"
+            ]
+            and not mcp_fetch_candidate_queue_writer_post_closeout_inventory_review[
+                "api_uses_external_network"
+            ]
+            and not mcp_fetch_candidate_queue_writer_post_closeout_inventory_review[
+                "api_inventory_query_executed"
+            ]
+            and not mcp_fetch_candidate_queue_writer_post_closeout_inventory_review[
+                "post_closeout_query_executed_by_api"
+            ]
+            and not mcp_fetch_candidate_queue_writer_post_closeout_inventory_review[
+                "database_write_executed"
+            ]
+            and not mcp_fetch_candidate_queue_writer_post_closeout_inventory_review[
+                "cli_executed"
+            ]
+            and not mcp_fetch_candidate_queue_writer_post_closeout_inventory_review[
+                "file_written"
+            ]
+            and not mcp_fetch_candidate_queue_writer_post_closeout_inventory_review[
+                "scheduler_attached"
+            ]
+        ),
         "candidate_queue_writer_postwrite_smoke_planned_safe": bool(
             candidate_queue_writer_postwrite_smoke["mode"]
             == "candidate_queue_writer_postwrite_smoke_planned"
@@ -1435,6 +1505,7 @@ def build_deployment_readiness_preview(*, service, market_intel_tables, schema_s
         "mcp_fetch_candidate_queue_writer_run_readiness": mcp_fetch_candidate_queue_writer_run_readiness,
         "mcp_fetch_candidate_queue_writer_run_receipt_review": mcp_fetch_candidate_queue_writer_run_receipt_review,
         "mcp_fetch_candidate_queue_writer_run_closeout_review": mcp_fetch_candidate_queue_writer_run_closeout_review,
+        "mcp_fetch_candidate_queue_writer_post_closeout_inventory_review": mcp_fetch_candidate_queue_writer_post_closeout_inventory_review,
         "scheduler_plan": scheduler_plan,
         "manual_sample_plan": manual_sample_plan,
         "manual_sample_acceptance": manual_sample_acceptance,

services/market_intel/mcp_fetch_candidate_queue_writer_post_closeout_inventory_review.py

@@ -0,0 +1,649 @@
+"""市場情報 MCP fetch candidate queue writer post-closeout inventory review。
+
+本模組只審核 closeout review 之後由 operator shell 完成的 live inventory
+read-only 摘要；API/UI 不讀 approval token、不執行 CLI、不開 DB、不寫 queue、
+不做 inventory query、不掛 scheduler。
+"""
+
+from copy import deepcopy
+
+from services.market_intel.mcp_fetch_candidate_queue_writer_preflight import TARGET_TABLE
+from services.market_intel.mcp_fetch_candidate_queue_writer_run_readiness import (
+    ARTIFACT_PREFIX,
+)
+from services.market_intel.mcp_fetch_candidate_queue_writer_run_closeout_review import (
+    build_mcp_fetch_candidate_queue_writer_run_closeout_review_preview,
+)
+
+
+_SAMPLE_POST_CLOSEOUT_INVENTORY_REVIEW_PACKAGE = None
+
+FORBIDDEN_SECRET_KEYS = (
+    "approval_token",
+    "approval-token",
+    "api_key",
+    "authorization",
+    "bearer",
+    "client_secret",
+    "cookie",
+    "password",
+    "secret",
+    "session_cookie",
+    "token",
+)
+
+SAFE_SECRET_METADATA_KEYS = {
+    "no_approval_token_payload",
+    "operator_confirmed_no_approval_token_payload",
+    "token_not_logged",
+}
+
+_BLOCKED_SIDE_EFFECT_KEYS = (
+    "allow_api_execution",
+    "allow_cli_execution",
+    "allow_database_write",
+    "allow_external_network_in_api",
+    "allow_scheduler_attach",
+    "api_execution_allowed",
+    "api_executed_cli",
+    "api_executes",
+    "api_executes_cli",
+    "api_inventory_query_executed",
+    "api_opens_database_connection",
+    "api_reads_approval_token",
+    "api_uses_external_network",
+    "api_writes_database",
+    "api_writes_file",
+    "apply_real_write",
+    "attach_scheduler",
+    "candidate_queue_created_by_api",
+    "candidate_queue_persisted_by_api",
+    "candidate_review_state_updated",
+    "cli_executed_by_api",
+    "command_executed_by_api",
+    "database_commit_executed",
+    "database_connection_opened",
+    "database_session_created",
+    "database_write_executed_by_api",
+    "execute_requested",
+    "external_network_executed_by_api",
+    "file_written",
+    "inventory_file_written",
+    "inventory_query_executed_by_api",
+    "inventory_review_persisted",
+    "network_request_allowed",
+    "opens_database_connection",
+    "package_artifact_created",
+    "payload_persisted",
+    "post_closeout_inventory_file_written",
+    "post_closeout_inventory_persisted",
+    "post_closeout_query_executed_by_api",
+    "ready_for_api_database_write",
+    "ready_for_real_write",
+    "real_write_allowed_by_api",
+    "review_state_update_executed",
+    "scheduler_attach",
+    "scheduler_attached",
+    "write_database",
+    "writes_database",
+    "writes_executed",
+    "would_write_database",
+)
+
+
+def _as_dict(value):
+    return value if isinstance(value, dict) else {}
+
+
+def _as_list(value):
+    if value is None:
+        return []
+    if isinstance(value, (list, tuple, set)):
+        return list(value)
+    return [value]
+
+
+def _safe_int(value):
+    try:
+        return int(value or 0)
+    except (TypeError, ValueError):
+        return 0
+
+
+def _safe_text(value, limit=500):
+    if value is None:
+        return None
+    text = str(value).strip()
+    return text[:limit] if text else None
+
+
+def _safe_path(value, *, prefixes, suffixes):
+    if not isinstance(value, str):
+        return False
+    normalized = value.strip().replace("\\", "/")
+    if not normalized or normalized.startswith("/"):
+        return False
+    parts = [part for part in normalized.split("/") if part]
+    if any(part in (".", "..") for part in parts):
+        return False
+    return normalized.startswith(prefixes) and normalized.endswith(suffixes)
+
+
+def _contains_forbidden_key(value, forbidden_keys, *, safe_keys=None):
+    safe_keys = safe_keys or set()
+    if isinstance(value, dict):
+        for key, nested in value.items():
+            normalized_key = str(key).lower()
+            if normalized_key in safe_keys and isinstance(nested, bool):
+                continue
+            if any(forbidden_key in normalized_key for forbidden_key in forbidden_keys):
+                return True
+            if _contains_forbidden_key(nested, forbidden_keys, safe_keys=safe_keys):
+                return True
+    elif isinstance(value, list):
+        return any(
+            _contains_forbidden_key(item, forbidden_keys, safe_keys=safe_keys)
+            for item in value
+        )
+    return False
+
+
+def _blocked_side_effects(payload):
+    found = []
+
+    def visit(value, path):
+        if isinstance(value, dict):
+            for key, item in value.items():
+                normalized_key = str(key).lower()
+                key_path = f"{path}.{key}" if path else key
+                if normalized_key in _BLOCKED_SIDE_EFFECT_KEYS and bool(item):
+                    found.append(key_path)
+                visit(item, key_path)
+        elif isinstance(value, list):
+            for index, item in enumerate(value):
+                visit(item, f"{path}[{index}]")
+
+    visit(payload, "")
+    return found
+
+
+def _closeout_review_from_inputs(closeout_package, closeout_result, phase):
+    if isinstance(closeout_result, dict) and closeout_result:
+        return closeout_result
+
+    closeout_package = _as_dict(closeout_package)
+    return build_mcp_fetch_candidate_queue_writer_run_closeout_review_preview(
+        writer_run_receipt_review_package=(
+            closeout_package.get("writer_run_receipt_review_package")
+            or closeout_package.get("candidate_queue_writer_run_receipt_review")
+            or closeout_package.get("writer_run_receipt_review")
+            or closeout_package.get("run_receipt_review_package")
+            or {}
+        ),
+        writer_run_receipt_review_result=(
+            closeout_package.get("writer_run_receipt_review_result")
+            or closeout_package.get(
+                "mcp_fetch_candidate_queue_writer_run_receipt_review"
+            )
+        ),
+        operator_closeout=(
+            closeout_package.get("operator_closeout")
+            or closeout_package.get("writer_run_closeout")
+            or closeout_package.get("candidate_queue_writer_run_closeout")
+            or closeout_package.get("closeout_payload")
+            or closeout_package.get("closeout")
+        ),
+        phase=phase,
+    )
+
+
+def _sample_post_closeout_inventory_review_package():
+    global _SAMPLE_POST_CLOSEOUT_INVENTORY_REVIEW_PACKAGE
+    if _SAMPLE_POST_CLOSEOUT_INVENTORY_REVIEW_PACKAGE is not None:
+        return deepcopy(_SAMPLE_POST_CLOSEOUT_INVENTORY_REVIEW_PACKAGE)
+
+    closeout_preview = build_mcp_fetch_candidate_queue_writer_run_closeout_review_preview()
+    closeout_package = closeout_preview["sample_writer_run_closeout_review_package"]
+    closeout_result = (
+        build_mcp_fetch_candidate_queue_writer_run_closeout_review_preview(
+            writer_run_receipt_review_package=closeout_package[
+                "writer_run_receipt_review_package"
+            ],
+            writer_run_receipt_review_result=closeout_package[
+                "writer_run_receipt_review_result"
+            ],
+            operator_closeout=closeout_package["operator_closeout"],
+        )
+    )
+    closeout = _closeout_review_summary(closeout_result)
+    operator_inventory = {
+        "inventory_review_id": (
+            "market-intel-candidate-writer-post-closeout-inventory-sample"
+        ),
+        "closeout_id": closeout["closeout_id"],
+        "run_package_id": closeout["run_package_id"],
+        "receipt_id": closeout["receipt_id"],
+        "target_table": TARGET_TABLE,
+        "payload_row_count": closeout["payload_row_count"],
+        "found_row_count": closeout["payload_row_count"],
+        "missing_row_count": 0,
+        "unexpected_duplicate_count": 0,
+        "inventory_artifact_path": (
+            ARTIFACT_PREFIX
+            + "candidate-queue-post-closeout-inventory-sample.json"
+        ),
+        "closeout_review_artifact_path": closeout["closeout_artifact_path"],
+        "read_only_query_result_path": (
+            ARTIFACT_PREFIX
+            + "candidate-queue-post-closeout-read-only-query-sample.json"
+        ),
+        "query_summary": {
+            "query_type": "read_only_select",
+            "read_only_query_executed_by_operator": True,
+            "expected_rows_found": True,
+            "row_count_matches_payload": True,
+            "target_table": TARGET_TABLE,
+        },
+        "operator_confirmations": {
+            "closeout_reviewed": True,
+            "inventory_read_only": True,
+            "no_missing_rows": True,
+            "no_unexpected_duplicates": True,
+            "no_approval_token_payload": True,
+            "no_api_cli_execution": True,
+            "no_api_database_write": True,
+            "no_api_inventory_query": True,
+            "no_api_file_write": True,
+            "no_scheduler_attach": True,
+        },
+        "api_execution_allowed": False,
+        "real_write_allowed_by_api": False,
+    }
+    _SAMPLE_POST_CLOSEOUT_INVENTORY_REVIEW_PACKAGE = {
+        "writer_run_closeout_review_package": closeout_package,
+        "writer_run_closeout_review_result": closeout_result,
+        "operator_inventory": operator_inventory,
+    }
+    return deepcopy(_SAMPLE_POST_CLOSEOUT_INVENTORY_REVIEW_PACKAGE)
+
+
+def _closeout_review_summary(closeout_result):
+    closeout_result = _as_dict(closeout_result)
+    closeout = _as_dict(closeout_result.get("operator_closeout_summary"))
+    side_effects_clear = bool(
+        not closeout_result.get("payload_persisted")
+        and not closeout_result.get("run_closeout_review_persisted")
+        and not closeout_result.get("run_closeout_persisted")
+        and not closeout_result.get("run_closeout_file_written")
+        and not closeout_result.get("closeout_file_written")
+        and not closeout_result.get("package_artifact_created")
+        and not closeout_result.get("network_request_allowed")
+        and not closeout_result.get("api_executes_cli")
+        and not closeout_result.get("api_reads_approval_token")
+        and not closeout_result.get("api_opens_database_connection")
+        and not closeout_result.get("api_writes_database")
+        and not closeout_result.get("api_writes_file")
+        and not closeout_result.get("api_uses_external_network")
+        and not closeout_result.get("post_closeout_query_executed_by_api")
+        and not closeout_result.get("database_write_executed")
+        and not closeout_result.get("cli_executed")
+        and not closeout_result.get("file_written")
+        and not closeout_result.get("scheduler_attached")
+        and not closeout_result.get("candidate_queue_created")
+        and not closeout_result.get("candidate_queue_persisted")
+    )
+    return {
+        "mode": closeout_result.get("mode"),
+        "accepted": bool(
+            closeout_result.get(
+                "mcp_fetch_candidate_queue_writer_run_closeout_review_accepted"
+            )
+        ),
+        "ready_for_post_closeout_inventory_review": bool(
+            closeout_result.get(
+                "ready_for_candidate_queue_post_closeout_inventory_review"
+            )
+        ),
+        "closeout_id": _safe_text(closeout.get("closeout_id"), 160),
+        "run_package_id": _safe_text(closeout.get("run_package_id"), 160),
+        "receipt_id": _safe_text(closeout.get("receipt_id"), 160),
+        "target_table": _safe_text(closeout.get("target_table"), 160),
+        "payload_row_count": _safe_int(closeout.get("payload_row_count")),
+        "closeout_artifact_path": _safe_text(
+            closeout.get("closeout_artifact_path")
+        ),
+        "post_closeout_inventory_plan_path": _safe_text(
+            closeout.get("post_closeout_inventory_plan_path")
+        ),
+        "artifact_manifest_preserved": bool(
+            closeout.get("manifest_writer_output_path")
+            and closeout.get("manifest_postwrite_smoke_result_path")
+            and closeout.get("manifest_backup_artifact_path")
+        ),
+        "side_effects_clear": side_effects_clear,
+        "blocked_reasons": closeout_result.get("blocked_reasons", []),
+    }
+
+
+def _operator_inventory_summary(operator_inventory):
+    operator_inventory = _as_dict(operator_inventory)
+    query = _as_dict(operator_inventory.get("query_summary"))
+    confirmations = _as_dict(operator_inventory.get("operator_confirmations"))
+    return {
+        "provided_keys": sorted(operator_inventory.keys()),
+        "inventory_review_id": _safe_text(
+            operator_inventory.get("inventory_review_id"), 160
+        ),
+        "closeout_id": _safe_text(operator_inventory.get("closeout_id"), 160),
+        "run_package_id": _safe_text(operator_inventory.get("run_package_id"), 160),
+        "receipt_id": _safe_text(operator_inventory.get("receipt_id"), 160),
+        "target_table": _safe_text(operator_inventory.get("target_table"), 160),
+        "payload_row_count": _safe_int(operator_inventory.get("payload_row_count")),
+        "found_row_count": _safe_int(operator_inventory.get("found_row_count")),
+        "missing_row_count": _safe_int(operator_inventory.get("missing_row_count")),
+        "unexpected_duplicate_count": _safe_int(
+            operator_inventory.get("unexpected_duplicate_count")
+        ),
+        "inventory_artifact_path": _safe_text(
+            operator_inventory.get("inventory_artifact_path")
+        ),
+        "closeout_review_artifact_path": _safe_text(
+            operator_inventory.get("closeout_review_artifact_path")
+        ),
+        "read_only_query_result_path": _safe_text(
+            operator_inventory.get("read_only_query_result_path")
+        ),
+        "inventory_artifact_path_safe": _safe_path(
+            operator_inventory.get("inventory_artifact_path"),
+            prefixes=(ARTIFACT_PREFIX,),
+            suffixes=(".json",),
+        ),
+        "closeout_review_artifact_path_safe": _safe_path(
+            operator_inventory.get("closeout_review_artifact_path"),
+            prefixes=(ARTIFACT_PREFIX,),
+            suffixes=(".json",),
+        ),
+        "read_only_query_result_path_safe": _safe_path(
+            operator_inventory.get("read_only_query_result_path"),
+            prefixes=(ARTIFACT_PREFIX,),
+            suffixes=(".json",),
+        ),
+        "query_type": _safe_text(query.get("query_type"), 80),
+        "read_only_query_executed_by_operator": bool(
+            query.get("read_only_query_executed_by_operator")
+        ),
+        "expected_rows_found": bool(query.get("expected_rows_found")),
+        "row_count_matches_payload": bool(query.get("row_count_matches_payload")),
+        "query_target_table": _safe_text(query.get("target_table"), 160),
+        "closeout_reviewed": bool(confirmations.get("closeout_reviewed")),
+        "inventory_read_only": bool(confirmations.get("inventory_read_only")),
+        "no_missing_rows": bool(confirmations.get("no_missing_rows")),
+        "no_unexpected_duplicates": bool(
+            confirmations.get("no_unexpected_duplicates")
+        ),
+        "no_approval_token_payload": bool(
+            confirmations.get("no_approval_token_payload")
+        ),
+        "no_api_cli_execution": bool(confirmations.get("no_api_cli_execution")),
+        "no_api_database_write": bool(confirmations.get("no_api_database_write")),
+        "no_api_inventory_query": bool(
+            confirmations.get("no_api_inventory_query")
+        ),
+        "no_api_file_write": bool(confirmations.get("no_api_file_write")),
+        "no_scheduler_attach": bool(confirmations.get("no_scheduler_attach")),
+        "api_execution_allowed": bool(operator_inventory.get("api_execution_allowed")),
+        "real_write_allowed_by_api": bool(
+            operator_inventory.get("real_write_allowed_by_api")
+        ),
+        "secret_or_token_submitted_to_api": _contains_forbidden_key(
+            operator_inventory,
+            FORBIDDEN_SECRET_KEYS,
+            safe_keys=SAFE_SECRET_METADATA_KEYS,
+        ),
+        "blocked_side_effects": _blocked_side_effects(operator_inventory),
+    }
+
+
+def _inventory_gates(*, closeout_received, inventory_received, closeout, inventory):
+    operator_confirmed_boundaries = bool(
+        inventory["closeout_reviewed"]
+        and inventory["inventory_read_only"]
+        and inventory["no_missing_rows"]
+        and inventory["no_unexpected_duplicates"]
+        and inventory["no_approval_token_payload"]
+        and inventory["no_api_cli_execution"]
+        and inventory["no_api_database_write"]
+        and inventory["no_api_inventory_query"]
+        and inventory["no_api_file_write"]
+        and inventory["no_scheduler_attach"]
+    )
+    return [
+        {
+            "key": "writer_run_closeout_review_payload_or_result_received",
+            "label": "已提供 writer run closeout review package 或已審核結果",
+            "passed": closeout_received,
+        },
+        {
+            "key": "writer_run_closeout_review_accepted",
+            "label": "writer run closeout review gate 必須已通過",
+            "passed": closeout["accepted"],
+        },
+        {
+            "key": "writer_run_closeout_review_ready_for_inventory",
+            "label": "closeout review 必須只放行到 post-closeout inventory review",
+            "passed": closeout["ready_for_post_closeout_inventory_review"],
+        },
+        {
+            "key": "writer_run_closeout_review_side_effect_free",
+            "label": "closeout review 未顯示 API 執行、寫 DB、寫檔或掛 scheduler",
+            "passed": closeout["side_effects_clear"],
+        },
+        {
+            "key": "writer_run_closeout_review_identity_recorded",
+            "label": "closeout review 必須保留 closeout_id、run_package_id 與 receipt_id",
+            "passed": bool(
+                closeout["closeout_id"]
+                and closeout["run_package_id"]
+                and closeout["receipt_id"]
+            ),
+        },
+        {
+            "key": "writer_run_closeout_review_manifest_preserved",
+            "label": "closeout review 必須保留 writer output、post-write smoke 與 backup manifest",
+            "passed": closeout["artifact_manifest_preserved"],
+        },
+        {
+            "key": "post_closeout_inventory_payload_received",
+            "label": "已提供 operator live inventory 摘要",
+            "passed": inventory_received,
+        },
+        {
+            "key": "post_closeout_inventory_identity_recorded",
+            "label": "inventory 必須記錄 inventory_review_id、closeout_id、run_package_id 與 receipt_id",
+            "passed": bool(
+                inventory["inventory_review_id"]
+                and inventory["closeout_id"]
+                and inventory["run_package_id"]
+                and inventory["receipt_id"]
+            ),
+        },
+        {
+            "key": "post_closeout_inventory_identity_matches_closeout",
+            "label": "inventory identity 必須對齊 closeout review",
+            "passed": bool(
+                inventory["closeout_id"] == closeout["closeout_id"]
+                and inventory["run_package_id"] == closeout["run_package_id"]
+                and inventory["receipt_id"] == closeout["receipt_id"]
+            ),
+        },
+        {
+            "key": "post_closeout_inventory_target_table_safe",
+            "label": "target table 必須是 market_alert_review_queue",
+            "passed": inventory["target_table"] == TARGET_TABLE,
+        },
+        {
+            "key": "post_closeout_inventory_row_count_matches_closeout",
+            "label": "inventory row count 必須對齊 closeout payload rows",
+            "passed": bool(
+                inventory["payload_row_count"]
+                and inventory["payload_row_count"] == closeout["payload_row_count"]
+                and inventory["found_row_count"] == closeout["payload_row_count"]
+                and inventory["missing_row_count"] == 0
+                and inventory["unexpected_duplicate_count"] == 0
+            ),
+        },
+        {
+            "key": "post_closeout_inventory_artifact_paths_safe",
+            "label": "inventory、closeout review 與 read-only query result paths 必須安全",
+            "passed": bool(
+                inventory["inventory_artifact_path_safe"]
+                and inventory["closeout_review_artifact_path_safe"]
+                and inventory["read_only_query_result_path_safe"]
+            ),
+        },
+        {
+            "key": "post_closeout_inventory_query_read_only",
+            "label": "inventory 查核必須由操作員只讀查詢完成",
+            "passed": bool(
+                inventory["query_type"] == "read_only_select"
+                and inventory["read_only_query_executed_by_operator"]
+                and inventory["expected_rows_found"]
+                and inventory["row_count_matches_payload"]
+                and inventory["query_target_table"] == TARGET_TABLE
+            ),
+        },
+        {
+            "key": "post_closeout_inventory_operator_boundaries_confirmed",
+            "label": "操作員確認只讀 inventory，且 API 未執行 CLI/DB/query/file/scheduler",
+            "passed": operator_confirmed_boundaries,
+        },
+        {
+            "key": "post_closeout_inventory_no_api_execution_or_real_write",
+            "label": "inventory payload 不得允許 API execution 或 real write",
+            "passed": bool(
+                not inventory["api_execution_allowed"]
+                and not inventory["real_write_allowed_by_api"]
+            ),
+        },
+        {
+            "key": "post_closeout_inventory_no_secret_or_token_key",
+            "label": "inventory payload 不得包含 secret、cookie、password 或 token key",
+            "passed": not inventory["secret_or_token_submitted_to_api"],
+        },
+        {
+            "key": "post_closeout_inventory_side_effect_free",
+            "label": "inventory payload 不得要求 API 寫檔、執行、查 DB、寫 DB 或掛 scheduler",
+            "passed": not inventory["blocked_side_effects"],
+        },
+    ]
+
+
+def build_mcp_fetch_candidate_queue_writer_post_closeout_inventory_review_preview(
+    *,
+    writer_run_closeout_review_package=None,
+    writer_run_closeout_review_result=None,
+    operator_inventory=None,
+    phase=None,
+):
+    """建立 writer post-closeout inventory review；不執行查詢或寫入。"""
+    writer_run_closeout_review_package = _as_dict(writer_run_closeout_review_package)
+    closeout_result_received = bool(
+        isinstance(writer_run_closeout_review_result, dict)
+        and writer_run_closeout_review_result
+    )
+    inventory_valid_object = (
+        isinstance(operator_inventory, dict) if operator_inventory is not None else True
+    )
+    inventory_payload = _as_dict(operator_inventory)
+    closeout_received = bool(
+        writer_run_closeout_review_package or closeout_result_received
+    )
+    closeout_result = (
+        _closeout_review_from_inputs(
+            writer_run_closeout_review_package,
+            writer_run_closeout_review_result,
+            phase,
+        )
+        if closeout_received
+        else {}
+    )
+    payload_received = bool(
+        closeout_received or inventory_payload or operator_inventory is not None
+    )
+    inventory_received = bool(inventory_payload)
+    closeout = _closeout_review_summary(closeout_result)
+    inventory = _operator_inventory_summary(inventory_payload)
+    gates = _inventory_gates(
+        closeout_received=closeout_received,
+        inventory_received=inventory_received and inventory_valid_object,
+        closeout=closeout,
+        inventory=inventory,
+    )
+    blocked_reasons = [gate["key"] for gate in gates if not gate["passed"]]
+    if not inventory_valid_object:
+        blocked_reasons.append("operator_inventory_payload_valid_object")
+    accepted = bool(payload_received and not blocked_reasons)
+
+    return {
+        "mode": (
+            "mcp_fetch_candidate_queue_writer_post_closeout_inventory_review"
+            if payload_received
+            else "mcp_fetch_candidate_queue_writer_post_closeout_inventory_review_preview"
+        ),
+        "phase": phase,
+        "post_closeout_inventory_review_payload_received": payload_received,
+        "writer_run_closeout_review_received": closeout_received,
+        "operator_inventory_received": inventory_received,
+        "operator_inventory_valid_object": inventory_valid_object,
+        "writer_run_closeout_review_accepted": closeout["accepted"],
+        "mcp_fetch_candidate_queue_writer_post_closeout_inventory_review_accepted": (
+            accepted
+        ),
+        "candidate_queue_writer_post_closeout_inventory_review_ready": accepted,
+        "ready_for_candidate_queue_review_handoff": accepted,
+        "ready_for_api_database_write": False,
+        "ready_for_real_write": False,
+        "ready_for_scheduler_attach": False,
+        "network_request_allowed": False,
+        "api_executes_cli": False,
+        "api_reads_approval_token": False,
+        "api_opens_database_connection": False,
+        "api_writes_database": False,
+        "api_writes_file": False,
+        "api_uses_external_network": False,
+        "api_inventory_query_executed": False,
+        "post_closeout_query_executed_by_api": False,
+        "payload_row_count": inventory["payload_row_count"],
+        "gate_count": len(gates),
+        "passed_gate_count": sum(1 for gate in gates if gate["passed"]),
+        "blocked_reasons": blocked_reasons,
+        "gates": gates,
+        "writer_run_closeout_review_summary": closeout,
+        "operator_inventory_summary": inventory,
+        "sample_writer_post_closeout_inventory_review_package": (
+            _sample_post_closeout_inventory_review_package()
+        ),
+        "next_operator_steps": [
+            "Inventory review 通過後，只代表可進入 candidate queue review handoff",
+            "API/UI 仍不得執行 DB inventory query、補寫 queue row、讀 token 或掛 scheduler",
+            "後續 handoff 必須只引用已審核 artifact，不得從 UI/API 自動修補缺資料",
+        ],
+        "payload_persisted": False,
+        "post_closeout_inventory_review_persisted": False,
+        "post_closeout_inventory_persisted": False,
+        "post_closeout_inventory_file_written": False,
+        "inventory_file_written": False,
+        "package_artifact_created": False,
+        "database_session_created": False,
+        "database_commit_executed": False,
+        "database_write_executed": False,
+        "external_network_executed": False,
+        "cli_executed": False,
+        "file_written": False,
+        "writes_executed": False,
+        "would_write_database": False,
+        "scheduler_attached": False,
+        "candidate_queue_created": False,
+        "candidate_queue_persisted": False,
+        "candidate_review_state_updated": False,
+    }

services/market_intel/mcp_fetch_candidate_queue_writer_run_closeout_review.py

@@ -199,16 +199,85 @@ def _sample_run_closeout_review_package():
     if _SAMPLE_RUN_CLOSEOUT_REVIEW_PACKAGE is not None:
         return deepcopy(_SAMPLE_RUN_CLOSEOUT_REVIEW_PACKAGE)
 
-    receipt_package = (
-        build_mcp_fetch_candidate_queue_writer_run_receipt_review_preview()[
-            "sample_writer_run_receipt_review_package"
-        ]
+    run_package_id = "market-intel-candidate-writer-run-package-sample"
+    receipt_id = "market-intel-candidate-writer-run-receipt-sample"
+    payload_row_count = 2
+    writer_output_path = (
+        ARTIFACT_PREFIX + "candidate-queue-writer-output-sample.json"
     )
-    receipt_result = build_mcp_fetch_candidate_queue_writer_run_receipt_review_preview(
-        writer_run_readiness_package=receipt_package["writer_run_readiness_package"],
-        writer_run_readiness_result=receipt_package["writer_run_readiness_result"],
-        writer_run_receipt=receipt_package["writer_run_receipt"],
+    postwrite_smoke_result_path = (
+        ARTIFACT_PREFIX + "candidate-queue-writer-postwrite-smoke-sample.json"
     )
+    backup_artifact_path = BACKUP_PREFIX + "momo_pro_system_backup_sample.zip"
+    receipt_package = {
+        "writer_run_readiness_package": {
+            "writer_run_package_review_package": {
+                "run_package_id": run_package_id,
+                "target_table": TARGET_TABLE,
+            }
+        },
+        "writer_run_readiness_result": {
+            "mode": "mcp_fetch_candidate_queue_writer_run_readiness_review",
+            "mcp_fetch_candidate_queue_writer_run_readiness_accepted": True,
+            "ready_for_candidate_queue_writer_run_receipt_review": True,
+            "payload_row_count": payload_row_count,
+            "network_request_allowed": False,
+            "api_executes_cli": False,
+            "api_reads_approval_token": False,
+            "api_opens_database_connection": False,
+            "api_writes_database": False,
+            "api_writes_file": False,
+            "api_uses_external_network": False,
+            "database_write_executed": False,
+            "cli_executed": False,
+            "file_written": False,
+            "scheduler_attached": False,
+            "candidate_queue_created": False,
+            "candidate_queue_persisted": False,
+        },
+        "writer_run_receipt": {
+            "receipt_id": receipt_id,
+            "run_package_id": run_package_id,
+            "target_table": TARGET_TABLE,
+            "payload_row_count": payload_row_count,
+            "writer_output_path": writer_output_path,
+            "postwrite_smoke_result_path": postwrite_smoke_result_path,
+            "backup_artifact_path": backup_artifact_path,
+        },
+    }
+    receipt_result = {
+        "mode": "mcp_fetch_candidate_queue_writer_run_receipt_review",
+        "mcp_fetch_candidate_queue_writer_run_receipt_review_accepted": True,
+        "ready_for_candidate_queue_writer_run_closeout_review": True,
+        "payload_row_count": payload_row_count,
+        "blocked_reasons": [],
+        "network_request_allowed": False,
+        "api_executes_cli": False,
+        "api_reads_approval_token": False,
+        "api_opens_database_connection": False,
+        "api_writes_database": False,
+        "api_writes_file": False,
+        "api_uses_external_network": False,
+        "postwrite_query_executed_by_api": False,
+        "database_write_executed": False,
+        "cli_executed": False,
+        "file_written": False,
+        "scheduler_attached": False,
+        "candidate_queue_created": False,
+        "candidate_queue_persisted": False,
+        "writer_run_receipt_summary": {
+            "run_package_id": run_package_id,
+            "receipt_id": receipt_id,
+            "target_table": TARGET_TABLE,
+            "payload_row_count": payload_row_count,
+            "writer_output_path": writer_output_path,
+            "postwrite_smoke_result_path": postwrite_smoke_result_path,
+            "backup_artifact_path": backup_artifact_path,
+            "postwrite_smoke_read_only_by_operator": True,
+            "postwrite_smoke_expected_rows_found": True,
+            "postwrite_smoke_row_count_matches_payload": True,
+        },
+    }
     receipt = _receipt_review_summary(receipt_result)
     operator_closeout = {
         "closeout_id": "market-intel-candidate-writer-run-closeout-sample",
@@ -564,14 +633,18 @@ def build_mcp_fetch_candidate_queue_writer_run_closeout_review_preview(
         isinstance(operator_closeout, dict) if operator_closeout is not None else True
     )
     closeout_payload = _as_dict(operator_closeout)
-    receipt_result = _receipt_review_from_inputs(
-        writer_run_receipt_review_package,
-        writer_run_receipt_review_result,
-        phase,
-    )
     receipt_received = bool(
         writer_run_receipt_review_package or receipt_result_received
     )
+    receipt_result = (
+        _receipt_review_from_inputs(
+            writer_run_receipt_review_package,
+            writer_run_receipt_review_result,
+            phase,
+        )
+        if receipt_received
+        else {}
+    )
     payload_received = bool(
         receipt_received or closeout_payload or operator_closeout is not None
     )

services/market_intel/phase.py

@@ -1,3 +1,3 @@
 """市場情報 rollout phase 單一來源。"""
 
-MARKET_INTEL_PHASE = "phase_133_market_intel_mcp_fetch_candidate_queue_writer_run_closeout_review"
+MARKET_INTEL_PHASE = "phase_134_market_intel_mcp_fetch_candidate_queue_writer_post_closeout_inventory_review"

templates/market_intel/disabled.html

@@ -994,6 +994,32 @@
         </div>
     </div>
 
+    <div class="market-intel-panel" data-market-intel-mcp-fetch-candidate-queue-writer-post-closeout-inventory-review>
+        <div class="market-intel-preview-head">
+            <div>
+                <p class="market-intel-muted momo-mono mb-1">MCP / POST-CLOSEOUT INVENTORY</p>
+                <h2 class="market-intel-preview-title">MCP Candidate Queue Writer Post-Closeout Inventory Review</h2>
+            </div>
+            <button class="market-intel-icon-button" type="button" title="重新整理 MCP Writer Post-Closeout Inventory Review" data-market-intel-mcp-fetch-candidate-queue-writer-post-closeout-inventory-review-refresh>
+                <i class="fas fa-rotate-right" aria-hidden="true"></i>
+            </button>
+        </div>
+        <div class="market-intel-preview-meta" data-market-intel-mcp-fetch-candidate-queue-writer-post-closeout-inventory-review-meta>
+            <span class="market-intel-pill">loading</span>
+        </div>
+        <div data-market-intel-mcp-fetch-candidate-queue-writer-post-closeout-inventory-review-body>
+            <div class="market-intel-empty">讀取 MCP Writer Post-Closeout Inventory Review 中...</div>
+        </div>
+        <div class="market-intel-control-row mt-3">
+            <textarea class="market-intel-json-input" rows="9" spellcheck="false" data-market-intel-mcp-fetch-candidate-queue-writer-post-closeout-inventory-review-input placeholder="writer run closeout review and operator inventory JSON"></textarea>
+            <div class="market-intel-control-actions">
+                <button class="market-intel-icon-button" type="button" title="審核 MCP Writer Post-Closeout Inventory Review JSON" data-market-intel-mcp-fetch-candidate-queue-writer-post-closeout-inventory-review-review>
+                    <i class="fas fa-check" aria-hidden="true"></i>
+                </button>
+            </div>
+        </div>
+    </div>
+
     <div class="market-intel-panel" data-market-intel-manual-sample>
         <div class="market-intel-preview-head">
             <div>
@@ -1515,6 +1541,7 @@
         const mcpFetchCandidateQueueWriterRunReadinessRoot = document.querySelector('[data-market-intel-mcp-fetch-candidate-queue-writer-run-readiness]');
         const mcpFetchCandidateQueueWriterRunReceiptReviewRoot = document.querySelector('[data-market-intel-mcp-fetch-candidate-queue-writer-run-receipt-review]');
         const mcpFetchCandidateQueueWriterRunCloseoutReviewRoot = document.querySelector('[data-market-intel-mcp-fetch-candidate-queue-writer-run-closeout-review]');
+        const mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewRoot = document.querySelector('[data-market-intel-mcp-fetch-candidate-queue-writer-post-closeout-inventory-review]');
         const manualSampleRoot = document.querySelector('[data-market-intel-manual-sample]');
         const sampleAcceptanceRoot = document.querySelector('[data-market-intel-sample-acceptance]');
         const sampleReviewRoot = document.querySelector('[data-market-intel-sample-review]');
@@ -1531,7 +1558,7 @@
         const liveInventoryRoot = document.querySelector('[data-market-intel-live-inventory]');
         const approvalRoot = document.querySelector('[data-market-intel-approval]');
         const deployRoot = document.querySelector('[data-market-intel-deploy]');
-        if (!root && !writerRoot && !cliRoot && !dbProbeRoot && !seedDiffRoot && !legacyBridgeRoot && !mcpReadinessRoot && !mcpPreflightRoot && !mcpActivationRoot && !mcpFetchGateRoot && !mcpCompletionRoot && !mcpActivationEvidenceRoot && !mcpRuntimeSmokeRoot && !mcpRuntimePromotionRoot && !mcpManualFetchHandoffRoot && !mcpFetchTargetReviewRoot && !mcpFetchRunPackageRoot && !mcpFetchRunReadinessRoot && !mcpFetchRunReceiptRoot && !mcpFetchResultParserReviewRoot && !mcpFetchCandidateHandoffReviewRoot && !mcpFetchCandidateQueueReviewRoot && !mcpFetchCandidateQueueWriterPreflightRoot && !mcpFetchCandidateQueueWriterCliReviewRoot && !mcpFetchCandidateQueueWriterRunPackageReviewRoot && !mcpFetchCandidateQueueWriterRunReadinessRoot && !mcpFetchCandidateQueueWriterRunReceiptReviewRoot && !mcpFetchCandidateQueueWriterRunCloseoutReviewRoot && !manualSampleRoot && !sampleAcceptanceRoot && !sampleReviewRoot && !schedulerRoot && !matchReviewRoot && !opportunityRoot && !opportunityScoringRoot && !opportunityEvidenceRoot && !opportunityAlertRoot && !migrationRoot && !migrationDrillRoot && !catalogReviewRoot && !liveSmokeRoot && !liveInventoryRoot && !approvalRoot && !deployRoot) return;
+        if (!root && !writerRoot && !cliRoot && !dbProbeRoot && !seedDiffRoot && !legacyBridgeRoot && !mcpReadinessRoot && !mcpPreflightRoot && !mcpActivationRoot && !mcpFetchGateRoot && !mcpCompletionRoot && !mcpActivationEvidenceRoot && !mcpRuntimeSmokeRoot && !mcpRuntimePromotionRoot && !mcpManualFetchHandoffRoot && !mcpFetchTargetReviewRoot && !mcpFetchRunPackageRoot && !mcpFetchRunReadinessRoot && !mcpFetchRunReceiptRoot && !mcpFetchResultParserReviewRoot && !mcpFetchCandidateHandoffReviewRoot && !mcpFetchCandidateQueueReviewRoot && !mcpFetchCandidateQueueWriterPreflightRoot && !mcpFetchCandidateQueueWriterCliReviewRoot && !mcpFetchCandidateQueueWriterRunPackageReviewRoot && !mcpFetchCandidateQueueWriterRunReadinessRoot && !mcpFetchCandidateQueueWriterRunReceiptReviewRoot && !mcpFetchCandidateQueueWriterRunCloseoutReviewRoot && !mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewRoot && !manualSampleRoot && !sampleAcceptanceRoot && !sampleReviewRoot && !schedulerRoot && !matchReviewRoot && !opportunityRoot && !opportunityScoringRoot && !opportunityEvidenceRoot && !opportunityAlertRoot && !migrationRoot && !migrationDrillRoot && !catalogReviewRoot && !liveSmokeRoot && !liveInventoryRoot && !approvalRoot && !deployRoot) return;
 
         const meta = root ? root.querySelector('[data-market-intel-preview-meta]') : null;
         const body = root ? root.querySelector('[data-market-intel-preview-body]') : null;
@@ -1680,6 +1707,12 @@
         const mcpFetchCandidateQueueWriterRunCloseoutReviewReview = mcpFetchCandidateQueueWriterRunCloseoutReviewRoot ? mcpFetchCandidateQueueWriterRunCloseoutReviewRoot.querySelector('[data-market-intel-mcp-fetch-candidate-queue-writer-run-closeout-review-review]') : null;
         const mcpFetchCandidateQueueWriterRunCloseoutReviewRefresh = mcpFetchCandidateQueueWriterRunCloseoutReviewRoot ? mcpFetchCandidateQueueWriterRunCloseoutReviewRoot.querySelector('[data-market-intel-mcp-fetch-candidate-queue-writer-run-closeout-review-refresh]') : null;
         const mcpFetchCandidateQueueWriterRunCloseoutReviewEndpoint = "{{ url_for('market_intel.market_intel_mcp_fetch_candidate_queue_writer_run_closeout_review') }}";
+        const mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewMeta = mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewRoot ? mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewRoot.querySelector('[data-market-intel-mcp-fetch-candidate-queue-writer-post-closeout-inventory-review-meta]') : null;
+        const mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewBody = mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewRoot ? mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewRoot.querySelector('[data-market-intel-mcp-fetch-candidate-queue-writer-post-closeout-inventory-review-body]') : null;
+        const mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewInput = mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewRoot ? mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewRoot.querySelector('[data-market-intel-mcp-fetch-candidate-queue-writer-post-closeout-inventory-review-input]') : null;
+        const mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewReview = mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewRoot ? mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewRoot.querySelector('[data-market-intel-mcp-fetch-candidate-queue-writer-post-closeout-inventory-review-review]') : null;
+        const mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewRefresh = mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewRoot ? mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewRoot.querySelector('[data-market-intel-mcp-fetch-candidate-queue-writer-post-closeout-inventory-review-refresh]') : null;
+        const mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewEndpoint = "{{ url_for('market_intel.market_intel_mcp_fetch_candidate_queue_writer_post_closeout_inventory_review') }}";
         const manualSampleMeta = manualSampleRoot ? manualSampleRoot.querySelector('[data-market-intel-manual-sample-meta]') : null;
         const manualSampleBody = manualSampleRoot ? manualSampleRoot.querySelector('[data-market-intel-manual-sample-body]') : null;
         const manualSampleRefresh = manualSampleRoot ? manualSampleRoot.querySelector('[data-market-intel-manual-sample-refresh]') : null;
@@ -4780,6 +4813,134 @@
             }
         };
 
+        const renderMcpFetchCandidateQueueWriterPostCloseoutInventoryReviewMeta = data => {
+            mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewMeta.innerHTML = [
+                `mode=${data.mode || 'unknown'}`,
+                `accepted=${data.mcp_fetch_candidate_queue_writer_post_closeout_inventory_review_accepted ? 'yes' : 'no'}`,
+                `gates=${data.passed_gate_count || 0}/${data.gate_count || 0}`,
+                `rows=${data.payload_row_count || 0}`,
+                `handoff=${data.ready_for_candidate_queue_review_handoff ? 'ready' : 'blocked'}`,
+                `query=${data.api_inventory_query_executed ? 'api' : 'operator'}`
+            ].map(item => `<span class="market-intel-pill">${escapeHtml(item)}</span>`).join('');
+        };
+
+        const renderMcpFetchCandidateQueueWriterPostCloseoutInventoryReviewBody = data => {
+            const blockers = (data.blocked_reasons || []).join(' / ');
+            const gates = data.gates || [];
+            const closeout = data.writer_run_closeout_review_summary || {};
+            const inventory = data.operator_inventory_summary || {};
+            const artifacts = [
+                ['inventory_artifact_path', inventory.inventory_artifact_path, inventory.inventory_artifact_path_safe],
+                ['closeout_review_artifact_path', inventory.closeout_review_artifact_path, inventory.closeout_review_artifact_path_safe],
+                ['read_only_query_result_path', inventory.read_only_query_result_path, inventory.read_only_query_result_path_safe]
+            ];
+            const steps = data.next_operator_steps || [];
+            const renderCheck = (key, label, status) => `
+                <div class="market-intel-check">
+                    <div>
+                        <strong>${escapeHtml(key)}</strong>
+                        <small>${escapeHtml(label || '')}</small>
+                    </div>
+                    <span>${escapeHtml(status)}</span>
+                </div>
+            `;
+            mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewBody.innerHTML = `
+                <div class="market-intel-empty mb-3">此 post-closeout inventory review 只審核操作員已完成的 live inventory read-only 摘要；API 不查 DB、不補寫 queue row、不讀 approval token、不執行 CLI、不掛 scheduler。${blockers ? `阻擋：${escapeHtml(blockers)}` : ''}</div>
+                <div class="market-intel-deploy-grid">
+                    <div data-market-intel-mcp-fetch-candidate-queue-writer-post-closeout-inventory-review-gates>
+                        <p class="market-intel-deploy-section-title">INVENTORY GATES</p>
+                        <div class="market-intel-check-list">${
+                            gates.length
+                                ? gates.map(item => renderCheck(item.key, item.label, item.passed ? 'PASS' : 'BLOCK')).join('')
+                                : '<div class="market-intel-empty">尚未提供 inventory gates。</div>'
+                        }</div>
+                    </div>
+                    <div data-market-intel-mcp-fetch-candidate-queue-writer-post-closeout-inventory-review-closeout>
+                        <p class="market-intel-deploy-section-title">CLOSEOUT LINK</p>
+                        <div class="market-intel-check-list">
+                            ${renderCheck('closeout_review', `${closeout.accepted ? 'accepted' : 'pending'} / rows=${closeout.payload_row_count || 0}`, closeout.accepted ? 'ACCEPTED' : 'PENDING')}
+                            ${renderCheck('closeout_id', closeout.closeout_id || 'missing', closeout.closeout_id ? 'LINKED' : 'BLOCK')}
+                            ${renderCheck('manifest', 'writer output + post-write smoke + backup', closeout.artifact_manifest_preserved ? 'PRESERVED' : 'BLOCK')}
+                            ${renderCheck('api_boundary', 'no CLI / no token / no DB / no scheduler', closeout.side_effects_clear ? 'CLOSED' : 'BLOCK')}
+                        </div>
+                    </div>
+                    <div data-market-intel-mcp-fetch-candidate-queue-writer-post-closeout-inventory-review-inventory>
+                        <p class="market-intel-deploy-section-title">INVENTORY SUMMARY</p>
+                        <div class="market-intel-check-list">
+                            ${renderCheck('inventory_review_id', inventory.inventory_review_id || 'missing', inventory.inventory_review_id ? 'RECORDED' : 'BLOCK')}
+                            ${renderCheck('found_rows', `${inventory.found_row_count || 0}/${closeout.payload_row_count || 0}`, inventory.found_row_count === closeout.payload_row_count ? 'MATCH' : 'BLOCK')}
+                            ${renderCheck('missing_rows', String(inventory.missing_row_count || 0), inventory.missing_row_count === 0 ? 'NONE' : 'BLOCK')}
+                            ${renderCheck('duplicates', String(inventory.unexpected_duplicate_count || 0), inventory.unexpected_duplicate_count === 0 ? 'NONE' : 'BLOCK')}
+                        </div>
+                    </div>
+                    <div data-market-intel-mcp-fetch-candidate-queue-writer-post-closeout-inventory-review-artifacts>
+                        <p class="market-intel-deploy-section-title">ARTIFACT TRACE</p>
+                        <div class="market-intel-check-list">
+                            ${artifacts.map(item => renderCheck(item[0], item[1] || 'missing', item[2] ? 'SAFE' : 'BLOCK')).join('')}
+                        </div>
+                    </div>
+                    <div data-market-intel-mcp-fetch-candidate-queue-writer-post-closeout-inventory-review-next>
+                        <p class="market-intel-deploy-section-title">BOUNDARY / NEXT</p>
+                        <div class="market-intel-check-list">
+                            ${renderCheck('read_only_query', `${inventory.query_type || 'missing'} / operator shell`, inventory.read_only_query_executed_by_operator && inventory.query_type === 'read_only_select' ? 'PASS' : 'BLOCK')}
+                            ${renderCheck('operator_boundaries', 'no API DB/query/CLI/file/scheduler', inventory.inventory_read_only && inventory.no_api_database_write && inventory.no_api_inventory_query && inventory.no_api_cli_execution && inventory.no_scheduler_attach ? 'CONFIRMED' : 'BLOCK')}
+                            ${renderCheck('api_side_effects', 'no inventory file / no API query / no DB write / no queue write', data.inventory_file_written || data.api_inventory_query_executed || data.api_writes_database || data.candidate_queue_persisted ? 'BLOCK' : 'CLOSED')}
+                            ${steps.map((item, index) => renderCheck(`step_${index + 1}`, item, 'NEXT')).join('')}
+                        </div>
+                    </div>
+                </div>
+            `;
+            if (mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewInput && !mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewInput.value.trim() && data.sample_writer_post_closeout_inventory_review_package) {
+                mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewInput.value = JSON.stringify(data.sample_writer_post_closeout_inventory_review_package, null, 2);
+            }
+        };
+
+        const loadMcpFetchCandidateQueueWriterPostCloseoutInventoryReview = async () => {
+            if (!mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewMeta || !mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewBody) return;
+            mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewBody.innerHTML = '<div class="market-intel-empty">讀取 MCP Writer Post-Closeout Inventory Review 中...</div>';
+            try {
+                const response = await fetch(mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewEndpoint, { credentials: 'same-origin' });
+                if (!response.ok) throw new Error(`HTTP ${response.status}`);
+                const data = await response.json();
+                renderMcpFetchCandidateQueueWriterPostCloseoutInventoryReviewMeta(data);
+                renderMcpFetchCandidateQueueWriterPostCloseoutInventoryReviewBody(data);
+            } catch (error) {
+                mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewMeta.innerHTML = '<span class="market-intel-pill">error</span>';
+                mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewBody.innerHTML = `<div class="market-intel-empty">MCP Writer Post-Closeout Inventory Review 讀取失敗：${escapeHtml(error.message)}</div>`;
+            }
+        };
+
+        const reviewMcpFetchCandidateQueueWriterPostCloseoutInventoryReview = async () => {
+            if (!mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewMeta || !mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewBody || !mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewInput) return;
+            let parsed;
+            try {
+                parsed = JSON.parse(mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewInput.value || '{}');
+            } catch (error) {
+                mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewMeta.innerHTML = '<span class="market-intel-pill">json_error</span>';
+                mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewBody.innerHTML = `<div class="market-intel-empty">JSON 格式錯誤：${escapeHtml(error.message)}</div>`;
+                return;
+            }
+            mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewBody.innerHTML = '<div class="market-intel-empty">審核 MCP Writer Post-Closeout Inventory Review 中...</div>';
+            try {
+                const response = await fetch(mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewEndpoint, {
+                    method: 'POST',
+                    credentials: 'same-origin',
+                    headers: {
+                        'Content-Type': 'application/json',
+                        'X-CSRFToken': csrfToken
+                    },
+                    body: JSON.stringify({ writer_post_closeout_inventory_review_package: parsed })
+                });
+                const data = await response.json();
+                if (!response.ok && !data.mode) throw new Error(`HTTP ${response.status}`);
+                renderMcpFetchCandidateQueueWriterPostCloseoutInventoryReviewMeta(data);
+                renderMcpFetchCandidateQueueWriterPostCloseoutInventoryReviewBody(data);
+            } catch (error) {
+                mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewMeta.innerHTML = '<span class="market-intel-pill">error</span>';
+                mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewBody.innerHTML = `<div class="market-intel-empty">MCP Writer Post-Closeout Inventory Review 審核失敗：${escapeHtml(error.message)}</div>`;
+            }
+        };
+
         const renderManualSampleMeta = data => {
             manualSampleMeta.innerHTML = [
                 `mode=${data.mode || 'unknown'}`,
@@ -14285,6 +14446,12 @@
         if (mcpFetchCandidateQueueWriterRunCloseoutReviewReview) {
             mcpFetchCandidateQueueWriterRunCloseoutReviewReview.addEventListener('click', reviewMcpFetchCandidateQueueWriterRunCloseoutReview);
         }
+        if (mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewRefresh) {
+            mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewRefresh.addEventListener('click', loadMcpFetchCandidateQueueWriterPostCloseoutInventoryReview);
+        }
+        if (mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewReview) {
+            mcpFetchCandidateQueueWriterPostCloseoutInventoryReviewReview.addEventListener('click', reviewMcpFetchCandidateQueueWriterPostCloseoutInventoryReview);
+        }
         if (manualSampleRefresh) {
             manualSampleRefresh.addEventListener('click', loadManualSample);
         }
@@ -14556,6 +14723,7 @@
         loadMcpFetchCandidateQueueWriterRunReadiness();
         loadMcpFetchCandidateQueueWriterRunReceiptReview();
         loadMcpFetchCandidateQueueWriterRunCloseoutReview();
+        loadMcpFetchCandidateQueueWriterPostCloseoutInventoryReview();
         loadManualSample();
         loadSampleAcceptance();
         loadSampleReview();