jbpm4.3 实现会签

jbpm4.3中会签的实现主要思路也是从网上找的。新接触jbpm简单的实现下，如果有什么疑问或错误，请指正。
jpdl.xml文件见附件，这里只贴出java代码

package com.zhangrun.custom;

import java.util.Iterator;
import java.util.List;
import java.util.Map;

import org.jbpm.api.Configuration;
import org.jbpm.api.ProcessInstance;
import org.jbpm.api.TaskService;
import org.jbpm.api.activity.ActivityExecution;
import org.jbpm.api.activity.ExternalActivityBehaviour;
import org.jbpm.api.task.Task;
import org.jbpm.pvm.internal.env.EnvironmentImpl;
import org.jbpm.pvm.internal.history.HistoryEvent;
import org.jbpm.pvm.internal.history.events.TaskActivityStart;
import org.jbpm.pvm.internal.model.Activity;
import org.jbpm.pvm.internal.model.ExecutionImpl;
import org.jbpm.pvm.internal.model.Transition;
import org.jbpm.pvm.internal.session.DbSession;
import org.jbpm.pvm.internal.task.TaskImpl;

/**
 * @author zr
 * 
 */
public class Custom implements ExternalActivityBehaviour {

	private static final long serialVersionUID = 1L;

	public void execute(ActivityExecution activityExecution) throws Exception {
		ExecutionImpl executionimpl = (ExecutionImpl) activityExecution;

		DbSession dbsession = EnvironmentImpl.getFromCurrent(DbSession.class);
		TaskImpl taskimpl = dbsession.createTask();
		taskimpl.setName("customTem");
		taskimpl.setExecution(executionimpl);
		taskimpl.setProcessInstance(executionimpl.getProcessInstance());
		taskimpl.setSignalling(false);
		taskimpl.setExecutionDbid(executionimpl.getDbid());
		dbsession.save(taskimpl);
		HistoryEvent.fire(new TaskActivityStart(taskimpl), executionimpl);
		// 子任务
		TaskImpl subtaskimpl1 = taskimpl.createSubTask();
		subtaskimpl1.setName("huigao1");
		subtaskimpl1.setAssignee("huigao1");
		subtaskimpl1.setSignalling(false);
		subtaskimpl1.setExecutionDbid(executionimpl.getDbid());
		dbsession.save(subtaskimpl1);
		HistoryEvent.fire(new TaskActivityStart(subtaskimpl1), executionimpl);
		TaskImpl subtaskimpl2 = taskimpl.createSubTask();
		subtaskimpl2.setName("huigao2");
		subtaskimpl2.setAssignee("huigao2");
		subtaskimpl2.setExecutionDbid(executionimpl.getDbid());
		subtaskimpl2.setSignalling(false);
		dbsession.save(subtaskimpl2);
		HistoryEvent.fire(new TaskActivityStart(subtaskimpl2), executionimpl);
		// 流程等待
		executionimpl.waitForSignal();
	}

	public void signal(ActivityExecution activityExecution, String signalName,
			Map<String, ?> parms) throws Exception {
		ExecutionImpl executionImpl = (ExecutionImpl) activityExecution;
		ProcessInstance pi = (ProcessInstance) executionImpl
				.getProcessInstance();
		TaskService taskService = Configuration.getProcessEngine()
				.getTaskService();
		Activity activity = executionImpl.getActivity();
		List<Task> tasks = taskService.createTaskQuery().processInstanceId(
				pi.getId()).list();

		List<Task> subTask_list = taskService.getSubTasks(tasks.get(0).getId());
		Iterator<Task> iter = subTask_list.iterator();
		while (iter.hasNext()) {
			Task subtask = iter.next();
			if (parms.get("username").equals(subtask.getAssignee())) {
				taskService.completeTask(subtask.getId());
			}
		}
		if (subTask_list == null || subTask_list.size() == 1) {
			Transition transition = null;
			if ((signalName == null)
					|| ((Task.STATE_COMPLETED.equals(signalName))
							&& (activity.getOutgoingTransitions() != null) && (activity
							.getOutgoingTransitions().size() == 1))) {
				transition = activity.getOutgoingTransitions().get(0);
			} else {
				transition = activity.findOutgoingTransition(signalName);
			}
			taskService.completeTask(tasks.get(0).getId());
			executionImpl.take(transition);
		} else {
			executionImpl.waitForSignal();
		}
	}

}

评论

5 楼 cdh111007 2012-10-29  

你好，请问为什么我使用Session session = EnvironmentImpl.getFromCurrent(Session.class);
方法的时候总是报错：
no environment to get org.jbpm.pvm.internal.session.DbSession
困扰了我好久 请问该如何设置？谢谢！

4 楼 yochor 2012-07-06  

com/zhangrun/forms/first.ftl很明显您没有提供这个嘛

3 楼 glassesbamboo 2011-12-30  

在吗前辈？
我允许您的代码，在HuiGao.java中的的getTaskList中报错了：
查找username的任务列表
private List<String[]> getTaskList(String username) {
List<Task> list = taskService.createTaskQuery().assignee(username)
.list();
Iterator<Task> iter = list.iterator();
List<String[]> returnList = new ArrayList<String[]>();
while (iter.hasNext()) {
String[] str = new String[5];
Task task = iter.next();
str[0] = task.getId();
str[1] = task.getName();
str[2] = task.getActivityName();
str[3] = task.getExecutionId();
str[4] = username;
String executionid = task.getExecutionId();
// 如果该task没有executionid，则从父task获得executionid
if (executionid == null || executionid.equals("")) {
EnvironmentFactory environmentFactory = null;
EnvironmentImpl environmentImpl = null;
try {
environmentFactory = (EnvironmentFactory) new ConfigurationImpl()
.buildProcessEngine();
environmentImpl = environmentFactory.openEnvironment();
DbSession dbsession = environmentImpl.get(DbSession.class);
TaskImpl taskimpl = (TaskImpl) dbsession.get(
TaskImpl.class, Long.parseLong(str[0])); executionid = taskimpl.getSuperTask().getExecutionId();
} finally {
if (environmentImpl != null)
environmentImpl.close();
}
}
str[3] = executionid;
returnList.add(str);
}
return returnList;
}


也就是在得到子任务的taskimpl的时候是null，得不到taskimpl.望指点。我的qq是1336051675，邮箱是[e-mail] 希望能得到前辈的帮助。愿幸福快乐。

2 楼 对酒当歌，人生几何 2010-06-21  

引用

包里的东西不全，跑不起来啊

不会吧，已经全部在上面了。只要再在web.xml里面配置一下servlet就可以了， jsp页面提交的时候都是给servlet处理的。

1 楼 lwx0730 2010-06-18  

包里的东西不全，跑不起来啊
  发个完整的包给我好吗，谢谢了
我的邮箱是[e-mail]