liurunyu
20 小时以前 d0a2f65d25242872fbf34611b5e34f3d9732e208
完善代码
2个文件已修改
4 ■■■■ 已修改文件
pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/forTcp/TcpSessionCache.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/mqtt/DevStatusDealer.java 2 ●●● 补丁 | 查看 | 原始文档 | blame | 历史
pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/forTcp/TcpSessionCache.java
@@ -250,7 +250,7 @@
                    if(tcpSe.ioSession != null && tcpSe.ioSession.isConnected()){
                        if(now - tcpSe.lastUpDataTimeForOnlineCtrl > ServerProperties.disconnectedByNoUpDataMinutes){
                            tcpSe.ioSession.closeNow() ;
                            RtuLogDealer.log(entry.getKey(), "因较长时间未收上行数据,认为设备离线");
                            RtuLogDealer.log(entry.getKey(), "因较长时间未收到上行数据,认为设备离线");
                        }
                    }
                }
pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/mqtt/DevStatusDealer.java
@@ -122,7 +122,7 @@
                    if(st.onLine != null && st.onLine.booleanValue() && st.lastUpDataTime != null){
                        if(now - st.lastUpDataTime > MqttUnit.confVo.noSubThenOff.longValue()){
                            st.onLine = false ;
                            RtuLogDealer.log4Mqtt(entry.getKey(), "因较长时间未收上行数据,认为设备离线");
                            RtuLogDealer.log4Mqtt(entry.getKey(), "因较长时间未收到上行数据,认为设备离线");
                        }
                    }
                }