| | |
| | | from app.service.ragflow import RagflowService |
| | | |
| | | |
| | | async def get_user_list(db, page_size: int, page_index: int, keyword: str, role_key:str, user_id): |
| | | query = db.query(UserModel) |
| | | if role_key != "admin": |
| | | query.filter(UserModel.creator==user_id) |
| | | async def get_user_list(db, page_index: int, page_size: int, keyword: str, role_key:str, user_id): |
| | | query = db.query(UserModel).filter(UserModel.permission!="admin") |
| | | # if role_key != "admin": |
| | | # query.filter(UserModel.creator==user_id) |
| | | if keyword: |
| | | query = query.filter(UserModel.group_name.like('%{}%'.format(keyword))) |
| | | users = query.order_by(UserModel.id.desc()).limit(page_size).offset( |
| | |
| | | |
| | | async def delete_user_data(db, user_id: str): |
| | | try: |
| | | db.query(UserModel).filter(UserModel.id == user_id).delete() |
| | | db.query(UserModel).filter(UserModel.id == user_id, UserModel.permission!="admin").delete() |
| | | db.commit() |
| | | except Exception as e: |
| | | logger.error(e) |