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
|
# Part of Odoo. See LICENSE file for full copyright and licensing details.
from odoo import api, fields, models
from odoo.tools.misc import str2bool
class SaleOrder(models.Model):
_inherit = 'sale.order'
pending_email_template_id = fields.Many2one(
string="Pending Email Template",
help="The template of the pending email that must be sent asynchronously.",
comodel_name='mail.template',
ondelete='set null',
readonly=True,
)
def _send_order_notification_mail(self, mail_template):
""" Override of `sale` to reschedule order status emails to be sent asynchronously. """
async_send = str2bool(self.env['ir.config_parameter'].sudo().get_param('sale.async_emails'))
cron = async_send and self.env.ref('sale_async_emails.cron', raise_if_not_found=False)
if async_send and cron and not self.env.context.get('is_async_email', False):
# Schedule the email to be sent asynchronously.
self.pending_email_template_id = mail_template
cron._trigger()
else: # We are in the cron job, or the user has disabled async emails.
super()._send_order_notification_mail(mail_template) # Send the email synchronously.
@api.model
def _cron_send_pending_emails(self, auto_commit=True):
""" Find and send pending order status emails asynchronously.
:param bool auto_commit: Whether the database cursor should be committed as soon as an email
is sent. Set to False in unit tests.
:return: None
"""
pending_email_orders = self.search([('pending_email_template_id', '!=', False)])
for order in pending_email_orders:
order = order[0] # Avoid pre-fetching after each cache invalidation due to committing.
order.with_context(is_async_email=True)._send_order_notification_mail(
order.pending_email_template_id
) # Asynchronously resume the email sending.
order.pending_email_template_id = None
if auto_commit:
self.env.cr.commit() # Save progress in case the cron is killed.
|
