| | |
|---|
| | | Object subD = d.getSubData(); |
|---|
| | | if (subD != null) { |
|---|
| | | DataV1_0_1 dV1_0_1 = (DataV1_0_1) subD; |
|---|
| | | // if (dV1_0_1 != null && dV1_0_1.dataCd83OpenVo != null) { |
|---|
| | | // Object[] objs = this.getTaskResults(TkPreGenObjs.taskId) ; |
|---|
| | | // DbSv sv = (DbSv)objs[0] ; |
|---|
| | | // PrController controller = (PrController)objs[1] ; |
|---|
| | | // try{ |
|---|
| | | // this.doDeal(sv, controller, d.getRtuAddr(), dV1_0_1, dV1_0_1.dataCd83OpenVo) ; |
|---|
| | | // }catch (Exception e){ |
|---|
| | | // log.error("保存控制器开阀上报时发生异常", e); |
|---|
| | | // } |
|---|
| | | // } |
|---|
| | | if (dV1_0_1 != null && dV1_0_1.subData != null) { |
|---|
| | | if(dV1_0_1.subData instanceof DataCd83OpenVo){ |
|---|
| | | DataCd83OpenVo vo83 = (DataCd83OpenVo)dV1_0_1.subData ; |
|---|
| | | Object[] objs = this.getTaskResults(TkPreGenObjs.taskId) ; |
|---|
| | | DbSv sv = (DbSv)objs[0] ; |
|---|
| | | PrController controller = (PrController)objs[1] ; |
|---|
| | | try{ |
|---|
| | | this.doDeal(sv, controller, d.getRtuAddr(), dV1_0_1, vo83) ; |
|---|
| | | }catch (Exception e){ |
|---|
| | | log.error("保存控制器开阀上报时发生异常", e); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | /** |
|---|
| | |
|---|
| | | RmOpenCloseValveLast poLast = sv.getRmOpenCloseValveLast(rtuAddr) ; |
|---|
| | | if(poLast == null){ |
|---|
| | | //数据库中不存在该控制器的开关阀数据 |
|---|
| | | //首先生成最新数据及历史数据，并先保存 |
|---|
| | | //首先生成开关阀的最新数据及历史数据，并先保存 |
|---|
| | | poLast = this.newRmOpenCloseValveLast(controller, rtuAddr, dV1_0_1, dataCd83OpenVo); |
|---|
| | | this.newHistoryDataDeal(sv, controller, rtuAddr, dV1_0_1, dataCd83OpenVo, poLast); |
|---|
| | | sv.saveRmOpenCloseValveLast(poLast); |
|---|
