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

Merge branch 'dev' into fix/wellOperation-date-time-offset

Browse Source
This commit is contained in:
on.nemtina 2023-12-29 14:22:47 +05:00
commit 264d19bdd3
2 changed files with 22 additions and 24 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
AsbCloudInfrastructure/Services/DetectOperations/DetectedOperationService.cs
View File

@ -173,35 +173,34 @@ namespace AsbCloudInfrastructure.Services.DetectOperations
}; };
} }
private IQueryable<DetectedOperation> BuildQueryBase(WellDto well, DetectedOperationRequest request) private IQueryable<DetectedOperation> BuildQueryBase(WellDto well, DetectedOperationRequest request)
{ {
var query = db.Set<DetectedOperation>() var query = db.Set<DetectedOperation>()
.Where(o => o.IdTelemetry == well.IdTelemetry); .Where(o => o.IdTelemetry == well.IdTelemetry);
if (request is not null) if (request.IdsTelemetries.Any())
{ {
if (request.IdsTelemetries.Any()) query = query
query = query.Where(o => request.IdsTelemetries.Contains(o.IdTelemetry)); .Union(db.Set<DetectedOperation>().Where(o => request.IdsTelemetries.Contains(o.IdTelemetry)));
}
if (request.IdsCategories.Any()) if (request.IdsCategories.Any())
query = query.Where(o => request.IdsCategories.Contains(o.IdCategory)); query = query.Where(o => request.IdsCategories.Contains(o.IdCategory));
if (request.GeDateStart is not null) if (request.GeDateStart is not null)
query = query.Where(o => o.DateStart >= request.GeDateStart.Value.Date.ToUtcDateTimeOffset(well.Timezone.Hours)); query = query.Where(o => o.DateStart >= request.GeDateStart.Value.Date.ToUtcDateTimeOffset(well.Timezone.Hours));
if (request.LeDateEnd is not null) if (request.LeDateEnd is not null)
query = query.Where(o => o.DateEnd <= request.LeDateEnd.Value.Date.ToUtcDateTimeOffset(well.Timezone.Hours)); query = query.Where(o => o.DateEnd <= request.LeDateEnd.Value.Date.ToUtcDateTimeOffset(well.Timezone.Hours));
if (request.GeDepth is not null) if (request.GeDepth is not null)
query = query.Where(o => o.DepthStart >= request.GeDepth); query = query.Where(o => o.DepthStart >= request.GeDepth);
if (request.LeDepth is not null) if (request.LeDepth is not null)
query = query.Where(o => o.DepthEnd <= request.LeDepth); query = query.Where(o => o.DepthEnd <= request.LeDepth);
if (request.IdTelemetryUser is not null) if (request.IdTelemetryUser is not null)
query = query.Where(o => o.IdUsersAtStart == request.IdTelemetryUser); query = query.Where(o => o.IdUsersAtStart == request.IdTelemetryUser);
}
return query; return query;
} }
@ -211,7 +210,7 @@ namespace AsbCloudInfrastructure.Services.DetectOperations
IQueryable<DetectedOperation> query = BuildQueryBase(well, request) IQueryable<DetectedOperation> query = BuildQueryBase(well, request)
.Include(o => o.OperationCategory); .Include(o => o.OperationCategory);
if (request?.SortFields?.Any() == true) if (request.SortFields?.Any() == true)
{ {
query = query.SortBy(request.SortFields); query = query.SortBy(request.SortFields);
} }
@ -220,10 +219,10 @@ namespace AsbCloudInfrastructure.Services.DetectOperations
.OrderBy(o => o.DateStart) .OrderBy(o => o.DateStart)
.ThenBy(o => o.DepthStart); .ThenBy(o => o.DepthStart);
if (request?.Skip > 0) if (request.Skip.HasValue)
query = query.Skip((int)request.Skip); query = query.Skip((int)request.Skip);
if (request?.Take > 0) if (request.Take.HasValue)
query = query.Take((int)request.Take); query = query.Take((int)request.Take);
return query; return query;

7
AsbCloudInfrastructure/Services/Subsystems/SubsystemService.cs
View File

@ -227,19 +227,17 @@ internal class SubsystemService : ISubsystemService
var request = new DetectedOperationRequest var request = new DetectedOperationRequest
{ {
IdsTelemetries = idsTelemetries, IdWell = well.Id,
IdsCategories = WellOperationCategory.MechanicalDrillingSubIds, IdsCategories = WellOperationCategory.MechanicalDrillingSubIds,
GeDateStart = geDateStartUtc, GeDateStart = geDateStartUtc,
LeDateEnd = leDateUtc, LeDateEnd = leDateUtc,
}; };
var operations = await detectedOperationService var telemetryOperations = await detectedOperationService
.GetOperationsAsync(request, token); .GetOperationsAsync(request, token);
var wellStat = new SubsystemActiveWellStatDto { Well = well }; var wellStat = new SubsystemActiveWellStatDto { Well = well };
var telemetryOperations = operations.Where(o => o.IdTelemetry == well.IdTelemetry);
if (!telemetryOperations.Any()) if (!telemetryOperations.Any())
continue; continue;
@ -250,6 +248,7 @@ internal class SubsystemService : ISubsystemService
wellStat.SubsystemAPD = subsystemStat.FirstOrDefault(s => s.IdSubsystem == IdSubsystemAPD); wellStat.SubsystemAPD = subsystemStat.FirstOrDefault(s => s.IdSubsystem == IdSubsystemAPD);
wellStat.SubsystemOscillation = subsystemStat.FirstOrDefault(s => s.IdSubsystem == IdSubsystemOscillation); wellStat.SubsystemOscillation = subsystemStat.FirstOrDefault(s => s.IdSubsystem == IdSubsystemOscillation);
wellsStat.Add(wellStat);
} }
return wellsStat; return wellsStat;