github
/
spug
mirror of https://github.com/openspug/spug
1
0
Fork 0
Code Issues Releases Wiki Activity

U 优化数据清理

pull/437/head v2.3.10
vapao 2020-09-15 09:54:26 +08:00
parent 5d3360bff5
commit 5df6361dee
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
spug_api/apps/deploy/views.py
View File

@ -130,6 +130,7 @@ class RequestView(View):
Argument('count', type=int, required=False, help='请输入数字') Argument('count', type=int, required=False, help='请输入数字')
).parse(request.GET) ).parse(request.GET)
if error is None: if error is None:
rds = get_redis_connection()
if form.id: if form.id:
DeployRequest.objects.filter(pk=form.id, status__in=('0', '1', '-1')).delete() DeployRequest.objects.filter(pk=form.id, status__in=('0', '1', '-1')).delete()
return json_response() return json_response()
@ -143,9 +144,15 @@ class RequestView(View):
else: else:
counter[item.deploy_id] += 1 counter[item.deploy_id] += 1
count, _ = DeployRequest.objects.filter(id__in=ids).delete() count, _ = DeployRequest.objects.filter(id__in=ids).delete()
if ids:
rds.delete(*(f'{settings.REQUEST_KEY}:{x}' for x in ids))
return json_response(count) return json_response(count)
elif form.expire: elif form.expire:
count, _ = DeployRequest.objects.filter(created_at__lt=form.expire).delete() requests = DeployRequest.objects.filter(created_at__lt=form.expire)
ids = [x.id for x in requests]
count, _ = requests.delete()
if ids:
rds.delete(*(f'{settings.REQUEST_KEY}:{x}' for x in ids))
return json_response(count) return json_response(count)
else: else:
return json_response(error='请至少使用一个删除条件') return json_response(error='请至少使用一个删除条件')