Compare commits

..

No commits in common. "607e6508ad457cb72a506aec142c35e3988f21ba" and "54d5007dae00a8dda704c91b9168ca6fcaffe412" have entirely different histories.

3 changed files with 17 additions and 24 deletions

View File

@ -68,6 +68,8 @@ def get_record(call_request: CallRequest, logging=True):
if result['call_result_code'] != call_status.STATUS_1:
call_request.call_text_log = result['text_log']
call_request.call_result = result['call_result']
if result['call_result_code'] not in [call_status.STATUS_14]:
call_request.request_status = call_request.RequestStatus.COMPLETED
if result['confirmed']:

View File

@ -211,12 +211,12 @@ CELERY_IGNORE_RESULT = True
CELERYBEAT_SCHEDULE = {
'update_call_requests_task': {
'task': 'appa.tasks.update_call_requests_task',
'schedule': crontab(hour='8', minute='0'),
'schedule': crontab(hour='23', minute='0'),
'options': {'queue': CELERY_DEFAULT_QUEUE}
},
'check_call_requests_task': {
'task': 'appa.tasks.check_call_requests_task',
'schedule': crontab(minute='*/5'),
'schedule': crontab(minute='*/1'),
'options': {'queue': CELERY_DEFAULT_QUEUE}
}
}

View File

@ -10,27 +10,18 @@ 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(
id__in=ids,
is_active=True
).exclude(
status__in=[
CallRequest.Status.APPROVED,
CallRequest.Status.CANCELED
]
)
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):
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(
date=tomorrow,
status=CallRequest.Status.PENDING,
is_active=True
status__in=[
CallRequest.Status.PENDING,
CallRequest.Status.WITHOUT_ANSWER
]
)
for call_request in call_requests: