jBPM(二)：jbpm4 请假demo

一. 请假流程如下图，即：申请人申请-->部门负责人审批-->人事部审批-->申请人归档
[img]http://dl.iteye.com/upload/picture/pic/127409/dcb4da59-a82e-3e71-b1ba-c39df210e904.png[/img]
对应的xml文件为：

<?xml version="1.0" encoding="UTF-8"?>

<process name="flowTest" xmlns="http://jbpm.org/4.3/jpdl">
   <start g="58,45,48,48" name="开始">
      <transition g="-81,-22" name="to 申请人申请" to="申请人申请"/>
   </start>
   <task g="279,40,92,52" name="申请人申请">  
      <assignment-handler class="jbpm.TaskAssignment"> 
      </assignment-handler> 
      <transition g="-105,-22" name="to 部门负责人审批" to="部门负责人审批"/>
   </task>
   <task g="591,48,114,52" name="部门负责人审批"> 
      <assignment-handler class="jbpm.TaskAssignment"> 
      </assignment-handler> 
      <transition g="-81,-22" name="to 人事部审批" to="人事部审批"/>
   </task>
   <task g="606,152,92,52" name="人事部审批"> 
      <assignment-handler class="jbpm.TaskAssignment"> 
      </assignment-handler>  
      <transition g="-81,-22" name="to 申请人归档" to="申请人归档"/>
   </task>
   <task g="334,153,92,52" name="申请人归档">
      <assignment-handler class="jbpm.TaskAssignment"> 
      </assignment-handler>  
      <transition g="-50,-22" name="to end1" to="结束"/>
   </task>
   <end g="65,150,48,48" name="结束"/>
</process>

二. 管理员登录系统，设置部门与人员信息如下：

张三（zhangsan） -- 研发部（员工）
朱孝敏（zxm） -- 研发部（负责人）
周慧（zhouhui） -- 人事部
[img]http://dl.iteye.com/upload/picture/pic/127389/2adbfdeb-d7fe-31f3-8f5d-7be8bac45614.png[/img]

三. 管理员部署程序：

String deploymentId = processEngine.getRepositoryService()
		                 .createDeployment()
		        .addResourceFromClasspath(resourceName)
		                 .deploy();

四. 请假流程：

1. 步骤1 ： 张三发起流程申请

[img]http://dl.iteye.com/upload/picture/pic/127397/4c488760-e5c6-3852-98d4-33cd0824fca3.png[/img]

发起流程主要逻辑：
（1）获取当前登录用户的信息，用于页面显示
（2）启动流程时，将当前信息存入
（3）根据当前节点，获得下一步的节点信息，以及下一步节点的参与者

	public String start() throws Exception{

		date = new Date();

		// 获得当前登录用户信息
		User curLoginUser = WebUtils.getLoginUser(request); 
		if(curLoginUser==null){
			return "error";
		}
		userName = curLoginUser.getUserName();
		Department dept = (Department)getCommonService().get(Department.class, curLoginUser.getDeptId());
		deptName = dept.getDeptName();

		// 启动流程时存入当前用户信息
		Map<String,Object> initData = new HashMap<String,Object>(); 
		initData.put(Constants.FLOW_CUR_USER, curLoginUser.getLoginName());

		processInstance = getJbpmService().startProcessByKey(processKey,initData);  
		if(processInstance!=null){ 
			// 流程定义
			processDefinitionId = processInstance.getProcessDefinitionId();
			processDefinition = getJbpmService().getProcessDefinition(processDefinitionId);

			curTask = getJbpmService().getCurTask(processInstance.getId());
			if(curTask!=null){
				taskId = curTask.getId();
				executionId = curTask.getExecutionId();
			}
			curActivity = getJbpmService().getCurActivity(processInstance.getId()); 
			List<Transition> transitions = curActivity.getOutgoingTransitions();
			// 此处只取第一个（测试代码，假设只有一个outgoing）
			if(transitions!=null&&transitions.size()>0){
				Transition transition = transitions.get(0);
				nextActivity = transition.getDestination();
			}	 
			userList = getCommonService().getLeaders(curLoginUser);   
		}
		return "start";
	}

张三输入申请信息之后，提交流程，后台的主要逻辑是：

（1）将下一节点的参与者存入流程
（2）新建表单对象FormData ，存储输入的申请信息，（FormData与流程id关联）
（3）根据用户的勾选（下一步 or 退回）进行处理


2. 步骤2：部门负责人（朱孝敏）登录，在待办公文中可以看到待办任务，
TaskService的findPersonalTasks方法，可以根据用户名获取该用户的待办任务。

[img]http://dl.iteye.com/upload/picture/pic/127403/6d4ea97e-fb82-3168-b6be-9345b51ca5bd.png[/img]

点击“处理”链接，进行流程审批，此处的逻辑是：

（1）获得表单信息以及对应的审批信息
（2）根据当前任务获得下一节点信息，取得对应的任务执行者
（3）获得可退回节点信息（即已执行的节点信息）

	public String edit() throws Exception{
		// 1. 表单信息
		formData = (FormData)getCommonService().get(FormData.class, formDataId);
		spDataList = getCommonService().findAll(SpData.class, " formDataId = '"+formDataId+"' ");

		// 2. 流程定义
		processDefinition = getJbpmService().getProcessDefinition(processDefinitionId);
		// 3. 流程的可流转信息
		curTask = getJbpmService().getCurTask(processInstanceId); 

		/**
		 * 处理的关键：下一步信息（节点，人员） ； 退回信息（全部节点--人员）
		 */

		// 4. 下一步
		nextNodeUserInfo = new HashMap<String,Object>();
		String nextActivityName = "";

		curActivity = getJbpmService().getCurActivity(processInstanceId); 
		List<Transition> transitions = curActivity.getOutgoingTransitions();
		// 此处只取第一个
		if(transitions!=null&&transitions.size()>0){
			Transition transition = transitions.get(0);
			Activity destination = transition.getDestination();
			if(destination!=null){
				nextActivityName = destination.getName();
			}
			// 根据下一节点，获得人员信息
			List<User> userList = getCommonService().getUserList(nextActivityName,processInstanceId);
			nextNodeUserInfo.put(nextActivityName, userList); 
		} 


		// 5. 可退回步骤
		Activity firstActivity = getJbpmService().getAllActivities(processInstanceId).get(1);
		if(firstActivity.getName().contains(curTask.getActivityName())){
			ifCanBack = 0;   
		}else{
			ifCanBack = 1;
		}
		if(ifCanBack.intValue()==1){
			canBackNames = getJbpmService().getBeforeNodeNames(processInstanceId, "");
		} 
		return "edit"; 
	}

部门负责人输入审批意见后进行[color=red][b]退回[/b][/color]操作，页面如下图：

[img]http://dl.iteye.com/upload/picture/pic/127405/16a328c4-8030-3a5f-acb0-4bcb4979ec82.png[/img]

提交之后，流程退回到张三处，张三登录系统，查看待办公文：

[img]http://dl.iteye.com/upload/picture/pic/127401/8ff13065-457f-32a1-b49c-d392852da4ea.png[/img]

进入之后，可以看到部门负责人的审批信息；然后其输入对应内容，再次提交到部门负责人处。

[img]http://dl.iteye.com/upload/picture/pic/127399/c080359e-319c-36ce-a033-672fb671cfac.png[/img]

步骤3：部门负责人登录之后，同意该请假，提交到人事部审批；

步骤4：人事部（周慧）登录系统，可以查看到待办公文，并进行审批；

[img]http://dl.iteye.com/upload/picture/pic/127395/336949f5-32c5-3ddf-8056-3feea9d51e5f.png[/img]

步骤5：人事部同意请假之后，申请人（张三）进行归档操作，流程结束。

[img]http://dl.iteye.com/upload/picture/pic/127391/0928b2c0-3913-3cf8-ac16-82b3543cabba.png[/img]


[b]说明：[/b]

1. 流程中每一个Task都配置assignment-handler来动态设置参与者，所以在提交时需要将下一节点的参与者传入流程中。

1.启动流程之后，流程进入到第一个节点  
2.任务分配器TaskAssignment在第一个任务complete之后执行，所以，设置变量信息需要在complete方法执行之前完成。

2. 退回部分代码：根据jbpm4_hist_actinst /// jbpm4_hist_task 表获得流程中对应节点的历史参与者。

		EnvironmentImpl envImpl = ((EnvironmentFactory)processEngine).openEnvironment();    
	      try {   
	          //动态回退
	    	  Task task = getTaskService().getTask(taskId);
	          ExecutionImpl e = (ExecutionImpl)getExecutionService().findExecutionById(task.getExecutionId());  
	          ActivityImpl currentActivityImpl = e.getActivity();  

	          ProcessDefinitionImpl processDefinitionImpl = currentActivityImpl.getProcessDefinition();  

	          //生成一个transition  
	          ActivityImpl destActivityImpl = processDefinitionImpl.findActivity(backActivityName);   // 获取退回目的地的活动定义对象

	          TransitionImpl backTransition = currentActivityImpl.createOutgoingTransition();  
	          backTransition.setSource(currentActivityImpl);  
	          backTransition.setDestination(destActivityImpl);  

	          //获得退回任务的历史参与者 （根据 jbpm4_hist_actinst /// jbpm4_hist_task 表获得 ）
	          String user = getHistTaskUser(String.valueOf(e.getDbid()),backActivityName);
	          Map<String,Object> initData = new HashMap<String,Object>(); 
	  		  initData.put(Constants.FLOW_CUR_USER, user);

	          getTaskService().completeTask(taskId,initData);
	      } catch (Exception e) {  
	          e.printStackTrace();  
	      }finally{  
	          envImpl.close();  
	      }