本文整理汇总了Java中ca.uhn.hl7v2.llp.MinLowerLayerProtocol类的典型用法代码示例。如果您正苦于以下问题：Java MinLowerLayerProtocol类的具体用法？Java MinLowerLayerProtocol怎么用？Java MinLowerLayerProtocol使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
MinLowerLayerProtocol类属于ca.uhn.hl7v2.llp包，在下文中一共展示了MinLowerLayerProtocol类的5个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: createPatient
import ca.uhn.hl7v2.llp.MinLowerLayerProtocol; //导入依赖的package包/类
protected void createPatient(String patientId) throws Exception {
if (!validatePatient)
return ;
patientId = patientId.replace("&", "&");
//If it is a valid patient, then no need to re-create.
if (isValidPatient(patientId))
return;
String msg = "MSH|^~\\&|OTHER_KIOSK|HIMSSSANDIEGO|PAT_IDENTITY_X_REF_MGR_MISYS|ALLSCRIPTS|20090512132906-0300||ADT^A04^ADT_A01|7723510070655179915|P|2.3.1\r" +
"EVN||20090512132906-0300\r" +
"PID|||"+ patientId +"||FARNSWORTH^STEVE||19781208|M|||820 JORIE BLVD^^CHICAGO^IL^60523\r" +
"PV1||O|";
PipeParser pipeParser = new PipeParser();
Message adt = pipeParser.parse(msg);
ConnectionHub connectionHub = ConnectionHub.getInstance();
Connection connection = connectionHub.attach(hostName, pixRegistryPort, new PipeParser(), MinLowerLayerProtocol.class);
Initiator initiator = connection.getInitiator();
Message response = initiator.sendAndReceive(adt);
String responseString = pipeParser.encode(response);
System.out.println("Received response:\n" + responseString);
MSA msa = (MSA)response.get("MSA");
assertEquals("AA", msa.getAcknowledgementCode().getValue());
}
开发者ID:jembi，项目名称:openxds，代码行数:25，代码来源:XdsTest.java
示例2: SendPIX
import ca.uhn.hl7v2.llp.MinLowerLayerProtocol; //导入依赖的package包/类
private void SendPIX(String msg) throws Exception {
PipeParser pipeParser = new PipeParser();
Message adt = pipeParser.parse(msg);
ConnectionHub connectionHub = ConnectionHub.getInstance();
Connection connection = connectionHub.attach(hostName, pixRegistryPort, new PipeParser(), MinLowerLayerProtocol.class);
Initiator initiator = connection.getInitiator();
Message response = initiator.sendAndReceive(adt);
String responseString = pipeParser.encode(response);
System.out.println("Received response:\n" + responseString);
MSA msa = (MSA)response.get("MSA");
assertEquals("AA", msa.getAcknowledgementCode().getValue());
}
开发者ID:jembi，项目名称:openxds，代码行数:13，代码来源:MergePatientTest.java
示例3: doConfigure
import ca.uhn.hl7v2.llp.MinLowerLayerProtocol; //导入依赖的package包/类
private void doConfigure()
{
try
{
app = (Application)(Class.forName(cfg.getApplicationClassName()).newInstance());
}
catch(Exception e)
{
throw new RuntimeException("Failed to load HL7 Nas Application", e);
}
server = new SimpleServer(cfg.getPort(), new MinLowerLayerProtocol(), new GenericParser());
//PMI ADT Messages handled
server.registerApplication(MsgTypes.ADT, EvnCodes.A01, app); //Admit Patient
server.registerApplication(MsgTypes.ADT, EvnCodes.A02, app); //Transfer Patient
server.registerApplication(MsgTypes.ADT, EvnCodes.A03, app); //Discharge Patient
server.registerApplication(MsgTypes.ADT, EvnCodes.A04, app); //Discharge Patient
server.registerApplication(MsgTypes.ADT, EvnCodes.A05, app); //Pre-admit/book
server.registerApplication(MsgTypes.ADT, EvnCodes.A08, app); //Update Patient Information
server.registerApplication(MsgTypes.ADT, EvnCodes.A11, app); //Cancel Patient Admit
server.registerApplication(MsgTypes.ADT, EvnCodes.A12, app); //Cancel Transfer
server.registerApplication(MsgTypes.ADT, EvnCodes.A13, app); //Cancel Patient Discharge
server.registerApplication(MsgTypes.QRY, EvnCodes.A19, app); //Patienty Query
server.registerApplication(MsgTypes.ADT, EvnCodes.A23, app); //Register Patient
server.registerApplication(MsgTypes.ADT, EvnCodes.A28, app); //Register Patient
server.registerApplication(MsgTypes.ADT, EvnCodes.A29, app); //Delete Patient
server.registerApplication(MsgTypes.ADT, EvnCodes.A31, app); //Update Patient
server.registerApplication(MsgTypes.ADT, EvnCodes.A34, app); //Merge Patient
server.registerApplication(MsgTypes.ADT, EvnCodes.A38, app); //Cancel Transfer
server.registerApplication(MsgTypes.ADT, EvnCodes.A40, app); //Merge Patient
server.registerApplication(MsgTypes.ADT, EvnCodes.A47, app); //Update IDs
server.registerApplication(MsgTypes.ADT, EvnCodes.A60, app); //Allergy
//MFN
server.registerApplication(MsgTypes.MFN, EvnCodes.M01, app); //Lookups Master File Message
server.registerApplication(MsgTypes.MFN, EvnCodes.M02, app);
server.registerApplication(MsgTypes.MFN, EvnCodes.M05, app);
//ORU
server.registerApplication(MsgTypes.ORU, EvnCodes.R01, app); //Observation Reporting
//SIU
server.registerApplication(MsgTypes.SIU, EvnCodes.S12, app);
server.registerApplication(MsgTypes.SIU, EvnCodes.S13, app);
server.registerApplication(MsgTypes.SIU, EvnCodes.S14, app);
server.registerApplication(MsgTypes.SIU, EvnCodes.S15, app);
server.registerApplication(MsgTypes.SIU, EvnCodes.S26, app);
server.registerApplication(MsgTypes.ACK, "*", app); //ACK Message
}
开发者ID:oopcell，项目名称:AvoinApotti，代码行数:50，代码来源:HL7NasListener.java
示例4: doConfigure
import ca.uhn.hl7v2.llp.MinLowerLayerProtocol; //导入依赖的package包/类
private void doConfigure() throws Exception
{
cfg = new HL7Config();
app = new HL7EngineApplication(cfg);
server = new SimpleServer(cfg.getPort(), new MinLowerLayerProtocol(), ((HL7EngineApplication)app).getParser());
//PMI ADT Messages handled
server.registerApplication(MsgTypes.ADT, EvnCodes.A28, app); //Register Patient
server.registerApplication(MsgTypes.ADT, EvnCodes.A31, app); //Update Patient
server.registerApplication(MsgTypes.ADT, EvnCodes.A29, app); //Delete Patient
server.registerApplication(MsgTypes.ADT, EvnCodes.A47, app); //Update Patient ID Numbers
server.registerApplication(MsgTypes.ADT, EvnCodes.A34, app); //Patient Merge
server.registerApplication(MsgTypes.ADT, EvnCodes.A40, app); //Patient Merge
//INPATIENT ADT Messages handled
server.registerApplication(MsgTypes.ADT, EvnCodes.A01, app); //Admit a Patient
server.registerApplication(MsgTypes.ADT, EvnCodes.A02, app); //Transfer a Patient
server.registerApplication(MsgTypes.ADT, EvnCodes.A03, app); //Discharge a Patient
server.registerApplication(MsgTypes.ADT, EvnCodes.A08, app); //Update Admission/Discharge details
server.registerApplication(MsgTypes.ADT, EvnCodes.A10, app); //PATIENT ARRIVING - TRACKING
server.registerApplication(MsgTypes.ADT, EvnCodes.A11, app); //Delete an Admission
server.registerApplication(MsgTypes.ADT, EvnCodes.A12, app); //Delete a Transfer
server.registerApplication(MsgTypes.ADT, EvnCodes.A13, app); //Delete a Discharge
server.registerApplication(MsgTypes.ADT, EvnCodes.A21, app); //Send on leave
server.registerApplication(MsgTypes.ADT, EvnCodes.A22, app); //Return from leave
server.registerApplication(MsgTypes.ADT, EvnCodes.A52, app); //Delete on leave
server.registerApplication(MsgTypes.ADT, EvnCodes.A53, app); //Delete on leave
server.registerApplication(MsgTypes.ADT, EvnCodes.A60, app); //Allergy messages
//OUTPATIENT ADT Messages handled
server.registerApplication(MsgTypes.ADT, EvnCodes.A05, app); //Book an Appointment
server.registerApplication(MsgTypes.ADT, EvnCodes.A04, app); //Record an Arrival
server.registerApplication(MsgTypes.ADT, EvnCodes.A38, app); //Cancel an Appointment
//OCS RESULTS ORU Messages Handled
server.registerApplication(MsgTypes.ORU, EvnCodes.R01, app); //Order Observation/Result
server.registerApplication(MsgTypes.ORR, EvnCodes.R01, app); //Order Response
server.registerApplication(MsgTypes.ORR, EvnCodes.O02, app); //General Order Response
//OCS ORDER Messages Handles
server.registerApplication(MsgTypes.ORM, EvnCodes.O01, app); //Used for Order Updates
server.registerApplication(MsgTypes.OMG, EvnCodes.O19, app); //Used for General Order Updates
server.registerApplication(MsgTypes.ORG, EvnCodes.O20, app); //Used for Gen Clinical Order Response
server.registerApplication(MsgTypes.RDS, EvnCodes.O13, app);
//Master Files
server.registerApplication(MsgTypes.MFN, EvnCodes.M01, app); //lOOKUPS
server.registerApplication(MsgTypes.MFN, EvnCodes.M02, app); //GP and Consultant Master File messages
server.registerApplication(MsgTypes.MFN, EvnCodes.M05, app); //Ward and Clinic Master File messages
// Patient Pathways
server.registerApplication(MsgTypes.PPG, EvnCodes.PCG, app); // Patient Pathway - Goal Oriented
server.registerApplication(MsgTypes.RDS, EvnCodes.O13, app);
// Referral Messages WDEV-11723
server.registerApplication(MsgTypes.REF, EvnCodes.I12, app);
server.registerApplication(MsgTypes.REF, EvnCodes.I13, app);
server.registerApplication(MsgTypes.REF, EvnCodes.I14, app);
server.registerApplication("ACK", "*", app); //ACK Message
//WDEV-6776
try{
if (ocsIfInbound == null)
{
ocsIfInbound = (OcsIfInbound) getDomainImpl("ims.ocs_if.domain.impl.OcsIfInboundImpl");
}
}
catch (Exception e)
{
throw new RuntimeException("Exception occurred creating ocsIfInbound instance - " + e.getMessage(), e);
}
}
开发者ID:oopcell，项目名称:AvoinApotti，代码行数:77，代码来源:HL7EngineListener.java
示例5: Enviar
import ca.uhn.hl7v2.llp.MinLowerLayerProtocol; //导入依赖的package包/类
public boolean Enviar() throws HL7Exception, LLPException, IOException{
int num=0;
for(RecepcionPrestaciones rp : this.recepcion.getRecepcionPrestaciones()){
//Se crea un tipo de dato segun el mensaje, en este caso ORM^O01
ORM_O01 orm = new ORM_O01();
/***************************************************************************************************************/
MSH MSH = orm.getMSH();
MSH.getFieldSeparator().setValue("|");
MSH.getEncodingCharacters().setValue("^~\\&");
MSH.getSendingApplication().getNamespaceID().setValue("EIMSRISV1");
MSH.getSendingFacility().getNamespaceID().setValue(""+this.getRecepcion().getDerivador().getId());
MSH.getDateTimeOfMessage().getDay();
MSH.getMessageType().getMessageCode().setValue("ORM");
MSH.getMessageType().getTriggerEvent().setValue("O01");
MSH.getMessageControlID().setValue(""+this.getRecepcion().getId());
MSH.getProcessingID().getProcessingID().setValue("P");
MSH.getVersionID().getVersionID().setValue("2.6");
ORM_O01_PATIENT PAT = orm.getPATIENT();
PAT.getPID().getSetIDPID();
PAT.getPID().getPatientID().getIDNumber().setValue(this.getRecepcion().getPaciente().getRUN());
PAT.getPID().insertPid3_PatientIdentifierList(0).getCx1_IDNumber().setValue(""+this.getRecepcion().getPaciente().getId());
PAT.getPID().getPatientName(0).getFamilyName().getSurname().setValue(this.getRecepcion().getPaciente().getAPaterno()+
" "+this.getRecepcion().getPaciente().getAMaterno());
PAT.getPID().getPatientName(0).getGivenName().setValue(this.getRecepcion().getPaciente().getNombre());
//PAT.getPID().getDateTimeOfBirth().setValue(this.getRecepcion().getPaciente().getFechaNacimiento().toString("yyyyMMdd"));
PAT.getPID().getAdministrativeSex().setValue(this.getRecepcion().getPaciente().getSexo());
PAT.getPID().getPatientAddress(0).getStreetAddress().getStreetOrMailingAddress().setValue(this.getRecepcion().getPaciente().getDireccion());
PAT.getPID().getPatientAddress(0).getCity().setValue(this.getRecepcion().getPaciente().getCiudad().getDescripcion());
ORM_O01_ORDER segmentoORDEN = orm.getORDER();
segmentoORDEN.getORC().getOrc1_OrderControl().setValue("NW");
segmentoORDEN.getORC().getPlacerOrderNumber().getEntityIdentifier().setValue(""+rp.getResponsable().getId());
segmentoORDEN.getORC().getFillerOrderNumber().getEntityIdentifier().setValue(rp.getPrestacion().getId());
segmentoORDEN.getORC().getEnteredBy(0).getIDNumber().setValue(this.getRecepcion().getUsuario());
segmentoORDEN.getORC().getOrderingProvider(0).getIDNumber().setValue(this.getRecepcion().getResponsable().getIniciales());
segmentoORDEN.getORC().getOrderingProvider(0).getFamilyName().getSurname().setValue(this.getRecepcion().getResponsable().getAPaterno());
segmentoORDEN.getORC().getOrderingProvider(0).getGivenName().setValue(this.getRecepcion().getResponsable().getNombre());
segmentoORDEN.getORC().getOrderingProvider(0).getPrefixEgDR().setValue(this.getRecepcion().getResponsable().getProfesion().getAbreviacion());
segmentoORDEN.getORC().getEntererSLocation().getPointOfCare().setValue(""+this.getRecepcion().getIDCitacion());
ORM_O01_ORDER_DETAIL segmentoORDEND = orm.getORDER().getORDER_DETAIL();
segmentoORDEND.getOBR().getObr2_PlacerOrderNumber().getEi1_EntityIdentifier().setValue("EIMSRIS");
segmentoORDEND.getOBR().getObr4_UniversalServiceIdentifier().getText().setValue(rp.getPrestacion().getDescripcion());
segmentoORDEND.getOBR().getObr4_UniversalServiceIdentifier().getNameOfCodingSystem().setValue(""+
rp.getPrestacion().getRRFFxDefecto().getId());
segmentoORDEND.getOBR().getObr4_UniversalServiceIdentifier().getAlternateIdentifier().setValue(rp.getPrestacion().getDescripcion());
segmentoORDEND.getOBR().getObr18_PlacerField1().setValue(""+this.getRecepcion().getId());
segmentoORDEND.getOBR().getObr19_PlacerField2().setValue(this.getRecepcion().getId()+""+rp.getPrestacion().getId());
segmentoORDEND.getOBR().getObr20_FillerField1().setValue(rp.getPrestacion().getId());
segmentoORDEND.getOBR().getObr24_DiagnosticServSectID().setValue(rp.getPrestacion().getRRFFxDefecto().getModalidad().getDescripcion());
segmentoORDEND.getOBR().getObr44_ProcedureCode().getText().setValue(rp.getPrestacion().getDescripcion());
segmentoORDEND.getOBR().getObr44_ProcedureCode().getCne1_Identifier().setValue(rp.getPrestacion().getId());
segmentoORDEN.getMessage().addNonstandardSegment("ZDS");
Terser t = new Terser(orm);
t.set("ZDS-1-1","1.2.826.0.1.3680043.9.88");
Parser parser = new PipeParser();
String encodedMessage = parser.encode(orm);
String original = "áàäéèëíìïóòöúùuñÁÀÄÉÈËÍÌÏÓÒÖÚÙÜÑçÇ";
String ascii = "aaaeeeiiiooouuunAAAEEEIIIOOOUUUNcC";
String output = encodedMessage;
for (int i=0; i<original.length(); i++) {
output = output.replace(original.charAt(i), ascii.charAt(i));
}
System.out.println("Printing ER7 Encoded Message:");
System.out.println(output);
Parser p = new GenericParser();
Message adt = parser.parse(output);
ConnectionHub connectionHub = ConnectionHub.getInstance();
// A connection object represents a socket attached to an HL7 server
Connection connection = connectionHub.attach("localhost", port, new PipeParser(), MinLowerLayerProtocol.class);
// The initiator is used to transmit unsolicited messages
Initiator initiator = connection.getInitiator();
Message response = initiator.sendAndReceive(adt);
String responseString = parser.encode(response);
System.out.println("Received response:\n" + responseString);
// Close the connection
//....
connection.close();
//connection2.close();
num++;
}
return false;
}
开发者ID:avenda，项目名称:miniRIS，代码行数:82，代码来源:HL7Message.java
注：本文中的ca.uhn.hl7v2.llp.MinLowerLayerProtocol类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论