write to csv

SMI · Jan 30, 2025 · e2c505b · e2c505b
1 parent 727865a
commit e2c505b
Showing 1 changed file with 8 additions and 12 deletions.
diff --git a/Rdmp.Dicom/Extraction/DicomTagToCSV.cs b/Rdmp.Dicom/Extraction/DicomTagToCSV.cs
@@ -11,6 +11,7 @@
 using Rdmp.Dicom.Extraction.FoDicomBased;
 using Rdmp.Dicom.Extraction.FoDicomBased.DirectoryDecisions;
 using System;
+using System.Collections;
 using System.Collections.Generic;
 using System.Data;
 using System.IO;
@@ -66,24 +67,26 @@ public DataTable ProcessPipelineData(DataTable toProcess, IDataLoadEventListener
             var fileRows = new Dictionary<string, DataRow>();
             var releaseIDs = new Dictionary<string, string>();
             var dicomFiles = new List<(string, string)>();
+
+            _putter ??= (IPutDicomFilesInExtractionDirectories)ObjectConstructor.Construct(PutterType);
+
             foreach (DataRow processRow in toProcess.Rows)
             {
                 var file = (string)processRow[RelativeArchiveColumnName];
                 fileRows.Add(file, processRow);
                 dicomFiles.Add((file, file));
             }
-            _putter ??= (IPutDicomFilesInExtractionDirectories)ObjectConstructor.Construct(PutterType);
+
 
             var dicomFilePaths = new AmbiguousFilePath(ArchiveRootIfAny, dicomFiles).GetDataset(FileFetchRetryLimit, FileFetchRetryTimeout, listener);
+
             foreach (var dcm in dicomFilePaths)
             {
-                var filepath = Path.Combine("C:\\temp\\csvtest", "output.csv");
+                _destinationDirectory.Create();
+                var filepath = Path.GetFullPath(_destinationDirectory.FullName, "dicomTags.csv");
 
                 var sw = new StreamWriter(filepath);
                 using var w = new CsvWriter(sw, System.Globalization.CultureInfo.InvariantCulture);
-                //w.WriteRecords(
-                //dcm.Item2.Dataset.SelectMany(t => Entry.ProcessTag(dcm.Item1, t))
-                //);
                 w.WriteRecords(
                 DicomFile.Open(dcm.Item1, FileReadOption.ReadAll).Dataset.SelectMany(t => Entry.ProcessTag(dcm.Item1, t))
                     );
@@ -94,14 +97,7 @@ public DataTable ProcessPipelineData(DataTable toProcess, IDataLoadEventListener
 
         public void Initialize(int projectNumber, DirectoryInfo destinationDirectory, IMappingRepository uidSubstitutionLookup = null)
         {
-            //_projectNumber = projectNumber;
-
-            //_uidSubstitutionLookup = uidSubstitutionLookup ?? (UIDMappingServer == null ? null : new MappingRepository(UIDMappingServer));
             _destinationDirectory = destinationDirectory;
-
-            //_deleteTags = GetDeleteTags().ToArray();
-
-            //initialized = true;
         }
 
         internal class Entry