| | |
|---|
| | | 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; |
|---|
| | |
|---|
| | | }else{ |
|---|
| | | System.out.println("@@@@@@$ #@@@@@@@@@$ &@@@@@@@@" ) ; |
|---|
| | | } |
|---|
| | | System.out.println("@@@@@@@@@@@@@@@@@@@@@@# &@@@@@@@@ Runing in standalone mode" ) ; |
|---|
| | | System.out.println("@@@@@@@@@@@@@@@@@@@@@@# &@@@@@@@@ Running in standalone mode" ) ; |
|---|
| | | System.out.println("@@@@@@@@@@@@@@@@@@@@@& &@@@@@@@@ Startup in " + (System.currentTimeMillis() - start) + " MS" ) ; |
|---|
| | | System.out.println("@@@@@@@@@@@@@@@@@@@# &@@@@@@@@ " + company) ; |
|---|
| | | System.out.println("@@@@@@@@@@@@@@@@#O &@@@@@@@@") ; |
|---|
| | |
|---|
| | | ServerProperties.downComandMaxResendTimes = conf.getSetAttrPlusInt(doc, "config.base", "downComandMaxResendTimes", null, 1, 5, null).byteValue() ; |
|---|
| | | //针对一个RTU，下发命令的时间间隔 |
|---|
| | | ServerProperties.commandSendInterval = conf.getSetAttrPlusInt(doc, "config.base", "commandSendInterval", null, 1, 40, null) * 1000L ; |
|---|
| | | //针对一个RTU，下发快速命令的时间间隔 |
|---|
| | | ServerProperties.fastCommandSendInterval = conf.getSetAttrPlusInt(doc, "config.base", "fastCommandSendInterval", null, 1, 40000, null) * 1L ; |
|---|
| | | //命令已经发送达最大次数，仍未收到命令结果，需要在缓存继续等待，其等待最大时长 |
|---|
| | | ServerProperties.cachWaitResultTimeout = conf.getSetAttrPlusInt(doc, "config.base", "cachWaitResultTimeout", null, 10, 360, null) * 1000L ; |
|---|
| | | ServerProperties.cacheWaitResultTimeout = conf.getSetAttrPlusInt(doc, "config.base", "cacheWaitResultTimeout", null, 10, 360, null) * 1000L ; |
|---|
| | | //不在线缓存的命令最大缓存时长 |
|---|
| | | ServerProperties.offLineCachTimeout = conf.getSetAttrPlusInt(doc, "config.base", "offLineCachTimeout", null, 15, 172800, null) * 1000L ; |
|---|
| | | ServerProperties.offLineCacheTimeout = conf.getSetAttrPlusInt(doc, "config.base", "offLineCacheTimeout", null, 15, 172800, null) * 1000L ; |
|---|
| | | //TCP上行数据时刻缓存时长，当达到时长时，TCP上行数据时刻被清空，采用TCP上行数据时刻目的是，阻止上数据同时下发数据，因为RTU处理不过来 |
|---|
| | | ServerProperties.lastUpDataTimeLive = conf.getSetAttrPlusInt(doc, "config.base", "lastUpDataTimeLive", null, 0, 5000, null) * 1L ; |
|---|
| | | //数据库数据id生成器的id后缀，0是默认的后缀，一般web系统应用，数据中间件id后缀大于等于1 |
|---|
| | |
|---|
| | | } |
|---|
| | | */ |
|---|
| | | |
|---|
| | | |
|---|
| | | ///////////////// |
|---|
| | | //消息中心模块 |
|---|
| | | 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(); |
|---|
| | | ugVo.enable = conf.getSetAttrBoolean(doc, "config.upgrade", "enable", null, null) ; |
|---|
| | | ugVo.noOneRtuUpgradeMaxDuration = conf.getSetAttrPlusInt(doc, "config.upgrade", "noOneRtuUpgradeMaxDuration", null, 5, 3600, null); |
|---|
| | | ugVo.openNoUpgrade = conf.getSetAttrBoolean(doc, "config.upgrade", "openNoUpgrade", null, null) ; |
|---|
| | | ugVo.lastOpenMaxGoOn = conf.getSetAttrPlusInt(doc, "config.upgrade", "lastOpenMaxGoOn", null, 5, 360000, null); |
|---|
| | | ugVo.lastOpenMaxGoOn = ugVo.lastOpenMaxGoOn * 1000 ;//变成毫秒 |
|---|
| | | ugVo.noOneRtuUpgradeMaxDuration = conf.getSetAttrPlusInt(doc, "config.upgrade", "noOneRtuUpgradeMaxDuration", null, 5, 360000, null); |
|---|
| | | ugVo.noOneRtuUpgradeMaxDuration = ugVo.noOneRtuUpgradeMaxDuration * 1000 ;//变成毫秒 |
|---|
| | | ugVo.runningAndIdleDuration = conf.getSetAttrPlusInt(doc, "config.upgrade", "runningAndIdleDuration", null, 5, 360000, null); |
|---|
| | | ugVo.runningAndIdleDuration = ugVo.runningAndIdleDuration * 1000 ;//变成毫秒 |
|---|
| | | ugVo.failTryTimes = conf.getSetAttrPlusInt(doc, "config.upgrade", "failTryTimes", null, 0, 100, null); |
|---|
| | | ugVo.ugMaxRtuAtOnce = conf.getSetAttrPlusInt(doc, "config.upgrade", "ugMaxRtuAtOnce", null, 0, 1000000, null); |
|---|
| | | ugVo.rtuOffLineWaitDuration = conf.getSetAttrPlusInt(doc, "config.upgrade", "rtuOffLineWaitDuration", null, 1, 36000, null); |
|---|
| | | ugVo.rtuOffLineWaitDuration = conf.getSetAttrPlusInt(doc, "config.upgrade", "rtuOffLineWaitDuration", null, 1, 3600000, null); |
|---|
| | | ugVo.rtuOffLineWaitDuration = ugVo.rtuOffLineWaitDuration * 1000;//变成毫秒 |
|---|
| | | ugVo.notifyStateInterval = conf.getSetAttrPlusInt(doc, "config.upgrade", "notifyStateInterval", null, 1, 300, null); |
|---|
| | | ugVo.notifyStateInterval = ugVo.notifyStateInterval * 1000;//变成毫秒 |
|---|
| | | ugVo.notifyTimesAfterOver = conf.getSetAttrPlusInt(doc, "config.upgrade", "notifyTimesAfterOver", null, 0, null, null); |
|---|
| | | ugVo.showStartInfo = showStartInfo ; |
|---|
| | | AdapterImp_UpgradeUnit ugAdap = new AdapterImp_UpgradeUnit(); |
|---|
| | | ugAdap.setConfig(ugVo); |
|---|
