diff --git a/Src/Dlhis.ScheduledTask/TaskAssignment/Services/Implements/AssignmentService.cs b/Src/Dlhis.ScheduledTask/TaskAssignment/Services/Implements/AssignmentService.cs index 2dc4f35a..840c49bb 100644 --- a/Src/Dlhis.ScheduledTask/TaskAssignment/Services/Implements/AssignmentService.cs +++ b/Src/Dlhis.ScheduledTask/TaskAssignment/Services/Implements/AssignmentService.cs @@ -340,17 +340,6 @@ public class AssignmentService : IAssignmentService DeviceTaskEnumType.SyncDateTime }; - //排除UploadRecord,SyncDateTime的任务,获取最近的任务ID - var limitData = await _dbContext.Queryable() - .Where(x => x.ModifiedTime >= limitTime) - .Where(x => x.DeviceUniqueNo == deviceUniqueNo) - .Where(x => !types.Contains(x.Type)) - .OrderBy(x => x.Id) - .Select(x => new { x.Id }) - .FirstAsync(); - - var startId = limitData?.Id; - //获取其他任务ID var otherIds = await _dbContext.Queryable() .Where(x => x.DeviceUniqueNo == deviceUniqueNo) @@ -359,6 +348,17 @@ public class AssignmentService : IAssignmentService .Select(x => x.Id) .ToListAsync(); + //排除UploadRecord,SyncDateTime的任务,获取最近的任务ID + var limitData = await _dbContext.Queryable() + .Where(x => x.ModifiedTime >= limitTime) + .Where(x => x.DeviceUniqueNo == deviceUniqueNo) + .Where(x => !otherIds.Contains(x.Id)) + .OrderBy(x => x.Id) + .Select(x => new { x.Id }) + .FirstAsync(); + + var startId = limitData?.Id; + return (startId, otherIds); }