mirror of https://github.com/OCA/web.git
129 lines
3.9 KiB
Python
129 lines
3.9 KiB
Python
# Copyright 2016 ACSONE SA/NV
|
|
# License AGPL-3.0 or later (http://www.gnu.org/licenses/agpl).
|
|
from odoo import _, api, exceptions, fields, models
|
|
|
|
from odoo.addons.bus.models.bus import channel_with_db, json_dump
|
|
from odoo.addons.web.controllers.main import clean_action
|
|
|
|
DEFAULT_MESSAGE = "Default message"
|
|
|
|
SUCCESS = "success"
|
|
DANGER = "danger"
|
|
WARNING = "warning"
|
|
INFO = "info"
|
|
DEFAULT = "default"
|
|
|
|
|
|
class ResUsers(models.Model):
|
|
_inherit = "res.users"
|
|
|
|
@api.depends("create_date")
|
|
def _compute_channel_names(self):
|
|
for record in self:
|
|
record.notify_success_channel_name = json_dump(
|
|
channel_with_db(self.env.cr.dbname, record.partner_id)
|
|
)
|
|
record.notify_danger_channel_name = json_dump(
|
|
channel_with_db(self.env.cr.dbname, record.partner_id)
|
|
)
|
|
record.notify_warning_channel_name = json_dump(
|
|
channel_with_db(self.env.cr.dbname, record.partner_id)
|
|
)
|
|
record.notify_info_channel_name = json_dump(
|
|
channel_with_db(self.env.cr.dbname, record.partner_id)
|
|
)
|
|
record.notify_default_channel_name = json_dump(
|
|
channel_with_db(self.env.cr.dbname, record.partner_id)
|
|
)
|
|
|
|
notify_success_channel_name = fields.Char(compute="_compute_channel_names")
|
|
notify_danger_channel_name = fields.Char(compute="_compute_channel_names")
|
|
notify_warning_channel_name = fields.Char(compute="_compute_channel_names")
|
|
notify_info_channel_name = fields.Char(compute="_compute_channel_names")
|
|
notify_default_channel_name = fields.Char(compute="_compute_channel_names")
|
|
|
|
def notify_success(
|
|
self,
|
|
message="Default message",
|
|
title=None,
|
|
sticky=False,
|
|
target=None,
|
|
action=None,
|
|
):
|
|
title = title or _("Success")
|
|
self._notify_channel(SUCCESS, message, title, sticky, target, action)
|
|
|
|
def notify_danger(
|
|
self,
|
|
message="Default message",
|
|
title=None,
|
|
sticky=False,
|
|
target=None,
|
|
action=None,
|
|
):
|
|
title = title or _("Danger")
|
|
self._notify_channel(DANGER, message, title, sticky, target, action)
|
|
|
|
def notify_warning(
|
|
self,
|
|
message="Default message",
|
|
title=None,
|
|
sticky=False,
|
|
target=None,
|
|
action=None,
|
|
):
|
|
title = title or _("Warning")
|
|
self._notify_channel(WARNING, message, title, sticky, target, action)
|
|
|
|
def notify_info(
|
|
self,
|
|
message="Default message",
|
|
title=None,
|
|
sticky=False,
|
|
target=None,
|
|
action=None,
|
|
):
|
|
title = title or _("Information")
|
|
self._notify_channel(INFO, message, title, sticky, target, action)
|
|
|
|
def notify_default(
|
|
self,
|
|
message="Default message",
|
|
title=None,
|
|
sticky=False,
|
|
target=None,
|
|
action=None,
|
|
):
|
|
title = title or _("Default")
|
|
self._notify_channel(DEFAULT, message, title, sticky, target, action)
|
|
|
|
def _notify_channel(
|
|
self,
|
|
type_message=DEFAULT,
|
|
message=DEFAULT_MESSAGE,
|
|
title=None,
|
|
sticky=False,
|
|
target=None,
|
|
action=None,
|
|
):
|
|
if not (self.env.user._is_admin() or self.env.su) and any(
|
|
user.id != self.env.uid for user in self
|
|
):
|
|
raise exceptions.UserError(
|
|
_("Sending a notification to another user is forbidden.")
|
|
)
|
|
if not target:
|
|
target = self.partner_id
|
|
if action:
|
|
action = clean_action(action, self.env)
|
|
bus_message = {
|
|
"type": type_message,
|
|
"message": message,
|
|
"title": title,
|
|
"sticky": sticky,
|
|
"action": action,
|
|
}
|
|
|
|
notifications = [[partner, "web.notify", [bus_message]] for partner in target]
|
|
self.env["bus.bus"]._sendmany(notifications)
|