|
@@ -500,6 +500,37 @@ async def rollback_pattern(
|
|
|
traceback.print_exc()
|
|
|
raise HTTPException(status_code=500, detail=f"Internal server error: {str(e)}")
|
|
|
|
|
|
+
|
|
|
+@router.put("/ws/delete_all_user")
|
|
|
+async def rollback_pattern(
|
|
|
+ user_id=Depends(valid_access_token),
|
|
|
+ body = Depends(remove_xss_json),
|
|
|
+ db: Session = Depends(get_db)
|
|
|
+):
|
|
|
+ try:
|
|
|
+ pattern_info = pattern_id_get_tp_pattern_ws_group_def_info(body['pattern_id'],db)
|
|
|
+ if pattern_info is None:
|
|
|
+ return JSONResponse(status_code=404, content={
|
|
|
+ 'code': 404,
|
|
|
+ 'msg': '抱歉,pattern_id不存在,请联系系统管理员'
|
|
|
+ })
|
|
|
+ if pattern_info.create_by!=user_id:
|
|
|
+ return JSONResponse(status_code=404, content={
|
|
|
+ 'code': 404,
|
|
|
+ 'msg': '抱歉,您无权限,请联系系统管理员'
|
|
|
+ })
|
|
|
+ users = pattern_id_get_tp_pattern_ws_user_list(body['pattern_id'],db)
|
|
|
+ for user in users:
|
|
|
+ user.del_flag='2'
|
|
|
+ user.update_by = user_id
|
|
|
+ db.commit()
|
|
|
+ return {"code": 200, "msg": "关闭协同成功", "data": None}
|
|
|
+ except Exception as e:
|
|
|
+ traceback.print_exc()
|
|
|
+ raise HTTPException(status_code=500, detail=f"Internal server error: {str(e)}")
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
@router.post("/ws/add_user")
|
|
|
async def rollback_pattern(
|
|
|
user_id=Depends(valid_access_token),
|