From c7884587bbbef99cb50f92862449dcea099c4215 Mon Sep 17 00:00:00 2001 From: Mike Phares Date: Wed, 23 Mar 2022 11:52:29 -0700 Subject: [PATCH] inProcessDirectories --- Adaptation/FileHandlers/DEP08SIASM/FileRead.cs | 17 +++++++++++++++++ Adaptation/FileHandlers/jpeg/FileRead.cs | 2 +- 2 files changed, 18 insertions(+), 1 deletion(-) diff --git a/Adaptation/FileHandlers/DEP08SIASM/FileRead.cs b/Adaptation/FileHandlers/DEP08SIASM/FileRead.cs index 9a29ea4..f0f43bc 100644 --- a/Adaptation/FileHandlers/DEP08SIASM/FileRead.cs +++ b/Adaptation/FileHandlers/DEP08SIASM/FileRead.cs @@ -253,6 +253,23 @@ public class FileRead : Shared.FileRead, IFileRead if (json != historicalText) 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; diff --git a/Adaptation/FileHandlers/jpeg/FileRead.cs b/Adaptation/FileHandlers/jpeg/FileRead.cs index 44b21d7..57b5bac 100644 --- a/Adaptation/FileHandlers/jpeg/FileRead.cs +++ b/Adaptation/FileHandlers/jpeg/FileRead.cs @@ -186,7 +186,7 @@ public class FileRead : Shared.FileRead, IFileRead double deviation = standardDeviation * 3; double upper = 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 }); _Log.Debug(message); if (processData.TotalDelta > upper || processData.TotalDelta < lower)