yuangb/jinko.yikatong
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix 并发计算

Browse Source
This commit is contained in:
liguoyang
2024-06-19 20:13:39 +08:00
parent 823adaff1f
commit 78ecf1e11d
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
Src/Dlhis.Basic/Device/Services/Implements/DevicePermissionService.cs
View File

@@ -212,7 +212,7 @@ public class DevicePermissionService : IDevicePermissionService
var devices = await _dbContext.Queryable<DeviceEntity>().Where(x => x.Enable).ToListAsync(); var devices = await _dbContext.Queryable<DeviceEntity>().Where(x => x.Enable).ToListAsync();
var waitTasks = new List<DeviceTaskEntity>(); var waitTasks = new List<DeviceTaskEntity>();
foreach (var userNo in userNos) Parallel.ForEach(userNos, userNo =>
{ {
before.TryGetValue(userNo, out var beforeTenantDeviceCodes); before.TryGetValue(userNo, out var beforeTenantDeviceCodes);
beforeTenantDeviceCodes ??= new(); beforeTenantDeviceCodes ??= new();
@@ -270,7 +270,7 @@ public class DevicePermissionService : IDevicePermissionService
waitTasks.AddRange(toDeleted.Concat(toAdd).ToList()); waitTasks.AddRange(toDeleted.Concat(toAdd).ToList());
} }
} });
_logger.LogInformation("任务产生数量{count}", waitTasks.Count); _logger.LogInformation("任务产生数量{count}", waitTasks.Count);
if (waitTasks.Any()) if (waitTasks.Any())