| | |
| | | user = authenticate_user(db, login_data.username, password) |
| | | if not user: |
| | | return Response(code=400, msg="Incorrect username or password") |
| | | """ |
| | | app_register = AppRegisterDao(db).get_apps() |
| | | token_dict = {} |
| | | for app in app_register: |
| | |
| | | token_dict[app["id"]] = token |
| | | except Exception as e: |
| | | return Response(code=500, msg=f"Failed to login with {app['id']}: {str(e)}") |
| | | |
| | | """ |
| | | # 创建本地token |
| | | access_token = create_access_token(data={"sub": user.username, "user_id": user.id}) |
| | | |
| | | await update_token(db, user.id, access_token, token_dict) |
| | | await update_user_token(db, user.id, token_dict) |
| | | # await update_token(db, user.id, access_token, token_dict) |
| | | # await update_user_token(db, user.id, token_dict) |
| | | ''' |
| | | result = await pdb.execute(select(AppToken).where(AppToken.id == user.id)) |
| | | db_app_token = result.scalars().first() |
| | | if isinstance(access_token, bytes): |
| | |
| | | db_app_token.app_token = json.dumps(token_dict) |
| | | await pdb.commit() |
| | | await pdb.refresh(db_app_token) |
| | | ''' |
| | | return Response(code=200, msg="Login successful", data={ |
| | | "access_token": access_token, |
| | | "token_type": "bearer", |
| | |
| | | db_user = db.query(UserModel).filter(UserModel.username == user.username).first() |
| | | if db_user: |
| | | return Response(code=200, msg="Username already registered") |
| | | """ |
| | | app_register = AppRegisterDao(db).get_apps() |
| | | register_dict = {} |
| | | token = "" |
| | |
| | | register_dict[app['id']] = {"id":register_info.get("id"), "name": name, "email": register_info.get("email")} |
| | | except Exception as e: |
| | | return Response(code=500, msg=f"Failed to register with {app['id']}: {str(e)}") |
| | | user_id = await save_register_user(db, user.username, password, user.email, app_password, register_dict) |
| | | """ |
| | | user_id = await save_register_user(db, user.username, password, user.email, "", {}) |
| | | if not user_id: |
| | | return Response(code=500, msg=f"Failed to register with app") |
| | | return Response(code=200, msg="User registered successfully",data={"userFlag": user_id}) |