From 12538de7b0964bd0091b2d93989b5be4ef833e93 Mon Sep 17 00:00:00 2001 From: wyb <1977763549@qq.com> Date: Wed, 12 Apr 2023 14:32:02 +0800 Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0http=E8=B0=83=E7=94=A8webserv?= =?UTF-8?q?ice?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../server/report/client/HttpWsClient.java | 60 +++++++ .../report/client/JaxWsDynamicClient.java | 9 +- .../docus/server/report/job/ReportJob.java | 155 +++++++++--------- 3 files changed, 143 insertions(+), 81 deletions(-) create mode 100644 src/main/java/com/docus/server/report/client/HttpWsClient.java diff --git a/src/main/java/com/docus/server/report/client/HttpWsClient.java b/src/main/java/com/docus/server/report/client/HttpWsClient.java new file mode 100644 index 0000000..9a9102a --- /dev/null +++ b/src/main/java/com/docus/server/report/client/HttpWsClient.java @@ -0,0 +1,60 @@ +package com.docus.server.report.client; + +import com.docus.core.util.Func; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +import java.io.BufferedReader; +import java.io.InputStreamReader; +import java.io.OutputStream; +import java.net.HttpURLConnection; +import java.net.URL; +import java.nio.charset.StandardCharsets; +import java.util.Map; + +/** + * 通过http的方式调用 webservice + */ +public class HttpWsClient { + private static final Logger logger = LoggerFactory.getLogger(HttpWsClient.class); + + public static String send(String wsdlUrl, Map requestProperty, String param) { + try { + byte[] paramBytes = param.getBytes(StandardCharsets.UTF_8); + URL url = new URL(wsdlUrl); + HttpURLConnection httpConn = (HttpURLConnection) url.openConnection(); + httpConn.setRequestProperty("Content-Length", String.valueOf(paramBytes.length)); + httpConn.setRequestProperty("Content-Type", "text/xml; charset=utf-8"); + // 额外的一些请求信息 + if (Func.isNotEmpty(requestProperty)) { + for (Map.Entry entry : requestProperty.entrySet()) { + httpConn.setRequestProperty(entry.getKey(), entry.getValue()); + } + } + httpConn.setRequestMethod("POST"); + httpConn.setDoOutput(true); + httpConn.setDoInput(true); + httpConn.setConnectTimeout(60000); + // 输入内容 + OutputStream outputStream = httpConn.getOutputStream(); + outputStream.write(paramBytes); + outputStream.flush(); + outputStream.close(); + // 获取返回内容 + InputStreamReader inputStreamReader = new InputStreamReader(httpConn.getInputStream()); + BufferedReader bufferedReader = new BufferedReader(inputStreamReader); + StringBuilder stringBuilder = new StringBuilder(); + String str = null; + while ((str = bufferedReader.readLine()) != null) { + stringBuilder.append(str).append("\n"); + } + bufferedReader.close(); + inputStreamReader.close(); + return stringBuilder.toString(); + } catch (Exception ex) { + logger.error("wsdl："+wsdlUrl+", ext requestProperty:"+requestProperty+", param:"+param,ex); + return null; + } + } + +} diff --git a/src/main/java/com/docus/server/report/client/JaxWsDynamicClient.java b/src/main/java/com/docus/server/report/client/JaxWsDynamicClient.java index b094d7d..ecdc3a3 100644 --- a/src/main/java/com/docus/server/report/client/JaxWsDynamicClient.java +++ b/src/main/java/com/docus/server/report/client/JaxWsDynamicClient.java @@ -8,7 +8,6 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; import javax.xml.namespace.QName; -import java.util.Arrays; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; @@ -22,22 +21,22 @@ public class JaxWsDynamicClient { private static final Map CLIENT_MAP=new ConcurrentHashMap<>(); private static final Logger logger= LoggerFactory.getLogger(JaxWsDynamicClient.class); - public static String send(String wsdlUrl,String namespaceUri,String operationName,Object[] params){ + public static String send(String wsdlUrl,String namespaceUri,String operationName,Object param){ try { Client client = getClient(wsdlUrl); Object[] result; if (namespaceUri == null || namespaceUri.isEmpty()) { - result = client.invoke(operationName, params); + result = client.invoke(operationName, param); } else { QName qName = new QName(namespaceUri, operationName); - result = client.invoke(qName, params); + result = client.invoke(qName, param); } if (result == null || result[0] == null) { return null; } return String.valueOf(result[0]); } catch (Exception ex) { - logger.error("wsdlUrl：" + wsdlUrl + " ，operationName：" + operationName + "，params:" + Arrays.toString(params) + " 调用失败了！", ex); + logger.error("wsdlUrl：" + wsdlUrl + " ，operationName：" + operationName + "，param:" + param + " 调用失败了！", ex); return null; } } diff --git a/src/main/java/com/docus/server/report/job/ReportJob.java b/src/main/java/com/docus/server/report/job/ReportJob.java index 3ad225c..ba33a24 100644 --- a/src/main/java/com/docus/server/report/job/ReportJob.java +++ b/src/main/java/com/docus/server/report/job/ReportJob.java @@ -65,8 +65,8 @@ public class ReportJob { LocalDateTime now = LocalDateTime.now(); log.info("LIS检验报告报告查询 任务开始了"); // 定义查基础数据 入院时间 开始结束 - AfJobTime afJobTime= getJobTimeByJobType(jobType); - String queryBasicAdmissStartDate =afJobTime.getUpdateTime(); + AfJobTime afJobTime = getJobTimeByJobType(jobType); + String queryBasicAdmissStartDate = afJobTime.getUpdateTime(); String queryBasicAdmissEndDate = now.toString(); // 查询基础数据定义 分页 int offset = 0; @@ -113,8 +113,8 @@ public class ReportJob { LocalDateTime now = LocalDateTime.now(); log.info("检查报告报告查询 任务开始了"); // 定义查基础数据 入院时间 开始结束 - AfJobTime afJobTime= getJobTimeByJobType(jobType); - String queryBasicAdmissStartDate =afJobTime.getUpdateTime(); + AfJobTime afJobTime = getJobTimeByJobType(jobType); + String queryBasicAdmissStartDate = afJobTime.getUpdateTime(); String queryBasicAdmissEndDate = now.toString(); // 查询基础数据定义 分页 int offset = 0; @@ -169,25 +169,25 @@ public class ReportJob { private List getInspectReportDtoListBySdRyReportPatientId(String sdRyReportPatientId, TBasic tBasic) { try { List reportDtos = new ArrayList<>(); - int pageNum=1; - final int pageSize=10; - boolean loopCondition=true; + int pageNum = 1; + final int pageSize = 5; + boolean loopCondition = true; do { - String requestParam = organizationQuerySdRyInspectReportParam(sdRyReportPatientId, tBasic,pageNum,pageSize); + String requestParam = organizationQuerySdRyInspectReportParam(sdRyReportPatientId, tBasic, pageNum, pageSize); String url = organizationQuerySdRyInspectReportUrl(sdRyReportQueryConfig.getReportQueryInspectUrl()); log.info("查询检查报告请求地址：{} ,请求body参数:{}", url, requestParam); - String respBody= this.sendPost(url,requestParam); + String respBody = this.sendPost(url, requestParam); log.info("查询检查报告请求成功,响应参数：{}", respBody); - List reportDtoList=parseQuerySdRyInspectReport(respBody,tBasic); - if(reportDtoList.isEmpty()){ + List reportDtoList = parseQuerySdRyInspectReport(respBody, tBasic); + if (reportDtoList.isEmpty()) { break; } - if(reportDtoList.size() map = new HashMap<>(7); - map.put("isPage",isPage); - map.put("pageNo",pageNum); - map.put("pageSize",pageSize); - map.put("OrgCode",orgCode); - map.put("StartTime",startTime); - map.put("EndTime",endTime); - map.put("PatientId",sdRyReportPatientId); + map.put("isPage", isPage); + map.put("pageNo", pageNum); + map.put("pageSize", pageSize); + map.put("OrgCode", orgCode); + map.put("StartTime", startTime); + map.put("EndTime", endTime); + map.put("PatientId", sdRyReportPatientId); + map.put("PatentTypeCode", "1"); return Func.toJson(map); } - private List parseQuerySdRyInspectReport(String respBody, TBasic tBasic) { + private List parseQuerySdRyInspectReport(String respBody, TBasic tBasic) { JSONObject jsonObject = Func.readJson(respBody, JSONObject.class); Object resultCode = jsonObject.get("ResultCode"); - String successCode="0"; - if(!successCode.equals(String.valueOf(resultCode))){ + String successCode = "0"; + if (!successCode.equals(String.valueOf(resultCode))) { return new ArrayList<>(); } try { Object data = jsonObject.get("data"); String dataJsonStr = Func.toJson(data); // 是否是json object ，因为返回的如果是 [] ，则不会识别为jsonObject - List reportDtoList = new ArrayList<>(); - if( Func.isJsonObject(dataJsonStr)){ + List reportDtoList = new ArrayList<>(); + if (Func.isJsonObject(dataJsonStr)) { JSONObject dataJsonObject = Func.readJson(dataJsonStr, JSONObject.class); Object result = dataJsonObject.get("result"); String resultJsonStr = Func.toJson(result); List reportObjectList = Func.parseJsonArray(resultJsonStr, JSONObject.class); - if(Func.isNotEmpty(reportObjectList)){ + if (Func.isNotEmpty(reportObjectList)) { for (JSONObject reportObject : reportObjectList) { // 检查报告号 - String examReportSn =String.valueOf( reportObject.get("EXAM_REPORT_SN")); + String examReportSn = String.valueOf(reportObject.get("EXAM_REPORT_SN")); // 申请单号 String requestSn = String.valueOf(reportObject.get("REQUEST_SN")); // pdf地址 @@ -263,7 +264,7 @@ public class ReportJob { reportDto.setAdmisstimes(tBasic.getAdmissTimes()); reportDto.setInpatientNo(tBasic.getInpatientNo()); // 确定报告唯一 报告单号+申请单号 - reportDto.setSerialnum(examReportSn+requestSn); + reportDto.setSerialnum(examReportSn + requestSn); reportDto.setFileTitle(reportName); reportDto.setDownUrl(pdfUrl); reportDto.setAssortId(sdRyReportQueryConfig.getReportQueryInspectAssortId()); @@ -275,36 +276,37 @@ public class ReportJob { } } return reportDtoList; - }catch (Exception ex){ - log.error(ex.getMessage(),ex); - return new ArrayList<>(); + } catch (Exception ex) { + log.error(ex.getMessage(), ex); + return new ArrayList<>(); } } - private String sendPost(String url,String body){ + private String sendPost(String url, String body) { HttpRequest post = HttpUtil.createPost(url); post.timeout(60 * 1000); post.header("Content-Type", "application/json; charset=utf-8"); post.body(body); HttpResponse response = post.execute(); - return response.body(); + return response.body(); } /** * 查询job需要的开始时间 + * * @param jobType job类型 * @return job需要的开始时间，未查到 默认 1801-01-01 00:00:00 */ - private AfJobTime getJobTimeByJobType(String jobType){ + private AfJobTime getJobTimeByJobType(String jobType) { AfJobTime afJobTime = afJobTimeMapper.getAfJobTimeByJobType(jobType); // 定义查基础数据 入院时间 开始结束 String startTime = "1801-01-01 00:00:00"; - if (afJobTime ==null) { + if (afJobTime == null) { afJobTime = new AfJobTime(); afJobTime.setJobType(jobType); afJobTime.setUpdateTime(startTime); } - if(Func.isBlank(afJobTime.getUpdateTime())){ + if (Func.isBlank(afJobTime.getUpdateTime())) { afJobTime.setUpdateTime(startTime); } return afJobTime; @@ -330,11 +332,11 @@ public class ReportJob { private List getLisReportDtoListBySdRyReportPatientId(String sdRyReportPatientId, TBasic tBasic) { try { List reportDtos = new ArrayList<>(); - int pageNum=1; - final int pageSize=10; - boolean loopCondition=true; + int pageNum = 1; + final int pageSize = 5; + boolean loopCondition = true; do { - String requestParam = organizationQuerySdRyLisReportParam(sdRyReportPatientId, tBasic,pageNum,pageSize); + String requestParam = organizationQuerySdRyLisReportParam(sdRyReportPatientId, tBasic, pageNum, pageSize); String url = organizationQuerySdRyLisReportUrl(sdRyReportQueryConfig.getReportQueryLisUrl()); log.info("查询Lis报告请求地址：{} ,请求body参数:{}", url, requestParam); HttpRequest post = HttpUtil.createPost(url); @@ -344,16 +346,16 @@ public class ReportJob { HttpResponse response = post.execute(); String respBody = response.body(); log.info("查询Lis报告请求成功,响应参数：{}", respBody); - List reportDtoList=parseQuerySdRyLisReport(respBody,tBasic); - if(reportDtoList.isEmpty()){ + List reportDtoList = parseQuerySdRyLisReport(respBody, tBasic); + if (reportDtoList.isEmpty()) { break; } - if(reportDtoList.size() parseQuerySdRyLisReport(String respBody, TBasic tBasic) { + private List parseQuerySdRyLisReport(String respBody, TBasic tBasic) { JSONObject jsonObject = Func.readJson(respBody, JSONObject.class); Object resultCode = jsonObject.get("ResultCode"); - String successCode="0"; - if(!successCode.equals(String.valueOf(resultCode))){ + String successCode = "0"; + if (!successCode.equals(String.valueOf(resultCode))) { return new ArrayList<>(); } try { Object data = jsonObject.get("data"); String dataJsonStr = Func.toJson(data); // 是否是json object ，因为返回的如果是 [] ，则不会识别为jsonObject - List reportDtoList = new ArrayList<>(); - if( Func.isJsonObject(dataJsonStr)){ + List reportDtoList = new ArrayList<>(); + if (Func.isJsonObject(dataJsonStr)) { JSONObject dataJsonObject = Func.readJson(dataJsonStr, JSONObject.class); Object result = dataJsonObject.get("result"); String resultJsonStr = Func.toJson(result); List reportObjectList = Func.parseJsonArray(resultJsonStr, JSONObject.class); - if(Func.isNotEmpty(reportObjectList)){ + if (Func.isNotEmpty(reportObjectList)) { for (JSONObject reportObject : reportObjectList) { // 检验报告号 - String labReportSn =String.valueOf( reportObject.get("LAB_REPORT_SN")); + String labReportSn = String.valueOf(reportObject.get("LAB_REPORT_SN")); // 申请单号 String requestSn = String.valueOf(reportObject.get("REQUEST_SN")); // pdf地址 @@ -395,7 +397,7 @@ public class ReportJob { reportDto.setAdmisstimes(tBasic.getAdmissTimes()); reportDto.setInpatientNo(tBasic.getInpatientNo()); // 确定报告唯一 报告单号+申请单号 - reportDto.setSerialnum(labReportSn+requestSn); + reportDto.setSerialnum(labReportSn + requestSn); reportDto.setFileTitle(reportTypeName); reportDto.setDownUrl(pdfUrl); reportDto.setAssortId(sdRyReportQueryConfig.getReportQueryLisAssortId()); @@ -407,9 +409,9 @@ public class ReportJob { } } return reportDtoList; - }catch (Exception ex){ - log.error(ex.getMessage(),ex); - return new ArrayList<>(); + } catch (Exception ex) { + log.error(ex.getMessage(), ex); + return new ArrayList<>(); } } @@ -423,27 +425,28 @@ public class ReportJob { private String organizationQuerySdRyLisReportParam(String sdRyReportPatientId, TBasic tBasic, int pageNum, int pageSize) { boolean isPage = true; - String orgCode="4560886379"; + String orgCode = "4560886379"; Date admissDate = tBasic.getAdmissDate(); - if(admissDate==null){ - throw new BaseException("patientId："+tBasic.getPatientId()+"的入院时间为空"); + if (admissDate == null) { + throw new BaseException("patientId：" + tBasic.getPatientId() + "的入院时间为空"); } Instant instant = admissDate.toInstant(); ZoneId zoneId = ZoneId.systemDefault(); LocalDate admissLocalDate = instant.atZone(zoneId).toLocalDate(); LocalDate endTimeLocalDate = admissLocalDate.plusDays(1); LocalDate startTimeLocalDate = admissLocalDate.plusDays(-3); - String startTime=startTimeLocalDate+" 00:00:00"; - String endTime=endTimeLocalDate+" 00:00:00"; + String startTime = startTimeLocalDate + " 00:00:00"; + String endTime = endTimeLocalDate + " 00:00:00"; HashMap map = new HashMap<>(7); - map.put("isPage",isPage); - map.put("pageNo",pageNum); - map.put("pageSize",pageSize); - map.put("OrgCode",orgCode); - map.put("StartTime",startTime); - map.put("EndTime",endTime); - map.put("PatientId",sdRyReportPatientId); + map.put("isPage", isPage); + map.put("pageNo", pageNum); + map.put("pageSize", pageSize); + map.put("OrgCode", orgCode); + map.put("StartTime", startTime); + map.put("EndTime", endTime); + map.put("PatientId", sdRyReportPatientId); + map.put("PatentTypeCode", "1"); return Func.toJson(map); } @@ -460,11 +463,11 @@ public class ReportJob { return new ArrayList<>(); } String param = organizationQuerySdRyReportIndexParam(sDryIndex); - String[] params = {param}; + String namespaceUri = sdRyReportQueryConfig.getQueryReportIndexWsdlNamespaceUri(); String wsdlAddr = sdRyReportQueryConfig.getQueryReportIndexWsdlAddr(); String operationName = sdRyReportQueryConfig.getQueryReportIndexWsdlOperationName(); - String result = JaxWsDynamicClient.send(wsdlAddr, namespaceUri, operationName, params); + String result = JaxWsDynamicClient.send(wsdlAddr, namespaceUri, operationName, param); log.info("查询顺德人医患者交叉索引数据，返回值：{}", result); if (result == null) { return new ArrayList<>();