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
52
53
54
|
import logging
from odoo import api, fields, models
from odoo.addons.event.models.event_mail import _INTERVALS
from odoo.exceptions import MissingError
_logger = logging.getLogger(__name__)
class EventMailRegistration(models.Model):
_name = 'event.mail.registration'
_description = 'Registration Mail Scheduler'
_rec_name = 'scheduler_id'
_order = 'scheduled_date DESC, id ASC'
scheduler_id = fields.Many2one('event.mail', 'Mail Scheduler', required=True, ondelete='cascade')
registration_id = fields.Many2one('event.registration', 'Attendee', required=True, ondelete='cascade')
scheduled_date = fields.Datetime('Scheduled Time', compute='_compute_scheduled_date', store=True)
mail_sent = fields.Boolean('Mail Sent')
@api.depends('registration_id', 'scheduler_id.interval_unit', 'scheduler_id.interval_type')
def _compute_scheduled_date(self):
for mail in self:
if mail.registration_id:
mail.scheduled_date = mail.registration_id.create_date.replace(microsecond=0) + _INTERVALS[mail.scheduler_id.interval_unit](mail.scheduler_id.interval_nbr)
else:
mail.scheduled_date = False
def execute(self):
# Deprecated, to be called only from parent scheduler
skip_domain = self._get_skip_domain() + [("registration_id.state", "in", ("open", "done"))]
self.filtered_domain(skip_domain)._execute_on_registrations()
def _execute_on_registrations(self):
""" Private mail registration execution. We consider input is already
filtered at this point, allowing to let caller do optimizations when
managing batches of registrations. """
todo = self.filtered(
lambda r: r.scheduler_id.notification_type == "mail"
)
for scheduler, reg_mails in todo.grouped('scheduler_id').items():
scheduler._send_mail(reg_mails.registration_id)
todo.mail_sent = True
return todo
def _get_skip_domain(self):
""" Domain of mail registrations ot skip: not already done, linked to
a valid registration, and scheduled in the past. """
return [
("mail_sent", "=", False),
("scheduled_date", "!=", False),
("scheduled_date", "<=", self.env.cr.now()),
]
|
