升级任务结束后，更新数据库，update任务完成状态

liurunyu

2024-11-28 f913e0bef379c480805046ae8cd09532f530cf31

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

@@ -10,7 +10,6 @@
import com.dy.pipIrrGlobal.pojoPr.PrControllerTramp;
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 +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,6 +152,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 +214,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 +268,12 @@

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

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

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

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

    /**
     * 保存控制器整点上报罪行数据
     * 保存控制器定点上报罪行数据
     * @param po
     */
    @Transactional(rollbackFor = Exception.class)
@@ -675,6 +677,7 @@
     * @param id
     * @param remainMoney
     */
    @Transactional(rollbackFor = Exception.class)
    public void updateIcCardRemainMoney(Long id , Double remainMoney){
        seClientCardDao.updateMoney(id,remainMoney);
    }
@@ -684,6 +687,7 @@
     * @param id
     * @param remainMoney
     */
    @Transactional(rollbackFor = Exception.class)
    public void updateVirIcCardRemainMoney(Long id , Double remainMoney){
        seVirtualCardDao.updateMoney(id,remainMoney);
    }
@@ -696,6 +700,7 @@
    public RmCommandHistory getCommandLog(String commandId){
        return rmCommandHistoryDao.selectByPrimaryKey(Long.parseLong(commandId)) ;
    }
    @Transactional(rollbackFor = Exception.class)
    public void updateCommandLog(RmCommandHistory po){
        rmCommandHistoryDao.updateByPrimaryKey(po) ;
    }