| | |
| | | from app.models.user import UserCreate, LoginData |
| | | from app.models.user_model import UserModel |
| | | from app.service.auth import authenticate_user, create_access_token, is_valid_password, save_register_user, \ |
| | | update_user_token, UserAppDao |
| | | update_user_token, UserAppDao, update_user_info |
| | | from app.service.bisheng import BishengService |
| | | from app.service.v2.app_register import AppRegisterDao |
| | | from app.service.difyService import DifyService |
| | |
| | | access_token = create_access_token(data={"sub": user.username, "user_id": user.id}) |
| | | |
| | | upsert_token(db, user.id, access_token, bisheng_token, ragflow_token) |
| | | |
| | | # print(111) |
| | | return Response(code=200, msg="Login successful", data={ |
| | | "access_token": access_token, |
| | | "token_type": "bearer", |
| | | "username": user.username, |
| | | "nickname": "", |
| | | "user": user.to_login_json() |
| | | # "user": user.to_login_json() |
| | | }) |
| | | |
| | | |
| | |
| | | logger.error("未知注册应用---") |
| | | continue |
| | | try: |
| | | name = login_data.username |
| | | user_app = await UserAppDao(db).get_data_by_id(user.id, app["id"]) |
| | | if user_app: |
| | | name = user_app.username |
| | | else: |
| | | await update_user_info(db, user.id) |
| | | token = await service.login(name, login_data.password) |
| | | token_dict[app["id"]] = token |
| | | except Exception as e: |