diff --git a/Src/Dlhis.Basic/Device/Services/Implements/DevicePermissionService.cs b/Src/Dlhis.Basic/Device/Services/Implements/DevicePermissionService.cs index 1c870be0..4aed72a0 100644 --- a/Src/Dlhis.Basic/Device/Services/Implements/DevicePermissionService.cs +++ b/Src/Dlhis.Basic/Device/Services/Implements/DevicePermissionService.cs @@ -233,7 +233,8 @@ public class DevicePermissionService : IDevicePermissionService _logger.LogInformation("{tenant}任务后置人数{count}", tenantId, userNos.Count); var devices = await _dbContext.Queryable().Where(x => x.Enable).ToListAsync(); - var waitTasks = new List(); + var waitAddTasks = new List(); + var waitDeleteTasks = new List(); foreach (var userNo in userNos) { @@ -268,7 +269,7 @@ public class DevicePermissionService : IDevicePermissionService addItems = addItems.Where(x => deviceCodes.Contains(x)).ToList(); //下发任务创建 - deletedItems.ForEach(x => waitTasks.Add(new DeviceTaskEntity + deletedItems.ForEach(x => waitDeleteTasks.Add(new DeviceTaskEntity { DeviceUniqueNo = devices.First(item => item.Code == x).UniqueNo, Status = DeviceTaskStatusEnumType.Wait, @@ -280,7 +281,7 @@ public class DevicePermissionService : IDevicePermissionService TenantId = tenant, })); - addItems.ForEach(x => waitTasks.Add(new DeviceTaskEntity + addItems.ForEach(x => waitAddTasks.Add(new DeviceTaskEntity { DeviceUniqueNo = devices.First(item => item.Code == x).UniqueNo, Status = DeviceTaskStatusEnumType.Wait, @@ -293,10 +294,14 @@ public class DevicePermissionService : IDevicePermissionService } } - _logger.LogInformation("{tenant}任务产生数量{count}", tenantId, waitTasks.Count); - if (waitTasks.Any()) + _logger.LogInformation("{tenant}任务产生新增数量{addCount},删除数量:{delteCount}", tenantId, waitAddTasks.Count, waitDeleteTasks.Count); + if (waitAddTasks.Any()) { - await _dbContext.InsertAsync(waitTasks); + await _dbContext.InsertAsync(waitAddTasks); + } + if (waitDeleteTasks.Any()) + { + await _dbContext.InsertAsync(waitDeleteTasks); } }