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

古城微笑少年丶 2022-05-15 14:22 322阅读 0赞

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

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

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

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

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

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

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

一、 工作流数据表设计

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

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

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

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

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

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

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

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

二、 常见流程

人工决策

领导传阅

部门领导审批

填写表单

结束

放弃

提交

同意

重填（退回）

不同意

完成

外部响应

发送支付信息

接收支付成功响应（外部 WS 触发该流程）

三、PHP 设计

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

<?php

class  Foo

function  Variable ()

$name  =  'Bar' ;

$this -> $name ();  // This calls the Bar() method

function  Bar ()

echo  "This is Bar" ;

\}   
\}

$foo  = new  Foo ();

$funcname  =  "Variable" ;

$foo -> $funcname ();   // This calls $foo->Variable()

使用前可以用 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)

参考文献：

[https://www.ctolib.com/topics-81696.html][https_www.ctolib.com_topics-81696.html]

[https_www.ctolib.com_topics-81696.html]: https://www.ctolib.com/topics-81696.html

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

发表评论取消回复

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

相关阅读

相关工作流引擎设计与实现·条件流程执行

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

相关工作流参考模型

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

相关 Openerp工作流参考资料

相关 PHP 工作流插件 Tpflow

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

相关工作流设计详解

相关工作流设计

相关采用SharePoint Designer设计工作流