浏览代码

Merge remote-tracking branch 'origin/master'

master
Johannes Oehm 10 年前
父节点
当前提交
a064b3a708
共有 2 个文件被更改,包括 13 次插入4 次删除
  1. +8
    -1
      src/main/java/de/uniluebeck/mi/projmi6/hapi/HL7Receiver.java
  2. +5
    -3
      src/main/java/de/uniluebeck/mi/projmi6/hapi/HL7Sender.java

+ 8
- 1
src/main/java/de/uniluebeck/mi/projmi6/hapi/HL7Receiver.java 查看文件

@@ -70,7 +70,14 @@ public class HL7Receiver<T extends AbstractMessage> implements ReceivingApplicat


private Message generateACKWithAR(Message message, String s) throws HL7Exception { private Message generateACKWithAR(Message message, String s) throws HL7Exception {
try { try {
return message.generateACK(AcknowledgmentCode.AR, new HL7Exception(s, ErrorCode.UNKNOWN_KEY_IDENTIFIER));
Message returnMessage = message.generateACK(AcknowledgmentCode.AR, new HL7Exception(s, ErrorCode.UNKNOWN_KEY_IDENTIFIER));
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) { } catch (IOException e) {
throw new HL7Exception(e); throw new HL7Exception(e);
} }


+ 5
- 3
src/main/java/de/uniluebeck/mi/projmi6/hapi/HL7Sender.java 查看文件

@@ -23,7 +23,9 @@ import java.util.Date;
import java.util.List; import java.util.List;


/** /**
* Manages all HL7 sending tasks. This includes: creating a message, sending the message,
* Created by taschi on 22.11.15. * Created by taschi on 22.11.15.
*
*/ */
public class HL7Sender { public class HL7Sender {


@@ -32,7 +34,7 @@ public class HL7Sender {
* *
* *
* @param fall to create the message from this content. patient and diagnosis are linked to fall * @param fall to create the message from this content. patient and diagnosis are linked to fall
* @throws Exception
* @throws HL7Exception, IOException, SQLException
*/ */
public static void createMessageADT_A01(Fall fall) throws HL7Exception, IOException, SQLException { public static void createMessageADT_A01(Fall fall) throws HL7Exception, IOException, SQLException {
Patient patient = fall.getPatient(); Patient patient = fall.getPatient();
@@ -93,7 +95,7 @@ public class HL7Sender {


/** /**
* Sending message handler. Calls function to send current message * Sending message handler. Calls function to send current message
* @param message
* @param message to send
* @throws HL7Exception * @throws HL7Exception
*/ */
private static void sendMessage(Message message) throws HL7Exception { private static void sendMessage(Message message) throws HL7Exception {
@@ -126,7 +128,7 @@ public class HL7Sender {
HL7LogEntry responseEntry = new HL7LogEntry(); HL7LogEntry responseEntry = new HL7LogEntry();


messageEntry.setMessage(message.encode()); messageEntry.setMessage(message.encode());
messageEntry.setSource("127.0.0.1:1234"); // TODO: Kann man den lokal genutzen Port raus finden?
messageEntry.setSource("127.0.0.1:1234");
messageEntry.setDirection(HL7LogEntry.Direction.OUT); messageEntry.setDirection(HL7LogEntry.Direction.OUT);
messageEntry.setTimestamp(LocalDateTime.now()); messageEntry.setTimestamp(LocalDateTime.now());
messageEntry.setTimestamp(HL7Utils.parseLocalDateTime(adt_a01.getMSH().getDateTimeOfMessage().getTime())); messageEntry.setTimestamp(HL7Utils.parseLocalDateTime(adt_a01.getMSH().getDateTimeOfMessage().getTime()));


正在加载...
取消
保存