From 058a08577707eaba0a14e921cf98505eadead613 Mon Sep 17 00:00:00 2001 From: Nils Dittberner Date: Sun, 22 Nov 2015 14:58:07 +0100 Subject: [PATCH] =?UTF-8?q?Senden=20von=20ADT=20A01=20m=C3=B6glich.?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../de/uniluebeck/mi/projmi6/hapi/HL7Sender.java | 130 ++++++++++++--------- 1 file changed, 72 insertions(+), 58 deletions(-) diff --git a/src/main/java/de/uniluebeck/mi/projmi6/hapi/HL7Sender.java b/src/main/java/de/uniluebeck/mi/projmi6/hapi/HL7Sender.java index 3f8d477..6c63a8e 100644 --- a/src/main/java/de/uniluebeck/mi/projmi6/hapi/HL7Sender.java +++ b/src/main/java/de/uniluebeck/mi/projmi6/hapi/HL7Sender.java @@ -12,11 +12,10 @@ import ca.uhn.hl7v2.model.v251.message.ACK; import ca.uhn.hl7v2.model.v251.message.ADT_A01; import ca.uhn.hl7v2.model.v251.segment.*; import ca.uhn.hl7v2.parser.Parser; -import ca.uhn.hl7v2.parser.PipeParser; -import ca.uhn.hl7v2.validation.impl.ValidationContextFactory; import de.uniluebeck.mi.projmi6.Main; import de.uniluebeck.mi.projmi6.model.Diagnose; import de.uniluebeck.mi.projmi6.model.Fall; +import de.uniluebeck.mi.projmi6.model.HL7LogEntry; import de.uniluebeck.mi.projmi6.model.Patient; import java.io.BufferedWriter; @@ -25,6 +24,8 @@ import java.io.FileWriter; import java.io.IOException; import java.sql.SQLException; import java.time.LocalDateTime; +import java.time.ZoneId; +import java.util.Date; import java.util.List; import static de.uniluebeck.mi.projmi6.db.DBHandler.getDiagnosenByFall; @@ -37,59 +38,60 @@ public class HL7Sender { /** * erstellt eine ADT_A0 nachricht, welche anschließend an die OPS Gruppe verschickt werden soll. * TODO Mit OPS Gruppe absprechen, welche Informationen sie auf jeden Fall benötigen und Code entsprechend anpassen. + * * @param fall nach dem Erstellen eines neuen Falls wird diese Methode aufgerufen um Hl7 Nachricht zu erzeugen * @throws Exception */ public static void createMessageADT_A01(Fall fall) throws HL7Exception, IOException, SQLException { - Patient patient = fall.getPatient (); - ADT_A01 adt = new ADT_A01 (); + Patient patient = fall.getPatient(); + ADT_A01 adt = new ADT_A01(); //default MSH Values (Sets Segments: 1,2,7,9,11 - adt.initQuickstart ("ADT", "A01", "P"); + adt.initQuickstart("ADT", "A01", "P"); //MSH Segment: MSH mshSegment = adt.getMSH(); - mshSegment.getMsh3_SendingApplication ().getNamespaceID ().parse ( "KISGruppe6" ); - mshSegment.getMsh5_ReceivingApplication ().getNamespaceID ().parse("OPS Gruppe von Maurice und Torben"); - mshSegment.getMsh12_VersionID ().getVersionID ().parse ( "2.51" ); - mshSegment.getMsh15_AcceptAcknowledgmentType ().parse ( "AL" ); + mshSegment.getMsh3_SendingApplication().getNamespaceID().parse("KISGruppe6"); + mshSegment.getMsh5_ReceivingApplication().getNamespaceID().parse("OPS Gruppe von Maurice und Torben"); + mshSegment.getMsh12_VersionID().getVersionID().parse("2.5.1"); + mshSegment.getMsh15_AcceptAcknowledgmentType().parse("AL"); //TODO check ob segment 10 gesetzt wurde //EVN Segment: - EVN evnSegment = adt.getEVN (); - evnSegment.getEvn1_EventTypeCode ().parse("A01"); - evnSegment.getEvn2_RecordedDateTime ().parse ( String.valueOf ( LocalDateTime.now () ) ); - evnSegment.getEvn4_EventReasonCode ().parse ( "01" ); + EVN evnSegment = adt.getEVN(); + evnSegment.getEvn1_EventTypeCode().parse("A01"); + evnSegment.getEvn2_RecordedDateTime().getTime().setValue(mshSegment.getDateTimeOfMessage().encode()); + evnSegment.getEvn4_EventReasonCode().parse("01"); //PID - PID pidSegment = adt.getPID (); - pidSegment.getPid2_PatientID ().getIDNumber ().parse ( String.valueOf ( patient.getPatID () ) ); - pidSegment.getPid3_PatientIdentifierList (0).getIDNumber ().parse ( Integer.toString(patient.getPatID ()) ); - pidSegment.getPid5_PatientName (0).getFamilyName ().getSurname ().parse ( patient.getNachname () ); - pidSegment.getPid5_PatientName (0).getGivenName ().parse ( patient.getVorname () ); - pidSegment.getPid7_DateTimeOfBirth ().getTime ().parse( patient.getGeburtsdatum ().toString () ); - pidSegment.getPid8_AdministrativeSex ().parse ( patient.getGeschlecht ().toString () ); - pidSegment.getPid11_PatientAddress (0).getStreetAddress ().getStreetName().parse ( patient.getStrasse () ); - pidSegment.getPid11_PatientAddress (0).getStreetAddress ().getDwellingNumber ( ).parse( patient.getHausnummer () ); - pidSegment.getPid11_PatientAddress (0).getCity ().parse (patient.getOrt () ); - pidSegment.getPid13_PhoneNumberHome (0).getTelephoneNumber ().parse ( patient.getTelefon () ); - pidSegment.getPid16_MaritalStatus ().getAlternateIdentifier ().parse ( patient.getFamilienstand ().toString()); + PID pidSegment = adt.getPID(); + pidSegment.getPid2_PatientID().getIDNumber().parse(String.valueOf(patient.getPatID())); + pidSegment.getPid3_PatientIdentifierList(0).getIDNumber().parse(Integer.toString(patient.getPatID())); + pidSegment.getPid5_PatientName(0).getFamilyName().getSurname().parse(patient.getNachname()); + pidSegment.getPid5_PatientName(0).getGivenName().parse(patient.getVorname()); + pidSegment.getPid7_DateTimeOfBirth().getTime().setValue(Date.from(patient.getGeburtsdatum().atStartOfDay().atZone(ZoneId.systemDefault()).toInstant())); + pidSegment.getPid8_AdministrativeSex().parse(patient.getGeschlecht().toString()); + pidSegment.getPid11_PatientAddress(0).getStreetAddress().getStreetName().parse(patient.getStrasse()); + pidSegment.getPid11_PatientAddress(0).getStreetAddress().getDwellingNumber().parse(patient.getHausnummer()); + pidSegment.getPid11_PatientAddress(0).getCity().parse(patient.getOrt()); + pidSegment.getPid13_PhoneNumberHome(0).getTelephoneNumber().parse(patient.getTelefon()); + pidSegment.getPid16_MaritalStatus().getAlternateIdentifier().parse(patient.getFamilienstand().toString()); //Diagnosen - List diagnosen = getDiagnosenByFall ( fall ); - diagnosen.add(fall.getHauptDiagnose ()); - PV1 pv1Segment = adt.getPV1 (); - pv1Segment.getPv12_PatientClass ().parse ( "U" ); - if(!diagnosen.isEmpty ()) { - int i =1; + List diagnosen = getDiagnosenByFall(fall); + diagnosen.add(fall.getHauptDiagnose()); + PV1 pv1Segment = adt.getPV1(); + pv1Segment.getPv12_PatientClass().parse("U"); + if (!diagnosen.isEmpty()) { + int i = 1; DG1 dg1Segment; for (Diagnose diagnose : diagnosen) { - dg1Segment = adt.getDG1 ( (i) ); - dg1Segment.getDg11_SetIDDG1 ().parse ( String.valueOf ( i ) ); - dg1Segment.getDg13_DiagnosisCodeDG1 ().getIdentifier ().parse ( diagnose.getIcd10code ().getCode () ); + dg1Segment = adt.getDG1(i - 1); + dg1Segment.getDg11_SetIDDG1().parse(String.valueOf(i)); + dg1Segment.getDg13_DiagnosisCodeDG1().getIdentifier().parse(diagnose.getIcd10code().getCode()); // dg1Segment.getDg116_DiagnosingClinician ()[0].parse ( diagnose.getArzt ().getEinweisenderArzt () ); - dg1Segment.getDg14_DiagnosisDescription ().parse ( diagnose.getFreiText () ); - dg1Segment.getDg16_DiagnosisType ().parse ( diagnose.getDiagArt ().toString () ); + dg1Segment.getDg14_DiagnosisDescription().parse(diagnose.getFreiText()); + dg1Segment.getDg16_DiagnosisType().parse(diagnose.getDiagArt().toString()); i++; //Segment 2 Verschluesselung ? } @@ -99,16 +101,16 @@ public class HL7Sender { } - private static void sendMessage(Message message) { + private static void sendMessage(Message message) throws HL7Exception { /* * The following section of code establishes a server listening * on port 1011 for new connections, and then "handles" them by */ - if(message instanceof ADT_A01) { + if (message instanceof ADT_A01) { ADT_A01 adt = (ADT_A01) message; int port = Main.OPS_PORT; - HapiContext context = new DefaultHapiContext (); - HL7Service server = context.newServer ( port, false ); + HapiContext context = new DefaultHapiContext(); + HL7Service server = context.newServer(port, false); /* @@ -119,54 +121,67 @@ public class HL7Sender { // A connection object represents a socket attached to an HL7 server Connection connection = null; try { - connection = context.newClient ( Main.OPS_IP, port, false); + connection = context.newClient(Main.OPS_IP, port, false); } catch (HL7Exception e) { - e.printStackTrace (); + e.printStackTrace(); } // The initiator is used to transmit unsolicited messages - Initiator initiator = connection.getInitiator (); + Initiator initiator = connection.getInitiator(); Message response = null; + HL7LogEntry messageEntry = new HL7LogEntry(); + messageEntry.setMessage(message.encode()); + messageEntry.setSource("127.0.0.1:1234"); // TODO: naja... + messageEntry.setDirection(HL7LogEntry.Direction.OUT); + messageEntry.setTimestamp(LocalDateTime.now()); + HL7Util.logHL7MessageToDatabase(messageEntry); try { - while (! (response instanceof ACK)) { - response = initiator.sendAndReceive ( adt ); - Thread.sleep ( 5000 ); + while (!(response instanceof ACK)) { + response = initiator.sendAndReceive(adt); + Thread.sleep(5000); } } catch (HL7Exception e) { - e.printStackTrace (); + e.printStackTrace(); } catch (LLPException e) { - e.printStackTrace (); + e.printStackTrace(); } catch (IOException e) { - e.printStackTrace (); + e.printStackTrace(); } catch (InterruptedException e) { - e.printStackTrace (); + e.printStackTrace(); } + + HL7LogEntry responseEntry = new HL7LogEntry(); + responseEntry.setMessage(response.encode()); + responseEntry.setSource(Main.OPS_IP + ":" + Main.OPS_PORT); + responseEntry.setDirection(HL7LogEntry.Direction.IN); + responseEntry.setTimestamp(LocalDateTime.now()); + HL7Util.logHL7MessageToDatabase(responseEntry); + /* * Close the connection when you are done with it. */ - connection.close (); + connection.close(); // Stop the receiving server and client - server.stop (); + server.stop(); } } - - /** * gibt erzeugte hl7 Nachricht auf der Konsole aus (Kann nach Debug phase wieder geloescht werden) + * * @param msg * @throws HL7Exception */ public void printXMLEncodedMessageADT(Message msg) throws HL7Exception, IOException { - HapiContext context = new DefaultHapiContext (); + HapiContext context = new DefaultHapiContext(); Parser parser = context.getXMLParser(); String encodedMessage = parser.encode(msg); LocalDateTime ldt = LocalDateTime.now(); - File file = new File("ADTA01Messafge" +LocalDateTime.now().toString() +"xml" ); + File file = new File("ADTA01Messafge" + LocalDateTime.now().toString() + "xml"); if (!file.exists()) { file.createNewFile(); } @@ -174,9 +189,8 @@ public class HL7Sender { BufferedWriter bw = new BufferedWriter(fw); bw.write(encodedMessage); bw.close(); - System.out.println (encodedMessage); + System.out.println(encodedMessage); } - }