diff --git a/src/main/java/de/uniluebeck/mi/projmi6/Main.java b/src/main/java/de/uniluebeck/mi/projmi6/Main.java index 55a55e4..f358508 100644 --- a/src/main/java/de/uniluebeck/mi/projmi6/Main.java +++ b/src/main/java/de/uniluebeck/mi/projmi6/Main.java @@ -2,7 +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.hapi2.HL7Server2; +import de.uniluebeck.mi.projmi6.hapi.HL7Server; import javafx.application.Application; import javafx.beans.property.ReadOnlyStringProperty; import javafx.collections.FXCollections; @@ -27,7 +27,7 @@ import javafx.stage.StageStyle; public class Main extends Application { - private HL7Server2 server; + private HL7Server server; /** * Cuz building the GUI from FXML is a bit costly, @@ -73,7 +73,7 @@ public class Main extends Application { Parent root = fxmlLoader.load(); // TODO: Jojo, das muss irgendwie am ende noch geschlossen werden! - server = new HL7Server2(mainController); + server = new HL7Server(mainController); return root; } diff --git a/src/main/java/de/uniluebeck/mi/projmi6/hapi2/HL7ConnectionListener2.java b/src/main/java/de/uniluebeck/mi/projmi6/hapi/HL7ConnectionListener.java similarity index 81% rename from src/main/java/de/uniluebeck/mi/projmi6/hapi2/HL7ConnectionListener2.java rename to src/main/java/de/uniluebeck/mi/projmi6/hapi/HL7ConnectionListener.java index a0dbac6..cc972d6 100644 --- a/src/main/java/de/uniluebeck/mi/projmi6/hapi2/HL7ConnectionListener2.java +++ b/src/main/java/de/uniluebeck/mi/projmi6/hapi/HL7ConnectionListener.java @@ -1,4 +1,4 @@ -package de.uniluebeck.mi.projmi6.hapi2; +package de.uniluebeck.mi.projmi6.hapi; import ca.uhn.hl7v2.app.Connection; import ca.uhn.hl7v2.app.ConnectionListener; @@ -6,7 +6,7 @@ import ca.uhn.hl7v2.app.ConnectionListener; /** * Created by nils on 20.11.2015. */ -class HL7ConnectionListener2 implements ConnectionListener { +class HL7ConnectionListener implements ConnectionListener { @Override public void connectionReceived(Connection c) { diff --git a/src/main/java/de/uniluebeck/mi/projmi6/hapi2/HL7ExceptionHandler2.java b/src/main/java/de/uniluebeck/mi/projmi6/hapi/HL7ExceptionHandler.java similarity index 75% rename from src/main/java/de/uniluebeck/mi/projmi6/hapi2/HL7ExceptionHandler2.java rename to src/main/java/de/uniluebeck/mi/projmi6/hapi/HL7ExceptionHandler.java index b746016..40f92ad 100644 --- a/src/main/java/de/uniluebeck/mi/projmi6/hapi2/HL7ExceptionHandler2.java +++ b/src/main/java/de/uniluebeck/mi/projmi6/hapi/HL7ExceptionHandler.java @@ -1,4 +1,4 @@ -package de.uniluebeck.mi.projmi6.hapi2; +package de.uniluebeck.mi.projmi6.hapi; import ca.uhn.hl7v2.HL7Exception; import ca.uhn.hl7v2.protocol.ReceivingApplicationExceptionHandler; @@ -8,7 +8,7 @@ import java.util.Map; /** * Created by nils on 20.11.2015. */ -public class HL7ExceptionHandler2 implements ReceivingApplicationExceptionHandler { +public class HL7ExceptionHandler implements ReceivingApplicationExceptionHandler { @Override public String processException(String incomingMessage, Map incomingMetadata, String outgoingMessage, Exception e) throws HL7Exception { return outgoingMessage; diff --git a/src/main/java/de/uniluebeck/mi/projmi6/hapi2/HL7Receiver2.java b/src/main/java/de/uniluebeck/mi/projmi6/hapi/HL7Receiver.java similarity index 95% rename from src/main/java/de/uniluebeck/mi/projmi6/hapi2/HL7Receiver2.java rename to src/main/java/de/uniluebeck/mi/projmi6/hapi/HL7Receiver.java index b529dd5..5ee5754 100644 --- a/src/main/java/de/uniluebeck/mi/projmi6/hapi2/HL7Receiver2.java +++ b/src/main/java/de/uniluebeck/mi/projmi6/hapi/HL7Receiver.java @@ -1,4 +1,4 @@ -package de.uniluebeck.mi.projmi6.hapi2; +package de.uniluebeck.mi.projmi6.hapi; import ca.uhn.hl7v2.AcknowledgmentCode; import ca.uhn.hl7v2.ErrorCode; @@ -27,11 +27,11 @@ import java.util.Map; /** * Created by nils on 20.11.2015. */ -public class HL7Receiver2 implements ReceivingApplication { +public class HL7Receiver implements ReceivingApplication { private final Class type; private final MainController mainctrl; - public HL7Receiver2(Class type, MainController mainctrl) { + public HL7Receiver(Class type, MainController mainctrl) { this.type = type; this.mainctrl = mainctrl; } @@ -127,8 +127,8 @@ public class HL7Receiver2 implements ReceivingApplica StationsHistorie hist = new StationsHistorie(); // TODO: StationsHist schreiben/schon vorhanden! hist.setStationKey(station.getStation()); - hist.setAufnahmeDatum(HL7Util2.parseLocalDateTime(pv1.getAdmitDateTime().getTime())); - hist.setEntlassungsDatum(HL7Util2.parseLocalDateTime(pv1.getDischargeDateTime()[0].getTime())); // TODO: null? + hist.setAufnahmeDatum(HL7Util.parseLocalDateTime(pv1.getAdmitDateTime().getTime())); + hist.setEntlassungsDatum(HL7Util.parseLocalDateTime(pv1.getDischargeDateTime()[0].getTime())); // TODO: null? hist.setFallID(fallid); List dg1s = visit.getDG1All(); @@ -201,7 +201,7 @@ public class HL7Receiver2 implements ReceivingApplica } untersuchung.setOpscode(opscode); - untersuchung.setUntersuchungsdatum(HL7Util2.parseLocalDateTime(pr1.getProcedureDateTime().getTime())); + untersuchung.setUntersuchungsdatum(HL7Util.parseLocalDateTime(pr1.getProcedureDateTime().getTime())); // Mitarbeiter ID anhand von EinweisenderArzt erkennen. Mitarbeiter mitarbeiter; @@ -261,7 +261,7 @@ public class HL7Receiver2 implements ReceivingApplica private void logHL7MessageToDatabase(Message message, MSH msh, Map metadata, HL7LogEntry.Direction direction) throws HL7Exception { String sendind_ip = metadata.get("SENDING_IP").toString(); String sendind_port = metadata.get("SENDING_PORT").toString(); - LocalDateTime ldt = HL7Util2.parseLocalDateTime(msh.getDateTimeOfMessage().getTime()); + LocalDateTime ldt = HL7Util.parseLocalDateTime(msh.getDateTimeOfMessage().getTime()); HL7LogEntry entry = new HL7LogEntry(); diff --git a/src/main/java/de/uniluebeck/mi/projmi6/hapi2/HL7Server2.java b/src/main/java/de/uniluebeck/mi/projmi6/hapi/HL7Server.java similarity index 83% rename from src/main/java/de/uniluebeck/mi/projmi6/hapi2/HL7Server2.java rename to src/main/java/de/uniluebeck/mi/projmi6/hapi/HL7Server.java index f670f6a..fff1919 100644 --- a/src/main/java/de/uniluebeck/mi/projmi6/hapi2/HL7Server2.java +++ b/src/main/java/de/uniluebeck/mi/projmi6/hapi/HL7Server.java @@ -1,4 +1,4 @@ -package de.uniluebeck.mi.projmi6.hapi2; +package de.uniluebeck.mi.projmi6.hapi; import ca.uhn.hl7v2.DefaultHapiContext; import ca.uhn.hl7v2.HapiContext; @@ -14,14 +14,14 @@ import java.util.concurrent.TimeUnit; /** * Created by nils on 20.11.2015. */ -public class HL7Server2 { +public class HL7Server { private static final int PORT = 1111; private final HapiContext context; private final HL7Service server; private final ThreadPoolExecutor executor; - public HL7Server2(MainController mainctrl) throws InterruptedException { + public HL7Server(MainController mainctrl) throws InterruptedException { executor = new ThreadPoolExecutor(10, 100, 30, TimeUnit.SECONDS, new ArrayBlockingQueue(100)); executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy()); @@ -29,11 +29,11 @@ public class HL7Server2 { context.setExecutorService(executor); server = context.newServer(PORT, false); - server.registerApplication("ADT", "A01", new HL7Receiver2(ADT_A01.class, mainctrl)); - server.registerApplication("BAR", "P05", new HL7Receiver2(BAR_P05.class, mainctrl)); + server.registerApplication("ADT", "A01", new HL7Receiver(ADT_A01.class, mainctrl)); + server.registerApplication("BAR", "P05", new HL7Receiver(BAR_P05.class, mainctrl)); - server.registerConnectionListener(new HL7ConnectionListener2()); - server.setExceptionHandler(new HL7ExceptionHandler2()); + server.registerConnectionListener(new HL7ConnectionListener()); + server.setExceptionHandler(new HL7ExceptionHandler()); //server.startAndWait(); server.start(); diff --git a/src/main/java/de/uniluebeck/mi/projmi6/hapi2/HL7Util2.java b/src/main/java/de/uniluebeck/mi/projmi6/hapi/HL7Util.java similarity index 92% rename from src/main/java/de/uniluebeck/mi/projmi6/hapi2/HL7Util2.java rename to src/main/java/de/uniluebeck/mi/projmi6/hapi/HL7Util.java index b323e5e..84e4c3d 100644 --- a/src/main/java/de/uniluebeck/mi/projmi6/hapi2/HL7Util2.java +++ b/src/main/java/de/uniluebeck/mi/projmi6/hapi/HL7Util.java @@ -1,4 +1,4 @@ -package de.uniluebeck.mi.projmi6.hapi2; +package de.uniluebeck.mi.projmi6.hapi; import ca.uhn.hl7v2.model.DataTypeException; import ca.uhn.hl7v2.model.v251.datatype.DTM; @@ -9,7 +9,7 @@ import java.time.ZoneId; /** * Created by nils on 20.11.2015. */ -public class HL7Util2 { +public class HL7Util { public static LocalDateTime parseLocalDateTime(DTM dtm) { try { return LocalDateTime.ofInstant(dtm.getValueAsDate().toInstant(), ZoneId.systemDefault());