水肥、气象、墒情数据处理：最新数据、历史数据、墒情日数据

liurunyu

6 天以前 4efc605092f68311876299290a33697ebbfd3a5d

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

@@ -1,16 +1,13 @@
package com.dy.rtuMw.server.rtuData.dbSv;

import com.dy.common.util.NumUtil;
import com.dy.pipIrrGlobal.daoPr.PrControllerMapper;
import com.dy.pipIrrGlobal.daoPr.PrControllerTrampMapper;
import com.dy.pipIrrGlobal.daoPr.*;
import com.dy.pipIrrGlobal.daoRm.*;
import com.dy.pipIrrGlobal.daoSe.SeClientCardMapper;
import com.dy.pipIrrGlobal.daoSe.SeVirtualCardMapper;
import com.dy.pipIrrGlobal.pojoPr.PrController;
import com.dy.pipIrrGlobal.pojoPr.PrControllerTramp;
import com.dy.pipIrrGlobal.pojoPr.*;
import com.dy.pipIrrGlobal.pojoRm.*;
import com.dy.pipIrrGlobal.pojoSe.SeClient;
import com.dy.pipIrrGlobal.pojoSe.SeClientCard;
import com.dy.pipIrrGlobal.voSe.VoCardInfo1;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@@ -69,9 +66,30 @@
    private RmTimingReportLastMapper rmTimingReportLastDao; // 定点上报最新数据DAO

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

    @Autowired
    private PrStManureMapper prStManureDao; //水肥机DAO
    @Autowired
    private PrStSoilMapper prStSoilDao; //墒情站DAO
    @Autowired
    private PrStWeatherMapper prStWeatherDao; //气象站DAO
    @Autowired
    private RmManureLastMapper rmManureLastDao; //水肥DAO
    @Autowired
    private RmManureHistoryMapper rmManureHistoryDao; //水肥DAO
    @Autowired
    private RmSoilLastMapper rmSoilLastDao; //墒情DAO
    @Autowired
    private RmSoilHistoryMapper rmSoilHistoryDao; //墒情DAO
    @Autowired
    private RmSoilDayMapper rmSoilDayDao; //墒情DAO
    @Autowired
    private RmWeatherLastMapper rmWeatherLastDao; //气象DAO
    @Autowired
    private RmWeatherHistoryMapper rmWeatherHistoryDao; //气象DAO


    //@Autowired
@@ -99,6 +117,7 @@
                vo = new SeClient() ;
                vo.setId(Long.parseLong(map.get("clientId").toString()));
                vo.setName(map.get("clientName").toString());
                vo.setAddress(map.get("clientAddress").toString());
            }
        }
        return vo ;
@@ -117,6 +136,7 @@
                vo = new SeClient() ;
                vo.setId(Long.parseLong(map.get("clientId").toString()));
                vo.setName(map.get("clientName").toString());
                vo.setAddress(map.get("clientAddress").toString());
            }
        }
        return vo ;
@@ -153,6 +173,9 @@
     */
    @Transactional(rollbackFor = Exception.class)
    public void savePrConctrollerTramp(PrControllerTramp po){
        if(po.getOrgTag().trim().length() > 2) {
            po.setOrgTag("DY");
        }
        this.prControllerTrampMapperDao.insert(po) ;
    }
   /**
@@ -212,8 +235,8 @@
     * @param intakeId
     */
    @Transactional(rollbackFor = Exception.class)
    public void updateVirCardNoUseState(Long intakeId){
        this.seVirtualCardDao.updateVcCardNoUseStateByIntakeId(intakeId); ;
    public void updateVirCardNoUseState(Long intakeId, Date now){
        this.seVirtualCardDao.updateVcCardNoUseStateByIntakeId(intakeId, now) ;
    }


@@ -266,12 +289,12 @@

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

    /**
     * 保存控制器整点上报历史数据
     * 保存控制器定点上报历史数据
     * @param po
     */
    @Transactional(rollbackFor = Exception.class)
@@ -280,7 +303,7 @@
    }

    /**
     * 根据阀控器地址获取整点上报最新数据
     * 根据阀控器地址获取定点上报最新数据
     * @param intakeId
     * @return
     */
@@ -294,7 +317,7 @@
    }

    /**
     * 保存控制器整点上报最新数据
     * 保存控制器定点上报最新数据
     * @param po
     */
    @Transactional(rollbackFor = Exception.class)
@@ -303,7 +326,7 @@
    }

    /**
     * 保存控制器整点上报罪行数据
     * 保存控制器定点上报罪行数据
     * @param po
     */
    @Transactional(rollbackFor = Exception.class)
@@ -690,6 +713,209 @@
        seVirtualCardDao.updateMoney(id,remainMoney);
    }


    //////////////////////////////////////////////////////
    //
    // 水肥数据相关
    //
    //////////////////////////////////////////////////////
    /**
     * 通过FBox序列号得到水肥机实体
     * @param fboxId FBox序列号
     * @param no 编号
     * @return 水肥机实体
     */
    public PrStManure getStManureByFBoxIdAndNo(String fboxId, Integer no){
        List<PrStManure> list = this.prStManureDao.selectStPoByFBoxIdAndNo(fboxId, no) ;
        if(list != null && list.size() > 0){
            return list.get(0) ;
        }
        return null ;
    }
    /**
     * 查询上报最新数据
     * @param stManureId
     * @return
     */
    public RmManureLast getRmManureLast(Long stManureId) {
        List<RmManureLast> list = this.rmManureLastDao.selectRmManureLast(stManureId) ;
        if(list != null && list.size() > 0){
            return list.get(0) ;
        }
        return null ;
    }
    /**
     * 保存最新记录
     * @param po
     */
    @Transactional(rollbackFor = Exception.class)
    public void saveRmManureHistory(RmManureHistory po) {
        this.rmManureHistoryDao.insert(po);
    }

    /**
     * 保存最新记录
     * @param po
     */
    @Transactional(rollbackFor = Exception.class)
    public void saveRmManureLast(RmManureLast po) {
        this.rmManureLastDao.insert(po);
    }
    /**
     * 更新最新记录
     * @param po
     */
    @Transactional(rollbackFor = Exception.class)
    public void updateRmManureLast(RmManureLast po){
        this.rmManureLastDao.updateByPrimaryKey(po) ;
    }


    //////////////////////////////////////////////////////
    //
    // 墒情数据相关
    //
    //////////////////////////////////////////////////////
    /**
     * 通过FBox序列号得到墒情站实体
     * @param fboxId FBox序列号
     * @param no 编号
     * @return 水肥机实体
     */
    public PrStSoil getStSoilByFBoxIdAndNo(String fboxId, Integer no){
        List<PrStSoil> list = this.prStSoilDao.selectStPoByFBoxIdAndNo(fboxId, no) ;
        if(list != null && list.size() > 0){
            return list.get(0) ;
        }
        return null ;
    }
    /**
     * 查询上报最新数据
     * @param stSoilId
     * @return
     */
    public RmSoilLast getRmSoilLast(Long stSoilId) {
        List<RmSoilLast> list = this.rmSoilLastDao.selectRmSoilLast(stSoilId) ;
        if(list != null && list.size() > 0){
            return list.get(0) ;
        }
        return null ;
    }
    /**
     * 保存最新记录
     * @param po
     */
    @Transactional(rollbackFor = Exception.class)
    public void saveRmSoilHistory(RmSoilHistory po) {
        this.rmSoilHistoryDao.insert(po);
    }

    /**
     * 保存最新记录
     * @param po
     */
    @Transactional(rollbackFor = Exception.class)
    public void saveRmSoilLast(RmSoilLast po) {
        this.rmSoilLastDao.insert(po);
    }
    /**
     * 更新最新记录
     * @param po
     */
    @Transactional(rollbackFor = Exception.class)
    public void updateRmSoilLast(RmSoilLast po){
        this.rmSoilLastDao.updateByPrimaryKey(po) ;
    }

    /**
     * 查询上报日数据
     * @param stSoilId
     * @return
     */
    @Transactional(rollbackFor = Exception.class)
    public RmSoilDay getRmSoilDay(Long stSoilId, Integer nowYmd) {
        List<RmSoilDay> list = this.rmSoilDayDao.selectRmSoilDay(stSoilId, nowYmd) ;
        if(list != null && list.size() > 0){
            return list.get(0) ;
        }
        return null ;
    }
    /**
     * 保存日记录
     * @param po
     */
    @Transactional(rollbackFor = Exception.class)
    public void saveRmSoilDay(RmSoilDay po) {
        this.rmSoilDayDao.insert(po);
    }
    /**
     * 更新日记录
     * @param po
     */
    @Transactional(rollbackFor = Exception.class)
    public void updateRmSoilDay(RmSoilDay po){
        this.rmSoilDayDao.updateByPrimaryKey(po) ;
    }



    //////////////////////////////////////////////////////
    //
    // 气象数据相关
    //
    //////////////////////////////////////////////////////
    /**
     * 通过FBox序列号得到气象站实体
     * @param fboxId FBox序列号
     * @param no 编号
     * @return 水肥机实体
     */
    public PrStWeather getStWeatherByFBoxIdAndNo(String fboxId, Integer no){
        List<PrStWeather> list = this.prStWeatherDao.selectStPoByFBoxIdAndNo(fboxId, no) ;
        if(list != null && list.size() > 0){
            return list.get(0) ;
        }
        return null ;
    }

    /**
     * 查询上报最新数据
     * @param stWeatherId
     * @return
     */
    public RmWeatherLast getRmWeatherLast(Long stWeatherId) {
        List<RmWeatherLast> list = this.rmWeatherLastDao.selectRmWeatherLast(stWeatherId) ;
        if(list != null && list.size() > 0){
            return list.get(0) ;
        }
        return null ;
    }
    /**
     * 保存最新记录
     * @param po
     */
    @Transactional(rollbackFor = Exception.class)
    public void saveRmWeatherHistory(RmWeatherHistory po) {
        this.rmWeatherHistoryDao.insert(po);
    }

    /**
     * 保存最新记录
     * @param po
     */
    @Transactional(rollbackFor = Exception.class)
    public void saveRmWeatherLast(RmWeatherLast po) {
        this.rmWeatherLastDao.insert(po);
    }
    /**
     * 更新最新记录
     * @param po
     */
    @Transactional(rollbackFor = Exception.class)
    public void updateRmWeatherLast(RmWeatherLast po){
        this.rmWeatherLastDao.updateByPrimaryKey(po) ;
    }

    //////////////////////////////////////////////////////
    //
    // 命令日志相关