summaryrefslogtreecommitdiff
path: root/src/main/java/ATCCodes/services/CsvAtcCodeService.java
diff options
context:
space:
mode:
authorPaul-Christian Volkmer2023-03-10 09:24:12 +0100
committerPaul-Christian Volkmer2023-03-10 09:28:52 +0100
commit4b121482f1a8323ea23858e8118934be5d9aa54c (patch)
treeaee5e630082ae7a1f81fccdc0ebdaeefc950689c /src/main/java/ATCCodes/services/CsvAtcCodeService.java
parent9d66c42460dda63a6380ba0f30004fcd92a4f5c4 (diff)
Issue #5: Vorschlag für den Aufbau des Projekts
* Maven-Projekt direkt im Hauptverzeichnis * Anpassung der Maven-POM-Datei - nicht benötigte Abhängigkeiten entfernt * Gitignore-Datei angelegt
Diffstat (limited to 'src/main/java/ATCCodes/services/CsvAtcCodeService.java')
-rw-r--r--src/main/java/ATCCodes/services/CsvAtcCodeService.java51
1 files changed, 51 insertions, 0 deletions
diff --git a/src/main/java/ATCCodes/services/CsvAtcCodeService.java b/src/main/java/ATCCodes/services/CsvAtcCodeService.java
new file mode 100644
index 0000000..fa834e7
--- /dev/null
+++ b/src/main/java/ATCCodes/services/CsvAtcCodeService.java
@@ -0,0 +1,51 @@
+package ATCCodes.services;
+
+import ATCCodes.AgentCode;
+import ATCCodes.AtcCode;
+import ATCCodes.FileParsingException;
+import org.apache.commons.csv.CSVFormat;
+import org.springframework.core.io.ResourceLoader;
+import org.springframework.stereotype.Service;
+
+import java.io.IOException;
+import java.io.InputStreamReader;
+import java.util.ArrayList;
+import java.util.List;
+
+/**
+ * Service to query for agent codes based on WHO xml file
+ *
+ * @author Paul-Christian Volkmer
+ * @since 0.1.0
+ */
+@Service
+public class CsvAtcCodeService extends FileBasedAgentCodeService {
+
+ public CsvAtcCodeService(final ResourceLoader resourceLoader) {
+ super(resourceLoader);
+ }
+
+ protected List<AgentCode> parseFile(final ResourceLoader resourceLoader) {
+ var result = new ArrayList<AgentCode>();
+ var filename = getFilePath("atc.csv");
+ try {
+ var inputStream = resourceLoader.getResource(filename).getInputStream();
+ var parser = CSVFormat.RFC4180
+ .withHeader()
+ .withSkipHeaderRecord()
+ .parse(new InputStreamReader(inputStream));
+ for (var row : parser) {
+ if (!row.isMapped("CODE") || !row.isMapped("NAME")) {
+ throw new FileParsingException("No CSV column 'CODE' or 'NAME' found");
+ }
+ result.add(new AtcCode(row.get("CODE"), row.get("NAME")));
+ }
+ logger.info("Found CSV file for ATC-Codes.");
+ return result;
+ } catch (IOException | FileParsingException e) {
+ logger.warn("Error reading CSV file '{}' for ATC-Codes. Proceeding without data", filename);
+ }
+ return result;
+ }
+
+} \ No newline at end of file