@@ -127,11 +127,13 @@ void flowWaitingTest() {
127
127
.title ("请假流程" )
128
128
.nodes ()
129
129
.node ("开始节点" , "start" , "default" , ApprovalType .UN_SIGN , OperatorMatcher .anyOperatorMatcher ())
130
- .node ("老板审批" , "boss" , "default" , ApprovalType .UN_SIGN , OperatorMatcher .specifyOperatorMatcher (boss .getUserId ()))
130
+ .node ("老板审批" , "boss" , "default" , ApprovalType .SIGN , OperatorMatcher .specifyOperatorMatcher (boss .getUserId ()))
131
+ .node ("老板审批" , "boss1" , "default" , ApprovalType .SIGN , OperatorMatcher .specifyOperatorMatcher (boss .getUserId ()))
131
132
.node ("结束节点" , "over" , "default" , ApprovalType .UN_SIGN , OperatorMatcher .anyOperatorMatcher ())
132
133
.relations ()
133
134
.relation ("老板审批" , "start" , "boss" )
134
- .relation ("结束节点" , "boss" , "over" )
135
+ .relation ("老板审批1" , "boss" , "boss1" )
136
+ .relation ("结束节点" , "boss1" , "over" )
135
137
.build ();
136
138
137
139
flowWorkRepository .save (flowWork );
@@ -151,11 +153,17 @@ void flowWaitingTest() {
151
153
String processId = userTodos .get (0 ).getProcessId ();
152
154
153
155
FlowRecord userTodo = userTodos .get (0 );
154
- flowService .submitFlow (userTodo .getId (), lorne , leave , Opinion .waiting ( "自己先提交 " ));
156
+ flowService .submitFlow (userTodo .getId (), lorne , leave , Opinion .pass ( "我提交了 " ));
155
157
156
158
// 查看boss的待办
157
159
List <FlowRecord > bossTodos = flowRecordRepository .findTodoByOperatorId (boss .getUserId (), pageRequest ).getContent ();
158
- assertEquals (0 , bossTodos .size ());
160
+ assertEquals (1 , bossTodos .size ());
161
+
162
+ FlowRecord bossTodo = bossTodos .get (0 );
163
+ flowService .submitFlow (bossTodo .getId (), boss , leave , Opinion .waiting ("我等待提交" ));
164
+
165
+ userTodos = flowRecordRepository .findTodoByOperatorId (lorne .getUserId (), pageRequest ).getContent ();
166
+ assertEquals (0 , userTodos .size ());
159
167
160
168
// 通知流程
161
169
flowService .notifyFlow (processId ,boss );
@@ -164,14 +172,14 @@ void flowWaitingTest() {
164
172
bossTodos = flowRecordRepository .findTodoByOperatorId (boss .getUserId (), pageRequest ).getContent ();
165
173
assertEquals (1 , bossTodos .size ());
166
174
167
- FlowRecord bossTodo = bossTodos .get (0 );
175
+ bossTodo = bossTodos .get (0 );
168
176
flowService .submitFlow (bossTodo .getId (), boss , leave , Opinion .pass ("领导审批通过" ));
169
177
170
178
bossTodos = flowRecordRepository .findTodoByOperatorId (lorne .getUserId (), pageRequest ).getContent ();
171
179
assertEquals (0 , bossTodos .size ());
172
180
173
181
List <FlowRecord > records = flowRecordRepository .findAll (pageRequest ).getContent ();
174
- assertEquals (2 , records .size ());
182
+ assertEquals (3 , records .size ());
175
183
176
184
// 查看所有流程是否都已经结束
177
185
assertTrue (records .stream ().allMatch (FlowRecord ::isFinish ));
0 commit comments