public interface WorkflowEngine{
/**
核心是:拿到定义,部署定义
*inputStream the content of process definition
id of the new deployed process
remark
*/
public long deployProcessDefinition(InputStream inputStream,String remark);
/*
*启动流程之后,第一个节点随之结束,执行点在第二个节点
pdname 流程定义的名称
starter 流程的启动者
version 流程定义的版本,如果不为空,则启动指定版本的流程
long 返回刚启动的流程实例的id
varMap 变量列表,在工作流启动的时候,可以设置些变量进去
*/
public String startProcess(Strin pname,String starter,String version,Map varMap);
/**
* 获取参与者指定状态的任务列表
actorId 参与者id
status 任务的状态
PagedObject 分页后的结果集
*/
public PagedObject getWorkList(String actorId,WorkitemCriteria wc);
/**
* 办理任务,主要实现任务的签收
actorId 任务参与者id
wid 工作项id
*/
public String takeWorkitem(String actorId,String wid);
/**
*完成任务
*/
public void completeWorkitem(String currentWorkItemId ,NextStep nextStep);
}
public class JbpmImpl implements WorkflowEngine{
public String deployProcessDefinition(InputStream inputStream,String remark){
JbpmContext jbpmContext = JbpmConfiguration.getInstance().getCurrentJbpmContext();
ProcessDefinition pd = ProcessDefinition.parseParZipInputStream(new ZipInputStream(inputStream));
jbpmContext.deployProcessDefinition(pd);
//可以将remark存入我们自己扩充的表里
return Long.toString(pd.getId());
}
public String startProcess(String pdname,String starter,String version,Map varMap){
ProcessDefinition pd = null;
JbpmContext jbpmContext = JbpmConfiguration.getInstance().getCurrentJbpmContext();
if(version != null){ //如果version为空,则获得最新版本的流程定义
pd = jbpmContext.getGraphSession().findProcessDefinition(pdname,Integer.parseInt(version));
}else{
pd = jbpmContext.getGraphSession().findLatestProcessDefinition(pdname);
}
ProcessInstance pi = new ProcessInstance(pd);
if(varMap != null){
for(Iterator it =varMap.keySet().iterator();it.hasNext()){
String varName = (String)it.next();
pi.getContextInstance().setVariable(varName,varMap.get(varName));
}
}
pi.getInstance().setVariable("starter",starter); //为了以后的节点可以拿到它
jbpmContext.setActorId(starter); //设置参与者
//如果开始节点有Task和没有Task的不同处理,如果没有Task,那么endTime当然可以不用设置
if(pi.getTaskMgmtInstance().getTaskMgmtDefinition().getStartTask() != null){
TaskInstance ti = pi.getTaskMgmtInstance().createStartTaskInstance();
ti.start();
ti.end()
}else{
pi.signal();
}
jbpmContext.save(pi);
return Long.toString(pi.getId());
}
public PagedObject getWorkList(String actorId,WorkitemCriteria wc){
PagedObject po = new PagedObject();
JbpmContext jbpmContext = JbpmConfiguration.getInstance().getCurrentJbpmContext();
Criteria rootCriteria = jbpmContext.getSession().createCriteria(TaskInstance.class);
if(wc.getPdname() != null && !"".equals(wc.getPdname()))
rootCriteria.createAlias("processInstance","pi")
.createAlias("pi.processDefinition","pd")
.add(Expression.like("pd.name"),wc.getPdname());
if(wc.getActorIdea() != null && !"".equals(wc.getActorIdea()))
rootCriteria.add(Expression.eq("actorId",actorId));
if(wc.getTname()!= null && !"".equals(wc.getTname()))
rootCriteria.add(Expression.like("name",wc.getTname()));
if(wc.getStatus() != null){
if("0".equals(wc.getStatus())) //刚创建
rootCriteria.add(Expression.and(Expression.isNull("start"),Expression.isNull("end")));
if("1".equals(wc.getStatus())) //任务已经启动
rootCriteria.add(Expression.and(Expression.isNotNull("start"),Expression.isNull("end")));
if("2".equals(wc.getStatus())) //任务完成
rootCriteria.add(Expression.and(Expression.isNotNull("start"),Expression.isNotNull("end")));
}
int total = (Integer)(rootCriteria.setProjection(org.hibernate.criterion.Projections.countDistinct("id")).uniqueResult()).intValue();
rootCriteria.setProjection(null);
rootCriteria.setMaxResults(wc.getNeveryPage());
rootCriteria.setFirstResult(wc.getStart());
List list = rootCriteria.setResultTransformer(Criteria.DISINCT_ROOT_ENTITY).list();
po.setResult(list);
po.setTotal(total);
po.setNpages((total+wc.getNereryPage()-1)/wc.getNereryPage());
return po;
}
public String takeWorkitem(String actorId,String wid){
JbpmContext jbpmContext = JbmpConfiguration.getInstance().getCurrentJbpmContext();
TaskInstance ti = jbpmContext.loadTaskInstance(Long.parseLong(wid));
if(ti.getStart() != null){
ti.start();
if(actorId != null)ti.start(actorId);
}
String pdname = ti.getProcessInstance().getProcessDefinition().getName();
String view = ProcessViewMap.getView(pdname);
return view
}
//完成任务的核心是 ti.end(),但是是需要end到下
public void completeWorkitem(String currentWorkItemId ,NextStep nextStep){
JbpmContext jbpmContext = JbpmConfiguration.getInstance().getCurrentJbpmContext();
TaskInstance ti = jbpmContext.loadTaskInstance(Long.parseLong(currentWorkItemId));
if(nextStep != null){
if(nextStep.getActorId() != null&&!"".equals(nextStep.getActorId())) //下一步可能有多个执行者,把这个设置进去
ti.getProcessInstance().getContextInstance().setVariable("actorId",nextStep.getActorId());
if(nextStep.getNextStepName() != null && !"".equals(nextStep.getNextStepName())){
ti.end(nextStep.getNextStepName());
}
}else{
ti.end();
}
}
}
public class ServiceLocator{
public static WorkflowEngine getWorkflowEngine(){
return new JbpmImpl();
}
}
public class PagedObject{
private int ncurrentPage;
private static int N_EVERY_PAGE = 10;
private List result;
private int total;
public int getNpages(){
return (total+N_EVERY_PAGE -1)/N_EVERY_PAGE;
}
}
public class WorkitemCriteria{
private String pdname;
private String tname;
private String status;
private String actorId;
private int start;
private int maxResult;
}
public class NextStep{
private String nextStepName;
private String actorId;
}
分享到:
相关推荐
5. **服务封装**:jbpm 5.0支持服务组件的封装,可以通过服务代理将外部系统整合进流程中,如Web服务、EJB或任何其他可调用的服务。 6. **工作流建模工具**:jbpm提供了基于Eclipse的建模工具,使得开发者可以图形...
开发者可以利用Java的面向对象特性,通过继承、多态和封装等机制,灵活地构建和扩展业务流程。 总的来说,"jbpm-jpdl-javadoc"是jbpm框架中JPDL部分的API文档,它为Java开发者提供了一套完整的参考指南,帮助他们...
3. 创建Service Bean:实现对JBPM API的封装,如startProcess、completeTask等方法。 4. 配置Struts2:编写Struts2动作类,注入Service Bean,根据用户请求调用相应的方法。 5. 实现流程交互:在Struts2的Action中...
2. **数据处理**:在BPEL流程中,数据通常被封装为消息,并且可以在不同的服务之间传递。jBPM支持高级的数据处理功能,如变量映射、数据转换等,确保了数据的一致性和完整性。 3. **与流程的交互**:除了传统的...
你可以自定义服务任务的行为,将业务逻辑封装在Java服务类中,并通过工作流引擎调用。 9. **异常处理与回退**:jbpm允许定义异常处理和回退策略,当流程执行过程中遇到问题时,可以根据预设规则进行错误恢复或流程...
jbpm封装则是将jbpm的核心功能进行二次开发,以适应特定项目需求或提高开发效率的过程。 在jbpm封装中,通常会涉及到以下几个关键知识点: 1. **流程定义(BPMN 2.0)**:jbpm基于Business Process Model and ...
KieContainer 是一个资源库和会话接口封装,提供了 KieBase、KieSession 和 StatelessKieSession 等接口。 JBPM7 基础开发是基于流程引擎的开发方式和实现方式的简单说明,旨在提高不同部门之间业务的整合效率,...
【标题】"JBPM4 web设计器实践--命令模式的使用"揭示了在JBPM4中如何运用命令模式来提升流程设计的效率与可维护性。命令模式是一种设计模式,它将请求封装为一个对象,使得我们可以用不同的请求对客户进行参数化,对...
1. **spring-modules-jbpm31.jar**:这是Spring与JBPM集成的一个模块,包含Spring对JBPM的封装和扩展,使得可以在Spring环境中方便地使用JBPM的功能。 2. **项目源代码(全,不含jar包).rar**:这可能是一个完整的...
服务类封装了对工作流的操作,而DAO类则负责与数据库的交互,如保存流程实例、查询任务信息等。 在实际操作中,可能还需要处理事务的边界,确保在执行工作流操作时,相关的业务数据也能正确地保存或更新。SSH框架...
用户任务代表需要人工参与的活动,服务任务则对应系统自动完成的任务,子流程可以封装复杂的流程结构。 4. **变量和数据管理**: 流程实例在运行过程中,会涉及到数据的传递和存储,jbpm通过变量机制管理这些数据。 ...
通过SSH的集成,我们可以将这些复杂的业务逻辑封装起来,使得Web应用更加模块化,同时保持良好的可扩展性和维护性。 总的来说,SSH+JBPM4.3的整合使得开发者能够在一个统一的框架下处理业务逻辑和流程管理,提高...
- 创建一个ActionForm,用于封装与工作流相关的参数,如任务ID、流程实例ID等。 - 设计视图,显示工作流的状态、任务列表,以及处理任务的表单。你可以使用Struts的标签库来帮助渲染这些视图。 - 编写业务逻辑,...
- 其他辅助类和工具,如数据访问对象(DAO)和模型对象,用于与数据库交互和封装业务逻辑。 通过分析这些源代码,我们可以了解开发者如何根据实际需求对jbpm进行了定制,从而更好地理解和应用jbpm框架。对于想要...
jbpm4的流程启动、结束等操作可以通过Struts2的Action类进行封装,提供Web界面操作。 - **Action与流程**:jbpm4的流程状态可以通过Struts2的Action传递给视图层,用户可以在页面上查看或操作流程。 4. **整合过程...
5. **业务逻辑封装**: 在SSH中封装jbpm的API,以便在业务层调用,如创建流程实例、查询任务等。 6. **视图展示**: 设计用户界面,展示流程状态、任务列表等,用户可以通过界面完成任务操作。 **总结** jbpm4.4与...