| | |
| | | import java.util.List; |
| | | |
| | | import com.dy.rtuMw.server.*; |
| | | import com.dy.rtuMw.server.msCenter.MsCenterConfigVo; |
| | | import com.dy.rtuMw.server.msCenter.MsCenterUnit; |
| | | import com.dy.rtuMw.server.rtuData.RtuDataUnit; |
| | | import com.dy.rtuMw.server.rtuData.RtuDataUnitConfigVo; |
| | | import com.dy.rtuMw.server.tasks.FromRtuComResultConstantTask; |
| | |
| | | } |
| | | */ |
| | | |
| | | |
| | | ///////////////// |
| | | //消息中心模块 |
| | | MsCenterConfigVo mscVo = new MsCenterConfigVo(); |
| | | mscVo.enable = conf.getSetAttrBoolean(doc, "config.msCenter", "enable", null, null) ; |
| | | mscVo.notifyMsInterval = conf.getSetAttrPlusInt(doc, "config.msCenter", "notifyInterval", null, 1, 600, null) * 1000L ; |
| | | mscVo.showStartInfo = showStartInfo ; |
| | | AdapterImp_MsCenterUnit mscAdapt = new AdapterImp_MsCenterUnit(); |
| | | mscAdapt.setConfig(mscVo); |
| | | MsCenterUnit mscUnit = MsCenterUnit.getInstance(); |
| | | mscUnit.setAdapter(mscAdapt); |
| | | mscUnit.start(obj -> { |
| | | }); |
| | | units.add(mscUnit) ; |
| | | |
| | | |
| | | ///////////////// |
| | | //RTU远程升级模块 |
| | | UpgradeUnitConfigVo ugVo = new UpgradeUnitConfigVo(); |