调整优化正来电子粮情协议

jiazx0107@163.com

2024-01-04 013c5f28422defd9b47abbe17a827be693872a26

 src/main/java/com/fzzy/protocol/zldz/server/SessionListener.java

@@ -35,21 +35,25 @@
        Constant.updateCacheOnline(session.getAddress(), session.getPort());


        /***********************设备上线后主动获取配置信息******************/
        try {
            /***********************设备上线后主动获取配置信息******************/

        BaseRequest request = new BaseRequest();
        request.setIp(session.getAddress());
        request.setPort(session.getPort());
        request.setCompanyId(ZldzServerUtil.DEFAULT_COMPANY);
        // Step1 生成在线测试命令
        Message message = OnLineCommandBuilder.getInstance().buildMessage(request);
        // 发送命令
        InvokeResult result = session.invoke(message.getByteMsg());
        //如果命令发送失败，直接踢掉连接
        if (!InvokeResult.SUCCESS.getCode().equals(result.getCode())) {
            session.destroy();
            BaseRequest request = new BaseRequest();
            request.setIp(session.getAddress());
            request.setPort(session.getPort());
            request.setCompanyId(ZldzServerUtil.DEFAULT_COMPANY);
            // Step1 生成在线测试命令
            Message message = OnLineCommandBuilder.getInstance().buildMessage(request);
            // 发送命令
            InvokeResult result = session.invoke(message.getByteMsg());
            //如果命令发送失败，直接踢掉连接
            if (!InvokeResult.SUCCESS.getCode().equals(result.getCode())) {
                session.destroy();
            }
            log.info("平台------->>分机---设备上线，自动发送设备配置信息请求命令--{}", message);
        } catch (Exception e) {
            log.error("平台------->>分机---设备上线，自动发送设备配置信息请求命令失败--{}", session.getAddress());
        }
        log.info("平台------->>分机---设备上线，自动发送设备配置信息请求命令--{}",message);
    }

    /**
@@ -69,8 +73,9 @@
        if (null == gatewayDeviceService) {
            gatewayDeviceService = SpringUtil.getBean(GatewayDeviceService.class);
        }

        gatewayDeviceService.OfflineByCommonDevice(commonDevice);

        //踢出连接
        session.destroy();
    }
}