|  |  |  | 
|---|
|  |  |  | 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) { | 
|---|