新增删除用户接口

routers/prod_api/system/dept/__init__.py

@@ -276,7 +276,7 @@ async def dept_info_update(
             "msg": "部门更新成功"
         }
     except Exception as e:
-        # db.rollback()
+        db.rollback()
         if str(e)=='':
             e = detail
         raise HTTPException(status_code=status.HTTP_500_INTERNAL_SERVER_ERROR, detail=str(e))

routers/prod_api/system/user/__init__.py

@@ -216,7 +216,6 @@ async def userlist( deptId: int = Query(None ,description='部门id'),
         traceback.print_exc()
         raise HTTPException(status_code=500, detail=f"Internal server error: {str(e)}")
 
-
 @router.get('/list/dept/{dept_id}')
 async def get_dept_user_list(
     # request: Request,
@@ -260,5 +259,55 @@ async def get_dept_user_list(
         "code": 200,
         "data": user_list_dict,
 
+        "msg": "操作成功"
+    }
+
+
+@router.put('/changeStatus')
+async def change_user_status(
+        db: Session = Depends(get_db),
+        body=Depends(remove_xss_json),
+        user_id=Depends(valid_access_token)
+):
+    try:
+        userId = body['userId']
+        status = body['status']
+        query = db.query(SysUser)
+        query = query.filter(SysUser.del_flag != '2')
+        query = query.filter(SysUser.user_id == userId)
+
+        user = query.first()
+        user.status= status
+        user.update_by=user_id
+        db.commit()
+        return {
+            "code": 200,
+            "msg": "操作成功"
+        }
+    except Exception as e:
+        # 处理异常
+        db.rollback()
+        traceback.print_exc()
+        raise HTTPException(status_code=500, detail=str(e))
+
+
+@router.delete('/{user_id1}')
+async def delete_dept(
+    user_id1:int,
+    db: Session = Depends(get_db),
+    body = Depends(remove_xss_json),
+    user_id = Depends(valid_access_token)
+):
+
+    user = user_id_get_user_info(db,user_id1)
+    # 将模型实例转换为字典
+    print(user)
+    user.del_flag = '2'
+    user.update_by = user_id
+    db.commit()
+
+    return {
+        "code": 200,
+        "data": None,
         "msg": "操作成功"
     }

utils/ry_system_util.py

@@ -9,7 +9,7 @@ def dept_id_get_dept_info(db,dept_id):
 def user_id_get_user_info(db,user_id):
     query = db.query(SysUser)
     query = query.filter(SysUser.del_flag != '2')
-    query = query.filter(SysUser.dept_id == user_id)
+    query = query.filter(SysUser.user_id == user_id)
     return query.first()
 
 def parent_id_get_dept_info(db,parent_id,dept_id=None):