1、靳总协议功能码调整与增加； 2、实现只有靳总协议中有的整上报数据处理逻辑及数据库设计。

liurunyu

2024-06-26 f5658e38d9aaec4fc002f22938646343a7e86c81

 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/dbSv/DbSv.java

@@ -53,6 +53,11 @@
    private RmTimingReportLastMapper rmTimingReportLastDao; // 定点上报最新数据DAO

    @Autowired
    private RmOnHourReportHistoryMapper rmOnHourReportHistoryDao; // 整点上报历史数据DAO
    @Autowired
    private RmOnHourReportLastMapper rmOnHourReportLastDao; // 整点上报最新数据DAO

    @Autowired
    private RmOpenCloseHistoryMapper rmOpenCloseHistoryDao;
    @Autowired
    private RmOpenCloseLastMapper rmOpenCloseLastDao;
@@ -162,7 +167,7 @@

    /////////////////////////////////////////////////
    //
    // 定点报数据功能
    // 定点报数据功能(只在王江海的协议有此数据)
    //
    ////////////////////////////////////////////////

@@ -207,6 +212,52 @@
        this.rmTimingReportLastDao.updateByPrimaryKeySelective(po);
    }

    /////////////////////////////////////////////////
    //
    // 整点上报实时数据功能(只在靳总的协议有此数据)
    //
    ////////////////////////////////////////////////

    /**
     * 保存控制器整点上报历史数据
     * @param po
     */
    @Transactional(rollbackFor = Exception.class)
    public void saveRmOnHourReportHistory(RmOnHourReportHistory po){
        this.rmOnHourReportHistoryDao.insert(po);
    }

    /**
     * 根据阀控器地址获取整点上报最新数据
     * @param rtuAddr
     * @return
     */
    @Transactional(rollbackFor = Exception.class)
    public RmOnHourReportLast getRmOnHourReportLast(String rtuAddr) {
        List<RmOnHourReportLast> list = this.rmOnHourReportLastDao.getRmOnHourReportLast(rtuAddr) ;
        if(list != null && list.size() > 0){
            return list.get(0) ;
        }
        return null ;
    }

    /**
     * 保存控制器整点上报最新数据
     * @param po
     */
    @Transactional(rollbackFor = Exception.class)
    public void saveRmOnHourReportLast(RmOnHourReportLast po) {
        this.rmOnHourReportLastDao.insert(po);
    }

    /**
     * 保存控制器整点上报罪行数据
     * @param po
     */
    @Transactional(rollbackFor = Exception.class)
    public void updateRmOnHourReportLast(RmOnHourReportLast po) {
        this.rmOnHourReportLastDao.updateByPrimaryKeySelective(po);
    }

    /////////////////////////////////////////////////
    //