1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
|
from celery import shared_task
from django.core import serializers
from restaurant_orders.consumers import NotificationsConsumer
from core.utils import Orders, SendMail, SendSms
import re
def send_notification(is_success, message, user_pk):
status = NotificationsConsumer.OK if is_success else NotificationsConsumer.ERROR
NotificationsConsumer.send_notifications(
user_pk,
status,
message
)
@shared_task
def create_order_and_send_notification(order, items, is_email=None, is_sms=None, user_pk=None):
order = [obj for obj in serializers.deserialize('json', order)]
if len(order) != 1:
return
order = order[0].object
phone = order.billing.get('phone')
email = order.billing.get('email')
new_order = Orders(order.restaurant, order.billing).create_custom_order(items)
# if new_order is None:
# send_notification(False,
# "Niestety nie udalo sie skontaktowac z restauracja, prosze sprowbowac ponownie pozniej.",
# user_pk)
# return
EMAIL_REGEX = r'\b[A-Za-z0-9._%+-]+@[A-Za-z0-9.-]+\.[A-Z|a-z]{2,}\b'
if is_sms: # TODO: Make regex for sms
sms = SendSms(new_order).send()
send_notification(*sms, user_pk)
if is_email and re.fullmatch(EMAIL_REGEX, str(email)):
mail = SendMail(new_order).send()
send_notification(*mail, user_pk)
|