fix 同步任务生成处理

This commit is contained in:
2024-02-23 18:14:15 +08:00
parent bc812a30b9
commit 0e156159b1

View File

@@ -22,10 +22,18 @@ namespace Dlhis.ScheduledTask.TaskAssignment.Job
_dbContext.Client.QueryFilter.ClearAndBackup();
try
{
var devices = await _dbContext.Queryable<DeviceEntity>().Where(x => x.Enable).ToListAsync();
var deviceUniqueNos = await _dbContext.Queryable<DeviceTaskEntity>().Where(x => x.Status == DeviceTaskStatusEnumType.Wait)
.Where(x => x.Type == DeviceTaskEnumType.SyncDateTime)
.Select(x => x.DeviceUniqueNo)
.ToListAsync();
var devices = await _dbContext.Queryable<DeviceEntity>()
.Where(x => deviceUniqueNos.Contains(x.UniqueNo))
.Where(x => x.Enable)
.ToListAsync();
var tasks = devices.Select(x => new DeviceTaskEntity
{
DeviceUniqueNo = x.UniqueNo,
Status = DeviceTaskStatusEnumType.Wait,