Update app.py

app.py

@@ -37,6 +37,10 @@ WORKSPACE_DIR = APP_CONFIG.get("workspace_dir", ".workspace")
 os.makedirs(WORKSPACE_DIR, exist_ok=True)
 CHECKPOINT_FILE = os.path.join(WORKSPACE_DIR, "snapshot.json")
 
+# [新增修改 1] 定义本地输出文件夹，用于存放最终生成的 ZIP 备份
+OUTPUT_DIR = "outputs"
+os.makedirs(OUTPUT_DIR, exist_ok=True)
+
 META_SECTIONS_BLACKLIST = set(APP_CONFIG["blacklists"]["meta_sections"])
 
 def clean_trailing_references(text, keywords=("reference", "references", "reference list", "参考文献")):
@@ -196,19 +200,11 @@ ui, target_lang = APP_CONFIG["ui_labels"][lang_choice], APP_CONFIG["target_lang_
 st.markdown(f"<div class='main-title'><h2>{ui['title']}</h2></div>", unsafe_allow_html=True)
 
 if os.path.exists(CHECKPOINT_FILE) and not (st.session_state.is_running or st.session_state.resume_pipeline or st.session_state.start_pipeline):
-    st.warning("⚠️ 系统检测到上次因网络或意外中断的未完成论文任务。")
-    colA, colB = st.columns([1, 1])
-    if colA.button("🔄 恢复断点续传 (Resume Progress)", key="resume_task"):
-        st.session_state.resume_pipeline = True
-        st.session_state.start_pipeline = False
-        st.rerun()
-    if colB.button("🗑️ 清除临时数据 (Clear Garbage)", key="clear_task"):
-        try: 
-            os.remove(CHECKPOINT_FILE)
-        except OSError: 
-            pass
-        st.rerun()
-    st.markdown("---")
+    st.toast("🔄 检测到页面刷新或网络抖动，系统正在自动恢复进度...", icon="⚡")
+    st.session_state.is_running = False
+    st.session_state.start_pipeline = False
+    st.session_state.resume_pipeline = True
+    st.rerun()
 
 topic = st.text_input(ui["topic_label"], value="Generative Artificial Intelligence in Ubiquitous Learning: Evaluating a Chatbot-based Recommendation Engine for Personalized and Context-aware Education", disabled=st.session_state.is_running)
 keywords = st.text_input(ui["keywords_label"], value="Ubiquitous computing; Context awareness; Deep learning; Personalized educational; Educational technologies; HCI; Recommendation system; LLMs; Generative AI; ChatGPT; Prompting engineering; Few-shot prompting", disabled=st.session_state.is_running)
@@ -291,17 +287,6 @@ if st.session_state.start_pipeline or st.session_state.resume_pipeline:
         st.error("❌ DEEPSEEK_API_KEY missing. 请配置API KEY。")
         st.stop()
         
-    if st.session_state.get("is_running", False):
-        if global_lock.locked():
-            try: global_lock.release()
-            except: pass
-        # 【修改点：无感自动恢复，移除按钮拦截，直接重置状态并重跑】
-        st.toast("🔄 检测到页面刷新或网络抖动，系统正在自动恢复进度...", icon="⚡")
-        st.session_state.is_running = False
-        st.session_state.start_pipeline = False
-        st.session_state.resume_pipeline = True
-        st.rerun()
-        
     if not global_lock.acquire(blocking=False):
         st.warning("⏳ 有小伙伴正在创作，您在15-20 分钟后就能正常使用啦")
         st.session_state.start_pipeline = False
@@ -599,7 +584,7 @@ if st.session_state.start_pipeline or st.session_state.resume_pipeline:
                         if trans_text:
                             full_draft_translated += trans_text + "\n\n"
                     except Exception as e:
-                        logging.error(f"翻译任务失败: {e}")
+                        pass
                     
                     full_draft_en += previous_task["en_text"] + "\n\n"
                     state["completed_sections"].append(previous_task["name"])
@@ -779,7 +764,7 @@ if st.session_state.start_pipeline or st.session_state.resume_pipeline:
                     if trans_text:
                         full_draft_translated += trans_text + "\n\n"
                 except Exception as e:
-                    logging.error(f"翻译任务失败: {e}")
+                    pass
                 
                 full_draft_en += previous_task["en_text"] + "\n\n"
                 state["completed_sections"].append(previous_task["name"])
@@ -844,6 +829,14 @@ if st.session_state.start_pipeline or st.session_state.resume_pipeline:
             st.session_state.zip_buffer = zip_buffer.getvalue()
             st.session_state.zip_filename = f"Draft_{bj_time}.zip"
             
+            # [新增修改 2] 落地即保存机制：写入本地硬盘备份
+            try:
+                disk_save_path = os.path.join(OUTPUT_DIR, st.session_state.zip_filename)
+                with open(disk_save_path, "wb") as f_out:
+                    f_out.write(st.session_state.zip_buffer)
+            except Exception as e:
+                pass
+            
             try: 
                 os.remove(CHECKPOINT_FILE)
             except OSError: