| | |
| | | from app.models.base_model import get_db |
| | | from app.models.user import PageParameter, UserStatus, UserInfo, LoginData |
| | | from app.models.user_model import UserModel |
| | | from app.service.auth import is_valid_password |
| | | from app.service.user import get_user_list, edit_user_status, delete_user_data, create_user, edit_user_data, \ |
| | | edit_user_pwd, get_user_info, get_user_routers, get_user_menus |
| | | edit_user_pwd, get_user_info, get_user_routers, get_user_menus, get_user_permission, get_user_dept |
| | | |
| | | user_router = APIRouter() |
| | | |
| | |
| | | async def add_user(user: UserInfo, current_user: UserModel = Depends(get_current_user), db=Depends(get_db)): |
| | | if not user.userName: |
| | | return Response(code=400, msg="The userName cannot be empty!") |
| | | if user.pwd: |
| | | if not is_valid_password(user.pwd): |
| | | return Response(code=400, msg="The password must be at least 8 and contain both numbers and letters") |
| | | db_user = db.query(UserModel).filter(UserModel.username == user.userName).first() |
| | | if db_user: |
| | | return Response(code=200, msg="user already created") |
| | | pwd = user.pwd |
| | | if not pwd: |
| | | pwd = "000000" |
| | | pwd = "basic123456" |
| | | is_create = await create_user(db, user.userName, user.email, user.phone, user.loginName, pwd, user.roles, |
| | | user.groups, current_user.id) |
| | | if not is_create: |
| | |
| | | |
| | | |
| | | @user_router.get("/menus", response_model=ResponseList) |
| | | async def user_menus(current_user: UserModel = Depends(get_current_user),db=Depends(get_db)): |
| | | async def user_menus(keyword="", current_user: UserModel = Depends(get_current_user),db=Depends(get_db)): |
| | | menus = await get_user_menus(db, current_user.id) |
| | | # return Response(code=200, msg="successfully", data=menus) |
| | | # result = [item.to_dict() for item in agents] |
| | | return ResponseList(code=200, msg="successfully", data=menus) |
| | | return ResponseList(code=200, msg="successfully", data=menus) |
| | | |
| | | |
| | | @user_router.get("/permission", response_model=Response) |
| | | async def user_permission(userId:int, current_user: UserModel = Depends(get_current_user),db=Depends(get_db)): |
| | | menus = await get_user_permission(db, userId) |
| | | return Response(code=200, msg="successfully", data=menus) |
| | | |
| | | |
| | | @user_router.get("/dept", response_model=Response) |
| | | async def user_dept_api(userId:int, current_user: UserModel = Depends(get_current_user),db=Depends(get_db)): |
| | | menus = await get_user_dept(db, userId) |
| | | return Response(code=200, msg="successfully", data=menus) |