| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | if(poLast.opType != null){ |
|---|
| | | //原记录存在开阀数据，首先进行时间对比 |
|---|
| | | //原记录存在开阀数据，首先进行订单号对比 |
|---|
| | | 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))){ |
|---|
| | |
|---|
| | | this.newHistoryDataDeal(sv, clientVo, controller, rtuAddr, dataV202404, dataCd84Vo, poLast); |
|---|
| | | } |
|---|
| | | }else if(poLast.clType != null){ |
|---|
| | | //原记录不存在开阀数据，但存在关阀数据，首先进行时间比对 |
|---|
| | | //原记录不存在开阀数据，但存在关阀数据，首先进行订单号比对 |
|---|
| | | if(poLast.clOrderNo != null && poLast.clOrderNo.equals(dataCd84Vo.orderNo)){ |
|---|
| | | //当前上报的开阀数据与原来的关阀数据匹配 |
|---|
| | | RmOpenCloseValveHistory poHistory = null ; |
|---|
| | |
|---|
| | | poHistory.controllerId = controller==null?null:controller.getId(); |
|---|
| | | poHistory.intakeId = controller==null?null:controller.getIntakeId(); |
|---|
| | | poHistory.rtuAddr = rtuAddr; |
|---|
| | | poHistory.updateFrom(dataV202404, dataCd84Vo, false); |
|---|
| | | poHistory.updateFrom(dataV202404, dataCd84Vo, clearLastCloseValve); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
