Projet

Général

Profil

« Précédent | Suivant » 

Révision afefedf4

Ajouté par Serghei Mihai (congés, retour 15/05) il y a presque 8 ans

announces send command (#10805)

Ran as cron job every 5 minutes

Voir les différences:

corbo/models.py
1
from datetime import datetime
2
import logging
3
from html2text import HTML2Text
4
from emails.django import Message
5
from lxml.etree import HTML as HTMLTree
6

  
1 7
from django.utils import timezone
2 8
from django.conf import settings
3 9
from django.db import models
10
from django.core.files.storage import DefaultStorage
4 11
from django.utils.translation import ugettext_lazy as _
5 12

  
6 13
from ckeditor.fields import RichTextField
......
10 17
    ('homepage', _('Homepage'))
11 18
)
12 19

  
20
logger = logging.getLogger(__name__)
21

  
13 22
class Category(models.Model):
14 23
    name = models.CharField(max_length=64, blank=False, null=False)
15 24
    ctime = models.DateTimeField(auto_now_add=True)
......
62 71
                id=self.announce.id, time=self.deliver_time)
63 72
        return u'announce {id} to deliver'.format(id=self.announce.id)
64 73

  
74
    def send(self):
75
        subscriptions = self.announce.category.subscription_set.all()
76
        total_sent = 0
77
        handler = HTML2Text()
78
        m = Message(html=self.announce.text, subject=self.announce.title,
79
                    text=handler.handle(self.announce.text),
80
                    mail_from=settings.CORBO_DEFAULT_FROM_EMAIL)
81
        html_tree = HTMLTree(self.announce.text)
82
        storage = DefaultStorage()
83
        for img in html_tree.xpath('//img/@src'):
84
            img_path = img.lstrip(storage.base_url)
85
            m.attach(filename=img, data=storage.open(img_path))
86
            m.attachments[img].is_inline = True
87
        m.transformer.synchronize_inline_images()
88
        m.transformer.load_and_transform()
89
        m.transformer.save()
90
        for s in subscriptions:
91
            if not s.identifier:
92
                continue
93
            sent = m.send(to=s.identifier)
94
            if sent:
95
                total_sent += 1
96
                logger.info('Announce "%s" sent to %s', self.announce.title, s.identifier)
97
            else:
98
                logger.warning('Error occured while sending announce "%s" to %s.',
99
                               self.announce.title, s.identifier)
100
        self.result = total_sent
101
        self.deliver_time = timezone.now()
102
        self.save()
103

  
65 104
    class Meta:
66 105
        verbose_name = _('sent')
67 106
        ordering = ('-deliver_time',)

Formats disponibles : Unified diff