1:28 p.m.
1: Sure, no problem... just model it that way
2: leaving the node but keeping the task and 'just' notify? Via Email? That is
possible with a timer. Via a new task, leaving the node where to? A new tasknode? And what
if the user finishes the task before someone else can react on this task? Do you want to
cancel it then?
Remember that jBPM van have tasks that are not in the flow... you can create and start
them when a timer goes off. And e.g. cancel them when a transition is taken on the
original node.
Just to show you (and this is a one time effort by me ;-)) I've made an example of
this which is even somewhat configurable.
These are all possible with jBPM *now* just think out of the box and model these things
into your process. Or write some code (actionhandlers etc..) The thing is, escalation, or
the way people want it, is so dependant on the case, it cannot to the fullest extend be
part of the processlanguage.
The solution for the initial problem 'reported' is to give both the timer and the
duedate (which is just for informing the original owner) the same date. but what need is a
date for a reminder if when the duedate is reached
| package net.vankuijk.jbpm;
|
| import java.util.ArrayList;
| import java.util.Collection;
| import java.util.List;
| import java.util.Map;
|
| import org.apache.commons.logging.Log;
| import org.apache.commons.logging.LogFactory;
| import org.jbpm.db.AbstractDbTestCase;
| import org.jbpm.graph.def.ActionHandler;
| import org.jbpm.graph.def.Node;
| import org.jbpm.graph.def.ProcessDefinition;
| import org.jbpm.graph.exe.ExecutionContext;
| import org.jbpm.graph.exe.ProcessInstance;
| import org.jbpm.graph.exe.Token;
| import org.jbpm.graph.node.TaskNode;
| import org.jbpm.taskmgmt.def.Task;
| import org.jbpm.taskmgmt.exe.TaskInstance;
| import org.jbpm.taskmgmt.exe.TaskMgmtInstance;
|
| public class EscalationExampleTest extends AbstractDbTestCase {
|
| ArrayList ownerIDs;
| ArrayList escalatorIDs;
|
| List ownerTasks;
| List escalatorTasks;
|
| public void setUp() throws Exception {
| super.setUp();
|
| ownerIDs = new ArrayList();
| ownerIDs.add("owner");
|
| escalatorIDs = new ArrayList();
| escalatorIDs.add("escalator");
|
| }
|
| static String processDefinition = "<process-definition
name='testEscalation'>"
| + " <swimlane name='ownerSwimlane'>"
| + " <assignment pooled-actors='owner' />"
| + " </swimlane>"
|
| + " <event type='node-leave'>"
| + " <action
class='net.vankuijk.jbpm.EscalationExampleTest$CancelEscalationTask' />"
| + " </event>"
|
| + " <action name='createEscalationTask'
class='net.vankuijk.jbpm.EscalationExampleTest$CreateEscalationTask'>"
| + " <escalationTaskNodeName>task
escalated</escalationTaskNodeName>"
| + " </action>"
|
| + " <swimlane name='escalationSwimlane'>"
| + " <assignment pooled-actors='escalator' />"
| + " </swimlane>"
|
| + " <start-state>"
| + " <transition name='to_task' to='task' />"
| + " </start-state>"
|
| + " <task-node name='task'>"
| + " <task name='task 0'
swimlane='ownerSwimlane'>"
| + " <timer duedate='5 seconds'>"
| + " <action ref-name='createEscalationTask' />"
| + " </timer>"
| + " </task>"
| + " <transition name='to_end' to='end' />"
| + " </task-node>"
|
| + " <task-node name='task escalated'>"
| + " <task name='escalated task 0'
swimlane='escalationSwimlane' signalling='false'/>"
| + " </task-node>"
|
| + " <end-state name='end' />"
|
| + "</process-definition>";
|
| void deployProcessDefinition(String xml) {
| ProcessDefinition processDefinition = ProcessDefinition
| .parseXmlString(xml);
| jbpmContext.deployProcessDefinition(processDefinition);
| newTransaction();
| }
|
| public void testNormalFlow() {
|
| deployProcessDefinition(processDefinition);
|
| ProcessInstance processInstance = jbpmContext
| .newProcessInstanceForUpdate("testEscalation");
| processInstance.signal();
|
| processInstance = saveAndReload(processInstance);
|
| ownerTasks = jbpmContext.getGroupTaskList(ownerIDs);
| TaskInstance ownerTask = (TaskInstance) ownerTasks.get(0);
| ownerTask.end();
|
| assertEquals(0, processInstance.getTaskMgmtInstance()
| .getUnfinishedTasks(processInstance.getRootToken()).size());
|
| assertEquals(true, processInstance.hasEnded());
|
| }
|
| public void testEndingNormalTaskAfterEscalationCancelsEscalation() {
| deployProcessDefinition(processDefinition);
|
| ProcessInstance processInstance = jbpmContext
| .newProcessInstanceForUpdate("testEscalation");
| long piId = processInstance.getId();
| processInstance.signal();
|
| assertEquals(1, processInstance.getTaskMgmtInstance()
| .getTaskInstances().size());
|
| processInstance = saveAndReload(processInstance);
|
| ownerTasks = jbpmContext.getGroupTaskList(ownerIDs);
| assertEquals(1, ownerTasks.size());
|
| escalatorTasks = jbpmContext.getGroupTaskList(escalatorIDs);
| assertEquals(0, escalatorTasks.size());
|
| processJobs(10000);
|
| processInstance = jbpmContext.getProcessInstance(piId);
|
| assertEquals(2, processInstance.getTaskMgmtInstance()
| .getTaskInstances().size());
|
| escalatorTasks = jbpmContext.getGroupTaskList(escalatorIDs);
| assertEquals(1, escalatorTasks.size());
|
| ownerTasks = jbpmContext.getGroupTaskList(ownerIDs);
| TaskInstance ownerTask = (TaskInstance) ownerTasks.iterator().next();
| ownerTask.end();
|
| // processInstance = saveAndReload(processInstance);
|
| // Escalation task should be cancelled
| escalatorTasks = jbpmContext.getGroupTaskList(escalatorIDs);
| assertEquals(0, escalatorTasks.size());
|
| }
|
| public void testEscalationEnded_NormalTaskStays() {
| deployProcessDefinition(processDefinition);
|
| ProcessInstance processInstance = jbpmContext
| .newProcessInstanceForUpdate("testEscalation");
| long piId = processInstance.getId();
| processInstance.signal();
|
| assertEquals(1, processInstance.getTaskMgmtInstance()
| .getTaskInstances().size());
|
| processInstance = saveAndReload(processInstance);
|
| ownerTasks = jbpmContext.getGroupTaskList(ownerIDs);
| assertEquals(1, ownerTasks.size());
|
| escalatorTasks = jbpmContext.getGroupTaskList(escalatorIDs);
| assertEquals(0, escalatorTasks.size());
|
| processJobs(10000);
|
| processInstance = jbpmContext.getProcessInstance(piId);
|
| assertEquals(2, processInstance.getTaskMgmtInstance()
| .getTaskInstances().size());
|
| escalatorTasks = jbpmContext.getGroupTaskList(escalatorIDs);
| assertEquals(1, escalatorTasks.size());
|
| TaskInstance escalatorTask = (TaskInstance) escalatorTasks.iterator()
| .next();
| assertEquals("escalated task 0", escalatorTask.getName());
| escalatorTask.end();
|
| processInstance = saveAndReload(processInstance);
|
| // owner task should still be there... is it?
| ownerTasks = jbpmContext.getGroupTaskList(ownerIDs);
| assertEquals(1, ownerTasks.size());
|
| escalatorTasks = jbpmContext.getGroupTaskList(escalatorIDs);
| assertEquals(0, escalatorTasks.size());
|
| }
|
| public static class CreateEscalationTask implements ActionHandler {
| private static final long serialVersionUID = 1L;
|
| public String escalationTaskNodeName;
|
| public void execute(ExecutionContext executionContext) throws Exception {
|
|
| if ("".equals(escalationTaskNodeName) || escalationTaskNodeName == null)
{
| log.warn("escalationTaskNodeName not specified");
| return;
| }
|
| Token token = executionContext.getToken();
| TaskMgmtInstance tmi = executionContext.getTaskMgmtInstance();
|
| Node node = executionContext.getProcessDefinition().getNode(
| escalationTaskNodeName);
| if (node != null) {
| TaskNode escalatedTaskNode = (TaskNode) node;
|
| // assuming 1 task in node... otherwise also use e.g. a param
| // like escalationTaskNodeName. Errorhandling for this not done yet
| Task escalateTask = (Task) escalatedTaskNode.getTasksMap()
| .values().iterator().next();
|
| Token childToken = new Token(token, token.getFullName()
| + "_child_" + token.getChildren().size());
|
| childToken.setNode(escalatedTaskNode);
|
| tmi.createTaskInstance(escalateTask, childToken);
| } else {
| log.warn("escalationTaskNode with name " + escalationTaskNodeName +
" not found.");
| }
|
| }
| }
|
| public static class CancelEscalationTask implements ActionHandler {
| private static final long serialVersionUID = 1L;
|
| public void execute(ExecutionContext executionContext) throws Exception {
|
| // Assuming max one active childToken and max one unfinished task in
| // this childtoken
| Map activeChildren = executionContext.getToken()
| .getActiveChildren();
| if (!activeChildren.isEmpty()) {
| Token childToken = (Token) activeChildren.values().iterator()
| .next();
| Collection unfinishedTasks = executionContext
| .getTaskMgmtInstance().getUnfinishedTasks(childToken);
| if (!unfinishedTasks.isEmpty()) {
| ((TaskInstance) unfinishedTasks.iterator().next()).cancel();
| }
| }
|
| }
| }
|
| private static final Log log = LogFactory.getLog(EscalationExampleTest.class);
|
| }
|
|
Maybe someone wants to make a wiki page out of this....
View the original post :
http://www.jboss.com/index.html?module=bb&op=viewtopic&p=4176232#...
Reply to the post :
http://www.jboss.com/index.html?module=bb&op=posting&mode=reply&a...