Merge pull request #21 from CCC-MF/issue_20

Anpassung des ConsentManagements an verschiedene Standorte

1 files changed, 121 insertions, 0 deletions

diff --git a/src/main/java/DNPM/services/consent/MrConsentManagerService.java b/src/main/java/DNPM/services/consent/MrConsentManagerService.java
new file mode 100644
index 0000000..bf054b4
--- /dev/null
+++ b/src/main/java/DNPM/services/consent/MrConsentManagerService.java
@@ -0,0 +1,121 @@
+package DNPM.services.consent;
+
+import DNPM.VerweisVon;
+import de.itc.onkostar.api.IOnkostarApi;
+import de.itc.onkostar.api.Item;
+import de.itc.onkostar.api.Procedure;
+import org.hibernate.SQLQuery;
+import org.hibernate.Session;
+import org.hibernate.SessionFactory;
+import org.hibernate.transform.Transformers;
+import org.hibernate.type.StandardBasicTypes;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * Detailimplementierung für das Formular `MR.Consent`
+ *
+ * @since 0.2.0
+ */
+public class MrConsentManagerService implements ConsentManagerService {
+
+    private Logger logger = LoggerFactory.getLogger(this.getClass());
+
+    private final IOnkostarApi onkostarApi;
+
+    public MrConsentManagerService(final IOnkostarApi onkostarApi) {
+        this.onkostarApi = onkostarApi;
+    }
+
+    /**
+     * Wende Consent an, wenn dieses Consent-Formular gespeichert wird
+     *
+     * @param procedure Prozedur des Consent-Formulars
+     */
+    @Override
+    public void applyConsent(Procedure procedure) {
+        int value = 0;
+        try {
+            SessionFactory sessionFactory = onkostarApi.getSessionFactory();
+            Session session = sessionFactory.getCurrentSession();
+            // geänderte Werte checken
+            String sql1 = "select id, max(timestamp) AS datum from aenderungsprotokoll where entity_id = '" + procedure.getId() + "'";
+            SQLQuery query1 = session.createSQLQuery(sql1)
+                    .addScalar("id", StandardBasicTypes.INTEGER)
+                    .addScalar("datum", StandardBasicTypes.TIMESTAMP);
+            logger.info("Wert-Check: {}", query1.uniqueResult());
+
+            String sql = "SELECT prozedur.id AS procedure_id, prozedur.data_form_id, data_catalogue.name AS data_catalogue, data_catalogue_entry.name AS data_catalogue_entry, data_form.description AS formname, prozedur.beginndatum AS datum " +
+                    "FROM prozedur " +
+                    "LEFT JOIN data_form_data_catalogue ON data_form_data_catalogue.data_form_id = prozedur.data_form_id " +
+                    "LEFT JOIN data_catalogue_entry ON data_catalogue_entry.data_catalogue_id = data_form_data_catalogue.data_catalogue_id " +
+                    "LEFT JOIN data_catalogue ON data_catalogue.id = data_catalogue_entry.data_catalogue_id " +
+                    "LEFT JOIN data_form ON data_form.id = prozedur.data_form_id " +
+                    "WHERE patient_id = " + procedure.getPatientId() + " " +
+                    "AND geloescht = 0 " +
+                    "AND data_catalogue_entry.type = 'formReference' " +
+                    "GROUP BY prozedur.id, prozedur.data_form_id, data_catalogue.name, data_catalogue_entry.name";
+
+            SQLQuery query = session.createSQLQuery(sql)
+                    .addScalar("procedure_id", StandardBasicTypes.INTEGER)
+                    .addScalar("data_form_id", StandardBasicTypes.INTEGER)
+                    .addScalar("data_catalogue", StandardBasicTypes.STRING)
+                    .addScalar("data_catalogue_entry", StandardBasicTypes.STRING)
+                    .addScalar("formname", StandardBasicTypes.STRING)
+                    .addScalar("datum", StandardBasicTypes.DATE);
+
+            query.setResultTransformer(Transformers.aliasToBean(VerweisVon.class));
+
+            @SuppressWarnings("unchecked")
+            List<VerweisVon> result = query.list();
+
+            for (VerweisVon verweisVon : result) {
+                sql = verweisVon.getSQL();
+                query = session.createSQLQuery(sql)
+                        .addScalar("value", StandardBasicTypes.INTEGER);
+                if (query.uniqueResult() != null) {
+                    value = (Integer) query.uniqueResult();
+                }
+                if (value == procedure.getId()) {
+                    saveReferencedProcedure(procedure, verweisVon);
+                    value = 0;
+                }
+            }
+        } catch (RuntimeException e) {
+            logger.error("Sonstiger Fehler bei der Ausführung von analyze()", e);
+        }
+    }
+
+    private void saveReferencedProcedure(Procedure prozedur, VerweisVon verweisVon) {
+        Procedure andereprozedur = onkostarApi.getProcedure(verweisVon.getProcedure_id());
+        try {
+            Map<String, Item> felder = prozedur.getAllValues();
+            for (Map.Entry<String, Item> feld : felder.entrySet()) {
+                if (feld.getKey().startsWith("Consent")) {
+                    if (feld.getKey().equals("ConsentStatusEinwilligungDNPM")) {
+                        switch (feld.getValue().getValue().toString()) {
+                            case "z":
+                                andereprozedur.setValue(feld.getKey(), new Item(feld.getKey(), "active"));
+                                break;
+                            case "a":
+                            case "w":
+                                andereprozedur.setValue(feld.getKey(), new Item(feld.getKey(), "rejected"));
+                                break;
+                            default:
+                                break;
+                        }
+                    } else {
+                        andereprozedur.setValue(feld.getKey(), prozedur.getValue(feld.getKey()));
+                    }
+                }
+            }
+            onkostarApi.saveProcedure(andereprozedur);
+        } catch (Exception e) {
+            logger.error("Kann Prozedur nicht speichern", e);
+        }
+    }
+
+}