Merge branch 'master' of zlf/esb into master

Hos-Resource-Rest/pom.xml

@@ -90,7 +90,11 @@
            <artifactId>commons-codec</artifactId>
            <version>1.10</version>
        </dependency>
        <dependency>
            <groupId>com.yihu.core</groupId>
            <artifactId>api-dict</artifactId>
            <version>1.6.0</version>
        </dependency>
        <dependency>
            <groupId>org.apache.commons</groupId>
            <artifactId>commons-collections4</artifactId>

Hos-Resource-Rest/src/main/java/com/yihu/hos/config/CxfConfig.java

@@ -18,7 +18,6 @@ import javax.xml.ws.Endpoint;
@Configuration
public class CxfConfig {
    @Bean
    public ServletRegistrationBean dispatcherRegistration() {
        ServletRegistrationBean registration = new ServletRegistrationBean(dispatcherServlet(), "/*");
@@ -35,8 +34,6 @@ public class CxfConfig {
        return new ServletRegistrationBean(new CXFServlet(), "/service/*");
    }
    @Bean(name = Bus.DEFAULT_BUS_ID)
    public SpringBus springBus() {
        return new SpringBus();

Hos-Resource-Rest/src/main/java/com/yihu/hos/gateway/util/RPCUtil.java

@@ -2,9 +2,14 @@ package com.yihu.hos.gateway.util;
import com.yihu.hos.config.Config;
import com.yihu.openplatform.service.AppKeyService;
import com.yihu.wsgw.api.ServiceBus;
import net.sf.json.JSONObject;
import java.util.Date;
import java.util.HashMap;
import java.util.Map;
import javax.xml.namespace.QName;
/**
 * Created by Administrator on 2016/4/18.
 */
@@ -27,26 +32,26 @@ public class RPCUtil {
     * @param inputValuetype
     * @return
     */
//    public static String getObjectByAxis2CallClient(String webServiceAddr, String webserviceNamespace, String webServiceMethod,
//                                                    Object[] inputValues, Class[] inputValuetype) {
//
//        try {
//            //新建RPC服务客户端
//            RPCServiceClient serviceClient = new RPCServiceClient();
//            Options options = serviceClient.getOptions();
//            //设置URL
//            EndpointReference targetEPR = new EndpointReference(webServiceAddr);
//            options.setTo(targetEPR);
//            //设置参数的类型
//            //设置namespace和方法名
//            QName opAddEntry = new QName(webserviceNamespace, webServiceMethod);
//            //数组的第一个值为返回值
//            return (String) (serviceClient.invokeBlocking(opAddEntry, inputValues, inputValuetype))[0];
//        } catch (Exception e) {
//            e.printStackTrace();
//        }
//        return "";
//    }
   /* public static String getObjectByAxis2CallClient(String webServiceAddr, String webserviceNamespace, String webServiceMethod,
                                                    Object[] inputValues, Class[] inputValuetype) {
        try {
            //新建RPC服务客户端
            RPCServiceClient serviceClient = new RPCServiceClient();
            Options options = serviceClient.getOptions();
            //设置URL
            EndpointReference targetEPR = new EndpointReference(webServiceAddr);
            options.setTo(targetEPR);
            //设置参数的类型
            //设置namespace和方法名
            QName opAddEntry = new QName(webserviceNamespace, webServiceMethod);
            //数组的第一个值为返回值
            return (String) (serviceClient.invokeBlocking(opAddEntry, inputValues, inputValuetype))[0];
        } catch (Exception e) {
            e.printStackTrace();
        }
        return "";
    }*/
    /*
    public static void main(String[] args) throws Exception {
        String apiName = "report.ReportWs.GetReportList";
@@ -80,21 +85,21 @@ public class RPCUtil {
    public static void main(String[] args) {
        String apiName="";
        String param="";
                //获取报告单列表
       // apiName = "ZEUS.HosHOPWs.GetReportList";
        //获取报告单列表
        // apiName = "ZEUS.HosHOPWs.GetReportList";
        //param = "<Req><TransactionCode>5001</TransactionCode><Data><CardType>1</CardType><CardNo>000021341249</CardNo><IdCardNo>352103197603094519</IdCardNo><StartDate>2016-01-01</StartDate><EndDate>2016-04-05</EndDate><Mobile>1885215394</Mobile><PatientName>周春生</PatientName><ReportType>1</ReportType></Data></Req>";
        //检查/检验报告单
       //	apiName = "ZEUS.HosHOPWs.GetReportInfo";
        //	apiName = "ZEUS.HosHOPWs.GetReportInfo";
        //		param = "<Req><TransactionCode>5002</TransactionCode><Data><ReportId>201405228-A-110B</ReportId><ReportType>0</ReportType><CardNo>000021341249</CardNo></Data></Req>";
        //查询病人信息
        //		apiName = "ZEUS.HosHOPWs.QueryUserInfo";
       //		param = "<Req><TransactionCode>5003</TransactionCode><Data><CardType>1</CardType><CardNo>000021341249</CardNo><Mobile></Mobile><PatientId></PatientId></Data></Req>";
        //		param = "<Req><TransactionCode>5003</TransactionCode><Data><CardType>1</CardType><CardNo>000021341249</CardNo><Mobile></Mobile><PatientId></PatientId></Data></Req>";
       apiName = "ZEUS.HosHOPWs.QueryRegInfo";
       param = "<Req><TransactionCode>5003</TransactionCode><Data><CardType>1</CardType><CardNo>6001</CardNo><IdCardNo>123123</IdCardNo><OrderId>订单号</OrderId><ClinicCard>就诊卡号</ClinicCard><TimeSlice>就诊时段</TimeSlice><StartTime>就诊日期开始</StartTime><EndTime>就诊日期结束</EndTime><RegFlag>1-预约 2-当天挂号</RegFlag></Data></Req>" ;
       // param = "<Req><TransactionCode>5003</TransactionCode><Data><StartTime>2016-04-08</StartTime></Data></Req>" ;
        //apiName = "ZEUS.HosHOPWs.QueryRegInfo";
        //param = "<Req><TransactionCode>5003</TransactionCode><Data><CardType>1</CardType><CardNo>6001</CardNo><IdCardNo>123123</IdCardNo><OrderId>订单号</OrderId><ClinicCard>就诊卡号</ClinicCard><TimeSlice>就诊时段</TimeSlice><StartTime>就诊日期开始</StartTime><EndTime>就诊日期结束</EndTime><RegFlag>1-预约 2-当天挂号</RegFlag></Data></Req>" ;
        // param = "<Req><TransactionCode>5003</TransactionCode><Data><StartTime>2016-04-08</StartTime></Data></Req>" ;
        //挂号事件推送
        //apiName = "ZEUS.HosHOPWs.PushGuaHaoEvent";
@@ -107,22 +112,50 @@ public class RPCUtil {
        //		apiName = "ZEUS.HosHOPWs.QueryHospital";
        //		param = "<Req><TransactionCode></TransactionCode><Data><HosId>944</HosId></Data></Req>";
            String apiparam = "{\"ChannelId\"=\"100123\"," + "\"ParamType\"=1,"
                    + "\"Params\"=\"" + param + "\"," + "\"Guid\"=\""
                    + "00000001111111" + "\"," + "\"V\"=\"3.0.0\","
                    + "\"OutType\"=1," + "\"HospitalId\"=\"1026333\"}";
            String result = null;
            try {
                result = ServiceBus.getInstance(
                        "172.18.20.21:2181",
                       "EsbCloud")
                        .call(apiName, apiparam);
            } catch (Exception e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            System.out.println("result=" + result);
        //处方审阅成功推送
//        apiName = "ZEUS.HosHOPWs.PushReport";
//        param = "<Req><TransactionCode></TransactionCode><Data><orgCode>orgCode</orgCode><eventNo>eventNo</eventNo><patientId>patientId</patientId></Data></Req>";
//
//
//        String apiparam = "{\"ChannelId\"=\"100123\"," + "\"ParamType\"=1,"
//                    + "\"Params\"=\"" + param + "\"," + "\"Guid\"=\""
//                    + "00000001111111" + "\"," + "\"V\"=\"3.0.0\","
//                    + "\"OutType\"=1," + "\"HospitalId\"=\"1026333\"}";
//            String result = null;
//
//            try {
//                result = ServiceBus.getInstance(
//                        "172.18.20.21:2181",
//                       "EsbCloud")
//                        .call(apiName, apiparam);
//            } catch (Exception e) {
//                // TODO Auto-generated catch block
//                e.printStackTrace();
//            }
//            System.out.println("result=" + result);
        AppKeyService.init(null, 3);
        AppKeyService.setDebug(true);
        HashMap<String, String> paramMap=new HashMap();
        paramMap.put("type","35");//表示属于咨询的推送
        // paramMap.put("appId","EsbCloud");//表示属于咨询的推送
        paramMap.put("timestamp",new Date().getTime()+"");//表示属于咨询的推送
        JSONObject jsonData=new JSONObject();//构造推送的数据
        jsonData.put("operation", "1");
        jsonData.put("uniqueId", "11113");
        jsonData.put("org_code", "test");
        jsonData.put("event_no", "123666");
        jsonData.put("patientId", "123666");
        paramMap.put("data", jsonData.toString());
        Map result;
        try {
            result = AppKeyService.postToAllThirdParty(paramMap,"EsbCloud");  //paramMap为需要推送的参数,myt为调用者的appId
            System.out.println(result);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

Hos-Resource-Rest/src/main/java/com/yihu/hos/ws/service/ServiceGateWay.java

@@ -1,12 +1,10 @@
package com.yihu.hos.ws.service;
import com.yihu.hos.resource.util.StringUtil;
import com.yihu.hos.ws.model.WSReturnModel;
import com.yihu.hos.ws.thread.QLCThread;
import com.yihu.hos.ws.thread.PrescriptionThread;
import org.dom4j.Document;
import org.dom4j.DocumentHelper;
import org.dom4j.Element;
import org.springframework.stereotype.Service;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
@@ -34,7 +32,7 @@ public class ServiceGateWay implements ServiceGateWayPortType {
    public String service(String authInfo, String sequenceNo, String api, String param, int paramType, int outType, String v) {
        System.out.println("authInfo:" + authInfo);
        System.out.println("sequenceNo:" + sequenceNo);
        System.out.println("api,:" + api);
        System.out.println("api:" + api);
        System.out.println("param:" + param);
        System.out.println("paramType:" + paramType);
        System.out.println("outType:" + outType);
@@ -47,7 +45,7 @@ public class ServiceGateWay implements ServiceGateWayPortType {
                    Document document = DocumentHelper.parseText(param.trim());
                    Element root = document.getRootElement();
                    Element data = root.element("Data");
                    Thread thread = new QLCThread(data);
                    Thread thread = new PrescriptionThread(data);
                    thread.run();
                    wsReturnModel.setTransactionCode("10000");
                    wsReturnModel.setRespMessage("成功");

Hos-Resource-Rest/src/main/java/com/yihu/hos/ws/thread/PrescriptionThread.java

@@ -0,0 +1,279 @@
package com.yihu.hos.ws.thread;
import com.coreframework.remoting.Url;
import com.coreframework.remoting.reflect.InvokeRequest;
import com.coreframework.remoting.reflect.Rpc;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.mysql.fabric.proto.xmlrpc.XmlRpcClient;
import com.yihu.hos.config.Config;
import com.yihu.hos.resource.util.DateUtil;
import com.yihu.hos.resource.util.httpclient.HttpClientUtil;
import com.yihu.openplatform.service.AppKeyService;
import net.sf.json.JSONArray;
import net.sf.json.JSONObject;
import org.dom4j.Document;
import org.dom4j.DocumentHelper;
import org.dom4j.Element;
import org.dom4j.io.SAXReader;
import java.net.MalformedURLException;
import java.net.URL;
import java.util.*;
/**
 * Created by lingfeng on 2016/6/23.
 */
public class PrescriptionThread extends Thread{
    private HttpClientUtil httpClientUtil = new HttpClientUtil();
    private Element data;
    public PrescriptionThread(Element data){
        this.data = data;
    }
    /*public void run() {
        Map<String, Object> paramsMap = new HashMap<>();
        Map<String, Object> params = new HashMap<>();
        params.put("EventType", data.element("EventType").getText());
        params.put("EventNo", data.element("EventNo").getText());
        params.put("CardType", data.element("CardType").getText());
        params.put("CardNo", data.element("CardNo").getText());
        params.put("PatientId", data.element("PatientId").getText());
        params.put("HospitalId", data.element("OrgCode").getText());
        paramsMap.put("api", "17");
        paramsMap.put("param", params.toString());
        try {
            String res = httpClientUtil.doPost("http://127.0.0.1:8081/gateway/transfer", paramsMap, null, null);
            System.out.println(res);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }*/
    public void run() {
        Map<String, String> datasetMap = new HashMap<>();
        datasetMap.put("HDSC01_15", "<?xml version=\"1.0\" encoding=\"UTF-8\" standalone=\"no\"?>\n" +
                "<Resp>\n" +
                "<TransactionCode></TransactionCode>\n" +
                "<RespCode>10000</RespCode>\n" +
                "<RespMessage>成功</RespMessage>\n" +
                "<Data>\n" +
                "<Code>HDSC01_15</Code>\n" +
                "<PatientId>123666</PatientId>\n" +
                "<EventNo>123666</EventNo>\n" +
                "<OrgCode>test</OrgCode>\n" +
                "<CreateDate></CreateDate>" +
                "<Data_1>" +
                "<HDSA00_01_003>test</HDSA00_01_003>\n" +
                "<PATIENT_ID>123666</PATIENT_ID>\n" +
                "<HDSD03_01_031>123666</HDSD03_01_031>\n" +
                "<HDSD00_04_002>123666</HDSD00_04_002>\n" +
                "<JDSD00_04_008></JDSD00_04_008>\n" +
                "<HDSD00_04_006></HDSD00_04_006>\n" +
                "<HDSD00_04_013></HDSD00_04_013>\n" +
                "<HDSD00_04_005></HDSD00_04_005>\n" +
                "<JDSD00_04_001></JDSD00_04_001>\n" +
                "<HDSD00_04_007></HDSD00_04_007>\n" +
                "<JDSD00_04_002></JDSD00_04_002>\n" +
                "<HDSD00_04_009></HDSD00_04_009>\n" +
                "<JDSD00_04_003></JDSD00_04_003>\n" +
                "<HDSD00_04_010></HDSD00_04_010>\n" +
                "<JDSD00_04_004></JDSD00_04_004>\n" +
                "<HDSD00_04_004></HDSD00_04_004>\n" +
                "<JDSD00_04_009></JDSD00_04_009>\n" +
                "<HDSD00_04_003></HDSD00_04_003>\n" +
                "<HDSD00_04_001></HDSD00_04_001>\n" +
                "<HDSD00_04_011></HDSD00_04_011>" +
                "</Data_1>\n" +
                "</Data>\n" +
                "</Resp>");
        datasetMap.put("HDSC01_04", "<?xml version=\"1.0\" encoding=\"UTF-8\" standalone=\"no\"?>\n" +
                "<Resp>\n" +
                "<TransactionCode></TransactionCode>\n" +
                "<RespCode>10000</RespCode>\n" +
                "<RespMessage>成功</RespMessage>\n" +
                "<Data>\n" +
                "<Code>HDSC01_04</Code>\n" +
                "<PatientId>123666</PatientId>\n" +
                "<EventNo>123666</EventNo>\n" +
                "<OrgCode>test</OrgCode>\n" +
                "<CreateDate></CreateDate>" +
                "<Data_1>" +
                "<HDSD00_04_002>123666</HDSD00_04_002>\n" +
                "<HDSD00_04_023></HDSD00_04_023>\n" +
                "<HDSD00_04_021></HDSD00_04_021>\n" +
                "<HDSD00_04_022></HDSD00_04_022>\n" +
                "<HDSD00_04_024></HDSD00_04_024>\n" +
                "<HDSD00_04_025></HDSD00_04_025>\n" +
                "<HDSD00_04_026></HDSD00_04_026>\n" +
                "<HDSB05_01_034></HDSB05_01_034>\n" +
                "<HDSD00_04_027></HDSD00_04_027>\n" +
                "<HDSD00_04_028></HDSD00_04_028>\n" +
                "<HDSD00_04_012></HDSD00_04_012>" +
                "</Data_1>\n" +
                "</Data>\n" +
                "</Resp>");
        datasetMap.put("HDSC01_08", "<?xml version=\"1.0\" encoding=\"UTF-8\" standalone=\"no\"?>\n" +
                "<Resp>\n" +
                "<TransactionCode></TransactionCode>\n" +
                "<RespCode>10000</RespCode>\n" +
                "<RespMessage>成功</RespMessage>\n" +
                "<Data>\n" +
                "<Code>HDSC01_08</Code>\n" +
                "<PatientId>123666</PatientId>\n" +
                "<EventNo>123666</EventNo>\n" +
                "<OrgCode>test</OrgCode>\n" +
                "<CreateDate></CreateDate>" +
                "<Data_1>" +
                "<HDSD00_04_002>123666</HDSD00_04_002>\n" +
                "<HDSD00_04_008></HDSD00_04_008>\n" +
                "<HDSD00_04_019></HDSD00_04_019>\n" +
                "<HDSD00_04_035></HDSD00_04_035>\n" +
                "<HDSD00_04_036></HDSD00_04_036>\n" +
                "<HDSD00_04_023></HDSD00_04_023>\n" +
                "<HDSD00_04_021></HDSD00_04_021>\n" +
                "<HDSD00_04_022></HDSD00_04_022>\n" +
                "<HDSD00_04_024></HDSD00_04_024>\n" +
                "<HDSD00_04_025></HDSD00_04_025>\n" +
                "<HDSD00_04_026></HDSD00_04_026>\n" +
                "<HDSD00_04_027></HDSD00_04_027>\n" +
                "<HDSB05_01_034></HDSB05_01_034>\n" +
                "<HDSD00_04_028></HDSD00_04_028>\n" +
                "<HDSD00_04_012></HDSD00_04_012>\n" +
                "<HDSD00_04_031></HDSD00_04_031>\n" +
                "<HDSD00_04_032></HDSD00_04_032>\n" +
                "<HDSD00_04_033></HDSD00_04_033>\n" +
                "<HDSD00_04_034></HDSD00_04_034>\n" +
                "<HDSD00_04_030></HDSD00_04_030>" +
                "</Data_1>\n" +
                "</Data>\n" +
                "</Resp>");
        datasetMap.put("HDSC01_16", "<?xml version=\"1.0\" encoding=\"UTF-8\" standalone=\"no\"?>\n" +
                "<Resp>\n" +
                "<TransactionCode></TransactionCode>\n" +
                "<RespCode>10000</RespCode>\n" +
                "<RespMessage>成功</RespMessage>\n" +
                "<Data>\n" +
                "<Code>HDSC01_08</Code>\n" +
                "<PatientId>123666</PatientId>\n" +
                "<EventNo>123666</EventNo>\n" +
                "<OrgCode>test</OrgCode>\n" +
                "<CreateDate></CreateDate>" +
                "<Data_1>" +
                "<HDSA00_01_003>test</HDSA00_01_003>\n" +
                "<PATIENT_ID>123666</PATIENT_ID>\n" +
                "<HDSA00_01_017>350181199101251517</HDSA00_01_017>\n" +
                "<HDSD03_01_031>123666</HDSD03_01_031>\n" +
                "<HDSD00_04_002>123666</HDSD00_04_002>\n" +
                "<JDSD00_04_005></JDSD00_04_005>\n" +
                "<JDSD00_04_006></JDSD00_04_006>\n" +
                "<JDSD00_04_007></JDSD00_04_007>\n" +
                "<JDSD00_04_010></JDSD00_04_010>" +
                "</Data_1>\n" +
                "</Data>\n" +
                "</Resp>");
//        InvokeRequest r = new InvokeRequest(new Url("127.0.0.1", 8891), "com.yihu.hos.service.basic", "GetPatientDataset", String.class);
//        for (String datasetCode : datasetMap.keySet()) {
//            r.add(String.class, "<Req>\n" +
//                    "<TransactionCode></TransactionCode>\n" +
//                    "<Data>\n" +
//                    "<PatientId>"+data.element("PatientId").getText()+"</PatientId>\n" +
//                    "<EventNo>"+data.element("EventNo").getText()+"</EventNo>\n" +
//                    "<DatasetCode>HDSC01_15</DatasetCode>\n" +
//                    "</Data>\n" +
//                    "</Req>");
//
//            r.setSendTimeOutMills(3000);//设置默认的超时时间
//            r.setSyncMode();//设置调用模式为同步模式
//            try {
//                Object s = Rpc.invoke(r);
//                Document document = DocumentHelper.parseText(s.toString());
//                Element root = document.getRootElement();
//                Element respCode = root.element("RespCode");
//                if (respCode.getText().equals("10000")) {
//                    datasetMap.put(datasetCode, s.toString());
//                }
//                System.out.println(s.toString());
//            } catch (Exception e1) {
//                e1.printStackTrace();
//            }//调用并返回结果
//        }
        try {
            for (String datasetCode : datasetMap.keySet()) {
                String dataset = datasetMap.get(datasetCode);
                Document document = DocumentHelper.parseText(dataset);
                Element root = document.getRootElement();
                Element data = root.element("Data");
                Map<String, Object> params = new HashMap<>();
                params.put("dataset", datasetCode);
                params.put("data", XML2JsonData(data));
                params.put("orgCode", data.element("OrgCode").getText());
                String monogoResult = httpClientUtil.doPost(Config.monogoUrl, params, null, null);
                if(monogoUrlValid(monogoResult, "处方mongo入库失败")) {
                    /**
                     * 上传
                     */
                    params = new HashMap<String, Object>();
                    String jsonObject="{\"orgCode\":\""+data.element("OrgCode").getText()+"\",\"eventNo\":\""+data.element("EventNo").getText()+"\",\"patientId\":\""+data.element("PatientId").getText()+"\",\"referenceTime\":\""+data.element("CreateDate").getText()+"\"}";
                    params.put("patient", jsonObject);
                    httpClientUtil.doPost(Config.startCollect, params, null, null);
                }
            }
            /**
             * 采集完成推送
             */
            AppKeyService.init(null, 3);
            AppKeyService.setDebug(true);
            HashMap<String, String> paramMap = new HashMap();
            paramMap.put("type","35");//表示属于咨询的推送
            // paramMap.put("appId","EsbCloud");//表示属于咨询的推送
            paramMap.put("timestamp",new Date().getTime()+"");//表示属于咨询的推送
            JSONObject jsonData=new JSONObject();//构造推送的数据
            jsonData.put("operation", "1");
            jsonData.put("uniqueId", "11113");
            jsonData.put("org_code", data.element("OrgCode").getText());
            jsonData.put("event_no", data.element("EventNo").getText());
            jsonData.put("patientId", data.element("EventNo").getText());
            paramMap.put("data", jsonData.toString());
            Map result;
            try {
                result = AppKeyService.postToAllThirdParty(paramMap,"EsbCloud");  //paramMap为需要推送的参数,myt为调用者的appId
                System.out.println(result);
            } catch (Exception e) {
                e.printStackTrace();
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    private static String XML2JsonData(Element data)  throws  Exception{
        JSONArray object=new JSONArray();
        try {
            List<Element> datasetList = data.elements();
            for (int i = 5; i < datasetList.size(); i++){
                Element datasetElement = datasetList.get(i);
                List<Element> metadataList = datasetElement.elements();
                JSONObject jo = new JSONObject();
                for (Element metadata : metadataList) {
                    if(metadata.hasContent()){
                        jo.put(metadata.getName(), metadata.getText());
                    }
                }
                object.add(jo);
            }
        }catch (Exception e){
            throw new Exception("返回的xml转JSON错误");
        }
        return object.toString();
    }
    private boolean monogoUrlValid(String monogoUrl,String message) throws Exception {
        JSONObject jo = JSONObject.fromObject(monogoUrl);
        if ((Boolean) jo.get("successFlg")) {
            return true;
        } else {
            throw new Exception(message+" --- "+jo.get("message").toString());
        }
    }
}

Hos-Resource-Rest/src/main/java/com/yihu/hos/ws/thread/QLCThread.java

@@ -1,36 +0,0 @@
package com.yihu.hos.ws.thread;
import com.yihu.hos.resource.util.httpclient.HttpClientUtil;
import org.dom4j.Element;
import java.util.HashMap;
import java.util.Map;
/**
 * Created by lingfeng on 2016/6/23.
 */
public class QLCThread extends Thread{
    private HttpClientUtil httpClientUtil = new HttpClientUtil();
    private Element data;
    public QLCThread(Element data){
        this.data = data;
    }
    public void run() {
        Map<String, Object> paramsMap = new HashMap<>();
        Map<String, Object> params = new HashMap<>();
        params.put("EventType", data.element("EventType").getText());
        params.put("EventNo", data.element("EventNo").getText());
        params.put("CardType", data.element("CardType").getText());
        params.put("CardNo", data.element("CardNo").getText());
        params.put("PatientId", data.element("PatientId").getText());
        params.put("HospitalId", data.element("OrgCode").getText());
        paramsMap.put("api", "17");
        paramsMap.put("param", params.toString());
        try {
            String res = httpClientUtil.doPost("http://127.0.0.1:8081/gateway/transfer", paramsMap, null, null);
            System.out.println(res);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

Hos-resource/src/main/java/com/yihu/ehr/datacollect/controller/DataPushController.java

@@ -22,7 +22,7 @@ public class DataPushController extends BaseController {
    /**************************** 推送数据 ************************************************/
    /*
    推数据
    全流程推数据
     */
    @RequestMapping("datapush")
    @ResponseBody