| | |
|---|
| | | package com.dy.rtuMw.server.forTcp; |
|---|
| | | |
|---|
| | | import com.dy.common.mw.protocol.rtuState.RtuStatus; |
|---|
| | | import org.apache.logging.log4j.LogManager; |
|---|
| | | import org.apache.logging.log4j.Logger; |
|---|
| | | |
|---|
| | |
|---|
| | | * 得到部分状态 |
|---|
| | | * @return |
|---|
| | | */ |
|---|
| | | public static Map<String, RtuStatus> partStatus(String[] rtuAddrArrGrp){ |
|---|
| | | public static Map<String, RtuStatus> someStatus(String[] rtuAddrArrGrp){ |
|---|
| | | synchronized (map){ |
|---|
| | | Map<String, RtuStatus> map = new HashMap<>(); |
|---|
| | | Map<String, RtuStatus> rsMap = new HashMap<>(); |
|---|
| | | for(String rtuAddr : rtuAddrArrGrp){ |
|---|
| | | RtuStatus status = map.get(rtuAddr) ; |
|---|
| | | if(status != null){ |
|---|
| | | map.put(rtuAddr, status) ; |
|---|
| | | rsMap.put(rtuAddr, status) ; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | return map ; |
|---|
| | | return rsMap ; |
|---|
| | | } |
|---|
| | | } |
|---|
| | | /** |
|---|
| | | * 得到一个RTU的状态 |
|---|
| | | * @return |
|---|
| | | */ |
|---|
| | | public static RtuStatus oneStatus(String rtuAddr){ |
|---|
| | | return map.get(rtuAddr) ; |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | public static void onLine(String rtuAddr, String ip, Integer port, String protocolName, Short protocolVersion){ |
|---|
| | | RtuStatus vo = map.get(rtuAddr) ; |
|---|
| | | if(vo == null) { |
|---|
