Issue #54: Verwende ECOG nach Update von Strahlen- und Systemtherapieformular

1 files changed, 0 insertions, 156 deletions

diff --git a/src/main/java/DNPM/analyzer/SystemtherapieAnalyzer.java b/src/main/java/DNPM/analyzer/SystemtherapieAnalyzer.java
deleted file mode 100644
index e8936cf..0000000
--- a/src/main/java/DNPM/analyzer/SystemtherapieAnalyzer.java
+++ /dev/null
@@ -1,156 +0,0 @@
-package DNPM.analyzer;
-
-import DNPM.dto.EcogStatusWithDate;
-import DNPM.services.systemtherapie.SystemtherapieService;
-import de.itc.onkostar.api.Disease;
-import de.itc.onkostar.api.IOnkostarApi;
-import de.itc.onkostar.api.Item;
-import de.itc.onkostar.api.Procedure;
-import de.itc.onkostar.api.analysis.AnalyseTriggerEvent;
-import de.itc.onkostar.api.analysis.AnalyzerRequirement;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.springframework.stereotype.Component;
-
-import java.text.SimpleDateFormat;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-import java.util.stream.Collectors;
-
-/**
- * Diese Klasse implementiert ein Plugin, welches Aktionen nach Bearbeitung eines Formulars zur Systemtherapie durchführt.
- *
- * @since 0.4.0
- */
-@Component
-public class SystemtherapieAnalyzer extends Analyzer {
-
-    private final Logger logger = LoggerFactory.getLogger(this.getClass());
-
-    private final IOnkostarApi onkostarApi;
-
-    private final SystemtherapieService systemtherapieService;
-
-    public SystemtherapieAnalyzer(
-            final IOnkostarApi onkostarApi,
-            final SystemtherapieService systemtherapieService
-    ) {
-        this.onkostarApi = onkostarApi;
-        this.systemtherapieService = systemtherapieService;
-    }
-
-    @Override
-    public String getDescription() {
-        return "Aktualisiert verknüpfte Formulare nach Änderungen im Formularen vom Typ Systemtherapie";
-    }
-
-    /**
-     * @deprecated
-     */
-    @Override
-    public boolean isRelevantForDeletedProcedure() {
-        return true;
-    }
-
-    @Override
-    public boolean isRelevantForAnalyzer(Procedure procedure, Disease disease) {
-        return null != procedure && null != disease && (
-                procedure.getFormName().equals("OS.Systemische Therapie")
-                        || procedure.getFormName().equals("OS.Systemische Therapie.VarianteUKW")
-        );
-    }
-
-    @Override
-    public boolean isSynchronous() {
-        return false;
-    }
-
-    @Override
-    public AnalyzerRequirement getRequirement() {
-        return AnalyzerRequirement.PROCEDURE;
-    }
-
-    @Override
-    public Set<AnalyseTriggerEvent> getTriggerEvents() {
-        return Set.of(
-                AnalyseTriggerEvent.EDIT_SAVE,
-                AnalyseTriggerEvent.EDIT_LOCK,
-                AnalyseTriggerEvent.REORG
-        );
-    }
-
-    @Override
-    public void analyze(Procedure procedure, Disease disease) {
-        var date = procedure.getStartDate();
-        var status = procedure.getValue("ECOGvorTherapie");
-
-        if (null == date || null == status) {
-            // Ignore
-            return;
-        }
-
-        var ecogFromCompleted = systemtherapieService.ecogStatus(procedure.getPatient())
-                .stream()
-                .filter(ecogStatusWithDate -> ecogStatusWithDate.getDate().after(disease.getDiagnosisDate()))
-                .collect(Collectors.toList());
-
-        if (ecogFromCompleted.isEmpty()) {
-            // Nothing to do
-            return;
-        }
-
-        procedure.getPatient().getDiseases().stream()
-                .flatMap(d -> onkostarApi.getProceduresForDiseaseByForm(d.getId(), "DNPM Klinik/Anamnese").stream())
-                .forEach(p -> {
-                    var ufEcog = p.getValue("ECOGVerlauf");
-                    if (null != ufEcog && ufEcog.getValue() instanceof List) {
-                        updateExistingEcogVerlauf(p, ecogFromCompleted, ufEcog);
-                    } else {
-                        newEcogverlauf(p, ecogFromCompleted);
-                    }
-                });
-    }
-
-    private void updateExistingEcogVerlauf(Procedure p, List<EcogStatusWithDate> ecogFromCompleted, Item ufEcog) {
-        var shouldSave = false;
-        var existingDates = ufEcog.<List<Map<String, String>>>getValue().stream()
-                .map(v -> v.get("Datum"))
-                .collect(Collectors.toList());
-        for (var ecog : ecogFromCompleted) {
-            var formattedDate = new SimpleDateFormat("yyyy-MM-dd").format(ecog.getDate());
-            if (!existingDates.contains(formattedDate)) {
-                var newSubProcedure = new Procedure(onkostarApi);
-                newSubProcedure.setStartDate(ecog.getDate());
-                newSubProcedure.setValue("Datum", new Item("Datum", ecog.getDate()));
-                newSubProcedure.setValue("ECOG", new Item("ECOG", ecog.getStatus()));
-                p.addSubProcedure("ECOGVerlauf", newSubProcedure);
-                shouldSave = true;
-            }
-        }
-        if (shouldSave) {
-            try {
-                onkostarApi.saveProcedure(p, true);
-            } catch (Exception e) {
-                logger.error("Cannot update ECOG for procedure '{}'", p.getId());
-            }
-        }
-    }
-
-    private void newEcogverlauf(Procedure p, List<EcogStatusWithDate> ecogFromCompleted) {
-        p.setValue("ECOGVerlauf", new Item("ECOGVerlauf", List.of()));
-        for (var ecog : ecogFromCompleted) {
-            var newSubProcedure = new Procedure(onkostarApi);
-            newSubProcedure.setStartDate(ecog.getDate());
-            newSubProcedure.setValue("Datum", new Item("Datum", ecog.getDate()));
-            newSubProcedure.setValue("ECOG", new Item("ECOG", ecog.getStatus()));
-            p.addSubProcedure("ECOGVerlauf", newSubProcedure);
-        }
-        try {
-            onkostarApi.saveProcedure(p, true);
-        } catch (Exception e) {
-            logger.error("Create update ECOG for procedure '{}'", p.getId());
-        }
-    }
-
-}