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

v2.47.1 - ISQ query in OI file name

Browse Source
This commit is contained in:
Mike Phares
2022-12-06 08:13:33 -07:00
parent 4875b31723
commit b2fd2a7600
7 changed files with 79 additions and 50 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
Adaptation/FileHandlers/OpenInsight/FileRead.cs
View File

@ -112,7 +112,7 @@ public class FileRead : Shared.FileRead, IFileRead
internal static string GetLines(Logistics logistics, List<txt.Description> descriptions)
{
StringBuilder result = new();
StringBuilder result = new("-");
if (logistics is null)
{ }
if (descriptions is null)
@ -136,11 +136,15 @@ public class FileRead : Shared.FileRead, IFileRead
{
string lines = GetLines(_Logistics, descriptions);
if (!string.IsNullOrEmpty(lines))
collection.Add(new(new ScopeInfo(tests[0], _OpenInsightFilePattern), lines));
_ = FromIQS.GetCommandText(_IqsConnectionString, _Logistics, descriptions[0]);
// string commandText = FromIQS.GetCommandText(_IqsConnectionString, _Logistics, descriptions[0]);
// if (!string.IsNullOrEmpty(commandText))
// collection.Add(new(new ScopeInfo(tests[0], _OpenInsightFilePattern), commandText));
{
long breakAfter = dateTime.AddSeconds(_BreakAfterSeconds).Ticks;
long preWait = _FileConnectorConfiguration?.FileHandleWaitTime is null ? dateTime.AddMilliseconds(1234).Ticks : dateTime.AddMilliseconds(_FileConnectorConfiguration.FileHandleWaitTime.Value).Ticks;
(long? subGroupId, string _) = FromIQS.GetCommandText(_BreakAfterSeconds, _IqsConnectionString, _Logistics, descriptions[0], breakAfter, preWait);
if (subGroupId is null)
collection.Add(new(new ScopeInfo(tests[0], _OpenInsightFilePattern), lines));
else
collection.Add(new(new ScopeInfo(tests[0], $"{subGroupId.Value}_{_OpenInsightFilePattern}"), lines));
}
}
if (_IsEAFHosted && _FileConnectorConfiguration.FileScanningIntervalInSeconds > 0)
WaitForFileConsumption(dateTime, descriptions, isDummyRun, successDirectory, duplicateDirectory, collection, duplicateFile);