diff --git a/Src/Dlhis.ScheduledTask/TaskAssignment/Services/Implements/AssignmentService.cs b/Src/Dlhis.ScheduledTask/TaskAssignment/Services/Implements/AssignmentService.cs index fb628937..108d4a36 100644 --- a/Src/Dlhis.ScheduledTask/TaskAssignment/Services/Implements/AssignmentService.cs +++ b/Src/Dlhis.ScheduledTask/TaskAssignment/Services/Implements/AssignmentService.cs @@ -272,21 +272,21 @@ public class AssignmentService : IAssignmentService return page.Data; } - //var taskIdVs = page.Data.Select(x => new { x.TaskId, x.Version, x.Status }).ToList(); - //var where = LinqExpressionExtensions.False(); - //taskIdVs.ForEach(p => - //{ - // where = where.Or(x => x.Id == p.TaskId && x.Version == p.Version && x.Status == p.Status); - //}); + var taskIdVs = page.Data.Select(x => new { x.TaskId, x.Version, x.Status }).ToList(); + var where = LinqExpressionExtensions.False(); + taskIdVs.ForEach(p => + { + where = where.Or(x => x.Id == p.TaskId && x.Version == p.Version && x.Status == p.Status); + }); - //var effecet = await _dbContext.Updateable() - // .SetColumns(x => x.Version == x.Version + 1) - // .SetColumns(x => x.Status == DeviceTaskStatusEnumType.Process) - // .SetColumns(x => x.ModifiedTime == DateTime.Now) - // .Where(where) - // .ExecuteCommandAsync(); + var effecet = await _dbContext.Updateable() + .SetColumns(x => x.Version == x.Version + 1) + .SetColumns(x => x.Status == DeviceTaskStatusEnumType.Process) + .SetColumns(x => x.ModifiedTime == DateTime.Now) + .Where(where) + .ExecuteCommandAsync(); - //(taskIdVs.Count != effecet).ThrowIfTrue("获取任务失败"); + (taskIdVs.Count != effecet).ThrowIfTrue("获取任务失败"); return page.Data;