Update core/pipeline_agent.py

core/pipeline_agent.py

@@ -98,35 +98,6 @@ class SSciPipelineAgent:
         sys_prompt = f"Translate the following text into {target_lang}. Preserve all formatting, line breaks, and [CITE-XX] tags exactly. Output ONLY the translation."
         return self.call_deepseek(sys_prompt, text, max_tokens=max_tokens, temp=0.2, model_name="deepseek-chat")
 
-    def _is_empirical_business_research(self, topic, keywords):
-        combined_text = f"{topic} {keywords}".lower()
-        empirical_strong_keywords = ["实证", "问卷", "定量", "量表", "empirical", "sem", "pls", "回归", "中介", "调节", "假设检验"]
-        if any(kw in combined_text for kw in empirical_strong_keywords):
-            st.success("🎯 规则拦截：命中强显式实证关键字，强制启用 AMJ 顶级期刊写作风格引擎。")
-            return True
-
-        sys_prompt = "You are an expert academic classifier. Your task is to determine if a given research topic falls into the category of 'empirical business/management research'."
-        user_prompt = f"""
-        Research Topic: {topic}
-        Keywords: {keywords}
-        Based on the topic and keywords, answer ONLY with a JSON object: {{"is_empirical": true/false, "reason": "brief justification"}}.
-        """
-        try:
-            response = self.call_deepseek(sys_prompt, user_prompt, max_tokens=100, temp=0.1)
-            json_match = re.search(r'\{.*\}', response, re.DOTALL)
-            if json_match:
-                result = json.loads(json_match.group(0))
-                is_empirical = result.get("is_empirical", False)
-                reason = result.get("reason", "")
-                if is_empirical:
-                    st.success(f"🎯 LLM嗅探：识别为工商管理实证研究，启用 AMJ 写作引擎。理由：{reason}")
-                else:
-                    st.info(f"ℹ️ LLM嗅探：未识别为实证研究，采用通用学术规范引擎。理由：{reason}")
-                return is_empirical
-            return False
-        except Exception:
-            return False
-
     @retry(stop=stop_after_attempt(3), wait=wait_random_exponential(multiplier=1, max=10), retry=retry_if_exception_type((requests.exceptions.Timeout, requests.exceptions.ConnectionError, requests.exceptions.HTTPError)))
     def _requests_get_with_retry(self, url, headers=None, params=None, timeout=15):
         resp = requests.get(url, headers=headers, params=params, timeout=timeout)