pipIrr-SV.git - Gitblit

			@@ -1,12 +1,14 @@
			package com.dy.rtuMw.server.upgrade;

			import com.alibaba.fastjson2.annotation.JSONField;
			import com.dy.common.mw.protocol.rtuState.RtuStatus;
			import com.dy.common.softUpgrade.parse.HexFileParse;
			import com.dy.common.softUpgrade.state.UpgradeRtu;
			import com.dy.common.softUpgrade.state.UpgradeState;
			import com.dy.common.softUpgrade.state.UpgradeTaskVo;
			import com.dy.common.util.Callback;
			import com.dy.common.util.DateTime;
			import com.dy.rtuMw.server.forTcp.RtuStatusDealer;
			import lombok.Data;
			import org.apache.logging.log4j.LogManager;
			import org.apache.logging.log4j.Logger;
			@@ -32,6 +34,10 @@
			protected Integer failTryTimes ;//升级失败后，重新偿试升级次数，0表示不重新偿试升级
			@JSONField(serialize = false)
			protected Integer ugMaxRtuSameTime ;//同时升级RTU最大个数
			@JSONField(serialize = false)
			private Boolean openNoUpgrade ;//阀开（泵开）不执行升级
			@JSONField(serialize = false)
			private Integer lastOpenMaxGoOn ;//阀开（泵开）状态设置以来持续最长时间（秒钟），超过这个时间认为状态无效（这个时长取决于工作报间隔）

			public String setupDt ;//设置时间(yyyy-mm-dd HH:MM:SS)
			@JSONField(serialize = false)
			@@ -60,7 +66,12 @@
			/**
			* 初始化配置信息
			*/
			public void initOption(Integer failTryTimes, Integer ugMaxRtuSameTime) {
			public void initOption(Boolean openNoUpgrade,
			Integer lastOpenMaxGoOn,
			Integer failTryTimes,
			Integer ugMaxRtuSameTime) {
			this.openNoUpgrade = openNoUpgrade;
			this.lastOpenMaxGoOn = lastOpenMaxGoOn;
			this.failTryTimes = failTryTimes;
			this.ugMaxRtuSameTime = ugMaxRtuSameTime;
			}
			@@ -123,7 +134,7 @@
			* @param code
			* @param callbackCom
			*/
			public void trigger(String rtuAddr, String code, String protocolName, Short protocolVersion, Callback callbackCom){
			public void trigger(String rtuAddr, String code, String protocolName, Short protocolVersion, Callback callbackCom, Object ...objects){
			if(this.upgradeRtus != null && this.upgradeRtus.size() > 0
			&& this.taskVo.rtuAddrList != null && this.taskVo.rtuAddrList.size() > 0){
			UpgradeRtu ugRtu = this.upgradeRtus.get(rtuAddr) ;
			@@ -142,13 +153,32 @@
			//当前RTU已经升级完成，无需再升级
			return;
			}else{
			if(this.openNoUpgrade){
			//首先判断是否是阀门打开状态
			RtuStatus rtuStatus = RtuStatusDealer.oneStatus(rtuAddr) ;
			if(rtuStatus != null
			&& rtuStatus.valveOpenTrueCloseFalse != null
			&& rtuStatus.valveOpenTrueCloseFalse.booleanValue() == true
			&& rtuStatus.valveStatusLastTimeStamp != null){
			//有状态，并且是阀开（泵开）
			Long now = System.currentTimeMillis() ;
			Long gap = now - rtuStatus.valveStatusLastTimeStamp ;
			if(gap < this.lastOpenMaxGoOn){
			//这时采纳阀门打开状态，进而不能升级
			ugRtu.isOver = true ;
			ugRtu.state = UpgradeRtu.STATE_FAILOPEN ;
			return;
			}
			}
			}

			if(UpgradeUnit.confVo.ugMaxRtuAtOnce > 0){
			//设置了同时升级的RTU最大数量的限制
			if(ugRtu.state == UpgradeRtuDev.STATE_OFFLINE){
			//初始态，说明升级任务设置以来，该RTU第一次上行数据
			if(this.curUgRunningRtuTotal <= UpgradeUnit.confVo.ugMaxRtuAtOnce){
			//当前正在升级的RTU数量还未受限
			ugRtu.trigger(code, protocolName, protocolVersion, this.softFileDataGrp, callbackCom) ;
			ugRtu.trigger(code, protocolName, protocolVersion, this.softFileDataGrp, callbackCom, objects) ;
			}else{
			//同时升级的RTU数量受限，等待下次机会
			//但先表明一下状态
			@@ -159,18 +189,18 @@
			//根据上面逻辑，说明必然在线了
			if(this.curUgRunningRtuTotal <= UpgradeUnit.confVo.ugMaxRtuAtOnce){
			//当前正在升级的RTU数量还未受限
			ugRtu.trigger(code, protocolName, protocolVersion, this.softFileDataGrp, callbackCom) ;
			ugRtu.trigger(code, protocolName, protocolVersion, this.softFileDataGrp, callbackCom, objects) ;
			}else{
			//同时升级的RTU数量受限，等待下次机会
			return ;
			}
			}else{
			//RTU已经处于升级过程中
			ugRtu.trigger(code, protocolName, protocolVersion, this.softFileDataGrp, callbackCom) ;
			ugRtu.trigger(code, protocolName, protocolVersion, this.softFileDataGrp, callbackCom, objects) ;
			}
			}else{
			//没有设置同时升级的RTU最大数量的限制
			ugRtu.trigger(code, protocolName, protocolVersion, this.softFileDataGrp, callbackCom) ;
			ugRtu.trigger(code, protocolName, protocolVersion, this.softFileDataGrp, callbackCom, objects) ;
			}
			}
			}
			@@ -222,6 +252,9 @@
			}else if(info.state == UpgradeRtu.STATE_FAILOFFLINE) {
			state.failTotal++;
			state.failOffTotal++;
			}else if(info.state == UpgradeRtu.STATE_FAILOPEN) {
			state.failTotal++;
			state.failOpenTotal++;
			}
			if(info.isOver){
			state.overTotal++;
			@@ -282,6 +315,29 @@
			///////////////////////////////////////////////////////////

			/**
			* 阀开（泵开）不升级处理
			*/
			protected void openNoUpgrade(){
			if(this.upgradeRtus != null && this.upgradeRtus.size() > 0){
			Map<String, RtuStatus> rsAllMap = RtuStatusDealer.allStatus() ;
			Long now = System.currentTimeMillis() ;
			this.upgradeRtus.values().stream().forEach(a -> {
			RtuStatus rs = rsAllMap.get(a.rtuAddr) ;
			if(rs != null
			&& rs.valveOpenTrueCloseFalse != null && rs.valveOpenTrueCloseFalse.booleanValue() == true
			&& rs.valveStatusLastTimeStamp != null){
			//有状态，并且是阀开（泵开）
			Long gap = now - rs.valveStatusLastTimeStamp ;
			if(gap < this.lastOpenMaxGoOn){
			//这时采纳阀门打开状态不能升级
			a.isOver = true ;
			a.state = UpgradeRtu.STATE_FAILOPEN ;
			}
			}
			});
			}
			}
			/**
			* 判断是否没用任何一个RTU进行过升级，而且超过了时限
			* @return -1:无一RTU升级且超时，0：无RTU升级但未超时等待，1有RTU升级正常执行
			*/