| | |
| | | try: |
| | | hashed_password = pwd_context.hash(password) |
| | | db_user = UserModel(username=username, hashed_password=hashed_password, email=email, sync_flag=sync_flag) |
| | | pwd = db_user.encrypted_password(app_password) |
| | | db_user.password = pwd |
| | | # pwd = db_user.encrypted_password(app_password) |
| | | # db_user.password = pwd |
| | | db_user.roles = [db.query(RoleModel).filter(RoleModel.role_type == 2).first()] |
| | | db_user.groups = [db.query(GroupModel).filter(GroupModel.group_type == 2).first()] |
| | | db.add(db_user) |
| | | db.commit() |
| | | db.refresh(db_user) |
| | | ''' |
| | | user_id = db_user.id |
| | | for k, v in register_dict.items(): |
| | | await UserAppDao(db).update_and_insert_data(v.get("name"), pwd, v.get("email"), user_id, str(v.get("id")), k) |
| | | |
| | | ''' |
| | | except Exception as e: |
| | | logger.error(e) |
| | | # db.roolback() |
| | | if user_id: |
| | | db.query(UserModel).filter(UserModel.id == user_id).delete() |
| | | db.commit |
| | | db.rollback() |
| | | return False |
| | | return sync_flag |
| | | |