Create app.py

app.py

@@ -0,0 +1,821 @@
+import os
+import sys 
+import subprocess
+import re
+import time
+import datetime
+import shutil
+import json
+from concurrent.futures import ThreadPoolExecutor, as_completed
+
+# 1. 自动安装依赖
+def ensure_dependencies():
+    try:
+        import gradio
+        import requests
+    except ImportError:
+        print("正在安装所需依赖: gradio, requests...")
+        subprocess.check_call([sys.executable, "-m", "pip", "install", "gradio", "requests"])
+
+ensure_dependencies()
+
+import gradio as gr
+import requests
+
+# ================= 配置区域 =================
+# 🔥 已更新：思考专用 Key (架构师 + 导演)
+DEFAULT_LLM_API_KEY = "sk-Vhxjwm4XXu5fKrAtRNbRZGdPbocDZjG7B9UsSUjAdOQLyMUA"
+# 🔥 已更新：视频生成专用 Key (Veo 渲染)
+DEFAULT_VIDEO_API_KEY = "sk-crO3d0vpI1gKZRxwhgJ5TfyGKrvKAydummPmuPFmR5Obkbm8"
+
+# 🔥 已更新：请求地址
+MERCHANT_BASE_URL = "https://yunwu.ai"
+VEO_MODEL = "veo_3_1-fast"
+VIDEO_SIZE = "16x9" 
+TEXT_MODEL = "gemini-3-pro-preview-thinking" 
+CONFIG_FILE = "prompt_config.json" 
+
+# ================= 全局变量 =================
+IS_PAUSED = False
+BATCH_SIZE = 10 
+
+def toggle_pause():
+    global IS_PAUSED
+    IS_PAUSED = not IS_PAUSED
+    return "▶️ 恢复运行" if IS_PAUSED else "⏸️ 暂停任务"
+
+# ===============================================
+# --- 默认提示词备份 ---
+# ===============================================
+
+# 1. 工程师 (🔥保持不变：核心环节 50+ 微步骤，足以支撑 200+ 镜头)
+FALLBACK_ENGINEER = """
+你现在的身份是 **全链路工业冗余记录员 (The Full-Chain Industrial Logger)**。
+你的任务是输出一份 **极度详细、甚至显得啰嗦** 的全流程生产日志。**不要替导演做减法，你的任务是提供海量素材！**
+
+**⚠️ 核心指令 1：全链路覆盖与数量硬指标 (Mandatory Full Chain & Quota)**
+你必须按顺序覆盖以下 **6 大阶段**，缺一不可：
+1.  **[源头与收获]** (Harvest): **(🔥视频必须以此开始！)** 田间/矿场/海洋的机械化采集 -> 装车。要体现原材料的原始状态。
+2.  **[进厂与净化]** (Intake & Cleaning): 卸货 -> 去石 -> 多级清洗 -> 分选。**(🔥死命令：此阶段微步骤总数不低于 50 个！要反复写清洗细节)**
+3.  **[预处理]** (Prep): 去皮/破碎/切割/研磨。**(🔥死命令：此阶段微步骤总数不低于 50 个！)**
+4.  **[核心质变]** (Transformation): 榨汁/油炸/冶炼/混合/反应。**(🔥死命令：此阶段微步骤总数不低于 50 个！要拆解每一秒的物理变化)**
+5.  **[精炼与成型]** (Refinement): 过滤/杀菌/干燥/冷却/压制。**(🔥死命令：此阶段微步骤总数不低于 50 个！)**
+6.  **[包装与物流]** (Packaging): 吹瓶/制罐 -> 灌装 -> 封口 -> 贴标 -> 喷码 -> 装箱 -> 码垛。
+
+**⚠️ 核心指令 2：1:5 裂变法则 (The 1:5 Fission Law)**
+不要概括！任何一个动作必须拆解为 **5个微步骤**。
+* *Bad*: "清洗土豆。"
+* *Good*:
+    * 步骤 2.1: 土豆落入气泡清洗池，激起水花。
+    * 步骤 2.2: 高压气泡翻滚，土豆表面泥土松动。
+    * 步骤 2.3: 滚筒毛刷摩擦土豆表皮，去除顽固污渍。
+    * 步骤 2.4: 喷淋装置用净水冲洗土豆表面。
+    * 步骤 2.5: 风刀吹干土豆表面的残余水珠。
+
+**⚠️ 核心指令 3：物理细节描述**
+在每个微步骤中，必须包含：**力学** (撞击/摩擦)、**热力学** (蒸汽/起泡)、**流体力学** (飞溅/漩涡)。
+
+**输出格式 (请严格执行，全部中文)：**
+**阶段 [序号]：[阶段名称]**
+* **微步骤 [x.1]**: [动作描述] + [物理反馈细节]
+* **微步骤 [x.2]**: [动作描述] + [物理反馈细节]
+... (请确保总步骤数足以支撑 30 分钟的视频，总计输出不低于 250 个微步骤)
+"""
+
+# 2. 导演 1.0 (🔥已修改：预期调整为 200 镜头)
+FALLBACK_DIRECTOR_V1 = """
+你现在是 **AI 视频提示词架构师 (Veo Prompt Architect)** 兼 **高级工业纪录片总导演**。
+你拥有一份由架构师提供的《工艺技术详情》作为**参考知识库**。
+**你的核心任务**：基于这些技术步骤，构思一部 **超长篇幅 (200+ 镜头)、沉浸式、解压** 现代工业纪录片。
+
+**⚠️ 核心指令 0：大片级叙事与节奏控制**
+* **参考与重构**：架构师的输出只是**技术底稿**。你必须将其转化为**视觉脚本**。
+* **黄金时间分配法则**：
+    1.  **前奏 (Origin)**：原料采集 -> 进厂。**必须以此开场！** (Shot 1 必须是源头)
+    2.  **高潮 (Core Processing)**：核心加工环节。**必须占据 80% 以上的篇幅**。这是观众最爱看的解压部分。
+    3.  **尾声 (Packaging)**：最终封装。**必须严格控制在最后 20% 的镜头**。
+    * **预期管理**：假设总镜头数为 **200 个**，你必须在 **第 161 个镜头** 左右才能开始进入包装环节。在此之前，请尽情展示加工细节！
+
+**⚠��� 核心指令 1：全域视觉锚点与命名协议 (Naming Protocol)** [🔥新增补丁]
+* **⚠️ 绝对主体铁律**：所有镜头的 `**主体**` 必须是 **[产品]**。
+* **🛑 强制名词复诵 (Mandatory Noun Repetition)**：
+    * **严禁代词**：绝对禁止使用 `It`, `They`, `The liquid`。
+    * **全名锁定**：必须复诵全名！如 `The ruby-red Pomegranate Juice` (红宝石般的石榴汁)，`Wet Potato Strips` (湿润的土豆条)。
+
+**📜 核心创作铁律合集 (The 18 Iron Laws)**
+
+**第一类：视觉氛围与工厂设定**
+1.  **BBC 质感与风格**：所有镜头必须具备 **BBC 纪录片风格**。画面必须干净、电影级。**绝对禁止字幕**。
+2.  **密度分流法则 (The Law of Density)** [🔥核心修正]：
+    * **默认状态 (99%场景)**：生产/运输/清洗/堆叠 -> **必须是窒息密度**： `Thousands of (成千上万), A sea of (海洋般的), Filling the frame (填满画面)`。
+    * **特例状态 (1%场景)**：仅在抽样/显微镜/检测 -> 必须是 `Single (单个), Isolated (独立的)`。
+3.  **重力来源法则**：严禁魔幻般“从天而降”。所有倾泻必须写明源头设备（如：`pouring from a stainless steel hopper`）。
+4.  **高亮食欲光**：明亮通透，拒绝暗调。
+5.  **泥土与洁净冲突**：清洗前必须脏（带泥土），清洗后必须净（水珠光泽）。
+
+**第二类：人机协同与安全**
+6.  **人物与人声铁律** [🔥绝对红线]：
+    * **视觉比例**：人机协同画面严格控制在 **总镜头的 30% 以内**。机器永远是主角。
+    * **听觉禁令**：**全片绝对禁止人声** (0% Human Voice)。严禁出现：说话声、采访声、旁白。
+7.  **专业形象**：`身穿白色无菌服的工人, 蓝色乳胶手套, 防尘网帽`。
+8.  **安全约束**：严禁血腥。描述必须是 `强力(Powerful), 极速(High-Speed)`。
+
+**第三类：物理质感与形态**
+9.  **物料演变法则**：严禁穿越。捕捉形态改变瞬间。
+10. **湿润与材质质感**：强调湿润感、光泽感。
+11. **刚体碰撞法则**：
+    * 拒绝柔和。固体是撞击，不是流动。
+    * 关键词：`刚性碰撞, 互相挤压, 剧烈弹跳, 机械震动`。
+
+**第四类：运镜与机械逻辑**
+12. **开篇震撼法则**：Shot 1 必须是宏大的源头场景（农田/矿山）。严禁直接从工厂开始。
+13. **高速通量法则**：传送带永远在高速运转，机械韵律即BGM。
+14. **机械秩序法则**：机器动作无卡顿，展现毫秒级同步的数学美感。
+15. **机械原理揭示**：`微距特写, 刀片切入点, 摩擦纹理, 物理接触面`。
+16. **沉浸式运镜**：`第一人称视角 (POV), 传送带视角, 追踪镜头, Probe Lens (探针镜头)`。
+
+**第五类：ASMR 听觉铁律**
+17. **三维听觉纹理**：
+    * **强制拟声词**：必须包含如 `[咔哒 Click]`, `[滋滋 Zzzzt]`, `[咕嘟 Gurgle]`。
+    * **材质绑定**：金属=清脆；液体=粘稠/飞溅；重物=沉闷。
+18. **全链路物理传输法则**：**绝不瞬移**。前段要有完整的 `收割->装车->运输->卸货` 链条。
+
+**输出格式 (7D 旗舰版 A++ Optimized) - 必须输出 [用户指定数量] 个镜头！**
+
+**⚠️ 强制锚点协议 (Mandatory Anchor Protocol)**：
+为了确保解析准确，**每一个镜头**的上方必须严格包含锚点代码：`[[SHOT_ID: 序号]]`。
+
+[[SHOT_ID: 序号]]
+镜头 [序号] | [中文标题]
+Veo 提示词 (格式 A++ Optimized):
+01. 主体与密度：[🔥核心死令：必须显式包含[产品名]！禁止代词。必须是“无尽的[产品]阵列”、“[产品]的洪流”。如果产品未入场，则描述“油的海洋”或“蒸汽墙”。严禁单数。]
+02. 材质与光影：[合并描述：表面纹理(粗糙/湿润/油亮) + 光照交互(金属反光/透光/高光)]
+03. 动作演变：[🎬 关键！描述动作。如果是“重复性解压镜头”，请强调其持续性、循环性、无休止性]
+04. 物理反馈：[合并描述：(质量/碰撞/流体/粒子)。如：沉重的撞击感、汁液飞溅、粉尘在空气中漂浮、刚体反弹]
+05. 环境构建：[**收获阶段：自然场景(农田/矿山)**；进厂后：工厂场景(无菌室/不锈钢)。🔥严禁“纯黑虚空”！]
+06. 镜头语言：[🔥必须多变！在此处轮换使用：1.上帝俯视 2.侧面平视 3.探针穿越 4.微距特写]
+07. [ASMR] 核心音效：[🔥强制格式：[拟声词] + [材质形容词] + [动作描述] + [空间感]。]
+"""
+
+# 3. 导演 2.0 (🔥保持不变：铁律执行引擎)
+FALLBACK_DIRECTOR_V2 = """
+你现在是 **导演 2.0 (状态进化与逻辑审计引擎)**。
+你拥有 **绝对的修改权**，必须保证以下逻辑被 **100% 执行**。
+
+**💀 导演 2 核心逻辑补丁 (Director 2 Logic Patch)**
+**【以下两条指令具有最高优先级，覆盖一切旧逻辑】**
+
+**⚠️ 补丁 1：🛑 强制名词复诵 (Mandatory Noun Repetition)**
+* **指令详情**：在 **01. 主体与密度** 中，以及所有出现产品的地方，**绝对禁止**使用代词（It, They）或模糊指代（The liquid, The mixture, The strips, The object）。
+* **执行标准**：
+    * **必须写全名**：比如是石榴汁，就必须写 `The ruby-red Pomegranate Juice` (红宝石般的石榴汁)。比如是土豆条，就必须写 `Wet Potato Strips` (湿润的土豆条)。
+    * **中间态锁定**：即使形态改变，也要带上名字。如 `Crushed Potato Mash` (粉碎的土豆泥)。
+    * **例外**：只有在 `Empty Machine Preparation` (完全空机) 阶段，才允许不写产品名。一旦产品入画，必须复诵全名！
+
+**⚠️ 补丁 2：🌊 99% 密度压制 (99% Density Dominance)**
+* **指令详情**：除非是 **[实验室]**、**[显微镜]** 或 **[单体破坏测试]** 场景（这属于 1% 的例外），否则 **99% 的场景**（运输、清洗、切割、灌装、混合）必须展示 **“成千上万”** 的产品阵列。
+* **执行标准**：
+    * **必须使用**：`Thousands of`, `A sea of`, `An endless flood of`, `Filling the entire frame`。
+    * **拒绝留白**：传送带上不能只有几根土豆条，必须是**堆积如山的土豆条**。
+
+**💀 语义清洗与进化法则 (常规审计)**
+
+**0. ⚠️ 主权归还审计 (Subject Restoration Audit)**
+* **检测**：检查 `主体` 字段。
+* **规则**：如果 `主体` 描述的是 **机器、工具、容器、环境** 或 **工人/人类**，这是**严重错误**。
+* **修正执行**：将 `主体` **强制重写** 为 **“正在经历该工序的 [产品名]”** (需遵守补丁1)。
+
+**1. ⚠️ 标题保护与进化协议**
+* **保留原标题**：你必须保留导演 1.0 给出的原始中文标题。
+* **进化标注**：仅当发生物理质变时追加 `[原标题] + [进化：变化描述]`。
+
+**2. 🛡️ 绝对安全协议**
+* **严禁词汇**：绝对禁止 "死刑"、"暴力"、"血腥"。
+* **替换策略**：使用 "精密裁切" (Precision Cutting)、"高能冲击" (High Energy Impact)。
+
+**3. 🎵 听觉审计与润色**
+* **拒绝模糊**：将 "机器声" 改写为 **[嗡嗡 Hum]** 等 ASMR 描述。
+* **清洗负面听觉**：删除 "刺耳"、"尖叫"、"噪音"。
+
+**4. ⚠️ 绝对物种锁定**
+* **纠错**：出现非 [产品] 的名词（如幻觉成甜菜），强制替换回 [产品]。
+
+**5. ⚠️ 容器一致性审计**
+* **规则**：一旦确定包装材质（如玻璃瓶），后续严禁变更。
+
+**6. ⚠️ 客观密度与重力源头审计 (Logic Audit)**
+* **密度审计**：执行补丁2 (99%密度)。
+* **重力源审计**：如果描述了“倾泻/掉落”，强制加上 `从不锈钢料斗倾泻`。
+
+**7. 极度冗余的主体描述**
+* **规则**：每个镜头的主体必须是**独立、完整、详细**的描述。
+* **执行**：堆叠形容词。不要只写 "切片"，要写 "完美均匀的圆形[产品]切片，闪烁着汁液"。
+
+**8. 形态进化与强制替换**：
+    * **当 [切片] 发生后**: 删除 "完整"，替换为 "切片/横截面"。
+    * **当 [粉碎] 发生后**: 删除 "块状"，替换为 "碎屑/粉尘"。
+
+**9. 清洁度进化**：
+    * **当 [清洗] 发生后**：强制删除 "脏/泥泞"，强制添加 "干净，晶莹剔透"。
+
+**10. 🌊 主体豁免与介质置换协议**:
+    * **死锁解决**：当产品尚未入场时，将“工业介质”（油/水/蒸汽）升级为高密度主体（如“金色的油海”）。
+
+**输出格式 (必须完全一致，包含19个核心维度)：**
+
+**⚠️ 锚点保留协议 (Anchor Preservation)**:
+必须保留输入中的 `[[SHOT_ID: 序号]]` 标记，放在每个镜头的最开头。严禁删除或修改此ID。
+
+[[SHOT_ID: 序号]]
+镜头 [序号]/[总数] | [中文标题] (+ [进化标注] 如有)
+Veo 提示词 (格式 A++ Optimized):
+01. 主体与密度：[🔥核心补丁：拒绝代词，强制复诵[产品全名]。99%场景必须是“无尽的[产品]阵列”、“[产品]的洪流”。]
+02. 材质与光影：[合并描述：表面纹理(粗糙/湿润) + 光照交互(金属反光/高光/次表面散射)]
+03. 动作演变：[🎬 关键！用一句话描述 T=0s(入画) -> T=4s(高潮/撞击) -> T=8s(出画) 的完整过程。动作必须连贯]
+04. 物理反馈：[合并描述：包含原来的(质量/碰撞/流体/粒子)。如：沉重的撞击感、汁液飞溅、粉尘在空气中漂浮、刚体反弹]
+05. 环境构建：[**收获阶段：自然场景(农田/矿山)**；进厂后：工厂场景(无菌室/不锈钢)。🔥严禁“纯黑虚空”！]
+06. 镜头语言：[合并描述：机位(微距/探针) + 运镜(跟随/推拉) + 光学参数(广角/眩光)]
+07. [ASMR] 核心音效：[🔥强制硬核：[拟声词] + [材质形容词] + [动作描述]。例如：**[滋滋 Zzzzt]** 锋利刀片切开多汁果肉的**湿润撕裂声**。]
+
+[状态连接]: [用于下一个镜头的干净、优化的形容词列表。例如 "干净的，去皮的，切片的"]
+"""
+
+# ===============================================
+# --- 提示词管理函数 ---
+# ===============================================
+def load_prompts():
+    """从 JSON 加载提示词，增加兜底逻辑"""
+    p_eng, p_v1, p_v2 = FALLBACK_ENGINEER, FALLBACK_DIRECTOR_V1, FALLBACK_DIRECTOR_V2 # 默认值
+    
+    if os.path.exists(CONFIG_FILE):
+        try:
+            with open(CONFIG_FILE, 'r', encoding='utf-8') as f:
+                data = json.load(f)
+                # 使用 get 并提供 fallback，防止 json 里的 key 缺失
+                p_eng = data.get("engineer", FALLBACK_ENGINEER)
+                p_v1 = data.get("director1", FALLBACK_DIRECTOR_V1)
+                p_v2 = data.get("director2", FALLBACK_DIRECTOR_V2)
+        except Exception as e:
+            pass
+            
+    return p_eng, p_v1, p_v2
+
+def save_prompts(p_eng, p_v1, p_v2):
+    """保存提示词到 JSON"""
+    data = {
+        "engineer": p_eng,
+        "director1": p_v1,
+        "director2": p_v2,
+        "last_updated": datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S")
+    }
+    try:
+        with open(CONFIG_FILE, 'w', encoding='utf-8') as f:
+            json.dump(data, f, ensure_ascii=False, indent=4)
+        return f"✅ 配置已保存 ({data['last_updated']})"
+    except Exception as e:
+        return f"❌ 保存失败: {e}"
+
+def refresh_config_on_load():
+    """刷新回调，确保返回正确的值"""
+    return load_prompts()
+
+# ===============================================
+# --- 核心逻辑 (API 调用) ---
+# ===============================================
+
+def get_timestamp():
+    return datetime.datetime.now().strftime("%H:%M:%S")
+
+def log_msg(logs, msg, level="INFO"):
+    icon = {"INFO": "ℹ️", "PROCESS": "⚙️", "SUCCESS": "✅", "WARN": "⚠️", "STATE": "🧬", "WAIT": "⏳", "NET": "📡", "RETRY": "🔄", "ERROR": "❌", "PAUSE": "⏸️", "AUDIT": "👁️"}.get(level, "")
+    entry = f"[{get_timestamp()}] {icon} {msg}"
+    logs.append(entry)
+    return "\n".join(logs)
+
+# 1. 工程师
+def execute_engineer(topic, api_key, system_prompt):
+    if not api_key: yield "❌ 未提供 API Key"; return
+    yield "⏳ [工程师] 正在构建现代工厂工艺流程 (全链路+裂变模式)..."
+    
+    url = f"{MERCHANT_BASE_URL}/v1/chat/completions"
+    headers = {"Authorization": f"Bearer {api_key.strip()}", "Content-Type": "application/json"}
+    data = {"model": TEXT_MODEL, "messages": [{"role": "system", "content": system_prompt}, {"role": "user", "content": f"产品: {topic}"}]}
+    
+    for attempt in range(5):
+        try:
+            yield f"📡 [工程师] 正向 LLM 发送请求 (尝试 {attempt+1}/5)..."
+            res = requests.post(url, headers=headers, json=data, timeout=120)
+            if res.status_code != 200: raise Exception(res.text)
+            yield res.json()['choices'][0]['message']['content']
+            return
+        except Exception as e:
+            if attempt == 4: yield f"❌ 错误 (最终失败): {e}"
+            else: yield f"⚠️ 请求失败: {e}，正在重试..."
+            time.sleep(2)
+
+# 2. 导演 1.0 (分批接力 + 全量历史)
+def execute_director_v1(topic, architecture, count, api_key, system_prompt):
+    if not architecture: yield "❌ 请先生成工艺架构"; return
+    
+    V1_BATCH_SIZE = 10
+    
+    # 🔥 核心修正：使用列表来存储所有结果，防止覆盖
+    v1_all_results = []
+    
+    packaging_start_shot = int(count * 0.8) + 1
+    yield f"⏳ [导演 1.0] 正在构思 {count} 个镜头的解压沉浸剧本..."
+    yield f"📌 [时间线控制] Shot 1=源头, Shot {packaging_start_shot}=包装开始 (97% 处)"
+
+    for batch_start in range(1, count + 1, V1_BATCH_SIZE):
+        batch_end = min(batch_start + V1_BATCH_SIZE - 1, count)
+        current_batch_count = batch_end - batch_start + 1
+        
+        yield f"📡 [导演 1.0] 正在生成第 {batch_start} - {batch_end} 个镜头 (Batch Processing)..."
+        
+        # 构建当前全量剧本用于上下文 (只取列表中的 string)
+        current_full_script = "\n".join(v1_all_results)
+        
+        context_instruction = ""
+        if current_full_script:
+            context_instruction = f"""
+            **⚠️ 前序镜头全量历史 (Context History - DO NOT REPEAT)**:
+            {current_full_script}
+            """
+        
+        user_content = f"""
+        产品: {topic}
+        工程协议:
+        {architecture}
+        
+        {context_instruction}
+        
+        任务: 生成第 {batch_start} 到 {batch_end} 个镜头 (共 {current_batch_count} 个)。
+        
+        **⚠️ 时间线与包装死令**:
+        1. **起始点**：如果包含 Shot 1，**必须是【原料采集/源头】**。
+        2. **包装禁令**：**在第 {packaging_start_shot} 个镜头之前，绝对禁止进入包装环节！**
+        
+        **⚠️ 强制格式锚点 (Format Anchor)**:
+        必须严格执行提示词中的输出格式，每个镜头前必须加上 `[[SHOT_ID: 序号]]`。
+        
+        **警告：必须真实生成 {current_batch_count} 个独立的提示词块！**
+        输出: 结构化镜头列表，全部使用中文。
+        """
+        
+        url = f"{MERCHANT_BASE_URL}/v1/chat/completions"
+        headers = {"Authorization": f"Bearer {api_key.strip()}", "Content-Type": "application/json"}
+        data = {"model": TEXT_MODEL, "messages": [{"role": "system", "content": system_prompt}, {"role": "user", "content": user_content}]}
+        
+        success = False
+        for attempt in range(5):
+            try:
+                res = requests.post(url, headers=headers, json=data, timeout=300)
+                if res.status_code != 200: raise Exception(f"API Error: {res.text}")
+                
+                new_content = res.json()['choices'][0]['message']['content']
+                
+                # 🔥 增加空内容防御
+                if not new_content or len(new_content) < 50:
+                    raise Exception("返回内容为空或过短，可能被安全拦截")
+                
+                # 🔥 存入列表
+                v1_all_results.append(new_content)
+                
+                # 🔥 强制拼合并返回
+                yield "\n\n".join(v1_all_results)
+                success = True
+                break
+            except Exception as e:
+                yield f"⚠️ Batch 失败 (尝试 {attempt+1}/5): {e}"
+                time.sleep(2)
+        
+        if not success:
+            yield "❌ 致命错误：多次重试失败，流程终止。"
+            return
+
+# 3. 导演 2.0 API (带 prev_context_shots)
+def call_director_v2_batch_api(batch_plans, start_idx, total, prev_state, prev_context_shots, api_key, system_prompt):
+    
+    joined_plans = "\n\n".join(batch_plans)
+    packaging_start_shot = int(total * 0.8) + 1
+    
+    # 🔥 核心修改：回溯指令 (首批次豁免 + N-1 自动逻辑)
+    context_instruction = ""
+    if prev_context_shots and start_idx > 1:
+        # 如果是 Shot 7，list slice [-10:] 会返回 Shot 1-6，符合 "N-1" 要求
+        context_instruction = f"""
+        **👁️ 扩展视觉记忆 (Extended Visual Memory - Previous Shots)**:
+        以下是该镜头之前 **最多10个镜头** 的记录 (用于确保物理状态连续)。
+        ---
+        {prev_context_shots}
+        ---
+        **强制约束**: Shot {start_idx} 必须继承[产品]的真实物理状态，并延续视觉风格。
+        """
+    else:
+        # 🔥 Shot 1 不回溯
+        context_instruction = "**【初始批次】：这是视频的开头（Shot 1），无需回溯历史。请建立基准物理状态（通常为原料采集）。**"
+    
+    user_content = f"""
+    **批量任务**: 正在处理第 {start_idx} 到第 {start_idx + len(batch_plans) - 1} 个镜头 (共 {len(batch_plans)} 个)。
+    
+    **⚠️ 包装时间线检查**:
+    - 包装允许开始点: Shot {packaging_start_shot}
+    
+    🧬 **初始状态**: "{prev_state}"
+    
+    {context_instruction}
+    
+    📜 **导演 1 原始计划组**: 
+    {joined_plans}
+    
+    **你的任务**: 
+    请**依次**处理这 {len(batch_plans)} 个镜头。
+    **输出格式要求**:
+    必须输出 {len(batch_plans)} 个完整的 7D 格式块，每个都要带 `[[SHOT_ID]]` 锚点。
+    在所有镜头输出完毕后，**必须**输出一行最终状态：
+    `[BATCH_END_STATE]: <这里写最后一个镜头完成后的物理状态>`
+    """
+    
+    url = f"{MERCHANT_BASE_URL}/v1/chat/completions"
+    headers = {"Authorization": f"Bearer {api_key.strip()}", "Content-Type": "application/json"}
+    data = {"model": TEXT_MODEL, "messages": [{"role": "system", "content": system_prompt}, {"role": "user", "content": user_content}], "temperature": 0.3}
+    
+    try:
+        res = requests.post(url, headers=headers, json=data, timeout=300)
+        content = res.json()['choices'][0]['message']['content']
+        
+        final_state = prev_state
+        if "[BATCH_END_STATE]" in content:
+            parts = content.split("[BATCH_END_STATE]")
+            content_body = parts[0].strip()
+            state_raw = parts[1].strip()
+            if state_raw.startswith(":") or state_raw.startswith("："): 
+                final_state = state_raw[1:].strip()
+        else:
+            content_body = content 
+            
+        return content_body, final_state
+        
+    except Exception as e: return None, str(e)
+
+# 3. 导演 2.0 循环 (结果缓存 + 10段回溯)
+def execute_director_v2_loop(v1_text, count, api_key, system_prompt):
+    if not v1_text: yield "❌ 请先生成导演 1.0 的视觉方案", ""; return
+    global IS_PAUSED
+    IS_PAUSED = False
+    logs = []
+    
+    # 🔥 核心修正：UI 持久化容器
+    # 只要生成了，就塞进这里，永远不丢
+    all_generated_batches = []
+    
+    full_results_history = [] 
+    
+    raw_text = v1_text.strip()
+    
+    # 🔥 核心修复：双重锚点解析 (兼容性 MAX)
+    header_pattern = re.compile(r'(?:\[\[\s*SHOT_ID\s*[:：]\s*(\d+)\s*\]\]|###\s*镜头\s*(\d+))', re.IGNORECASE)
+    matches = list(header_pattern.finditer(raw_text))
+    
+    if not matches:
+        yield log_msg(logs, f"❌ 严重错误：未找到锚点。请确认导演 1.0 输出包含 [[SHOT_ID]] 或 ### 镜头。", "ERROR"), ""
+        return
+
+    visual_plans = []
+    seen_ids = set() # 去重，防止同一镜头被重复解析
+    
+    for i in range(len(matches)):
+        start = matches[i].start()
+        end = matches[i+1].start() if i+1 < len(matches) else len(raw_text)
+        block = raw_text[start:end].strip()
+        
+        try:
+            val1 = matches[i].group(1)
+            val2 = matches[i].group(2)
+            shot_id = int(val1) if val1 else int(val2)
+        except:
+            shot_id = i + 1 
+            
+        if shot_id not in seen_ids and len(block) > 5:
+             visual_plans.append({"id": shot_id, "content": block})
+             seen_ids.add(shot_id)
+
+    # 排序以防万一
+    visual_plans.sort(key=lambda x: x['id'])
+
+    yield log_msg(logs, f"🚀 导演 2.0 启动：状态进化引擎 (7D 旗舰版 | Batch={BATCH_SIZE})", "SUCCESS"), ""
+    yield log_msg(logs, f"📊 成功解析 {len(visual_plans)} 个镜头 (首镜ID: {visual_plans[0]['id']})", "INFO"), ""
+    
+    prev_state = "原材料，脏的，完整的，未处理的 (自然状态)"
+    yield log_msg(logs, f"🧬 [初始状态] {prev_state}", "STATE"), ""
+
+    total_shots = len(visual_plans)
+    
+    for i in range(0, total_shots, BATCH_SIZE):
+        batch_items = visual_plans[i : i + BATCH_SIZE]
+        batch_texts = [item['content'] for item in batch_items]
+        
+        start_real_id = batch_items[0]['id']
+        end_real_id = batch_items[-1]['id']
+        
+        # 强制显式返回一次全量数据
+        full_text_snapshot = "\n\n".join(all_generated_batches)
+        if IS_PAUSED:
+            yield log_msg(logs, f"⏸️ 已暂停...", "PAUSE"), full_text_snapshot
+            while IS_PAUSED: time.sleep(1)
+            yield log_msg(logs, f"▶️ 恢复", "PROCESS"), full_text_snapshot
+
+        # 回溯逻辑
+        prev_context_shots = ""
+        if full_results_history:
+            last_10 = full_results_history[-10:]
+            prev_context_shots = "\n\n".join(last_10)
+            yield log_msg(logs, f"👁️ [视觉审阅] 回溯 Shot {max(1, start_real_id-10)} - {start_real_id-1}...", "AUDIT"), full_text_snapshot
+        else:
+            yield log_msg(logs, f"👁️ [视觉审阅] 初始批次 (Shot 1)，无前序记忆", "INFO"), full_text_snapshot
+            
+        yield log_msg(logs, f"⚙️ [批量处理] 镜头 {start_real_id} - {end_real_id} ({len(batch_items)}个)...", "PROCESS"), full_text_snapshot
+        yield log_msg(logs, f"🧬 [思维链继承] 起始状态: {prev_state}", "STATE"), full_text_snapshot
+        
+        success = False
+        for attempt in range(5):
+            if IS_PAUSED: 
+                yield log_msg(logs, "⏸️ 暂停中...", "PAUSE"), full_text_snapshot
+                while IS_PAUSED: time.sleep(1)
+            try:
+                if attempt > 0: yield log_msg(logs, f"   🔄 重试 ({attempt}/5)...", "RETRY"), full_text_snapshot
+                
+                # 🔥 传入真实的 start_real_id
+                batch_result, next_state = call_director_v2_batch_api(
+                    batch_texts, start_real_id, count, prev_state, prev_context_shots, api_key, system_prompt
+                )
+                
+                if batch_result:
+                    success = True
+                    yield log_msg(logs, f"   📥 Batch 完成", "SUCCESS"), full_text_snapshot
+                    
+                    # 🔥 核心修正：追加到全局列表
+                    all_generated_batches.append(batch_result)
+                    full_text_snapshot = "\n\n".join(all_generated_batches) # 更新快照
+                    
+                    split_regex = r'(?:\[\[\s*SHOT_ID\s*[:：]\s*\d+\s*\]\]|###\s*镜头\s*\d+)'
+                    current_blocks = re.split(split_regex, batch_result)
+                    current_blocks = [b.strip() for b in current_blocks if len(b) > 20]
+                    full_results_history.extend(current_blocks)
+                    
+                    if prev_state != next_state:
+                        yield log_msg(logs, f"   🌊 [进化] ... -> {next_state}", "STATE"), full_text_snapshot
+                    else:
+                        yield log_msg(logs, f"   🧬 [保持] {next_state}", "STATE"), full_text_snapshot
+                    
+                    prev_state = next_state 
+                    break 
+                time.sleep(1.5 * (attempt + 1))
+            except Exception as e: 
+                yield log_msg(logs, f"   ⚠️ Batch 错误: {e}", "WARN"), full_text_snapshot
+                time.sleep(1.5 * (attempt + 1))
+        
+        if not success:
+            yield log_msg(logs, f"   ❌ Batch 失败 (跳过)", "ERROR"), full_text_snapshot
+        
+        # 🔥 每一批次完成后，必须显式返回全量文本
+        yield "\n".join(logs[-20:]), full_text_snapshot
+        time.sleep(0.2) 
+
+    yield log_msg(logs, "🎉 全片逻辑闭环完成", "SUCCESS"), "\n\n".join(all_generated_batches)
+
+# ===============================================
+# --- 渲染逻辑升级 (7要素拼接 + 格式化展示) ---
+# ===============================================
+
+def inject_satisfaction_physics(satisfaction_text):
+    booster = ""
+    if not satisfaction_text: return booster
+    if any(k in satisfaction_text for k in ["填满", "堆叠", "丰盛", "空虚", "数量"]):
+        booster += "，极高密度填充，画面无任何空隙，形成视觉实体墙，"
+    if any(k in satisfaction_text for k in ["秩序", "同步", "整齐", "治愈", "强迫症"]):
+        booster += "，完美几何对齐，毫秒级机械同步运动，无任何误差，"
+    if any(k in satisfaction_text for k in ["剥离", "去除", "刮", "磨", "分离", "炸开"]):
+        booster += "，表面污垢被物理暴力剥离，瞬间露出完美内部，"
+    if any(k in satisfaction_text for k in ["净化", "洁净", "丝滑", "顺滑", "粘稠"]):
+        booster += "，极度洁净的表面，丝滑的高光反射，无暇质感，"
+    return booster
+
+def assemble_veo_prompt(raw_block):
+    """提取+拼接+转译 (适配新的 7D 格式)"""
+    def extract(key_pattern, text):
+        match = re.search(key_pattern, text)
+        return match.group(1).strip().rstrip("。") if match else ""
+
+    f_subject = extract(r"01\. 主体与密度：(.*?)\n", raw_block)
+    f_texture = extract(r"02\. 材质与光影：(.*?)\n", raw_block)
+    f_action = extract(r"03\. 动作演变：(.*?)\n", raw_block)
+    f_physics = extract(r"04\. 物理反馈：(.*?)\n", raw_block)
+    f_env = extract(r"05\. 环境构建：(.*?)\n", raw_block)
+    f_camera = extract(r"06\. 镜头语言：(.*?)\n", raw_block)
+
+    physics_booster = inject_satisfaction_physics(f_physics)
+
+    parts = [
+        "BBC纪录片风格，无字幕，无说话声，8k分辨率，超写实电影质感",
+        f"{f_camera}",
+        f"{f_subject}",
+        f"{f_texture}",
+        f"{f_action}{physics_booster}",
+        f"{f_physics}",
+        f"位于{f_env}"
+    ]
+    
+    final_prompt = "，".join([p for p in parts if p and p.strip() != "，"])
+    final_prompt = re.sub(r"，+", "，", final_prompt)
+    final_prompt = f"{final_prompt} --ar 16x9"
+    return final_prompt
+
+def render_videos(script, topic, video_key, progress=gr.Progress()):
+    if not script: yield "无脚本", None, ""; return
+    session_dir = os.path.join("AutoSaved_Videos", f"{topic}_{int(time.time())}")
+    os.makedirs(session_dir, exist_ok=True)
+    
+    # 🔥 核心修复：兼容双重锚点
+    raw_blocks = []
+    matches = list(re.finditer(r'(?:\[\[\s*SHOT_ID\s*[:：]\s*(\d+)\s*\]\]|###\s*镜头\s*(\d+))', script, re.IGNORECASE))
+    
+    if not matches:
+        logs = ["❌ 无法解析脚本：未找到任何 '[[SHOT_ID]]' 标记"]
+        yield "\n".join(logs), None, ""; return
+
+    for i in range(len(matches)):
+        start = matches[i].start()
+        if i < len(matches) - 1:
+            end = matches[i+1].start()
+        else:
+            end = len(script)
+        
+        block = script[start:end].strip()
+        if "Veo 提示词" in block or "01. 主体" in block:
+            raw_blocks.append(block)
+
+    logs = [f"🚀 全量并发渲染启动: 检测到 {len(raw_blocks)} 个独立镜头任务...", "✨ 已启用 [7大要素拼接] + [心理物理转译]"]
+    yield "\n".join(logs), None, ""
+    
+    if len(raw_blocks) == 0:
+        logs.append("❌ 未找到可渲染提示词块 (请确保脚本包含 7D 格式)"); yield "\n".join(logs), None, ""; return
+
+    formatted_prompts_display = ""
+    parsed_tasks = []
+    
+    for i, block in enumerate(raw_blocks):
+        title_match = re.search(r'(?:镜头|Shot)\s*(\d+)(?:/\d+)?\s*[\|｜]\s*(.*)', block)
+        title = title_match.group(2).strip() if title_match else f"Untitled"
+        safe_title = re.sub(r'[\\/*?:"<>|]', "", title).replace(" ", "_")
+        
+        final_p = assemble_veo_prompt(block)
+        if len(final_p) < 50: 
+            pattern = r"(?:Veo 提示词|Veo Prompt).*?[:：]\s*(.*?)(?=\[状态连接\]|\[NEXT_LINK\]|镜头|Shot|$)"
+            match = re.search(pattern, block, re.DOTALL | re.IGNORECASE)
+            if match:
+                final_p = f"BBC纪录片风格，无字幕，无说话声，8k分辨率，超写实，{match.group(1).strip().replace(chr(10), ' ')} --ar 16x9"
+        
+        shot_num = f"{i+1:03d}"
+        formatted_entry = f"=== Shot {shot_num}/{len(raw_blocks)}: {title} ===\nveo Prompt (English): {final_p}\n\n"
+        formatted_prompts_display += formatted_entry
+        
+        fname = f"Shot_{shot_num}_{safe_title}"
+        parsed_tasks.append((final_p, fname))
+
+    yield "\n".join(logs), None, formatted_prompts_display
+
+    files = []
+    with ThreadPoolExecutor(max_workers=len(parsed_tasks)) as executor:
+        futures = {}
+        for final_p, fname in parsed_tasks:
+            futures[executor.submit(simple_veo_call, final_p, fname, session_dir, video_key)] = fname
+        
+        done = 0
+        for f in as_completed(futures):
+            res = f.result()
+            done += 1
+            progress(done/len(parsed_tasks))
+            if res['ok']: 
+                logs.append(f"✅ {res['name']} 完成")
+                files.append(res['path'])
+            else: 
+                error_msg = res.get('error', '未知错误')
+                logs.append(f"❌ {res['name']} 失败: {error_msg}")
+            yield "\n".join(logs[-15:]), None, formatted_prompts_display
+            
+    if files:
+        shutil.make_archive(session_dir, 'zip', session_dir)
+        yield "\n".join(logs), f"{session_dir}.zip", formatted_prompts_display
+
+def simple_veo_call(prompt, name, folder, key):
+    last_error = ""
+    for attempt in range(5):
+        try:
+            url = f"{MERCHANT_BASE_URL}/v1/chat/completions"
+            headers = {"Authorization": f"Bearer {key}", "Content-Type": "application/json"}
+            data = {"model": VEO_MODEL, "messages": [{"role": "user", "content": prompt}], "size": VIDEO_SIZE}
+            r = requests.post(url, headers=headers, json=data, timeout=300)
+            
+            if r.status_code != 200:
+                raise Exception(f"API Error {r.status_code}: {r.text[:100]}") 
+
+            content = r.json()['choices'][0]['message']['content']
+            v_url = re.search(r'(https?://[^\s)"]+)', content).group(1)
+            
+            path = os.path.join(folder, name + ".mp4")
+            with open(path, "wb") as f: f.write(requests.get(v_url).content)
+            
+            return {"ok": True, "name": name, "path": path}
+        except Exception as e:
+            last_error = str(e)
+            time.sleep(2 * (attempt + 1))
+            continue 
+            
+    return {"ok": False, "name": name, "error": last_error}
+
+# ===============================================
+# --- UI 界面构造 ---
+# ===============================================
+with gr.Blocks(title="Veo 终极全能引擎 (全链路覆盖版)") as app:
+    
+    init_eng, init_v1, init_v2 = load_prompts()
+
+    gr.Markdown("## 🏭 Veo 终极全能引擎 (全链路覆盖版：微观拆解 + 多机位重复 + 7D)")
+    gr.Markdown("**提示**：此版本已强制工程师覆盖从【源头收获】到【包装物流】的全流程，并保留了所有历史铁律。")
+
+    # 0. 全局配置 & 保存按钮
+    with gr.Row(variant="panel"):
+        with gr.Column(scale=2):
+            with gr.Row():
+                llm_key = gr.Textbox(label="🔑 LLM Key", value=DEFAULT_LLM_API_KEY, type="password")
+                video_key = gr.Textbox(label="🎬 Video Key", value=DEFAULT_VIDEO_API_KEY, type="password")
+        with gr.Column(scale=1):
+            btn_save_config = gr.Button("💾 保存所有配置", variant="primary")
+            save_status = gr.Textbox(label="状态", lines=1, interactive=False)
+            topic_input = gr.Textbox(label="📦 产品名称", placeholder="例如：菠萝")
+
+    # 1. 工程师
+    with gr.Row():
+        with gr.Column():
+            gr.Markdown("### 🛠️ 步骤 1: 工程师 (全链路拆解)")
+            # 🔥 修改点：open=True，强制展开
+            with gr.Accordion("提示词设定 (可修改)", open=True):
+                prompt_eng_input = gr.Textbox(value=init_eng, lines=10, label="工程师提示词", interactive=True)
+            btn_eng = gr.Button("1. 生成海量素材日志", variant="secondary")
+        with gr.Column():
+            arch_output = gr.Textbox(label="工艺架构输出", lines=10)
+
+    gr.HTML("<hr>")
+
+    # 2. 导演 1.0
+    with gr.Row():
+        with gr.Column():
+            gr.Markdown("### 🎨 步骤 2: 导演 1.0 (最终剪辑与铺排)")
+            # 🔥 默认值改为 200，最大值改为 300
+            count_slider = gr.Slider(1, 300, 200, step=1, label="镜头数量")
+            # 🔥 修改点：open=True，强制展开
+            with gr.Accordion("提示词设定 (可修改)", open=True):
+                prompt_v1_input = gr.Textbox(value=init_v1, lines=15, label="导演1.0提示词", interactive=True)
+            btn_v1 = gr.Button("2. 生成完整剧本", variant="primary")
+        with gr.Column():
+            v1_output = gr.Textbox(label="V1 剧本输出", lines=15)
+
+    gr.HTML("<hr>")
+
+    # 3. 导演 2.0
+    with gr.Row():
+        with gr.Column():
+            gr.Markdown("### 🧬 步骤 3: 导演 2.0 (状态进化)")
+            # 🔥 修改点：open=True，强制展开
+            with gr.Accordion("提示词设定 (可修改)", open=True):
+                prompt_v2_input = gr.Textbox(value=init_v2, lines=10, label="导演2.0提示词", interactive=True)
+            with gr.Row():
+                btn_v2 = gr.Button("3. 启动逻辑变异 (Batch=10)", variant="primary")
+                btn_pause = gr.Button("⏸️ 暂停/继续", variant="secondary")
+            log_output = gr.Textbox(label="演算日志", lines=15, elem_id="log_box", autoscroll=True)
+        with gr.Column():
+            v2_output = gr.Textbox(label="最终脚本输出", lines=20, autoscroll=True)
+
+    gr.HTML("<hr>")
+
+    # 4. 渲染
+    with gr.Row(variant="panel"):
+        with gr.Column(scale=1):
+            gr.Markdown("### 🚀 步骤 4: 渲染")
+            btn_render = gr.Button("4. 全量并发渲染", variant="stop")
+            zip_output = gr.File(label="下载 ZIP")
+        with gr.Column(scale=2):
+            final_prompts_output = gr.Textbox(label="拼接后的提示词 (Assembled Prompts)", lines=20, interactive=False)
+
+    # 绑定加载事件
+    app.load(refresh_config_on_load, inputs=None, outputs=[prompt_eng_input, prompt_v1_input, prompt_v2_input])
+    # 绑定按钮事件
+    btn_save_config.click(save_prompts, [prompt_eng_input, prompt_v1_input, prompt_v2_input], [save_status])
+    btn_eng.click(execute_engineer, [topic_input, llm_key, prompt_eng_input], [arch_output])
+    btn_v1.click(execute_director_v1, [topic_input, arch_output, count_slider, llm_key, prompt_v1_input], [v1_output])
+    btn_pause.click(toggle_pause, [], [btn_pause])
+    btn_v2.click(execute_director_v2_loop, [v1_output, count_slider, llm_key, prompt_v2_input], [log_output, v2_output])
+    btn_render.click(render_videos, [v2_output, topic_input, video_key], [log_output, zip_output, final_prompts_output])
+
+app.launch()