This commit is contained in:
Ilya Mukhortov 2025-03-05 09:07:49 +10:00
parent 607e6508ad
commit f8517d0677
2 changed files with 9 additions and 3 deletions

View File

@ -218,7 +218,12 @@ CELERYBEAT_SCHEDULE = {
'task': 'appa.tasks.check_call_requests_task', 'task': 'appa.tasks.check_call_requests_task',
'schedule': crontab(minute='*/5'), 'schedule': crontab(minute='*/5'),
'options': {'queue': CELERY_DEFAULT_QUEUE} 'options': {'queue': CELERY_DEFAULT_QUEUE}
} },
'send_daily_call_request_task': {
'task': 'appa.tasks.send_daily_call_request_task',
'schedule': crontab(hour='10', minute='0'),
'options': {'queue': CELERY_DEFAULT_QUEUE}
},
} }
DATE_FORMAT = 'd.m.Y' DATE_FORMAT = 'd.m.Y'

View File

@ -25,7 +25,7 @@ def send_call_request_task(self, ids=None):
@app.task(bind=True, acks_late=True) @app.task(bind=True, acks_late=True)
def send_daily_call_request_task(self, ids=None): def send_daily_call_request_task(self):
tomorrow = datetime.date.today() + datetime.timedelta(days=1) tomorrow = datetime.date.today() + datetime.timedelta(days=1)
call_requests = CallRequest.objects.filter( call_requests = CallRequest.objects.filter(
date=tomorrow, date=tomorrow,
@ -82,6 +82,7 @@ def update_call_requests_task(self):
@app.task(bind=True, acks_late=True) @app.task(bind=True, acks_late=True)
def check_call_requests_task(self): def check_call_requests_task(self):
for call_request in CallRequest.objects.filter( for call_request in CallRequest.objects.filter(
request_status=CallRequest.RequestStatus.SENT request_status=CallRequest.RequestStatus.SENT,
date=datetime.date.today()
): ):
call_api.get_record(call_request) call_api.get_record(call_request)