diff --git a/src/SJZY.Track.Application/Services/Warning/CompleteWarningService.cs b/src/SJZY.Track.Application/Services/Warning/CompleteWarningService.cs index 43162cde..93a53005 100644 --- a/src/SJZY.Track.Application/Services/Warning/CompleteWarningService.cs +++ b/src/SJZY.Track.Application/Services/Warning/CompleteWarningService.cs @@ -134,7 +134,7 @@ public class CompleteWarningService : ApplicationService // todo:缓存优化 var trackStatusIds = result.List - .SelectMany(x => x.MissingTrackStatusIds.Split(',').Select(int.Parse)) + .SelectMany(x => x.GetMissingTrackStatusIdGroups().SelectMany(y => y)) .ToHashSet(); var trackStatusDict = (await _trackStatusRepository.GetListAsync(x => trackStatusIds.Contains(x.Id), x => new { diff --git a/src/SJZY.Track.Repository/Repositories/WarningDetailsEsRepository.cs b/src/SJZY.Track.Repository/Repositories/WarningDetailsEsRepository.cs index c5021853..ef7b52b3 100644 --- a/src/SJZY.Track.Repository/Repositories/WarningDetailsEsRepository.cs +++ b/src/SJZY.Track.Repository/Repositories/WarningDetailsEsRepository.cs @@ -818,8 +818,12 @@ public class WarningDetailsEsRepository : IWarningDetailsEsRepository, ITransien u.Index(GlobalConst.CompleteWarningDetailsIndex) .Query(q => q.Bool(b => b.Must(musts))) .Script(s => s - .Source("ctx._source.status = params.status") + .Source(@" + ctx._source.status = params.status; + ctx._source.processedTime = params.processedTime; + ") .Params(p => p.Add("status", (int) input.SetStatus)) + .Params(p => p.Add("processedTime", DateTime.Now)) ) );