feat(gateway): run_message/AgentExecutor 支持 default_pipeline_id

无当前项目时按入口指定产线装载能力(替代硬回退 sdlc_general)。
投标产线会话入口传 bidding_general 即可复用通用 agent 多 session 界面。

pipeline_service/agent_loop_v2.py

@@ -66,12 +66,13 @@ class AgentExecutor:
         generic: bool = False,         # True = 纯通用会话（不解析项目、不挂产线能力）
         session=None,                  # GatewaySession（会话级状态：approve_all/pending_confirm）
         session_id: str = "",          # 会话内唯一标识（web 多 tab 独立会话；历史隔离键）
+        default_pipeline_id: str = "", # 无当前项目时的默认产线（入口指定，如 bidding_general）
     ):
         self.config = config
         self.project_id = project_id
         self.user_id = user_id
         self.org_id = ""              # loaded from project context
-        self.pipeline_id = ""          # loaded from project context（产线能力包 key）
+        self.pipeline_id = default_pipeline_id or ""  # 默认产线（入口指定）；有项目时被项目 pipeline_id 覆盖
         self.role = role               # 产线内角色（技能/工具/prompt 按角色加载）
         self.generic = generic         # 是否纯通用会话
         self._session = session        # GatewaySession（approve_all/pending_confirm 会话级状态）
@@ -399,6 +400,7 @@ class AgentExecutor:
             self._memory_store = None
 
         # 5. pipeline_id 为空时 fallback 到默认产线（保证 slash/ability/skill 统一按产线挂载）
+        #    入口已指定 default_pipeline_id 时优先用它（投标/开发产线独立入口），否则用引擎默认。
         if not self.pipeline_id:
             try:
                 from pipeline_core import DEFAULT_ABILITY_ID

pipeline_service/gateway.py

@@ -119,7 +119,8 @@ class Gateway:
 
     async def run_message(self, channel: str, user_id: str, content: str,
                           history=None, role: str = "", generic: bool = False,
-                          base_url: str = "", session_id: str = "") -> AsyncGenerator[str, None]:
+                          base_url: str = "", session_id: str = "",
+                          pipeline_id: str = "") -> AsyncGenerator[str, None]:
         """统一消息入口：解析上下文 → 加载产线能力 → AgentExecutor 执行 → yield 事件流。
 
         Args:
@@ -130,6 +131,8 @@ class Gateway:
             role: 可选产线内角色（驾驶舱 agent 为空）
             generic: True = 纯通用会话（不解析项目、不加载产线能力，只用 GENERAL_TOOLS + 通用心智）
             session_id: 会话内唯一标识（web 多 tab 独立会话用；空 = 单会话）
+            pipeline_id: 产线默认能力（会话入口指定，如 bidding_general/sdlc_general）。
+                         无当前项目时用此产线装载能力，替代硬回退 DEFAULT_ABILITY_ID。
         """
         from pipeline_core.agent_config import load_agent_config
         from .agent_loop_v2 import AgentExecutor
@@ -139,6 +142,9 @@ class Gateway:
             ctx = {"pid": "", "pipeline_id": "", "name": ""}
         else:
             ctx = await self.resolve_project(user_id, session_id)
+            # 无当前项目 → 用入口指定的默认产线（投标/开发产线各自独立入口的关键）
+            if not ctx.get("pipeline_id") and pipeline_id:
+                ctx["pipeline_id"] = pipeline_id
 
         # 2. 会话生命周期（跟踪 project 切换；session_id 区分多 tab 会话）
         key = self._session_key(channel, user_id, session_id)
@@ -165,7 +171,8 @@ class Gateway:
             config.model_name = ctx["default_llm_name"]
         executor = AgentExecutor(
             config=config, project_id=ctx["pid"], user_id=user_id, role=role,
-            base_url=base_url, generic=generic, session=sess, session_id=session_id)
+            base_url=base_url, generic=generic, session=sess, session_id=session_id,
+            default_pipeline_id=pipeline_id)
 
         # 4. 转发标准化事件流
         async for chunk in executor.run(content, history=history):