| | |
|---|
| | | import com.dy.common.mw.protocol.ProtocolUnit; |
|---|
| | | 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.resource.ResourceUnit; |
|---|
| | | import com.dy.rtuMw.resource.ResourceUnitConfigVo; |
|---|
| | |
|---|
| | | |
|---|
| | | //工作报太频繁，N次上报处理1次，取值范围是1-100 |
|---|
| | | ServerProperties.workReportDealOneByTimes = conf.getSetAttrPlusInt(doc, "config.base", "workReportDealOneByTimes", null, 1, 100, null) ; |
|---|
| | | if(ServerProperties.workReportDealOneByTimes < 1 || ServerProperties.disconnectedByNoUpDataMinutes > 100){ |
|---|
| | | throw new Exception("workReportDealOneByTimes取值必须是1~100") ; |
|---|
| | | } |
|---|
| | | |
|---|
| | | //有报警发生时，向钉钉发送消息的间隔时长（分钟） |
|---|
| | | ServerProperties.sendDingDingAlarmMsInterval = conf.getSetAttrPlusInt(doc, "config.base", "sendDingDingAlarmMsInterval", null, 1, 600, null) ; |
|---|
| | | |
|---|
| | | //设置ID生成器的后缀 |
|---|
| | | IDLongGenerator.setSuffix(ServerProperties.dbDataIdSuffix.intValue()); |
|---|
| | |
|---|
| | | CoreUnit.addConstantTask(new ToRtuConstantTask()); |
|---|
| | | CoreUnit.addConstantTask(new FromRtuDataConstantTask()); |
|---|
| | | CoreUnit.addConstantTask(new FromRtuComResultConstantTask()); |
|---|
| | | CoreUnit.addConstantTask(new SendMsConstantTask()); |
|---|
| | | coreUnit.start(obj -> { |
|---|
| | | }); |
|---|
| | | units.add(coreUnit) ; |
|---|
