OuYingJun1024
1893c01f54
- SavingsBattle 仓储/schema/接口新增 compare_count(= 有效记录数,与 order_count 同源) - 更新 docs/api/savings-battle.md 与 tests/test_welfare.py 断言 Co-Authored-By: Claude Opus 4.8 <noreply@anthropic.com>
61 lines
2.0 KiB
Python
61 lines
2.0 KiB
Python
"""省钱 endpoint(profile 的「累计帮你省了」「省钱战绩」「省钱明细」)。
|
|
|
|
路由前缀 `/api/v1/savings`:
|
|
GET /summary 累计省下 + 订单数 + 平均每单省
|
|
GET /battle 本周已省 + 超过百分比 + 连续省钱天数
|
|
GET /records 省钱明细(游标分页)
|
|
"""
|
|
from __future__ import annotations
|
|
|
|
import logging
|
|
|
|
from fastapi import APIRouter, Query
|
|
|
|
from app.api.deps import CurrentUser, DbSession
|
|
from app.repositories import savings as crud_savings
|
|
from app.schemas.welfare import (
|
|
SavingsBattleOut,
|
|
SavingsRecordOut,
|
|
SavingsRecordPage,
|
|
SavingsSummaryOut,
|
|
)
|
|
|
|
logger = logging.getLogger("shagua.savings")
|
|
|
|
router = APIRouter(prefix="/api/v1/savings", tags=["savings"])
|
|
|
|
|
|
@router.get("/summary", response_model=SavingsSummaryOut, summary="累计帮你省了")
|
|
def summary(user: CurrentUser, db: DbSession) -> SavingsSummaryOut:
|
|
s = crud_savings.get_summary(db, user.id)
|
|
return SavingsSummaryOut(
|
|
total_saved_cents=s.total_saved_cents,
|
|
order_count=s.order_count,
|
|
avg_saved_cents=s.avg_saved_cents,
|
|
)
|
|
|
|
|
|
@router.get("/battle", response_model=SavingsBattleOut, summary="省钱战绩")
|
|
def battle(user: CurrentUser, db: DbSession) -> SavingsBattleOut:
|
|
b = crud_savings.get_battle(db, user.id)
|
|
return SavingsBattleOut(
|
|
week_saved_cents=b.week_saved_cents,
|
|
beat_percent=b.beat_percent,
|
|
streak_days=b.streak_days,
|
|
compare_count=b.compare_count,
|
|
)
|
|
|
|
|
|
@router.get("/records", response_model=SavingsRecordPage, summary="省钱明细(游标分页)")
|
|
def records(
|
|
user: CurrentUser,
|
|
db: DbSession,
|
|
limit: int = Query(20, ge=1, le=100),
|
|
cursor: int | None = Query(None, description="上一页末条 id"),
|
|
) -> SavingsRecordPage:
|
|
items, next_cursor = crud_savings.list_records(db, user.id, limit=limit, cursor=cursor)
|
|
return SavingsRecordPage(
|
|
items=[SavingsRecordOut.model_validate(it) for it in items],
|
|
next_cursor=next_cursor,
|
|
)
|