Jbpm 常用基础方法 相关编程接口

一 ：JbpmContext类负责了对所有功能模块的管理

在Jbpm应用中，只需要：
JbpmConfiguration jbpmConfiguration = JbpmConfiguration.getInstance();
JbpmContext jbpmContext = jbpmConfiguration.createJbpmContext();
两条语句就可以配置好一切。

二：查找所有ProcessInstances

public void findAllProcessInstance() throws Exception {
List processDefinitions = jbpmContext.getGraphSession().findAllProcessDefinitions();
for(int i = 0 ; i < processDefinitions.size();i++){
ProcessDefinition processDefinition = (ProcessDefinition)processDefinitions.get(i);
long processDefinitionId = processDefinition.getId();
List processInstances = jbpmContext.getGraphSession().findProcessInstances(processDefinitionId);
for(int j =0;j<processInstances.size();j++){
ProcessInstance processInstance = (ProcessInstance)processInstances.get(i);
Collection taskInstances = processInstance.getTaskMgmtInstance().getTaskInstances();
TaskInstance taskInstance =(TaskInstance) taskInstances.iterator().next();
Map tvs = taskInstance.getVariableInstances();
if(tvs==null){
System.out.println("==task tvs is null==");
return;
}
Iterator it =tvs.entrySet().iterator() ;
while(it.hasNext() ){
Map.Entry entry = (Map.Entry)it.next() ;
System.out.println("==key is:"+entry.getKey().toString() +"==");
System.out.println("==value is:"+entry.getValue().toString() +"==");
}
 }
}
}

三：查找特定用户得任务列表

ublic void findByActorId(String actorId){
List processDefinitions = jbpmContext.getGraphSession().findAllProcessDefinitions();
for(int i = 0;i<processDefinitions.size();i++){
ProcessDefinition processDefinition = (ProcessDefinition)processDefinitions.get(i);
long processDefinitionId = processDefinition.getId();
List processInstances =jbpmContext.getGraphSession().findProcessInstances(processDefinitionId);
for(int j = 0;j<processInstances.size();j++){
ProcessInstance processIntance  = (ProcessInstance)processInstances.get(j);
System.out.println("processInstance is create in : " +processIntance.getStart().toString());
TaskMgmtSession taskMgmeSession = jbpmContext.getTaskMgmtSession();
List taskInstances = taskMgmeSession.findPooledTaskInstances(actorId);
for(int m = 0;m<taskInstances.size();m++){
TaskInstance taskInstance = (TaskInstance)taskInstances.get(i);
Map tvs = taskInstance.getVariableInstances();
if(tvs==null){
System.out.println("==task tvs is null==");
return;
}
Iterator it =tvs.entrySet().iterator() ;
while(it.hasNext() ){
Map.Entry entry = (Map.Entry)it.next() ;
System.out.println("==key is:"+entry.getKey().toString() +"==");
System.out.println("==value is:"+entry.getValue().toString() +"==");
}
}
}
}
}

四：删除一个processInstance

public void deleteProcessInstance(long processInstanceId){
//boolean flag = false;
jbpmContext.getGraphSession().deleteProcessInstance(processInstanceId);
System.out.println("delete processInstance Id is : " + processInstanceId);
//return flag;

}

五：判定用户登陆

public boolean checkUserValidate(String userName,String password) throws Exception{
 boolean flag  = false;
 Connection conn = jbpmContext.getConnection();
 Statement stmt = conn.createStatement();
 String sql = "select name_,password_ from jbpm_id_user where name_='"+userName+"'";
 ResultSet rs = stmt.executeQuery(sql);
 while(rs.next()){
 if(rs.getObject("password_").equals("password")){
 flag = true;
 
 }else{
 flag = false;
 
 }
 
 }
 rs.close();
 stmt.close();
 conn.close();
 return flag;
}

六：挂起一个实例processInstance

public void userCancleProcessInstance(long processDefinitionId ) throws Exception {
 ProcessDefinition processDefinition = jbpmContext.getGraphSession().loadProcessDefinition(processDefinitionId);
 ProcessInstance processInstance = new ProcessInstance(processDefinition);
 /*
  * 挂起一个实例
  */
 processInstance.suspend();
 Date end = new Date();
 processInstance.setEnd(end);

}

七 ： 使用TaskController 原理介绍

实现方式：

public Map useTaskController(long processDefinitionId){
Map parameters  = new HashMap();
 ProcessDefinition processDefinition = jbpmContext.getGraphSession().loadProcessDefinition(processDefinitionId);
 ProcessInstance processInstance = new ProcessInstance(processDefinition);
 TaskInstance taskInstance = processInstance.getTaskMgmtInstance().createStartTaskInstance();
 TaskController taskController = taskInstance.getTask().getTaskController();
 if (taskController!=null) {
      List variableAccesses = taskController.getVariableAccesses();
      Iterator iter = variableAccesses.iterator();
      while (iter.hasNext()) {
        VariableAccess variableAccess = (VariableAccess) iter.next();
        String mappedName = variableAccess.getMappedName();
        Object value = taskInstance.getVariable(mappedName);
        parameters.put(mappedName, value);
       }
 
 }
 return parameters;
}