add points_api
This commit is contained in:
27
backend/app/admin/api/v1/points.py
Normal file
27
backend/app/admin/api/v1/points.py
Normal file
@@ -0,0 +1,27 @@
|
||||
#!/usr/bin/env python3
|
||||
# -*- coding: utf-8 -*-
|
||||
from fastapi import APIRouter, Depends, Path,Request
|
||||
from typing import Optional
|
||||
|
||||
from backend.app.admin.service.points_service import points_service
|
||||
from backend.app.admin.schema.points import PointsBalanceInfo
|
||||
from backend.common.response.response_schema import response_base, ResponseSchemaModel
|
||||
from backend.common.security.jwt import DependsJwtAuth
|
||||
|
||||
router = APIRouter()
|
||||
|
||||
@router.get('/self', summary='获取用户积分和过期时间', dependencies=[DependsJwtAuth])
|
||||
async def get_user_points_info(
|
||||
request: Request,
|
||||
) -> ResponseSchemaModel[Optional[PointsBalanceInfo]]:
|
||||
"""
|
||||
根据用户ID获取对应的积分和过期时间
|
||||
"""
|
||||
points_info = await points_service.get_user_points(request.user.id)
|
||||
if points_info:
|
||||
balance_info = PointsBalanceInfo(
|
||||
balance=points_info.balance,
|
||||
expired_time=points_info.expired_time
|
||||
)
|
||||
return response_base.success(data=balance_info)
|
||||
return response_base.success(data=None)
|
||||
Reference in New Issue
Block a user