selfrelease
fad458b2a7
- UIUX 文档：填充 19 个缺口（多主体画像/健康度/AI+看板/增长域/洞察域/创始人端/OODA/助推/商密） - UIUX 文档：插入 6 个新章节（十四~十九），旧章节重编号为二十~三十一，更新目录和交叉引用 - 作业指导书 x5：导航改为 6 域分组，新增 Context Bar/工作模式/Insight Rail/决策线程/多工作区等 UI 概念 - 新建 docs/2-task-uiux.md：50 个代码落地开发任务，按 P0-P6 分优先级 + 8 Sprint 规划 - 后端/前端：大量新增模型、路由、组件（来自之前 Phase 开发）
73 lines
2.8 KiB
Python
73 lines
2.8 KiB
Python
"""多主体画像路由。"""
|
|
|
|
from fastapi import APIRouter, Depends, Query, status
|
|
from sqlalchemy import select
|
|
from sqlalchemy.ext.asyncio import AsyncSession
|
|
|
|
from app.core.database import get_db
|
|
from app.core.dependencies import get_current_user
|
|
from app.models.profile import FirmProfile, FundProfile, ManagerProfile
|
|
from app.models.user import User
|
|
from app.schemas.common import ApiResponse, success
|
|
|
|
router = APIRouter(prefix="/profiles", tags=["profiles"])
|
|
|
|
|
|
@router.get("/firms", response_model=ApiResponse[list])
|
|
async def list_firms(
|
|
db: AsyncSession = Depends(get_db),
|
|
user: User = Depends(get_current_user),
|
|
):
|
|
"""获取投资机构列表。"""
|
|
result = await db.execute(
|
|
select(FirmProfile).where(FirmProfile.tenant_id == user.tenant_id)
|
|
)
|
|
items = result.scalars().all()
|
|
return success(data=[
|
|
{"id": str(i.id), "name": i.name, "focus_areas": i.focus_areas, "stage_preference": i.stage_preference, "description": i.description}
|
|
for i in items
|
|
])
|
|
|
|
|
|
@router.post("/firms", response_model=ApiResponse[dict], status_code=status.HTTP_201_CREATED)
|
|
async def create_firm(req: dict, db: AsyncSession = Depends(get_db), user: User = Depends(get_current_user)):
|
|
"""创建投资机构画像。"""
|
|
firm = FirmProfile(
|
|
tenant_id=user.tenant_id,
|
|
name=req.get("name"),
|
|
focus_areas=req.get("focus_areas"),
|
|
stage_preference=req.get("stage_preference"),
|
|
description=req.get("description"),
|
|
)
|
|
db.add(firm)
|
|
await db.flush()
|
|
return success(data={"id": str(firm.id)}, message="创建成功")
|
|
|
|
|
|
@router.get("/funds", response_model=ApiResponse[list])
|
|
async def list_funds(firm_id: str | None = Query(default=None), db: AsyncSession = Depends(get_db), user: User = Depends(get_current_user)):
|
|
"""获取基金列表。"""
|
|
query = select(FundProfile)
|
|
if firm_id:
|
|
query = query.where(FundProfile.firm_id == firm_id)
|
|
result = await db.execute(query)
|
|
items = result.scalars().all()
|
|
return success(data=[
|
|
{"id": str(i.id), "firm_id": str(i.firm_id), "name": i.name, "fund_size": i.fund_size, "vintage_year": i.vintage_year, "strategy": i.strategy}
|
|
for i in items
|
|
])
|
|
|
|
|
|
@router.get("/managers", response_model=ApiResponse[list])
|
|
async def list_managers(firm_id: str | None = Query(default=None), db: AsyncSession = Depends(get_db), user: User = Depends(get_current_user)):
|
|
"""获取投资经理列表。"""
|
|
query = select(ManagerProfile)
|
|
if firm_id:
|
|
query = query.where(ManagerProfile.firm_id == firm_id)
|
|
result = await db.execute(query)
|
|
items = result.scalars().all()
|
|
return success(data=[
|
|
{"id": str(i.id), "firm_id": str(i.firm_id), "name": i.name, "focus_areas": i.focus_areas, "portfolio_count": i.portfolio_count}
|
|
for i in items
|
|
])
|