| | |
|---|
| | | import com.dy.common.mw.support.SupportUnit; |
|---|
| | | import com.dy.common.mw.support.SupportUnitConfigVo; |
|---|
| | | import com.dy.rtuMw.server.tasks.SendMsConstantTask; |
|---|
| | | import com.dy.rtuMw.server.tasks.ToRtuConstantTask; |
|---|
| | | import com.dy.rtuMw.server.tasks.RtuDownConstantTask; |
|---|
| | | import com.dy.rtuMw.resource.ResourceUnit; |
|---|
| | | import com.dy.rtuMw.resource.ResourceUnitConfigVo; |
|---|
| | | import com.dy.common.springUtil.SpringContextUtil; |
|---|
| | | import com.dy.common.util.ConfigXml4Springboot; |
|---|
| | | import com.dy.common.util.IDLongGenerator; |
|---|
| | | |
|---|
| | | import com.dy.rtuMw.server.upgrade.UpgradeUnit; |
|---|
| | | import com.dy.rtuMw.server.upgrade.UpgradeUnitConfigVo; |
|---|
| | | import org.jdom2.Document; |
|---|
| | | import org.springframework.beans.factory.annotation.Autowired; |
|---|
| | | import org.springframework.beans.factory.annotation.Value; |
|---|
| | |
|---|
| | | //工作报太频繁，N次上报处理1次，取值范围是1-100 |
|---|
| | | ServerProperties.workReportDealOneByTimes = conf.getSetAttrPlusInt(doc, "config.base", "workReportDealOneByTimes", null, 1, 100, null) ; |
|---|
| | | |
|---|
| | | //触发发送钉钉报警消息的取水口日漏损量的最小值（包括但除0.0外） |
|---|
| | | ServerProperties.intakeAlarmLossMinValue = conf.getSetAttrPlusDouble(doc, "config.base", "intakeAlarmLossMinValue", null, 0.0, 1000000.0, null) ; |
|---|
| | | |
|---|
| | | //有报警发生时，向钉钉发送消息的间隔时长（分钟） |
|---|
| | | ServerProperties.sendDingDingAlarmMsInterval = conf.getSetAttrPlusInt(doc, "config.base", "sendDingDingAlarmMsInterval", null, 1, 600, null) ; |
|---|
| | | |
|---|
| | |
|---|
| | | */ |
|---|
| | | |
|---|
| | | ///////////////// |
|---|
| | | //RTU远程升级模块 |
|---|
| | | UpgradeUnitConfigVo ugVo = new UpgradeUnitConfigVo(); |
|---|
| | | ugVo.enable = conf.getSetAttrBoolean(doc, "config.upgrade", "enable", null, null) ; |
|---|
| | | 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 = ugVo.rtuOffLineWaitDuration + 1000;//变成毫秒 |
|---|
| | | ugVo.notifyStateInterval = conf.getSetAttrPlusInt(doc, "config.upgrade", "notifyStateInterval", null, 1, 300, null); |
|---|
| | | ugVo.notifyStateInterval = ugVo.notifyStateInterval + 1000;//变成毫秒 |
|---|
| | | ugVo.showStartInfo = showStartInfo ; |
|---|
| | | AdapterImp_UpgradeUnit ugAdap = new AdapterImp_UpgradeUnit(); |
|---|
| | | ugAdap.setConfig(ugVo); |
|---|
| | | UpgradeUnit ugUnit = UpgradeUnit.getInstance(); |
|---|
| | | ugUnit.setAdapter(ugAdap); |
|---|
| | | ugUnit.start(obj -> { |
|---|
| | | }); |
|---|
| | | units.add(ugUnit) ; |
|---|
| | | |
|---|
| | | ///////////////// |
|---|
| | | //RTU上行数据处理模块（任务树） |
|---|
| | | RtuDataUnitConfigVo rducVo = new RtuDataUnitConfigVo(); |
|---|
| | | rducVo.resourceLoader = this.resourceLoader ; |
|---|
| | |
|---|
| | | coreAdap.setConfig(coreConfVo); |
|---|
| | | CoreUnit coreUnit = CoreUnit.getInstance(); |
|---|
| | | coreUnit.setAdapter(coreAdap); |
|---|
| | | CoreUnit.addConstantTask(new ToRtuConstantTask()); |
|---|
| | | CoreUnit.addConstantTask(new RtuDownConstantTask()); |
|---|
| | | CoreUnit.addConstantTask(new FromRtuDataConstantTask()); |
|---|
| | | CoreUnit.addConstantTask(new FromRtuComResultConstantTask()); |
|---|
| | | CoreUnit.addConstantTask(new SendMsConstantTask()); |
|---|
