| | |
|---|
| | | package com.dy.rtuMw.server.mqtt; |
|---|
| | | |
|---|
| | | import com.dy.common.mw.protocol4Mqtt.status.DevRunSt; |
|---|
| | | import com.dy.common.mw.protocol4Mqtt.status.DevRunInfo; |
|---|
| | | import com.dy.rtuMw.server.forTcp.RtuLogDealer; |
|---|
| | | import com.dy.rtuMw.server.local.localProtocol.RtuOnLineStateStatisticsVo; |
|---|
| | | |
|---|
| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | return rsMap ; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | public static Boolean oneOnLine(String devId){ |
|---|
| | | synchronized (map){ |
|---|
| | | DevStatus st = map.get(devId) ; |
|---|
| | | if(st != null){ |
|---|
| | | return st.onLine ; |
|---|
| | | } |
|---|
| | | return false ; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | /** |
|---|
| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | public static void setStatus(String devId, DevRunSt st){ |
|---|
| | | public static void setStatus(String devId, DevRunInfo st){ |
|---|
| | | DevStatus vo = map.get(devId) ; |
|---|
| | | if(vo != null) { |
|---|
| | | if(st.stirRunning != null){ |
|---|
