新增日志记录

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)
+    @Scheduled(fixedRate = 1000 * 60 * 5)
-    public void beat(){
+    public void beat() {
         logger.info("------------心跳开始---------------");
-        Map<String,String> params=new HashMap<>();
+        Map<String, String> params = new HashMap<>();
-        params.put("code",String.valueOf(FileUtils.getJsonByName("collectorid")));
+        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("-------------心跳结束---------------");
         }
     }

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 {

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<String> 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;
     }
 

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