Notification

apps/notification/celery.py

@@ -0,0 +1,21 @@
+import string
+import time
+
+from celery import shared_task
+from django.core.mail import EmailMultiAlternatives
+from django.template.loader import render_to_string
+
+
+@shared_task(name="notification")
+def send_email(subject: string, text: string, to: list):
+    context = {
+        'subject': subject,
+        'context': text
+    }
+    email_html_message = render_to_string('email/notification.html', context)
+    email_plaintext_message = render_to_string('email/notification.txt', context)
+    msg = EmailMultiAlternatives(subject=subject, from_email="datadays.sharif@gmail.com",
+                                 bcc=to, body=email_plaintext_message)
+    msg.attach_alternative(email_html_message, "text/html")
+    msg.send()
+    time.sleep(60)

apps/notification/migrations/0001_initial.py

@@ -1,4 +1,4 @@
-# Generated by Django 2.2.8 on 2019-12-21 13:54
+# Generated by Django 2.2.8 on 2020-01-10 18:56
 
 from django.conf import settings
 from django.db import migrations, models
@@ -18,6 +18,7 @@ class Migration(migrations.Migration):
             name='EmailText',
             fields=[
                 ('id', models.AutoField(auto_created=True, primary_key=True, serialize=False, verbose_name='ID')),
+                ('subject', models.CharField(max_length=100)),
                 ('text', models.TextField()),
                 ('html', models.TextField(editable=False)),
             ],
@@ -26,7 +27,7 @@ class Migration(migrations.Migration):
             name='Subscriber',
             fields=[
                 ('id', models.AutoField(auto_created=True, primary_key=True, serialize=False, verbose_name='ID')),
-                ('email', models.EmailField(max_length=254)),
+                ('email', models.EmailField(max_length=254, unique=True)),
             ],
         ),
         migrations.CreateModel(

apps/notification/migrations/0002_emailtext_receivers.py

@@ -0,0 +1,18 @@
+# Generated by Django 2.2.8 on 2020-01-14 17:17
+
+from django.db import migrations, models
+
+
+class Migration(migrations.Migration):
+
+    dependencies = [
+        ('notification', '0001_initial'),
+    ]
+
+    operations = [
+        migrations.AddField(
+            model_name='emailtext',
+            name='receivers',
+            field=models.ManyToManyField(to='notification.Subscriber'),
+        ),
+    ]

apps/notification/models.py

@@ -1,11 +1,13 @@
 import markdown
 from django.contrib.auth.models import User
-from django.core.mail import send_mail
+from django.core.mail import EmailMultiAlternatives
+from django.template.loader import render_to_string
+
 from django.db import models
+from apps.notification.celery import *
 
 
 # Create your models here.
-from rest_framework.validators import UniqueValidator
 
 
 class Notification(models.Model):
@@ -14,15 +16,34 @@ class Notification(models.Model):
     text = models.TextField(max_length=200, null=False)
     seen = models.BooleanField(default=False, null=False)
 
+    def __str__(self):
+        return self.text
+
 
 class Subscriber(models.Model):
     email = models.EmailField(null=False, unique=True)
 
+    def __str__(self):
+        return self.email
+
 
 class EmailText(models.Model):
+    subject = models.CharField(null=False, max_length=100)
     text = models.TextField(null=False)
     html = models.TextField(editable=False)
+    receivers = models.ManyToManyField(Subscriber)
+
+    def __str__(self):
+        return self.text
 
     def save(self, force_insert=False, force_update=False, using=None,
              update_fields=None):
         self.html = markdown.markdown(self.text)
+        if not self.pk:
+            subscribers = list()
+            for subscriber in Subscriber.objects.values_list('email'):
+                subscribers.append(subscriber[0])
+            for i in range(0, len(subscribers) + 1, 20):
+                send_email.apply_async([self.subject, self.text, subscribers[i:i + 20]])
+
+        super().save(force_insert, force_update, using, update_fields)

apps/notification/templates/email/notification.html

@@ -0,0 +1,16 @@
+{% load static i18n %}
+
+{% get_current_language_bidi as LANGUAGE_BIDI %}
+
+<!DOCTYPE html>
+<html>
+<head>
+    <meta charset="UTF-8">
+    <title>{{ subject }}</title>
+</head>
+<body>
+{% autoescape off %}
+    {{ context }}
+{% endautoescape %}
+</body>
+</html> 

apps/notification/templates/email/notification.txt

@@ -0,0 +1,9 @@
+{% load static i18n %}
+
+{% get_current_language_bidi as LANGUAGE_BIDI %}
+
+
+
+{% autoescape off %}
+    {{ context }}
+{% endautoescape %}

thebackend/settings/production.py

@@ -2,7 +2,6 @@
 
 from .development import *
 
-
 SECRET_KEY = 'oaeu#@$puoeuj,#$>Ueok,4IY@#$"PU.ohukAEOUO>AYU34$IPK'
 
 DEBUG = False
@@ -85,7 +84,6 @@
     }
 }
 
-
 TIME_ZONE = 'Iran'
 
 STATIC_URL = '/static/'
@@ -96,10 +94,9 @@
 
 CSRF_COOKIE_HTTPONLY = True
 
-EMAIL_BACKEND = os.getenv('EMAIL_BACKEND')
-EMAIL_USE_TLS = os.getenv('EMAIL_USE_TLS')
-EMAIL_HOST = os.getenv('EMAIL_HOST')
-EMAIL_HOST_USER = os.getenv('EMAIL_HOST_USER')
-EMAIL_HOST_PASSWORD = os.getenv('EMAIL_HOST_PASSWORD')
-EMAIL_PORT = os.getenv('EMAIL_PORT')
-
+EMAIL_BACKEND = 'django.core.mail.backends.smtp.EmailBackend'
+EMAIL_USE_TLS = True
+EMAIL_HOST = 'smtp.gmail.com'
+EMAIL_HOST_USER = 'datadays.sharif@gmail.com'
+EMAIL_HOST_PASSWORD = ''
+EMAIL_PORT = 587