diff --git a/Src/Dlhis.ScheduledTask/TaskAssignment/Services/Implements/AssignmentService.cs b/Src/Dlhis.ScheduledTask/TaskAssignment/Services/Implements/AssignmentService.cs index beb7da5a..881fb7d3 100644 --- a/Src/Dlhis.ScheduledTask/TaskAssignment/Services/Implements/AssignmentService.cs +++ b/Src/Dlhis.ScheduledTask/TaskAssignment/Services/Implements/AssignmentService.cs @@ -242,7 +242,7 @@ public class AssignmentService : IAssignmentService private async Task> GetDataAsync(DeviceTaskGetRequest request) { var limitTime = DateTime.Now.AddDays(-3); - var limitData = await _dbContext.Queryable().Where(x => x.ModifiedTime >= limitTime).FirstAsync(); + var limitData = await _dbContext.Queryable().Where(x => x.ModifiedTime >= limitTime).OrderBy(x => x.ModifiedTime).FirstAsync(); if (limitData == null) { return new List(); @@ -250,6 +250,12 @@ public class AssignmentService : IAssignmentService var startId = limitData.Id; + var otherIds = await _dbContext.Queryable().Where(x => x.DeviceUniqueNo == request.DeviceUniqueNo) + .Where(x => x.Type == DeviceTaskEnumType.UploadRecord || x.Type == DeviceTaskEnumType.SyncDateTime) + .Where(x => x.Status == DeviceTaskStatusEnumType.Wait) + .Select(x => x.Id) + .ToListAsync(); + var data = await CommonHelper.RetryAsync(async () => { var rows = await _dbContext.Queryable() @@ -259,8 +265,8 @@ public class AssignmentService : IAssignmentService .LeftJoin((deviceTask, device, ga, gaLeave, department) => department.No == ga.DepartmentNo) .LeftJoin((deviceTask, device, ga, gaLeave, department, deviceRegistry) => deviceRegistry.DeviceUniqueNo == deviceTask.DeviceUniqueNo) .Where((deviceTask, device) => - deviceTask.Id >= startId && - deviceTask.DeviceUniqueNo == request.DeviceUniqueNo + (deviceTask.Id >= startId || otherIds.Contains(deviceTask.Id)) + && deviceTask.DeviceUniqueNo == request.DeviceUniqueNo ) .WhereIF(!request.IsProcess, deviceTask => deviceTask.Status == DeviceTaskStatusEnumType.Wait) .WhereIF(request.IsProcess, deviceTask => deviceTask.Status == DeviceTaskStatusEnumType.Process