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-24 21:07:46 +08:00
parent ef18e20adf
commit 2c0e0ea636
1 changed files with 11 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -233,7 +233,8 @@ public class DevicePermissionService : IDevicePermissionService
_logger.LogInformation("{tenant}任务后置人数{count}", tenantId, userNos.Count);
var devices = await _dbContext.Queryable<DeviceEntity>().Where(x => x.Enable).ToListAsync();
var waitTasks = new List<DeviceTaskEntity>();
var waitAddTasks = new List<DeviceTaskEntity>();
var waitDeleteTasks = new List<DeviceTaskEntity>();
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);
}
}