From 8c58d3990eea5fc5f5047f0ce1b85cf5ee40c9e6 Mon Sep 17 00:00:00 2001 From: caoqianming Date: Sat, 16 Sep 2023 23:38:53 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20event=5Fpush=20=E8=B6=85=E8=BF=8748h?= =?UTF-8?q?=E6=9C=AA=E5=A4=84=E7=90=86=E4=B9=9F=E4=B8=8D=E5=86=8D=E6=8E=A8?= =?UTF-8?q?=E9=80=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- apps/ecm/tasks.py | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) 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