diff --git a/src/main/java/de/uniluebeck/mi/projmi6/Main.java b/src/main/java/de/uniluebeck/mi/projmi6/Main.java index 6d934bf..bf7c636 100644 --- a/src/main/java/de/uniluebeck/mi/projmi6/Main.java +++ b/src/main/java/de/uniluebeck/mi/projmi6/Main.java @@ -2,9 +2,7 @@ package de.uniluebeck.mi.projmi6; import de.uniluebeck.mi.projmi6.controller.MainController; import de.uniluebeck.mi.projmi6.db.DBHandler; -import de.uniluebeck.mi.projmi6.model.Kasse; -import de.uniluebeck.mi.projmi6.model.Mitarbeiter; -import de.uniluebeck.mi.projmi6.model.OpsCode; +import de.uniluebeck.mi.projmi6.hapi2.HL7Server2; import javafx.application.Application; import javafx.beans.property.ReadOnlyStringProperty; import javafx.collections.FXCollections; @@ -14,7 +12,6 @@ import javafx.geometry.Insets; import javafx.geometry.Pos; import javafx.scene.Parent; import javafx.scene.Scene; -import javafx.scene.control.ProgressIndicator; import javafx.scene.image.Image; import javafx.scene.image.ImageView; import javafx.scene.layout.Background; @@ -72,6 +69,11 @@ public class Main extends Application { Parent root = fxmlLoader.load(); + // TODO: Jojo, das muss irgendwie am ende noch geschlossen werden! + HL7Server2 hl7server = new HL7Server2(mainController); + //hl7server.stop(); + //hl7server.shutdown(); + return root; } }; @@ -81,6 +83,14 @@ public class Main extends Application { */ private Image icon = new Image("icon.png", true); + /** + * Applications entry point. + * + * @param args Commandline parameters + */ + public static void main(String[] args) { + launch(args); + } @Override public void start(Stage primaryStage) { @@ -117,7 +127,7 @@ public class Main extends Application { * * @return the splash screen */ - public Stage createLoadWindow(ReadOnlyStringProperty progressMessage){ + public Stage createLoadWindow(ReadOnlyStringProperty progressMessage) { Text kis = new Text("KIS"); kis.setFont(Font.font(50)); @@ -127,7 +137,7 @@ public class Main extends Application { Text progress = new Text(); progress.textProperty().bind(progressMessage); - VBox root = new VBox(gruppe6, new ImageView(icon), kis, progress); + VBox root = new VBox(gruppe6, new ImageView(icon), kis, progress); root.setSpacing(20); root.setAlignment(Pos.CENTER); Scene scene = new Scene(root, 400, 500); @@ -140,13 +150,4 @@ public class Main extends Application { return stage; } - - /** - * Applications entry point. - * - * @param args Commandline parameters - */ - public static void main(String[] args) { - launch(args); - } } diff --git a/src/main/java/de/uniluebeck/mi/projmi6/db/DBHandler.java b/src/main/java/de/uniluebeck/mi/projmi6/db/DBHandler.java index 4982a1d..56c1e77 100644 --- a/src/main/java/de/uniluebeck/mi/projmi6/db/DBHandler.java +++ b/src/main/java/de/uniluebeck/mi/projmi6/db/DBHandler.java @@ -155,6 +155,7 @@ public class DBHandler { "`FallID`) " + "VALUES (?, ?, ?, ?, ?, ?, ?, ?)"; private static final String DELETE_STATHIST = "DELETE FROM `stationshistorie` WHERE `StatHistID` =?"; + private static final String SELECT_FALLIDS_BY_PATID = "SELECT `fallid` FROM `fall` WHERE `patientid` =?"; private DBHandler() { @@ -841,4 +842,16 @@ public class DBHandler { entry.setSource(rs.getString("source")); return entry; } + + public static List getAlleFallIdsByPatID(int patid) throws SQLException { + PreparedStatement statement = MySqlConnectionFactory.getConnection().prepareStatement(SELECT_FALLIDS_BY_PATID); + statement.setInt(1, patid); + ResultSet rs = statement.executeQuery(); + + List fallids = new ArrayList<>(); + while (rs.next()) { + fallids.add(rs.getInt("fallid")); + } + return fallids; + } } diff --git a/src/main/java/de/uniluebeck/mi/projmi6/hapi2/HL7Receiver2.java b/src/main/java/de/uniluebeck/mi/projmi6/hapi2/HL7Receiver2.java new file mode 100644 index 0000000..b3d9f46 --- /dev/null +++ b/src/main/java/de/uniluebeck/mi/projmi6/hapi2/HL7Receiver2.java @@ -0,0 +1,245 @@ +package de.uniluebeck.mi.projmi6.hapi2; + +import ca.uhn.hl7v2.AcknowledgmentCode; +import ca.uhn.hl7v2.ErrorCode; +import ca.uhn.hl7v2.HL7Exception; +import ca.uhn.hl7v2.model.AbstractMessage; +import ca.uhn.hl7v2.model.Message; +import ca.uhn.hl7v2.model.v251.group.BAR_P05_PROCEDURE; +import ca.uhn.hl7v2.model.v251.group.BAR_P05_VISIT; +import ca.uhn.hl7v2.model.v251.message.ADT_A01; +import ca.uhn.hl7v2.model.v251.message.BAR_P05; +import ca.uhn.hl7v2.model.v251.segment.*; +import ca.uhn.hl7v2.protocol.ReceivingApplication; +import ca.uhn.hl7v2.protocol.ReceivingApplicationException; +import de.uniluebeck.mi.projmi6.controller.MainController; +import de.uniluebeck.mi.projmi6.db.DBHandler; +import de.uniluebeck.mi.projmi6.model.*; + +import java.io.IOException; +import java.sql.SQLException; +import java.util.ArrayList; +import java.util.List; +import java.util.Map; + +/** + * Created by nils on 20.11.2015. + */ +public class HL7Receiver2 implements ReceivingApplication { + private final Class type; + private final MainController mainctrl; + + public HL7Receiver2(Class type, MainController mainctrl) { + this.type = type; + this.mainctrl = mainctrl; + } + + + @Override + public Message processMessage(Message message, Map metadata) throws ReceivingApplicationException, HL7Exception { + + if (type == ADT_A01.class) { + return processADT_A01(message, metadata); + } + if (type == BAR_P05.class) { + return processBAR_P05(message, metadata); + } + + // TODO: Handle unknown Messages, maybe write to database, send ACK and go on. + try { + return message.generateACK(); + } catch (IOException e) { + throw new HL7Exception(e); + } + } + + @Override + public boolean canProcess(Message message) { + // TODO: Erstmal alles processen. + return true; + } + + private Message generateACK(Message message) throws HL7Exception { + try { + return message.generateACK(); + } catch (IOException e) { + throw new HL7Exception(e); + } + } + + private Message generateACKWithAR(Message message, String s) throws HL7Exception { + try { + return message.generateACK(AcknowledgmentCode.AR, new HL7Exception(s, ErrorCode.UNKNOWN_KEY_IDENTIFIER)); + } catch (IOException e) { + throw new HL7Exception(e); + } + } + + private Message processBAR_P05(Message message, Map metadata) throws HL7Exception { + BAR_P05 bar_p05 = (BAR_P05) message; + + MSH msh = bar_p05.getMSH(); + PID pid = bar_p05.getPID(); + + int patid = Integer.parseInt(pid.getPatientID().encode()); + Patient patient = mainctrl.getStammdaten().getPatienten().stream().filter(p -> p.getPatID() == patid).findFirst().orElse(null); + + if (patient == null) { + return generateACKWithAR(message, "Patient nicht gefunden."); + } + + List visits = bar_p05.getVISITAll(); + + // Ab hier wird es dirty. + for (BAR_P05_VISIT visit : visits) { + PV1 pv1 = visit.getPV1(); + int fallid = Integer.parseInt(pv1.getVisitNumber().encode()); + + List fallids = new ArrayList<>(); + try { + fallids = DBHandler.getAlleFallIdsByPatID(patient.getPatID()); + } catch (SQLException e) { + e.printStackTrace(); + } + if (fallids.isEmpty() || !fallids.contains(fallid)) { + return generateACKWithAR(message, "Fall nicht gefunden."); + } + + Fall fall = new Fall(); + fall.setFallID(fallid); + fall.setPatient(patient); + + List diagnosen = new ArrayList<>(); + List untersuchungen = new ArrayList<>(); + + // Station(PV1-3-1), Fachabteilung(PV1-3-4), Aufnahmedatum(PV1-44), Entlassungsdatum(PV1-45), Fallnummer(PV1-19) + Station station = new Station(); + station.setStation(pv1.getAssignedPatientLocation().getPointOfCare().encode()); + station.setAbteilung(pv1.getAssignedPatientLocation().getFacility().encode()); + + StationsHistorie hist = new StationsHistorie(); + hist.setStationKey(station.getStation()); + hist.setAufnahmeDatum(HL7Util2.parseLocalDateTime(pv1.getAdmitDateTime().getTime())); + hist.setEntlassungsDatum(HL7Util2.parseLocalDateTime(pv1.getDischargeDateTime()[0].getTime())); // TODO: null? + hist.setFallID(fallid); + + List dg1s = visit.getDG1All(); + for (DG1 dg1 : dg1s) { + Diagnose diagnose = new Diagnose(); + diagnose.setErsteller(99999); + diagnose.setBearbeiter(99999); + diagnose.setFall(fall); + + String icd10 = dg1.getDiagnosisCodeDG1().getIdentifier().encode(); + Icd10Code icd10code = mainctrl.getStammdaten().getIcd10Codes().stream().filter(i -> i.getCode().equals(icd10)).findFirst().orElse(null); + if (icd10code == null) { + // TODO: Oder einfach ueberspringen? + continue; + // TODO: Behandeln von sonder Codes. K35.9V (Verdacht...) + // return generateACKWithAR(message, "ICD10 Code nicht gefunden."); + } + diagnose.setIcd10code(icd10code); + + // Mitarbeiter ID anhand von EinweisenderArzt erkennen. + Mitarbeiter mitarbeiter; + if (dg1.getDiagnosingClinician().length != 0) { + String einweisenderarzt = dg1.getDiagnosingClinician(0).encode(); // Wir holen uns immer den ersten der verantwortlichen Aerzte... // (DG1-16) + mitarbeiter = mainctrl.getStammdaten().getMitarbeiter().stream().filter(m -> m.getEinweisenderArzt().equals(einweisenderarzt)).findFirst().orElse(null); + if (mitarbeiter == null) { + return generateACKWithAR(message, "Mitarbeiter nicht gefunden."); + } + } else { + mitarbeiter = new Mitarbeiter(99999); + } + diagnose.setArzt(mitarbeiter); + // (DG1-6) // TODO: Enum umstellen? Neeee... + String diagart = dg1.getDiagnosisType().encode(); + switch (diagart) { + case "A": + diagnose.setDiagArt(DiagArt.EINWEISUNG); + break; + case "F": + diagnose.setDiagArt(DiagArt.ENTLASSUNG); + break; + case "W": + default: + diagnose.setDiagArt(DiagArt.VERDACHT); + } + + diagnosen.add(diagnose); + } + List procedures = visit.getPROCEDUREAll(); + for (BAR_P05_PROCEDURE procedure : procedures) { + PR1 pr1 = procedure.getPR1(); + Untersuchung untersuchung = new Untersuchung(); + untersuchung.setErsteller(99999); + untersuchung.setBearbeiter(99999); + untersuchung.setFall(fall); + + String ops = pr1.getProcedureCode().encode(); + OpsCode opscode = mainctrl.getStammdaten().getOpsCodes().stream().filter(o -> o.getOpsCode().equals(ops)).findFirst().orElse(null); + if (opscode == null) { + // TODO: Oder einfach ueberspringen? + continue; + // TODO: Behandeln von sonder Codes. + // return generateACKWithAR(message, "OPS Code nicht gefunden."); + } + untersuchung.setOpscode(opscode); + + untersuchung.setUntersuchungsdatum(HL7Util2.parseLocalDateTime(pr1.getProcedureDateTime().getTime())); + + // Mitarbeiter ID anhand von EinweisenderArzt erkennen. + Mitarbeiter mitarbeiter; + if (pr1.getProcedurePractitioner().length != 0) { + String einweisenderarzt = pr1.getProcedurePractitioner(0).encode(); // Wir holen uns immer den ersten der verantwortlichen Aerzte... + mitarbeiter = mainctrl.getStammdaten().getMitarbeiter().stream().filter(m -> m.getEinweisenderArzt().equals(einweisenderarzt)).findFirst().orElse(null); + if (mitarbeiter == null) { + return generateACKWithAR(message, "Mitarbeiter nicht gefunden."); + } + } else { + mitarbeiter = new Mitarbeiter(99999); + } + untersuchung.setDurchfuehrenderArzt(mitarbeiter); + + untersuchungen.add(untersuchung); + } + + // Hier jeweils Untersuchung und Diagnose in die Datenbank schreiben. + diagnosen.forEach(d -> { + try { + DBHandler.setDiagnose(d); + } catch (SQLException e) { + e.printStackTrace(); + } + }); + + untersuchungen.forEach(u -> { + try { + DBHandler.setUntersuchung(u, 99999, false); + } catch (SQLException e) { + e.printStackTrace(); + } + }); + } + + // HL7 Nachricht loggen. + try { + String sendind_ip = metadata.get("SENDING_IP").toString(); + String sendind_port = metadata.get("SENDING_PORT").toString(); + DBHandler.setHL7Nachricht(message.encode(), HL7Util2.parseLocalDateTime(msh.getDateTimeOfMessage().getTime()), sendind_ip + ":" + sendind_port); + } catch (SQLException e) { + e.printStackTrace(); + } + + return generateACK(message); + } + + + private Message processADT_A01(Message message, Map metadata) throws HL7Exception { + ADT_A01 adt_a01 = (ADT_A01) message; + System.out.println(adt_a01.toString()); + + return generateACK(message); + } + +} diff --git a/src/main/java/de/uniluebeck/mi/projmi6/hapi2/HL7Recever2.java b/src/main/java/de/uniluebeck/mi/projmi6/hapi2/HL7Recever2.java deleted file mode 100644 index 678e69d..0000000 --- a/src/main/java/de/uniluebeck/mi/projmi6/hapi2/HL7Recever2.java +++ /dev/null @@ -1,160 +0,0 @@ -package de.uniluebeck.mi.projmi6.hapi2; - -import ca.uhn.hl7v2.AcknowledgmentCode; -import ca.uhn.hl7v2.ErrorCode; -import ca.uhn.hl7v2.HL7Exception; -import ca.uhn.hl7v2.model.AbstractMessage; -import ca.uhn.hl7v2.model.Message; -import ca.uhn.hl7v2.model.v251.group.BAR_P05_PROCEDURE; -import ca.uhn.hl7v2.model.v251.group.BAR_P05_VISIT; -import ca.uhn.hl7v2.model.v251.message.ADT_A01; -import ca.uhn.hl7v2.model.v251.message.BAR_P05; -import ca.uhn.hl7v2.model.v251.segment.*; -import ca.uhn.hl7v2.protocol.ReceivingApplication; -import ca.uhn.hl7v2.protocol.ReceivingApplicationException; -import de.uniluebeck.mi.projmi6.model.*; - -import java.io.IOException; -import java.util.ArrayList; -import java.util.List; -import java.util.Map; - -/** - * Created by nils on 20.11.2015. - */ -public class HL7Recever2 implements ReceivingApplication { - private final Class type; - - public HL7Recever2(Class type) { - this.type = type; - } - - - @Override - public Message processMessage(Message message, Map metadata) throws ReceivingApplicationException, HL7Exception { - - if (type == ADT_A01.class) { - return processADT_A01(message, metadata); - } - if (type == BAR_P05.class) { - return processBAR_P05(message, metadata); - } - - // TODO: Handle unknown Messages, maybe write to database, sen ACK and go on. - try { - return message.generateACK(); - } catch (IOException e) { - throw new HL7Exception(e); - } - } - - @Override - public boolean canProcess(Message message) { - // TODO: Erstmal alles processen. - return true; - } - - private Message generateACK(Message message) throws HL7Exception { - try { - return message.generateACK(); - } catch (IOException e) { - throw new HL7Exception(e); - } - } - - private Message generateACKWithAR(Message message, String s) throws HL7Exception { - try { - return message.generateACK(AcknowledgmentCode.AR, new HL7Exception(s, ErrorCode.TABLE_VALUE_NOT_FOUND)); - } catch (IOException e) { - throw new HL7Exception(e); - } - } - - private Message processBAR_P05(Message message, Map metadata) throws HL7Exception { - Patient patient = new Patient(); - List faelle = new ArrayList<>(); - List ALLE_UNTERSUCHUNGEN = new ArrayList<>(); - List ALLE_DIAGNOSEN = new ArrayList<>(); - - BAR_P05 bar_p05 = (BAR_P05) message; - - MSH msh = bar_p05.getMSH(); - PID pid = bar_p05.getPID(); - - patient.setPatID(Integer.parseInt(pid.getPatientID().encode())); - - List visits = bar_p05.getVISITAll(); - - // Ab hier wird es dirty. - for (BAR_P05_VISIT visit : visits) { - - Fall fall = new Fall(); - fall.setPatient(patient); - - List diagnosen = new ArrayList<>(); - List untersuchungen = new ArrayList<>(); - - PV1 pv1 = visit.getPV1(); - // TODO: Extract Station(PV1-3-1),Fachabteilung(PV1-3-4),Aufnahmedatum(PV1-44),Entlassungsdatum(PV1-45),Fallnummer(PV1-19) - Station station = new Station(); - station.setStation(pv1.getAssignedPatientLocation().getPointOfCare().encode()); - station.setAbteilung(pv1.getAssignedPatientLocation().getFacility().encode()); - StationsHistorie hist = new StationsHistorie(); - hist.setStationKey(station.getStation()); - hist.setAufnahmeDatum(HL7Util2.parseLocalDateTime(pv1.getAdmitDateTime().getTime())); - hist.setEntlassungsDatum(HL7Util2.parseLocalDateTime(pv1.getDischargeDateTime()[0].getTime())); - fall.setFallID(Integer.parseInt(pv1.getVisitNumber().encode())); - - List dg1s = visit.getDG1All(); - for (DG1 dg1 : dg1s) { - Icd10Code icd10code = new Icd10Code(dg1.getDiagnosisCodeDG1().getIdentifier().encode(), "", 20); // TODO: Version hard gecoded. - // TODO: Mitarbeiter ID anhand von EinweisenderArzt erkennen! - String einweisenderarzt = dg1.getDiagnosingClinician(0).encode(); // TODO: Wir holen uns immer den ersten der verantwortlichen Aerzte... - int mitarbid = 1000; // TODO: SQL: SELECT * FROM Mitarbeiter WHERE einweisenderarzt = ... - Mitarbeiter mitarbeiter = new Mitarbeiter(mitarbid); - - Diagnose diagnose = new Diagnose(); - diagnose.setIcd10code(icd10code); - diagnose.setArzt(mitarbeiter); // TODO: (DG1-16) - diagnose.setFall(fall); - // diagnose.setDiagArt(); // TODO: (DG1-6) // Enum umstellen???? - - diagnosen.add(diagnose); - } - List procedures = visit.getPROCEDUREAll(); - for (BAR_P05_PROCEDURE procedure : procedures) { - PR1 pr1 = procedure.getPR1(); - Untersuchung untersuchung = new Untersuchung(); - untersuchung.setFall(fall); - - OpsCode opscode = new OpsCode(pr1.getProcedureCode().encode(), "", 20); // TODO: Version hardcoded... - untersuchung.setOpscode(opscode); - untersuchung.setUntersuchungsdatum(HL7Util2.parseLocalDateTime(pr1.getProcedureDateTime().getTime())); - - String einweisenderarzt = pr1.getPr112_ProcedurePractitioner(0).encode(); // TODO: Wieder nur den ersten Arzt.. - int mitarbid = 1000; // TODO: Siehe oben - untersuchung.setDurchfuehrenderArzt(new Mitarbeiter(mitarbid)); - - // TODO: Extract OPS(3), Zeitpunkt(5), Arzt(12) - - untersuchungen.add(untersuchung); - } - - // TODO: hier jeweils Fall, Untersuchung und Diagnosen in die Datenbank schreiben... - faelle.add(fall); - ALLE_DIAGNOSEN.addAll(diagnosen); - ALLE_UNTERSUCHUNGEN.addAll(untersuchungen); - } - - return generateACK(message); - } - - - private Message processADT_A01(Message message, Map metadata) throws HL7Exception { - ADT_A01 adt_a01 = (ADT_A01) message; - System.out.println(adt_a01.toString()); - - return generateACK(message); - } - -} diff --git a/src/main/java/de/uniluebeck/mi/projmi6/hapi2/HL7Server2.java b/src/main/java/de/uniluebeck/mi/projmi6/hapi2/HL7Server2.java index f302d4e..a1f80d1 100644 --- a/src/main/java/de/uniluebeck/mi/projmi6/hapi2/HL7Server2.java +++ b/src/main/java/de/uniluebeck/mi/projmi6/hapi2/HL7Server2.java @@ -5,6 +5,7 @@ import ca.uhn.hl7v2.HapiContext; import ca.uhn.hl7v2.app.HL7Service; import ca.uhn.hl7v2.model.v251.message.ADT_A01; import ca.uhn.hl7v2.model.v251.message.BAR_P05; +import de.uniluebeck.mi.projmi6.controller.MainController; import java.util.concurrent.ArrayBlockingQueue; import java.util.concurrent.ThreadPoolExecutor; @@ -20,7 +21,7 @@ public class HL7Server2 { private final HL7Service server; private final ThreadPoolExecutor executor; - public HL7Server2() throws InterruptedException { + public HL7Server2(MainController mainctrl) throws InterruptedException { executor = new ThreadPoolExecutor(10, 100, 30, TimeUnit.SECONDS, new ArrayBlockingQueue(100)); executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); @@ -28,8 +29,8 @@ public class HL7Server2 { context.setExecutorService(executor); server = context.newServer(PORT, false); - server.registerApplication("ADT", "A01", new HL7Recever2(ADT_A01.class)); - server.registerApplication("BAR", "P05", new HL7Recever2(BAR_P05.class)); + server.registerApplication("ADT", "A01", new HL7Receiver2(ADT_A01.class, mainctrl)); + server.registerApplication("BAR", "P05", new HL7Receiver2(BAR_P05.class, mainctrl)); server.registerConnectionListener(new HL7ConnectionListener2()); server.setExceptionHandler(new HL7ExceptionHandler2()); @@ -40,7 +41,7 @@ public class HL7Server2 { // TODO: Remove, for testing purpose only! public static void main(String[] args) throws InterruptedException { - HL7Server2 srv = new HL7Server2(); + HL7Server2 srv = new HL7Server2(null); for (; ; ) { }