Merge pull request #12 from CCC-MF/issue_11

Übernahme des MTB-Protokolls in DNPM-Therapieplan - Protokollauszug

15 files changed, 445 insertions, 9 deletions

diff --git a/src/main/java/DNPM/analyzer/TherapieplanAnalyzer.java b/src/main/java/DNPM/analyzer/TherapieplanAnalyzer.java
index cf3b633..bdda750 100644
--- a/src/main/java/DNPM/analyzer/TherapieplanAnalyzer.java
+++ b/src/main/java/DNPM/analyzer/TherapieplanAnalyzer.java
@@ -3,6 +3,7 @@ package DNPM.analyzer;
 import DNPM.services.Studie;
 import DNPM.services.StudienService;
 import DNPM.services.TherapieplanServiceFactory;
+import DNPM.services.mtb.MtbService;
 import de.itc.onkostar.api.Disease;
 import de.itc.onkostar.api.Procedure;
 import de.itc.onkostar.api.analysis.AnalyseTriggerEvent;
@@ -27,12 +28,16 @@ public class TherapieplanAnalyzer implements IProcedureAnalyzer {
 
     private final TherapieplanServiceFactory therapieplanServiceFactory;
 
+    private final MtbService mtbService;
+
     public TherapieplanAnalyzer(
             final StudienService studienService,
-            final TherapieplanServiceFactory therapieplanServiceFactory
+            final TherapieplanServiceFactory therapieplanServiceFactory,
+            final MtbService mtbService
     ) {
         this.studienService = studienService;
         this.therapieplanServiceFactory = therapieplanServiceFactory;
+        this.mtbService = mtbService;
     }
 
     @Override
@@ -110,6 +115,7 @@ public class TherapieplanAnalyzer implements IProcedureAnalyzer {
      * </pre>
      *
      * @param input Map mit Eingabewerten
+     * @return Liste mit Studien
      */
     public List<Studie> getStudien(Map<String, Object> input) {
         var query = input.get("q");
@@ -120,4 +126,38 @@ public class TherapieplanAnalyzer implements IProcedureAnalyzer {
         return studienService.findByQuery(query.toString());
     }
 
+    /**
+     * Übergibt den Text der referenzierten MTBs für den Protokollauszug
+     *
+     * <p>Wurde der Eingabewert <code>id</code> nicht übergeben, wird ein leerer String zurück gegeben.
+     *
+     * <p>Beispiel zur Nutzung in einem Formularscript
+     * <pre>
+     * executePluginMethod(
+     *   'TherapieplanAnalyzer',
+     *   'getProtokollauszug',
+     *   { id: 12345 },
+     *   (response) => console.log(response),
+     *   false
+     * );
+     * </pre>
+     *
+     * @param input Map mit Eingabewerten
+     * @return Zeichenkette mit Protokollauszug
+     */
+    public String getProtokollauszug(Map<String, Object> input) {
+        var id = input.get("id");
+
+        if (null == id || 0 == Integer.parseInt(id.toString())) {
+            return "";
+        }
+
+        var procedureId = Integer.parseInt(id.toString());
+        return mtbService.getProtocol(
+                therapieplanServiceFactory
+                        .currentUsableInstance()
+                        .findReferencedMtbs(procedureId)
+        );
+    }
+
 }
diff --git a/src/main/java/DNPM/config/PluginConfiguration.java b/src/main/java/DNPM/config/PluginConfiguration.java
index 36b1875..3f27034 100644
--- a/src/main/java/DNPM/config/PluginConfiguration.java
+++ b/src/main/java/DNPM/config/PluginConfiguration.java
@@ -1,10 +1,14 @@
 package DNPM.config;
 
+import DNPM.database.SettingsRepository;
 import DNPM.services.*;
+import DNPM.services.mtb.DefaultMtbService;
+import DNPM.services.mtb.MtbService;
 import de.itc.onkostar.api.IOnkostarApi;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.ComponentScan;
 import org.springframework.context.annotation.Configuration;
+import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
 
 import javax.sql.DataSource;
 
@@ -15,6 +19,7 @@ import javax.sql.DataSource;
  */
 @Configuration
 @ComponentScan(basePackages = "DNPM.analyzer")
+@EnableJpaRepositories(basePackages = "DNPM.database")
 public class PluginConfiguration {
 
     @Bean
@@ -28,8 +33,22 @@ public class PluginConfiguration {
     }
 
     @Bean
-    public TherapieplanServiceFactory therapieplanServiceFactory(final IOnkostarApi onkostarApi, final FormService formService) {
-        return new TherapieplanServiceFactory(onkostarApi, formService);
+    public SettingsService settingsService(final SettingsRepository settingsRepository) {
+        return new SettingsService(settingsRepository);
+    }
+
+    @Bean
+    public MtbService mtbService(final SettingsService settingsService) {
+        return new DefaultMtbService(settingsService);
+    }
+
+    @Bean
+    public TherapieplanServiceFactory therapieplanServiceFactory(
+            final IOnkostarApi onkostarApi,
+            final SettingsService settingsService,
+            final FormService formService
+    ) {
+        return new TherapieplanServiceFactory(onkostarApi, settingsService, formService);
     }
 
 }
diff --git a/src/main/java/DNPM/database/ReadOnlyRepository.java b/src/main/java/DNPM/database/ReadOnlyRepository.java
new file mode 100644
index 0000000..775388d
--- /dev/null
+++ b/src/main/java/DNPM/database/ReadOnlyRepository.java
@@ -0,0 +1,20 @@
+package DNPM.database;
+
+import org.springframework.data.repository.NoRepositoryBean;
+import org.springframework.data.repository.Repository;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * Basis-Repository for ReadOnly Spring-Data-JPA Repositories
+ * <p>Entity-Klassen müssen in Package <code>de.itc.db.dnpm</code> liegen
+ * @param <T> Typ des Entities
+ * @param <ID> Typ der ID
+ */
+@NoRepositoryBean
+public interface ReadOnlyRepository<T, ID extends Serializable> extends Repository<T, ID> {
+
+    List<T> findAll();
+
+}
diff --git a/src/main/java/DNPM/database/SettingsRepository.java b/src/main/java/DNPM/database/SettingsRepository.java
new file mode 100644
index 0000000..9a6e331
--- /dev/null
+++ b/src/main/java/DNPM/database/SettingsRepository.java
@@ -0,0 +1,14 @@
+package DNPM.database;
+
+import de.itc.db.dnpm.Setting;
+import org.springframework.stereotype.Repository;
+
+/**
+ * Spring Data JPA Repository zum Lesen von Einstellungen
+ */
+@Repository("dnpmSettingRepository")
+public interface SettingsRepository extends ReadOnlyRepository<Setting, Long> {
+
+    Setting findByName(String name);
+
+}
diff --git a/src/main/java/DNPM/services/DefaultTherapieplanService.java b/src/main/java/DNPM/services/DefaultTherapieplanService.java
index f705ce8..eee2041 100644
--- a/src/main/java/DNPM/services/DefaultTherapieplanService.java
+++ b/src/main/java/DNPM/services/DefaultTherapieplanService.java
@@ -6,6 +6,7 @@ import de.itc.onkostar.api.Procedure;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.util.List;
 import java.util.Objects;
 
 import static DNPM.services.FormService.hasValue;
@@ -36,6 +37,40 @@ public class DefaultTherapieplanService implements TherapieplanService {
         this.updateMtbInSubforms(procedure);
     }
 
+    /**
+     * Finde verlinkte MTBs in Hauptformular und Unterformularen
+     *
+     * @param procedure Die Prozedur mit Hauptformular
+     * @return Liste mit verlinkten MTBs
+     */
+    @Override
+    public List<Procedure> findReferencedMtbs(Procedure procedure) {
+        if (!hasValue(procedure, "referstemtb")) {
+            return List.of();
+        }
+
+        var mtbProcedure = this.onkostarApi.getProcedure(procedure.getValue("referstemtb").getInt());
+        if (null == mtbProcedure) {
+            return List.of();
+        }
+        return List.of(mtbProcedure);
+    }
+
+    /**
+     * Finde verlinkte MTBs in Hauptformular und Unterformularen
+     *
+     * @param procedureId ID der Prozedur mit Hauptformular
+     * @return Liste mit verlinkten MTBs
+     */
+    @Override
+    public List<Procedure> findReferencedMtbs(int procedureId) {
+        var procedure = this.onkostarApi.getProcedure(procedureId);
+        if (null == procedure) {
+            return List.of();
+        }
+        return findReferencedMtbs(procedure);
+    }
+
     private void updateMtbInSections(Procedure procedure) {
         if (!isYes(procedure, "humangenberatung") && !isYes(procedure, "reevaluation")) {
             return;
diff --git a/src/main/java/DNPM/services/MultipleMtbTherapieplanService.java b/src/main/java/DNPM/services/MultipleMtbTherapieplanService.java
index d4eb297..faded4b 100644
--- a/src/main/java/DNPM/services/MultipleMtbTherapieplanService.java
+++ b/src/main/java/DNPM/services/MultipleMtbTherapieplanService.java
@@ -1,12 +1,75 @@
 package DNPM.services;
 
+import de.itc.onkostar.api.IOnkostarApi;
 import de.itc.onkostar.api.Procedure;
 
+import java.util.ArrayList;
+import java.util.Comparator;
+import java.util.List;
+import java.util.Objects;
+import java.util.stream.Collectors;
+
+import static DNPM.services.FormService.hasValue;
+import static DNPM.services.FormService.isYes;
+
 public class MultipleMtbTherapieplanService implements TherapieplanService {
 
+    private final IOnkostarApi onkostarApi;
+
+    private final FormService formService;
+
+    public MultipleMtbTherapieplanService(final IOnkostarApi onkostarApi, final FormService formService) {
+        this.onkostarApi = onkostarApi;
+        this.formService = formService;
+    }
+
     @Override
     public void updateRequiredMtbEntries(Procedure procedure) {
         // No action required
     }
 
+    @Override
+    public List<Procedure> findReferencedMtbs(Procedure procedure) {
+        var procedureIds = new ArrayList<Integer>();
+
+        var mtbReference = procedure.getValue("referstemtb").getInt();
+        procedureIds.add(mtbReference);
+
+        if (isYes(procedure, "humangenberatung") && hasValue(procedure, "reftkhumangenber")) {
+            procedureIds.add(procedure.getValue("reftkhumangenber").getInt());
+        }
+
+        if (isYes(procedure, "reevaluation") && hasValue(procedure, "reftkreevaluation")) {
+            procedureIds.add(procedure.getValue("reftkreevaluation").getInt());
+        }
+
+        formService.getSubFormProcedureIds(procedure.getId()).stream()
+                .map(onkostarApi::getProcedure)
+                .filter(Objects::nonNull)
+                .forEach(subform -> {
+                    if (subform.getFormName().equals("DNPM UF Einzelempfehlung")) {
+                        procedureIds.add(subform.getValue("mtb").getInt());
+                    }
+
+                    if (subform.getFormName().equals("DNPM UF Rebiopsie")) {
+                        procedureIds.add(subform.getValue("reftumorkonferenz").getInt());
+                    }
+                });
+
+        return procedureIds.stream()
+                .distinct()
+                .map(onkostarApi::getProcedure)
+                .filter(Objects::nonNull)
+                .sorted(Comparator.comparing(Procedure::getStartDate))
+                .collect(Collectors.toList());
+    }
+
+    @Override
+    public List<Procedure> findReferencedMtbs(int procedureId) {
+        var procedure = this.onkostarApi.getProcedure(procedureId);
+        if (null == procedure) {
+            return List.of();
+        }
+        return findReferencedMtbs(procedure);
+    }
 }
diff --git a/src/main/java/DNPM/services/SettingsService.java b/src/main/java/DNPM/services/SettingsService.java
new file mode 100644
index 0000000..7459d4e
--- /dev/null
+++ b/src/main/java/DNPM/services/SettingsService.java
@@ -0,0 +1,47 @@
+package DNPM.services;
+
+import DNPM.database.SettingsRepository;
+
+import java.util.Optional;
+
+/**
+ * Implementiert den Dienst zur Ermittlung von Systemeinstellungen
+ */
+public class SettingsService {
+
+    private final SettingsRepository settingsRepository;
+
+    public SettingsService(final SettingsRepository settingsRepository) {
+        this.settingsRepository = settingsRepository;
+    }
+
+    /**
+     * Übergibt ein <code>Optional</code> für die Einstellung mit angegebenen Namen
+     * @param name Name der Einstellung
+     * @return Optional mit Wert der Einstellung oder ein leeres Optional, wenn Einstellung nicht gefunden
+     */
+    public Optional<String> getSetting(String name) {
+        var sid = settingsRepository.findByName(name);
+        if (null == sid) {
+            return Optional.empty();
+        }
+        return Optional.of(sid.getValue());
+    }
+
+    /**
+     * Übergibt die SID als <code>Optional</code>
+     * @return Optional mit Wert der SID
+     */
+    public Optional<String> getSID() {
+        return getSetting("SID");
+    }
+
+    /**
+     * Übergibt die Einstellung für <code>mehrere_mtb_in_mtbepisode</code>
+     * @return Übergibt <code>true</code>, wenn <code>mehrere_mtb_in_mtbepisode</code> auf "Ja" gesetzt ist.
+     */
+    public boolean multipleMtbsInMtbEpisode() {
+        var setting = getSetting("mehrere_mtb_in_mtbepisode");
+        return setting.isPresent() && setting.get().equals("true");
+    }
+}
diff --git a/src/main/java/DNPM/services/TherapieplanService.java b/src/main/java/DNPM/services/TherapieplanService.java
index e47d75e..7a725fc 100644
--- a/src/main/java/DNPM/services/TherapieplanService.java
+++ b/src/main/java/DNPM/services/TherapieplanService.java
@@ -2,6 +2,8 @@ package DNPM.services;
 
 import de.itc.onkostar.api.Procedure;
 
+import java.util.List;
+
 public interface TherapieplanService {
 
     /**
@@ -12,4 +14,20 @@ public interface TherapieplanService {
      */
     void updateRequiredMtbEntries(Procedure procedure);
 
+    /**
+     * Finde verlinkte MTBs in Hauptformular und Unterformularen
+     *
+     * @param procedure Die Prozedur mit Hauptformular
+     * @return Liste mit verlinkten MTBs
+     */
+    List<Procedure> findReferencedMtbs(Procedure procedure);
+
+    /**
+     * Finde verlinkte MTBs in Hauptformular und Unterformularen
+     *
+     * @param procedureId ID der Prozedur mit Hauptformular
+     * @return Liste mit verlinkten MTBs
+     */
+    List<Procedure> findReferencedMtbs(int procedureId);
+
 }
diff --git a/src/main/java/DNPM/services/TherapieplanServiceFactory.java b/src/main/java/DNPM/services/TherapieplanServiceFactory.java
index 5b3b54c..3e05fb4 100644
--- a/src/main/java/DNPM/services/TherapieplanServiceFactory.java
+++ b/src/main/java/DNPM/services/TherapieplanServiceFactory.java
@@ -6,19 +6,23 @@ public class TherapieplanServiceFactory {
 
     private final IOnkostarApi onkostarApi;
 
+    private final SettingsService settingsService;
+
     private final FormService formService;
 
-    public TherapieplanServiceFactory(IOnkostarApi onkostarApi, FormService formService) {
+    public TherapieplanServiceFactory(
+            final IOnkostarApi onkostarApi,
+            final SettingsService settingsService,
+            final FormService formService
+    ) {
         this.onkostarApi = onkostarApi;
+        this.settingsService = settingsService;
         this.formService = formService;
     }
 
     public TherapieplanService currentUsableInstance() {
-        if (
-                null != onkostarApi.getGlobalSetting("mehrere_mtb_in_mtbepisode")
-                        && onkostarApi.getGlobalSetting("mehrere_mtb_in_mtbepisode").equals("true")
-        ) {
-            return new MultipleMtbTherapieplanService();
+        if (settingsService.multipleMtbsInMtbEpisode()) {
+            return new MultipleMtbTherapieplanService(onkostarApi, formService);
         }
 
         return new DefaultTherapieplanService(onkostarApi, formService);
diff --git a/src/main/java/DNPM/services/mtb/DefaultMtbService.java b/src/main/java/DNPM/services/mtb/DefaultMtbService.java
new file mode 100644
index 0000000..40d9360
--- /dev/null
+++ b/src/main/java/DNPM/services/mtb/DefaultMtbService.java
@@ -0,0 +1,39 @@
+package DNPM.services.mtb;
+
+import DNPM.services.SettingsService;
+import de.itc.onkostar.api.Procedure;
+
+import java.util.List;
+
+public class DefaultMtbService implements MtbService {
+
+    private final SettingsService settingsService;
+
+    public DefaultMtbService(final SettingsService settingsService) {
+        this.settingsService = settingsService;
+    }
+
+    @Override
+    public String getProtocol(List<Procedure> procedures) {
+        ProcedureToProtocolMapper mapper = null;
+        var sid = settingsService.getSID();
+
+        if (sid.isPresent()) {
+            switch (sid.get()) {
+                case "20119":
+                    mapper = new OsTumorkonferenzVarianteUkwToProtocolMapper();
+                default:
+                    if (!settingsService.multipleMtbsInMtbEpisode()) {
+                        mapper = new OsTumorkonferenzToProtocolMapper();
+                    }
+            }
+        }
+
+        if (null == mapper) {
+            return "";
+        }
+
+        return mapper.apply(procedures).orElse("");
+    }
+
+}
diff --git a/src/main/java/DNPM/services/mtb/MtbService.java b/src/main/java/DNPM/services/mtb/MtbService.java
new file mode 100644
index 0000000..b854307
--- /dev/null
+++ b/src/main/java/DNPM/services/mtb/MtbService.java
@@ -0,0 +1,9 @@
+package DNPM.services.mtb;
+
+import de.itc.onkostar.api.Procedure;
+
+import java.util.List;
+
+public interface MtbService {
+    String getProtocol(List<Procedure> procedures);
+}
diff --git a/src/main/java/DNPM/services/mtb/OsTumorkonferenzToProtocolMapper.java b/src/main/java/DNPM/services/mtb/OsTumorkonferenzToProtocolMapper.java
new file mode 100644
index 0000000..6379ecf
--- /dev/null
+++ b/src/main/java/DNPM/services/mtb/OsTumorkonferenzToProtocolMapper.java
@@ -0,0 +1,33 @@
+package DNPM.services.mtb;
+
+import de.itc.onkostar.api.Procedure;
+
+import java.util.List;
+import java.util.Optional;
+
+public class OsTumorkonferenzToProtocolMapper implements ProcedureToProtocolMapper {
+    @Override
+    public Optional<String> apply(List<Procedure> procedures) {
+        assert(procedures.size() == 1);
+
+        var procedure = procedures.get(0);
+
+        assert(procedure.getFormName().equals("OS.Tumorkonferenz"));
+
+        var fragestellung = procedure.getValue("Fragestellung");
+        var empfehlung = procedure.getValue("Empfehlung");
+
+        if (
+                null != fragestellung && !fragestellung.getString().isBlank()
+                && null != empfehlung && !empfehlung.getString().isBlank()
+        ) {
+            return Optional.of(String.format("Fragestellung:\n%s\n\nEmpfehlung:\n%s", fragestellung.getString(), empfehlung.getString()));
+        } else if (null != fragestellung && !fragestellung.getString().isBlank()) {
+            return Optional.of(fragestellung.getString());
+        } else if (null != empfehlung && !empfehlung.getString().isBlank()) {
+            return Optional.of(empfehlung.getString());
+        }
+
+        return Optional.empty();
+    }
+}
diff --git a/src/main/java/DNPM/services/mtb/OsTumorkonferenzVarianteUkwToProtocolMapper.java b/src/main/java/DNPM/services/mtb/OsTumorkonferenzVarianteUkwToProtocolMapper.java
new file mode 100644
index 0000000..78a94eb
--- /dev/null
+++ b/src/main/java/DNPM/services/mtb/OsTumorkonferenzVarianteUkwToProtocolMapper.java
@@ -0,0 +1,42 @@
+package DNPM.services.mtb;
+
+import de.itc.onkostar.api.Procedure;
+
+import java.util.Comparator;
+import java.util.List;
+import java.util.Optional;
+import java.util.stream.Collectors;
+
+public class OsTumorkonferenzVarianteUkwToProtocolMapper implements ProcedureToProtocolMapper {
+    @Override
+    public Optional<String> apply(List<Procedure> procedures) {
+        procedures.forEach(procedure -> {
+            assert (procedure.getFormName().equals("OS.Tumorkonferenz.VarianteUKW"));
+        });
+
+        procedures.sort(Comparator.comparing(Procedure::getStartDate));
+
+        var result = procedures.stream().map(procedure -> {
+            var fragestellung = procedure.getValue("Fragestellung");
+            var empfehlung = procedure.getValue("Empfehlung");
+
+            if (
+                    null != fragestellung && !fragestellung.getString().isBlank()
+                            && null != empfehlung && !empfehlung.getString().isBlank()
+            ) {
+                return String.format("Fragestellung:\n%s\n\nEmpfehlung:\n%s", fragestellung.getString().trim(), empfehlung.getString().trim());
+            } else if (null != fragestellung && !fragestellung.getString().isBlank()) {
+                return fragestellung.getString().trim();
+            } else if (null != empfehlung && !empfehlung.getString().isBlank()) {
+                return empfehlung.getString().trim();
+            }
+            return "";
+        }).collect(Collectors.joining("\n\n"));
+
+        if (!result.isBlank()) {
+            return Optional.of(result);
+        }
+
+        return Optional.empty();
+    }
+}
diff --git a/src/main/java/DNPM/services/mtb/ProcedureToProtocolMapper.java b/src/main/java/DNPM/services/mtb/ProcedureToProtocolMapper.java
new file mode 100644
index 0000000..54c04d9
--- /dev/null
+++ b/src/main/java/DNPM/services/mtb/ProcedureToProtocolMapper.java
@@ -0,0 +1,10 @@
+package DNPM.services.mtb;
+
+import de.itc.onkostar.api.Procedure;
+
+import java.util.List;
+import java.util.Optional;
+import java.util.function.Function;
+
+@FunctionalInterface
+public interface ProcedureToProtocolMapper extends Function<List<Procedure>, Optional<String>> {}
diff --git a/src/main/java/de/itc/db/dnpm/Setting.java b/src/main/java/de/itc/db/dnpm/Setting.java
new file mode 100644
index 0000000..262d2c9
--- /dev/null
+++ b/src/main/java/de/itc/db/dnpm/Setting.java
@@ -0,0 +1,43 @@
+package de.itc.db.dnpm;
+
+import org.hibernate.annotations.Immutable;
+
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.Id;
+import javax.persistence.Table;
+
+@Entity
+@Immutable
+@Table(name = "einstellung")
+public class Setting {
+    @Id
+    private Long id;
+
+    private String name;
+
+    @Column(name = "wert")
+    private String value;
+
+    protected Setting() {
+        // No content
+    }
+
+    public Setting(Long id, String name, String value) {
+        this.id = id;
+        this.name = name;
+        this.value = value;
+    }
+
+    public Long getId() {
+        return id;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public String getValue() {
+        return value;
+    }
+}