一套完整自定义工作流的实现

摘要:
流程自定义、步骤自定义、步骤重复、步骤类型(顺序/并行)和定义排序功能,即工作流中的工作如何组织在一起的逻辑和规则在计算机中用适当的模型表示并计算。第一部分:业务逻辑分析1。自定义工作流是指工作流阶段及其参数的完全自定义_名称)2)步骤信息表:action_名称)3)流程步骤信息表(Process Step information table):Step_ action Storage处理结果:

概述:

本工作流以一套金融软件业务处理流程为例,实现功能包括:流程自定义、步骤自定义、步骤重复次数、步骤类型(顺序/并行)、定义排序功能,完全使用数据库实现,本文将详细分析业务流程、系统设计及实现细节。

术语:

工作流(Workflow)[1],是对工作流程及其各操作步骤之间业务规则的抽象、概括、描述。工作流建模,即将工作流程中的工作如何前后组织在一起的逻辑和规则在计算机中以恰当的模型进行表示并对其实施计算。工作流要解决的主要问题是:为实现某个业务目标,在多个参与者之间,利用计算机,按某种预定规则自动传递文档、信息或者任务。工作流管理系统(Workflow Management System, WfMS)的主要功能是通过计算机技术的支持去定义、执行和管理工作流,协调工作流执行过程中工作之间以及群体成员之间的信息交互。工作流需要依靠工作流管理系统来实现。

流程:工作流包含多个工作流程,处理时可任选一种流程进行处理,其包含步骤信息;

步骤:流程中每一环节的名称,某一流程将包含多个步骤(其他工作流中也称为节点)。

正文:

  第一部分、业务逻辑分析

1、自定义工作流是指工作流各个环节及其参数完全自定义,常用于公文处理、业务流程签批处理等。本系统来源于本人参与开发的一套金融管理软件,业务处理人分不同角色拥有不同权限进行业务处理,将贷款数据库从贷款调查一直到贷款签批的完整流程。其中由于软件功能要求,需要将贷款调查固定置为第一步骤,将贷款签批置为最后一步骤。

一套完整自定义工作流的实现第1张

其中数字表示当前步骤重复次数。

2、用户业务处理部分包括:

1)、通过:当前步骤处理通过,(选择下一处理人)进入当前流程中下一步骤,若为末步骤,则流程完成;

2)、退回:将步骤退回至上一步骤,即返回至上一处理人处,若为首步骤,则不可进行退回;

3)、否决:将步骤直接结束,不可再进行操作,或者回退至第一步骤;本系统中采用第二种方式;

4)、撤回:若当前步骤已处理,且在下一处理人未进行处理的情况下可进行撤回操作。

一套完整自定义工作流的实现第2张

3、顺序与并行

顺序是指上一处理人指定某一处理人时,其他拥有此步骤权限的操作员不可进行查看和操作,必须当前处理人处理完毕后,流程才能继续;并行是由上一处理人指定固定多个处理人时,由任一员工处理即可,不分前后顺序,全部处理完成,进入下一步骤,此处理人数目由当前步骤重复次数确定。

两者之间对应关系如下。

一套完整自定义工作流的实现第3张

  第二部分、系统设计

数据库设计如下:

1)、流程信息表:S_flow_info(flow_id,flow_name)

2)、步骤信息表:S_action_info(action_id,action_name)

3)、流程-步骤信息表:S_step_info(step_id,action_id,flow_id,step_repeat_no,step_order_no,step_type)

(其中step_repeat_no为重复次数,step_order_no为排序号,step_type为类型:0为顺序,1为并行)

4)、流程处理明细表:L_tranct_proc(proc_id,loan_id,step_id,step_action,step_emp_id)

(其中loan_id为数据主表主键,step_id关联S_action_info,step_action存储处理结果:0--不通过,1--通过,2--退回,3--否决,4--撤回,step_emp_id为当前处理员工编号)

一套完整自定义工作流的实现第4张

其中流程表、步骤表、流程步骤关系表为核心数据表,它们三者确定工作流的完全自定义。流程处理明细表为重要数据表,查询数据主要通过此表进行连接查询。

一套完整自定义工作流的实现第5张

其他相关表包括:

1)、数据主表L_loan_info(loan_id,loan_name,flow_id,step_id,...)

(flow_id为流程编号,step_id关联S_action_info)

2)、操作员工表E_emp_info(emp_id,emp_name,..)

3)、角色信息表E_role_info(role_id,role_name)

4)、员工-角色关系表E_emp_role(emp_role_id,emp_id,role_id)

(关联角色表与员工表)

5)、步骤角色关系表S_action_role(action_role_id,action_id,role_id)

(关联角色表与步骤表)

6)、下一处理人表L_loan_next_emp(loan_next_emp_id,loan_id,next_emp_id,step_id)

(其中next_emp_id关联操作员工表E_emp_info,step_id关联S_action_info)

其中数据流向如下:

1)业务最开始发生时,数据主表L_loan_info插入数据,其step_id为其所在流程的第一个步骤的编号,可根据下一步骤的重复次数来去将下一处理人的操作员编号插入到下一处理人表L_loan_next_emp中;插入流程处理明细表中数据,step_id为当前步骤编号;更新主表L_loan_info的step_id为下一步骤编号;

2)流程进入下一步骤;

3)下一处理人可查看当前待处理数据(以及本环节待处理数据),选定进行处理,将处理结果(0:不通过,1:通过,2:退回,3:否决)插入到流程处理明细表中,若为通过由更新主表L_loan_info的step_id为下一步骤编号,退回更新为上一步骤编号,否决则更新到第一个步骤编号;

4)在本人已处理数据中可查看已处理过的数据,若下一步骤中操作员还没有进行操作,则可对数据操作进行撤回,撤回时将处理结果(4:撤回)插入到流程处理明细表中,其中的next_emp_id为本人操作员工编号);更新主表L_loan_info的step_id为流程的第一步骤的编号;

5)下一处理人继续3)、4)的循环,直至流程的结束;

6)流程最后一个步骤,将处理结果中step_id值为0插入至流程处理明细中。

  第三部分、实现细节

1、第一步骤中获得数据列表代码如下: 

SELECT * FROM L_loan_info WHERE step_id=@step_id

其中@step_id使用代码得到当前数据的第一步骤编号

2、第一步骤获得已处理数据列表代码:

SELECT * FROM L_loan_info WHERE loan_id IN (SELECT DISTINCT loan_id FROM l_tranct_proc WHERE step_id=@step_id)

3、获得任一步骤数据列表(含未处理和已处理)

/// <summary>
/// 方法:获得审批(或签批)数据列表
/// 开发:王洪剑http://www.cnblogs.com/walkingp     http://www.51obj.cn/
/// 时间:2010-6-29
/// 最后修改时间:2010-6-29
/// 修改详情:
/// </summary>
/// <param name="step_emp_id">签批人(默认为当前操作员):0、本环节 其他、当前处理人</param>
/// <param name="action_id">步骤</param>
/// <param name="step_action">操作值:0:待审批/签批 1:已审批/签批 _:所有</param>
/// <param name="version">版本:3.0</param>
/// <returns></returns>
public List<Hope.Model.L_loan_info> GetModelByProcess(int step_emp_id, int action_id, string step_action, int version)
{
    #region
    string sql = "SELECT COUNT(*) FROM s_flow_info WHERE del_sign='1' and flow_id in(select flow_id from s_step_info where action_id=@action_id)";
    SqlParameter[] para ={ new SqlParameter("@action_id", SqlDbType.Int, 4) };
    para[0].Value = action_id;
    int count = int.Parse(DbHelperSQL.GetSingle(sql, para).ToString());
    string[] arrFlowId = new string[count];//流程信息
    sql = "SELECT flow_id FROM s_flow_info WHERE del_sign='1' and flow_id in(select flow_id from s_step_info where action_id=@action_id)";
    DataTable dt = DbHelperSQL.Query(sql, para).Tables[0];
    for (int i = 0; i < count; i++)
    {
        arrFlowId[i] = dt.Rows[i]["flow_id"].ToString();
    }

    string[] pre_action_id = new string[count];//当前流程中上一流程id
    string[] next_action_id = new string[count];//当前流程中下一流程id
    
    for (int i = 0; i < count; i++)
    {
        sql = "SELECT TOP 1 action_id FROM s_step_info WHERE step_order_no<(SELECT order_no FROM S_action_info WHERE action_id=@action_id) AND flow_id=" + arrFlowId[i] + " ORDER BY s_step_info.step_order_no DESC";
        SqlParameter[] paras ={ new SqlParameter("@action_id", SqlDbType.Int, 4) };
        paras[0].Value = action_id;
        dt.Clear();
        dt = DbHelperSQL.Query(sql, paras).Tables[0];
        if (dt.Rows.Count > 0)
            pre_action_id[i] = dt.Rows[0][0].ToString();

        sql = "SELECT TOP 1 action_id FROM s_step_info,l_loan_info WHERE step_order_no>(SELECT order_no FROM S_action_info WHERE action_id=@action_id) AND s_step_info.flow_id=" + arrFlowId[i] + " ORDER BY s_step_info.step_order_no";
        SqlParameter[] paras_ ={
                new SqlParameter("@action_id",SqlDbType.Int,4)
        };
        paras_[0].Value = action_id;
        dt.Clear();
        dt = DbHelperSQL.Query(sql, paras).Tables[0];
        if (dt.Rows.Count > 0)
            next_action_id[i] = dt.Rows[0][0].ToString();
    }

    DataSet ds = new DataSet();
    for (int k = 0; k < count; k++)
    {
        StringBuilder sbTmp = new StringBuilder();
        if (!string.IsNullOrEmpty(pre_action_id[k]))
            sbTmp.Append("(step_id=" + pre_action_id[k] + " AND step_action='1')");
        if (!string.IsNullOrEmpty(pre_action_id[k]) && !string.IsNullOrEmpty(next_action_id[k]))
            sbTmp.Append(" OR ");
        if (!string.IsNullOrEmpty(next_action_id[k]))
            sbTmp.Append("(step_id=" + next_action_id[k] + " AND step_action='2')");

        string strTemp = "1=1";
        if (!string.IsNullOrEmpty(sbTmp.ToString()))
            strTemp += " AND " + sbTmp.ToString();

        sql = "SELECT * FROM l_loan_info WHERE ";
        sql += "1=1";
        if (step_action == "1")//已审批(签批)
        {
            sql += " AND loan_id IN (SELECT loan_id FROM l_tranct_proc WHERE step_id=@action_id AND step_action='1'";
            if (step_emp_id == 0)
                sql += ")";
            else
                sql += " AND step_emp_id=@step_emp_id)";
        }
        else if (step_action == "0")//待审批(签批)
        {
            sql += " AND step_id=@action_id AND loan_id IN (SELECT loan_id FROM l_tranct_proc WHERE " + strTemp + ")";
            if (step_emp_id == 0)
                sql += "";
            else
                sql += " AND loan_id IN (select loan_id from l_loan_next_emp where next_emp_id=@step_emp_id)";
        }
        else if (step_action == "")//所有
        {
            sql += " AND loan_id IN (SELECT loan_id FROM l_tranct_proc WHERE step_id=@action_id AND step_action='1'";
            if (step_emp_id == 0)
                sql += ")";
            else
                sql += " AND step_emp_id=@step_emp_id)";//已审批(签批)
            sql += " UNION ";
            sql += " AND step_id=@action_id AND loan_id IN (SELECT loan_id FROM l_tranct_proc WHERE " + strTemp + ")";
            if (step_emp_id == 0)
                sql += "";
            else
                sql += " AND loan_id IN (select loan_id from l_loan_next_emp where next_emp_id=@step_emp_id)";//待审批(签批)
        }
        sql += " ORDER BY loan_id DESC";

        SqlParameter[] parameters ={
            new SqlParameter("@step_emp_id",SqlDbType.Int,4),
            new SqlParameter("@action_id",SqlDbType.Int,4)};
        parameters[0].Value = step_emp_id;
        parameters[1].Value = action_id;
        if (ds.Tables.Count == 0)
            ds = DbHelperSQL.Query(sql, parameters);
        else
        {
            ds.Merge(DbHelperSQL.Query(sql, parameters), true, MissingSchemaAction.AddWithKey);
        }
    }

    dt = ds.Tables[0];

    /*去除重复*/
    DataView dv = new DataView(dt);
    string[] strCol ={ "loan_id" };
    dt = dv.ToTable(true, strCol);

    Hope.Model.L_loan_info model;
    List<Hope.Model.L_loan_info> modelList = new List<Hope.Model.L_loan_info>();
    if (dt.Rows.Count > 0)
    {
        #region
        for (int i = 0; i < dt.Rows.Count; i++)
        {
            model = new Hope.Model.L_loan_info();
            model = GetModel(int.Parse(dt.Rows[i]["loan_id"].ToString()));
            modelList.Add(model);
        }
        #endregion
        return modelList;
    }
    else
    {
        return null;
    }
}

以上为核心代码,当然由于工作流的具体需求不同,可调整相应代码。

  第四部分、运行结果

1、系统参数配置

一套完整自定义工作流的实现第6张

一套完整自定义工作流的实现第7张

一套完整自定义工作流的实现第8张

2、待处理列表

一套完整自定义工作流的实现第9张

3、处理页面

一套完整自定义工作流的实现第10张

(注:当前为最后一处理,下一处理人选择不可见)

4、撤回页面

一套完整自定义工作流的实现第11张

结语:

完整自定义工作流由于应用广泛且业务逻辑复杂,要实现真正意义上通用的工作流还需要去做更多的分析和研究。

另本文不提供代码及其他资料下载,请勿留言索取。

抛砖引玉,欢迎拍砖!

参考文档:

[1]:维基百科:工作流技术 http://zh.wikipedia.org/zh-cn/工作流

免责声明:文章转载自《一套完整自定义工作流的实现》仅用于学习参考。如对内容有疑问,请及时联系本站处理。

上篇机器学习算法与Python实践之(七)逻辑回归(Logistic Regression)plsql学习笔记1下篇

宿迁高防,2C2G15M,22元/月;香港BGP,2C5G5M,25元/月 雨云优惠码:MjYwNzM=

相关文章

LNMP平台搭建---MySQL安装篇

  在前两篇中,安装了一个基本的Web服务器,但是只能提供静态网页查看,要做成动态网站,就必须要数据库或其他编程语言支持了,这里先介绍MySQL数据库的安装。   MySQL是一个开源的数据库,在互联网行业应用的很广泛,下面来记录一下从源码安装的步骤,当然,MySQL也有其他安装方式,比如,使用yum下载安装rpm包,或者二进制方式安装,如果机器比较多,可...

MySQL 幻象行

当同一个查询在不同的时间产生不同的行集时,就会出现所谓的幻像问题。例如,如果执行了两次SELECT,但是第二次返回了第一次没有返回的行,那么该行就是一个“幻象”行。 假设在表child的id列上有一个索引,你想读取并锁定表中标识符值大于100的所有行,并打算稍后更新所选行的某些列: SELECT * FROM child WHERE id > 100...

【Excle数据透视表】如何利用图标集将销售数据划分为五个等级

我们如何用图标集来直观看出订单情况呢? 现在有数据如下: 步骤 选中“订单列”→开始→条件格式→图标集→等级→ 此时,在每个数字前面都出现了一个等级符号了 查看预置五等级图标集的规则如下: 开始→条件格式→管理规则→显示其格式规则(当前工作表)→编辑规则 清除规则的步骤 条件格式→清除规则...

Sql Server 2008 增加字段、修改字段、修改类型、修改默认值

1、修改字段名:   alter table 表名 rename column A to B        -- Sql Server 2016 修改SQL(执行后会有提示:注意: 更改对象名的任一部分都可能会破坏脚本和存储过程。)   exec sp_rename "[dbo].[TBL_00001].id","sex是变更后的名称","column";...

phpBB3导入版面的Python脚本

关联的数据表 在phpBB3中导入版面时, 需要处理的有两张表, 一个是 forums, 一个是 acl_groups.  如果是干净的论坛, 可以不保留安装时填入的默认分区和版面, 直接用以下语句初始化: -- 清空 forums 表 TRUNCATE phpbb_forums; -- 清空 acl_groups 表 TRUNCATE ph...

git 学习删除某次提交

cmd里的快捷键 ctrl+a : 跳到开头 ctrl+e : 跳到结尾 which vi 查看vi这么命令在哪个目录下 >> /uer/bin/vi git log 太多了看不完, 空格 往下看 q退出 ctrl+f往后走, ctrl+d 往前走 mkdir a && cd - 创建并进入啊目录 vim下 :...