jiazx0107@163.com
2023-12-05 ebaaa34038ebda73630c9ab82465c5f76692b5c2
src/main/java/com/fzzy/protocol/fzzy/server/MsgConsumer.java
@@ -43,19 +43,19 @@
            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);
    }
}