| | |
|---|
| | | |
|---|
| | | import com.dy.common.mw.UnitAdapterInterface; |
|---|
| | | import com.dy.common.mw.UnitInterface; |
|---|
| | | import com.dy.common.mw.UnitStartedCallbackInterface; |
|---|
| | | import com.dy.common.mw.UnitCallbackInterface; |
|---|
| | | |
|---|
| | | |
|---|
| | | public class ProtocolUnit implements UnitInterface { |
|---|
| | |
|---|
| | | /** |
|---|
| | | * 启动模块 |
|---|
| | | */ |
|---|
| | | public void start(UnitStartedCallbackInterface callback) throws Exception { |
|---|
| | | public void start(UnitCallbackInterface callback) throws Exception { |
|---|
| | | //得到唯一实例， 并在生成唯一实例时，扫描注解类 |
|---|
| | | AnnotationScan.getIntance() ; |
|---|
| | | |
|---|
| | | //各个协议驱动类扫描自己的功能码注解 |
|---|
| | | HashMap<String, AnnotationDriverVo> drivers = ProtocolCache.getDriverMap() ; |
|---|
| | | Collection<String> colDrivers = drivers.keySet() ; |
|---|
| | | Collection<String> keys = drivers.keySet() ; |
|---|
| | | StringBuilder totalProtocols = new StringBuilder() ; |
|---|
| | | for(String protocolName : colDrivers){ |
|---|
| | | for(String protocolNameVersion : keys){ |
|---|
| | | if(!totalProtocols.isEmpty()){ |
|---|
| | | totalProtocols.append("，") ; |
|---|
| | | } |
|---|
| | | totalProtocols.append(protocolName) ; |
|---|
| | | Driver dri = ProtocolCache.getDriver(protocolName) ; |
|---|
| | | totalProtocols.append(protocolNameVersion) ; |
|---|
| | | Driver dri = ProtocolCache.getDriver(protocolNameVersion) ; |
|---|
| | | if(dri != null){ |
|---|
| | | dri.scanAnnotationCode(); |
|---|
| | | dri.setNotify(adapter.getSingleRtuInfoNotify(protocolNameVersion)); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | if(adapter.getConfig().showStartInfo){ |
|---|
| | |
|---|
| | | } |
|---|
| | | |
|---|
| | | @Override |
|---|
| | | public void stop(UnitStartedCallbackInterface callback) { |
|---|
| | | public void stop(UnitCallbackInterface callback) { |
|---|
| | | } |
|---|
| | | |
|---|
| | | /* |
|---|
