| | |
|---|
| | | sv.saveRmOpenCloseValveLast(poLast); |
|---|
| | | }else{ |
|---|
| | | //数据库中存在该控制器的开关阀数据 |
|---|
| | | if(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd83OpenVo.openDt).equals(poLast.openDt)){ |
|---|
| | | //时间一致，重复上报数据，不进行任何处理 |
|---|
| | | //log.error("测试开阀日期一致"); |
|---|
| | | }else{ |
|---|
| | | if(poLast.opType != null){ |
|---|
| | | //原记录存在开阀数据，首先进行时间对比 |
|---|
| | | if(poLast.openDt != null && poLast.openDt.after(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd83OpenVo.openDt))){ |
|---|
| | | //补报的许久之前的开阀数据，不进行处理 |
|---|
| | | }else if(poLast.openDt != null && poLast.openDt.equals(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd83OpenVo.openDt))){ |
|---|
| | | //重复上报的开阀数据，不进行处理 |
|---|
| | | }else{ |
|---|
| | | //当前开阀上报是新的一次开阀，不管原记录是否存在关阀数据，一律清空关阀数据 |
|---|
| | | this.updateOpenValve(controller, poLast, null, dV1_0_1, dataCd83OpenVo, true) ; |
|---|
| | | //生成并保存新的开阀上报历史数据记录 |
|---|
| | | this.newHistoryDataDeal(sv, controller, rtuAddr, dV1_0_1, dataCd83OpenVo, poLast); |
|---|
| | | } |
|---|
| | | }else if(poLast.clType != null){ |
|---|
| | | //原记录不存在开阀数据，但存在关阀数据，首先进行时间比对 |
|---|
| | | if(poLast.closeDt != null && poLast.closeDt.after(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd83OpenVo.openDt))){ |
|---|
| | | //当前上报是补报的开阀数据 |
|---|
| | | RmOpenCloseValveHistory poHistory = null ; |
|---|
| | | if(poLast.lastHistoryId != null){ |
|---|
| | | poHistory = sv.getRmOpenCloseValveHistory(poLast.lastHistoryId) ; |
|---|
| | | } |
|---|
| | | this.updateOpenValve(controller, poLast, poHistory, dV1_0_1, dataCd83OpenVo, false) ; |
|---|
| | | if(poHistory != null){ |
|---|
| | | 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); |
|---|
| | | }else { |
|---|
| | | //当前上报的开阀数据与原来的关阀数据同一时间，这种情况应该不存在，但也处理 |
|---|
| | | RmOpenCloseValveHistory poHistory = null ; |
|---|
| | | if(poLast.lastHistoryId != null){ |
|---|
| | | poHistory = sv.getRmOpenCloseValveHistory(poLast.lastHistoryId) ; |
|---|
| | | } |
|---|
| | | this.updateOpenValve(controller, poLast, poHistory, dV1_0_1, dataCd83OpenVo, false) ; |
|---|
| | | if(poHistory != null){ |
|---|
| | | sv.updateRmOpenCloseValveHistory(poHistory); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | if(poLast.opType != null){ |
|---|
| | | //原记录存在开阀数据，首先进行时间对比 |
|---|
| | | if(poLast.openDt != null && poLast.openDt.after(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd83OpenVo.openDt))){ |
|---|
| | | //补报的许久之前的开阀数据，不进行处理 |
|---|
| | | }else if(poLast.openDt != null && poLast.openDt.equals(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd83OpenVo.openDt))){ |
|---|
| | | //重复上报的开阀数据，不进行处理 |
|---|
| | | }else{ |
|---|
| | | //if(po.clType == null) |
|---|
| | | //原记录不存在开阀数据也不存在关阀数据，这种情况不存在，但为安全也进行处理 |
|---|
| | | //当前开阀上报是新的一次开阀，不管原记录是否存在关阀数据，一律清空关阀数据 |
|---|
| | | this.updateOpenValve(controller, poLast, null, dV1_0_1, dataCd83OpenVo, true) ; |
|---|
| | | //生成并保存新的开阀上报历史数据记录 |
|---|
| | | this.newHistoryDataDeal(sv, controller, rtuAddr, dV1_0_1, dataCd83OpenVo, poLast); |
|---|
| | | } |
|---|
| | | |
|---|
| | | sv.updateRmOpenCloseValveLast(poLast); |
|---|
| | | }else if(poLast.clType != null){ |
|---|
| | | //原记录不存在开阀数据，但存在关阀数据，首先进行时间比对 |
|---|
| | | if(poLast.clOpenDt != null && poLast.clOpenDt.after(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd83OpenVo.openDt))){ |
|---|
| | | //补报的许久之前的开阀报数据，不进行处理 |
|---|
| | | }else if(poLast.clOpenDt != null && poLast.clOpenDt.before(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd83OpenVo.openDt))){ |
|---|
| | | //当前上报是新的开阀数据，把最新(last)数据中的关阀内容清空 |
|---|
| | | this.updateOpenValve(controller, poLast, null, dV1_0_1, dataCd83OpenVo, true) ; |
|---|
| | | //生成并保存新的开阀上报历史数据记录 |
|---|
| | | this.newHistoryDataDeal(sv, controller, rtuAddr, dV1_0_1, dataCd83OpenVo, poLast); |
|---|
| | | }else { |
|---|
| | | //当前上报的开阀数据与原来的关阀数据同一时间，这种情况应该不存在，但也处理 |
|---|
| | | RmOpenCloseValveHistory poHistory = null ; |
|---|
| | | if(poLast.lastHistoryId != null){ |
|---|
| | | poHistory = sv.getRmOpenCloseValveHistory(poLast.lastHistoryId) ; |
|---|
| | | } |
|---|
| | | this.updateOpenValve(controller, poLast, poHistory, dV1_0_1, dataCd83OpenVo, false) ; |
|---|
| | | if(poHistory != null){ |
|---|
| | | sv.updateRmOpenCloseValveHistory(poHistory); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | }else{ |
|---|
| | | //if(poLast.opType == null && po.clType == null) |
|---|
| | | //原记录不存在开阀数据也不存在关阀数据，这种情况不存在，但为安全也进行处理 |
|---|
| | | this.updateOpenValve(controller, poLast, null, dV1_0_1, dataCd83OpenVo, true) ; |
|---|
| | | //生成并保存新的开阀上报历史数据记录 |
|---|
| | | this.newHistoryDataDeal(sv, controller, rtuAddr, dV1_0_1, dataCd83OpenVo, poLast); |
|---|
| | | } |
|---|
| | | |
|---|
| | | sv.updateRmOpenCloseValveLast(poLast); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
