| | |
| | | from sqlalchemy.orm import Session |
| | | |
| | | from Log import logger |
| | | from app.config.const import RAGFLOW |
| | | from app.models.base_model import Base |
| | | from app.service.auth import UserAppDao |
| | | |
| | | |
| | | class TokenModel(Base): |
| | |
| | | db.rollback() # 回滚事务 |
| | | |
| | | |
| | | async def get_token(db: Session, user_id: int): |
| | | res = {i.app_type.replace("app", "token"): i.access_token for i in await UserAppDao(db).get_user_datas(user_id)} |
| | | if not res: |
| | | token = db.query(TokenModel).filter_by(user_id=user_id).first() |
| | | res = {"ragflow_token": token.ragflow_token, "bisheng_token": token.bisheng_token} |
| | | return res |
| | | |