| | |
| | | sv.saveRmOpenCloseValveLast(poLast); |
| | | }else{ |
| | | //数据库中存在该控制器的开关阀数据 |
| | | if(poLast.openDt != null && poLast.opIcCardAddr != null && poLast.opIcCardNo != null){ |
| | | if(poLast.openDt.equals(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd84Vo.openDt)) |
| | | if(poLast.opOrderNo != null && poLast.opIcCardAddr != null && poLast.opIcCardNo != null){ |
| | | if(poLast.opOrderNo.equals(dataCd84Vo.orderNo) |
| | | && poLast.opIcCardAddr.equals(dataCd84Vo.icCardAddr) |
| | | && poLast.opIcCardNo.equals(dataCd84Vo.icCardNo)){ |
| | | //重复上报,原因是下行数据处理慢了,就重复上报了 |
| | |
| | | } |
| | | if(poLast.opType != null){ |
| | | //原记录存在开阀数据,首先进行时间对比 |
| | | if(poLast.openDt != null && poLast.openDt.equals(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd84Vo.openDt))){ |
| | | if(poLast.opOrderNo != null && poLast.opOrderNo.equals(dataCd84Vo.orderNo)){ |
| | | //重复上报的开阀数据,不进行处理 |
| | | }else if(poLast.openDt != null && poLast.openDt.after(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd84Vo.openDt))){ |
| | | //补报的许久之前的开阀数据(对于after:等于或晚于都返回true) |
| | |
| | | } |
| | | }else if(poLast.clType != null){ |
| | | //原记录不存在开阀数据,但存在关阀数据,首先进行时间比对 |
| | | if(poLast.clOpenDt != null && poLast.clOpenDt.before(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd84Vo.openDt))){ |
| | | //当前上报是新的开阀数据,把最新(last)数据中的关阀内容清空 |
| | | this.updateOpenValve(clientVo, controller, rtuAddr, poLast, null, dataV202404, dataCd84Vo, true) ; |
| | | //生成并保存新的开阀上报历史数据记录 |
| | | this.newHistoryDataDeal(sv, clientVo, controller, rtuAddr, dataV202404, dataCd84Vo, poLast); |
| | | }else if(poLast.clOpenDt != null && poLast.clOpenDt.after(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd84Vo.openDt))){ |
| | | //补报的许久之前的开阀报数据(对于after:等于或晚于都返回true) |
| | | this.dealSupplyReport() ; |
| | | }else { |
| | | //当前上报的开阀数据与原来的关阀数据同一时间,这种情况应该不存在,但也处理 |
| | | if(poLast.clOrderNo != null && poLast.clOrderNo.equals(dataCd84Vo.orderNo)){ |
| | | //当前上报的开阀数据与原来的关阀数据匹配 |
| | | RmOpenCloseValveHistory poHistory = null ; |
| | | if(poLast.lastHistoryId != null){ |
| | | poHistory = sv.getRmOpenCloseValveHistory(poLast.lastHistoryId) ; |
| | |
| | | if(poHistory != null){ |
| | | sv.updateRmOpenCloseValveHistory(poHistory); |
| | | } |
| | | }else if(poLast.clOpenDt != null && poLast.clOpenDt.before(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd84Vo.openDt))){ |
| | | //当前上报是新的开阀数据,把最新(last)数据中的关阀内容清空 |
| | | this.updateOpenValve(clientVo, controller, rtuAddr, poLast, null, dataV202404, dataCd84Vo, true) ; |
| | | //生成并保存新的开阀上报历史数据记录 |
| | | this.newHistoryDataDeal(sv, clientVo, controller, rtuAddr, dataV202404, dataCd84Vo, poLast); |
| | | }else if(poLast.clOpenDt != null && poLast.clOpenDt.after(DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dataCd84Vo.openDt))){ |
| | | //补报的许久之前的开阀报数据(对于after:等于或晚于都返回true) |
| | | this.dealSupplyReport() ; |
| | | }else { |
| | | //订单号不同,时间相同 |
| | | //认为当前上报是新的开阀数据,把最新(last)数据中的关阀内容清空 |
| | | this.updateOpenValve(clientVo, controller, rtuAddr, poLast, null, dataV202404, dataCd84Vo, true) ; |
| | | //生成并保存新的开阀上报历史数据记录 |
| | | this.newHistoryDataDeal(sv, clientVo, controller, rtuAddr, dataV202404, dataCd84Vo, poLast); |
| | | } |
| | | }else{ |
| | | //if(poLast.opType == null && po.clType == null) |