43 lines
1.6 KiB
Python
43 lines
1.6 KiB
Python
|
# -*- coding: utf-8 -*-
|
||
|
|
"""业务层 · 路演服务（发布审核规则）。"""
|
||
|
|
from __future__ import annotations
|
||
|
|
|
||
|
|
from fastapi import HTTPException
|
||
|
|
|
||
|
|
from ..infrastructure.repositories import Database
|
||
|
|
|
||
|
|
|
||
|
|
class RoadshowService:
|
||
|
|
"""路演发布：按发布主体与范围判定是否需审核。"""
|
||
|
|
|
||
|
|
def __init__(self, db: Database):
|
||
|
|
self.db = db
|
||
|
|
|
||
|
|
def _need_review(self, user: dict, req) -> bool:
|
||
|
|
role = user.get("role")
|
||
|
|
if role == "operator":
|
||
|
|
return False
|
||
|
|
if role == "government":
|
||
|
|
scope = user.get("scope_region_ids", [])
|
||
|
|
if req.scope_type == "region" and req.region_id and req.region_id in scope:
|
||
|
|
return False # 自身权限范围内，免审
|
||
|
|
return True # 超出范围，需审核
|
||
|
|
# 投资机构/载体/企业：一律需审核
|
||
|
|
return True
|
||
|
|
|
||
|
|
async def create(self, req, actor: dict) -> dict:
|
||
|
|
"""创建路演（含审核判定）。"""
|
||
|
|
if not req.title.strip():
|
||
|
|
raise HTTPException(status_code=400, detail="标题不能为空")
|
||
|
|
if req.end_at and req.start_at and req.end_at < req.start_at:
|
||
|
|
raise HTTPException(status_code=400, detail="结束时间不能早于开始时间")
|
||
|
|
need_review = self._need_review(actor, req)
|
||
|
|
fields = {
|
||
|
|
**req.model_dump(exclude_none=True),
|
||
|
|
"publisher_id": actor["id"],
|
||
|
|
"publisher_role": actor.get("role", "investor"),
|
||
|
|
"status": "submitted" if need_review else "published",
|
||
|
|
"need_review": need_review,
|
||
|
|
}
|
||
|
|
return await self.db.roadshows.create(fields)
|