|  |  | 
 |  |  |             PrController controller = (PrController)objs[1] ; | 
 |  |  |             if(cdObj instanceof DataCd81Vo){ | 
 |  |  |                 //设备终端随机自报 | 
 |  |  |                 if(this.needSave2Db( d.getRtuAddr())) { | 
 |  |  |                     //在一个小时内没有存储报警数据 | 
 |  |  |                     DataCd81Vo cdData = (DataCd81Vo)(cdObj) ; | 
 |  |  |                     this.toMsCenter(controller, d.getRtuAddr(), dV202404, cdData, dV202404.dt); | 
 |  |  |                     this.saveOrUpdateLast(sv, controller, d.getRtuAddr(), cdData.rtuDt, cdData, dV202404.dt) ; | 
 |  |  |                     this.saveHistory(sv, controller, d.getRtuAddr(), cdData.rtuDt, cdData, dV202404.dt) ; | 
 |  |  |                     this.cacheSaveTime(d.getRtuAddr()); | 
 |  |  |                     if(cdData.statePump != null && cdData.statePump.byteValue() == AlarmVo.DevCloseState){ | 
 |  |  |                         if(controller != null && controller.getIntakeId() != null){ | 
 |  |  |                             this.taskResult = new Object[]{controller.getIntakeId(), AlarmVo.DevCloseState} ; | 
 |  |  |                             toNext = true ; | 
 |  |  |                         } | 
 |  |  |                 //81功能码数据,不进行“在一个小时内没有存储报警数据”的控制 | 
 |  |  |                 DataCd81Vo cdData = (DataCd81Vo)(cdObj) ; | 
 |  |  |                 this.toMsCenter(controller, d.getRtuAddr(), dV202404, cdData, dV202404.dt); | 
 |  |  |                 this.saveOrUpdateLast(sv, controller, d.getRtuAddr(), cdData.rtuDt, cdData, dV202404.dt) ; | 
 |  |  |                 this.saveHistory(sv, controller, d.getRtuAddr(), cdData.rtuDt, cdData, dV202404.dt) ; | 
 |  |  |                 this.cacheSaveTime(d.getRtuAddr()); | 
 |  |  |                 if(cdData.statePump != null && cdData.statePump.byteValue() == AlarmVo.DevCloseState){ | 
 |  |  |                     if(controller != null && controller.getIntakeId() != null){ | 
 |  |  |                         this.taskResult = new Object[]{controller.getIntakeId(), AlarmVo.DevCloseState} ; | 
 |  |  |                         toNext = true ; | 
 |  |  |                     } | 
 |  |  |                 } | 
 |  |  |             }else if(cdObj instanceof DataCd80_5BVo){ | 
 |  |  | 
 |  |  |                         } | 
 |  |  |                     } | 
 |  |  |                 } | 
 |  |  |             }else if(cdObj instanceof DataCd93_A3Vo){ | 
 |  |  |             } | 
 |  |  |             /* 2025-06-11 王江海说:以下数据中的状态不准确,尤其阀门状态,所以不再采纳 | 
 |  |  |             else if(cdObj instanceof DataCd93_A3Vo){ | 
 |  |  |                 //平台/APP远程关闭水泵/阀门   +  刷卡关泵/阀上报 | 
 |  |  |                 if(this.needSave2Db( d.getRtuAddr())) { | 
 |  |  |                     //在一个小时内没有存储报警数据 | 
 |  |  | 
 |  |  |                     } | 
 |  |  |                 } | 
 |  |  |             } | 
 |  |  |              */ | 
 |  |  |         }catch (Exception e){ | 
 |  |  |             log.error("保存控制器报警和状态数据时发生异常", e); | 
 |  |  |         } |