on.nemtina/DD.WellWorkover.Cloud
1
0
Fork 0
forked from ddrilling/AsbCloudServer
Code Pull Requests Activity

Рефактор метода GetMessagesAsync в MessageService

Browse Source
This commit is contained in:
Olga Nemt 2023-02-02 16:07:41 +05:00
parent e81abc86e6
commit 2746c94729
1 changed files with 15 additions and 23 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
AsbCloudInfrastructure/Services/SAUB/MessageService.cs
View File

@ -28,16 +28,8 @@ namespace AsbCloudInfrastructure.Services.SAUB
public async Task<PaginationContainer<MessageDto>> GetMessagesAsync(MessageRequest request, CancellationToken token) public async Task<PaginationContainer<MessageDto>> GetMessagesAsync(MessageRequest request, CancellationToken token)
{ {
var idWell = request.IdWell;
var categoryids = request.Categoryids;
var searchString = request.SearchString;
var begin = request.Begin;
var end = request.End;
var skip = request.Skip ?? 0;
var take = request.Take ?? 32;
var sortFields = request.SortFields;
var idTelemetry = telemetryService.GetOrDefaultIdTelemetryByIdWell(idWell); var idTelemetry = telemetryService.GetOrDefaultIdTelemetryByIdWell(request.IdWell);
if (idTelemetry is null) if (idTelemetry is null)
return null; return null;
@ -50,13 +42,13 @@ namespace AsbCloudInfrastructure.Services.SAUB
var query = db.TelemetryMessages.Where(m => m.IdTelemetry == idTelemetry) var query = db.TelemetryMessages.Where(m => m.IdTelemetry == idTelemetry)
.OrderBy(m => m.DateTime).AsNoTracking(); .OrderBy(m => m.DateTime).AsNoTracking();
if (categoryids?.Any() == true || !string.IsNullOrEmpty(searchString)) if (request.Categoryids?.Any() == true || !string.IsNullOrEmpty(request.SearchString))
{ {
if (!string.IsNullOrEmpty(searchString)) if (!string.IsNullOrEmpty(request.SearchString))
events = events.Where(e => e.MessageTemplate.Contains(searchString, StringComparison.OrdinalIgnoreCase)); events = events.Where(e => e.MessageTemplate.Contains(request.SearchString, StringComparison.OrdinalIgnoreCase));
if (categoryids?.Any() == true) if (request.Categoryids?.Any() == true)
events = events.Where(e => categoryids.ToList().Contains(e.IdCategory)); events = events.Where(e => request.Categoryids.ToList().Contains(e.IdCategory));
var eventIds = events.Select(e => e.IdEvent); var eventIds = events.Select(e => e.IdEvent);
@ -70,31 +62,31 @@ namespace AsbCloudInfrastructure.Services.SAUB
var timezone = telemetryService.GetTimezone(idTelemetry ?? default); var timezone = telemetryService.GetTimezone(idTelemetry ?? default);
if (begin != default) if (request.Begin != default)
{ {
var beginUtc = begin.Value.ToUtcDateTimeOffset(timezone.Hours); var beginUtc = request.Begin.Value.ToUtcDateTimeOffset(timezone.Hours);
query = query.Where(m => m.DateTime >= beginUtc); query = query.Where(m => m.DateTime >= beginUtc);
} }
if (end != default) if (request.End != default)
{ {
var endUtc = end.Value.ToUtcDateTimeOffset(timezone.Hours); var endUtc = request.End.Value.ToUtcDateTimeOffset(timezone.Hours);
query = query.Where(m => m.DateTime <= endUtc); query = query.Where(m => m.DateTime <= endUtc);
} }
var result = new PaginationContainer<MessageDto> var result = new PaginationContainer<MessageDto>
{ {
Skip = skip, Skip = request.Skip ?? 0,
Take = take, Take = request.Take ?? 32,
Count = query.Count() Count = query.Count()
}; };
if (sortFields?.Any() == true) if (request.SortFields?.Any() == true)
{ {
query = query.SortBy(request.SortFields); query = query.SortBy(request.SortFields);
} }
var messagesList = await query.Skip(skip) var messagesList = await query.Skip(request.Skip ?? 0)
.Take(take).AsNoTracking() .Take(request.Take ?? 32).AsNoTracking()
.ToListAsync(token).ConfigureAwait(false); .ToListAsync(token).ConfigureAwait(false);
if (messagesList.Count == 0) if (messagesList.Count == 0)