This commit is contained in:
2026-07-06 15:39:33 +08:00
parent fa4f48a62f
commit 9b213b1551
4 changed files with 139 additions and 13 deletions
+30
View File
@@ -253,3 +253,33 @@ async def handle_join_request(
db, request_id, current_user.id, req.action, req.note
)
return {"message": "ok"}
# ── 团队积分变动记录 ────────────────────────────────────
@router.get("/credit-records")
async def list_team_credit_records(
page: int = Query(1, ge=1),
page_size: int = Query(20, ge=1, le=100),
user_id: str | None = Query(None),
record_type: str | None = Query(None, pattern="^(recharge|consume|refund|admin)$"),
start_date: str | None = Query(None),
end_date: str | None = Query(None),
current_user: User = Depends(get_current_user),
db: AsyncSession = Depends(get_db),
):
"""查看团队所有成员的积分变动记录(仅管理人)。"""
team = await get_managed_team(db, current_user.id)
if not team:
raise HTTPException(status_code=403, detail="只有团队管理人可查看")
from app.services.admin_credit_record_service import list_admin_credit_records
return await list_admin_credit_records(
db,
page=page,
page_size=page_size,
team_id=team.id,
user_id=user_id,
record_type=record_type,
start_date=start_date,
end_date=end_date,
)