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

TelemetryDataBaseService replace telemetry tracer by telemetryDataCache.

Browse Source
This commit is contained in:
ngfrolov 2023-05-19 16:32:37 +05:00
parent 36556bd6e3
commit b2b2682dba
Signed by: ng.frolov
GPG Key ID: E99907A0357B29A7
1 changed files with 3 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
AsbCloudInfrastructure/Services/SAUB/TelemetryDataBaseService.cs
View File

@ -101,19 +101,15 @@ namespace AsbCloudInfrastructure.Services.SAUB
DateTimeOffset dateBeginUtc; DateTimeOffset dateBeginUtc;
if (dateBegin == default) if (dateBegin == default)
{ {
dateBeginUtc = telemetryService.GetLastTelemetryDate(telemetry.Id) var dateRange = telemetryDataCache.GetOrDefaultDataDateRange(telemetry.Id);
.ToUtcDateTimeOffset(timezone.Hours); dateBeginUtc = (dateRange?.To.ToUtcDateTimeOffset(timezone.Hours) ?? DateTime.UtcNow)
if (dateBeginUtc != default) .AddSeconds(-intervalSec);
dateBeginUtc = dateBeginUtc.AddSeconds(-intervalSec);
} }
else else
{ {
dateBeginUtc = dateBegin.ToUtcDateTimeOffset(timezone.Hours); dateBeginUtc = dateBegin.ToUtcDateTimeOffset(timezone.Hours);
} }
if (dateBeginUtc == default)
dateBeginUtc = DateTime.UtcNow.AddSeconds(-intervalSec);
var cacheData = telemetryDataCache.GetOrDefault(telemetry.Id, dateBeginUtc.ToRemoteDateTime(timezone.Hours), intervalSec, approxPointsCount); var cacheData = telemetryDataCache.GetOrDefault(telemetry.Id, dateBeginUtc.ToRemoteDateTime(timezone.Hours), intervalSec, approxPointsCount);
if (cacheData is not null) if (cacheData is not null)
return cacheData; return cacheData;