pcvolkmer/onkostar-plugin-dnpm
1
0
Fork 0
mirror of https://github.com/pcvolkmer/onkostar-plugin-dnpm.git synced 2025-07-03 01:32:55 +00:00
Code Issues Activity

Methode getVerweise() vereinfacht

Browse Source
This commit is contained in:
Paul-Christian Volkmer
2023-03-30 12:05:59 +02:00
parent 2f691efeb3
commit 82ab2234e8
2 changed files with 58 additions and 41 deletions
Download Patch File Download Diff File Expand all files Collapse all files

82
src/main/java/DNPM/DNPMHelper.java
View File

@ -18,7 +18,10 @@ import org.hibernate.type.StandardBasicTypes;
import org.slf4j.Logger; import org.slf4j.Logger;
import org.slf4j.LoggerFactory; import org.slf4j.LoggerFactory;
import java.util.*; import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
public class DNPMHelper implements IProcedureAnalyzer { public class DNPMHelper implements IProcedureAnalyzer {
@ -90,58 +93,55 @@ public class DNPMHelper implements IProcedureAnalyzer {
return null; return null;
} }
int value = 0; var verbundeneFormulare = new ArrayList<Map<String, String>>();
var VerbundeneFormulare = new ArrayList<Map<String, String>>();
try { try {
SessionFactory sessionFactory = onkostarApi.getSessionFactory(); SessionFactory sessionFactory = onkostarApi.getSessionFactory();
Session session = sessionFactory.getCurrentSession(); Session session = sessionFactory.getCurrentSession();
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 = " + patientId.get() + " " +
"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));
List<VerweisVon> result = query.list();
try { try {
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 " + int value = 0;
"FROM prozedur " + for (VerweisVon verweisVon : result) {
"LEFT JOIN data_form_data_catalogue ON data_form_data_catalogue.data_form_id = prozedur.data_form_id " + sql = verweisVon.getSQL();
"LEFT JOIN data_catalogue_entry ON data_catalogue_entry.data_catalogue_id = data_form_data_catalogue.data_catalogue_id " + query = session.createSQLQuery(sql)
"LEFT JOIN data_catalogue ON data_catalogue.id = data_catalogue_entry.data_catalogue_id " + .addScalar("value", StandardBasicTypes.INTEGER);
"LEFT JOIN data_form ON data_form.id = prozedur.data_form_id " + if (query.uniqueResult() != null) {
"WHERE patient_id = " + patientId.get() + " " + value = (Integer) query.uniqueResult();
"AND geloescht = 0 " + }
"AND data_catalogue_entry.type = 'formReference' " + if (value == procedureId.get()) {
"GROUP BY prozedur.id, prozedur.data_form_id, data_catalogue.name, data_catalogue_entry.name"; verbundeneFormulare.add(Map.of("formular", verweisVon.getVerbundenesFormular()));
value = 0;
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));
List<VerweisVon> result = query.list();
try {
for (VerweisVon var : result) {
sql = var.getSQL();
query = session.createSQLQuery(sql)
.addScalar("value", StandardBasicTypes.INTEGER);
if (query.uniqueResult() != null) {
value = (Integer) query.uniqueResult();
}
if (value == procedureId.get()) {
VerbundeneFormulare.add(Map.of("formular", var.getVerbundenesFormular()));
value = 0;
}
} }
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
} }
} catch (Exception e) { } catch (Exception e) {
return null; logger.warn("Fehler beim Hinzufügen eines Formularverweises", e);
} }
} catch (Exception e) { } catch (Exception e) {
logger.error("Fehler beim Ermitteln der Formularverweise", e);
return null; return null;
} }
return VerbundeneFormulare; return verbundeneFormulare;
} }
public List<Map<String, String>> getSystemischeTherapienFromDiagnose(final Map<String, Object> input) { public List<Map<String, String>> getSystemischeTherapienFromDiagnose(final Map<String, Object> input) {

17
src/test/java/DNPM/DNPMHelperTest.java
View File

@ -228,6 +228,23 @@ class DNPMHelperTest {
verify(onkostarApi, times(1)).getSessionFactory(); verify(onkostarApi, times(1)).getSessionFactory();
} }
@Test
void testShouldCreateSqlQueryWithPatientId() {
var sessionFactory = mock(SessionFactory.class);
var session = mock(Session.class);
var query = mock(SQLQuery.class);
when(onkostarApi.getSessionFactory()).thenReturn(sessionFactory);
when(sessionFactory.getCurrentSession()).thenReturn(session);
when(session.createSQLQuery(anyString())).thenReturn(query);
dnpmHelper.getVerweise(Map.of("ProcedureId", 1, "PatientId", 2));
var argumentCaptor = ArgumentCaptor.forClass(String.class);
verify(session, times(1)).createSQLQuery(argumentCaptor.capture());
assertThat(argumentCaptor.getValue()).contains("WHERE patient_id = 2 AND geloescht = 0");
}
} }
} }