package com.Deer.activiti;

import java.util.Iterator;  
import java.util.Map;  
import org.activiti.engine.impl.interceptor.Command;  
import org.activiti.engine.impl.interceptor.CommandContext;  
import org.activiti.engine.impl.persistence.entity.ExecutionEntity;  
import org.activiti.engine.impl.persistence.entity.ExecutionEntityManager;  
import org.activiti.engine.impl.persistence.entity.TaskEntity;  
import org.activiti.engine.impl.pvm.process.ActivityImpl;  
   
/** 
 * 
 * 節點的跳轉 
 */  
public class NodeJumpTaskCmd implements Command<Void> {
	
	protected String executionId;//執行ID
	protected ActivityImpl desActivity; //目標引擎物件 
	protected Map<String, Object> paramvar;//變數
	protected ActivityImpl currentActivity;//當前引擎物件
	protected String deleteReason = "completed";
	/** 
	 * 構造引數 可以根據自己的業務需要新增更多的欄位 
	 * @param executionId 
	 * @param desActivity 
	 * @param paramvar 
	 * @param currentActivity 
	 */  
	public NodeJumpTaskCmd(String executionId, ActivityImpl desActivity,  
		Map<String, Object> paramvar, ActivityImpl currentActivity) {  
			this.executionId = executionId;  
			this.desActivity = desActivity;  
			this.paramvar = paramvar;  
			this.currentActivity = currentActivity;  
	}
	public NodeJumpTaskCmd(String executionId, ActivityImpl desActivity,  
			Map<String, Object> paramvar, ActivityImpl currentActivity,String deleteReason) {  
				this.executionId = executionId;  
				this.desActivity = desActivity;  
				this.paramvar = paramvar;  
				this.currentActivity = currentActivity;  
				this.deleteReason = deleteReason;  
		}
	
	/**
	 * 獲取執行實體管理
	 * 獲取當前的任務執行物件 設定對應的值
	 * 獲取當前的任務
	 * 刪除
	 * 執行目標工作流
	 */
	public Void execute(CommandContext commandContext) {
		//獲取執行實體管理
		ExecutionEntityManager executionEntityManager = commandContext.getExecutionEntityManager();  
		//根據ExecutionID 查詢執行實體   獲取當前流程的executionId，因為在併發的情況下executionId是唯一的。  
		ExecutionEntity executionEntity = executionEntityManager.findExecutionById(executionId);  
		executionEntity.setVariables(paramvar);  
		executionEntity.setEventSource(this.currentActivity);  
		executionEntity.setActivity(this.currentActivity);  
		//獲取當前ExecutionID的任務       根據executionId 獲取Task  
		Iterator<TaskEntity> localIterator = commandContext.getTaskEntityManager()  
							.findTasksByExecutionId(this.executionId).iterator();  
		while (localIterator.hasNext()) {  
			TaskEntity taskEntity = (TaskEntity) localIterator.next();  
			// 觸發任務監聽  
			taskEntity.fireEvent("complete");  
			// 刪除任務的原因  
			commandContext.getTaskEntityManager()  
			.deleteTask(taskEntity, this.deleteReason, false);  
		}  
		executionEntity.executeActivity(this.desActivity);  
		System.out.println();
		return null;  
	}  
}