提交代码

offline-backend-20260512/backend/app/gateway/app.py

@@ -30,6 +30,7 @@ from app.gateway.routers import (
     artifacts,
     assistants_compat,
     auth,
+    business_mapping,
     channels,
     checkpoint_migration,
     feedback,
@@ -766,6 +767,16 @@ async def lifespan(app: FastAPI) -> AsyncGenerator[None, None]:
                 "Roundtable functional agent seeding failed at startup (non-fatal)"
             )
 
+        # 业务链条管理：幂等补建固定业务行（3Q/6BF/7BF/8BF），agent/chain 初始为空。
+        try:
+            business_mapping_store = getattr(app.state, "business_mapping_store", None)
+            if business_mapping_store is not None:
+                inserted = await business_mapping_store.ensure_seed_defaults()
+                if inserted:
+                    logger.info("Seeded %d business mapping rows", inserted)
+        except Exception:
+            logger.exception("Business mapping seeding failed at startup (non-fatal)")
+
         # 一次性把 .deer-flow/agents/{id}/ 目录里历史遗留的 agent 导入 agents 表。
         # 路由层原本每次请求都跑一遍这个 sync(扫文件系统 + N 个 agent 各一次 DB
         # SELECT/UPDATE),把它挪到启动期 + 路由层只保留 TTL 兜底,显著降低
@@ -1124,6 +1135,9 @@ This gateway provides custom endpoints for models, MCP configuration, skills, an
     # Roundtable-planning business chains at /api/roundtable-chains
     app.include_router(roundtable_chains.router)
 
+    # Global business → agent / chain mapping at /api/business-mapping
+    app.include_router(business_mapping.router)
+
     # Standalone parallel multi-agent panel: fan-out streaming + saved tasks
     app.include_router(parallel_agents.router)
     app.include_router(parallel_agent_tasks.router)