|
@@ -192,6 +192,9 @@ public class WorkflowApplication : IWorkflowApplication, IScopeDependency
|
|
|
throw new UserFriendlyException("未正确配置开始节点");
|
|
|
//var firstStepDefines = definition.FindStepDefines(startStep.NextSteps.Select(d => d.Code));
|
|
|
var firstStepDefine = definition.FindStepDefine(startStep.NextSteps.First().Code);
|
|
|
+ if (firstStepDefine == null)
|
|
|
+ throw new UserFriendlyException("未正确配置首个办理节点");
|
|
|
+
|
|
|
var secondStepDefines = definition.FindStepDefines(firstStepDefine.NextSteps.Select(d => d.Code));
|
|
|
|
|
|
if (firstStepDefine.PathPolicy is not EPathPolicy.None && firstStepDefine.NextSteps.Count > 1)
|
|
@@ -287,7 +290,7 @@ public class WorkflowApplication : IWorkflowApplication, IScopeDependency
|
|
|
var roles = await _roleRepository.Queryable()
|
|
|
.Includes(d => d.Accounts, x => x.User)
|
|
|
.Where(d => stepDefine.HandlerClassifies.Select(d => d.Id).Contains(d.Name))
|
|
|
- .ToListAsync();
|
|
|
+ .ToListAsync(cancellationToken);
|
|
|
handlers = roles.SelectMany(d => d.Accounts).Distinct().Select(d => new IdName(d.Id, d.User.Name)).ToList();
|
|
|
}
|
|
|
|
|
@@ -346,7 +349,7 @@ public class WorkflowApplication : IWorkflowApplication, IScopeDependency
|
|
|
var users1 = await _userRepository.Queryable()
|
|
|
.Includes(d => d.Organization)
|
|
|
.Where(d => dto.NextHandlers.Select(x => x.Id).Contains(d.Id))
|
|
|
- .ToListAsync();
|
|
|
+ .ToListAsync(cancellationToken);
|
|
|
assigns = users1.Select(d => WorkflowAssign.Create(workflow.Id, d.OrgCode, d.Organization.OrgName))
|
|
|
.ToList();
|
|
|
}
|
|
@@ -365,7 +368,7 @@ public class WorkflowApplication : IWorkflowApplication, IScopeDependency
|
|
|
var accounts = await _accountRepository.Queryable()
|
|
|
.Includes(d => d.User, d => d.Organization)
|
|
|
.Where(d => dto.NextHandlers.Select(d => d.Id).Contains(d.Name))
|
|
|
- .ToListAsync();
|
|
|
+ .ToListAsync(cancellationToken);
|
|
|
assigns = accounts.Select(d => d.User.Organization).Select(d =>
|
|
|
WorkflowAssign.Create(workflow.Id, d.OrgCode, d.OrgName)).ToList();
|
|
|
//}
|
|
@@ -384,7 +387,7 @@ public class WorkflowApplication : IWorkflowApplication, IScopeDependency
|
|
|
var users = await _userRepository.Queryable()
|
|
|
.Includes(d => d.Organization)
|
|
|
.Where(d => dto.NextHandlers.Select(x => x.Id).Contains(d.Id))
|
|
|
- .ToListAsync();
|
|
|
+ .ToListAsync(cancellationToken);
|
|
|
assigns = users.Select(d => WorkflowAssign.Create(workflow.Id, d.OrgCode, d.Organization.OrgName))
|
|
|
.ToList();
|
|
|
break;
|