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 开发）
38 lines
1.2 KiB
Python
38 lines
1.2 KiB
Python
"""流失风险预警。"""
|
|
|
|
from datetime import datetime, timezone
|
|
|
|
from sqlalchemy import select, func
|
|
from sqlalchemy.ext.asyncio import AsyncSession
|
|
|
|
from app.models.company import Company
|
|
from app.models.report import MonthlyReport
|
|
|
|
|
|
async def detect_churn_risk(db: AsyncSession, tenant_id: str) -> list[dict]:
|
|
"""识别企业活跃度下降/数据共享减少/互动减少的早期信号。"""
|
|
result = await db.execute(
|
|
select(Company).where(Company.tenant_id == tenant_id)
|
|
)
|
|
companies = result.scalars().all()
|
|
|
|
risks: list[dict] = []
|
|
for company in companies:
|
|
# 检查最近月报提交情况
|
|
report_result = await db.execute(
|
|
select(func.count(MonthlyReport.id))
|
|
.where(MonthlyReport.company_id == company.id)
|
|
)
|
|
report_count = report_result.scalar_one()
|
|
|
|
if report_count == 0:
|
|
risks.append({
|
|
"company_id": str(company.id),
|
|
"company_name": company.name,
|
|
"risk_level": "high",
|
|
"signals": ["从未提交月报"],
|
|
"detected_at": datetime.now(timezone.utc).isoformat(),
|
|
})
|
|
|
|
return risks
|