一、前言

　　接上一篇?.NET Core微服務(wù) 權(quán)限系統(tǒng)+工作流（一）權(quán)限系統(tǒng)?，再來一發(fā)

　　工作流，我在接觸這塊開發(fā)的時候一直好奇它的實(shí)現(xiàn)方式，翻看各種工作流引擎代碼，探究其實(shí)現(xiàn)方式，個人總結(jié)出來一個核心要點(diǎn)：

　　實(shí)際上工作流引擎處理流轉(zhuǎn)的核心要義是如何解析流轉(zhuǎn)XML或者JSON或者其它持久化方式，工作流通過解析XML或者JSON判斷當(dāng)前節(jié)點(diǎn)的狀態(tài)和下個節(jié)點(diǎn)的信息并做出一些處理。感覺等于沒說？直白一點(diǎn)，就是通過解析JSON文件得到下一步是誰處理。

　　工作流的流轉(zhuǎn)線路實(shí)際上是固定死的，排列組合即可知道所有可能的線路，并沒有想象中的那么難以理解。理解好這點(diǎn)，那么接下來開發(fā)就很簡單了，壘代碼而已（手動微笑.ing）。本系統(tǒng)著重分析工作流具體的實(shí)現(xiàn)方式，不闡述具體的實(shí)現(xiàn)步驟，詳細(xì)代碼請看GitHub地址。

二、系統(tǒng)介紹

深入研究過工作流的朋友可能會知道，流程表單它分為兩種：

1、定制表單。更加貼近業(yè)務(wù)，但會累死開發(fā)人員。以前的公司都是這種方式開發(fā)，這個和具體的業(yè)務(wù)邏輯有關(guān)系，比較復(fù)雜的建議使用定制表單方式，即開發(fā)人員把業(yè)務(wù)功能開發(fā)完了，與流程關(guān)聯(lián)即可。

2、代碼生成的表單。不需要編寫代碼，系統(tǒng)可自動生成，方便，但是功能擴(kuò)展性較差。

當(dāng)然各有好處。本系統(tǒng)兩種方式都已經(jīng)實(shí)現(xiàn)，著重闡述定制流程。本系統(tǒng)人為規(guī)定：一個流程只能綁定一個表單，一個表單只能綁定一個流程。即一對一，這是一切的前提。至于為什么這么做？

通常情況下一個流程的走向是跟表單邏輯是相掛鉤的，基本上不存在多個的可能性，而且容易造成組織錯亂，有的話，那就在再畫一個流程一個表單。@_^_@

三、工作流實(shí)現(xiàn)

還是以面向數(shù)據(jù)庫的方法來開發(fā)，先看表：

wf_workflow ： 工作流表，存放工作流基本信息

wf_workflow_category ： 流程分類表

wf_workflow_form ： 流程表單表，分為兩種類型，系統(tǒng)生成表單和系統(tǒng)定制表單，系統(tǒng)定制表單只存放URL地址

wf_workflow_instance?： 流程實(shí)例表，核心

wf_workflow_instance_form ： 流程實(shí)例表單關(guān)聯(lián)表

wf_workflow_line ： 流程連線表。目前之存放兩種相反的形式（同意、不同意），后期會添加自定義SQL判斷業(yè)務(wù)邏輯流轉(zhuǎn)節(jié)點(diǎn)

wf_workflow_operation_history ： 流程操作歷史表。用于獲取審批意見等

wf_workflow_transition_history ： 流程流轉(zhuǎn)記錄。用于獲取 退回某一步獲取節(jié)點(diǎn)等。

目前工作流實(shí)現(xiàn)了這幾個功能：保存、提交、同意、不同意、退回、終止、流程圖、審批意見，后期會繼續(xù)升級迭代，如添加會簽、掛起、通知等等，目前這幾個功能應(yīng)該能應(yīng)付一般業(yè)務(wù)需求了，像會簽這種功能99%用不到，但是確是比較復(fù)雜的功能，涉及并行、串行計算方式，80%時間都花在這些用不到的功能上來，所謂的二八法則吧。

全部功能較多，不一一列舉了：目前只有流程分類功能沒實(shí)現(xiàn)，后續(xù)再寫吧，但是不影響功能使用，只是用于篩選而已

流程設(shè)計界面：采用GooFlow插件，并對其代碼做出一些修改，界面確實(shí)比較難看，設(shè)計比較簡陋，畢竟本人不會平面設(shè)計，如果覺得不丑，就當(dāng)我沒說。

核心代碼：實(shí)際上就是解析JSON文件，并寫一些方便讀取節(jié)點(diǎn)、連線的方法

1 /// <summary>
2 /// workflow context
3 /// </summary>
4 public class MsWorkFlowContext : WorkFlowContext
5 {
6 /// <summary>
7 /// 構(gòu)造器傳參
8 /// </summary>
9 /// <param name="dbworkflow"></param>
10 public MsWorkFlowContext(WorkFlow dbworkflow)
11 {
12 if (dbworkflow.FlowId == default(Guid))
13 {
14 throw new ArgumentNullException("FlowId", " input workflow flowid is null");
15 }
16 if (dbworkflow.FlowJSON.IsNullOrEmpty())
17 {
18 throw new ArgumentException("FlowJSON", "input workflow json is null");
19 }
20 if (dbworkflow.ActivityNodeId == null)
21 {
22 throw new ArgumentException("ActivityNodeId", "input workflow ActivityNodeId is null");
23 }
24
25 this.WorkFlow = dbworkflow;
26
27 dynamic jsonobj = JsonConvert.DeserializeObject(this.WorkFlow.FlowJSON);
28 //獲取節(jié)點(diǎn)
29 this.WorkFlow.Nodes = this.GetNodes(jsonobj.nodes);
30 //獲取連線
31 this.WorkFlow.Lines = this.GetFromLines(jsonobj.lines);
32
33 this.WorkFlow.ActivityNodeId = dbworkflow.ActivityNodeId == default(Guid) ? this.WorkFlow.StartNodeId : dbworkflow.ActivityNodeId;
34
35 this.WorkFlow.ActivityNodeType = this.GetNodeType(this.WorkFlow.ActivityNodeId);
36
37 //會簽開始節(jié)點(diǎn)和流程結(jié)束節(jié)點(diǎn)沒有下一步
38 if (this.WorkFlow.ActivityNodeType == WorkFlowInstanceNodeType.ChatNode || this.WorkFlow.ActivityNodeType == WorkFlowInstanceNodeType.EndRound)
39 {
40 this.WorkFlow.NextNodeId = default(Guid);//未找到節(jié)點(diǎn)
41 this.WorkFlow.NextNodeType = WorkFlowInstanceNodeType.NotRun;
42 }
43 else
44 {
45 var nodeids = this.GetNextNodeId(this.WorkFlow.ActivityNodeId);
46 if (nodeids.Count == 1)
47 {
48 this.WorkFlow.NextNodeId = nodeids[0];
49 this.WorkFlow.NextNodeType = this.GetNodeType(this.WorkFlow.NextNodeId);
50 }
51 else
52 {
53 //多個下個節(jié)點(diǎn)情況
54 this.WorkFlow.NextNodeId = default(Guid);
55 this.WorkFlow.NextNodeType = WorkFlowInstanceNodeType.NotRun;
56 }
57 }
58 }
59
60 /// <summary>
61 /// 下個節(jié)點(diǎn)是否是多個
62 /// </summary>
63 public bool IsMultipleNextNode { get; set; }
64
65 /// <summary>
66 /// 獲取節(jié)點(diǎn)集合
67 /// </summary>
68 /// <param name="nodesobj"></param>
69 /// <returns></returns>
70 private Dictionary<Guid, FlowNode> GetNodes(dynamic nodesobj)
71 {
72 Dictionary<Guid, FlowNode> nodes = new Dictionary<Guid, FlowNode>();
73
74 foreach (JObject item in nodesobj)
75 {
76 FlowNode node = item.ToObject<FlowNode>();
77 if (!nodes.ContainsKey(node.Id))
78 {
79 nodes.Add(node.Id, node);
80 }
81 if (node.Type == FlowNode.START)
82 {
83 this.WorkFlow.StartNodeId = node.Id;
84 }
85 }
86 return nodes;
87 }
88
89 /// <summary>
90 /// 獲取工作流節(jié)點(diǎn)及以節(jié)點(diǎn)為出發(fā)點(diǎn)的流程
91 /// </summary>
92 /// <param name="linesobj"></param>
93 /// <returns></returns>
94 private Dictionary<Guid, List<FlowLine>> GetFromLines(dynamic linesobj)
95 {
96 Dictionary<Guid, List<FlowLine>> lines = new Dictionary<Guid, List<FlowLine>>();
97
98 foreach (JObject item in linesobj)
99 {
100 FlowLine line = item.ToObject<FlowLine>();
101
102 if (!lines.ContainsKey(line.From))
103 {
104 lines.Add(line.From, new List<FlowLine> { line });
105 }
106 else
107 {
108 lines[line.From].Add(line);
109 }
110 }
111
112 return lines;
113 }
114
115 /// <summary>
116 /// 獲取全部流程線
117 /// </summary>
118 /// <returns></returns>
119 public List<FlowLine> GetAllLines()
120 {
121 dynamic jsonobj = JsonConvert.DeserializeObject(this.WorkFlow.FlowJSON);
122 List<FlowLine> lines = new List<FlowLine>();
123 foreach (JObject item in jsonobj.lines)
124 {
125 FlowLine line = item.ToObject<FlowLine>();
126 lines.Add(line);
127 }
128 return lines;
129 }
130
131 /// <summary>
132 /// 根據(jù)節(jié)點(diǎn)ID獲取From（流入的線條）
133 /// </summary>
134 /// <param name="nodeid"></param>
135 /// <returns></returns>
136 public List<FlowLine> GetLinesForFrom(Guid nodeid)
137 {
138 var lines = GetAllLines().Where(m => m.To == nodeid).ToList();
139 return lines;
140 }
141
142 public List<FlowLine> GetLinesForTo(Guid nodeid)
143 {
144 var lines = GetAllLines().Where(m => m.From == nodeid).ToList();
145 return lines;
146 }
147
148 /// <summary>
149 /// 獲取全部節(jié)點(diǎn)
150 /// </summary>
151 /// <returns></returns>
152 public List<FlowNode> GetAllNodes()
153 {
154 dynamic jsonobj = JsonConvert.DeserializeObject(this.WorkFlow.FlowJSON);
155 List<FlowNode> nodes = new List<FlowNode>();
156 foreach (JObject item in jsonobj.nodes)
157 {
158 FlowNode node = item.ToObject<FlowNode>();
159 nodes.Add(node);
160 }
161 return nodes;
162 }
163
164 /// <summary>
165 /// 根據(jù)節(jié)點(diǎn)ID獲取節(jié)點(diǎn)類型
166 /// </summary>
167 /// <param name="nodeId"></param>
168 /// <returns></returns>
169 public WorkFlowInstanceNodeType GetNodeType(Guid nodeId)
170 {
171 var _thisnode = this.WorkFlow.Nodes[nodeId];
172 return _thisnode.NodeType();
173 }
174
175 /// <summary>
176 /// 根據(jù)節(jié)點(diǎn)id獲取下個節(jié)點(diǎn)id
177 /// </summary>
178 /// <param name="nodeId"></param>
179 /// <returns></returns>
180 public List<Guid> GetNextNodeId(Guid nodeId)
181 {
182 List<FlowLine> lines = this.WorkFlow.Lines[nodeId];
183 if (lines.Count > 1)
184 {
185 this.IsMultipleNextNode = true;
186 }
187 return lines.Select(m => m.To).ToList();
188 }
189
190 /// <summary>
191 /// 節(jié)點(diǎn)駁回
192 /// </summary>
193 /// <param name="rejectType">駁回節(jié)點(diǎn)類型</param>
194 /// <param name="rejectNodeid">要駁回到的節(jié)點(diǎn)</param>
195 /// <returns></returns>
196 public Guid RejectNode(NodeRejectType rejectType, Guid? rejectNodeid)
197 {
198 switch (rejectType)
199 {
200 case NodeRejectType.PreviousStep:
201 return this.WorkFlow.PreviousId;
202 case NodeRejectType.FirstStep:
203 var startNextNodeId = this.GetNextNodeId(this.WorkFlow.StartNodeId).First();
204 return startNextNodeId;
205 case NodeRejectType.ForOneStep:
206 if (rejectNodeid == null || rejectNodeid == default(Guid))
207 {
208 throw new Exception("駁回節(jié)點(diǎn)沒有值！");
209 }
210 var fornode = this.WorkFlow.Nodes[rejectNodeid.Value];
211 return fornode.Id;
212 case NodeRejectType.UnHandled:
213 default:
214 return this.WorkFlow.PreviousId;
215 }
216 }
217
218 }

流程流轉(zhuǎn)代碼（主要部分）：這段代碼是處理流轉(zhuǎn)核心功能，只完成了部分核心功能

1 /// <summary>
2 /// 流程過程流轉(zhuǎn)處理
3 /// </summary>
4 /// <param name="model"></param>
5 /// <returns></returns>
6 public async Task<WorkFlowResult> ProcessTransitionFlowAsync(WorkFlowProcessTransition model)
7 {
8 WorkFlowResult result = new WorkFlowResult();
9 switch (model.MenuType)
10 {
11 case WorkFlowMenu.Submit:
12 break;
13 case WorkFlowMenu.ReSubmit:
14 result = await ProcessTransitionReSubmitAsync(model);
15 break;
16 case WorkFlowMenu.Agree:
17 result = await ProcessTransitionAgreeAsync(model);
18 break;
19 case WorkFlowMenu.Deprecate:
20 result = await ProcessTransitionDeprecateAsync(model);
21 break;
22 case WorkFlowMenu.Back:
23 result = await ProcessTransitionBackAsync(model);
24 break;
25 case WorkFlowMenu.Stop://剛開始提交，下一個節(jié)點(diǎn)未審批情況，流程發(fā)起人可以終止
26 result = await ProcessTransitionStopAsync(model);
27 break;
28 case WorkFlowMenu.Cancel:
29 break;
30 case WorkFlowMenu.Throgh:
31 break;
32 case WorkFlowMenu.Assign:
33 break;
34 case WorkFlowMenu.View:
35 break;
36 case WorkFlowMenu.FlowImage:
37 break;
38 case WorkFlowMenu.Approval:
39 break;
40 case WorkFlowMenu.CC:
41 break;
42 case WorkFlowMenu.Suspend:
43 break;
44 case WorkFlowMenu.Resume:
45 break;
46 case WorkFlowMenu.Save:
47 case WorkFlowMenu.Return:
48 default:
49 result = WorkFlowResult.Error("未找到匹配按鈕！");
50 break;
51 }
52 return result;
53 }

如果以定制表單關(guān)聯(lián)流程的方式開發(fā)，會遇到一個重要問題：流程狀態(tài)如何與表單同步？因為工作流與業(yè)務(wù)流是區(qū)分開的，怎么辦？

　　我的做法是（以請假為例）：讓實(shí)體先繼承流程狀態(tài)實(shí)體，通過CAP的方式推送和訂閱，我以前的公司工作流是通過頁面回調(diào)的方式實(shí)現(xiàn)，我感覺這個很不靠譜，實(shí)際上也是經(jīng)常出問題

流程狀態(tài)的判斷：WfWorkflowInstance實(shí)體下的兩個字段， 這塊可能不太好理解，尤其是沒有開發(fā)過的朋友，簡單解釋下：IsFinish 是表示流程運(yùn)行的狀態(tài)，Status表示用戶操作流程的狀態(tài)，我們判斷這個流程是否結(jié)束不能單純的判斷根據(jù)IsFinish進(jìn)行判斷，

舉個例子（請假）：

　　我提交了一個請假申請==>下個節(jié)點(diǎn)審批不同意。你說這個流程有沒有結(jié)束？當(dāng)然結(jié)束了，只不過它沒有審批通過而已。簡而言之，IsFinish表示流程流轉(zhuǎn)是否結(jié)束，即是否最終到了最后一個結(jié)束節(jié)點(diǎn)。

1 #region 結(jié)合起來判斷流程是否結(jié)束
2 /* 流轉(zhuǎn)狀態(tài)判斷 實(shí)際情況組合
3 * IsFinish=1 & Status=WorkFlowStatus.IsFinish 表示通過
4 * IsFinish==null & Status=WorkFlowStatus.UnSubmit 表示未提交
5 * IsFinish=0 & Status=WorkFlowStatus.Running 表示運(yùn)行中
6 * IsFinish=0 & Status=WorkFlowStatus.Deprecate 表示不同意
7 * IsFinish=0 & Status=WorkFlowStatus.Back 表示流程被退回
8 * **/
9 /// <summary>
10 /// 流程節(jié)點(diǎn)是否結(jié)束
11 /// 注：此字段代表工作流流轉(zhuǎn)過程中運(yùn)行的狀態(tài)判斷
12 /// </summary>
13 public int? IsFinish { get; set; }
14
15 /// <summary>
16 /// 用戶操作狀態(tài)<see cref="WorkFlowStatus"/>
17 /// 注：此字段代表用戶操作流程的狀態(tài)
18 /// </summary>
19 public int Status { get; set; }
20
21 #endregion

至于頁面審批按鈕的展示，因為這個功能是公用的，我把它寫在了組件里面，共兩個菜單組件，一個是定制一個是系統(tǒng)生成，代碼稍微有些不同，組件視圖代碼比較多，就不展示了。

下面走一個不同意的請假流程：

1、wms賬號先選擇要發(fā)起的流程

2、流程發(fā)起界面

3、流程提交之后的界面，注：終止：當(dāng)用戶提交表單之后，下個節(jié)點(diǎn)未進(jìn)行審批的時候，流程發(fā)起人有權(quán)終止（取消流程）

4、wangwu賬號登錄

5、結(jié)果展示

6、審批意見查看

7、流程圖查看，綠色節(jié)點(diǎn)表示流程當(dāng)前節(jié)點(diǎn)。

8、也可以在OA員工請假看到結(jié)果

注：因為工作流引擎不涉及具體的業(yè)務(wù)邏輯，通常與OA系統(tǒng)進(jìn)行表單綁定，所以我建了OA服務(wù)，并簡單寫了個請假流程方便測試。工作流依賴于之前的權(quán)限系統(tǒng)，如果登錄人員顯示沒有權(quán)限，請先進(jìn)行授權(quán)

四、結(jié)束

　　每個程序員剛畢業(yè)的時候都有一種我要獨(dú)立寫一個超級牛逼系統(tǒng)的沖動，我也是，都不記得多少年了，斷斷續(xù)續(xù)堅持到現(xiàn)在，雖然不算完善，更談不上多么牛逼，寫這兩篇算是給自己一個交代吧。如果大家覺得有研究價值的話，我會繼續(xù)升級迭代。

運(yùn)行方式參考?上一篇?（末尾）

管理員登錄賬號wms，密碼：所有賬號密碼都是123

代碼地址:

https://github.com/wangmaosheng/MsSystem-BPM-ServiceAndWebApps

如果覺得有點(diǎn)作用的話，可以?start?下，后續(xù)會持續(xù)更新。

原文地址：https://www.cnblogs.com/wms01/p/10940565.html

.NET社區(qū)新聞，深度好文，歡迎訪問公眾號文章匯總?http://www.csharpkit.com?

總結(jié)

以上是生活随笔為你收集整理的.NET Core微服务 权限系统+工作流（二）工作流系统的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。