From 5af340bd2b649a451551c22a0e6af17a64a8501b Mon Sep 17 00:00:00 2001
From: Ilya Mukhortov <ilya.muhortov@gmail.com>
Date: Tue, 4 Mar 2025 22:11:50 +1000
Subject: [PATCH] pass

---
 appa/settings.py |  4 ++--
 appa/tasks.py    | 33 +++++++++++++++++++++------------
 2 files changed, 23 insertions(+), 14 deletions(-)

diff --git a/appa/settings.py b/appa/settings.py
index b342bc3..9bba4f0 100644
--- a/appa/settings.py
+++ b/appa/settings.py
@@ -211,12 +211,12 @@ CELERY_IGNORE_RESULT = True
 CELERYBEAT_SCHEDULE = {
     'update_call_requests_task': {
         'task': 'appa.tasks.update_call_requests_task',
-        'schedule': crontab(hour='23', minute='0'),
+        'schedule': crontab(hour='8', minute='0'),
         'options': {'queue': CELERY_DEFAULT_QUEUE}
     },
     'check_call_requests_task': {
         'task': 'appa.tasks.check_call_requests_task',
-        'schedule': crontab(minute='*/1'),
+        'schedule': crontab(minute='*/5'),
         'options': {'queue': CELERY_DEFAULT_QUEUE}
     }
 }
diff --git a/appa/tasks.py b/appa/tasks.py
index c423b0e..60001a3 100644
--- a/appa/tasks.py
+++ b/appa/tasks.py
@@ -10,19 +10,28 @@ from appa.medicine_api import api as medicine_api
 
 @app.task(bind=True, acks_late=True)
 def send_call_request_task(self, ids=None):
-    call_requests = CallRequest.objects.filter(is_active=True)
-    if ids and len(ids) > 0:
-        call_requests = call_requests.filter(id__in=ids)
-    else:
-        tomorrow = datetime.date.today() + datetime.timedelta(days=1)
+    call_requests = CallRequest.objects.filter(
+        id__in=ids,
+        is_active=True
+    ).exclude(
+        status__in=[
+            CallRequest.Status.APPROVED,
+            CallRequest.Status.CANCELED
+        ]
+    )
 
-        call_requests = CallRequest.objects.filter(
-            date=tomorrow,
-            status__in=[
-                CallRequest.Status.PENDING,
-                CallRequest.Status.WITHOUT_ANSWER
-            ]
-        )
+    for call_request in call_requests:
+        call_api.add_call_request(call_request)
+
+
+@app.task(bind=True, acks_late=True)
+def send_daily_call_request_task(self, ids=None):
+    tomorrow = datetime.date.today() + datetime.timedelta(days=1)
+    call_requests = CallRequest.objects.filter(
+        date=tomorrow,
+        status=CallRequest.Status.PENDING,
+        is_active=True
+    )
 
     for call_request in call_requests:
         call_api.add_call_request(call_request)