一个最符合中国国情的工作流设计参考（包括PHP实现）

港控/mmm° 2022-08-09 03:17 111阅读 0赞

工作流很少有让人满意的，即便是国内用的比较多的jbpm，用起来也会觉得很便扭。再加上PHP中没有什么好用的工作流，于是干脆自己设计一个，设计的原则如下：

1 根据80/20原则，只使用wfmc模型中最符合自身应用的20％功能

2 充分吸收国内使用jbpm开发BOSS中遇到的问题，工作流引擎只负责参数的收集和流程的流转，具体和业务的控制，交给每个流程定制的控制类去实现。

3 表单采用简单的html+控制标签的方法实现

4 权限和模板引擎，以及其它辅助函数直接使用办公系统自带的框架

5 充分利用PHP语言的特点，流程设计是基于数据库的，程序上使用OO设计，但采用重对象的方法

6 不把可视化设计流程的工作交给最终客户，而且由设计时完成，因此不考虑流程版本更新的问题

一、工作流数据表设计

tbl\_workflow\_defination：工作流定义表

<table style="color:rgb(51,51,51)"> 
 <tbody> 
 <tr> 
 <td> defination_id </td> 
 <td> 流程id </td> 
 <td> &nbsp; </td> 
 </tr> 
 <tr> 
 <td> defination_name </td> 
 <td> 流程名称 </td> 
 <td> &nbsp; </td> 
 </tr> 
 <tr> 
 <td> defination_handler </td> 
 <td> 流程处理辅助文件，每个工作流一个文件 </td> 
 <td> 自定义处理文件，及其对象。例如workflow-proporsal-handler.php，其中定义对象proposal </td> 
 </tr> 
 </tbody> 
</table>

tbl\_workflow\_node：流程结点步骤表

<table style="color:rgb(51,51,51)"> 
 <tbody> 
 <tr> 
 <td> node_id </td> 
 <td> 结点id </td> 
 <td> &nbsp; </td> 
 </tr> 
 <tr> 
 <td> defination_id </td> 
 <td> 流程id </td> 
 <td> &nbsp; </td> 
 </tr> 
 <tr> 
 <td> node_index </td> 
 <td> 结点序号 </td> 
 <td> 结点的step </td> 
 </tr> 
 <tr> 
 <td> node_name </td> 
 <td> 结点名称 </td> 
 <td> &nbsp; </td> 
 </tr> 
 <tr> 
 <td> node_type </td> 
 <td> 结点类型 </td> 
 <td> 1人为决策，2自动处理(直接执行execute_function)，3等待外部响应(例如外部WS触发),4分支，5汇总&nbsp;6结束结点（此结点执行时候自动终止进程） </td> 
 </tr> 
 <tr> 
 <td> init_function </td> 
 <td> 流程初始函数 </td> 
 <td> &nbsp; </td> 
 </tr> 
 <tr> 
 <td> run_function </td> 
 <td> 流程运行函数 </td> 
 <td> &nbsp; </td> 
 </tr> 
 <tr> 
 <td> save_function </td> 
 <td> 流程保存函数 </td> 
 <td> &nbsp; </td> 
 </tr> 
 <tr> 
 <td> transit_function </td> 
 <td> 流程流转函数 </td> 
 <td> &nbsp; </td> 
 </tr> 
 <tr> 
 <td> prev_node_index </td> 
 <td> 前结点序号 </td> 
 <td> 例如1。开始结点没有 执行前，通过此来校验一下流程 </td> 
 </tr> 
 <tr> 
 <td> next_node_index </td> 
 <td> 后结点序号 </td> 
 <td> 例如[同意]3,[不同意]4。尾结点或要结束的结点没有，若没有，直接调用end </td> 
 </tr> 
 <tr> 
 <td> executor </td> 
 <td> 执行角色，组，人 </td> 
 <td> role[1,2] group[1,2] user[1,2],为空由运行时决定 </td> 
 </tr> 
 <tr> 
 <td> execute_type </td> 
 <td> 执行类型 </td> 
 <td> 0需所有人执行&nbsp;1只需一人执行 </td> 
 </tr> 
 <tr> 
 <td> remind </td> 
 <td> 提醒 </td> 
 <td> 0不提醒&nbsp;1邮件&nbsp;2短信&nbsp;3邮件和短信 </td> 
 </tr> 
 <tr> 
 <td> field </td> 
 <td> 可编辑的字段 </td> 
 <td> name,content </td> 
 </tr> 
 <tr> 
 <td> max_day </td> 
 <td> 最长时间(天) </td> 
 <td> &nbsp; </td> 
 </tr> 
 </tbody> 
</table>

tbl\_workflow\_process ：流程执行进程表

<table style="color:rgb(51,51,51)"> 
 <tbody> 
 <tr> 
 <td> process_id </td> 
 <td> 进程id </td> 
 <td> &nbsp; </td> 
 </tr> 
 <tr> 
 <td> defination_id </td> 
 <td> 流程id </td> 
 <td> &nbsp; </td> 
 </tr> 
 <tr> 
 <td> process_desc </td> 
 <td> 进程描述 </td> 
 <td> 显示在我的工作台中 </td> 
 </tr> 
 <tr> 
 <td> context </td> 
 <td> 上下文 </td> 
 <td> 存放上下文变量,例如业务表的id </td> 
 </tr> 
 <tr> 
 <td> current_node_index </td> 
 <td> 当前结点序号 </td> 
 <td> &nbsp; </td> 
 </tr> 
 <tr> 
 <td> start_time </td> 
 <td> 流程启动时间 </td> 
 <td> 如遇分支、汇合显示为： 1＝》3,4＝》3,5＝》6 </td> 
 </tr> 
 <tr> 
 <td> finish_time </td> 
 <td> 流程完成时间 </td> 
 <td> &nbsp; </td> 
 </tr> 
 <tr> 
 <td> state </td> 
 <td> 状态 </td> 
 <td> 1运行&nbsp;2结束 </td> 
 </tr> 
 <tr> 
 <td> start_user </td> 
 <td> 发起人 </td> 
 <td> 发起人，用于显示自己的流程 </td> 
 </tr> 
 </tbody> 
</table>

tbl\_workflow\_thread ：流程执行线程表

<table style="color:rgb(51,51,51)"> 
 <tbody> 
 <tr> 
 <td> thread_id </td> 
 <td> 线程id </td> 
 <td> &nbsp; </td> 
 </tr> 
 <tr> 
 <td> process_id </td> 
 <td> 进程id </td> 
 <td> &nbsp; </td> 
 </tr> 
 <tr> 
 <td> process_desc </td> 
 <td> 进程描述 </td> 
 <td> &nbsp; </td> 
 </tr> 
 <tr> 
 <td> node_id </td> 
 <td> 结点id </td> 
 <td> &nbsp; </td> 
 </tr> 
 <tr> 
 <td> node_name </td> 
 <td> 结点名称 </td> 
 <td> &nbsp; </td> 
 </tr> 
 <tr> 
 <td> executor </td> 
 <td> 执行人 </td> 
 <td> &nbsp; </td> 
 </tr> 
 <tr> 
 <td> start_time </td> 
 <td> 线程生成时间 </td> 
 <td> &nbsp; </td> 
 </tr> 
 <tr> 
 <td> receive_time </td> 
 <td> 线程接收时间 </td> 
 <td> &nbsp; </td> 
 </tr> 
 <tr> 
 <td> finish_time </td> 
 <td> 线程完成时间 </td> 
 <td> &nbsp; </td> 
 </tr> 
 <tr> 
 <td> max_time </td> 
 <td> 结点规定的最长时间 </td> 
 <td> &nbsp; </td> 
 </tr> 
 <tr> 
 <td> state </td> 
 <td> 状态 </td> 
 <td> 0未接收&nbsp;1已接收&nbsp;2已处理 </td> 
 </tr> 
 </tbody> 
</table>

二、常见流程

人工决策

<table> 
 <tbody> 
 <tr> 
 <td> 部门领导审批 </td> 
 </tr> 
 </tbody> 
</table>

外部响应

<table style="color:rgb(51,51,51)"> 
 <tbody> 
 <tr> 
 <td> 发送支付信息 </td> 
 </tr> 
 </tbody> 
</table>

<table> 
 <tbody> 
 <tr> 
 <td> 
 <div> 
 接收支付成功响应（外部WS触发该流程） 
 </div> </td> 
 </tr> 
 </tbody> 
</table>

三、PHP设计

运行的函数由结点在设计时候决定，如果没有设定，就使用默认的函数。利用了PHP语言的以下特性

<table style="color:rgb(51,51,51)"> 
 <tbody> 
 <tr> 
 <td> <code>&lt;?php</code> <code>class&nbsp;</code><code>Foo</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;function&nbsp;</code><code>Variable</code><code>()</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>$name&nbsp;</code><code>=&nbsp;</code><code>'Bar'</code><code>;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>$this</code><code>-&gt;</code><code>$name</code><code>();&nbsp;</code><code>//&nbsp;This&nbsp;calls&nbsp;the&nbsp;Bar()&nbsp;method</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;function&nbsp;</code><code>Bar</code><code>()</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;echo&nbsp;</code><code>"This&nbsp;is&nbsp;Bar"</code><code>;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;}</code> <code>}</code> <code>$foo&nbsp;</code><code>=&nbsp;new&nbsp;</code><code>Foo</code><code>();</code> <code>$funcname&nbsp;</code><code>=&nbsp;</code><code>"Variable"</code><code>;</code> <code>$foo</code><code>-&gt;</code><code>$funcname</code><code>();&nbsp;&nbsp;</code><code>//&nbsp;This&nbsp;calls&nbsp;$foo-&gt;Variable()</code> <code>?&gt;</code> </td> 
 </tr> 
 </tbody> 
</table>

使用前可以用method\_exists来检查。

WorkflowService.php

WorkflowService

$defination

$process

$node

$thread

$input 用户输入的和流程有关的变量

list\_defination()

init\_process(defination\_id)

\{  global user;

取得$defination，得到业务的handler,例如WorkflowProposalHandler

建立$process行记录

start\_process()

\{  调用WorkflowProposalHandler->start($process)//新建业务对象，并把业务类的参数例如proposal\_id放到$process\[‘context’\]里面

init\_thread(1);  //默认调用第一个结点

list\_ my\_thread ()

\{  global user;

init\_thread(node\_index)

取得$node

取得$process

修改$process为运行到当前结点

Switch($node\[‘node\_type’\])

Case 1: 人工决策

建立$thread

WorkflowProposalHandler-> init\_function ($process,$node,$thread)

发送提醒

Case 2: 自动处理

建立$thread

WorkflowProposalHandler-> init\_function ($process,$node,$thread)

调用run\_thread(thread\_id)

Case 3: 等待外部响应

建立$thread

WorkflowProposalHandler-> init\_function ($process,$node,$thread)

Case 4: 分支

取得所有分支的子结点

init\_thread(子结点)

Case 5: 汇总：

取得所有前结点，如果所有前结点的Thread都结束了，调出下一结点

调用init\_thread(子结点)

Case 6: 结束：直接结束进程process

end\_process()

run\_thread(thread\_id)

取得$node

取得$process

取得$thread

Switch($node\[‘node\_type’\])

Case 1: 人工决策

修改$thread为已接收

WorkflowProposalHandler-> run\_function ($process,$node,$thread) 显示表单

Case 2: 自动处理

修改$thread为已接收

$next\_node\_id=WorkflowProposalHandler-> run\_function ($process,$node,$thread)

调用transit\_thread(thread\_id, $next\_node\_id)

Case 3: 等待外部响应

修改$thread为已接收

$next\_node\_id=WorkflowProposalHandler-> run\_function ($process,$node,$thread)

transit\_thread(thread\_id, $next\_node\_id)

Case 4: 分支

Case 5: 汇总：

Case 6: 结束：

save\_thread(thread\_id)

\{  //保存结点数据

取得$node

取得$process

取得$thread

Switch($node\[‘node\_type’\])

Case 1: 人工决策

WorkflowProposalHandler-> save\_function ($process,$node,$thread) 保存表单

WorkflowProposalHandler-> run\_function ($process,$node,$thread) 显示表单

Case 2: 自动处理

Case 3: 等待外部响应

Case 4: 分支

Case 5: 汇总：

Case 6: 结束：

transit\_thread(thread\_id, $next\_node\_id)

\{ 取得$node

取得$process

取得$thread

Switch($node\[‘node\_type’\])

Case 1: 人工决策

WorkflowProposalHandler->transit\_function($process,$node,$thread,$next\_node\_id)

修改$thread为已完成

If($next\_node\_id < $ cur\_node\_id) \{ //回退

删除所有大于$next\_node\_id的Thread

init\_thread($next\_node\_id)

Case 2: 自动处理

修改$thread为已完成

If($next\_node\_id < $ cur\_node\_id) \{ //回退

删除所有大于$next\_node\_id的Thread

init \_thread($next\_node\_id)

Case 3: 等待外部响应

修改$thread为已完成

If($next\_node\_id < $ cur\_node\_id) \{ //回退

删除所有大于$next\_node\_id的Thread

init \_thread($next\_node\_id)

Case 4: 分支

Case 5: 汇总：

Case 6: 结束：

end\_process()

list\_my\_process

view\_process

workflow\_proposal\_handler.php

WorkflowProposalHandler

start()

prepare\_input() 准备用户输入变量，从$\_POST收集

init\_function () 线程建立后调用的默认函数，当流程的执行者由程序生成时，在此函数内更改$thread的executor，例如直接赋值user\[2\]

run\_function () 线程运行化时候调用的默认函数

save\_function () 保存运行信息

transit\_function () 执行流转

sendmail 其它结点调用函数

workflow.php

switch(op)

case list\_defination

参数：无

WorkflowService->list\_defination()

case start\_process : 启动

参数：defination\_id

WorkflowService->init\_process(defination\_id)

WorkflowService->start\_process()

case list\_ my\_thread : 待处理的列表

WorkflowService->list\_ my\_thread()

case run\_thread :

参数：thread\_id

WorkflowService->run\_thread(thread\_id)

case save\_thread :

参数：thread\_id

把input收集起来（所有的变量以 f\_ 开头），赋给WorkflowService的Input，另外还要获得thread\_id

WorkflowService->save\_thread(thread\_id)

case transit\_thread :

参数：thread\_id

把input收集起来，赋给WorkflowService的Input，另外还要获得thread\_id

$next\_node\_id = 得到用户选择的下一结点id

WorkflowService-> transit \_thread(thread\_id，$next\_node\_id)

case list\_my\_process: 所有我发起的流程

case list\_all\_process: 所有我发起的流程

case view\_process :

在其它程序中初始化流程

1先自行建立好业务表单

2WorkflowService->init\_process(defination\_id)

3把建好的业务表单的ID放在process的context里面

4WorkflowService->init\_thread(1)

WorkflowService->transit\_thread(1，2) 通过手动调用把前面的流程过掉

外部服务继续流转流程（只用于自动流程）

1 把input收集起来，赋给WorkflowService的Input，另外还要获得thread\_id

2 WorkflowService->run\_thread(thread\_id)

一个最符合中国国情的工作流设计参考（包括PHP实现）

发表评论取消回复

还没有评论，来说两句吧...

相关阅读

相关 JAVA实现一个工作流引擎

相关 jbpm工作流(jBPM工作流组件设计分析)

相关 php替换符合,php如何替换所有符合条件的字符串

相关工作流之三：依赖mq设计工作流引擎

相关工作流参考模型

相关一个最符合中国国情的工作流设计参考（包括PHP实现）

相关 Openerp工作流参考资料

相关工作流设计参考（包括PHP实现）

相关工作流设计详解

相关工作流设计