From efa66517488cda6e6016c60020c3c232d8d2730b Mon Sep 17 00:00:00 2001 From: caoqianming Date: Fri, 1 Sep 2023 09:38:07 +0800 Subject: [PATCH] feat: remind_push --- apps/ecm/tasks.py | 15 ++++++++++++--- 1 file changed, 12 insertions(+), 3 deletions(-) diff --git a/apps/ecm/tasks.py b/apps/ecm/tasks.py index 29d00bd3..808fbaa9 100644 --- a/apps/ecm/tasks.py +++ b/apps/ecm/tasks.py @@ -1,10 +1,10 @@ from __future__ import absolute_import, unicode_literals import os from threading import Thread - +from channels.layers import get_channel_layer +from asgiref.sync import async_to_sync from celery import shared_task import requests - from apps.am.models import Area from apps.ecm.models import EventCate, Eventdo, Event from apps.ecm.service import notify_event, snap_and_analyse @@ -202,4 +202,13 @@ def compressed_all_ecm_image(): for event in events: if event.global_img and event.global_img_compressed is None: event.global_img_compressed = compress_global_img(event.global_img) - event.save() \ No newline at end of file + event.save() + +@shared_task(base=CustomTask) +def remind_push(userId: str): + channel_layer = get_channel_layer() + data = { + 'type': 'event', + 'msg': '' + } + async_to_sync(channel_layer.group_send)(f"user_{userId}", data) \ No newline at end of file