Merge branch 'master' of http://8.140.179.55:20000/r/pipIrr-SV

Administrator

2024-08-05 faf02e3bad9fe25c60acf9a8be7e58122a4cec4a

 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/Server.java

@@ -19,6 +19,7 @@
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;
@@ -59,11 +60,11 @@
//      try {
//         URL url = Server.class.getResource("/config/this.licence");
//         if(!new Lnp(null).parese(url.getPath())){
//            System.out.println("zhzc licence error!") ;   
//            System.out.println("licence error!") ;
//            return ;
//         }
//      } catch (Exception e) {
//         System.out.println("zhzc licence error!") ; 
//         System.out.println("licence error!") ;
//         return ;
//      }
      //Server sv = new Server();
@@ -189,9 +190,9 @@

         //工作报太频繁，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());
@@ -294,7 +295,8 @@

         
         /////////////////
         //RMI模块
         //RMI模块 暂时不应用
         /*
         RmiConfigVo rmiVo = new RmiConfigVo();
         rmiVo.enable = conf.getSetAttrBoolean(doc, "config.rmi", "enable", null, null) ;
         if(rmiVo.enable){
@@ -310,7 +312,7 @@
            RmiSvUrl = "[ip]:" + rmiVo.port + "/" + rmiVo.context ;
            units.add(rmiUnit) ;
         }

         */

         /////////////////
         //RTU上行数据处理模块
@@ -340,6 +342,7 @@
         CoreUnit.addConstantTask(new ToRtuConstantTask());
         CoreUnit.addConstantTask(new FromRtuDataConstantTask());
         CoreUnit.addConstantTask(new FromRtuComResultConstantTask());
         CoreUnit.addConstantTask(new SendMsConstantTask());
         coreUnit.start(obj -> {
         });
         units.add(coreUnit) ;