summaryrefslogtreecommitdiff
path: root/odoo/addons/base/workflow/workflow.py
diff options
context:
space:
mode:
Diffstat (limited to 'odoo/addons/base/workflow/workflow.py')
-rw-r--r--odoo/addons/base/workflow/workflow.py185
1 files changed, 0 insertions, 185 deletions
diff --git a/odoo/addons/base/workflow/workflow.py b/odoo/addons/base/workflow/workflow.py
deleted file mode 100644
index 18eeb5002eb..00000000000
--- a/odoo/addons/base/workflow/workflow.py
+++ /dev/null
@@ -1,185 +0,0 @@
-# -*- coding: utf-8 -*-
-# Part of Odoo. See LICENSE file for full copyright and licensing details.
-
-from odoo import api, fields, models, _
-from odoo.exceptions import UserError
-import odoo.workflow
-
-
-class Workflow(models.Model):
- _name = "workflow"
- _table = "wkf"
- _order = "name"
-
- 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"))
-
- @api.multi
- def write(self, vals):
- odoo.workflow.clear_cache(self._cr, self._uid)
- return super(Workflow, self).write(vals)
-
- @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:
- 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()
-
- 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}
-
- @api.model
- def create(self, vals):
- odoo.workflow.clear_cache(self._cr, self._uid)
- return super(Workflow, self).create(vals)
-
-
-class WorkflowActivity(models.Model):
- _name = "workflow.activity"
- _table = "wkf_activity"
- _order = "name"
-
- 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(WorkflowActivity, self).unlink()
-
-
-class WorkflowTransition(models.Model):
- _name = "workflow.transition"
- _table = "wkf_transition"
- _rec_name = 'signal'
- _order = 'sequence,id'
-
- 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')
-
- @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:
- 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)
-
-
-class WorkflowInstance(models.Model):
- _name = "workflow.instance"
- _table = "wkf_instance"
- _rec_name = 'res_type'
- _log_access = False
-
- 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):
- res = 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=%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)')
- return res
-
-
-class WorkflowWorkitem(models.Model):
- _name = "workflow.workitem"
- _table = "wkf_workitem"
- _rec_name = 'state'
- _log_access = False
-
- 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):
- res = 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)')
- return res
generated by cgit v1.2.3 (git 2.25.1) at 2026-10-23 18:02:28 +0000