|
@@ -464,8 +464,7 @@ public class TestController : BaseController
|
|
|
.Where(d => !SqlFunc.Subqueryable<WorkflowStepHandler>().Where(x => x.WorkflowStepId == d.StepId).Any())
|
|
|
.ToListAsync(HttpContext.RequestAborted);
|
|
|
|
|
|
- var a = items.Select(d => d.StepId).ToList();
|
|
|
-
|
|
|
+ _logger.LogInformation($"traces.count: {items.Count}");
|
|
|
//var items = await _workflowTraceRepository.Queryable()
|
|
|
// .LeftJoin<WorkflowStepHandler>((t, h) => t.StepId == h.WorkflowStepId)
|
|
|
// .Where((t, h) => h == null)
|
|
@@ -523,9 +522,11 @@ public class TestController : BaseController
|
|
|
}
|
|
|
}
|
|
|
|
|
|
+ _logger.LogInformation($"待更新traces: {updateTraces.Count}");
|
|
|
if (updateTraces.Any())
|
|
|
await _workflowTraceRepository.UpdateRangeAsync(updateTraces, HttpContext.RequestAborted);
|
|
|
|
|
|
+ _logger.LogInformation($"待更新traces: {handlers.Count}");
|
|
|
if (handlers.Any())
|
|
|
await _workflowStepHandleRepository.AddRangeAsync(handlers, HttpContext.RequestAborted);
|
|
|
}
|