You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
86 lines
3.4 KiB
86 lines
3.4 KiB
# Copyright 2017 Tecnativa - Jairo Llopis
|
|
# License AGPL-3.0 or later (https://www.gnu.org/licenses/agpl).
|
|
|
|
from odoo import api, fields, models
|
|
from odoo.tools import safe_eval
|
|
|
|
|
|
class MassMailingList(models.Model):
|
|
_inherit = "mail.mass_mailing.list"
|
|
|
|
dynamic = fields.Boolean(
|
|
help="Set this list as dynamic, to make it autosynchronized with "
|
|
"partners from a given criteria.",
|
|
)
|
|
sync_method = fields.Selection(
|
|
[
|
|
("add", "Only add new records"),
|
|
("full", "Add and remove records as needed"),
|
|
],
|
|
default="add",
|
|
required=True,
|
|
help="Choose the syncronization method for this list if you want to "
|
|
"make it dynamic",
|
|
)
|
|
sync_domain = fields.Char(
|
|
string="Synchronization critera",
|
|
default="[('opt_out', '=', False), ('email', '!=', False)]",
|
|
required=True,
|
|
help="Filter partners to sync in this list",
|
|
)
|
|
is_synced = fields.Boolean(
|
|
help="Helper field to make the user aware of unsynced changes",
|
|
default=True,
|
|
)
|
|
|
|
def action_sync(self):
|
|
"""Sync contacts in dynamic lists."""
|
|
Contact = self.env["mail.mass_mailing.contact"].with_context(
|
|
syncing=True,
|
|
)
|
|
Partner = self.env["res.partner"]
|
|
# Skip non-dynamic lists
|
|
dynamic = self.filtered("dynamic")
|
|
for one in dynamic:
|
|
sync_domain = safe_eval(one.sync_domain) + [("email", "!=", False)]
|
|
desired_partners = Partner.search(sync_domain)
|
|
# Remove undesired contacts when synchronization is full
|
|
if one.sync_method == "full":
|
|
contacts = Contact.search([("list_ids", "in", [one.id]),
|
|
("partner_id", "not in",
|
|
desired_partners.ids)])
|
|
for contact in contacts:
|
|
# No delete contacts with other lists
|
|
if len(contact.list_ids) > 1:
|
|
contact.write({'list_ids': [(3, one.id, False)]})
|
|
else:
|
|
contact.unlink()
|
|
current_contacts_in_list = \
|
|
Contact.search([("list_ids", "in", [one.id])])
|
|
current_partners_in_list = \
|
|
current_contacts_in_list.mapped("partner_id")
|
|
current_contacts_not_in_list = \
|
|
Contact.search([("partner_id", "in", desired_partners.ids),
|
|
("list_ids", "not in", [one.id])])
|
|
current_partners_not_in_list = \
|
|
current_contacts_not_in_list.mapped("partner_id")
|
|
# Add new contacts
|
|
for partner in desired_partners - current_partners_in_list - \
|
|
current_partners_not_in_list:
|
|
Contact.create({
|
|
"list_ids": [(4, one.id, False)],
|
|
"partner_id": partner.id,
|
|
})
|
|
# Add list in existing contacts
|
|
for contact in current_contacts_not_in_list:
|
|
contact.write({
|
|
"list_ids": [(4, one.id, False)],
|
|
})
|
|
one.is_synced = True
|
|
# Invalidate cached contact count
|
|
self.invalidate_cache(["contact_nbr"], dynamic.ids)
|
|
|
|
@api.onchange("dynamic", "sync_method", "sync_domain")
|
|
def _onchange_dynamic(self):
|
|
if self.dynamic:
|
|
self.is_synced = False
|