From 47e87687f4e2012ca5be5a73d9b811d647b56e05 Mon Sep 17 00:00:00 2001 From: zengwh Date: Fri, 22 Sep 2023 10:13:14 +0800 Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E9=87=91=E5=9F=9F=E5=A4=96?= =?UTF-8?q?=E9=80=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- pom.xml | 20 ++ .../ann/demo/controller/TestController.java | 12 + .../demo/entity/interfaceEntity/Patient.java | 19 ++ .../ann/demo/entity/interfaceEntity/Root.java | 76 +++++ .../entity/interfaceEntity/Scanfiles.java | 71 +++++ .../com/ann/demo/service/AnalysisService.java | 37 ++- .../ann/demo/service/CollectCheckService.java | 268 +++++++++++++++++ .../demo/service/JAXDynamicClientFactory.java | 42 +++ .../java/com/ann/demo/utils/Base64Utils.java | 9 + .../com/ann/demo/utils/HttpClientUtils.java | 269 ++++++++++++++++++ .../java/com/ann/demo/utils/JsonUtils.java | 32 +++ .../java/com/ann/demo/utils/Md5Utils.java | 41 +++ src/main/resources/application.yml | 22 ++ .../com/ann/demo/DemoApplicationTests.java | 2 + 14 files changed, 907 insertions(+), 13 deletions(-) create mode 100644 src/main/java/com/ann/demo/entity/interfaceEntity/Patient.java create mode 100644 src/main/java/com/ann/demo/entity/interfaceEntity/Root.java create mode 100644 src/main/java/com/ann/demo/entity/interfaceEntity/Scanfiles.java create mode 100644 src/main/java/com/ann/demo/service/CollectCheckService.java create mode 100644 src/main/java/com/ann/demo/service/JAXDynamicClientFactory.java create mode 100644 src/main/java/com/ann/demo/utils/HttpClientUtils.java create mode 100644 src/main/java/com/ann/demo/utils/JsonUtils.java create mode 100644 src/main/java/com/ann/demo/utils/Md5Utils.java diff --git a/pom.xml b/pom.xml index b196a72..87e5c46 100644 --- a/pom.xml +++ b/pom.xml @@ -106,6 +106,26 @@ axis 1.4 + + commons-discovery + commons-discovery + 0.2 + + + commons-logging + commons-logging + + + + + org.apache.axis + axis-jaxrpc + 1.4 + + + org.apache.httpcomponents + httpclient + diff --git a/src/main/java/com/ann/demo/controller/TestController.java b/src/main/java/com/ann/demo/controller/TestController.java index 7fded09..d81cbe6 100644 --- a/src/main/java/com/ann/demo/controller/TestController.java +++ b/src/main/java/com/ann/demo/controller/TestController.java @@ -8,6 +8,7 @@ import com.ann.demo.entity.filing.MessageSubordinate; import com.ann.demo.entity.filing.dto.MessageDto; import com.ann.demo.entity.filing.dto.PatientMainDto; import com.ann.demo.service.AnalysisService; +import com.ann.demo.service.CollectCheckService; import com.ann.demo.utils.XMLUtils; import org.apache.cxf.endpoint.Client; import org.apache.cxf.jaxws.endpoint.dynamic.JaxWsDynamicClientFactory; @@ -16,6 +17,7 @@ import org.springframework.stereotype.Controller; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.ResponseBody; +import javax.annotation.Resource; import java.util.Date; import java.util.Objects; @@ -30,6 +32,9 @@ public class TestController { @Autowired AnalysisService analysisService; + @Resource + private CollectCheckService collectCheckService; + @RequestMapping("/demo") public String aa() { return "demo"; @@ -61,4 +66,11 @@ public class TestController { } return "redirect:/demo"; } + + @RequestMapping("/demo1") + @ResponseBody + public String demo1() { + collectCheckService.downFileWithCheck("123","100041535327","GZ002WWRQAZEUXP","http://kmcs.kingmed.com.cn:8890/km-platform-web/restful/fileDownload/0df10c5e-af85-4acd-b2df-c1628f77b59c@88f14792ee4a31129fa721f85e2068bb"); + return "demo1"; + } } diff --git a/src/main/java/com/ann/demo/entity/interfaceEntity/Patient.java b/src/main/java/com/ann/demo/entity/interfaceEntity/Patient.java new file mode 100644 index 0000000..7662738 --- /dev/null +++ b/src/main/java/com/ann/demo/entity/interfaceEntity/Patient.java @@ -0,0 +1,19 @@ +package com.ann.demo.entity.interfaceEntity; + + +public class Patient +{ + private String patientid; + + public void setPatientid(String patientid){ + this.patientid = patientid; + } + public String getPatientid(){ + return this.patientid; + } + + public Patient(String patientid) { + this.patientid = patientid; + } +} + diff --git a/src/main/java/com/ann/demo/entity/interfaceEntity/Root.java b/src/main/java/com/ann/demo/entity/interfaceEntity/Root.java new file mode 100644 index 0000000..4d2a6c5 --- /dev/null +++ b/src/main/java/com/ann/demo/entity/interfaceEntity/Root.java @@ -0,0 +1,76 @@ +package com.ann.demo.entity.interfaceEntity; + +import java.util.ArrayList; +import java.util.List; + +public class Root +{ + private String collectorid; + + private String ip; + + private String assortid; + + private Patient patient; + + private List scanfiles; + + private String scanusercode; + + private String scanusername; + + public Root(Scanfiles scanfiles,String masterId) { + List list = new ArrayList<>(); + list.add(scanfiles); + this.collectorid = "10"; + this.ip = "127.0.0.1"; + this.assortid = "10"; + this.patient = new Patient(masterId); + this.scanfiles = list; + this.scanusercode = "zwh"; + this.scanusername = "zwh"; + } + + public void setCollectorid(String collectorid){ + this.collectorid = collectorid; + } + public String getCollectorid(){ + return this.collectorid; + } + public void setIp(String ip){ + this.ip = ip; + } + public String getIp(){ + return this.ip; + } + public void setAssortid(String assortid){ + this.assortid = assortid; + } + public String getAssortid(){ + return this.assortid; + } + public void setPatient(Patient patient){ + this.patient = patient; + } + public Patient getPatient(){ + return this.patient; + } + public void setScanfiles(List scanfiles){ + this.scanfiles = scanfiles; + } + public List getScanfiles(){ + return this.scanfiles; + } + public void setScanusercode(String scanusercode){ + this.scanusercode = scanusercode; + } + public String getScanusercode(){ + return this.scanusercode; + } + public void setScanusername(String scanusername){ + this.scanusername = scanusername; + } + public String getScanusername(){ + return this.scanusername; + } +} \ No newline at end of file diff --git a/src/main/java/com/ann/demo/entity/interfaceEntity/Scanfiles.java b/src/main/java/com/ann/demo/entity/interfaceEntity/Scanfiles.java new file mode 100644 index 0000000..de87071 --- /dev/null +++ b/src/main/java/com/ann/demo/entity/interfaceEntity/Scanfiles.java @@ -0,0 +1,71 @@ +package com.ann.demo.entity.interfaceEntity; + +public class Scanfiles +{ + private int taskid; + + private String filetitle; + + private int filesource; + + private int filestoragetype; + + private int filetype; + + private String downurl; + + private String serialnum; + + public Scanfiles(String filetitle,String downurl, String serialnum) { + this.taskid = -1; + this.filetitle = filetitle; + this.filesource = 1; + this.filestoragetype = 1; + this.filetype = 2; + this.downurl = downurl; + this.serialnum = serialnum; + } + + public void setTaskid(int taskid){ + this.taskid = taskid; + } + public int getTaskid(){ + return this.taskid; + } + public void setFiletitle(String filetitle){ + this.filetitle = filetitle; + } + public String getFiletitle(){ + return this.filetitle; + } + public void setFilesource(int filesource){ + this.filesource = filesource; + } + public int getFilesource(){ + return this.filesource; + } + public void setFilestoragetype(int filestoragetype){ + this.filestoragetype = filestoragetype; + } + public int getFilestoragetype(){ + return this.filestoragetype; + } + public void setFiletype(int filetype){ + this.filetype = filetype; + } + public int getFiletype(){ + return this.filetype; + } + public void setDownurl(String downurl){ + this.downurl = downurl; + } + public String getDownurl(){ + return this.downurl; + } + public void setSerialnum(String serialnum){ + this.serialnum = serialnum; + } + public String getSerialnum(){ + return this.serialnum; + } +} \ No newline at end of file diff --git a/src/main/java/com/ann/demo/service/AnalysisService.java b/src/main/java/com/ann/demo/service/AnalysisService.java index 69b801e..8a85fe6 100644 --- a/src/main/java/com/ann/demo/service/AnalysisService.java +++ b/src/main/java/com/ann/demo/service/AnalysisService.java @@ -10,6 +10,7 @@ import com.ann.demo.entity.filing.dto.PatientMainDto; import com.ann.demo.entity.filing.ArchiveDetail; import com.ann.demo.entity.interfaceEntity.ExamApply; import com.ann.demo.entity.interfaceEntity.MessageLog; +import com.ann.demo.utils.Base64Utils; import com.ann.demo.utils.FileUtils; import com.ann.demo.utils.PdfUtils; import com.ann.demo.utils.XMLUtils; @@ -19,6 +20,7 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import org.springframework.util.ObjectUtils; +import javax.annotation.Resource; import java.io.File; import java.util.Date; import java.util.Objects; @@ -47,6 +49,8 @@ public class AnalysisService { @Autowired ArchiveDetailService archiveDetailService; + @Resource + private CollectCheckService collectCheckService; /** * 2019-7-8 * @Param xmlStr 需要解析的字符串 @@ -80,20 +84,28 @@ public class AnalysisService { //System.out.println(messageDto.getReportAddress()); UUID uuid = UUID.randomUUID(); File pdfFile = FileUtils.createFile("pdfs", messageDto.getInpNo(), messageDto.getVisitId(), uuid.toString(), null); - if(PdfUtils.base64StringToPDF(messageDto.getReportAddress(),pdfFile)){ - // 查询库中是否存在 如果存在就更新 - archiveDetail = archiveDetailService.isExit(archiveMasterId, messageDto.getType(), messageDto.getSource(), messageDto.getApplyId(),messageDto.getCheckReportId()); - if (archiveDetail == null) { - archiveDetail = new ArchiveDetail(uuid.toString(),archiveMasterId, new Date(), messageDto.getType(), messageDto.getSource(), messageDto.getApplyId(), - messageDto.getDetailType(),messageDto.getCheckReportId()); - archiveDetail.setPdfPath(pdfFile.getAbsolutePath()); - archiveDetailService.save(archiveDetail); - }else{ - archiveDetail.setPdfPath(pdfFile.getAbsolutePath()); - archiveDetailService.save(archiveDetail); + if(Base64Utils.isBase64(messageDto.getReportAddress())) { + //是base64 + if (!PdfUtils.base64StringToPDF(messageDto.getReportAddress(), pdfFile)) { + textContentTemp = "加密字节流转换pdf失败"; } }else{ - textContentTemp = "加密字节流转换pdf失败"; + //不是base64 2023-09-05新增，根据接口下载pdf + boolean downFileFlag = collectCheckService.downFileWithCheck(archiveMasterId,messageDto.getBarCode(),messageDto.getCheckReportId(), messageDto.getReportAddress()); + if(!downFileFlag){ + textContentTemp = "金域外送base64下载失败"; + } + } + // 查询库中是否存在 如果存在就更新 + archiveDetail = archiveDetailService.isExit(archiveMasterId, messageDto.getType(), messageDto.getSource(), messageDto.getApplyId(),messageDto.getCheckReportId()); + if (archiveDetail == null) { + archiveDetail = new ArchiveDetail(uuid.toString(),archiveMasterId, new Date(), messageDto.getType(), messageDto.getSource(), messageDto.getApplyId(), + messageDto.getDetailType(),messageDto.getCheckReportId()); + archiveDetail.setPdfPath(pdfFile.getAbsolutePath()); + archiveDetailService.save(archiveDetail); + }else{ + archiveDetail.setPdfPath(pdfFile.getAbsolutePath()); + archiveDetailService.save(archiveDetail); } // 替换消息的pdf节点 String tempMessage = XMLUtils.replaceXpath(message, pdfFile.getAbsolutePath()); @@ -149,7 +161,6 @@ public class AnalysisService { return outContent; } - private String changeApply(ExamApply examApply,String interfaceName) throws Exception{ String textContent = null; ExamApply examApplyTemp = examApplyService.findExamApply(examApply.getApplyId()); diff --git a/src/main/java/com/ann/demo/service/CollectCheckService.java b/src/main/java/com/ann/demo/service/CollectCheckService.java new file mode 100644 index 0000000..661e194 --- /dev/null +++ b/src/main/java/com/ann/demo/service/CollectCheckService.java @@ -0,0 +1,268 @@ +package com.ann.demo.service; + +import com.alibaba.fastjson.JSON; +import com.ann.demo.utils.HttpClientUtils; +import com.ann.demo.utils.JsonUtils; +import com.ann.demo.utils.Md5Utils; + +import com.fasterxml.jackson.databind.JsonNode; +import com.fasterxml.jackson.databind.ObjectMapper; +import lombok.extern.slf4j.Slf4j; +import org.apache.axis.client.Call; + +import javax.xml.namespace.QName; +import javax.xml.rpc.ParameterMode; +import javax.xml.rpc.ServiceException; +import javax.xml.rpc.encoding.XMLType; + +import org.apache.axis.client.Service; +import org.apache.axis.utils.StringUtils; +import org.springframework.beans.factory.annotation.Value; +import org.springframework.stereotype.Component; +import org.springframework.util.CollectionUtils; + +import java.io.IOException; +import java.rmi.RemoteException; +import java.text.SimpleDateFormat; +import java.util.*; + +/** + * @author 曾文和 + * @description: 外送报告采集类 + * @createTime 2023/9/5 16:48 + */ +@Component +@Slf4j +public class CollectCheckService { + private Map tokenCacheMap = new HashMap<>(); + + private String FILENAME = "fileName"; + private String FILEBASE64 = "fileBase64"; + @Value("${siteCode}") + private String siteCode; + @Value("${customerCode}") + private String customerCode; + @Value("${collectionLocation}") + private String collectionLocation; + @Value("${loginUrl}") + private String loginUrl; + @Value("${namespaceURI}") + private String namespaceURI; + @Value("${webServiceMethod}") + private String webServiceMethod; + @Value("${webServiceDownMethod}") + private String webServiceDownMethod; + @Value("${downfileUrl}") + private String downfileUrl; + + public boolean downFileWithCheck(String masterId,String hospBarcode,String reportOdd,String fileUrl) { + //登录 + String token = getTokenByCheckKey(siteCode, customerCode, collectionLocation); + //下载 + return downFileWithCheck(masterId,hospBarcode,reportOdd,fileUrl,token); + } + + /** + * 下载文件 + * @param masterId + * @param hospBarcode + * @param reportOdd + * @param fileUrl + * @param token + * @return + */ + private boolean downFileWithCheck(String masterId,String hospBarcode,String reportOdd,String fileUrl,String token){ + //根据参数请求接口返回json数据 + String result = reqInterfaceByParam(hospBarcode, reportOdd, fileUrl, token); + //解析返回json数据 + Map map = analysisData(result); + //唯一文件码 + String serialnum = hospBarcode + "_" + reportOdd; + //根据解析的数据调用下载 + String reqResult = downFile(masterId,map,serialnum); + if(!StringUtils.isEmpty(reqResult)) { + String code = JsonUtils.getValueByKey(reqResult, "code"); + if(!StringUtils.isEmpty(code) && "0".equals(code)){ + return true; + } + } + return false; + } + + /** + * 根据解析的数据调用下载 + * @param map + */ + private String downFile(String masterId,Map map,String serialnum) { + if(!CollectionUtils.isEmpty(map)){ + //设置下载参数 + Map rootMap = setDownReqParams(masterId, map, serialnum); + //调用下载接口 + String result = HttpClientUtils.doPost(downfileUrl,JSON.toJSONString(rootMap)); + log.info("上传下载服务result:"+result); + return result; + } + return null; + } + + /** + * 设置下载请求参数 + * @param masterId + * @param map + * @param serialnum + * @return + */ + private Map setDownReqParams(String masterId, Map map, String serialnum) { + //设置文件信息参数 + Map scanfilesMap = new HashMap<>(); + scanfilesMap.put("taskid",-1); + scanfilesMap.put("filetitle", map.get(FILENAME)); + scanfilesMap.put("filesource",1); + scanfilesMap.put("filestoragetype",1); + scanfilesMap.put("filetype",2); + scanfilesMap.put("downurl", map.get(FILEBASE64)); + scanfilesMap.put("serialnum", serialnum +"1"); + List> scanfilesList = new ArrayList<>(); + scanfilesList.add(scanfilesMap); + //设置患者信息参数 + Map patientMap = new HashMap<>(); + patientMap.put("patientid", masterId); + //设置全部参数 + Map rootMap = new HashMap<>(); + rootMap.put("collectorid","10"); + rootMap.put("ip","127.0.0.1"); + rootMap.put("assortid","10"); + rootMap.put("patient",patientMap); + rootMap.put("scanfiles",scanfilesList); + rootMap.put("scanusercode","zwh"); + rootMap.put("scanusername","zwh"); + return rootMap; + } + + /** + * 解析返回json数据 + * @param result + */ + private Map analysisData(String result) { + Map map = new HashMap<>(); + if(!StringUtils.isEmpty(result)) { + ObjectMapper objectMapper = new ObjectMapper(); + //解析 + try { + // 将JSON字符串转换为Map对象 + JsonNode jsonNode = objectMapper.readTree(result); + String fileName = jsonNode.get("result").get("fileName").asText(); + if (!StringUtils.isEmpty(fileName)) { + fileName = fileName.substring(0, fileName.length() - 4); + } + map.put(FILENAME,fileName); + String fileBase64 = jsonNode.get("result").get("file").asText(); + map.put(FILEBASE64,fileBase64); + } catch (IOException e) { + e.printStackTrace(); + } + } + return map; + } + + /** + * 根据参数请求接口 + * @param hospBarcode + * @param reportOdd + * @param fileUrl + * @param token + * @return + */ + private String reqInterfaceByParam(String hospBarcode, String reportOdd, String fileUrl, String token) { + Map paramMap = new HashMap<>(); + paramMap.put("siteCode",siteCode); + paramMap.put("customerCode",customerCode); + paramMap.put("collectionLocation",collectionLocation); + paramMap.put("hospBarcode", hospBarcode); + paramMap.put("reportOdd", reportOdd); + paramMap.put("fileUrl", fileUrl); + String paramStr = JSON.toJSONString(paramMap); + String jsonMd5 = Md5Utils.strToMd5(paramStr); + //调用webService + Object[] objects = {jsonMd5, token, paramStr}; + String[] params ={"md5","token","postJson"}; + String result = null; + try { + result = getWebService(loginUrl,namespaceURI,webServiceDownMethod,params,objects); + } catch (Exception e) { + e.printStackTrace(); + log.info("调用接口失败："+objects.toString()); + } + return result; + } + + /** + * 登录 + * @param siteCode + * @param customerCode + * @param collectionLocation + * @return + */ + private String getTokenByCheckKey(String siteCode,String customerCode,String collectionLocation){ + //组织协定秘钥secretKey + SimpleDateFormat fmt = new SimpleDateFormat("yyyyMMdd"); + String toDay = fmt.format(new Date()); + //判断token是否存在 + String token = tokenCacheMap.get(toDay); + if(!StringUtils.isEmpty(token)){ + //取缓存 + return token; + } + String secretKey = collectionLocation + customerCode + siteCode + toDay; + //MD5转换 + String secretKeyMd5 = Md5Utils.strToMd5(secretKey); + //调用第三方webService接口登录 + //实例化org.apache.axis.client.Service对象 + //创建service调用对象 + Object[] objects = {siteCode, customerCode, collectionLocation, secretKeyMd5}; + String[] params ={"siteCode","customerCode","collectionLocation","secretKey"}; + String result = getWebService(loginUrl,namespaceURI,webServiceMethod,params,objects); + ObjectMapper objectMapper = new ObjectMapper(); + //解析 + try { + // 将JSON字符串转换为Map对象 + JsonNode jsonNode = objectMapper.readTree(result); + token = jsonNode.get("result").get("token").asText(); + } catch (IOException e) { + e.printStackTrace(); + } + if(!StringUtils.isEmpty(token)) { + //存缓存 + tokenCacheMap.clear(); + tokenCacheMap.put(toDay, token); + } + return token; + } + + /** + * 调用webService + * @return + */ + private String getWebService(String webServiceUrl,String namespaceURI,String webServiceMethod,String[] params,Object[] objects ){ + try { + Service service = new Service(); + Call call; + call=(Call) service.createCall(); + QName opAddEntry = new QName(namespaceURI, webServiceMethod); //设置命名空间和需要调用的方法名 + call.setTargetEndpointAddress(webServiceUrl); //设置请求路径 + call.setOperationName(webServiceMethod); //调用的方法名 + call.setTimeout(Integer.valueOf(2000)); //设置请求超时 + //按顺序设置请求参数、请求类型,多个需多添加参数 + for(String param : params){ + call.addParameter(param, XMLType.XSD_STRING, ParameterMode.IN); + } + call.setReturnType(org.apache.axis.encoding.XMLType.XSD_STRING);//设置返回类型 + return (String) call.invoke(opAddEntry,objects); + } catch (ServiceException e) { + e.printStackTrace(); + } catch (RemoteException e) { + e.printStackTrace(); + } + return null; + } +} diff --git a/src/main/java/com/ann/demo/service/JAXDynamicClientFactory.java b/src/main/java/com/ann/demo/service/JAXDynamicClientFactory.java new file mode 100644 index 0000000..fb08a88 --- /dev/null +++ b/src/main/java/com/ann/demo/service/JAXDynamicClientFactory.java @@ -0,0 +1,42 @@ +package com.ann.demo.service; + +import org.apache.cxf.Bus; +import org.apache.cxf.bus.CXFBusFactory; +import org.apache.cxf.endpoint.EndpointImplFactory; +import org.apache.cxf.endpoint.dynamic.DynamicClientFactory; +import org.apache.cxf.jaxws.support.JaxWsEndpointImplFactory; + +import java.util.List; + + +public class JAXDynamicClientFactory extends DynamicClientFactory { + protected JAXDynamicClientFactory(Bus bus) { + super(bus); + } + + protected EndpointImplFactory getEndpointImplFactory() { + return JaxWsEndpointImplFactory.getSingleton(); + } + + protected boolean allowWrapperOps() { + return true; + } + + public static JAXDynamicClientFactory newInstance(Bus b) { + return new JAXDynamicClientFactory(b); + } + + public static JAXDynamicClientFactory newInstance() { + Bus bus = CXFBusFactory.getThreadDefaultBus(); + return new JAXDynamicClientFactory(bus); + } + public boolean compileJavaSrc(String classPath, List srcList, String dest) { + org.apache.cxf.common.util.Compiler javaCompiler + = new org.apache.cxf.common.util.Compiler(); + javaCompiler.setEncoding("UTF-8"); + javaCompiler.setClassPath(classPath); + javaCompiler.setOutputDir(dest); + javaCompiler.setTarget("1.8"); + return javaCompiler.compileFiles(srcList); + } +} \ No newline at end of file diff --git a/src/main/java/com/ann/demo/utils/Base64Utils.java b/src/main/java/com/ann/demo/utils/Base64Utils.java index 31f44a5..6658c04 100644 --- a/src/main/java/com/ann/demo/utils/Base64Utils.java +++ b/src/main/java/com/ann/demo/utils/Base64Utils.java @@ -13,4 +13,13 @@ public class Base64Utils { } return null; } + + public static boolean isBase64(String str) { + try { + Base64.decode(str); + return true; + } catch (IllegalArgumentException e) { + return false; + } + } } diff --git a/src/main/java/com/ann/demo/utils/HttpClientUtils.java b/src/main/java/com/ann/demo/utils/HttpClientUtils.java new file mode 100644 index 0000000..c5969c7 --- /dev/null +++ b/src/main/java/com/ann/demo/utils/HttpClientUtils.java @@ -0,0 +1,269 @@ +/** + * Copyright (C), 2015-2019 + * Author: HJL + * Date: 2019/6/13 18:49 + * Description: + */ +package com.ann.demo.utils; +import com.alibaba.fastjson.JSONObject; +import org.apache.http.HttpEntity; +import org.apache.http.HttpResponse; +import org.apache.http.HttpStatus; +import org.apache.http.NameValuePair; +import org.apache.http.client.config.RequestConfig; +import org.apache.http.client.entity.UrlEncodedFormEntity; +import org.apache.http.client.methods.CloseableHttpResponse; +import org.apache.http.client.methods.HttpGet; +import org.apache.http.client.methods.HttpPost; +import org.apache.http.client.utils.URIBuilder; +import org.apache.http.entity.ContentType; +import org.apache.http.entity.StringEntity; +import org.apache.http.impl.client.CloseableHttpClient; +import org.apache.http.impl.client.HttpClients; +import org.apache.http.message.BasicNameValuePair; +import org.apache.http.util.EntityUtils; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +import java.io.IOException; +import java.net.URI; +import java.util.ArrayList; +import java.util.List; +import java.util.Map; + +/** + * HttpClient4.3工具类 + * + * @author + */ +public class HttpClientUtils { + private static Logger logger = LoggerFactory.getLogger(HttpClientUtils.class); // 日志记录 + + private static RequestConfig requestConfig = null; + + static { + // 设置请求和传输超时时间 + requestConfig = RequestConfig.custom().setSocketTimeout(600000).setConnectTimeout(600000).build(); + } + + /** + * post请求传输json参数 + * + * @param url url地址 + * @param jsonParam 参数 + * @return + */ + public static JSONObject httpPost(String url, JSONObject jsonParam) { + // post请求返回结果 + CloseableHttpClient httpClient = HttpClients.createDefault(); + JSONObject jsonResult = null; + HttpPost httpPost = new HttpPost(url); + // 设置请求和传输超时时间 + httpPost.setConfig(requestConfig); + try { + if (null != jsonParam) { + // 解决中文乱码问题 + StringEntity entity = new StringEntity(jsonParam.toString(), "utf-8"); + entity.setContentEncoding("UTF-8"); + entity.setContentType("application/json"); + httpPost.setEntity(entity); + } + CloseableHttpResponse result = httpClient.execute(httpPost); + // 请求发送成功，并得到响应 + if (result.getStatusLine().getStatusCode() == HttpStatus.SC_OK) { + String str = ""; + try { + // 读取服务器返回过来的json字符串数据 + str = EntityUtils.toString(result.getEntity(), "utf-8"); + // 把json字符串转换成json对象 + jsonResult = JSONObject.parseObject(str); + } catch (Exception e) { + logger.error("post请求提交失败:" + url, e); + } + } + } catch (IOException e) { + logger.error("post请求提交失败:" + url, e); + } finally { + httpPost.releaseConnection(); + } + return jsonResult; + } + + /** + * post请求传输String参数 例如：name=Jack&sex=1&type=2 + * Content-type:application/x-www-form-urlencoded + * + * @param url url地址 + * @param strParam 参数 + * @return + */ + public static JSONObject httpPost(String url, String strParam) { + // post请求返回结果 + CloseableHttpClient httpClient = HttpClients.createDefault(); + JSONObject jsonResult = null; + HttpPost httpPost = new HttpPost(url); + httpPost.setConfig(requestConfig); + try { + if (null != strParam) { + // 解决中文乱码问题 + StringEntity entity = new StringEntity(strParam, "utf-8"); + entity.setContentEncoding("UTF-8"); + entity.setContentType("application/x-www-form-urlencoded"); + httpPost.setEntity(entity); + } + CloseableHttpResponse result = httpClient.execute(httpPost); + // 请求发送成功，并得到响应 + if (result.getStatusLine().getStatusCode() == HttpStatus.SC_OK) { + String str = ""; + try { + // 读取服务器返回过来的json字符串数据 + str = EntityUtils.toString(result.getEntity(), "utf-8"); + // 把json字符串转换成json对象 + jsonResult = JSONObject.parseObject(str); + } catch (Exception e) { + logger.error("post请求提交失败:" + url, e); + } + } + } catch (IOException e) { + logger.error("post请求提交失败:" + url, e); + } finally { + httpPost.releaseConnection(); + } + return jsonResult; + } + + /** + * 发送get请求 + * + * @param url 路径 + * @return + */ + public static JSONObject httpGet(String url) { + // get请求返回结果 + JSONObject jsonResult = null; + CloseableHttpClient client = HttpClients.createDefault(); + // 发送get请求 + HttpGet request = new HttpGet(url); + request.setConfig(requestConfig); + try { + CloseableHttpResponse response = client.execute(request); + + // 请求发送成功，并得到响应 + if (response.getStatusLine().getStatusCode() == HttpStatus.SC_OK) { + // 读取服务器返回过来的json字符串数据 + HttpEntity entity = response.getEntity(); + String strResult = EntityUtils.toString(entity, "utf-8"); + // 把json字符串转换成json对象 + jsonResult = JSONObject.parseObject(strResult); + } else { + logger.error("get请求提交失败:" + url); + } + } catch (IOException e) { + logger.error("get请求提交失败:" + url, e); + } finally { + request.releaseConnection(); + } + return jsonResult; + } + + public static String doGet(String url, Map param) { + + // 创建Httpclient对象 + CloseableHttpClient httpclient = HttpClients.createDefault(); + + String resultString = ""; + CloseableHttpResponse response = null; + try { + // 创建uri + URIBuilder builder = new URIBuilder(url); + if (param != null) { + for (String key : param.keySet()) { + builder.addParameter(key, param.get(key)); + } + } + URI uri = builder.build(); + + // 创建http GET请求 + HttpGet httpGet = new HttpGet(uri); + + // 执行请求 + response = httpclient.execute(httpGet); + // 判断返回状态是否为200 + if (response.getStatusLine().getStatusCode() == 200) { + resultString = EntityUtils.toString(response.getEntity(), "UTF-8"); + } + } catch (Exception e) { + e.printStackTrace(); + } finally { + try { + if (response != null) { + response.close(); + } + httpclient.close(); + } catch (IOException e) { + e.printStackTrace(); + } + } + return resultString; + } + + public static String doGet(String url) { + return doGet(url, null); + } + + public static String doPost(String url,String param) { + CloseableHttpClient httpClient = HttpClients.createDefault(); + try { + HttpPost httpPost = new HttpPost(url); + StringEntity requestEntity = new StringEntity(param, ContentType.APPLICATION_JSON); + httpPost.setEntity(requestEntity); + HttpResponse response = httpClient.execute(httpPost); + HttpEntity responseEntity = response.getEntity(); + String responseBody = EntityUtils.toString(responseEntity); + System.out.println(responseBody); + return responseBody; + } catch (IOException e) { + e.printStackTrace(); + } finally { + try { + httpClient.close(); + } catch (IOException e) { + e.printStackTrace(); + } + } + return null; + } + + public static String doPost(String url) { + return doPost(url, null); + } + + public static String doPostJson(String url, String json) { + // 创建Httpclient对象 + CloseableHttpClient httpClient = HttpClients.createDefault(); + CloseableHttpResponse response = null; + String resultString = ""; + try { + // 创建Http Post请求 + HttpPost httpPost = new HttpPost(url); + // 创建请求内容 + StringEntity entity = new StringEntity(json, ContentType.APPLICATION_JSON); + httpPost.setEntity(entity); + // 执行http请求 + response = httpClient.execute(httpPost); + resultString = EntityUtils.toString(response.getEntity(), "utf-8"); + } catch (Exception e) { + e.printStackTrace(); + } finally { + try { + response.close(); + } catch (IOException e) { + // TODO Auto-generated catch block + e.printStackTrace(); + } + } + + return resultString; + } + +} \ No newline at end of file diff --git a/src/main/java/com/ann/demo/utils/JsonUtils.java b/src/main/java/com/ann/demo/utils/JsonUtils.java new file mode 100644 index 0000000..d014649 --- /dev/null +++ b/src/main/java/com/ann/demo/utils/JsonUtils.java @@ -0,0 +1,32 @@ +package com.ann.demo.utils; + +import com.fasterxml.jackson.databind.JsonNode; +import com.fasterxml.jackson.databind.ObjectMapper; + +public class JsonUtils { + public static String getValueByKey(String jsonString, String key) { + try { + ObjectMapper objectMapper = new ObjectMapper(); + JsonNode jsonNode = objectMapper.readTree(jsonString); + + JsonNode valueNode = jsonNode.get(key); + if (valueNode != null) { + return valueNode.asText(); + } + } catch (Exception e) { + e.printStackTrace(); + } + + return null; + } + + public static void main(String[] args) { + String jsonString = "{\"name\":\"John\",\"age\":30}"; + + String name = getValueByKey(jsonString, "name"); + int age = Integer.parseInt(getValueByKey(jsonString, "age")); + + System.out.println("Name: " + name); + System.out.println("Age: " + age); + } +} diff --git a/src/main/java/com/ann/demo/utils/Md5Utils.java b/src/main/java/com/ann/demo/utils/Md5Utils.java new file mode 100644 index 0000000..b8ea537 --- /dev/null +++ b/src/main/java/com/ann/demo/utils/Md5Utils.java @@ -0,0 +1,41 @@ +package com.ann.demo.utils; + +import java.security.MessageDigest; +import java.security.NoSuchAlgorithmException; + +/** + * @author 曾文和 + * @description: XXX类 + * @createTime 2023/9/5 16:57 + */ +public class Md5Utils { + + public static String strToMd5(String str) { + String hexString = null; + try { + // 创建MD5消息摘要对象 + MessageDigest md = MessageDigest.getInstance("MD5"); + + // 计算消息的摘要 + byte[] digest = md.digest(str.getBytes()); + + // 将摘要转换为十六进制字符串 + hexString = bytesToHex(digest); + } catch (NoSuchAlgorithmException e) { + e.printStackTrace(); + } + return hexString; + } + + private static String bytesToHex(byte[] bytes) { + StringBuilder hexString = new StringBuilder(); + for (byte b : bytes) { + String hex = Integer.toHexString(0xff & b); + if (hex.length() == 1) { + hexString.append('0'); + } + hexString.append(hex); + } + return hexString.toString(); + } +} diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml index 8ffbad7..baf6d9b 100644 --- a/src/main/resources/application.yml +++ b/src/main/resources/application.yml @@ -63,3 +63,25 @@ file: pdfPath: D:/project_js server: port: 8080 + +################################################# +#登录接口 +#子公司代码 +siteCode: K0101 +#客户代码 +customerCode: 44000259-001 +#收样点代码 +collectionLocation: 44000259-001|001 +#loginUrl +loginUrl: https://kmcs.kingmed.com.cn/km-op/cxf/v0.1.0.0/syncInfo2?wsdl +#namespaceURI +namespaceURI: http://com.org.kingmed +#webServiceMethod +webServiceMethod: login + +#下载金域外送报告接口 +#webServiceDownMethod +webServiceDownMethod: downloadPictureInfo + +#调下载接口 +downfileUrl: http://192.168.16.85:9292/api/downplatform/report diff --git a/src/test/java/com/ann/demo/DemoApplicationTests.java b/src/test/java/com/ann/demo/DemoApplicationTests.java index c53b8d0..30dd2dd 100644 --- a/src/test/java/com/ann/demo/DemoApplicationTests.java +++ b/src/test/java/com/ann/demo/DemoApplicationTests.java @@ -11,6 +11,8 @@ public class DemoApplicationTests { @Test public void contextLoads() { + int i = (int)Math.pow(2,3); + System.out.println(i); } }