工作流设计(共11页).doc

《工作流设计(共11页).doc》由会员分享，可在线阅读，更多相关《工作流设计(共11页).doc（11页珍藏版）》请在淘文阁 - 分享文档赚钱的网站上搜索。

1、精选优质文档-倾情为你奉上 SevenStar Workflow Enginee 简单就是美。IT领域向来是名词、概念泛滥，正所谓一流公司做标准，经过这些大公司炒作之后，简单问题复杂化，EJB、EAI、ESB、SOA、工作流等等概莫如是。稳定可靠的系统建立在简单的结构之上，简单带来的是全面的优势，性能、可维护性、可控性、可扩展性等等。在清晰的明白所要解决的问题以及如何解决之后，便会发现，其实并没有那么复杂。引擎只是工作流系统中的一部分,其他还有流程设计工具等,在这里我们只对引擎做简单介绍.1 问题的提出在有工作流引擎之前，不外乎是借助状态字段来完成流程性功能。示例代码如下:public voi

2、d doFlow(String sts) if(“A”.equals(sts) int result = do 业务代码1。 if(result 0) doFlow(“B”); else doFlow(“C”); if(“B”.equals(sts) int result = do 业务代码2。 if(result 0) doFlow(“C”); else doFlow(“D”); if(“C”.equals(sts) int result = do 业务代码3。 if(result 0) doFlow(“A”); else doFlow(“B”); if(“D”.equals(sts) 业务

3、代码4。 return;/结束如上代码所示，复杂的并不是业务逻辑代码，而是代码承担了过多的职责，夹杂了复杂的流程逻辑判断。显然，我们将这段代码进行职责分离能够降低代码复杂性。合适的架构来自于Refector，工作流引擎亦来源于流程逻辑从业务逻辑中的分离。目标明确了，当然我们需要归纳分析具体有哪些流程逻辑，之后才能升华。抛开工作流、流程、节点、任务等已被定义的概念，按照自己的思路去思考引擎所要解决的系列逻辑问题如下： 工作流核心逻辑1) 处理先后顺序。2) 谁能处理。3) 是否可以处理了。4) 如何处理。5) 在哪里处理。6) 处理完后如何切换状态。 工作流考虑问题1) 版本问题。工作流的逻辑是

4、会变化的，自然是老的走老的，新的走新的。2) 每次的处理顺序记录。需要引入流程定义与实例的概念，显然每次的处理逻辑都可能是不一样的。3) 子流程问题。父流程，子流程如何交互？4) 聚合分支问题。5) 动态人员分配问题，即无法在流程定义的时候定义谁来处理这个问题，只有在运行时才能确定。比如考核，只有在运行时，根据被考核人，才能确认它的考核人是谁（被考核人的上级）。6) 流程事件 工作流与应用系统整合的问题1) 如何整合应用系统与工作流系统的权限。2) 如何让用户直接查询到需要处理的流程主体列表，比如合同列表、申请列表等。3) 如何整合应用系统与工作流系统的事务。4) 应用系统与工作流系统如何交互

5、。基于以上考虑，参考各大流行工作流引擎，我们设计了SevenStar Workflow Engine可以说它未必是规范、完美的，但一定是相当实用的，没有丝毫学院派味道。2 引擎模型 图 2-1-1 引擎模型图引擎将工作流的定义与运行完全分离，这样可以在运行时改变流程。 Definition1. 流程定义：功能为区分不同的流程，需要考虑的主要是版本问题，主要属性如下 序号名称列名类型备注1流程名称idnumber(12)2流程版本namevarchar2(200)3流程主体类型mainpart_typevarchar2(200)流程处理的主体类型，比如说 合同/申请/审批/请假 等2. 节点定义

6、：流程定义与节点定义为1对多关系，节点需要考虑的主要问题1) 聚合分叉，即串并行问题2) 节点执行条件，特殊情况下要考虑节点是否能启动序号名称列名类型备注1ididnumber(12)2节点名称namevarchar2(100)3显示名称display_namevarchar2(100)4流程定义proc_def_idnumber(12)5节点类型typevarchar2(10)start 起始节点startfork 起始分叉end 结束节点endjoin 结束聚合fork 分叉节点join 聚合节点joinfork 分叉聚合plain 普通6节点执行条件类型condition_typevar

7、char2(10)如果是shell，则value为 脚本id如果是action，则为实现类主要在于实现join的节点，只有判断所有的节点都到了才能执行7节点执行条件condition_valuevarchar2(20)3. 任务定义：节点定义与任务定义为一对多关系，任务需要考虑的主要问题1) 任务的类型，任务可能是表单/工单、动态表单，也可能是java代码、脚本、启子流程等2) 任务可能是必须执行的,也可能是可选的,比如OA中的办与阅的任务3) 任务的完成,可以执行此任务的可能有多个人员分配,可能中间一个人完成了就可以了,也可能需要所有人一起完成,也可能是认领模式,当然也可能是更灵活的模式序号

8、名称列名类型备注1ididnumber(12)2任务名称namevarchar2(200)3任务显示名称display_namevarchar2(200)4节点node_def_idnumber(12)5任务类型action_typevarchar2(20)form 表单执行(人工任务)，填urldynamic 动态表单action 后台任务shell 脚本subflow 子流程6任务值action_valuevarchar2(1000)看action_type的值如果是 form，则填入表单页面如果是 dynamic，则填入动态表单id如果是action，则填入实现类如果是shell，则填入

9、beanshell调用脚本id如果是subflow，则填入子流程id7是否必须完成is_mustvarchar2(1)Y/N如果必须完成的话，只有完成，节点才能往后走8是否必须每个人都完成is_allvarchar2(1)Y/N如果必须全部完成，只有分配的人员每个人都完成了，任务才能完成，节点才能往后走9是否打开认领模式is_claimvarchar2(1)Y/N如果是认领模式，分配人员必须先认领，才能开始做任务人员分配定义：即任务上的人员分配定义,哪些人可以执行此任务,需要考虑的问题1) 与现有权限架构的整合2) 运行时才能确认可以执行人员的问题序号名称列名类型备注1ididnumber(1

10、2)2分配类型assign_typevarchar2(200)user/role/dept/group。action/shell 如果是action/shell的话那就是根据脚本确定执行人，比如人员是根据 创建人动态确定的3分配值assign_valuevarchar2(200)如果是user，则为user_iddept则为dept_id4分配名称assign_namevarchar2(200)5任务定义表task_def_idnumber(12)7状态stsvarchar2(1)任务事件定义：即任务的Action监听事件序号名称列名类型备注1ididnumber(12)2事件名称nameva

11、rchar2(100)3事件显示名称display_namevarchar2(200)4事件类型typevarchar2(100)start/end/error/finally/back5关联类型target_typevarchar2(100)node/task6关联值target_valuevarchar2(200)7动作类型action_typevarchar2(100)action/shell8动作值action_valuevarchar2(200)9状态stsvarchar2(1)Y/N4. 路径定义：即节点之间走向,状态切换,主要考虑的问题1) 动态路径问题,即目标节点是运行时确认的

12、2) 路径执行的条件问题,即是否可以走这条路径序号名称列名类型备注1ididnumber(12)2节点定义node_def_idnumber(12)3转移名称namevarchar2(200)4显示名称display_namevarchar2(200)5转移条件类型condition_typevarchar2(200)action/shell如果有条件的话，只有满足条件的才能走这条路径6转移条件值condition_valuevarchar2(200)如果condition_type是action，则放实现WokflowAction接口的类路径，如果是shell，放s_flow_script表

13、的id7转移类型to_typevarchar2(200)plain 正常的路径action 通过action选择目标路径script 通过脚本选择目标路径8转移值to_valuevarchar2(200)如果to_type是plain的话，则为目标路径定义的id，如果是action，则为实现TransitionAction接口的action类路径，如果为script，则为s_flow_script表的id5. 节点事件定义：即节点的Action事件监听序号名称列名类型备注1ididnumber(12)2事件名称namevarchar2(100)3事件显示名称display_namevarcha

14、r2(200)4事件类型typevarchar2(100)start/end/error/finally/back5关联类型target_typevarchar2(100)node/task6关联值target_valuevarchar2(200)7动作类型action_typevarchar2(100)action/shell8动作值action_valuevarchar2(200)9状态stsvarchar2(1)Y/N Runtime1. 流程实例：主要考虑问题1) 流程主体,即此流程实例所处理的合同或者申请或者审批等.2) 子流程问题序号名称列名类型备注1ididnumber(12)2

15、流程定义def_idnumber(12)流程定义id3父流程任务实例task_instance_idnumber(12)父流程开启子流程的任务实例id4父流程实例parent_idnumber(12)5流程主体类型mainpart_typevarchar2(200)流程处理的主体类型，比如说 合同/申请/审批/请假 等6流程主体值mainpart_valuevarchar2(200)流程处理的主体的id，比如说 合同id/申请id/审批id/请假id 等2. 节点实例：序号名称列名类型备注1ididnumber(12)2当前节点node_def_idnumber(12)4流程实例proc_in

16、stance_idnumber(12)5子流程实例sub_proc_instance_idnumber(12)3. 任务实例：序号名称列名类型备注1ididnumber(12)2任务定义task_def_idnumber(12)3流程定义名称proc_def_namevarchar2(200)4流程实例proc_instance_idnumber(12)5节点实例node_instance_idnumber(12)4. 人员分配实例：序号名称列名类型备注1ididnumber(12)2任务分配swimlane_idnumber(12)3分配类型assign_typevarchar2(100)u

17、ser/role/dept/group。action/shell 如果是action/shell的话那就是根据脚本确定执行人，比如人员是根据 创建人动态确定的4分配值assign_valuevarchar2(100)如果是user，则为user_iddept则为dept_id5分配名称assign_namevarchar2(200)6任务实例task_instance_idnumber(12)5. 路径实例：序号名称列名类型备注1ididnumber(12)2转移定义tran_def_idnumber(12)3当前节点实例node_instance_idnumber(12)4下个节点实例nex

18、t_node_instance_idnumber(12)5创建时间create_datedate3 应用系统集成3.1 集成的核心问题1) 列表查询问题,我们需要得到的是等待办理的申请列表或者审批列表等,而不是纯粹的任务列表,在我们这里通过 应用表与人员分配实例表做关联查询来完成2) 事务问题,工作流的事务需要与应用逻辑代码统一事务,在我们这里,工作流引擎一样使用我们自己的Persistent层框架,所以没有这个问题.3) 框架问题,工作流引擎也需要数据库存储,也就需要相应的Persistent层框架,如果使用其他引擎,往往意味着我们在一个应用里面有两个Persistent层框架. 在我们这里

19、,工作流引擎一样使用我们自己的Persistent层框架,所以没有这个问题.3.2 流程启动import org.sevenstar.wf.WorkflowEngine;import org.sevenstar.wf.engine.instance.S_flow_process_instanceDomain;S_flow_process_instanceDomain procInstanceDomain = WorkflowEngine.instance.getProcessManager().start(proc_def_name,mainpart_value); proc_def_name

20、 为流程名 mainpart_value 为流程主体值，即流程要管理的3.3 流程主体列表查询流程主体表(比如合同表/申请表)与任务人员分配实例表(s_flow_swimlane_instance)的联合查询3.4 结束任务首先关闭人员分配实例，再关闭任务，参数由页面传来WorkflowEngine.instance.getSwimlaneManager().end(swimlane_instance_id);WorkflowEngine.instance.getTaskManager().end(task_instance_id);在任务结束后，引擎会调度继续走3.5 事务注意，所有的工作流

21、API调用都必须放在一个事务里面，即在Action方法上加上SSTransaction 4 流程配置Sample4.1 办件/阅件oa中经常有办件和阅件之分，区别在于办件必须处理掉后，流程才能继续，阅件则不必。 办件 见4.3.5 Task Defination里面将 is_must 设置为Y 阅件 见4.3.5 Task Defination里面将 is_must 设置为N在流程编辑的时候，编辑一个任务，编辑相应的 是否必须完成 下拉框，如下图所示例注意，必须写任务名称，否则引擎不会生成这个任务4.2 会签oa中有会签的概念，即一个任务，必须所有人做完后才能结束如下图所示，在流程编辑时，编辑

22、任务的 是否必须全部完成 ，选择 是4.3 循环审批循环审批的任务执行人只能在运行时确定，如图所示，在任务编辑选择处理时，选择 自己定义选择类型 为 java代码，然后在 自己定义选择值 里面填上 实现 org.sevenstar.wf.action.WorkflowAction接口的实现类，在实现类中将数据插入 任务分配任意运行时表 s_flow_swimlane_instance，引擎会在走到这个节点时执行任务时 执行这个java类，如果没有人员被分配，那么引擎会结束任务往下走WorkflowAction代码如下所示：package org.sevenstar.wf.engine.action;import org.sevenstar.wf.engine.WorkflowContext;public interface WorkflowAction public void execute(WorkflowContext wc);其中WorkflowContext为当前运行时环境4.4 子流程SevenStar workflow Engine的子流程是在任务中启动的，如下图所示，选择 任务类型 为 子流程，任务值 填上 子流程 在子流程结束后，引擎会结束父流程开启子流程的任务，然后父流程继续往下走专心-专注-专业