| | |
| | | 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): |
| | |
| | | if not isinstance(user_id, int) or user_id <= 0: |
| | | return |
| | | db_token = None |
| | | print(token) |
| | | # print(token) |
| | | try: |
| | | # 查询现有记录 |
| | | db_token = db.query(TokenModel).filter_by(user_id=user_id).first() |
| | |
| | | db.rollback() # 回滚事务 |
| | | |
| | | |
| | | def get_token(db: Session, user_id: int) -> Type[TokenModel] | None: |
| | | return db.query(TokenModel).filter_by(user_id=user_id).first() |
| | | async def get_token(db: Session, user_id: int): |
| | | # return db.query(TokenModel).filter_by(user_id=user_id).first() |
| | | |
| | | return {i.app_type.replace("app", "token"): i.access_token for i in await UserAppDao(db).get_user_datas(user_id)} |