新增市場情報 AI summary persistence writer preflight

templates/market_intel/disabled.html

@@ -691,6 +691,9 @@
                 <button class="market-intel-icon-button" type="button" title="產生 queue review AI summary persistence transaction preview" data-market-intel-sample-candidate-queue-review-ai-summary-persistence-transaction>
                     <i class="fas fa-code-branch" aria-hidden="true"></i>
                 </button>
+                <button class="market-intel-icon-button" type="button" title="檢查 queue review AI summary persistence writer preflight" data-market-intel-sample-candidate-queue-review-ai-summary-persistence-writer-preflight>
+                    <i class="fas fa-database" aria-hidden="true"></i>
+                </button>
             </div>
         </div>
     </div>
@@ -1049,6 +1052,7 @@
         const sampleCandidateQueueReviewAiSummaryOutputReceipt = sampleReviewRoot ? sampleReviewRoot.querySelector('[data-market-intel-sample-candidate-queue-review-ai-summary-output-receipt]') : null;
         const sampleCandidateQueueReviewAiSummaryPersistencePreflight = sampleReviewRoot ? sampleReviewRoot.querySelector('[data-market-intel-sample-candidate-queue-review-ai-summary-persistence-preflight]') : null;
         const sampleCandidateQueueReviewAiSummaryPersistenceTransaction = sampleReviewRoot ? sampleReviewRoot.querySelector('[data-market-intel-sample-candidate-queue-review-ai-summary-persistence-transaction]') : null;
+        const sampleCandidateQueueReviewAiSummaryPersistenceWriterPreflight = sampleReviewRoot ? sampleReviewRoot.querySelector('[data-market-intel-sample-candidate-queue-review-ai-summary-persistence-writer-preflight]') : 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') }}";
@@ -1084,6 +1088,7 @@
         const sampleCandidateQueueReviewAiSummaryOutputReceiptEndpoint = "{{ url_for('market_intel_review.market_intel_manual_sample_candidate_queue_review_ai_summary_output_receipt') }}";
         const sampleCandidateQueueReviewAiSummaryPersistencePreflightEndpoint = "{{ url_for('market_intel_review.market_intel_manual_sample_candidate_queue_review_ai_summary_persistence_preflight') }}";
         const sampleCandidateQueueReviewAiSummaryPersistenceTransactionEndpoint = "{{ url_for('market_intel_review.market_intel_manual_sample_candidate_queue_review_ai_summary_persistence_transaction') }}";
+        const sampleCandidateQueueReviewAiSummaryPersistenceWriterPreflightEndpoint = "{{ url_for('market_intel_review.market_intel_manual_sample_candidate_queue_review_ai_summary_persistence_writer_preflight') }}";
         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;
@@ -5295,6 +5300,123 @@
             }
         };
 
+        const renderCandidateQueueReviewAiSummaryPersistenceWriterPreflight = data => {
+            const blockers = (data.blocked_reasons || []).join(' / ');
+            const gates = data.gates || [];
+            const contract = data.writer_preflight_contract || {};
+            const statements = data.statement_payloads || [];
+            sampleReviewMeta.innerHTML = [
+                `mode=${data.mode || 'unknown'}`,
+                `preflight=${data.summary_persistence_writer_preflight_ready ? 'ready' : 'blocked'}`,
+                `run_package=${data.ready_for_summary_persistence_run_package ? 'ready' : 'blocked'}`,
+                `statements=${data.statement_count || 0}`,
+                `db=${data.database_write_executed ? 'written' : 'blocked'}`
+            ].map(item => `<span class="market-intel-pill">${escapeHtml(item)}</span>`).join('');
+            sampleReviewBody.innerHTML = `
+                <div class="market-intel-empty mb-3">此卡只檢查 AI summary persistence writer preflight；正式 metadata_json 寫入仍需未來 CLI-only run package。API/UI 不讀 token、不執行 CLI、不開 DB、不寫檔、不派送 Telegram。${blockers ? `阻擋：${escapeHtml(blockers)}` : ''}</div>
+                <div class="market-intel-deploy-grid">
+                    <div>
+                        <p class="market-intel-deploy-section-title">WRITER PREFLIGHT GATES</p>
+                        <div class="market-intel-check-list">${
+                            gates.map(gate => `
+                                <div class="market-intel-check">
+                                    <div>
+                                        <strong>${escapeHtml(gate.key)}</strong>
+                                        <small>${escapeHtml(gate.label)}</small>
+                                    </div>
+                                    <span>${gate.passed ? 'PASS' : 'BLOCK'}</span>
+                                </div>
+                            `).join('') || '<div class="market-intel-empty">尚未提供 writer preflight gate。</div>'
+                        }</div>
+                    </div>
+                    <div>
+                        <p class="market-intel-deploy-section-title">WRITER CONTRACT</p>
+                        <div class="market-intel-check-list">
+                            ${[
+                                ['target_table', contract.target_table || 'missing'],
+                                ['target_column', contract.target_column || 'missing'],
+                                ['json_path', (contract.target_json_path || []).join('.') || 'missing'],
+                                ['manual_cli_required', contract.manual_cli_required],
+                                ['api_write_allowed', contract.api_write_allowed],
+                                ['backup_required', contract.requires_metadata_json_backup],
+                                ['postwrite_smoke', contract.requires_postwrite_smoke]
+                            ].map(([key, value]) => `
+                                <div class="market-intel-check">
+                                    <div><strong>${escapeHtml(key)}</strong></div>
+                                    <span>${escapeHtml(String(value))}</span>
+                                </div>
+                            `).join('')}
+                        </div>
+                    </div>
+                    <div>
+                        <p class="market-intel-deploy-section-title">STATEMENT PAYLOADS</p>
+                        <div class="market-intel-check-list">${
+                            statements.map(item => `
+                                <div class="market-intel-check">
+                                    <div>
+                                        <strong>${escapeHtml(item.statement_type || 'UPDATE')}</strong>
+                                        <small>${escapeHtml(item.dedupe_key || 'missing')}</small>
+                                    </div>
+                                    <span>${item.execute_in_api ? 'WRITE' : 'CLI'}</span>
+                                </div>
+                            `).join('') || '<div class="market-intel-empty">尚未載入 statement payload。</div>'
+                        }</div>
+                    </div>
+                    <div>
+                        <p class="market-intel-deploy-section-title">NO-SIDE-EFFECTS</p>
+                        <div class="market-intel-check-list">
+                            ${[
+                                ['api_executes_cli', data.api_executes_cli],
+                                ['api_reads_approval_token', data.api_reads_approval_token],
+                                ['api_writes_database', data.api_writes_database],
+                                ['summary_persistence_writer_preflight_file_written', data.summary_persistence_writer_preflight_file_written],
+                                ['database_connection_opened', data.database_connection_opened],
+                                ['database_write_executed', data.database_write_executed],
+                                ['telegram_dispatched', data.telegram_dispatched],
+                                ['scheduler_attached', data.scheduler_attached]
+                            ].map(([key, value]) => `
+                                <div class="market-intel-check">
+                                    <div><strong>${escapeHtml(key)}</strong></div>
+                                    <span>${escapeHtml(String(value))}</span>
+                                </div>
+                            `).join('')}
+                        </div>
+                    </div>
+                </div>
+            `;
+        };
+
+        const loadCandidateQueueReviewAiSummaryPersistenceWriterPreflight = 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;
+            }
+            const body = parsed && parsed.sample_result ? parsed : { sample_result: parsed };
+            sampleReviewBody.innerHTML = '<div class="market-intel-empty">檢查 queue review AI summary persistence writer preflight 中...</div>';
+            try {
+                const response = await fetch(sampleCandidateQueueReviewAiSummaryPersistenceWriterPreflightEndpoint, {
+                    method: 'POST',
+                    credentials: 'same-origin',
+                    headers: {
+                        'Content-Type': 'application/json',
+                        'X-CSRFToken': csrfToken
+                    },
+                    body: JSON.stringify(body)
+                });
+                const data = await response.json();
+                if (!response.ok && !data.mode) throw new Error(`HTTP ${response.status}`);
+                renderCandidateQueueReviewAiSummaryPersistenceWriterPreflight(data);
+            } catch (error) {
+                sampleReviewMeta.innerHTML = '<span class="market-intel-pill">error</span>';
+                sampleReviewBody.innerHTML = `<div class="market-intel-empty">queue review AI summary persistence writer preflight 失敗：${escapeHtml(error.message)}</div>`;
+            }
+        };
+
         const renderCandidateQueueReviewDecisionWriter = data => {
             const blockers = (data.blocked_reasons || []).join(' / ');
             const summary = data.statement_summary || {};
@@ -7001,6 +7123,9 @@
         if (sampleCandidateQueueReviewAiSummaryPersistenceTransaction) {
             sampleCandidateQueueReviewAiSummaryPersistenceTransaction.addEventListener('click', loadCandidateQueueReviewAiSummaryPersistenceTransaction);
         }
+        if (sampleCandidateQueueReviewAiSummaryPersistenceWriterPreflight) {
+            sampleCandidateQueueReviewAiSummaryPersistenceWriterPreflight.addEventListener('click', loadCandidateQueueReviewAiSummaryPersistenceWriterPreflight);
+        }
         if (schedulerRefresh) {
             schedulerRefresh.addEventListener('click', loadScheduler);
         }