在這次學習工作流的過程中，工作流如何與業務結合有多種方式，雖然很簡單，但是每次都要再次梳理幾分鐘，這次拿出來整理一下，將它真正成為自己的知識。

從啟動流程開始說：

申請頁面：選擇所用流程（即畫的流程圖的id）

<table cellpadding="0" cellspacing="0" class="mainForm">
					<tr>                  
                        <td	width="120px">
	                        <div>                        
	                        	所用流程:<s:select name="processDefinitionKey" cssClass="SelectStyle"  
	                        		list="processDefinitionList" listKey="key" listValue="key"/>           		
	                        </div>                  
                        </td>              							
                    </tr>
                    <tr>
                      	<td>申請名稱:</td>
                        <td><input type="text" name="title" cssClass="InputStyle" /></td>
                    </tr>
                     <tr>
                        <td>申請理由:</td>
                        <td><input type="text" name="reason" cssClass="InputStyle" /></td>
                    </tr>
    </table>
 

提交申請：獲取前臺傳來的值

/** 提交申請 */
public String submit() throws Exception {
	
	// 封裝申請資訊
	Application application = new Application();
	title=new String(title.getBytes("iso-8859-1"),"utf-8");
	reason=new String(reason.getBytes("iso-8859-1"),"utf-8");
	application.setApplicant(getCurrentUser()); // 申請人，當前使用者	
	application.setTitle(title);
	application.setReason(reason);
        String processDefinitionKeyStr=new String(processDefinitionKey.getBytes("iso-8859-1"),"utf-8");
       application.setProcessDefinitionKey(processDefinitionKeyStr);

	// 呼叫業務方法（儲存申請資訊，並啟動流程開始流轉）
	applicationService.submit(application);

	return "toMyApplicationList"; // 成功後轉到"我的申請查詢"
}

public void submit(Application application) {
	// 1，設定屬性並儲存application
	application.setApplyTime(sdf.format(new Date())); // 申請時間，當前時間
	application.setStatus(Application.STATUS_RUNNING);		
	
	// 2，啟動程程例項開始流轉
	// >> 準備流程變數
	Map<String, Object> variablesMap = new HashMap<String, Object>();
	variablesMap.put("application", application);
	// >> 啟動流程例項，並帶上流程變數（當前的申請資訊）
	
	//獲取流程定義的key
	
	String pdKey = application.getProcessDefinitionKey();
	
	//根據流程定義的key值和相應的流程變數啟動流程		
	ProcessInstance pi = processEngine.getExecutionService()//
			.startProcessInstanceByKey(pdKey, variablesMap);
	application.setExecuteId(pi.getId());
	getSession().save(application); // 儲存
	
	// >> 辦理完第1個任務“提交申請”
	Task task = processEngine.getTaskService()// 
			.createTaskQuery()// 查詢出本流程例項中當前僅有的一個任務“提交申請”
			.processInstanceId(pi.getId())//
			.uniqueResult();
	processEngine.getTaskService().completeTask(task.getId());
}
 

當點選提交申請時application，我們來看看工作流的各個表的變化：

jbpm4_execution：

jbpm4_task：

jbpm4_variable：

那麼通過檢視上面表的變化，我們不難發現執行的流程是通過什麼和業務繫結的，即jbpm4_execution和jbpm4_variable的關係。

從流程的啟動開始，就與業務繫結關係，那麼接下來如何應用呢？

下面只是簡單介紹，對於一些結合業務的查詢問題會單獨再說明：

檢視待辦任務：一般是根據使用者名稱來檢視（當前登陸使用者）

/** 待我審批（我的任務列表） */
public String myTaskList() throws Exception {
			
	List<TaskView> taskViewList = applicationService.getMyTaskViewList(getCurrentUser());
	//List<TaskView> taskViewList = applicationService.getMyTaskViewList(user);
	ActionContext.getContext().put("taskViewList", taskViewList);
	return "myTaskList";
}
 

審批處理：

    本環節因為單獨出來有一個審批意見表，故會將所有的審批意見新增的審批意見表中，故這個環節的內容是儲存資料然後辦理任務並判斷流程是否結束。當然我們也可以不單獨設計審批意見表，而是將所有的審批意見儲存到流程變數中。

    辦理任務需要獲取任務id，也就是在檢視任務列表中獲取taskViewList。

審批處理頁面,審批處理：

/** 審批處理頁面 */
public String approveUI() throws Exception {
	Set<String> outcomes = applicationService.getOutcomesByTaskId(taskId);
	ActionContext.getContext().put("outcomes", outcomes);
	return "approveUI";
}

/** 審批處理 */
public String approve() throws Exception {
	// 封裝
	ApproveInfo approveInfo = new ApproveInfo();
										
	 comment=new String(comment.getBytes("iso-8859-1"),"utf-8");
		
	approveInfo.setComment(comment);
	approveInfo.setApproval(approval);
	approveInfo.setApplication(applicationService.getById(applicationId));
		
	approveInfo.setApprover(getCurrentUser()); // 審批人，當前登入使用者					
	approveInfo.setApproveTime(sdf.format(new Date())); // 當前時間
	if(outcome!=null){
		// 呼叫用業務方法（儲存本次審批資訊，並辦理完任務，並維護申請的狀態）
		outcome=new String(outcome.getBytes("iso-8859-1"),"utf-8");
	}
	applicationService.approve(approveInfo, taskId, outcome);

	return "toMyTaskList"; // 成功後轉到待我審批頁面
}

//辦理任務
public void approve(ApproveInfo approveInfo, String taskId, String outcome) {
	// 1，儲存本次審批資訊
	getSession().save(approveInfo);

	// 2，辦理完任務
	Task task = processEngine.getTaskService().getTask(taskId); // 一定要先取出Task物件，再完成任務，否則拿不到，因為執行完就變成歷史資訊了。
	if (outcome == null) {
		processEngine.getTaskService().completeTask(taskId);
	} else {
		processEngine.getTaskService().completeTask(taskId, outcome);
	}

	// >> 取出所屬的流程例項，如果取出的為null，說明流程例項執行完成了，已經變成了歷史記錄
	ProcessInstance pi = processEngine.getExecutionService().findProcessInstanceById(task.getExecutionId());

	// 3，維護申請的狀態
	Application application = approveInfo.getApplication();
	if (!approveInfo.isApproval()) {
		// 如果本環節不同意，則流程例項直接結束，申請的狀態為：未通過
		if (pi != null) { // 如果流程還未結束
			processEngine.getExecutionService().endProcessInstance(task.getExecutionId(), ProcessInstance.STATE_ENDED);
		}
		application.setStatus(Application.STATUS_REJECTED);
	} else {
		// 如果本環節同意，而且本環節是最後一個環節，則流程例項正常結束，申請的狀態為：已通過
		if (pi == null) { // 本環節是最後一個環節，即流程已經結束了
			application.setStatus(Application.STATUS_APPROVED);
		}
	}
	getSession().update(application);
}

檢視流轉記錄：即類似淘寶檢視物流資訊類似，完全使用業務資訊

/** 檢視流轉記錄 applicationId*/
public String approveHistory() throws Exception {						
	Application application = applicationService.getById(applicationId);
	System.out.println(application.getTitle());
	ActionContext.getContext().put("approveInfos", application.getApproveInfos());
	return "approveHistory";
}

檢視我的申請：完全檢視自己的業務資訊表即可

/** 我的申請查詢 */
public String myApplicationList() throws Exception {
		  						
	String strHQL="from Application where applicant="+getCurrentUser().getUserId() ;
	// 準備資料
	List<Application> applicationList = applicationService.findByHql(strHQL);
	ActionContext.getContext().put("applicationList", applicationList);			
	
	return "myApplicationList";
}

/**
 * 檢視流程圖，高亮當前正在執行的節點
 */
public String showProcessImageUI() throws Exception {
	/*boolean isEnded = "true".equals(request.getParameter("isEnded")); // 是否已執行完
	String processInstanceId = getParameter(request, "processInstanceId");*/
	
	//未考慮是否完成情況
	//boolean isEnded=false;
	//啟動的例項id
	//String processInstanceId="ApplyDepartment.8";
	
	// 1，獲取當前正在執行的活動名稱
	String deploymentId = null;
	String processDefinitionId = null;
	Set<String> activityNames = null;
	status=new String(status.getBytes("iso-8859-1"),"utf-8");
	if (!status.equals("審批中")) {
	// 已執行完的，就查詢歷史
	HistoryProcessInstance hpi = processEngine.getHistoryService()//
			.createHistoryProcessInstanceQuery()//
			.processInstanceId(processInstanceId)//
			.uniqueResult();

			processDefinitionId = hpi.getProcessDefinitionId();
			activityNames = new HashSet<String>();
			activityNames.add(hpi.getEndActivityName()); // 結束的活動名稱
	} else {
		// 正在執行的，就使用ExecutionService查詢
		ProcessInstance pi = processEngine.getExecutionService()//
				.createProcessInstanceQuery()//						
				.processInstanceId(processInstanceId)//
				.uniqueResult();

		processDefinitionId = pi.getProcessDefinitionId();
		activityNames = new HashSet<String>(pi.findActiveActivityNames()); // 當前正在執行的活動的名稱
	}
	ActionContext.getContext().put("processDefinitionId", processDefinitionId);
	// 2，找出他們的座標
	Set<ActivityCoordinates> coordList = new HashSet<ActivityCoordinates>();
	for (String activityName : activityNames) {
		ActivityCoordinates coord = processEngine.getRepositoryService().getActivityCoordinates(
				processDefinitionId, activityName);
		coordList.add(coord);
	}			
	ActionContext.getContext().put("coordList", coordList);
	// 3，獲取 deploymentId
	deploymentId = processEngine.getRepositoryService().createProcessDefinitionQuery()//
			.processDefinitionId(processDefinitionId)//
			.uniqueResult()//
			.getDeploymentId();			
	ActionContext.getContext().put("deploymentId", deploymentId);
	return "showProcessImageUI";
}

總結：

   其實寫這篇部落格的目的是結合工作流的資料庫來分析業務與流程是如何繫結的，那麼對於流程中需要的一些常用方法的使用在這裡也簡單的介紹了一番，這樣做的目的也是為後面的Activiti中的應用例項的常用方法介紹做個對比，其實無論是JBPM4.4還是它的升級版Activiti本質上都是一樣的。