46 lines
2.1 KiB
Python
46 lines
2.1 KiB
Python
|
# 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.
|