From 9e599f183a011427da48efabe52e6e3cb42f66e6 Mon Sep 17 00:00:00 2001 From: liguoyang Date: Wed, 13 May 2026 17:13:43 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E5=87=8F=E5=B0=91where=20=E6=9D=A1?= =?UTF-8?q?=E4=BB=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../TaskAssignment/Services/Implements/AssignmentService.cs | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/Src/Dlhis.ScheduledTask/TaskAssignment/Services/Implements/AssignmentService.cs b/Src/Dlhis.ScheduledTask/TaskAssignment/Services/Implements/AssignmentService.cs index b73e388b..6f8fa930 100644 --- a/Src/Dlhis.ScheduledTask/TaskAssignment/Services/Implements/AssignmentService.cs +++ b/Src/Dlhis.ScheduledTask/TaskAssignment/Services/Implements/AssignmentService.cs @@ -222,7 +222,6 @@ public class AssignmentService : IAssignmentService .Select((x, f) => f.AcsValue) .ToListAsync(); - var all = await CommonHelper.RetryAsync(async () => { var internalAll = new List(); @@ -244,7 +243,7 @@ public class AssignmentService : IAssignmentService var effect = await _dbContext.Updateable() .SetColumns(x => x.Status == DeviceTaskStatusEnumType.Process) .SetColumns(x => x.ModifiedTime == DateTime.Now) - .Where(x => internalAll.Contains(x.Id) && (x.Status == DeviceTaskStatusEnumType.Wait || x.Status == DeviceTaskStatusEnumType.Process)) + .Where(x => internalAll.Contains(x.Id)) .ExecuteCommandAsync(); if (effect != internalAll.Count) @@ -254,7 +253,7 @@ public class AssignmentService : IAssignmentService return internalAll; - }, 5); + }, 3); if (!all.Any()) {