pipIrr-SV.git - Gitblit

			@@ -1,5 +1,7 @@
			package com.dy.rtuMw.server.rtuData.p206V1_0_0;

			import com.dy.pipIrrGlobal.pojoRm.RmLossHistory;
			import com.dy.pipIrrGlobal.pojoRm.RmLossLast;
			import com.dy.rtuMw.server.rtuData.TaskSurpport;
			import com.dy.rtuMw.server.rtuData.dbSv.DbSv;
			import com.dy.common.mw.protocol.Data;
			@@ -7,8 +9,6 @@
			import com.dy.common.mw.protocol.p206V1_0_0.DataV1_0_1;
			import com.dy.common.util.DateTime;
			import com.dy.pipIrrGlobal.pojoPr.PrController;
			import com.dy.pipIrrGlobal.pojoRm.RmLossHistory;
			import com.dy.pipIrrGlobal.pojoRm.RmLossLast;
			import org.apache.logging.log4j.LogManager;
			import org.apache.logging.log4j.Logger;

			@@ -16,7 +16,7 @@
			* @Author liurunyu
			* @Date 2024/2/28 16:31
			* @LastEditTime 2024/2/28 16:31
			* @Description 控制器漏损统计
			* @Description 取水口漏损统计
			*/
			public class TkDealLoss extends TaskSurpport {

			@@ -42,7 +42,7 @@
			try{
			this.doDeal(sv, controller, d.getRtuAddr(), dV1_0_1, (DataCdC0Vo)cdObj);
			}catch (Exception e){
			log.error("保存遥测站自报实时数据中的漏损数据时发生异常", e);
			log.error("保存取水口漏损统计数据时发生异常", e);
			}
			}
			}
			@@ -56,9 +56,9 @@
			* @param dataCdC0Vo 开阀上报数据对象
			*/
			private void doDeal(DbSv sv, PrController controller, String rtuAddr, DataV1_0_1 dV1_0_1, DataCdC0Vo dataCdC0Vo) throws Exception {
			RmLossLast poLast = sv.getRmLossLast(rtuAddr);
			RmLossLast poLast = sv.getRmLossLast(controller.getIntakeId());
			if (poLast == null) {
			//数据库中不存在该控制器的漏损数据
			//数据库中不存在该取水口的漏损数据
			//首先生成最新数据及历史数据，并先保存
			poLast = this.newRmLossLast(controller, rtuAddr, dV1_0_1, dataCdC0Vo);
			this.newAndSaveHistoryDataDeal(sv, controller, rtuAddr, dV1_0_1, dataCdC0Vo, poLast);
			@@ -94,6 +94,7 @@
			//这种情况不存在（RTU时钟早于本地记录中的RTU时钟（RTU穿越回过去了，可能时钟重置了），此种情况不处理）
			}
			}
			sv.updateRmLossLast(poLast);
			}
			}