| | |
| | | reMessage.setStrMsg(message); |
| | | session.setCompanyId("0000"); |
| | | |
| | | log.info("控制柜------>>>>平台:IP={},PORT={},message={}", reMessage.getIp(), reMessage.getPort(), message); |
| | | log.debug("控制柜到---->>>>平台,未解析信息:IP={},PORT={},message={}", reMessage.getIp(), reMessage.getPort(), message); |
| | | |
| | | //调用解析接口开始解析 |
| | | if (null == analysisService) { |
| | | analysisService = (AnalysisService) SpringUtil.getBean(AnalysisService.BEAN_ID); |
| | | } |
| | | analysisService.analysis(reMessage); |
| | | |
| | | } catch (Exception e) { |
| | | log.error("控制柜------>>>>平台:收到报文解析异常:{}", e.getMessage()); |
| | | e.printStackTrace(); |
| | | } |
| | | |
| | | //调用解析接口开始解析 |
| | | if (null == analysisService) { |
| | | analysisService = (AnalysisService) SpringUtil.getBean(AnalysisService.BEAN_ID); |
| | | } |
| | | |
| | | analysisService.analysis(reMessage); |
| | | } |
| | | |
| | | } |