Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Support
Keyboard shortcuts
?
Submit feedback
Contribute to GitLab
Sign in / Register
Toggle navigation
erp5
Project overview
Project overview
Details
Activity
Releases
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Issues
0
Issues
0
List
Boards
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Analytics
Analytics
CI / CD
Repository
Value Stream
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
Lukas Niegsch
erp5
Commits
b72a4f65
Commit
b72a4f65
authored
Mar 09, 2015
by
wenjie.zheng
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
Transition.py: Add WorkflowHistoryList class which contains maximum 16 workflow history.
parent
a219c459
Changes
1
Show whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
120 additions
and
10 deletions
+120
-10
product/ERP5Workflow/Document/Transition.py
product/ERP5Workflow/Document/Transition.py
+120
-10
No files found.
product/ERP5Workflow/Document/Transition.py
View file @
b72a4f65
...
@@ -27,15 +27,17 @@
...
@@ -27,15 +27,17 @@
##############################################################################
##############################################################################
from
AccessControl
import
ClassSecurityInfo
from
AccessControl
import
ClassSecurityInfo
from
Acquisition
import
aq_base
from
Products.ERP5Type
import
Permissions
,
PropertySheet
from
Products.ERP5Type
import
Permissions
,
PropertySheet
from
Products.ERP5Type.XMLObject
import
XMLObject
from
Products.ERP5Type.XMLObject
import
XMLObject
from
Products.ERP5Type.Accessor.Base
import
_evaluateTales
from
Products.ERP5Type.Accessor.Base
import
_evaluateTales
from
Products.ERP5Type.Globals
import
PersistentMapping
from
Products.DCWorkflow.Expression
import
StateChangeInfo
from
Products.DCWorkflow.Expression
import
StateChangeInfo
from
zLOG
import
LOG
,
ERROR
,
DEBUG
,
WARNING
from
zLOG
import
LOG
,
ERROR
,
DEBUG
,
WARNING
from
Products.ERP5Type.Utils
import
convertToUpperCase
,
convertToMixedCase
from
Products.ERP5Type.Utils
import
convertToUpperCase
,
convertToMixedCase
from
Products.DCWorkflow.DCWorkflow
import
ObjectDeleted
,
ObjectMoved
from
Products.DCWorkflow.DCWorkflow
import
ObjectDeleted
,
ObjectMoved
from
copy
import
deepcopy
from
copy
import
deepcopy
from
Persistence
import
Persistent
class
Transition
(
XMLObject
):
class
Transition
(
XMLObject
):
"""
"""
...
@@ -120,6 +122,7 @@ class Transition(XMLObject):
...
@@ -120,6 +122,7 @@ class Transition(XMLObject):
# Do not proceed in case of failure of before script
# Do not proceed in case of failure of before script
if
not
before_script_success
:
if
not
before_script_success
:
former_status
=
old_state
# Remain in state
former_status
=
old_state
# Remain in state
self
.
setStatusOf
(
workflow
.
getId
(),
document
,
status_dict
)
sci
=
StateChangeInfo
(
sci
=
StateChangeInfo
(
document
,
workflow
,
former_status
,
self
,
old_sdef
,
new_sdef
,
kwargs
)
document
,
workflow
,
former_status
,
self
,
old_sdef
,
new_sdef
,
kwargs
)
# put the error message in the workflow history
# put the error message in the workflow history
...
@@ -160,7 +163,8 @@ class Transition(XMLObject):
...
@@ -160,7 +163,8 @@ class Transition(XMLObject):
for
variable
in
self
.
contentValues
(
portal_type
=
'Transition Variable'
):
for
variable
in
self
.
contentValues
(
portal_type
=
'Transition Variable'
):
status_dict
[
variable
.
getCausalityTitle
()]
=
variable
.
getInitialValue
(
object
=
object
)
status_dict
[
variable
.
getCausalityTitle
()]
=
variable
.
getInitialValue
(
object
=
object
)
workflow
.
_updateWorkflowHistory
(
document
,
status_dict
)
#workflow._updateWorkflowHistory(document, status_dict)
self
.
setStatusOf
(
workflow
.
getId
(),
document
,
status_dict
)
# Execute the "after" script.
# Execute the "after" script.
script_id
=
self
.
getAfterScriptId
()
script_id
=
self
.
getAfterScriptId
()
if
script_id
is
not
None
:
if
script_id
is
not
None
:
...
@@ -205,3 +209,109 @@ class Transition(XMLObject):
...
@@ -205,3 +209,109 @@ class Transition(XMLObject):
value
=
True
value
=
True
#print "CALC", expr_value, '-->', value
#print "CALC", expr_value, '-->', value
return
value
return
value
def
setStatusOf
(
self
,
wf_id
,
ob
,
status
):
""" Append an entry to the workflow history.
o Invoked by transition execution.
"""
wfh
=
None
has_history
=
0
if
getattr
(
aq_base
(
ob
),
'workflow_history'
,
None
)
is
not
None
:
history
=
ob
.
workflow_history
if
history
is
not
None
:
has_history
=
1
wfh
=
history
.
get
(
wf_id
,
None
)
if
wfh
is
not
None
and
not
isinstance
(
wfh
,
WorkflowHistoryList
):
wfh
=
WorkflowHistoryList
(
list
(
wfh
))
ob
.
workflow_history
[
wf_id
]
=
wfh
if
wfh
is
None
:
wfh
=
WorkflowHistoryList
()
if
not
has_history
:
ob
.
workflow_history
=
PersistentMapping
()
ob
.
workflow_history
[
wf_id
]
=
wfh
wfh
.
append
(
status
)
class
WorkflowHistoryList
(
Persistent
):
_bucket_size
=
16
def
__init__
(
self
,
iterable
=
None
,
prev
=
None
):
self
.
_prev
=
prev
self
.
_slots
=
[]
if
iterable
is
not
None
:
for
x
in
iterable
:
self
.
append
(
x
)
def
__add__
(
self
,
iterable
):
return
self
.
__class__
(
tuple
(
self
)
+
tuple
(
iterable
))
def
__contains__
(
self
,
item
):
return
item
in
tuple
(
self
)
def
__eq__
(
self
,
other
):
return
tuple
(
self
)
==
tuple
(
other
)
def
__getitem__
(
self
,
index
):
if
index
==
-
1
:
return
self
.
_slots
[
-
1
]
elif
isinstance
(
index
,
(
int
,
long
)):
if
index
<
0
:
# XXX this implementation is not so good, but rarely used.
index
+=
len
(
self
)
iterator
=
self
.
__iter__
()
for
i
in
xrange
(
index
):
iterator
.
next
()
return
iterator
.
next
()
elif
isinstance
(
index
,
slice
):
return
self
.
__class__
((
self
[
x
]
for
x
in
xrange
(
*
index
.
indices
(
len
(
self
)))))
else
:
raise
TypeError
,
'tuple indices must be integers'
def
__getslice__
(
self
,
start
,
end
):
return
self
.
__getitem__
(
slice
(
start
,
end
))
def
__getstate__
(
self
):
return
(
self
.
_prev
,
self
.
_slots
)
def
__iter__
(
self
):
bucket
=
self
stack
=
[]
while
bucket
is
not
None
:
stack
.
append
(
bucket
)
bucket
=
bucket
.
_prev
for
i
in
reversed
(
stack
):
for
j
in
i
.
_slots
:
yield
j
def
__len__
(
self
):
length
=
len
(
self
.
_slots
)
bucket
=
self
.
_prev
while
bucket
is
not
None
:
length
+=
len
(
bucket
.
_slots
)
bucket
=
bucket
.
_prev
return
length
def
__mul__
(
self
,
x
):
return
self
.
__class__
(
tuple
(
self
)
*
x
)
def
__nonzero__
(
self
):
return
len
(
self
.
_slots
)
!=
0
or
self
.
_prev
is
not
None
def
__repr__
(
self
):
#return '%s' % repr(tuple(self.__iter__()))
return
'<%s object at 0x%x %r>'
%
(
self
.
__class__
.
__name__
,
id
(
self
),
tuple
(
self
))
def
__rmul__
(
self
,
x
):
return
self
.
__class__
(
x
*
tuple
(
self
))
def
__setstate__
(
self
,
state
):
self
.
_prev
,
self
.
_slots
=
state
def
append
(
self
,
value
):
if
len
(
self
.
_slots
)
<
self
.
_bucket_size
:
self
.
_slots
.
append
(
value
)
self
.
_p_changed
=
1
else
:
self
.
_prev
=
self
.
__class__
(
self
.
_slots
,
prev
=
self
.
_prev
)
self
.
_slots
=
[
value
]
\ No newline at end of file
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment