pipIrr-SV.git - Gitblit

			@@ -21,6 +21,9 @@
			* @LastEditTime 2024-06-20 13:48
			* @Description
			*/
			/**
			* 处理控制器关阀上报
			*/
			public class TkDealCloseValveReportV202404 extends TaskSurpport {
			private static final Logger log = LogManager.getLogger(TkDealCloseValveReportV202404.class.getName());

			@@ -29,7 +32,6 @@

			/**
			* 执行节点任务：关阀上报
			*
			* @param data 需要处理的数据
			*/
			@Override
			@@ -119,7 +121,7 @@
			if(poHistory.openDt.equals(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd85Vo.startDt))){
			//匹配成功
			//当前关阀是原记录中开阀的对应关阀
			this.updateCloseValve(clientVo, controller, poLast, poHistory, dV202404, dataCd85Vo, false) ;
			this.updateCloseValve(clientVo, controller, rtuAddr, poLast, poHistory, dV202404, dataCd85Vo, false) ;
			sv.updateRmOpenCloseValveHistory(poHistory);
			}else if(poHistory.openDt.after(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd85Vo.startDt))){
			//匹配失败(对于after:等于或晚于都返回true)
			@@ -160,28 +162,28 @@
			if (poHistory != null) {
			if(poHistory.openDt.equals(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd85Vo.startDt))){
			//匹配上了
			this.updateCloseValve(clientVo, controller, poLast, poHistory, dV202404, dataCd85Vo, false) ;
			this.updateCloseValve(clientVo, controller, rtuAddr, poLast, poHistory, dV202404, dataCd85Vo, false) ;
			sv.updateRmOpenCloseValveHistory(poHistory);
			}else{
			//上个关阀报未上报
			this.updateCloseValve(clientVo, controller, poLast, null, dV202404, dataCd85Vo, true) ;
			this.updateCloseValve(clientVo, controller, rtuAddr, poLast, null, dV202404, dataCd85Vo, true) ;
			this.newHistoryDataDeal(sv, clientVo, controller, rtuAddr, dV202404, dataCd85Vo, poLast, null);
			}
			}else{
			//这种情况不存在，但为安全也进行处理，也认为上个关阀报未上报
			this.updateCloseValve(clientVo, controller, poLast, null, dV202404, dataCd85Vo, true) ;
			this.updateCloseValve(clientVo, controller, rtuAddr, poLast, null, dV202404, dataCd85Vo, true) ;
			this.newHistoryDataDeal(sv, clientVo, controller, rtuAddr, dV202404, dataCd85Vo, poLast, null);
			}
			}else{
			//这种情况不存在，但为安全也进行处理，也认为上个关阀报未上报
			this.updateCloseValve(clientVo, controller, poLast, null, dV202404, dataCd85Vo, true) ;
			this.updateCloseValve(clientVo, controller, rtuAddr, poLast, null, dV202404, dataCd85Vo, true) ;
			this.newHistoryDataDeal(sv, clientVo, controller, rtuAddr, dV202404, dataCd85Vo, poLast, null);
			}
			}
			}else{
			//if(po.opType == null)
			//原记录不存在开阀数据也不存在关阀数据，这种情况不存在，但为安全也进行处理，也认为上个关阀报未上报
			this.updateCloseValve(clientVo, controller, poLast, null, dV202404, dataCd85Vo, true) ;
			this.updateCloseValve(clientVo, controller, rtuAddr, poLast, null, dV202404, dataCd85Vo, true) ;
			//生成并保存新的关阀上报历史数据记录，没有对应的开发数据
			this.newHistoryDataDeal(sv, clientVo, controller, rtuAddr, dV202404, dataCd85Vo, poLast, null);
			}
			@@ -289,6 +291,7 @@
			*/
			private void updateCloseValve(SeClient clientVo,
			PrController controller,
			String rtuAddr,
			RmOpenCloseValveLast poLast,
			RmOpenCloseValveHistory poHistory,
			DataV202404 dV202404,
			@@ -298,73 +301,15 @@
			poLast.clientName = clientVo==null?null:clientVo.getName() ;
			poLast.controllerId = controller==null?null:controller.getId();
			poLast.intakeId = controller==null?null:controller.getIntakeId();

			poLast.rtuAddr = rtuAddr;
			poLast.updateFrom(dV202404, dataCd85Vo, clearLastOpenValue);

			if(poHistory != null){
			poHistory.clientId = clientVo==null?null:clientVo.getId() ;
			poHistory.clientName = clientVo==null?null:clientVo.getName() ;
			poHistory.controllerId = controller==null?null:controller.getId();
			poHistory.intakeId = controller==null?null:controller.getIntakeId();

			poHistory.rtuAddr = rtuAddr;
			poHistory.updateFrom(dV202404, dataCd85Vo, false);
			}
			}


			// /**
			// * 处理关阀报数据
			// * @param sv 服务
			// * @param clientVo 农户对象（不为空时，只有id和name有值）
			// * @param controller 控制器对象
			// * @param rtuAddr 控制器地址
			// * @param dataV202404 协议数据
			// * @param cdData 功能数据
			// */
			// private void doDeal(DbSv sv, SeClient clientVo, PrController controller, String rtuAddr, DataV202404 dataV202404, DataCd85Vo cdData) throws Exception {
			// this.saveOrUpdateLast(sv, controller, rtuAddr, dataV202404, cdData);
			// this.saveHistory(sv, controller, rtuAddr, dataV202404, cdData);
			// }
			//
			// /**
			// * 保存或更新控制器关阀报最新数据
			// * @param sv 服务bean
			// * @param controller 控制器对象
			// * @param rtuAddr 控制器地址
			// * @param dataV202404 协议数据
			// * @param cdData 功能数据
			// */
			// private void saveOrUpdateLast(DbSv sv, PrController controller, String rtuAddr, DataV202404 dataV202404, DataCd85Vo cdData)throws Exception {
			// RmOpenCloseValveLast po = sv.getRmOpenCloseValveLast(controller.getIntakeId());
			// if(po == null){
			// po = new RmOpenCloseValveLast();
			// po.controllerId = controller==null?null:controller.getId();
			// po.intakeId = controller==null?null:controller.getIntakeId();
			// po.rtuAddr = rtuAddr;
			// po.valueFrom85(dataV202404, cdData);
			// sv.saveRmOpenCloseValveLast(po);
			// }else{
			// po.controllerId = controller==null?null:controller.getId();
			// po.intakeId = controller==null?null:controller.getIntakeId();
			// po.valueFrom85(dataV202404, cdData);
			// sv.updateRmOpenCloseValveLast(po);
			// }
			// }
			//
			// /**
			// * 保存控制器关阀报历史数据
			// * @param sv 服务bean
			// * @param controller 控制器对象
			// * @param rtuAddr 控制器地址
			// * @param dataV202404 协议数据
			// * @param cdData 功能数据
			// */
			// private void saveHistory(DbSv sv, PrController controller, String rtuAddr, DataV202404 dataV202404, DataCd85Vo cdData)throws Exception {
			// RmOpenCloseValveHistory po = new RmOpenCloseValveHistory();
			// po.controllerId = controller==null?null:controller.getId();
			// po.intakeId = controller==null?null:controller.getIntakeId();
			// po.rtuAddr = rtuAddr;
			// po.valueFrom85(dataV202404, cdData);
			// sv.saveRmOpenCloseValveHistory(po); ;
			// }
			}