From 47c44578baea30c75dcfe520bcea858287b2bb7b Mon Sep 17 00:00:00 2001 From: Raphael Collet Date: Wed, 4 May 2016 10:23:44 +0200 Subject: [PATCH] [MIG] base/workflow --- openerp/addons/base/workflow/workflow.py | 268 +++++++++++------------ 1 file changed, 134 insertions(+), 134 deletions(-) diff --git a/openerp/addons/base/workflow/workflow.py b/openerp/addons/base/workflow/workflow.py index c59aa40a60c..b1b6e1a89c2 100644 --- a/openerp/addons/base/workflow/workflow.py +++ b/openerp/addons/base/workflow/workflow.py @@ -1,183 +1,183 @@ # -*- coding: utf-8 -*- # Part of Odoo. See LICENSE file for full copyright and licensing details. -from openerp.exceptions import UserError -from openerp.osv import fields, osv -from openerp.tools.translate import _ -import openerp.workflow +from odoo import api, fields, models, _ +from odoo.exceptions import UserError +import odoo.workflow -class workflow(osv.osv): + +class Workflow(models.Model): _name = "workflow" _table = "wkf" _order = "name" - _columns = { - 'name': fields.char('Name', required=True), - 'osv': fields.char('Resource Object', required=True,select=True), - 'on_create': fields.boolean('On Create', select=True), - 'activities': fields.one2many('workflow.activity', 'wkf_id', 'Activities'), - } - _defaults = { - 'on_create': lambda *a: True - } - def copy(self, cr, uid, id, values, context=None): + name = fields.Char('Name', required=True) + osv = fields.Char('Resource Object', required=True, index=True) + on_create = fields.Boolean('On Create', default=True, index=True) + activities = fields.One2many('workflow.activity', 'wkf_id', string='Activities') + + @api.multi + def copy(self, values): raise UserError(_("Duplicating workflows is not possible, please create a new workflow")) - def write(self, cr, user, ids, vals, context=None): - if not context: - context={} - openerp.workflow.clear_cache(cr, user) - return super(workflow, self).write(cr, user, ids, vals, context=context) + @api.multi + def write(self, vals): + odoo.workflow.clear_cache(self._cr, self._uid) + return super(Workflow, self).write(vals) - def get_active_workitems(self, cr, uid, res, res_id, context=None): - cr.execute('select * from wkf where osv=%s limit 1',(res,)) + @api.model + def get_active_workitems(self, res_model, res_id): + cr = self._cr + cr.execute("SELECT * FROM wkf WHERE osv=%s LIMIT 1", (res_model,)) wkfinfo = cr.dictfetchone() workitems = [] if wkfinfo: - cr.execute('SELECT id FROM wkf_instance \ - WHERE res_id=%s AND wkf_id=%s \ - ORDER BY state LIMIT 1', - (res_id, wkfinfo['id'])) + query = """ SELECT id FROM wkf_instance + WHERE res_id=%s AND wkf_id=%s + ORDER BY state LIMIT 1 """ + cr.execute(query, (res_id, wkfinfo['id'])) inst_id = cr.fetchone() - cr.execute('select act_id,count(*) from wkf_workitem where inst_id=%s group by act_id', (inst_id,)) + query = """ SELECT act_id, COUNT(*) FROM wkf_workitem + WHERE inst_id=%s GROUP BY act_id """ + cr.execute(query, (inst_id,)) workitems = dict(cr.fetchall()) - return {'wkf': wkfinfo, 'workitems': workitems} + return {'wkf': wkfinfo, 'workitems': workitems} - def create(self, cr, user, vals, context=None): - if not context: - context={} - openerp.workflow.clear_cache(cr, user) - return super(workflow, self).create(cr, user, vals, context=context) + @api.model + def create(self, vals): + odoo.workflow.clear_cache(self._cr, self._uid) + return super(Workflow, self).create(vals) -workflow() -class wkf_activity(osv.osv): +class WorkflowActivity(models.Model): _name = "workflow.activity" _table = "wkf_activity" _order = "name" - _columns = { - 'name': fields.char('Name', required=True), - 'wkf_id': fields.many2one('workflow', 'Workflow', required=True, select=True, ondelete='cascade'), - 'split_mode': fields.selection([('XOR', 'Xor'), ('OR','Or'), ('AND','And')], 'Split Mode', size=3, required=True), - 'join_mode': fields.selection([('XOR', 'Xor'), ('AND', 'And')], 'Join Mode', size=3, required=True), - 'kind': fields.selection([('dummy', 'Dummy'), ('function', 'Function'), ('subflow', 'Subflow'), ('stopall', 'Stop All')], 'Kind', required=True), - 'action': fields.text('Python Action'), - 'action_id': fields.many2one('ir.actions.server', 'Server Action', ondelete='set null'), - 'flow_start': fields.boolean('Flow Start'), - 'flow_stop': fields.boolean('Flow Stop'), - 'subflow_id': fields.many2one('workflow', 'Subflow'), - 'signal_send': fields.char('Signal (subflow.*)'), - 'out_transitions': fields.one2many('workflow.transition', 'act_from', 'Outgoing Transitions'), - 'in_transitions': fields.one2many('workflow.transition', 'act_to', 'Incoming Transitions'), - } - _defaults = { - 'kind': lambda *a: 'dummy', - 'join_mode': lambda *a: 'XOR', - 'split_mode': lambda *a: 'XOR', - } - def unlink(self, cr, uid, ids, context=None): - if context is None: context = {} - if not context.get('_force_unlink') and self.pool.get('workflow.workitem').search(cr, uid, [('act_id', 'in', ids)]): + name = fields.Char('Name', required=True) + wkf_id = fields.Many2one('workflow', string='Workflow', ondelete='cascade', + required=True, index=True) + split_mode = fields.Selection([('XOR', 'Xor'), ('OR','Or'), ('AND','And')], + string='Split Mode', size=3, required=True, default='XOR') + join_mode = fields.Selection([('XOR', 'Xor'), ('AND', 'And')], + string='Join Mode', size=3, required=True, default='XOR') + kind = fields.Selection([('dummy', 'Dummy'), ('function', 'Function'), + ('subflow', 'Subflow'), ('stopall', 'Stop All')], + string='Kind', required=True, default='dummy') + action = fields.Text('Python Action') + action_id = fields.Many2one('ir.actions.server', string='Server Action', ondelete='set null') + flow_start = fields.Boolean('Flow Start') + flow_stop = fields.Boolean('Flow Stop') + subflow_id = fields.Many2one('workflow', string='Subflow') + signal_send = fields.Char('Signal (subflow.*)') + out_transitions = fields.One2many('workflow.transition', 'act_from', string='Outgoing Transitions') + in_transitions = fields.One2many('workflow.transition', 'act_to', string='Incoming Transitions') + + @api.multi + def unlink(self): + if not self._context.get('_force_unlink') and \ + self.env['workflow.workitem'].search([('act_id', 'in', self.ids)]): raise UserError(_('Please make sure no workitems refer to an activity before deleting it!')) - super(wkf_activity, self).unlink(cr, uid, ids, context=context) + super(WorkflowActivity, self).unlink() -wkf_activity() -class wkf_transition(osv.osv): - _table = "wkf_transition" +class WorkflowTransition(models.Model): _name = "workflow.transition" + _table = "wkf_transition" _rec_name = 'signal' - _columns = { - 'trigger_model': fields.char('Trigger Object'), - 'trigger_expr_id': fields.char('Trigger Expression'), - 'sequence': fields.integer('Sequence'), - 'signal': fields.char('Signal (Button Name)', - help="When the operation of transition comes from a button pressed in the client form, "\ - "signal tests the name of the pressed button. If signal is NULL, no button is necessary to validate this transition."), - 'group_id': fields.many2one('res.groups', 'Group Required', - help="The group that a user must have to be authorized to validate this transition."), - 'condition': fields.char('Condition', required=True, - help="Expression to be satisfied if we want the transition done."), - 'act_from': fields.many2one('workflow.activity', 'Source Activity', required=True, select=True, ondelete='cascade', - help="Source activity. When this activity is over, the condition is tested to determine if we can start the ACT_TO activity."), - 'act_to': fields.many2one('workflow.activity', 'Destination Activity', required=True, select=True, ondelete='cascade', - help="The destination activity."), - 'wkf_id': fields.related('act_from','wkf_id', type='many2one', relation='workflow', string='Workflow', select=True), - } - _defaults = { - 'condition': lambda *a: 'True', - 'sequence': 10, - } - _order = 'sequence,id' - def name_get(self, cr, uid, ids, context=None): - return [(line.id, (line.act_from.name) + '+' + (line.act_to.name)) if line.signal == False else (line.id, line.signal) for line in self.browse(cr, uid, ids, context=context)] + trigger_model = fields.Char('Trigger Object') + trigger_expr_id = fields.Char('Trigger Expression') + sequence = fields.Integer('Sequence', default=10) + signal = fields.Char('Signal (Button Name)', + help="When the operation of transition comes from a button pressed in the client form, " + "signal tests the name of the pressed button. If signal is NULL, no button is necessary to validate this transition.") + group_id = fields.Many2one('res.groups', string='Group Required', + help="The group that a user must have to be authorized to validate this transition.") + condition = fields.Char('Condition', required=True, default='True', + help="Expression to be satisfied if we want the transition done.") + act_from = fields.Many2one('workflow.activity', string='Source Activity', + ondelete='cascade', required=True, index=True, + help="Source activity. When this activity is over, the condition is tested to determine if we can start the ACT_TO activity.") + act_to = fields.Many2one('workflow.activity', string='Destination Activity', + ondelete='cascade', required=True, index=True, + help="The destination activity.") + wkf_id = fields.Many2one('workflow', related='act_from.wkf_id', string='Workflow') - def name_search(self, cr, user, name, args=None, operator='ilike', context=None, limit=100): - if args is None: - args = [] + @api.multi + def name_get(self): + return [ + (line.id, line.signal or "%s+%s" % (line.act_from.name, line.act_to.name)) + for line in self + ] + + @api.model + def name_search(self, name, args=None, operator='ilike', limit=100): if name: - ids = self.search(cr, user, ['|',('act_from', operator, name),('act_to', operator, name)] + args, limit=limit) - return self.name_get(cr, user, ids, context=context) - return super(wkf_transition, self).name_search(cr, user, name, args=args, operator=operator, context=context, limit=limit) + domain = ['|', ('act_from', operator, name), ('act_to', operator, name)] + (args or []) + return self.search(domain, limit=limit).name_get() + return super(WorkflowTransition, self).name_search(name, args, operator, limit=limit) -wkf_transition() - -class wkf_instance(osv.osv): - _table = "wkf_instance" +class WorkflowInstance(models.Model): _name = "workflow.instance" + _table = "wkf_instance" _rec_name = 'res_type' _log_access = False - _columns = { - 'uid': fields.integer('User'), # FIXME no constraint?? - 'wkf_id': fields.many2one('workflow', 'Workflow', ondelete='cascade', select=True), - 'res_id': fields.integer('Resource ID'), - 'res_type': fields.char('Resource Object'), - 'state': fields.char('Status'), - 'transition_ids': fields.many2many('workflow.transition', 'wkf_witm_trans', 'inst_id', 'trans_id'), - } - def _auto_init(self, cr, context=None): - super(wkf_instance, self)._auto_init(cr, context) - cr.execute('SELECT indexname FROM pg_indexes WHERE indexname = \'wkf_instance_res_type_res_id_state_index\'') + + uid = fields.Integer('User') # FIXME no constraint?? + wkf_id = fields.Many2one('workflow', string='Workflow', ondelete='cascade', index=True) + res_id = fields.Integer('Resource ID') + res_type = fields.Char('Resource Object') + state = fields.Char('Status') + transition_ids = fields.Many2many('workflow.transition', 'wkf_witm_trans', 'inst_id', 'trans_id') + + @api.model_cr_context + def _auto_init(self): + super(WorkflowInstance, self)._auto_init() + cr = self._cr + cr.execute('SELECT indexname FROM pg_indexes WHERE indexname=%s', ['wkf_instance_res_type_res_id_state_index']) if not cr.fetchone(): cr.execute('CREATE INDEX wkf_instance_res_type_res_id_state_index ON wkf_instance (res_type, res_id, state)') - cr.execute('SELECT indexname FROM pg_indexes WHERE indexname = \'wkf_instance_res_id_wkf_id_index\'') + cr.execute('SELECT indexname FROM pg_indexes WHERE indexname=%s', ['wkf_instance_res_id_wkf_id_index']) if not cr.fetchone(): cr.execute('CREATE INDEX wkf_instance_res_id_wkf_id_index ON wkf_instance (res_id, wkf_id)') -wkf_instance() -class wkf_workitem(osv.osv): - _table = "wkf_workitem" +class WorkflowWorkitem(models.Model): _name = "workflow.workitem" - _log_access = False + _table = "wkf_workitem" _rec_name = 'state' - _columns = { - 'act_id': fields.many2one('workflow.activity', 'Activity', required=True, ondelete="cascade", select=True), - 'wkf_id': fields.related('act_id','wkf_id', type='many2one', relation='workflow', string='Workflow'), - 'subflow_id': fields.many2one('workflow.instance', 'Subflow', ondelete="set null", select=True), - 'inst_id': fields.many2one('workflow.instance', 'Instance', required=True, ondelete="cascade", select=True), - 'state': fields.char('Status', select=True), - } -wkf_workitem() - -class wkf_triggers(osv.osv): - _table = "wkf_triggers" - _name = "workflow.triggers" _log_access = False - _columns = { - 'res_id': fields.integer('Resource ID', size=128), - 'model': fields.char('Object'), - 'instance_id': fields.many2one('workflow.instance', 'Destination Instance', ondelete="cascade"), - 'workitem_id': fields.many2one('workflow.workitem', 'Workitem', required=True, ondelete="cascade"), - } - def _auto_init(self, cr, context=None): - super(wkf_triggers, self)._auto_init(cr, context) - cr.execute('SELECT indexname FROM pg_indexes WHERE indexname = \'wkf_triggers_res_id_model_index\'') + + act_id = fields.Many2one('workflow.activity', string='Activity', + ondelete="cascade", required=True, index=True) + wkf_id = fields.Many2one('workflow', related='act_id.wkf_id', string='Workflow') + subflow_id = fields.Many2one('workflow.instance', string='Subflow', + ondelete="set null", index=True) + inst_id = fields.Many2one('workflow.instance', string='Instance', + ondelete="cascade", required=True, index=True) + state = fields.Char('Status', index=True) + + +class WorkflowTriggers(models.Model): + _name = "workflow.triggers" + _table = "wkf_triggers" + _log_access = False + + res_id = fields.Integer('Resource ID', size=128) + model = fields.Char('Object') + instance_id = fields.Many2one('workflow.instance', string='Destination Instance', + ondelete="cascade") + workitem_id = fields.Many2one('workflow.workitem', string='Workitem', + ondelete="cascade", required=True) + + @api.model_cr_context + def _auto_init(self): + super(WorkflowTriggers, self)._auto_init() + cr = self._cr + cr.execute('SELECT indexname FROM pg_indexes WHERE indexname=%s', ['wkf_triggers_res_id_model_index']) if not cr.fetchone(): cr.execute('CREATE INDEX wkf_triggers_res_id_model_index ON wkf_triggers (res_id, model)') -wkf_triggers()