| | |
| | | from fastapi import APIRouter, Depends, Request |
| | | from fastapi.security import OAuth2PasswordBearer |
| | | from passlib.context import CryptContext |
| | | from fastapi import APIRouter, Depends |
| | | from sqlalchemy.orm import Session |
| | | |
| | | from app.api import Response, pwd_context, oauth2_scheme, get_current_user |
| | | from app.api import Response, pwd_context, get_current_user |
| | | from app.config.config import settings |
| | | from app.models.base_model import get_db |
| | | from app.models.token_model import upsert_token |
| | | from app.models.token_model import upsert_token, get_token |
| | | from app.models.user import UserCreate, LoginData |
| | | from app.models.user_model import UserModel |
| | | from app.service.auth import authenticate_user, create_access_token |
| | |
| | | from app.service.ragflow import RagflowService |
| | | |
| | | router = APIRouter() |
| | | |
| | | |
| | | |
| | | |
| | | @router.post("/register", response_model=Response) |
| | |
| | | "username": user.username, |
| | | "nickname": "", |
| | | }) |
| | | |
| | | |
| | | @router.get("/token", response_model=Response) |
| | | async def token_api(db: Session = Depends(get_db), current_user: UserModel = Depends(get_current_user)): |
| | | # 查询现有记录 |
| | | token = get_token(db, current_user.id) |
| | | if token is None: |
| | | return Response(code=400, msg="token not found") |
| | | return Response(code=200, msg="success", data={ |
| | | "ragflow_token": token.ragflow_token, |
| | | }) |