94 lines
4.0 KiB
Python
94 lines
4.0 KiB
Python
|
# -*- coding: utf-8 -*-
|
||
|
|
# Part of Odoo. See LICENSE file for full copyright and licensing details.
|
||
|
|
|
||
|
|
import werkzeug.urls
|
||
|
|
|
||
|
|
from odoo import _, Command, fields, models
|
||
|
|
|
||
|
|
|
||
|
|
class SMSComposer(models.TransientModel):
|
||
|
|
_inherit = 'sms.composer'
|
||
|
|
|
||
|
|
# mass mode with mass sms
|
||
|
|
mass_sms_allow_unsubscribe = fields.Boolean('Include opt-out link', default=True)
|
||
|
|
mailing_id = fields.Many2one('mailing.mailing', string='Mailing')
|
||
|
|
utm_campaign_id = fields.Many2one('utm.campaign', string='Campaign', ondelete='set null')
|
||
|
|
|
||
|
|
# ------------------------------------------------------------
|
||
|
|
# Mass mode specific
|
||
|
|
# ------------------------------------------------------------
|
||
|
|
|
||
|
|
def _get_unsubscribe_url(self, res_id, trace_code, number):
|
||
|
|
return werkzeug.urls.url_join(
|
||
|
|
self.get_base_url(),
|
||
|
|
'/sms/%s/%s' % (self.mailing_id.id, trace_code)
|
||
|
|
)
|
||
|
|
|
||
|
|
def _prepare_mass_sms_trace_values(self, record, sms_values):
|
||
|
|
trace_code = self.env['mailing.trace']._get_random_code()
|
||
|
|
trace_values = {
|
||
|
|
'mass_mailing_id': self.mailing_id.id,
|
||
|
|
'model': self.res_model,
|
||
|
|
'res_id': record.id,
|
||
|
|
'sms_code': trace_code,
|
||
|
|
'sms_number': sms_values['number'],
|
||
|
|
'sms_tracker_ids': [Command.create({'sms_uuid': sms_values['uuid']})],
|
||
|
|
'trace_type': 'sms',
|
||
|
|
}
|
||
|
|
if sms_values['state'] == 'error':
|
||
|
|
trace_values['failure_type'] = sms_values['failure_type']
|
||
|
|
trace_values['trace_status'] = 'error'
|
||
|
|
elif sms_values['state'] == 'canceled':
|
||
|
|
trace_values['failure_type'] = sms_values['failure_type']
|
||
|
|
trace_values['trace_status'] = 'cancel'
|
||
|
|
else:
|
||
|
|
if self.mass_sms_allow_unsubscribe:
|
||
|
|
sms_values['body'] = '%s\n%s' % (sms_values['body'] or '', _('STOP SMS: %s', self._get_unsubscribe_url(record.id, trace_code, sms_values['number'])))
|
||
|
|
return trace_values
|
||
|
|
|
||
|
|
def _get_optout_record_ids(self, records, recipients_info):
|
||
|
|
""" Fetch opt-out records based on mailing. """
|
||
|
|
res = super(SMSComposer, self)._get_optout_record_ids(records, recipients_info)
|
||
|
|
if self.mailing_id:
|
||
|
|
optout_res_ids = self.mailing_id._get_opt_out_list_sms()
|
||
|
|
res += optout_res_ids
|
||
|
|
return res
|
||
|
|
|
||
|
|
def _get_done_record_ids(self, records, recipients_info):
|
||
|
|
""" A/B testing could lead to records having been already mailed. """
|
||
|
|
res = super(SMSComposer, self)._get_done_record_ids(records, recipients_info)
|
||
|
|
if self.mailing_id:
|
||
|
|
seen_ids, seen_list = self.mailing_id._get_seen_list_sms()
|
||
|
|
res += seen_ids
|
||
|
|
return res
|
||
|
|
|
||
|
|
def _prepare_body_values(self, records):
|
||
|
|
all_bodies = super(SMSComposer, self)._prepare_body_values(records)
|
||
|
|
if self.mailing_id:
|
||
|
|
tracker_values = self.mailing_id._get_link_tracker_values()
|
||
|
|
for sms_id, body in all_bodies.items():
|
||
|
|
body = self.env['mail.render.mixin'].sudo()._shorten_links_text(body, tracker_values)
|
||
|
|
all_bodies[sms_id] = body
|
||
|
|
return all_bodies
|
||
|
|
|
||
|
|
def _prepare_mass_sms_values(self, records):
|
||
|
|
result = super(SMSComposer, self)._prepare_mass_sms_values(records)
|
||
|
|
if self.composition_mode == 'mass' and self.mailing_id:
|
||
|
|
for record in records:
|
||
|
|
sms_values = result[record.id]
|
||
|
|
|
||
|
|
trace_values = self._prepare_mass_sms_trace_values(record, sms_values)
|
||
|
|
sms_values.update({
|
||
|
|
'mailing_id': self.mailing_id.id,
|
||
|
|
'mailing_trace_ids': [(0, 0, trace_values)],
|
||
|
|
})
|
||
|
|
return result
|
||
|
|
|
||
|
|
def _prepare_mass_sms(self, records, sms_record_values):
|
||
|
|
sms_all = super(SMSComposer, self)._prepare_mass_sms(records, sms_record_values)
|
||
|
|
if self.mailing_id:
|
||
|
|
updated_bodies = sms_all._update_body_short_links()
|
||
|
|
for sms in sms_all:
|
||
|
|
sms.body = updated_bodies[sms.id]
|
||
|
|
return sms_all
|