Browse Source

Schreibe wirklich alle(!) HL7 Nachrichten in die DB. NullPointer abgefangen.

master
Nils Dittberner 10 years ago
parent
commit
3a4947e30f
2 changed files with 14 additions and 2 deletions
  1. +10
    -1
      src/main/java/de/uniluebeck/mi/projmi6/hapi/HL7Receiver.java
  2. +4
    -1
      src/main/java/de/uniluebeck/mi/projmi6/hapi/HL7Sender.java

+ 10
- 1
src/main/java/de/uniluebeck/mi/projmi6/hapi/HL7Receiver.java View File

@@ -71,7 +71,14 @@ public class HL7Receiver<T extends AbstractMessage> implements ReceivingApplicat
*/
private Message generateACK(Message message) throws HL7Exception {
try {
return message.generateACK();
Message returnMessage = message.generateACK();
HL7LogEntry entry = new HL7LogEntry();
entry.setMessage(returnMessage.encode());
entry.setSource("127.0.0.1:1234"); // TODO: Naja...
entry.setTimestamp(LocalDateTime.now());
entry.setDirection(HL7LogEntry.Direction.OUT);
HL7Utils.logHL7MessageToDatabase(entry);
return returnMessage;
} catch (IOException e) {
throw new HL7Exception(e);
}
@@ -176,6 +183,8 @@ public class HL7Receiver<T extends AbstractMessage> implements ReceivingApplicat
hist.setEntlassungsDatum(HL7Utils.parseLocalDateTime(pv1.getDischargeDateTime()[0].getTime()));
}
hist.setFallID(fallid);
hist.setErsteller(99999);
hist.setBearbeiter(99999);

//diagnosis
List<DG1> dg1s = visit.getDG1All();


+ 4
- 1
src/main/java/de/uniluebeck/mi/projmi6/hapi/HL7Sender.java View File

@@ -74,7 +74,10 @@ public class HL7Sender {
pv1.getPv11_SetIDPV1().setValue("1");
pv1.getPv12_PatientClass().setValue("U");
pv1.getPv119_VisitNumber().getIDNumber().setValue(String.valueOf(fall.getFallID()));
pv1.getPv144_AdmitDateTime().getTime().setValue(Date.from(fall.getAufnahmeDatum().atZone(ZoneId.systemDefault()).toInstant()));
// TODO: Was machen wir mit ambulanten?
if (fall.getAufnahmeDatum() != null) {
pv1.getPv144_AdmitDateTime().getTime().setValue(Date.from(fall.getAufnahmeDatum().atZone(ZoneId.systemDefault()).toInstant()));
}

for (int i = 0; i < diagnosen.size(); i++) {
Diagnose diagnose = diagnosen.get(i);


Loading…
Cancel
Save