CN106155769B - A workflow processing method, device and workflow engine - Google Patents

Abstract

The invention discloses a workflow processing method, device and workflow engine. The method includes: when detecting that a business system is started, acquiring a process parameter table in a storage unit, and generating a process object according to the process parameter table, so that the cache The unit caches the process object, and the process parameter table contains the process parameter information preset by the business system; when the workflow startup is detected, the process object corresponding to the workflow is obtained from the process object in the cache unit, and the process object is processed. After that, update the business table and the process record table in the storage unit; when the workflow query is detected, obtain the process object corresponding to the workflow from the process object in the cache unit, according to the process object and the process record in the storage unit table, assemble and display the flow chart. The invention overcomes the problem that the existing workflow definition, development and deployment requires a large workload, improves the workflow development efficiency, and at the same time improves the productization degree of the Web application system.

Description

A workflow processing method, device and workflow engine

technical field

The present invention relates to the technical field of computers, in particular to a workflow processing method, device and workflow engine.

Background technique

Due to the flexibility of the Web application system, customers have extremely rich personalized requirements for business processes. The same Web application system often has different business process implementations for different customers.

In the process of developing a web application system, in order to meet the individual needs of customer business processes, business processes need to be individually configured or developed for different projects. For mainstream workflow engines such as jbpm, osworkflow, and shark, the development and deployment processes are more complicated. This makes the development cost of Web application system high.

SUMMARY OF THE INVENTION

The technical problem to be solved by the present invention is how to provide a workflow processing method, device and workflow engine, so as to solve the problem that the existing workflow development workload is relatively large.

To this end, in a first aspect, the present invention provides a workflow processing method, the method comprising:

When it is detected that the business system is started, the process parameter table in the storage unit is obtained, and a process object is generated according to the process parameter table, so that the cache unit caches the process object, and the process parameter table contains the business system presets. Set process parameter information;

When the startup of the workflow is detected, the process object corresponding to the workflow is obtained from the process object in the cache unit, and after the process object is processed, the business table and the process in the storage unit are updated A record table; the process record table is a table stored in the storage unit for recording process flow;

When a workflow query is detected, the process object corresponding to the workflow is obtained from the process objects in the cache unit, and the flowchart is assembled according to the process object and the process record table in the storage unit. Shows the assembly flow chart.

Optionally, when the startup of the workflow is detected, the process object corresponding to the workflow is obtained from the process object in the cache unit, and after the process object is processed, the storage unit is updated. The business table and process record table in , including:

When detecting that the workflow is started, obtain the process code and business record identifier of the workflow;

Obtain the process object corresponding to the process code from the process object cached by the cache unit;

From the business table in the storage unit, obtain business information corresponding to the business record identifier;

Check whether the process object matches the business information, if not, send an error message; if it matches, add a process record to the process record table in the storage unit, and update the business table.

Optionally, when a workflow query is detected, the process object corresponding to the workflow is obtained from the process object in the cache unit, and the process object is obtained according to the process object and the process record in the storage unit. Tables, assemble and display flowcharts, including:

When a workflow query is detected, the process code and business record identifier of the workflow are obtained;

Obtain the process object corresponding to the process code from the process object cached by the cache unit;

From the business table in the storage unit, obtain business information corresponding to the business record identifier;

The flowchart is assembled and displayed through the process object, the business information and the process record table in the storage unit.

In a second aspect, the present invention also provides a workflow engine, the workflow engine includes:

The generating unit is used to obtain the process parameter table in the storage unit when detecting that the business system is started, and generate a process object according to the process parameter table, so that the cache unit caches the process object, and the process parameter table contains Process parameter information preset by the business system;

a processing unit, configured to obtain a process object corresponding to the workflow from the process objects in the cache unit when the workflow startup is detected, and after processing the process object, update the process object in the storage unit The business table and the process record table; the process record table is a table for recording process flow stored in the storage unit;

a query unit, configured to obtain a process object corresponding to the workflow from the process objects in the cache unit when a workflow query is detected, and according to the process object and the process record table in the storage unit , the assembly flow chart and display the assembly flow chart.

Optionally, the processing unit includes:

The first acquisition subunit is used to acquire the process code and business record identifier of the workflow when it is detected that the workflow is started;

A second acquisition subunit, configured to acquire the process object corresponding to the process code from the process object cached by the cache unit;

A third acquiring subunit, configured to acquire business information corresponding to the business record identifier from the business table in the storage unit;

A processing subunit, used to check whether the process object matches the business information, if not, send an error message; if it matches, add a process record in the process record table in the storage unit, and update the business table.

Optionally, the query unit includes:

a fourth acquiring subunit, configured to acquire the process code and business record identifier of the workflow when the workflow query is detected;

a fifth acquisition subunit, configured to acquire the process object corresponding to the process code from the process object cached by the cache unit;

The sixth acquiring subunit, for acquiring the business information corresponding to the business record identifier from the business table in the storage unit;

The display sub-unit is used for assembling and displaying the flowchart through the process object, the business information and the process record table in the storage unit.

In a third aspect, the present invention also provides a workflow processing device, the device includes: a workflow engine, a cache unit, and a storage unit;

the cache unit, configured to cache the process objects generated by the workflow engine;

The storage unit is used for storing a process parameter table, a business table and a process record table.

Optionally, the process parameter table in the storage unit includes process parameter information preset by the business system, and the process parameter information includes: process template information, process status information and/or role information;

The process template information includes: process code, process name, associated business table name, associated business table primary key column name, business table current handler column name, business table current state column name and/or associated process record table name;

The process state information includes: the process code to which it belongs, the state code, the state name, the corresponding role code and/or the next step state code set;

The role information includes: a role code and a role name, and the role code is associated with a user and authority in the business system and is used for authority control.

Optionally, the corresponding relationship between the process template information, process status information and role information is:

One described flow template corresponds to N described flow states, and N is a positive integer;

One piece of role information corresponds to N pieces of the process state.

Optionally, the process record table includes: process record identifier, business record identifier, operator, operation time, current state code, next state code, current handler and/or next handler.

Compared with the prior art, the workflow processing method, device and workflow engine of the present invention quickly realize the purpose of process definition by defining a small number of parameters. personnel, so as to define the work process simply and clearly, and provide functions such as process flow processing and process record retrieval. More importantly, most process requirements of customers can be met through flexible and highly configurable parameter information, and process functions can be expanded by extending parameter information. The core code is simple, clear, highly scalable, and highly available. It overcomes the problem of large workload in the definition, development and deployment of the existing workflow, improves the efficiency of workflow development, and at the same time improves the degree of productization of the Web application system.

Description of drawings

FIG. 1 is a flowchart of a workflow processing method provided by an embodiment of the present invention;

2 is a structural diagram of a workflow engine provided by an embodiment of the present invention;

FIG. 3 is a structural diagram of a processing unit according to an embodiment of the present invention;

4 is a structural diagram of a query unit provided by an embodiment of the present invention;

FIG. 5 is a structural diagram of a workflow processing apparatus according to an embodiment of the present invention;

FIG. 6 is a work flow diagram of a workflow processing apparatus provided by an embodiment of the present invention;

FIG. 7 is an effect diagram of a web page of a list of workflow process records generated by data obtained through process record retrieval according to an embodiment of the present invention.

Detailed ways

In order to make the purposes, technical solutions and advantages of the embodiments of the present invention clearer, the technical solutions in the embodiments of the present invention will be clearly described below with reference to the drawings in the embodiments of the present invention. Obviously, the described embodiments are the Some, but not all, embodiments are disclosed. Based on the embodiments of the present invention, all other embodiments obtained by those of ordinary skill in the art without creative efforts shall fall within the protection scope of the present invention.

As shown in FIG. 1 , this embodiment discloses a workflow processing method, and the method may include the following steps:

101. When detecting that the business system is started, obtain the process parameter table in the storage unit, and generate a process object according to the process parameter table, so that the cache unit caches the process object, and the process parameter table contains the business process. Process parameter information preset by the system;

The process parameter information includes: process template information, process status information, and role information;

Process template information is used to record process-related parameter information, including at least: process code, process name, associated business table name, associated business table primary key column name, business table current processor column name, business table current state column name and The name of the associated process record table;

The process state information is used to record the parameter information related to the process state, at least including: the process code to which it belongs, the state code, the state name, the corresponding role code, and the next state code set;

The role information is used to record the parameter information related to the role of the business system, at least including: role code and role name, the role code is associated with the user and authority in the business system, and is used for authority control.

The corresponding relationship between process template information, process status information and role information is:

A process template corresponds to N process states, where N is a positive integer;

One role information corresponds to N process states.

102. When detecting that the workflow is started, obtain the process object corresponding to the workflow from the process object in the cache unit, and after processing the process object, update the business table in the storage unit and process records;

Among them, the business table includes: business information, the current state of the process and the processor;

The process record table is used to record the information of the process flow, including at least: process record identifier, business record identifier, operator, operation time, current status code, next step status code, current handler and next handler. Among them, the next state code refers to which states the current state can be changed to, and the process flow rules can be constrained by the next state code, and a flowchart can be constructed.

103. When a workflow query is detected, obtain a process object corresponding to the workflow from the process object in the cache unit, and assemble and assemble the process object according to the process object and the process record table in the storage unit. Display the flowchart.

Wherein, step 102 may further include the following sub-steps not shown in FIG. 1 :

1021. When detecting that the workflow is started, obtain the process code and business record identifier of the workflow;

1022. Obtain a process object corresponding to the process code from the process object cached by the cache unit;

1023. Obtain business information corresponding to the business record identifier from the business table in the storage unit;

1024. Check whether the process object matches the business information, if not, send an error message; if it matches, add a process record in the process record table in the storage unit, and update the business table .

Wherein, step 103 may further include the following sub-steps not shown in FIG. 1 :

1031. When a workflow query is detected, obtain the process code and business record identifier of the workflow;

1032. Obtain a process object corresponding to the process code from the process object cached by the cache unit;

1033. Obtain business information corresponding to the business record identifier from the business table in the storage unit;

1034. Assemble and display a flowchart according to the process object, the business information, and the process record table in the storage unit.

In a specific application, the process template information can also be extended with other configuration information, such as the status code of participating in information statistics (another functional module of the business system, that is, the information statistics module).

In a specific application, the process status information can also be extended to other configuration information, such as the menu associated with the status, that is, the navigation menu for the business system to view business information (clicking on the menu only displays business records in the state associated with the menu).

The above-mentioned embodiments use configuration parameters to store self-defined business process information, provide simple and easy-to-use process flow processing and process record retrieval functions, and thus overcome the problem that the existing workflow definition, development, and deployment require large workloads. Improve workflow development efficiency.

The above embodiment can quickly achieve the purpose of process definition by defining a small number of parameters, and through state-based process control, that is, process states are associated with roles, roles are associated with permissions and personnel, so as to define the workflow simply and clearly, and provide process flow processing. and process record retrieval and other functions. More importantly, most process requirements of customers can be met through flexible and highly configurable parameter information, and process functions can be expanded by extending parameter information. The core code is simple, clear, highly scalable, and highly available. This embodiment expands the core module, adds a general module for the process submission page, and a general module for the process record viewing page, so that in a specific project, a set of codes can be used, and workflow flow can be realized only by configuring process definition parameters. Process recording and progress viewing functions, so it overcomes the problem of large workload of existing workflow definition, development, and deployment, improves the efficiency of workflow development, and improves the degree of productization of Web application systems.

As shown in FIG. 2 , this embodiment discloses a workflow engine, and the workflow engine may include the following units: a generating unit 21, a processing unit 22, and a query unit 23;

The generating unit 21 is configured to acquire the process parameter table in the storage unit when it is detected that the business system is started, and generate a process object according to the process parameter table, so that the cache unit caches the process object, and the process parameter table is in the process parameter table. Contains process parameter information preset by the business system;

The processing unit 22 is configured to acquire the process object corresponding to the workflow from the process objects in the cache unit when the startup of the workflow is detected, and after processing the process object, update the storage unit The business table and process record table in the;

The query unit 23 is configured to, when a workflow query is detected, obtain a process object corresponding to the workflow from the process objects in the cache unit, and obtain the process object corresponding to the workflow according to the process object and the process record in the storage unit table, assemble and display the flow chart.

As shown in FIG. 3, the processing unit 22 may also include the following subunits:

The first acquisition subunit 221 is used to acquire the process code and business record identifier of the workflow when it is detected that the workflow is started;

The second acquisition subunit 222 is configured to acquire the process object corresponding to the process code from the process object cached by the cache unit;

The third obtaining subunit 223 is configured to obtain business information corresponding to the business record identifier from the business table in the storage unit;

The processing subunit 224 is used to check whether the process object matches the business information, if not, send an error message; if it matches, add a process record in the process record table in the storage unit, and Update the business table.

As shown in FIG. 4, the query unit 23 may further include the following subunits:

The fourth acquisition subunit 231 is used to acquire the process code and business record identifier of the workflow when the workflow query is detected;

The fifth acquisition subunit 232 is used to acquire the process object corresponding to the process code from the process object cached by the cache unit;

The sixth obtaining subunit 233 is used to obtain the business information corresponding to the business record identifier from the business table in the storage unit;

The display subunit 234 is configured to assemble and display the flowchart according to the process object, the business information and the process record table in the storage unit.

The workflow engine of this embodiment has the process described in the foregoing embodiment in FIG. 1 , which is not described in detail in this embodiment.

As shown in FIG. 5 , this embodiment discloses a workflow processing apparatus, and the apparatus includes the workflow engine 51 , the cache unit 52 and the storage unit 53 described in the embodiment of FIG. 2 ;

The workflow engine 51 includes a generating unit 21, a processing unit 22 and a query unit 23;

The cache unit 52 is configured to cache the process objects generated by the workflow engine;

The storage unit 53 is used to store a process parameter table, a business table and a process record table.

As shown in FIG. 6 , this embodiment discloses the workflow of the embodiment of the workflow processing apparatus in FIG. 5 , including the following steps:

601. The workflow engine 51 acquires the process parameter table in the storage unit 53 when detecting that the business system is started;

602. The workflow engine 51 generates a process object according to the process parameter table, so that the cache unit 52 caches the process object; the process parameter table contains the process parameter information preset by the business system

603. When the workflow engine 51 detects that the workflow is started, it acquires the process object corresponding to the workflow from the process object in the cache unit 52;

604. After the workflow engine 51 processes the flow object, it updates the business table and the flow record table in the storage unit 53;

605. When the workflow engine 51 detects the workflow query, it acquires the process object corresponding to the workflow from the process object in the cache unit 52;

606 . The workflow engine 51 assembles and displays the flowchart according to the process object and the process record table in the storage unit 53 .

In step 601, the workflow engine 51 reads the process information in the process parameter table, and sequentially reads the process template record and the process state record. Specifically: first acquire all process template information, and then acquire corresponding process status information according to the process code in the process template information.

In step 602, the workflow engine 51 generates a process object for each process template record, and uses the process code, process name and other related information as the attributes of the object, and also uses the process state information as the attributes of the object.

Steps 601 and 602 are called initialization procedures.

Steps 603 and 604 are referred to as process flow.

In step 603, the workflow engine 51 acquires the process object according to the process code.

Step 604 specifically includes the following sub-steps:

6041. Acquire information related to the process in the business table according to the business record identifier, including the current handler, the current state, and the like.

6042. Perform the validity check of the process operation according to the process-related information in the process object and the business table, including whether the current handler in the calling method parameters is correct, whether the current state is correct, and whether the next state is the next state code of the current state object In the set, other special verifications (which special verifications are enabled through operation parameters). If the verification fails, an error message will be returned, and the verification will continue after the verification is passed.

6043. Add a process processing record.

6044. Update the business table data, including the current handler, the current state, and other business information.

Steps 605 and 606 are referred to as the process record retrieval process.

In step 605, the workflow engine 51 acquires the process object according to the process code.

Step 606 specifically includes the following sub-steps:

6061. Acquire information related to the process in the business table according to the business record identifier, including the current handler, the current state, and the like.

6062. Assemble the flow chart information according to the flow object (the flow chart can be constructed by the set of flow codes in the flow state parameter and the next state code), and return the flow chart information and operation record information.

FIG. 7 shows a web page effect diagram of the workflow process record generated by the data acquired through the process record retrieval.

As can be seen from the above embodiments, the present invention has achieved the following technical effects:

1. High configurability, by modifying a small number of process configuration parameters, it can meet most of the business process needs of customers;

2. The core module is simple and extensible. For the special verification and special processing of the process, it is only necessary to develop the corresponding functional module, make corresponding references and switches in the process flow, and perform corresponding control through the operation parameters;

3. Control the version branch. The individualized process requirements of different projects are only controlled by a small amount of process configuration information, and the main code is guaranteed to have only one set.

In this way, between different projects of the same application system, a large number of process configuration files and business processing codes are converted into a small number of process parameter differences, which frees up development resources to the greatest extent, and can even be configured by implementers. differences, thereby reducing project costs.

It should be noted that the "first" to "sixth" in this document are only used to distinguish different entities, and do not represent the relationship or sequence between the entities.

Obviously, those skilled in the art should understand that the above-mentioned modules or steps of the present invention can be implemented by a general-purpose computing device, which can be centralized on a single computing device, or distributed in a network composed of multiple computing devices Alternatively, they can be implemented with program codes executable by a computing device, so that they can be stored in a storage device and executed by the computing device, or they can be made into individual integrated circuit modules, or they can be integrated into The multiple modules or steps are fabricated into a single integrated circuit module. As such, the present invention is not limited to any particular combination of hardware and software.

Although the embodiments of the present invention have been described with reference to the accompanying drawings, various modifications and variations can be made by those skilled in the art without departing from the spirit and scope of the present invention, and such modifications and variations all fall within the scope of the appended claims within the limits of the requirements.

Claims (10)

1. A workflow processing method, wherein the method comprises: When it is detected that the business system is started, the process parameter table in the storage unit is obtained, and a process object is generated according to the process parameter table, so that the cache unit caches the process object, and the process parameter table contains the business system presets. Set process parameter information; When the startup of the workflow is detected, the process object corresponding to the workflow is obtained from the process object in the cache unit, and after the process object is processed, the business table and the process in the storage unit are updated A record table; the process record table is a table stored in the storage unit for recording process flow; When a workflow query is detected, the process object corresponding to the workflow is obtained from the process objects in the cache unit, and the flowchart is assembled according to the process object and the process record table in the storage unit. Shows the assembly flow chart. 2 . The method according to claim 1 , wherein when the startup of the workflow is detected, the process object corresponding to the workflow is obtained from the process objects in the cache unit, and the process object is processed in the process. 3 . After the process object, update the business table and process record table in the storage unit, including: When detecting that the workflow is started, obtain the process code and business record identifier of the workflow; Obtain the process object corresponding to the process code from the process object cached by the cache unit; From the business table in the storage unit, obtain business information corresponding to the business record identifier; Check whether the process object matches the business information, if not, send an error message; if it matches, add a process record to the process record table in the storage unit, and update the business table. 3. The method according to claim 1, wherein when a workflow query is detected, the process object corresponding to the workflow is obtained from the process objects in the cache unit, according to the The process object and the process record table in the storage unit, assemble and display the process flow, including: When a workflow query is detected, the process code and business record identifier of the workflow are obtained; Obtain the process object corresponding to the process code from the process object cached by the cache unit; From the business table in the storage unit, obtain business information corresponding to the business record identifier; According to the process object, the business information and the process record table in the storage unit, a flowchart is assembled and displayed. 4. A workflow engine, wherein the workflow engine comprises: The generating unit is used to obtain the process parameter table in the storage unit when detecting that the business system is started, and generate a process object according to the process parameter table, so that the cache unit caches the process object, and the process parameter table contains Process parameter information preset by the business system; a processing unit, configured to obtain a process object corresponding to the workflow from the process objects in the cache unit when the workflow startup is detected, and after processing the process object, update the process object in the storage unit The business table and the process record table; the process record table is a table for recording process flow stored in the storage unit; a query unit, configured to obtain a process object corresponding to the workflow from the process objects in the cache unit when a workflow query is detected, and according to the process object and the process record table in the storage unit , the assembly flow chart and display the assembly flow chart. 5. The workflow engine according to claim 4, wherein the processing unit comprises: The first acquisition subunit is used to acquire the process code and business record identifier of the workflow when it is detected that the workflow is started; A second acquisition subunit, configured to acquire the process object corresponding to the process code from the process object cached by the cache unit; A third acquiring subunit, configured to acquire business information corresponding to the business record identifier from the business table in the storage unit; A processing subunit, used to check whether the process object matches the business information, if not, send an error message; if it matches, add a process record in the process record table in the storage unit, and update the business table. 6. The workflow engine according to claim 5, wherein the query unit comprises: a fourth acquiring subunit, configured to acquire the process code and business record identifier of the workflow when the workflow query is detected; a fifth acquisition subunit, configured to acquire the process object corresponding to the process code from the process object cached by the cache unit; The sixth acquiring subunit, for acquiring the business information corresponding to the business record identifier from the business table in the storage unit; The display subunit is used for assembling and displaying the flowchart according to the process object, the business information and the process record table in the storage unit. 7. A workflow processing apparatus, wherein the apparatus comprises: a workflow engine according to any one of claims 4 to 6, a cache unit and a storage unit; the cache unit, configured to cache the process objects generated by the workflow engine; The storage unit is used for storing a process parameter table, a business table and a process record table. 8 . The device according to claim 7 , wherein the process parameter table in the storage unit includes process parameter information preset by the business system, and the process parameter information includes: process template information, process status information, and roles. 9 . information; The process template information includes: process code, process name, associated business table name, associated business table primary key column name, business table current handler column name, business table current state column name and/or associated process record table name; The process state information includes: the process code to which it belongs, the state code, the state name, the corresponding role code and/or the next step state code set; The role information includes: a role code and a role name, and the role code is associated with a user and authority in the business system and is used for authority control. 9. The device according to claim 8, wherein the corresponding relationship between the process template information, the process state information and the role information is: One described flow template corresponds to N described flow states, and N is a positive integer; One piece of role information corresponds to N pieces of the process state. 10. The device according to claim 7, wherein the process record table comprises: process record identifier, business record identifier, operator, operation time, current state code, next step state code, current handler and/or or the next processing person.

Images