feat: 删除接口
This commit is contained in:
parent
7e9f0eece2
commit
b2af30448d
|
|
@ -386,6 +386,22 @@ def create_app():
|
|||
|
||||
return StreamingResponse(_event(), media_type="text/event-stream")
|
||||
|
||||
@app.delete("/api/flows/status", tags=["Flow"], description="任务删除", response_model=BaseResponse)
|
||||
async def del_client(work_uuid: str, user: DB.User = Depends(get_current_user)):
|
||||
work = await DB.Work.filter(uuid=work_uuid).first()
|
||||
if not work:
|
||||
return BaseResponse()
|
||||
work_content = await DB.WorkContent.filter(work_id=work.id).first()
|
||||
async with in_transaction():
|
||||
work.is_deleted = 1
|
||||
work.update_time = datetime.datetime.now()
|
||||
await work.save()
|
||||
if work_content:
|
||||
work_content.is_deleted = 1
|
||||
work_content.update_time = datetime.datetime.now()
|
||||
await work_content.save()
|
||||
return BaseResponse()
|
||||
|
||||
@app.get("/api/clients", tags=["Client"], description="终端列表", response_model=TableResponse)
|
||||
async def clients_list(user: DB.User = Depends(get_current_user)):
|
||||
res = await DB.Client.filter(user_id=user.id).all()
|
||||
|
|
|
|||
Loading…
Reference in New Issue