互联互通数据推送
1.需求的产生
医院信息互联互通测评的项目应用评价分为七个等级，由低到高依次为一级、二级、三级、四级乙等、四级甲等、五级乙等、五级甲等，每个等级的要求由低到高逐级覆盖累加，即较高等级包含较低等级的全部要求。因此通常只要需要评级的医院，都离不开做互联互通，使用平台对医院的数据进行联网。因此，就有了下面的需求，完成与平台的互联互通。
需求是基于治疗数据，推送给平台，使用xml对数据进行组装，同时进行加密，里面包含所有的治疗数据与pdf，而生成是在完成治疗后进行数据的推送。这个过程是实时的，因此就需要考虑性能的问题，同时不能影响主流程。因此使用异步进行数据的推送，同时对生成的pdf需要进行加密，放入xml中。而提前的数据信息使用并行流的方式对数据进行组装。这里主要解决推送过程的方式。下面是最近的需求和解决的思路和方式。
2.推送的类型
通常医院的数据推送分为两类：一类是和医院his、lis以及影像资料对接对接的数据，一类是和平台对接的数据。通常和医院对接的数据通常是规则的，同时数据可以采用MQ或者webservice进行对接,比如医嘱对接使用MQ进行对接。而和平台对接，通常是患者的治疗数据和pdf记录单等，此类数据通常使用webService的soap进行推送。
3.推送过程思路
而这类数据通常是在xml中进行，因为推送的数据除了患者的基本治疗数据外和包含了一个pdf的信息，通常采用HL7协议进行数据的组装，此时就会涉及到对患者数据的组装，而组装的过程中，通常是在患者治疗下机后，就会产生记录单信息，而产生记录单信息的同时还需要对其进行pdf的生成，而生成后，根据生成的pdf路径，对pdf进行base64加密，然后在自定义的xml中组装节点元素，然后推送给平台，根据平台返回的想要信息，获取节点中返回的响应，然后进行确认，类似于ack确认；如果推送失败，则进行失败重试，如果重试失败，则将失败的信息记录到日志中，方便查看，然后进行人工干预，将数据进行手动推送。由于通常平台是根据国家要求，通常会使用基于卫生部的规范进行数据的cda规范推送。
4.推送的内容
而推送的过程包含两部分：一部分是注册xml信息，通常是由平台提供样例，然后根据样例进行xml节点元素的组装，另一部分是需要推送的数据信息，通常会包含两部分：一部分是患者的信息和患者的资料所有信息，采用soap方式进行推送。
5.推送的方式
下图是推送的数据方式：
推送过平台的数据，通常平台会根据我们推送的数据，进行解析，通常会根据我们提供的治疗所有信息的样例，进行平台代码的编写，或者根据我们提供的治疗消息样例，进行修改，然后推送他们想要的数据。
为了方便消息丢失问题的出现，这里需要将我们的失败日志信息写入到数据库中，夜间根据失败的日志数据进行重推到平台中，防止我们推送的数据丢失的情况。
推送并响应：
由于不同医院选择的互联互通的第三方平台，因此互联互通方案也会存在一定的差异性。
6.接口信息
平台那边需要的数据：
从里面我们可以看到平台需要的接口信息、接口名称、接口方法、参数信息、要发送的消息、返回信息。
根据他们提供的消息样例组装xml信息，然后进行推送。
cda文档类型，下面截图部分：
以上只是一部分，而这些cda的数据，通常都是医院的不同系统建立起来的。
对于推送，里面最重要的就是message，上面提到的参数里面。
也即我们想在需要做的就是将消息中需要的信息拿到，然后根据拿到的信息进行组装：
通常组装的xml中：下面截取xml中的一小部分内容,下面的数据有修改。
<RCMR_IN000002UV02 ITSVersion="XML_1.0" xmlns="urn:hl7-org:v3" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="urn:hl7-org:v3 ../multicacheschemas/RCMR_IN000002UV02.xsd">
<id root="3.2.5.1.1" extension="200200000000728"></id>
<creationTime value="20210430165413"></creationTime>
<interactionId root="3.2.5.1.2" extension="RCMR_IN000002UV02"></interactionId>
<processingCode code="P"></processingCode>
<processingModeCode></processingModeCode>
<acceptAckCode code="AL"></acceptAckCode>
<receiver typeCode="RCV">
...
</receiver>
<sender typeCode="SND">
...
</sender>
<controlActProcess classCode="STC" moodCode="APT">
<subject typeCode="SUBJ">
<clinicalDocument classCode="DOCCLIN" moodCode="EVN">
<id>
<item root="3.2.5.1.24" extension="900200000000728"></item>
</id>
<code code="EMR-SD-08" codeSystem="3.2.5.1.23" codeSystemName="文档类型代码">
<displayName value="治疗记录"></displayName>
</code>
...
<versionNumber value="1"></versionNumber>
<storageCode>
<!--需要存储的加密信息 -->
<originalText value=""></originalText>
<translation></translation>
</storageCode>
...
</clinicalDocument>
...
</subject>
</controlActProcess>
</RCMR_IN000002UV02>
而组装的方式可以是采用最为直接的stringbuffer进行组装，但是这样的话，容易产生硬编码的现象，同时扩展性的话，不够直接，但是如果是采用节点组装的方式，这样的话，下次进行扩展的时候会方便一些。其实xml的组装在安卓用得比较多。组装的方式采用xml属性和xml元素的方式进行组装，通常属性是xml标签里面的属性信息，而xml元素则是可以放入元素+属性信息，从而进行进一步的节点组装。同时我发现如果他们提供的样例如果节点设置并列关系多一点，数据结构的组装会方便很多，但是当时他们提供的组装样例麻烦，因此写出来的组装相对来说，嵌套会多一些。
@XmlAccessorType(XmlAccessType.FIELD)
@XmlRootElement(name = "RCMR_IN000002UV02", namespace = "urn:hl7-org:v3")
public class RCMR_IN000002UV02 {
@XmlAttribute(name = "xmlns")
public String xmlns = "urn:hl7-org:v3";
@XmlAttribute(name = "xmlns:xsi")
public String xsi = "http://www.w3.org/2001/XMLSchema-instance";
@XmlAttribute(name = "xsi:schemaLocation")
public String schemaLocation = "urn:hl7-org:v3 ../multicacheschemas/RCMR_IN000002UV02.xsd";
@XmlElement(name = "id")
public NodeAttr id;
@XmlElement(name = "creationTime")
public NodeAttr creationTime;
@XmlElement(name = "interactionId")
public NodeAttr interactionId;
...
// 省略get/set
}
属性信息使用 @XmlAttribute和元素信息@XmlElement对元素关系和元素结构进行组装，然后就可以构建好自定义的xml。
组装完数据，接着是对平台响应的xml信息进行获取，然后进行确认，如果成功，则不做处理，如果失败，则将失败的患者治疗id信息和治疗时间进行记录，存入失败表中，然后在晚上使用定时任务将失败的数据信息进行同步。除此之外，还将失败的数据信息打到日志管理界面中，日志管理界面通常会保存两个星期的审计日志数据。同时提供界面给实施人员进行下载，方便排查问题和反馈给开发进行解决。
<acceptAckCode code="AL"/>
<receiver typeCode="RCV">
<device classCode="DEV" determinerCode="INSTANCE">
....
</device>
</receiver>
<sender typeCode="SND">
<device classCode="DEV" determinerCode="INSTANCE">
....
</device>
</sender>
<!-- 处理结果，比如AA是成功，AF是失败 -->
<acknowledgement typeCode="AA">
<!--请求消息 ID-->
<targetMessage>
<id root="3.2.5.1.1" extension="请求的消息 ID"/>
</targetMessage>
<!-- 处理结果说明 -->
<acknowledgementDetail>
<text value="处理结果说明"/>
</acknowledgementDetail>
</acknowledgement>
</MCCI_IN000002UV01>
这里可以基于其返回的处理结果，进行确认对方是否收到了发过去的数据，这个结果类似于我们进行手动ack确认的依据。此时拿到处理结果：
Document doc = DocumentHelper.parseText(s);
Element root = doc.getRootElement();
Element response = root.element("acknowledgement");
//拿到处理结果
response.attribute("typeCode").getValue();
进行判断，从而进行相应的处理。
7.总结
而推送的过程中涉及到治疗信息的pdf生成和加密以及xml的组装，同时将信息放入到xml中过程。为了不影响主流程业务，通常我们会使用异步的方式进行消息的推送，因此我们这里使用线程池对其进行推送，数据的获取使用并行流的方式。