pipIrr-SV.git - Gitblit

			@@ -42,6 +42,13 @@
			private RtuUpgradeSv sv ;

			/**
			* 强制结束升级任务通信中间件成功执行后
			*/
			public static void afterMwForceOverCurUgTask(){
			cache = null ;
			}

			/**
			* rtu远程升级任务通信中间件执行情况统计回收
			* @param info 数据
			* @return 操作结果
			@@ -65,7 +72,7 @@
			info.ugRtuStateList = info.ugRtuStateList.stream().sorted(comparator).collect(Collectors.toList());

			//通信中间件传过来的机构tag，以用于查找数据源
			String token = req.getHeader(Constant.UserTokenKeyInHeader);
			String token = req.getHeader(Constant.TokenKeyInHeader);
			DataSourceContext.set(token);

			if(cache == null){
			@@ -234,6 +241,7 @@
			rtu.currentPackage = 0 ;
			rtu.currentRamAddr = 0x00 ;
			rtu.lastDownDt = "" ;
			rtu.lastDownDtAt = 0L ;
			rtu.reTryTimes = 0 ;
			rtu.isOver = false ;
			}else{
			@@ -241,6 +249,7 @@
			rtu.currentPackage = 1 ;
			rtu.currentRamAddr = 0x00 ;
			rtu.lastDownDt = DateTime.yyyy_MM_dd_HH_mm_ss() ;
			rtu.lastDownDtAt = System.currentTimeMillis() ;
			rtu.reTryTimes = 0 ;
			rtu.isOver = false ;
			}
			@@ -291,6 +300,7 @@
			rtu.currentPackage = 1 ;
			rtu.currentRamAddr = 0x00 ;
			rtu.lastDownDt = DateTime.yyyy_MM_dd_HH_mm_ss() ;
			rtu.lastDownDtAt = System.currentTimeMillis() ;
			rtu.reTryTimes++ ;
			rtu.isOver = false ;
			return ;
			@@ -303,6 +313,7 @@
			rtu.currentPackage += 1 ;
			rtu.currentRamAddr = 0x00 + UpgradeRtu.RAMADDRADD ;
			rtu.lastDownDt = DateTime.yyyy_MM_dd_HH_mm_ss() ;
			rtu.lastDownDtAt = System.currentTimeMillis() ;
			rtu.isOver = false ;
			}