Update core/pipeline_agent.py

core/pipeline_agent.py

@@ -477,6 +477,32 @@ You MUST output your response EXACTLY using the following two delimiters. Do not
         
         return final_abstract, final_conclusion
 
+        # ... 保留上面的 synthesize_literature 和 generate_anchors 函数不变 ...
+
+    # [新增] 综合文献的流式输出方法
+    def stream_synthesize_literature(self, topic, refs_text, user_core_literature=""):
+        user_injection = f"\n\nCRITICAL MANDATE: Prioritize User-Provided Core Literature:\n<USER_CORE_LITERATURE>\n{user_core_literature[:20000]}\n</USER_CORE_LITERATURE>\n" if user_core_literature else ""
+        sys_prompt = APP_CONFIG["prompt_templates"]["synthesis_system"]
+        user_prompt = APP_CONFIG["prompt_templates"]["synthesis_user"].replace(
+            "{topic}", topic).replace("{user_injection}", user_injection).replace(
+            "{refs_text}", refs_text).replace("{directive}", APP_CONFIG['deep_synthesis_directive'])
+        return self.stream_deepseek(sys_prompt, user_prompt, model_name="deepseek-chat")
+
+    # [新增] 生成锚点的流式输出方法
+    def stream_generate_anchors(self, topic, keywords, synthesis_result, refs_text):
+        sys_prompt = "You are a senior scholar conceptualizing a high-impact empirical paper."
+        format_mandate = """\n\n[CRITICAL FORMAT MANDATE]
+You MUST output your response EXACTLY using the following two delimiters. Do not add Markdown headings like ## before them:
+---ABSTRACT---
+(Write the comprehensive abstract here)
+---CONCLUSION---
+(Write the expected conclusion here)"""
+
+        base_directive = APP_CONFIG.get('anchor_generation_directive', '')
+        user_prompt = f"Topic: {topic}\nKeywords: {keywords}\nLiterature Synthesis:\n{synthesis_result}\nCitation Context:\n{refs_text[:3000]}\n{base_directive}{format_mandate}"
+        
+        return self.stream_deepseek(sys_prompt, user_prompt, max_tokens=8000, model_name="deepseek-reasoner")
+
     # =====================================================================
     # [核心架构升级] 双轨制大纲路由，取代自由生成的结构断层风险
     # =====================================================================