diff --git a/src/main/java/com/docus/bgts/config/MyScheduling.java b/src/main/java/com/docus/bgts/config/MyScheduling.java index 8cae5ae..a5bc622 100644 --- a/src/main/java/com/docus/bgts/config/MyScheduling.java +++ b/src/main/java/com/docus/bgts/config/MyScheduling.java @@ -17,20 +17,20 @@ public class MyScheduling { @Value("${beat.url}") private String beatUrl; - private Logger logger= LogManager.getLogger(MyScheduling.class); + private Logger logger = LogManager.getLogger(MyScheduling.class); //5分钟执行一次 - @Scheduled(fixedRate = 1000*60*1) - public void beat(){ + @Scheduled(fixedRate = 1000 * 60 * 5) + public void beat() { logger.info("------------心跳开始---------------"); - Map params=new HashMap<>(); - params.put("code",String.valueOf(FileUtils.getJsonByName("collectorid"))); + Map params = new HashMap<>(); + params.put("code", String.valueOf(FileUtils.getJsonByName("collectorid"))); try { - HttpUtils.get(beatUrl,params); + HttpUtils.get(beatUrl, params); } catch (URISyntaxException e) { e.printStackTrace(); logger.info("心跳推送出错,可能是住院服务没有开启"); - }finally { + } finally { logger.info("-------------心跳结束---------------"); } } diff --git a/src/main/java/com/docus/bgts/controller/BgtsController.java b/src/main/java/com/docus/bgts/controller/BgtsController.java index 6ef7fca..7895b05 100644 --- a/src/main/java/com/docus/bgts/controller/BgtsController.java +++ b/src/main/java/com/docus/bgts/controller/BgtsController.java @@ -40,6 +40,7 @@ public class BgtsController { logger.info("采集接口接收到参数:\nempId--"+empId+"\ncollectSubId--"+collectSubId); bgtsService.collect(empId); afCollectTaskService.updateInterfaceCollect(collectSubId, 1); + logger.info("------------采集结束-----------"); } catch (RuntimeException e) { e.printStackTrace(); try { diff --git a/src/main/java/com/docus/bgts/service/BgtsServiceImpl.java b/src/main/java/com/docus/bgts/service/BgtsServiceImpl.java index bf05c37..b2c1f2f 100644 --- a/src/main/java/com/docus/bgts/service/BgtsServiceImpl.java +++ b/src/main/java/com/docus/bgts/service/BgtsServiceImpl.java @@ -16,6 +16,8 @@ import com.docus.bgts.utils.JAXDynamicClientFactory; import com.docus.bgts.utils.XmlUtils; import com.fasterxml.jackson.databind.ObjectMapper; import org.apache.cxf.endpoint.Client; +import org.apache.logging.log4j.LogManager; +import org.apache.logging.log4j.Logger; import org.dom4j.Document; import org.dom4j.DocumentHelper; import org.dom4j.Element; @@ -36,6 +38,8 @@ public class BgtsServiceImpl implements IBgtsService { @Value("${ws.localMethod}") private String wsLocalMethod; + private Logger logger= LogManager.getLogger(BgtsServiceImpl.class); + @Autowired IAfCollectTaskService afCollectTaskService; @@ -175,7 +179,15 @@ public class BgtsServiceImpl implements IBgtsService { } } request.setText(empId); - String resXml = invokeWs(document.asXML()); + logger.info("-------根据患者主索引号查询多个报告单号,地址:"+wsUrl+",方法:"+wsLocalMethod+"---------"); + String xml = document.asXML(); + logger.info("---------------------------"); + logger.info(xml); + logger.info("----------------------------"); + String resXml = invokeWs(xml); + logger.info("---------返回值-------------"); + logger.info(resXml); + logger.info("-----------------------------"); //解析XML XmlUtils xmlUtils = new XmlUtils(new ByteArrayInputStream(resXml.getBytes("UTF-8"))); // List dis = new ArrayList<>(); @@ -224,12 +236,14 @@ public class BgtsServiceImpl implements IBgtsService { // call.setTimeout(100000);//超时 // String result = (String) call.invoke(object);// 远程调用 // System.out.println(result); - + logger.info("-----\n客户端调用服务端:",wsUrl,"方法:",wsLocalMethod,"\n------------"); JAXDynamicClientFactory dcf = JAXDynamicClientFactory.newInstance(); Client client = dcf.createClient(wsUrl); Object[] objects = client.invoke(wsLocalMethod,xml); String str = objects[0].toString(); System.out.println(str); + logger.info("----------结果---------"); + logger.info(str); return str; } diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml index ea1399a..1c5cac8 100644 --- a/src/main/resources/application.yml +++ b/src/main/resources/application.yml @@ -13,6 +13,7 @@ mybatis-plus: db-type: MYSQL beat: url: http://localhost:9399/beat + ws: url: http://192.168.1.115:8010/ws_server/weather?wsdl localMethod: OperationA