package com.vci.test.workflow;
|
|
import java.util.List;
|
import java.util.Map;
|
|
import org.jbpm.api.ProcessEngine;
|
import org.jbpm.api.ProcessInstance;
|
import org.jbpm.api.TaskQuery;
|
import org.jbpm.api.TaskService;
|
import org.jbpm.api.task.Task;
|
import org.junit.Test;
|
|
import com.vci.common.utility.ObjectUtility;
|
import com.vci.corba.common.VCIError;
|
import com.vci.server.workflow.objects.FlowInstance;
|
import com.vci.server.workflow.server.template.ProcessTemplateService;
|
|
public class ProcessTemplateServiceTest {
|
|
/**
|
* @throws VCIError
|
*
|
*/
|
@Test
|
public void testStartProcessInstanceByKey() throws VCIError {
|
|
ProcessTemplateService s = new ProcessTemplateService();
|
|
// try {
|
// s.getOutComesByTaskName("120001","任务1");
|
// } catch (Exception e) {
|
// e.printStackTrace();
|
// }
|
|
String depolymentID = s.getDepolymentID("分支测试.20001");
|
System.out.println(depolymentID);
|
|
// String processDefinitionKey = "分支测试-3";
|
// FlowInstanceInfo var = new FlowInstanceInfo();
|
// var.applicant = "22222222222";
|
// var.tableName = "PLMxFxKxi6K1X7Jvc";
|
// var.clsfOid="";
|
// var.creator="22222222222";
|
// var.desc="";
|
// var.processType="";
|
// var.processName="流程事件";
|
// String[] objId = new String[]{"1"};
|
// String[] userNames = new String[0];
|
// String outcome = "";
|
// ProcessEngine processEngine = JbpmEngine.getProcessEngine();
|
// Map<String, Object> variables = new HashMap<String, Object>();
|
// variables.put("process_applicant", var.applicant);
|
// variables.put("content", "任务1");
|
// s.startProcessInstanceByKey(processDefinitionKey, var, objId, userNames, outcome);
|
// Map<String,String[]> taskAndUserMap = new HashMap<String,String[]>();
|
// taskAndUserMap.put("任务", new String[]{"1"});
|
// taskAndUserMap.put("任务2", new String[]{"3"});
|
// taskAndUserMap.put("任务3", new String[]{"4"});
|
|
//流程启动
|
// BaseService bs = new BaseService();
|
// UserEntity userEntity= new UserEntity();
|
// userEntity.setUserName(var.applicant);
|
// bs.setUserEntity(userEntity);
|
// s.startProcessInstanceByKey(processDefinitionKey, var, objId, userNames, outcome);
|
// s.completeTask(taskId, outcome, nextTaskName, approvalNote, userNames);
|
// TaskService taskService = processEngine.getTaskService();
|
// ExecutionService executionService = processEngine.getExecutionService();
|
// ExecutionImpl e = (ExecutionImpl)executionService.findProcessInstanceById("123123.1820001");
|
// Task task = taskService.createTaskQuery().processInstanceId("123123.1850001").uniqueResult();
|
// s.completeTask(task.getId(), outcome, "", "tongi", userNames);
|
// try {
|
// taskService.addTaskParticipatingUser(task.getId(),
|
// "123", Participation.CANDIDATE);
|
// List<Participation> taskParticipations = taskService.getTaskParticipations(task.getId());
|
// taskService.completeTask(task.getId());
|
// } catch (Exception e) {
|
// e.getMessage();
|
// e.printStackTrace();
|
// }
|
|
// try {
|
// BigDecimal deploymentID = s.getDeploymentID("测试发起流程时设置责任人-2");
|
// String jbpmDeploymentId = deploymentID.toString();
|
// String[] allTaskNames = s.getAllTaskNames(jbpmDeploymentId);
|
// for(String string: allTaskNames){
|
// System.out.println(string);
|
// }
|
// } catch (VCIError e) {
|
// String[] error_message = e.error_message;
|
// String string = error_message[0];
|
// e.printStackTrace();
|
// }
|
// try {
|
// s.completeTask(task.getId(), "", "任务2", "", new String[]{"123","456"});
|
// } catch (VCIError e) {
|
// e.printStackTrace();
|
// }//(new String[]{"123","456"}, "测试发起流程时设置责任人.1730006", "任务2");
|
//ProcessDefinitionImpl pdI = new ProcessDefinitionImpl();
|
// ExecutionService executionService= processEngine.getExecutionService();
|
// RepositoryService repositoryService = processEngine.getRepositoryService();
|
//
|
// EnvironmentImpl envImpl = ((EnvironmentFactory)processEngine).openEnvironment();
|
// ExecutionImpl e = (ExecutionImpl)executionService.findProcessInstanceById(proccessInstanceId);
|
// ActivityImpl currentActivityImpl = e.getActivity();
|
// ProcessDefinitionImpl processDefinitionImpl = currentActivityImpl.getProcessDefinition();
|
// List<? extends Activity> activities = processDefinitionImpl.getActivities();
|
// for(Activity a : activities){
|
// ActivityImpl at = (ActivityImpl)a;
|
// ActivityBehaviour activityBehaviour = at.getActivityBehaviour();
|
// if(activityBehaviour instanceof TaskActivity){
|
// TaskActivity ta = (TaskActivity)activityBehaviour;
|
// TaskDefinitionImpl taskDefinition = ta.getTaskDefinition();
|
//
|
// String assigneeExpression = taskDefinition.getAssigneeExpression();
|
// String candidateUsersExpression = taskDefinition.getCandidateUsersExpression();
|
// System.out.println("Task:"+taskDefinition.getName()+"--- 用户assigneeExpression："+assigneeExpression);
|
// System.out.println("Task:"+taskDefinition.getName()+"--- 用户candidateUsersExpression："+candidateUsersExpression);
|
// taskDefinition.setAssigneeExpression("t1");
|
// taskDefinition.setCandidateUsersExpression("t2,t3");
|
// System.out.println("Tasknew:"+taskDefinition.getName()+"--- 用户assigneeExpression："+taskDefinition.getAssigneeExpression());
|
// System.out.println("Tasknew:"+taskDefinition.getName()+"--- 用户candidateUsersExpression："+taskDefinition.getCandidateUsersExpression());
|
//// taskService.addTaskParticipatingUser(,
|
//// null, Participation.CANDIDATE);
|
//
|
// }
|
// }
|
// catch (Exception e) {
|
// TODO Auto-generated catch block
|
// e.printStackTrace();
|
// }
|
|
// Task nextTask = taskService.createTaskQuery()
|
// .processInstanceId(task.getExecutionId())
|
// .uniqueResult();
|
// String[] nextTaskCandidateUsers = s.nextTaskCandidateUsers(task.getExecutionId(),nextTask.getName());
|
// for(String s1 : nextTaskCandidateUsers){
|
// System.out.println(s1);
|
// }
|
// taskService.removeTaskParticipatingUser(taskId, userId, participationType);
|
// taskService.addTaskParticipatingUser(nextTask.getId(),
|
// null, Participation.CANDIDATE);
|
// identityService.createUser("123", "", "");
|
|
|
// BigDecimal deploymentID = s.getDeploymentID("分支-4");
|
// String jbpmDeploymentId = deploymentID.toString();
|
// try {
|
// //获取分支对应的任务节点
|
// s.getAllTaskNames(jbpmDeploymentId);
|
// } catch (Exception e) {
|
// e.printStackTrace();
|
// }
|
|
|
|
// startProcess(processDefinitionKey, processEngine, variables);
|
// getForInfo(processDefinitionKey, processEngine, variables);
|
// completeTask(processDefinitionKey, processEngine, variables);
|
// try {
|
// s.getCurCandidates("", "", outcome);
|
// } catch (Exception e) {
|
// // TODO Auto-generated catch block
|
// e.printStackTrace();
|
// }
|
// System.out.println(WorkFlowCahe.getTemplateMap());
|
}
|
|
/**
|
* 流程启动
|
* @param processDefinitionKey
|
* @param processEngine
|
* @param variables
|
*/
|
private void startProcess(String processDefinitionKey,
|
ProcessEngine processEngine, Map<String, Object> variables) {
|
//System.out.println("startProcessInstanceById开始！");
|
ProcessInstance processInstance = processEngine.getExecutionService().startProcessInstanceById(processDefinitionKey, variables);
|
//System.out.println("startProcessInstanceById结束！");
|
FlowInstance flowInstance = new FlowInstance();
|
String flowInstanceId = ObjectUtility.getNewObjectID36();
|
flowInstance.setId(flowInstanceId);
|
String proccessInstanceId = processInstance.getId();
|
TaskService taskService = processEngine.getTaskService();
|
TaskQuery activityName = processEngine.getTaskService().createTaskQuery().processInstanceId(proccessInstanceId).activityName("任务１");
|
Task task = activityName.uniqueResult();
|
//System.out.println(task.getActivityName());
|
taskService.completeTask(task.getId());
|
}
|
|
private void getForInfo(String processDefinitionKey,
|
ProcessEngine processEngine, Map<String, Object> variables){
|
List<Task> findPersonalTasks = processEngine.getTaskService().findPersonalTasks("2222222222222");
|
for(Task task : findPersonalTasks){
|
System.out.println(task.getActivityName());
|
}
|
}
|
|
private void completeTask(String processDefinitionKey,
|
ProcessEngine processEngine, Map<String, Object> variables){
|
// ProcessInstanceQuery processInstanceKey = processEngine.getExecutionService().createProcessInstanceQuery().processDefinitionId("");
|
// ProcessInstance uniqueResult = processInstanceKey.uniqueResult();
|
// String proccessInstanceId = uniqueResult.getId();
|
TaskService taskService = processEngine.getTaskService();
|
TaskQuery activityName = processEngine.getTaskService().createTaskQuery().activityName("任务２");
|
Task task = activityName.list().get(0);
|
taskService.completeTask(task.getId(),"同意");
|
|
|
// String processInstanceId = uniqueResult.getId();
|
// List<Task> subTasks = taskService.getSubTasks("");
|
|
// List<Task> joinTask=taskService.getSubTasks("60001");
|
// System.out.println(joinTask);
|
}
|
|
private void deleteTask(String processDefinitionKey,
|
ProcessEngine processEngine, Map<String, Object> variables){
|
TaskService taskService = processEngine.getTaskService();
|
taskService.deleteTask("");
|
}
|
// @Test
|
// public void testCompleteTask() {
|
// fail("Not yet implemented");
|
// }
|
|
// public static void main(String[] args) {
|
// ProcessTemplateService service = new ProcessTemplateService();
|
// Map<String, String[]> taskAndUserMap = new HashMap<String, String[]>();
|
// taskAndUserMap.put("task", new String[]{"1","2"});
|
// service.configTaskAndUser("dddd", new String[]{"dddss"}, taskAndUserMap);
|
// }
|
}
|
