diff --git a/apps/ecm/tasks.py b/apps/ecm/tasks.py index 159f307b..4e081f04 100644 --- a/apps/ecm/tasks.py +++ b/apps/ecm/tasks.py @@ -218,6 +218,9 @@ def event_push(eventId: str): async_to_sync(channel_layer.group_send)('event', data) event.last_ws_pushtime = timezone.now() event.save() - 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)) \ No newline at end of file + if event.create_time + timedelta(hours=48) < now: + pass + 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)) \ No newline at end of file