|  |  |  | 
|---|
|  |  |  | * @param stateVo 状态对象 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | private void saveOrUpdateLast(DbSv sv, PrController controller, String rtuAddr, String rtuDt, DataV1_0_1 dV1_0_1, DataAlarmVo alarmVo, DataStateVo stateVo) throws Exception { | 
|---|
|  |  |  | RmAlarmStateLast po = sv.getRmAlarmStateLast(rtuAddr) ; | 
|---|
|  |  |  | if(po == null){ | 
|---|
|  |  |  | po = new RmAlarmStateLast(null, controller==null?null:controller.getId(), controller==null?null:controller.getIntakeId(), | 
|---|
|  |  |  | rtuAddr, | 
|---|
|  |  |  | DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt), | 
|---|
|  |  |  | DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(rtuDt), | 
|---|
|  |  |  | alarmVo==null?null:alarmVo.batteryVolt, alarmVo==null?null:alarmVo.loss, alarmVo==null?null:alarmVo.meter, alarmVo==null?null:alarmVo.valve, | 
|---|
|  |  |  | stateVo==null?null:stateVo.icCard, stateVo==null?null:stateVo.working, stateVo==null?null:stateVo.valve) ; | 
|---|
|  |  |  | sv.saveRmAlarmStateLast(po) ; | 
|---|
|  |  |  | }else{ | 
|---|
|  |  |  | po = this.update(controller, po, rtuDt, dV1_0_1, alarmVo, stateVo) ; | 
|---|
|  |  |  | sv.updateRmAlarmStateLast(po); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //        RmAlarmStateLast po = sv.getRmAlarmStateLast(rtuAddr) ; | 
|---|
|  |  |  | //        if(po == null){ | 
|---|
|  |  |  | //            po = new RmAlarmStateLast(null, controller==null?null:controller.getId(), controller==null?null:controller.getIntakeId(), | 
|---|
|  |  |  | //                    rtuAddr, | 
|---|
|  |  |  | //                    DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt), | 
|---|
|  |  |  | //                    DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(rtuDt), | 
|---|
|  |  |  | //                    alarmVo==null?null:alarmVo.batteryVolt, alarmVo==null?null:alarmVo.loss, alarmVo==null?null:alarmVo.meter, alarmVo==null?null:alarmVo.valve, | 
|---|
|  |  |  | //                    stateVo==null?null:stateVo.icCard, stateVo==null?null:stateVo.working, stateVo==null?null:stateVo.valve) ; | 
|---|
|  |  |  | //            sv.saveRmAlarmStateLast(po) ; | 
|---|
|  |  |  | //        }else{ | 
|---|
|  |  |  | //            po = this.update(controller, po, rtuDt, dV1_0_1, alarmVo, stateVo) ; | 
|---|
|  |  |  | //            sv.updateRmAlarmStateLast(po); | 
|---|
|  |  |  | //        } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | 
|---|
|  |  |  | * @param stateVo 状态对象 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | private void saveHistory(DbSv sv, PrController controller, String rtuAddr, String rtuDt, DataV1_0_1 dV1_0_1, DataAlarmVo alarmVo, DataStateVo stateVo) throws Exception { | 
|---|
|  |  |  | RmAlarmStateHistory po = new RmAlarmStateHistory(null, controller==null?null:controller.getId(), controller==null?null:controller.getIntakeId(), | 
|---|
|  |  |  | rtuAddr, | 
|---|
|  |  |  | DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt), | 
|---|
|  |  |  | DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(rtuDt), | 
|---|
|  |  |  | alarmVo==null?null:alarmVo.batteryVolt, alarmVo==null?null:alarmVo.loss, alarmVo==null?null:alarmVo.meter, alarmVo==null?null:alarmVo.valve, | 
|---|
|  |  |  | stateVo==null?null:stateVo.icCard, stateVo==null?null:stateVo.working, stateVo==null?null:stateVo.valve) ; | 
|---|
|  |  |  | sv.saveRmAlarmStateHistory(po) ; | 
|---|
|  |  |  | //        RmAlarmStateHistory po = new RmAlarmStateHistory(null, controller==null?null:controller.getId(), controller==null?null:controller.getIntakeId(), | 
|---|
|  |  |  | //                rtuAddr, | 
|---|
|  |  |  | //                DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt), | 
|---|
|  |  |  | //                DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(rtuDt), | 
|---|
|  |  |  | //                alarmVo==null?null:alarmVo.batteryVolt, alarmVo==null?null:alarmVo.loss, alarmVo==null?null:alarmVo.meter, alarmVo==null?null:alarmVo.valve, | 
|---|
|  |  |  | //                stateVo==null?null:stateVo.icCard, stateVo==null?null:stateVo.working, stateVo==null?null:stateVo.valve) ; | 
|---|
|  |  |  | //        sv.saveRmAlarmStateHistory(po) ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | private RmAlarmStateLast update(PrController controller, RmAlarmStateLast po, String rtuDt, DataV1_0_1 dV1_0_1, DataAlarmVo alarmVo, DataStateVo stateVo) throws Exception { | 
|---|
|  |  |  | po.controllerid = controller==null?null:controller.getId() ; | 
|---|
|  |  |  | po.intakeid = controller==null?null:controller.getIntakeId() ; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | po.dt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt) ; | 
|---|
|  |  |  | po.rtudt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(rtuDt) ; | 
|---|
|  |  |  | if(alarmVo != null){ | 
|---|
|  |  |  | po.bateryvolt = alarmVo.batteryVolt ; | 
|---|
|  |  |  | po.loss = alarmVo.loss ; | 
|---|
|  |  |  | po.meter = alarmVo.meter ; | 
|---|
|  |  |  | po.valve = alarmVo.valve ; | 
|---|
|  |  |  | }else{ | 
|---|
|  |  |  | po.bateryvolt = null ; | 
|---|
|  |  |  | po.loss = null ; | 
|---|
|  |  |  | po.meter = null ; | 
|---|
|  |  |  | po.valve = null ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | if(stateVo != null){ | 
|---|
|  |  |  | po.iccard = stateVo.icCard ; | 
|---|
|  |  |  | po.working = stateVo.working ; | 
|---|
|  |  |  | po.valvestate = stateVo.valve ; | 
|---|
|  |  |  | }else{ | 
|---|
|  |  |  | po.iccard = null ; | 
|---|
|  |  |  | po.working = null ; | 
|---|
|  |  |  | po.valvestate = null ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | //        po.controllerid = controller==null?null:controller.getId() ; | 
|---|
|  |  |  | //        po.intakeid = controller==null?null:controller.getIntakeId() ; | 
|---|
|  |  |  | // | 
|---|
|  |  |  | //        po.dt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(dV1_0_1.dt) ; | 
|---|
|  |  |  | //        po.rtudt = DateTime.dateFrom_yyyy_MM_dd_HH_mm_ss(rtuDt) ; | 
|---|
|  |  |  | //        if(alarmVo != null){ | 
|---|
|  |  |  | //            po.bateryvolt = alarmVo.batteryVolt ; | 
|---|
|  |  |  | //            po.loss = alarmVo.loss ; | 
|---|
|  |  |  | //            po.meter = alarmVo.meter ; | 
|---|
|  |  |  | //            po.valve = alarmVo.valve ; | 
|---|
|  |  |  | //        }else{ | 
|---|
|  |  |  | //            po.bateryvolt = null ; | 
|---|
|  |  |  | //            po.loss = null ; | 
|---|
|  |  |  | //            po.meter = null ; | 
|---|
|  |  |  | //            po.valve = null ; | 
|---|
|  |  |  | //        } | 
|---|
|  |  |  | //        if(stateVo != null){ | 
|---|
|  |  |  | //           po.iccard = stateVo.icCard ; | 
|---|
|  |  |  | //           po.working = stateVo.working ; | 
|---|
|  |  |  | //           po.valvestate = stateVo.valve ; | 
|---|
|  |  |  | //        }else{ | 
|---|
|  |  |  | //            po.iccard = null ; | 
|---|
|  |  |  | //            po.working = null ; | 
|---|
|  |  |  | //            po.valvestate = null ; | 
|---|
|  |  |  | //        } | 
|---|
|  |  |  | return po ; | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|