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-04-20 15:37:08 +08:00
parent 66367ec4f4
commit b3b1952ba0
1 changed files with 13 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

26
Src/Dlhis.ScheduledTask/TaskAssignment/Services/Implements/AssignmentService.cs
View File

@@ -272,21 +272,21 @@ public class AssignmentService : IAssignmentService
return page.Data;
}
//var taskIdVs = page.Data.Select(x => new { x.TaskId, x.Version, x.Status }).ToList();
//var where = LinqExpressionExtensions.False<DeviceTaskEntity>();
//taskIdVs.ForEach(p =>
//{
// where = where.Or(x => x.Id == p.TaskId && x.Version == p.Version && x.Status == p.Status);
//});
var taskIdVs = page.Data.Select(x => new { x.TaskId, x.Version, x.Status }).ToList();
var where = LinqExpressionExtensions.False<DeviceTaskEntity>();
taskIdVs.ForEach(p =>
{
where = where.Or(x => x.Id == p.TaskId && x.Version == p.Version && x.Status == p.Status);
});
//var effecet = await _dbContext.Updateable<DeviceTaskEntity>()
// .SetColumns(x => x.Version == x.Version + 1)
// .SetColumns(x => x.Status == DeviceTaskStatusEnumType.Process)
// .SetColumns(x => x.ModifiedTime == DateTime.Now)
// .Where(where)
// .ExecuteCommandAsync();
var effecet = await _dbContext.Updateable<DeviceTaskEntity>()
.SetColumns(x => x.Version == x.Version + 1)
.SetColumns(x => x.Status == DeviceTaskStatusEnumType.Process)
.SetColumns(x => x.ModifiedTime == DateTime.Now)
.Where(where)
.ExecuteCommandAsync();
//(taskIdVs.Count != effecet).ThrowIfTrue("获取任务失败");
(taskIdVs.Count != effecet).ThrowIfTrue("获取任务失败");
return page.Data;