| | |
| | | if(tcpSe.ioSession != null && tcpSe.ioSession.isConnected()){ |
| | | if(now - tcpSe.lastUpDataTimeForOnlineCtrl > ServerProperties.disconnectedByNoUpDataMinutes){ |
| | | tcpSe.ioSession.closeNow() ; |
| | | RtuLogDealer.log(entry.getKey(), "因较长时间未收上行数据,认为设备离线"); |
| | | RtuLogDealer.log(entry.getKey(), "因较长时间未收到上行数据,认为设备离线"); |
| | | } |
| | | } |
| | | } |
| | |
| | | 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(), "因较长时间未收到上行数据,认为设备离线"); |
| | | } |
| | | } |
| | | } |