Senden von ADT A01 möglich.

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<Diagnose> diagnosen = getDiagnosenByFall ( fall );
-        diagnosen.add(fall.getHauptDiagnose ());
-        PV1 pv1Segment = adt.getPV1 ();
-        pv1Segment.getPv12_PatientClass ().parse ( "U" );
-        if(!diagnosen.isEmpty ()) {
-            int i =1;
+        List<Diagnose> 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);
     }
 
 
-
 }