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-02-29 13:43:53 +08:00
parent 942330fd1d
commit 10cc93cf76
1 changed files with 6 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
Src/Dlhis.ScheduledTask/TaskAssignment/Job/CreateGetUploadRecordJob.cs
View File

@@ -29,16 +29,14 @@ public class CreateGetUploadRecordJob
|| x.Type == DeviceTypeEnumType.Door) || x.Type == DeviceTypeEnumType.Door)
.ToListAsync(); .ToListAsync();
var uniqueNos = devices.Select(x => x.UniqueNo).ToList();
//过滤处理中的任务 //过滤处理中的任务
uniqueNos = await _dbContext.Queryable<DeviceTaskEntity>() var currentUniqueNos = await _dbContext.Queryable<DeviceTaskEntity>()
.Where(x => !uniqueNos.Contains(x.DeviceUniqueNo)) .Where(x => x.Type == DeviceTaskEnumType.UploadRecord)
.Where(x => x.Type == DeviceTaskEnumType.UploadRecord) .Where(x => x.Status == DeviceTaskStatusEnumType.Process || x.Status == DeviceTaskStatusEnumType.Wait)
.Where(x => x.Status == DeviceTaskStatusEnumType.Process || x.Status == DeviceTaskStatusEnumType.Wait) .Select(x => x.DeviceUniqueNo)
.Select(x => x.DeviceUniqueNo) .ToListAsync();
.ToListAsync();
var tasks = devices.Where(x => uniqueNos.Contains(x.UniqueNo)).Select(x => new DeviceTaskEntity var tasks = devices.Where(x => !currentUniqueNos.Contains(x.UniqueNo)).Select(x => new DeviceTaskEntity
{ {
DeviceUniqueNo = x.UniqueNo, DeviceUniqueNo = x.UniqueNo,
Status = DeviceTaskStatusEnumType.Wait, Status = DeviceTaskStatusEnumType.Wait,