diff --git a/Src/Dlhis.ScheduledTask/TaskAssignment/Services/Implements/AssignmentService.cs b/Src/Dlhis.ScheduledTask/TaskAssignment/Services/Implements/AssignmentService.cs index d258885b..71a7bcd9 100644 --- a/Src/Dlhis.ScheduledTask/TaskAssignment/Services/Implements/AssignmentService.cs +++ b/Src/Dlhis.ScheduledTask/TaskAssignment/Services/Implements/AssignmentService.cs @@ -245,7 +245,7 @@ public class AssignmentService : IAssignmentService var data = await CommonHelper.RetryAsync(async () => { - var page = await _dbContext.Queryable() + var rows = await _dbContext.Queryable() .LeftJoin((deviceTask, device) => deviceTask.DeviceUniqueNo == device.UniqueNo) .LeftJoin((deviceTask, device, deviceTemplate) => deviceTemplate.Code == device.TemplateCode) .LeftJoin((deviceTask, device, deviceTemplate, ga) => deviceTask.UserNo == ga.No) @@ -294,14 +294,14 @@ public class AssignmentService : IAssignmentService : SqlFunc.ToInt32(ga.CardType) : 1 }) - .ToPageListAsync(request); + .ToPageListAsync(request.PageIndex, request.PageSize); - if (!page.Data.Any()) + if (!rows.Any()) { - return page.Data; + return rows; } - var taskIdVs = page.Data.Select(x => new { x.TaskId, x.Version, x.Status }).ToList(); + var taskIdVs = rows.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); }); @@ -317,7 +317,7 @@ public class AssignmentService : IAssignmentService throw new VersionExceptions("version exceptions"); } - return page.Data; + return rows; }, 5); return data;