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

OperationDetectionBackgroundService remove statistic for optimization.

Browse Source
This commit is contained in:
ngfrolov 2022-06-27 10:28:27 +05:00
parent 383e27d230
commit d45145b8a5
1 changed files with 1 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
AsbCloudInfrastructure/Services/DetectOperations/OperationDetectionBackgroundService.cs
View File

@ -132,24 +132,13 @@ namespace AsbCloudInfrastructure.Services.DetectOperations
var startDate = begin; var startDate = begin;
var detectedOperations = new List<DetectedOperation>(8); var detectedOperations = new List<DetectedOperation>(8);
var dbRequests_ = 0;
var dbTime_ = 0d;
var sw_ = new Stopwatch();
var otherTime_ = 0d;
while (true) while (true)
{ {
sw_.Restart();
var data = await query var data = await query
.Where(d => d.DateTime > startDate) .Where(d => d.DateTime > startDate)
.Take(take) .Take(take)
.ToArrayAsync(token); .ToArrayAsync(token);
sw_.Stop();
dbTime_ += sw_.ElapsedMilliseconds;
dbRequests_++;
sw_.Restart();
if (data.Length < minFragmentLength) if (data.Length < minFragmentLength)
break; break;
@ -182,16 +171,9 @@ namespace AsbCloudInfrastructure.Services.DetectOperations
skip += minStepLength; skip += minStepLength;
} }
sw_.Stop();
otherTime_ += sw_.ElapsedMilliseconds;
if (!isDetected) if (!isDetected)
{ {
if (data.Length < take) startDate = startDate.AddSeconds(0.95 * take);
break;
var lastPartDate = data.Last().DateTime;
startDate = startDate + (0.75 * (lastPartDate - startDate));
} }
} }