phares3757/dep08siasm
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

inProcessDirectories

Browse Source
This commit is contained in:
Mike Phares 2022-03-23 11:52:29 -07:00
parent fe1c4762d2
commit c7884587bb
2 changed files with 18 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
Adaptation/FileHandlers/DEP08SIASM/FileRead.cs
View File

@ -253,6 +253,23 @@ public class FileRead : Shared.FileRead, IFileRead
if (json != historicalText) if (json != historicalText)
throw new Exception("File doesn't match historical!"); throw new Exception("File doesn't match historical!");
} }
string[] inProcessDirectorySegments;
string[] inProcessDirectories = Directory.GetDirectories(jobIdDirectory, "*_*_*", SearchOption.TopDirectoryOnly);
foreach (string inProcessDirectory in inProcessDirectories)
{
inProcessDirectorySegments = Path.GetFileName(inProcessDirectory).Split('_');
if (inProcessDirectorySegments.Length != 3)
continue;
if (!long.TryParse(inProcessDirectorySegments[1], out long ticks))
continue;
if (ticks > _Logistics.Sequence)
continue;
if (Directory.GetDirectories(inProcessDirectory).Any())
continue;
if (Directory.GetFiles(inProcessDirectory).Any())
continue;
Directory.Delete(inProcessDirectory);
}
} }
} }
return results; return results;

2
Adaptation/FileHandlers/jpeg/FileRead.cs
View File

@ -186,7 +186,7 @@ public class FileRead : Shared.FileRead, IFileRead
double deviation = standardDeviation * 3; double deviation = standardDeviation * 3;
double upper = average + deviation; double upper = average + deviation;
double lower = average - deviation; double lower = average - deviation;
var dynamic = new { _Logistics.DateTimeFromSequence.Ticks, average, sum, standardDeviation, upper, lower, processData.TotalDelta, processData.Text, _PreviousTotalDeltaCollection.Count }; var dynamic = new { _Logistics.Sequence, average, sum, standardDeviation, upper, lower, processData.TotalDelta, processData.Text, _PreviousTotalDeltaCollection.Count };
string message = JsonSerializer.Serialize(dynamic, new JsonSerializerOptions { WriteIndented = true }); string message = JsonSerializer.Serialize(dynamic, new JsonSerializerOptions { WriteIndented = true });
_Log.Debug(message); _Log.Debug(message);
if (processData.TotalDelta > upper || processData.TotalDelta < lower) if (processData.TotalDelta > upper || processData.TotalDelta < lower)