panates / hl7v2 Goto Github PK

   const testHL7 = async(body) => {
   const DEFAULT_VERSION = "2.5";
   const msg = new HL7Message({version: DEFAULT_VERSION});

   let segMSH = msg.add("MSH");
   segMSH._fields[1]._data = "^~\\&";  // Encoding Characters
   segMSH._fields[2]._data = "EVAS";  // Sending Application
   segMSH._fields[3]._data = "KKK";  // Sending Facility
   segMSH._fields[4]._data = "DCM4CHEE";  // Receiving Application
   segMSH._fields[5]._data = "KKK";  // Recieving Facility
   segMSH._fields[6]._data = `${moment2(new Date()).tz("Asia/Taipei").format("YYYYMMDDHHMMSSZ")}^S`;  
   segMSH._fields[8]._data = "OMI^O23^OMI_O23";  // Message Type
   segMSH._fields[9]._data = "YYYMMDD_patient_no_Type";  // Message Control ID  // ??
   segMSH._fields[10]._data = "T";  // Processing ID, T for training, P for production, D for debugging
   segMSH._fields[11]._data = "2.5";  //Version ID
   segMSH._fields[17]._data = "UNICODE UTF-8";
   
   let segPID = msg.add("PID");
   segPID._fields[1]._data = "patient_no_903874";  // Patient ID -> 病例號
   segPID._fields[2]._data = "K223984446";  // Alternate Patient ID - PID -> 存放病例號
   segPID._fields[4]._data = "林美惠";  // Patient Name -> PID.5.2: Given Name
   segPID._fields[6]._data = `${moment2(new Date("1955-01-23")).tz("Asia/Taipei").format("YYYYMMDDZ")}^D`;  
   segPID._fields[7]._data = "F";  // Sex

   let segPV1 = msg.add("PV1");
   segPV1._fields[1]._data = "O";  // Patient Class -> O stands for Outpatient

   let segORC = msg.add("ORC");
   segORC._fields[0]._data = "NW";  // Order Control, NW stands for New order/service
   // segORC._fields[1]._data = `^IHE_OM_OP^1.3.6.1.4.1.12559.11.1.2.2.4.2^ISO`;  // Placer Order Number
   // segORC._fields[2]._data = `^IHE_OM_OP^1.3.6.1.4.1.12559.11.1.2.2.4.2^ISO`;  // Filler Order Number
   segORC._fields[4]._data = "SC";  // Order Status, SC stands for "In process, scheduled"
   segORC._fields[6]._data = `^20221118&D`;  // Quantity/Timing, ORC.7.4: Start Date/Time

   let segOBR = msg.add("OBR");
   segOBR._fields[1]._data = `^IHE_OM_OP^1.3.6.1.4.1.12559.11.1.2.2.4.2^ISO`;  // Placer Order Number
   // segOBR._fields[2]._data = `^IHE_OM_OP^1.3.6.1.4.1.12559.11.1.2.2.4.2^ISO`;  // Filler Order Number
   segOBR._fields[3]._data = `28017C^coloscopy^Taiwan NHI^2^腸鏡`;  // Universal Service Identifier 
   segOBR._fields[15]._data = `C133225490^doctor name`;  // Ordering Provider 
   segOBR._fields[44]._data = `28017C^coloscopy^Taiwan NHI^2^腸鏡`;  // Procedure Code 

   let segIPC = msg.add("IPC");
   segIPC._fields[4]._data = "ES";  // Modality

   // connection
   const client = new HL7Client();
   client.setKeepAlive(true);
   client.connect(2575, "192.168.0.114")
       .then(() => client.send(msg)
   );

   return;
}

  it('should apply message header timestamp timezone to date fields in other segments', function() {
    const msg = HL7Message.parse('MSH|^~\\&|||||201506301532.123+0300|||||2.5\r' +
        'AL1|1|||||20151231\r');
    const seg = msg.getSegment('AL1');
    assert.deepStrictEqual(seg.IdentificationDate.value, new Date('2015-12-31T00:00:00.000+0300'));
  });

  it('should apply message header timestamp timezone to time fields in other segments', function() {
    const msg = HL7Message.parse('MSH|^~\\&|||||201506301532.123+0300|||||2.5\r' +
    'TQ1||||134523');
    const seg = msg.getSegment('TQ1');
    assert.deepStrictEqual(seg.ExplicitTime.value, new Date('0000-01-01T13:45:23.000+0300'));
  });

  it('should apply message header timestamp timezone to date time fields in other segments', function() {
    const msg = HL7Message.parse('MSH|^~\\&|||||201506301532.123+0300||SIU^S12|||2.5\r' +
        'SCH||||||NW^Booking appointed|||||^^20^20150830080000||||||||||||||||\r');
    const seg = msg.getSegment('SCH');
    assert.deepStrictEqual(seg.AppointmentTimingQuantity[0].StartDateTime.value, new Date('2015-08-30T08:30:00.000+0300'));
  });

    const testHL7 = async() => {
    console.log("testHL7");
    const DEFAULT_VERSION = "2.5.1";
    const msg = new HL7Message({version: DEFAULT_VERSION});

    let segMSH = msg.add("MSH");
    segMSH.FieldSeparator.value = "|";
    segMSH.EncodingCharacters.value = "^~\\&";  // Encoding Characters
    segMSH.SendingApplication.value = "EVAS";  // Sending Application
    segMSH.SendingFacility.value = "Kenkone";  // Sending Facility
    segMSH.ReceivingApplication.value = "DCM4CHEE";  // Receiving Application
    segMSH.ReceivingFacility.value = "dcm4chee-arc";  // Recieving Facility
    segMSH.DateTimeOfMessage.value = `${moment2(new Date()).tz("Asia/Taipei").format("YYYYMMDDHHMMSSZ")}`;  // Date/Time of Message
    segMSH.MessageType.value = "OMI^O23^OMI_O23";  // Message Type
    segMSH.MessageControlId.value = "1111215_903874_2";  // Message Control ID
    segMSH.ProcessingId.value = "T";  // Processing ID, T for training, P for production, D for debugging
    segMSH.VersionId.value = DEFAULT_VERSION;  //Version ID
    // segMSH.CharacterSet.value = "unicodeutf8";  // Try UNICODE UTF8 -> said "Encoding not recognized: 'UNICODE UTF-8'"
    
    let segPID = msg.add("PID");
    segPID.PatientId.value = "K223984446";  // Patient ID -> 身分證字號
    segPID.PatientIdentifierList.value = "903874";  // Patient Identifier List -> 存放病例號
    segPID.PatientName.value = "^林芳芳";  // Patient Name -> PID.5.2: Given Name
    segPID.DateTimeOfBirth.value = `${moment2(new Date("1955-01-23")).tz("Asia/Taipei").format("YYYYMMDDZ")}^D`;  // Date/Time of Birth  // Date/Time of Message //!!時區，時間格式對 PACS 的影響
    console.log("segPID.DateTimeOfBirth.value:", segPID.DateTimeOfBirth.value);
    segPID.AdministrativeSex.value = "F";  // Sex

    let segPV1 = msg.add("PV1");
    segPV1.PatientClass.value = "O";  // Patient Class -> O stands for Outpatient

    let segORC = msg.add("ORC");
    segORC.OrderControl.value = "NW";  // Order Control, NW stands for New order/service
    segORC.OrderStatus.value = "SC";  // Order Status, SC stands for "In process, scheduled"
    segORC.QuantityTiming.value = `^^^20221220&D`;  // Quantity/Timing, ORC.7.4: Start Date/Time

    let segOBR = msg.add("OBR");
    segOBR.OrderingProvider.value = `B205004830^^3`;  // Ordering Provider -> 開單醫師 id
    segOBR.ProcedureCode.value = `28017C^Coloscopy^999NHI`;  // Procedure Code -> 醫令代買

    let segIPC = msg.add("IPC");
    segIPC.AccessionIdentifier.value = "20221215GH937566";  // Accession No
    segIPC.RequestedProcedureId.value = "20221215GH937566";  // Requested Procedure ID
    segIPC.ScheduledProcedureStepId.value = "2";  // Scheduled Procedure Step ID -> 原接醫院的醫令代碼寫在這裡
    segIPC.Modality.value = "ES";  // Modality
    segIPC.ProtocolCode.value = "28017C^Colonscopy^999NHI";  // Protocol Code

    // 連線
    const ev = new EventEmitter();
    // const sockets = new Set();
    // console.log("ev:", ev);
    // console.log("sockets:", sockets);

    let receivedData = [];
    function listenerOnData() {
        if (receivedData.length)
          return Promise.resolve(receivedData.shift());
        return new Promise(resolve => {
          ev.once('data', () => {
            return resolve(receivedData.shift());
          });
        });
      }

    const client = new HL7Client();
    client.setKeepAlive(true);
    client.connect(2575, "192.168.0.109")
        .then(() => console.log("AisConneted:", client.connected))
        .then(() => client.send(msg))
        .then(() => console.log("BisConneted:", client.connected))
        .then(() => listenerOnData()
        .then(data => { console.log(data);})
        .then(() => client.close())
        .then(() => console.log("\(should be closed\)isConneted:", client.connected))
        .catch(e => console.log(e))
    );
    
    console.log("after testHL7 message");
    

    return msg;
    // return (client.connect(2575, '"192.168.0.114"));
}