文档章节

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

周进
 周进
发布于 2014/09/12 18:03
字数 2421
阅读 50
收藏 1

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

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

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

 

正文:

  第一部分、业务逻辑分析

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

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

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

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

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

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

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

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为当前处理员工编号)

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

其他相关表包括:

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、系统参数配置

2、待处理列表

3、处理页面

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

4、撤回页面

结语:

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

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


本文转载自:

周进
粉丝 16
博文 35
码字总数 5679
作品 0
成都
CTO(技术副总裁)
私信 提问
web工作流管理系统开发之十 数据库连接及事务设定

为了方便设置数据库连接和事务的一致,将所有数据库连接信息统一设置在fcconfig.xml文件中; fcconfig.xml的内容: /ebsys 用户.ID,用户.名称,部门.ID,部门.名称,系统.单位名称 其中节点中可...

长平狐
2012/10/11
70
0
通用审批节点的实现

很多人认为,工作流就是做审批流,上工作流系统,就是为了处理审批流。这显然是个误区,大概是给大量的oa办公系统给闹的,那套oa系统不包含一个审批流? 一套工作流系统,包含流程引擎,流程...

长平狐
2012/10/11
223
0
工作流软件产品集成struts2框架

工作流软件产品只负责业务流程的流转,流程节点上业务模块的办理,以及监控业务流程的执行。通常一套工作流管理系统,会包含流程引擎,流程设计器,流程管理中心,表单设计器,自定义表单系统...

长平狐
2012/10/11
136
0
初生牛犊式工作流系统

在论坛中常常会看到一些初生牛犊发布的,我设计的工作流系统 等等。对这类的帖子我都会饶有兴趣点击进去,准备仔细观摩和研究,但往往是一略而过,失望而归,或许是我的期望太高了,以为能得...

长平狐
2012/10/11
152
0
推荐一款快速开发平台,web中最好的快速开发平台

力软快速开发平台是力软自主开发的基于SOA面向服务的应用系统开发平台,可以方便快捷的搭建企业、医院、工厂、学校等行业的企业级运营管理平台。平台采用.net.技术架构,webapi服务搭建。 力...

力软信息
02/22
0
0

没有更多内容

加载失败,请刷新页面

加载更多

浅谈Visitor访问者模式

一、前言 什么叫访问,如果大家学过数据结构,对于这点就很清晰了,遍历就是访问的一般形式,单独读取一个元素进行相应的处理也叫作访问,读取到想要查看的内容+对其进行处理就叫作访问,那么...

青衣霓裳
22分钟前
5
0
JS内嵌多个页面,页面之间如何更快捷的查找相关联的页面

假设parent为P页面, P页面有两个子页面,分别为B页面和C页面; B页面和C页面分别内嵌一个iframe,分别为:D页面和E页面 现在通过B页面的内嵌页面D的方法refreshEpage(eUrl)来加载内嵌页面E的内容...

文文1
23分钟前
6
0
Hibernate 5 升级后 getProperties 错误

升级到 Hibernate 5 后,提示有错误: org.hibernate.engine.spi.SessionFactoryImplementor.getProperties()Ljava/util/Map; 完整的错误栈为: java.lang.NoSuchMethodError: org.hibernate......

honeymoose
24分钟前
4
0
mysql-connector-java升级到8.0后保存时间到数据库出现了时差

在一个新项目中用到了新版的mysql jdbc 驱动 <dependency>     <groupId>mysql</groupId>     <artifactId>mysql-connector-java</artifactId>     <version>8.0.18</version> ......

ValSong
27分钟前
6
0
Spring中BeanFactory与FactoryBean的区别

在Spring中有BeanFactory和FactoryBean这2个接口,从名字来看很相似,比较容易搞混。 一、BeanFactory BeanFactory是一个接口,它是Spring中工厂的顶层规范,是SpringIoc容器的核心接口,它定...

大王叫下
30分钟前
5
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部