| | |
| | | package com.dy.rtuMw.server.rtuData.dbSv; |
| | | |
| | | import com.alibaba.fastjson2.JSON; |
| | | import com.dy.common.util.NumUtil; |
| | | import com.dy.pipIrrGlobal.daoPr.PrControllerMapper; |
| | | import com.dy.pipIrrGlobal.daoPr.PrControllerTrampMapper; |
| | |
| | | private RmTimingReportLastMapper rmTimingReportLastDao; // 定点上报最新数据DAO |
| | | |
| | | @Autowired |
| | | private RmOnHourReportHistoryMapper rmOnHourReportHistoryDao; // 整点上报历史数据DAO |
| | | private RmOnHourReportHistoryMapper rmOnHourReportHistoryDao; // 定点上报历史数据DAO |
| | | @Autowired |
| | | private RmOnHourReportLastMapper rmOnHourReportLastDao; // 整点上报最新数据DAO |
| | | private RmOnHourReportLastMapper rmOnHourReportLastDao; // 定点上报最新数据DAO |
| | | |
| | | |
| | | //@Autowired |
| | |
| | | */ |
| | | @Transactional(rollbackFor = Exception.class) |
| | | public void savePrConctrollerTramp(PrControllerTramp po){ |
| | | System.out.println("------------------------------********************--------------------"); |
| | | po.setOrgTag("DY"); |
| | | System.out.println(JSON.toJSONString(po)); |
| | | if(po.getOrgTag().trim().length() > 2) { |
| | | po.setOrgTag("DY"); |
| | | } |
| | | this.prControllerTrampMapperDao.insert(po) ; |
| | | } |
| | | /** |
| | |
| | | |
| | | ///////////////////////////////////////////////// |
| | | // |
| | | // 整点上报实时数据功能(只在靳总的协议有此数据) |
| | | // 定点上报实时数据功能(只在靳总的协议有此数据) |
| | | // |
| | | //////////////////////////////////////////////// |
| | | |
| | | /** |
| | | * 保存控制器整点上报历史数据 |
| | | * 保存控制器定点上报历史数据 |
| | | * @param po |
| | | */ |
| | | @Transactional(rollbackFor = Exception.class) |
| | |
| | | } |
| | | |
| | | /** |
| | | * 根据阀控器地址获取整点上报最新数据 |
| | | * 根据阀控器地址获取定点上报最新数据 |
| | | * @param intakeId |
| | | * @return |
| | | */ |
| | |
| | | } |
| | | |
| | | /** |
| | | * 保存控制器整点上报最新数据 |
| | | * 保存控制器定点上报最新数据 |
| | | * @param po |
| | | */ |
| | | @Transactional(rollbackFor = Exception.class) |
| | |
| | | } |
| | | |
| | | /** |
| | | * 保存控制器整点上报罪行数据 |
| | | * 保存控制器定点上报罪行数据 |
| | | * @param po |
| | | */ |
| | | @Transactional(rollbackFor = Exception.class) |