package com.bjsxt.oa.manager.impl;
import java.io.ByteArrayInputStream;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.Set;
import org.jbpm.JbpmConfiguration;
import org.jbpm.JbpmContext;
import org.jbpm.graph.def.ProcessDefinition;
import org.jbpm.graph.def.Transition;
import org.jbpm.graph.exe.ProcessInstance;
import org.jbpm.taskmgmt.exe.TaskInstance;
import com.bjsxt.oa.manager.JbpmFacade;
import com.bjsxt.oa.model.Document;
public class JbpmFacadeImpl extends AbstractManager implements JbpmFacade {
private JbpmConfiguration jbpmConfiguration;
public long addProcessInstance(String processName, Document document) {
JbpmContext context = getJbpmContext();
ProcessDefinition def = context.getGraphSession().findLatestProcessDefinition(processName);
ProcessInstance instance = new ProcessInstance(def);
instance.getContextInstance().setVariable("document", document.getId());
//将公文标题也提交到流程实例变量中，以便在E-Mail中能够提示这个公文的名称
instance.getContextInstance().setVariable("docTitle", document.getTitle());
//将公文的相关属性设置进入流程实例变量
Map props = document.getProperties();
if(props != null){
Set entries = props.entrySet();
for (Iterator iterator = entries.iterator(); iterator.hasNext();) {
Map.Entry entry = (Map.Entry) iterator.next();
String propertyName = (String)entry.getKey();
Object obj = document.getProperty(propertyName);
//将变量放入流程实例变量
instance.getContextInstance().setVariable(propertyName, obj);
}
}
context.save(instance);
return instance.getId();
}
public void delProcessDefinition(String processName) {
JbpmContext context = getJbpmContext();
List defs = context.getGraphSession().findAllProcessDefinitionVersions(processName);
for (Iterator iterator = defs.iterator(); iterator.hasNext();) {
ProcessDefinition def = (ProcessDefinition) iterator.next();
context.getGraphSession().deleteProcessDefinition(def);
}
}
public void delProcessInstance(long processInstanceId) {
JbpmContext context = getJbpmContext();
context.getGraphSession().deleteProcessInstance(processInstanceId);
}
public String deployProcessDefinition(byte[] processDef) {
JbpmContext context = getJbpmContext();
ProcessDefinition def = ProcessDefinition.parseXmlInputStream(
new ByteArrayInputStream(processDef)
);
context.deployProcessDefinition(def);
return def.getName();
}
public String nextStep(long processInstanceId, String actorId,
String transitionName) {
JbpmContext context = getJbpmContext();
ProcessInstance instance = context.getProcessInstance(processInstanceId);
//当前节点
String currentNodeName = instance.getRootToken().getNode().getName();
//起点的名称
String startNodeName = instance.getProcessDefinition().getStartState().getName();
//如果是在起点
if(startNodeName.equals(currentNodeName)){
if(transitionName == null){
instance.signal();
}else{
instance.signal(transitionName);
}
}else{
List taskInstances = context.getTaskMgmtSession().findTaskInstances(actorId);
for (Iterator iterator = taskInstances.iterator(); iterator
.hasNext();) {
TaskInstance ti = (TaskInstance) iterator.next();
if(ti.getProcessInstance().getId() == processInstanceId){
if(transitionName == null){
ti.end();
}else{
ti.end(transitionName);
}
break;
}
}
//查找所属组的任务实例
List pooledTaskInstances = context.getTaskMgmtSession().findPooledTaskInstances(actorId);
for (Iterator iterator = pooledTaskInstances.iterator(); iterator
.hasNext();) {
TaskInstance ti = (TaskInstance) iterator.next();
if(ti.getProcessInstance().getId() == processInstanceId){
if(transitionName == null){
ti.end();
}else{
ti.end(transitionName);
}
break;
}
}
}
//返回转向之后的节点名称
return instance.getRootToken().getNode().getName();
}
//回退
public Object[] backStep(long processInstanceId, String actorId) {
JbpmContext context = getJbpmContext();
//根据流程实例标识查找流程实例
ProcessInstance instance = context.getProcessInstance(processInstanceId);
Object[] os = new Object[2];
//搜索用户对应的所有的任务实例
List taskInstances = context.getTaskMgmtSession().findTaskInstances(actorId);
for (Iterator iterator = taskInstances.iterator(); iterator
.hasNext();) {
TaskInstance ti = (TaskInstance) iterator.next();
if(ti.getProcessInstance().getId() == processInstanceId){
//先判断是否是要回退到起点
Set set = ti.getToken().getNode().getArrivingTransitions();
for (Iterator iterator2 = set.iterator(); iterator2.hasNext();) {
Transition t = (Transition) iterator2.next();
//如果它需要回退到起点
if(t.getFrom().equals(ti.getProcessInstance().getProcessDefinition().getStartState())){
int docId = (Integer)ti.getProcessInstance().getContextInstance().getVariable("document");
//结束当前的流程实例
ti.getProcessInstance().end();
//结束当前任务实例
ti.end();
//重新创建流程实例对象
ProcessInstance pi = new ProcessInstance(ti.getProcessInstance().getProcessDefinition());
pi.getContextInstance().setVariable("document", docId);
//将流程实例对象重新持久化到数据库
context.save(pi);
os[0] = Document.STATUS_NEW;
os[1] = pi.getId();
return os;
}
}
//如果不需要回退到起点
ti.end(CreateTransitionAction.BACK_TRANSITION);
break;
}
}
os[0] = instance.getRootToken().getNode().getName();
os[1] = processInstanceId;
return os;
}
public List searchMyTaskList(String actorId) {
JbpmContext context = getJbpmContext();
List docIds = new ArrayList();
List taskInstances = context.getTaskMgmtSession().findTaskInstances(actorId);
for (Iterator iterator = taskInstances.iterator(); iterator.hasNext();) {
TaskInstance ti = (TaskInstance) iterator.next();
Integer docId = (Integer)ti.getProcessInstance().getContextInstance().getVariable("document");
docIds.add(docId);
}
//查找所属组的任务实例
List pooledTaskInstances = context.getTaskMgmtSession().findPooledTaskInstances(actorId);
for (Iterator iterator = pooledTaskInstances.iterator(); iterator
.hasNext();) {
TaskInstance ti = (TaskInstance) iterator.next();
Integer docId = (Integer)ti.getProcessInstance().getContextInstance().getVariable("document");
docIds.add(docId);
}
return docIds;
}
public List searchNextTransitions(long processInstanceId, String actorId) {
JbpmContext context = getJbpmContext();
ProcessInstance instance = context.getProcessInstance(processInstanceId);
//当前节点
String currentNodeName = instance.getRootToken().getNode().getName();
//起点的名称
String startNodeName = instance.getProcessDefinition().getStartState().getName();
Collection transitions = null;
//如果是在起点
if(startNodeName.equals(currentNodeName)){
transitions = instance.getRootToken().getAvailableTransitions();
}else{
List taskInstances = context.getTaskMgmtSession().findTaskInstances(actorId);
for (Iterator iterator = taskInstances.iterator(); iterator
.hasNext();) {
TaskInstance ti = (TaskInstance) iterator.next();
if(ti.getProcessInstance().getId() == processInstanceId){
transitions = ti.getAvailableTransitions();
break;
}
}
//查找所属组的任务实例
List pooledTaskInstances = context.getTaskMgmtSession().findPooledTaskInstances(actorId);
for (Iterator iterator = pooledTaskInstances.iterator(); iterator
.hasNext();
SSH最新项目（struts+spring +hibernate+Jbpm+freemarker） （1058个子文件） 
DojoExternalInterface.as 9KB DojoExternalInterface.as 7KB Storage.as 4KB ExpressInstall.as 3KB JbpmFacadeImpl.class 8KB InitSystemDatasImpl.class 7KB DocumentAction.class 6KB AclManagerImpl.class 6KB Document.class 6KB DocumentManagerImpl.class 5KB FlowFormAction.class 5KB MeetingRoomAction.class 5KB UserManagerImpl.class 5KB UserAction.class 4KB FormManagerImpl.class 4KB MeetingRoomManagerImpl.class 4KB WorkflowAction.class 4KB OrgManagerImpl.class 3KB OrgAction.class 3KB MeetingRoomActionForm.class 3KB AbstractManager.class 3KB ModuleAction.class 3KB PersonAction.class 3KB DocumentActionForm.class 3KB AclAction.class 3KB CreateTransitionAction.class 3KB SystemExceptionHandler.class 3KB PagerFilter.class 3KB PersonActionTree.class 3KB OrgActionTree.class 3KB WorkflowManagerImpl.class 2KB ModuleManagerImpl.class 2KB RoleAction.class 2KB DocumentProperty.class 2KB FlowFormActionForm.class 2KB OrgManagerTest.class 2KB ACL.class 2KB UtilFunction.class 2KB RoleAssignmentAction.class 2KB Person.class 2KB FormField.class 2KB PersonActionForm.class 2KB PersonManagerImpl.class 2KB UserActionForm.class 2KB LoginAction.class 2KB IndexAction.class 2KB MeetingRoomApply.class 2KB DynaFormFunction.class 2KB Module.class 2KB DojoFileStorageProvider.class 2KB User.class 2KB Organization.class 2KB ApproveInfo.class 2KB SystemException.class 2KB RoleAssignmentHandler.class 2KB OrgActionForm.class 2KB BaseAction.class 2KB RoleManagerImpl.class 1KB ModuleActionForm.class 1KB Workflow.class 1KB OrgTreeFunction.class 1KB TerminateTaskInstanceAction.class 1KB WorkflowActionForm.class 1KB FlowForm.class 1KB SystemContext.class 1KB UsersRoles.class 1KB MeetingRoomManagerTest.class 1KB MeetingRoomApplyVO.class 1KB MeetingRoom.class 1KB InitServlet.class 1KB FreemarkerUtil.class 1KB UtilDateConverter.class 971B FieldInput.class 930B FieldType.class 915B AclActionForm.class 826B InitSystemDatasTest.class 809B AutoArrayList.class 802B RoleActionForm.class 775B SecurityFunctions.class 772B ByteArrayConverter.class 753B PagerModel.class 730B FieldItem.class 728B Role.class 718B FormManager.class 715B DocumentManager.class 702B JbpmFacade.class 633B UserManager.class 588B BaseUnitTest.class 514B MeetingRoomManager.class 487B AclManager.class 481B Permission.class 435B PersonManager.class 379B ModuleManager.class 341B OrgManager.class 332B RoleManager.class 321B WorkflowManager.class 309B InitSystemDatas.class 187B .classpath 5KB oa.css 6KB EditorToolbar.css 4KB共 1058 条
- 1
- 2
- 3
- 4
- 5
- 6
- 11
- 1
- 2
前往页