ideship/track
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge branch 'S07' into test

Browse Source
This commit is contained in:
hardstylewyl 2025-03-26 15:42:42 +08:00
commit 77939a0b70
2 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/SJZY.Track.Application/Services/Warning/CompleteWarningService.cs
View File

@ -134,7 +134,7 @@ public class CompleteWarningService : ApplicationService
// todo:缓存优化 // todo:缓存优化
var trackStatusIds = result.List var trackStatusIds = result.List
.SelectMany(x => x.MissingTrackStatusIds.Split(',').Select(int.Parse)) .SelectMany(x => x.GetMissingTrackStatusIdGroups().SelectMany(y => y))
.ToHashSet(); .ToHashSet();
var trackStatusDict = (await _trackStatusRepository.GetListAsync(x => trackStatusIds.Contains(x.Id), x => new var trackStatusDict = (await _trackStatusRepository.GetListAsync(x => trackStatusIds.Contains(x.Id), x => new
{ {

6
src/SJZY.Track.Repository/Repositories/WarningDetailsEsRepository.cs
View File

@ -818,8 +818,12 @@ public class WarningDetailsEsRepository : IWarningDetailsEsRepository, ITransien
u.Index(GlobalConst.CompleteWarningDetailsIndex) u.Index(GlobalConst.CompleteWarningDetailsIndex)
.Query(q => q.Bool(b => b.Must(musts))) .Query(q => q.Bool(b => b.Must(musts)))
.Script(s => s .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("status", (int) input.SetStatus))
.Params(p => p.Add("processedTime", DateTime.Now))
) )
); );