| | |
| | | import com.dy.common.mw.protocol.MidResult; |
| | | import com.dy.common.mw.protocol.Command; |
| | | import com.dy.common.mw.protocol.Driver; |
| | | import com.dy.common.mw.protocol.ProtocolCache; |
| | | import com.dy.common.mw.protocol.ProtocolCach; |
| | | import com.dy.aceMw.server.ServerProperties; |
| | | import com.dy.aceMw.server.forTcp.TcpSessionCach; |
| | | |
| | |
| | | |
| | | /** |
| | | * 处理命令 |
| | | * @param com 命令 |
| | | * @param webJgroupName |
| | | * @param com |
| | | * @throws Exception |
| | | */ |
| | | private void deal(Command com) throws Exception{ |
| | |
| | | String protocolName = TcpSessionCach.getTcpProtocolName(rtuAddr) ; |
| | | if(protocolName == null){ |
| | | //RTU未曾上线 |
| | | int count = ProtocolCache.driverCount() ; |
| | | int count = ProtocolCach.driverCount() ; |
| | | if(count == 1){ |
| | | //只有一个协议 |
| | | dri = ProtocolCache.getFirstDriver() ; |
| | | dri = ProtocolCach.getFirstDriver() ; |
| | | } |
| | | }else{ |
| | | dri = ProtocolCache.getDriver(protocolName) ; |
| | | dri = ProtocolCach.getDriver(protocolName) ; |
| | | } |
| | | if(dri == null){ |
| | | log.error("严重错误,未能得到协议" + protocolName + "驱动类实例!"); |