|
@@ -275,7 +275,7 @@ public class OrderDomainService : IOrderDomainService, IScopeDependency
|
|
cancellationToken);
|
|
cancellationToken);
|
|
if (steps.Any())
|
|
if (steps.Any())
|
|
{
|
|
{
|
|
- List<(string userId, string username, string orgId, string orgName, ICollection<WorkflowStep> steps)> handlers = new();
|
|
|
|
|
|
+ List<(string userId, string username, string orgId, string orgName,string? roleId,string? roleName, ICollection<WorkflowStep> steps)> handlers = new();
|
|
var avg = steps.Count / schedulings.Count;
|
|
var avg = steps.Count / schedulings.Count;
|
|
var remaining = steps.Count % schedulings.Count;
|
|
var remaining = steps.Count % schedulings.Count;
|
|
for (var i = 0; i < schedulings.Count; i++)
|
|
for (var i = 0; i < schedulings.Count; i++)
|
|
@@ -287,6 +287,7 @@ public class OrderDomainService : IOrderDomainService, IScopeDependency
|
|
scheduling.SchedulingUser.UserName,
|
|
scheduling.SchedulingUser.UserName,
|
|
scheduling.SchedulingUser.OrgId,
|
|
scheduling.SchedulingUser.OrgId,
|
|
scheduling.SchedulingUser.OrgIdName,
|
|
scheduling.SchedulingUser.OrgIdName,
|
|
|
|
+ null,null,
|
|
steps.Take(size).ToList()));
|
|
steps.Take(size).ToList()));
|
|
scheduling.SendOrderNum += size;
|
|
scheduling.SendOrderNum += size;
|
|
await _schedulingRepository.Updateable()
|
|
await _schedulingRepository.Updateable()
|