odoo/openerp/addons/base/base_needaction.py

218 lines
10 KiB
Python

# -*- coding: utf-8 -*-
##############################################################################
#
# OpenERP, Open Source Management Solution
# Copyright (C) 2009-Today OpenERP SA (<http://www.openerp.com>)
#
# This program is free software: you can redistribute it and/or modify
# it under the terms of the GNU Affero General Public License as
# published by the Free Software Foundation, either version 3 of the
# License, or (at your option) any later version
#
# This program is distributed in the hope that it will be useful,
# but WITHOUT ANY WARRANTY; without even the implied warranty of
# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
# GNU Affero General Public License for more details
#
# You should have received a copy of the GNU Affero General Public License
# along with this program. If not, see <http://www.gnu.org/licenses/>
#
##############################################################################
import openerp.pooler as pooler
from osv import osv, fields
from tools.translate import _
class base_needaction_users_rel(osv.osv):
'''
base_needaction_users_rel holds data related to the needaction
mechanism inside OpenERP. A needaction is characterized by:
- res_model: model of the record requiring an action
- res_id: ID of the record requiring an action
- user_id: foreign key to the res.users table, to the user that
has to perform the action
'''
_name = 'base.needaction_users_rel'
_description = 'Needaction relationship table'
_rec_name = 'id'
_order = 'res_model asc'
_columns = {
'res_model': fields.char('Related Document Model', size=128,
select=1, required=True),
'res_id': fields.integer('Related Document ID',
select=1, required=True),
'user_id': fields.many2one('res.users', string='Related User',
ondelete='cascade', select=1, required=True),
}
class base_needaction(osv.osv):
'''Mixin class for objects using the need action feature.
Need action feature can be used by objects willing to be able to
signal that an action is required on a particular record. If in the
business logic an action must be performed by somebody, for instance
validation by a manager, this mechanism allows to set a list of
users asked ot perform an action.
This class wraps a table (base.needaction_users_rel) that behaves
like a many2many field. However, no field is added to the model
inheriting from base.needaction. The mixin class manages the low-level
considerations of updating relationships. Every change made on the
record calls a method that updates the relationships.
Objects using the need_action feature should override the
``get_needaction_user_ids`` method. This methods returns a dictionary
whose keys are record ids, and values a list of user ids, like
in a many2many relationship. Therefore by defining only one method,
you can specify if an action is required by defining the users
that have to do it, in every possible situation.
This class also offers several global services,:
- ``needaction_get_user_record_references``: for a given uid, get all
the records that ask this user to perform an action. Records
are given as references, a list of tuples (model_name, record_id).
- ``needaction_get_record_ids``: for a given model_name and uid, get
all record ids that ask this user to perform an action. This
mechanism is used for instance to display the number of pending
actions in menus, such as Leads (12).
- ``needaction_get_action_count``: as ``needaction_get_record_ids``
but returns only the number of action, not the ids (performs a
search with count=True)
'''
_name = 'base.needaction'
_description = 'Need action of users on records API'
_columns = {
}
#------------------------------------------------------
# need action relationship management
#------------------------------------------------------
def _get_user_ids(self, cr, uid, ids, context=None):
"""Given ids of model self._name, find the user_ids that have an action to perform"""
if context is None:
context = {}
needact_obj = self.pool.get('base.needaction_users_rel')
needact_ids = needact_obj.search(cr, uid, [('res_model', '=', self._nanme), ('res_id', 'in', ids)], context=context)
needacts = needact_obj.read(cr, uid, needact_ids, context=context)
return [needact['user_id'] for needact in needacts]
def _link_users(self, cr, uid, ids, user_ids, context=None):
"""Given ids of model self._name, add user_ids to the relationship table"""
if context is None:
context = {}
needact_obj = self.pool.get('base.needaction_users_rel')
for id in ids:
for user_id in user_ids:
needact_obj.create(cr, uid, {'res_model': self._name, 'res_id': id, 'user_id': user_id}, context=context)
return True
def _unlink_users(self, cr, uid, ids, context=None):
"""Given ids of model self._name, delete all entries in the relationship table"""
if context is None:
context = {}
needact_obj = self.pool.get('base.needaction_users_rel')
to_del_ids = needact_obj.search(cr, uid, [('res_model', '=', self._name), ('res_id', 'in', ids)], context=context)
return needact_obj.unlink(cr, uid, to_del_ids, context=context)
def _update_users(self, cr, uid, ids, user_ids, context=None):
"""Given ids of model self._name, update their entries in the relationship table to user_ids"""
if context is None:
context = {}
# unlink old records
self._unlink_users(cr, uid, ids, context=context)
# link new records
self._link_users(cr, uid, ids, user_ids, context=context)
return True
#------------------------------------------------------
# Addon API
#------------------------------------------------------
def get_needaction_user_ids(self, cr, uid, ids, context=None):
return dict.fromkeys(ids, [])
def create(self, cr, uid, values, context=None):
if context is None:
context = {}
# perform create
obj_id = super(base_needaction, self).create(cr, uid, values, context=context)
# link user_ids
needaction_user_ids = self.get_needaction_user_ids(cr, uid, [obj_id], context=context)
self._update_users(cr, uid, [obj_id], needaction_user_ids[obj_id], context=context)
return obj_id
def write(self, cr, uid, ids, values, context=None):
if context is None:
context = {}
# perform write
write_res = super(base_needaction, self).write(cr, uid, ids, values, context=context)
# get and update user_ids
needaction_user_ids = self.get_needaction_user_ids(cr, uid, ids, context=context)
for id in ids:
self._update_users(cr, uid, [id], needaction_user_ids[id], context=context)
return write_res
def unlink(self, cr, uid, ids, context=None):
if context is None:
context = {}
# unlink user_ids
self._unlink_users(cr, uid, ids, context=context)
# perform unlink
return super(base_needaction, self).unlink(cr, uid, ids, context=context)
#------------------------------------------------------
# Need action API
#------------------------------------------------------
@classmethod
def needaction_get_user_ids(cls, cr, uid, model_name, user_id, context=None):
"""Given a model
get the user_ids that have to perform at least one action"""
if context is None:
context = {}
need_act_obj = pooler.get_pool(cr.dbname).get('base.needaction_users_rel')
need_act_ids = need_act_obj.search(cr, uid, [('res_model', '=', model)], context=context)
need_acts = need_act_obj.read(cr, uid, need_act_ids, context=context)
return list(set([need_act['user_id'] for need_act in need_acts]))
@classmethod
def needaction_get_record_ids(cls, cr, uid, model_name, user_id, limit=80, context=None):
"""Given a model and a user_id
get the number of actions it has to perform"""
if context is None:
context = {}
need_act_obj = pooler.get_pool(cr.dbname).get('base.needaction_users_rel')
need_act_ids = need_act_obj.search(cr, uid, [('res_model', '=', model_name), ('user_id', '=', user_id)], limit=limit, context=context)
return [need_act['res_id'] for need_act in need_act_obj.read(cr, uid, need_act_ids, context=context)]
@classmethod
def needaction_get_action_count(cls, cr, uid, model_name, user_id, limit=80, context=None):
"""Given a model and a user_id
get the number of actions it has to perform"""
if context is None:
context = {}
need_act_obj = pooler.get_pool(cr.dbname).get('base.needaction_users_rel')
return need_act_obj.search(cr, uid, [('res_model', '=', model_name), ('user_id', '=', user_id)], limit=limit, count=True, context=context)
@classmethod
def needaction_get_record_references(cls, cr, uid, user_id, offset=None, limit=None, order=None, context=None):
"""General method
For a given user_id, get all the records that asks this user to
perform an action. Records are given as references, a list of
tuples (model_name, record_id).
This method is trans-model."""
if context is None:
context = {}
need_act_obj = pooler.get_pool(cr.dbname).get('base.needaction_users_rel')
need_act_ids = need_act_obj.search(cr, uid, [('user_id', '=', user_id)], offset=offset, limit=limit, order=order, context=context)
need_acts = need_act_obj.browse(cr, uid, need_act_ids, context=context)
record_references = [(need_act.res_model, need_act.res_id) for need_act in need_acts]
return record_references
# vim:expandtab:smartindent:tabstop=4:softtabstop=4:shiftwidth=4: