mirror of
https://github.com/pcvolkmer/onkostar-plugin-dnpm.git
synced 2025-07-03 17:52:53 +00:00
Issue #20: Detailimplementierungen für Consent Management
This commit is contained in:
@ -1,31 +1,29 @@
|
||||
package DNPM;
|
||||
|
||||
import DNPM.services.consent.ConsentManagerServiceFactory;
|
||||
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.AnalyzerRequirement;
|
||||
import de.itc.onkostar.api.analysis.IProcedureAnalyzer;
|
||||
import de.itc.onkostar.api.analysis.OnkostarPluginType;
|
||||
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;
|
||||
|
||||
public class ConsentManager implements IProcedureAnalyzer {
|
||||
|
||||
private final Logger logger = LoggerFactory.getLogger(this.getClass());
|
||||
|
||||
private final IOnkostarApi onkostarApi;
|
||||
|
||||
public ConsentManager(final IOnkostarApi onkostarApi) {
|
||||
private final ConsentManagerServiceFactory consentManagerServiceFactory;
|
||||
|
||||
public ConsentManager(
|
||||
final IOnkostarApi onkostarApi,
|
||||
final ConsentManagerServiceFactory consentManagerServiceFactory
|
||||
) {
|
||||
this.onkostarApi = onkostarApi;
|
||||
this.consentManagerServiceFactory = consentManagerServiceFactory;
|
||||
}
|
||||
|
||||
@Override
|
||||
@ -71,85 +69,7 @@ public class ConsentManager implements IProcedureAnalyzer {
|
||||
|
||||
@Override
|
||||
public void analyze(Procedure prozedur, Disease erkrankung) {
|
||||
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 = '" + prozedur.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 = " + prozedur.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 == prozedur.getId()) {
|
||||
saveReferencedProcedure(prozedur, 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);
|
||||
}
|
||||
consentManagerServiceFactory.currentUsableInstance().applyConsent(prozedur);
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@ -2,6 +2,7 @@ package DNPM.config;
|
||||
|
||||
import DNPM.database.SettingsRepository;
|
||||
import DNPM.services.*;
|
||||
import DNPM.services.consent.ConsentManagerServiceFactory;
|
||||
import DNPM.services.mtb.DefaultMtbService;
|
||||
import DNPM.services.mtb.MtbService;
|
||||
import DNPM.services.systemtherapie.DefaultSystemtherapieService;
|
||||
@ -52,6 +53,11 @@ public class PluginConfiguration {
|
||||
return new DefaultSystemtherapieService(onkostarApi, settingsService);
|
||||
}
|
||||
|
||||
@Bean
|
||||
public ConsentManagerServiceFactory consentManagerServiceFactory(final IOnkostarApi onkostarApi) {
|
||||
return new ConsentManagerServiceFactory(onkostarApi);
|
||||
}
|
||||
|
||||
@Bean
|
||||
public TherapieplanServiceFactory therapieplanServiceFactory(
|
||||
final IOnkostarApi onkostarApi,
|
||||
|
||||
@ -0,0 +1,18 @@
|
||||
package DNPM.services.consent;
|
||||
|
||||
import de.itc.onkostar.api.Procedure;
|
||||
|
||||
/**
|
||||
* Schnittstelle für die Anwendung von Consent-Änderungen
|
||||
*
|
||||
* @since 0.2.0
|
||||
*/
|
||||
public interface ConsentManagerService {
|
||||
|
||||
/**
|
||||
* Wende Consent an, wenn dieses Consent-Formular gespeichert wird
|
||||
* @param procedure Prozedur des Consent-Formulars
|
||||
*/
|
||||
void applyConsent(Procedure procedure);
|
||||
|
||||
}
|
||||
@ -0,0 +1,25 @@
|
||||
package DNPM.services.consent;
|
||||
|
||||
import de.itc.onkostar.api.IOnkostarApi;
|
||||
|
||||
public class ConsentManagerServiceFactory {
|
||||
|
||||
private final IOnkostarApi onkostarApi;
|
||||
|
||||
public ConsentManagerServiceFactory(
|
||||
final IOnkostarApi onkostarApi
|
||||
) {
|
||||
this.onkostarApi = onkostarApi;
|
||||
}
|
||||
|
||||
public ConsentManagerService currentUsableInstance() {
|
||||
var consentFormName = onkostarApi.getGlobalSetting("consentform");
|
||||
|
||||
switch (consentFormName) {
|
||||
case "MR.Consent":
|
||||
default:
|
||||
return new MrConsentManagerService(this.onkostarApi);
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
121
src/main/java/DNPM/services/consent/MrConsentManagerService.java
Normal file
121
src/main/java/DNPM/services/consent/MrConsentManagerService.java
Normal file
@ -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);
|
||||
}
|
||||
}
|
||||
|
||||
}
|
||||
Reference in New Issue
Block a user