pipIrr-SV.git - Gitblit

			@@ -36,16 +36,16 @@
			Object subD = d.getSubData();
			if (subD != null) {
			DataV1_0_1 dV1_0_1 = (DataV1_0_1) subD;
			if (dV1_0_1 != null && dV1_0_1.dataCd83OpenVo != null) {
			Object[] objs = this.getTaskResults(TkPreGenObjs.taskId) ;
			DbSv sv = (DbSv)objs[0] ;
			PrController controller = (PrController)objs[1] ;
			try{
			this.doDeal(sv, controller, d.getRtuAddr(), dV1_0_1, dV1_0_1.dataCd83OpenVo) ;
			}catch (Exception e){
			log.error("保存控制器开阀上报时发生异常", e);
			}
			}
			// if (dV1_0_1 != null && dV1_0_1.dataCd83OpenVo != null) {
			// Object[] objs = this.getTaskResults(TkPreGenObjs.taskId) ;
			// DbSv sv = (DbSv)objs[0] ;
			// PrController controller = (PrController)objs[1] ;
			// try{
			// this.doDeal(sv, controller, d.getRtuAddr(), dV1_0_1, dV1_0_1.dataCd83OpenVo) ;
			// }catch (Exception e){
			// log.error("保存控制器开阀上报时发生异常", e);
			// }
			// }
			}
			}
			/**
			@@ -59,11 +59,13 @@
			private void doDeal(DbSv sv, PrController controller, String rtuAddr, DataV1_0_1 dV1_0_1, DataCd83OpenVo dataCd83OpenVo) throws Exception {
			RmOpenCloseValveLast poLast = sv.getRmOpenCloseValveLast(rtuAddr) ;
			if(poLast == null){
			//首先生成历史数据，并保存
			//数据库中不存在该控制器的开关阀数据
			//首先生成最新数据及历史数据，并先保存
			poLast = this.newRmOpenCloseValveLast(controller, rtuAddr, dV1_0_1, dataCd83OpenVo);
			this.newHistoryDataDeal(sv, controller, rtuAddr, dV1_0_1, dataCd83OpenVo, poLast);
			sv.saveRmOpenCloseValveLast(poLast);
			}else{
			//数据库中存在该控制器的开关阀数据
			if(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd83OpenVo.openDt).equals(poLast.openDt)){
			//时间一致，重复上报数据，不进行任何处理
			}else{
			@@ -92,7 +94,7 @@
			sv.updateRmOpenCloseValveHistory(poHistory);
			}
			}else if(poLast.closeDt != null && poLast.closeDt.before(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd83OpenVo.openDt))){
			//当前上报是新的开阀数据
			//当前上报是新的开阀数据，把最新数据中的关阀内容清空
			this.updateOpenValve(controller, poLast, null, dV1_0_1, dataCd83OpenVo, true) ;
			//生成并保存新的开阀上报历史数据记录
			this.newHistoryDataDeal(sv, controller, rtuAddr, dV1_0_1, dataCd83OpenVo, poLast);