zcdsj
/
factory
5
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: event_push 超过48h未处理也不再推送

This commit is contained in:
caoqianming 2023-09-16 23:38:53 +08:00
parent 0c2589c151
commit 8c58d3990e
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
apps/ecm/tasks.py
View File

@ -218,6 +218,9 @@ def event_push(eventId: str):
async_to_sync(channel_layer.group_send)('event', data) async_to_sync(channel_layer.group_send)('event', data)
event.last_ws_pushtime = timezone.now() event.last_ws_pushtime = timezone.now()
event.save() event.save()
main_cate = event.cates.all().order_by('priority', 'create_time').first() if event.create_time + timedelta(hours=48) < now:
unhandled_push_interval = main_cate.unhandled_push_interval pass
event_push.apply_async(args=[eventId], eta=now + timedelta(seconds=unhandled_push_interval)) else:
main_cate = event.cates.all().order_by('priority', 'create_time').first()
unhandled_push_interval = main_cate.unhandled_push_interval
event_push.apply_async(args=[eventId], eta=now + timedelta(seconds=unhandled_push_interval))