| | |
| | | @Autowired |
| | | private RmAlarmStateHistoryMapper rmAlarmStateHistoryMapperDao ;//控制器历史报警和状态DAO |
| | | @Autowired |
| | | private RmAutoReportLastMapper rmAutoReportLastMapperDao ;//控制器最新上报数据DAO |
| | | @Autowired |
| | | private RmAutoReportHistoryMapper rmAutoReportHistoryMapperDao ;//控制器历史上报数据DAO |
| | | @Autowired |
| | | private RmOpenCloseValveLastMapper rmOpenCloseValveLastMapperDao ;//控制器最新开关阀上报数据DAO |
| | | @Autowired |
| | | private RmOpenCloseValveHistoryMapper rmOpenCloseValveHistoryMapperDao ;//控制器历史开关阀上报数据DAO |
| | |
| | | |
| | | ///////////////////////////////////////////////// |
| | | // |
| | | // 主动上报数据功能 |
| | | // 定点报数据功能 |
| | | // |
| | | //////////////////////////////////////////////// |
| | | /** |
| | | * 得到控制器上报数据最新记录 |
| | | * @param rtuAddr |
| | | * @return |
| | | */ |
| | | public RmAutoReportLast getRmAutoReportLast(String rtuAddr){ |
| | | List<RmAutoReportLast> list = rmAutoReportLastMapperDao.selectByRtuAddr(rtuAddr) ; |
| | | if(list != null && list.size() > 0){ |
| | | return list.get(0) ; |
| | | } |
| | | return null ; |
| | | } |
| | | /** |
| | | * 保存控制器上报数据最新记录 |
| | | * @param po |
| | | */ |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public void saveRmAutoReportLast(RmAutoReportLast po){ |
| | | this.rmAutoReportLastMapperDao.insert(po) ; |
| | | } |
| | | /** |
| | | * 保存控制器上报数据最新记录 |
| | | * @param po |
| | | */ |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public void updateRmAutoReportLast(RmAutoReportLast po){ |
| | | this.rmAutoReportLastMapperDao.updateByPrimaryKeySelective(po) ; |
| | | } |
| | | /** |
| | | * 保存控制器上报数据历史记录 |
| | | * @param po |
| | | */ |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public void saveRmAutoReportHistory(RmAutoReportHistory po){ |
| | | this.rmAutoReportHistoryMapperDao.insert(po) ; |
| | | } |
| | | |
| | | |
| | | |
| | | |
| | | ///////////////////////////////////////////////// |