liurunyu
2024-10-31 74b5d60307823de027c220d9a5e98ce6104822aa
pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/rtuData/dbSv/DbSv.java
@@ -1,6 +1,5 @@
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;
@@ -69,9 +68,9 @@
    private RmTimingReportLastMapper rmTimingReportLastDao; // 定点上报最新数据DAO
    @Autowired
    private RmOnHourReportHistoryMapper rmOnHourReportHistoryDao; // 整点上报历史数据DAO
    private RmOnHourReportHistoryMapper rmOnHourReportHistoryDao; // 定点上报历史数据DAO
    @Autowired
    private RmOnHourReportLastMapper rmOnHourReportLastDao; // 整点上报最新数据DAO
    private RmOnHourReportLastMapper rmOnHourReportLastDao; // 定点上报最新数据DAO
    //@Autowired
@@ -153,9 +152,9 @@
     */
    @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) ;
    }
   /**
@@ -269,12 +268,12 @@
    /////////////////////////////////////////////////
    //
    // 整点上报实时数据功能(只在靳总的协议有此数据)
    // 定点上报实时数据功能(只在靳总的协议有此数据)
    //
    ////////////////////////////////////////////////
    /**
     * 保存控制器整点上报历史数据
     * 保存控制器定点上报历史数据
     * @param po
     */
    @Transactional(rollbackFor = Exception.class)
@@ -283,7 +282,7 @@
    }
    /**
     * 根据阀控器地址获取整点上报最新数据
     * 根据阀控器地址获取定点上报最新数据
     * @param intakeId
     * @return
     */
@@ -297,7 +296,7 @@
    }
    /**
     * 保存控制器整点上报最新数据
     * 保存控制器定点上报最新数据
     * @param po
     */
    @Transactional(rollbackFor = Exception.class)
@@ -306,7 +305,7 @@
    }
    /**
     * 保存控制器整点上报罪行数据
     * 保存控制器定点上报罪行数据
     * @param po
     */
    @Transactional(rollbackFor = Exception.class)