Update app.py

app.py

@@ -42,42 +42,17 @@ def get_user_dirs(session_id):
 # --- 🎨 Custom Purple Theme Definition ---
 # ==========================================
 colors.purple = colors.Color(
-    name="purple",
-    c50="#FAF5FF",
-    c100="#F3E8FF",
-    c200="#E9D5FF",
-    c300="#DAB2FF",
-    c400="#C084FC",
-    c500="#A855F7",
-    c600="#9333EA",
-    c700="#7E22CE",
-    c800="#6B21A8",
-    c900="#581C87",
-    c950="#3B0764",
+    name="purple", c50="#FAF5FF", c100="#F3E8FF", c200="#E9D5FF",
+    c300="#DAB2FF", c400="#C084FC", c500="#A855F7", c600="#9333EA",
+    c700="#7E22CE", c800="#6B21A8", c900="#581C87", c950="#3B0764",
 )
 
 class PurpleTheme(Soft):
-    def __init__(
-        self,
-        *,
-        primary_hue: colors.Color | str = colors.gray,
-        secondary_hue: colors.Color | str = colors.purple,
-        neutral_hue: colors.Color | str = colors.slate,
-        text_size: sizes.Size | str = sizes.text_lg,
-        font: fonts.Font | str | Iterable[fonts.Font | str] = (
-            fonts.GoogleFont("Outfit"), "Arial", "sans-serif",
-        ),
-        font_mono: fonts.Font | str | Iterable[fonts.Font | str] = (
-            fonts.GoogleFont("IBM Plex Mono"), "ui-monospace", "monospace",
-        ),
-    ):
+    def __init__(self, **kwargs):
         super().__init__(
-            primary_hue=primary_hue,
-            secondary_hue=secondary_hue,
-            neutral_hue=neutral_hue,
-            text_size=text_size,
-            font=font,
-            font_mono=font_mono,
+            primary_hue=colors.gray, secondary_hue=colors.purple, neutral_hue=colors.slate,
+            font=(fonts.GoogleFont("Outfit"), "Arial", "sans-serif"),
+            font_mono=(fonts.GoogleFont("IBM Plex Mono"), "ui-monospace", "monospace"),
         )
         super().set(
             background_fill_primary="*primary_50",
@@ -85,30 +60,39 @@ class PurpleTheme(Soft):
             body_background_fill="linear-gradient(135deg, *primary_200, *primary_100)",
             body_background_fill_dark="linear-gradient(135deg, *primary_900, *primary_800)",
             button_primary_text_color="white",
-            button_primary_text_color_hover="white",
             button_primary_background_fill="linear-gradient(90deg, *secondary_500, *secondary_600)",
             button_primary_background_fill_hover="linear-gradient(90deg, *secondary_600, *secondary_700)",
-            button_primary_background_fill_dark="linear-gradient(90deg, *secondary_600, *secondary_700)",
-            button_primary_background_fill_hover_dark="linear-gradient(90deg, *secondary_500, *secondary_600)",
             button_secondary_text_color="black",
-            button_secondary_text_color_hover="white",
             button_secondary_background_fill="linear-gradient(90deg, *primary_300, *primary_300)",
-            button_secondary_background_fill_hover="linear-gradient(90deg, *primary_400, *primary_400)",
-            button_secondary_background_fill_dark="linear-gradient(90deg, *primary_500, *primary_600)",
-            button_secondary_background_fill_hover_dark="linear-gradient(90deg, *primary_500, *primary_500)",
             slider_color="*secondary_500",
-            slider_color_dark="*secondary_600",
-            block_title_text_weight="600",
             block_border_width="3px",
             block_shadow="*shadow_drop_lg",
             button_primary_shadow="*shadow_drop_lg",
-            button_large_padding="11px",
-            color_accent_soft="*primary_100",
-            block_label_background_fill="*primary_200",
         )
 
 purple_theme = PurpleTheme()
 
+# ==========================================
+# --- 🚀 HTML Progress Bar Components ---
+# ==========================================
+def empty_progress_html(text="Waiting for action..."):
+    return f"""
+    <div class="custom-progress-container" style="background-color: transparent; border: 2px dashed rgba(168, 85, 247, 0.4);">
+        <div class="custom-progress-text" style="color: #A855F7;">{text}</div>
+    </div>
+    """
+
+def create_progress_html(percent, text, status="active"):
+    """
+    status: "active" (紫色滚动条纹), "success" (绿色), "error" (红色)
+    """
+    return f"""
+    <div class="custom-progress-container">
+        <div class="custom-progress-bar {status}" style="width: {percent}%;"></div>
+        <div class="custom-progress-text">{text} ({percent}%)</div>
+    </div>
+    """
+
 # ==========================================
 # --- ⚙️ Backend Logic & Functions ---
 # ==========================================
@@ -159,51 +143,44 @@ def get_debug_info(session_id):
     return html
 
 def save_api_settings(api_key, api_base_url, session_id):
-    """不再写入全局 yaml，而是保存在 Gradio State 并在运行时通过环境变量注入"""
     if not api_key: 
         return "❌ Key cannot be empty", get_debug_info(session_id), False, "", ""
-    
     success_msg = "✅ Key saved securely in session memory"
     if api_base_url: success_msg += ", Base URL updated"
-        
     return success_msg, get_debug_info(session_id), True, api_key, api_base_url
 
 def save_pdf(file, session_id):
-    if file is None: return "❌ Please select a PDF first", get_debug_info(session_id), False
+    if file is None: 
+        return empty_progress_html("❌ Please select a PDF first"), get_debug_info(session_id), False
     try:
         papers_dir, _, _ = get_user_dirs(session_id)
-        
-        # 清理旧文件
         for f in os.listdir(papers_dir):
             file_to_del = os.path.join(papers_dir, f)
             if os.path.isfile(file_to_del): os.remove(file_to_del)
                 
         file_path = os.path.join(papers_dir, os.path.basename(file.name))
         shutil.copy(file.name, file_path)
-        return f"✅ Saved: {os.path.basename(file.name)}", get_debug_info(session_id), True
+        return create_progress_html(100, f"✅ PDF Uploaded: {os.path.basename(file.name)}", "success"), get_debug_info(session_id), True
     except Exception as e:
-        return f"❌ Error: {str(e)}", get_debug_info(session_id), False
+        return create_progress_html(0, f"❌ Error: {str(e)}", "error"), get_debug_info(session_id), False
 
 def clear_pdf(session_id):
     try:
         user_base = os.path.join(SESSIONS_BASE_DIR, session_id)
         if os.path.exists(user_base):
-            shutil.rmtree(user_base) # 直接删除该用户的整个工作区
+            shutil.rmtree(user_base) 
             
         disable_btn = gr.update(interactive=False)
-        return f"🗑️ Workspace cleared", get_debug_info(session_id), False, disable_btn, disable_btn, disable_btn, disable_btn
+        return empty_progress_html("🗑️ Workspace cleared"), empty_progress_html("No generation task currently..."), get_debug_info(session_id), False, disable_btn, disable_btn, disable_btn, disable_btn
     except Exception as e:
-        return f"❌ Error deleting: {str(e)}", get_debug_info(session_id), False, gr.update(), gr.update(), gr.update(), gr.update()
+        return create_progress_html(0, f"❌ Clear Error: {str(e)}", "error"), gr.update(), get_debug_info(session_id), False, gr.update(), gr.update(), gr.update(), gr.update()
 
 def build_user_env(api_key, api_base_url, papers_dir, output_dir):
-    """构建用户专属的子进程环境变量"""
     env = os.environ.copy()
     env["MINERU_FORMULA_ENABLE"] = "false"
     env["MINERU_TABLE_ENABLE"] = "false"
     env["MINERU_DEVICE_MODE"] = "cpu"
     env["MINERU_VIRTUAL_VRAM_SIZE"] = "8"
-    
-    # 注入专属 API 配置和路径
     if api_key: env["GEMINI_API_KEY"] = api_key
     if api_base_url: env["GEMINI_API_BASE_URL"] = api_base_url
     env["USER_PAPERS_DIR"] = papers_dir
@@ -216,69 +193,73 @@ def run_mineru_parsing_and_dag_gen(session_id, api_key, api_base_url, progress=g
     papers_dir, output_dir, _ = get_user_dirs(session_id)
     
     if not os.path.exists(papers_dir) or not any(f.endswith('.pdf') for f in os.listdir(papers_dir)):
-        yield "❌ No PDF file found", get_debug_info(session_id), "No execution logs.", no_change, no_change, no_change, no_change
+        yield create_progress_html(0, "❌ No PDF file found", "error"), get_debug_info(session_id), "No execution logs.", no_change, no_change, no_change, no_change
         return
 
     full_log = ""
     try:
         env = build_user_env(api_key, api_base_url, papers_dir, output_dir)
-
         command_mineru = ["mineru", "-p", papers_dir, "-o", output_dir]
         full_log += f"--- Mineru Executing (Session: {session_id[:8]}) ---\n"
         
+        # 10%
         progress(0.1, desc="启动 Mineru 解析...")
-        yield "⏳ Executing Mineru parsing...", get_debug_info(session_id), full_log, no_change, no_change, no_change, no_change
+        yield create_progress_html(10, "⏳ Starting Mineru parsing...", "active"), get_debug_info(session_id), full_log, no_change, no_change, no_change, no_change
 
         process_mineru = subprocess.Popen(
             command_mineru, env=env, stdout=subprocess.PIPE, stderr=subprocess.STDOUT, text=True, bufsize=1
         )
         
+        # 30%
         progress(0.3, desc="Mineru 正在解析 PDF...")
         for line in iter(process_mineru.stdout.readline, ''):
             full_log += line
-            yield "⏳ Executing Mineru parsing...", get_debug_info(session_id), full_log, no_change, no_change, no_change, no_change
+            yield create_progress_html(30, "⏳ Mineru parsing PDF...", "active"), get_debug_info(session_id), full_log, no_change, no_change, no_change, no_change
         process_mineru.stdout.close()
         returncode_mineru = process_mineru.wait()
 
         if returncode_mineru != 0:
             progress(1.0, desc="Mineru 解析失败")
-            yield f"❌ Mineru parsing failed (Exit Code: {returncode_mineru})", get_debug_info(session_id), full_log, disable_btn, disable_btn, disable_btn, disable_btn
+            yield create_progress_html(30, f"❌ Mineru failed (Code {returncode_mineru})", "error"), get_debug_info(session_id), full_log, disable_btn, disable_btn, disable_btn, disable_btn
             return
 
         command_dag = [sys.executable, "gen_dag.py"]
         full_log += "\n--- DAG Gen Executing ---\n"
+        
+        # 60%
         progress(0.6, desc="执行 DAG 生成...")
-        yield "⏳ Executing DAG generation...", get_debug_info(session_id), full_log, no_change, no_change, no_change, no_change
+        yield create_progress_html(60, "⏳ Executing DAG generation...", "active"), get_debug_info(session_id), full_log, no_change, no_change, no_change, no_change
         
         process_dag = subprocess.Popen(
             command_dag, env=env, stdout=subprocess.PIPE, stderr=subprocess.STDOUT, text=True, bufsize=1
         )
         
+        # 80%
         progress(0.8, desc="构建图结构中...")
         for line in iter(process_dag.stdout.readline, ''):
             full_log += line
-            yield "⏳ Executing DAG generation...", get_debug_info(session_id), full_log, no_change, no_change, no_change, no_change
+            yield create_progress_html(80, "⏳ Building Graph...", "active"), get_debug_info(session_id), full_log, no_change, no_change, no_change, no_change
         process_dag.stdout.close()
         returncode_dag = process_dag.wait()
         
         if returncode_dag == 0:
             progress(1.0, desc="解析与构建完成！")
             enable_btn = gr.update(interactive=True)
-            yield "✅ PDF parsing & DAG generation fully completed", get_debug_info(session_id), full_log, enable_btn, enable_btn, enable_btn, enable_btn
+            yield create_progress_html(100, "✅ Fully completed", "success"), get_debug_info(session_id), full_log, enable_btn, enable_btn, enable_btn, enable_btn
         else:
             progress(1.0, desc="DAG 生成失败")
-            yield f"❌ DAG generation failed", get_debug_info(session_id), full_log, disable_btn, disable_btn, disable_btn, disable_btn
+            yield create_progress_html(80, "❌ DAG generation failed", "error"), get_debug_info(session_id), full_log, disable_btn, disable_btn, disable_btn, disable_btn
 
     except Exception as e:
         progress(1.0, desc="发生异常")
         error_log = full_log + f"\n[Global Exception]:\n{str(e)}"
-        yield "❌ Execution Exception", get_debug_info(session_id), error_log, disable_btn, disable_btn, disable_btn, disable_btn
+        yield create_progress_html(0, "❌ Execution Exception", "error"), get_debug_info(session_id), error_log, disable_btn, disable_btn, disable_btn, disable_btn
 
 def run_final_generation(task_type, session_id, api_key, api_base_url, progress=gr.Progress()):
     papers_dir, output_dir, zip_path = get_user_dirs(session_id)
     
     if not os.path.exists(output_dir):
-        yield "❌ Please run parsing first", get_debug_info(session_id), "No output folder found.", gr.update(visible=False)
+        yield create_progress_html(0, "❌ Please run parsing first", "error"), get_debug_info(session_id), "No output folder found.", gr.update(visible=False)
         return
 
     scripts_to_run = []
@@ -289,7 +270,7 @@ def run_final_generation(task_type, session_id, api_key, api_base_url, progress=
     
     full_log = f"🚀 Starting {len(scripts_to_run)} tasks for session {session_id[:8]}...\n"
     progress(0.1, desc=f"启动 {task_type.upper()} 生成任务...")
-    yield f"⏳ Starting {task_type.upper()} generation...", get_debug_info(session_id), full_log, gr.update(visible=False)
+    yield create_progress_html(10, f"⏳ Starting {task_type.upper()}...", "active"), get_debug_info(session_id), full_log, gr.update(visible=False)
 
     q = queue.Queue()
     processes = []
@@ -317,7 +298,7 @@ def run_final_generation(task_type, session_id, api_key, api_base_url, progress=
             try:
                 script_name, line = q.get(timeout=0.1)
                 full_log += f"[{script_name}] {line}"
-                yield f"⏳ Generating {task_type.upper()}...", get_debug_info(session_id), full_log, gr.update(visible=False)
+                yield create_progress_html(50, f"⏳ Generating {task_type.upper()}...", "active"), get_debug_info(session_id), full_log, gr.update(visible=False)
             except queue.Empty:
                 active_processes = sum(1 for _, p in processes if p.poll() is None)
 
@@ -325,24 +306,24 @@ def run_final_generation(task_type, session_id, api_key, api_base_url, progress=
 
         if not success: 
             progress(1.0, desc="生成失败")
-            yield f"❌ Tasks failed, check logs", get_debug_info(session_id), full_log, gr.update(visible=False)
+            yield create_progress_html(50, "❌ Tasks failed", "error"), get_debug_info(session_id), full_log, gr.update(visible=False)
             return
 
         full_log += "\n📦 Zipping output directory...\n"
         progress(0.9, desc="打包压缩结果...")
-        yield f"⏳ Zipping outputs...", get_debug_info(session_id), full_log, gr.update(visible=False)
+        yield create_progress_html(90, "⏳ Zipping outputs...", "active"), get_debug_info(session_id), full_log, gr.update(visible=False)
         
         zip_base_name = zip_path.replace(".zip", "")
         shutil.make_archive(zip_base_name, 'zip', output_dir)
         
         full_log += "✅ All tasks completed successfully.\n"
         progress(1.0, desc="全部完成！")
-        yield f"✅ {task_type.upper()} successfully generated", get_debug_info(session_id), full_log, gr.update(value=zip_path, visible=True)
+        yield create_progress_html(100, f"✅ {task_type.upper()} Generated", "success"), get_debug_info(session_id), full_log, gr.update(value=zip_path, visible=True)
         
     except Exception as e:
         progress(1.0, desc="发生全局异常")
         error_log = full_log + f"\n[Global Exception]:\n{str(e)}"
-        yield "❌ Global exception", get_debug_info(session_id), error_log, gr.update(visible=False)
+        yield create_progress_html(0, "❌ Global exception", "error"), get_debug_info(session_id), error_log, gr.update(visible=False)
 
 # ==========================================
 # --- 🚀 UI Configuration & Advanced CSS ---
@@ -402,8 +383,42 @@ body, .gradio-container {
     border-color: rgba(168, 85, 247, 0.3) !important; 
 }
 
-.gradio-group > div, 
-.gradio-group > .form { border-radius: 12px !important; }
+/* ================= 进度条自定义 CSS ================= */
+@keyframes progress-bar-stripes {
+    from { background-position: 1rem 0; }
+    to { background-position: 0 0; }
+}
+.custom-progress-container {
+    width: 100%; 
+    background-color: rgba(233, 213, 255, 0.3); 
+    border-radius: 12px; 
+    overflow: hidden; 
+    position: relative; 
+    height: 40px; 
+    border: 1px solid rgba(168, 85, 247, 0.3); 
+    box-shadow: inset 0 2px 4px rgba(0,0,0,0.05);
+}
+.custom-progress-bar {
+    height: 100%; 
+    border-radius: 12px; 
+    transition: width 0.4s ease;
+}
+.custom-progress-bar.active { 
+    background-color: #A855F7;
+    background-image: linear-gradient(45deg, rgba(255, 255, 255, .15) 25%, transparent 25%, transparent 50%, rgba(255, 255, 255, .15) 50%, rgba(255, 255, 255, .15) 75%, transparent 75%, transparent);
+    background-size: 1rem 1rem;
+    animation: progress-bar-stripes 1s linear infinite; 
+    box-shadow: 0 0 10px rgba(168, 85, 247, 0.5);
+}
+.custom-progress-bar.success { background-image: none; background-color: #10B981; box-shadow: 0 0 10px rgba(16, 185, 129, 0.5);}
+.custom-progress-bar.error { background-image: none; background-color: #EF4444; box-shadow: 0 0 10px rgba(239, 68, 68, 0.5);}
+.custom-progress-text {
+    position: absolute; top: 0; left: 0; width: 100%; height: 100%; 
+    display: flex; align-items: center; justify-content: center; 
+    font-weight: 600; color: #581C87; font-size: 14px; 
+    text-shadow: 0 0 4px rgba(255,255,255,0.8);
+}
+.dark .custom-progress-text { color: #E9D5FF; text-shadow: 0 0 4px rgba(0,0,0,0.8); }
 
 #pdf-upload-box {
     border: 2px dashed rgba(192, 132, 252, 0.6) !important;
@@ -493,7 +508,6 @@ body, .gradio-container {
 }
 .action-btn:active { transform: translateY(2px) scale(0.98) !important; box-shadow: 0 2px 10px rgba(147, 51, 234, 0.2) !important; }
 
-/* ======== CSS FOR DISABLED BUTTONS ======== */
 .primary-action-btn:disabled, .action-btn:disabled {
     background: #e5e7eb !important;
     color: #9ca3af !important;
@@ -515,13 +529,11 @@ body, .gradio-container {
 ::-webkit-scrollbar-track { background: rgba(168, 85, 247, 0.05); border-radius: 4px; }
 ::-webkit-scrollbar-thumb { background: linear-gradient(135deg, #A855F7, #C084FC); border-radius: 4px; }
 ::-webkit-scrollbar-thumb:hover { background: linear-gradient(135deg, #9333EA, #A855F7); }
-
 details > summary { transition: color 0.2s ease; }
 details > summary:hover { color: #E9D5FF !important; }
 """
 
 with gr.Blocks(theme=purple_theme, css=custom_css) as demo:
-    # 核心：为每个连接的用户生成唯一的 Session ID 和存放凭证的状态
     session_id_state = gr.State("")
     user_api_key_state = gr.State("")
     user_api_base_state = gr.State("")
@@ -534,7 +546,6 @@ with gr.Blocks(theme=purple_theme, css=custom_css) as demo:
         gr.Markdown("One-click parsing of academic PDFs, DAG structuring, and multi-modal asset generation.", elem_id="subtitle")
         
         with gr.Row():
-            # ================= LEFT COLUMN: SETTINGS & ACTIONS =================
             with gr.Column(scale=1):
                 # 1. API Configuration
                 with gr.Group(elem_classes="gradio-group"):
@@ -543,69 +554,54 @@ with gr.Blocks(theme=purple_theme, css=custom_css) as demo:
                         key_input = gr.Textbox(label="API Key", type="password", placeholder="sk-...", scale=1)
                         api_base_url_input = gr.Textbox(label="Base URL (Optional)", placeholder="https://api.example.com", scale=1)
                     key_btn = gr.Button("💾 Save API Configuration")
-                    api_status = gr.Textbox(
-                        show_label=False, placeholder="Waiting for API configuration...", lines=1, interactive=False, elem_classes="status-text"
-                    )
+                    api_status = gr.Textbox(show_label=False, interactive=False, elem_classes="status-text")
 
                 # 2. Document Parsing
                 with gr.Group(elem_classes="gradio-group"):
                     gr.Markdown("### 📄 2. Document Parsing")
-                    pdf_input = gr.File(
-                        label="Upload Document", 
-                        file_types=[".pdf"], 
-                        elem_id="pdf-upload-box"
-                    )
+                    pdf_input = gr.File(label="Upload Document", file_types=[".pdf"], elem_id="pdf-upload-box")
                     parse_btn = gr.Button("🚀 Start Mineru & DAG Extraction", elem_classes="primary-action-btn", interactive=False)
-                    parse_status = gr.Textbox(
-                        show_label=False, placeholder="Waiting for document upload...", lines=1, interactive=False, elem_classes="status-text"
-                    )
+                    
+                    # 进度条替换原本的文本框
+                    parse_progress = gr.HTML(value=empty_progress_html("Waiting for document upload..."))
 
                 # 3. Asset Generation
                 with gr.Group(elem_classes="gradio-group"):
                     gr.Markdown("### 🎯 3. Asset Generation")
-                    gr.Markdown("Generate final formats based on DAG structure:")
                     with gr.Row(elem_classes="action-row"):
                         gen_ppt_btn = gr.Button("📊 Gen PPT", elem_classes="action-btn", interactive=False)
                         gen_poster_btn = gr.Button("🖼️ Gen Poster", elem_classes="action-btn", interactive=False)
                         gen_pr_btn = gr.Button("📰 Gen PR", elem_classes="action-btn", interactive=False)
                     gen_all_btn = gr.Button("✨ Generate All Assets (ALL)", elem_classes="primary-action-btn", interactive=False)
+                    
+                    # 新增进度的展示条
+                    gen_progress = gr.HTML(value=empty_progress_html("No generation task currently..."))
 
-            # ================= RIGHT COLUMN: OUTPUTS & LOGS =================
             with gr.Column(scale=1):
                 # 4. Results & Downloads
                 with gr.Group(elem_classes="gradio-group"):
                     gr.Markdown("### 📦 Generation Results & Download")
-                    gen_status = gr.Textbox(
-                        show_label=False, placeholder="No generation task currently...", lines=2, interactive=False, elem_classes="status-text"
-                    )
                     download_file = gr.File(label="📥 Get Final Zip Archive", interactive=False, visible=False)
 
-                # 5. Debugging & Terminal
+                # 5. Debugging
                 with gr.Group(elem_classes="gradio-group"):
                     gr.Markdown("### 🛠️ Developer Monitoring (Debug Only)")
                     with gr.Tabs():
                         with gr.Tab("📜 Terminal Stream"):
-                            cmd_logs = gr.Textbox(
-                                label="Stdout / Stderr", placeholder="Waiting for task to start...", lines=14, interactive=False, elem_classes="log-box" 
-                            )
+                            cmd_logs = gr.Textbox(show_label=False, lines=14, interactive=False, elem_classes="log-box")
                         with gr.Tab("🔍 System Snapshot"):
                             refresh_btn = gr.Button("🔄 Refresh Directory Tree") 
                             debug_view = gr.HTML()
 
-    # ================= LOGIC BINDINGS =================
+# ================= LOGIC BINDINGS =================
 
-    # [新增] 专门的页面初始化函数：当用户打开网页时，生成 UUID 并返回给 State
     def init_app_for_user():
         new_session_id = str(uuid.uuid4())
-        # 获取 debug info 的同时，顺便把属于该用户的空文件夹也创建好
         debug_html = get_debug_info(new_session_id)
         return new_session_id, debug_html
 
-    # 在页面加载的瞬间，生成专属 ID 存入状态，并渲染空的监控视图
     demo.load(fn=init_app_for_user, inputs=None, outputs=[session_id_state, debug_view])
 
-    # ================= EVENT BINDINGS =================
-    
     key_btn.click(
         fn=save_api_settings, 
         inputs=[key_input, api_base_url_input, session_id_state], 
@@ -615,13 +611,13 @@ with gr.Blocks(theme=purple_theme, css=custom_css) as demo:
     pdf_input.upload(
         fn=save_pdf, 
         inputs=[pdf_input, session_id_state], 
-        outputs=[parse_status, debug_view, pdf_ready_state]
+        outputs=[parse_progress, debug_view, pdf_ready_state]
     )
     
     pdf_input.clear(
         fn=clear_pdf, 
         inputs=[session_id_state],
-        outputs=[parse_status, debug_view, pdf_ready_state, gen_ppt_btn, gen_poster_btn, gen_pr_btn, gen_all_btn]
+        outputs=[parse_progress, gen_progress, debug_view, pdf_ready_state, gen_ppt_btn, gen_poster_btn, gen_pr_btn, gen_all_btn]
     )
     
     def check_parse_btn_ready(api_ready, pdf_ready):
@@ -633,7 +629,7 @@ with gr.Blocks(theme=purple_theme, css=custom_css) as demo:
     parse_btn.click(
         fn=run_mineru_parsing_and_dag_gen, 
         inputs=[session_id_state, user_api_key_state, user_api_base_state],
-        outputs=[parse_status, debug_view, cmd_logs, gen_ppt_btn, gen_poster_btn, gen_pr_btn, gen_all_btn]
+        outputs=[parse_progress, debug_view, cmd_logs, gen_ppt_btn, gen_poster_btn, gen_pr_btn, gen_all_btn]
     )
 
     def trigger_gen_ppt(sid, ak, ab, progress=gr.Progress()): yield from run_final_generation("ppt", sid, ak, ab, progress)
@@ -641,13 +637,12 @@ with gr.Blocks(theme=purple_theme, css=custom_css) as demo:
     def trigger_gen_pr(sid, ak, ab, progress=gr.Progress()): yield from run_final_generation("pr", sid, ak, ab, progress)
     def trigger_gen_all(sid, ak, ab, progress=gr.Progress()): yield from run_final_generation("all", sid, ak, ab, progress)
 
-    # 绑定需要传递所有专属状态
-    gen_ppt_btn.click(fn=trigger_gen_ppt, inputs=[session_id_state, user_api_key_state, user_api_base_state], outputs=[gen_status, debug_view, cmd_logs, download_file])
-    gen_poster_btn.click(fn=trigger_gen_poster, inputs=[session_id_state, user_api_key_state, user_api_base_state], outputs=[gen_status, debug_view, cmd_logs, download_file])
-    gen_pr_btn.click(fn=trigger_gen_pr, inputs=[session_id_state, user_api_key_state, user_api_base_state], outputs=[gen_status, debug_view, cmd_logs, download_file])
-    gen_all_btn.click(fn=trigger_gen_all, inputs=[session_id_state, user_api_key_state, user_api_base_state], outputs=[gen_status, debug_view, cmd_logs, download_file])
+    gen_ppt_btn.click(fn=trigger_gen_ppt, inputs=[session_id_state, user_api_key_state, user_api_base_state], outputs=[gen_progress, debug_view, cmd_logs, download_file])
+    gen_poster_btn.click(fn=trigger_gen_poster, inputs=[session_id_state, user_api_key_state, user_api_base_state], outputs=[gen_progress, debug_view, cmd_logs, download_file])
+    gen_pr_btn.click(fn=trigger_gen_pr, inputs=[session_id_state, user_api_key_state, user_api_base_state], outputs=[gen_progress, debug_view, cmd_logs, download_file])
+    gen_all_btn.click(fn=trigger_gen_all, inputs=[session_id_state, user_api_key_state, user_api_base_state], outputs=[gen_progress, debug_view, cmd_logs, download_file])
     
     refresh_btn.click(fn=get_debug_info, inputs=[session_id_state], outputs=debug_view)
 
 if __name__ == "__main__":
-    demo.launch()
+    demo.queue(default_concurrency_limit=5).launch()