了解到硬件设备开阀后的工作报上报间隔都已经修改了，测控一体阀改为十多分钟上报一次数据，表阀一体机30分钟上报一次数据，所以config.xml配置文件...

liurunyu

2025-02-25 137f898781b3ee2b545f5014bd8f46b419d54cc2

 pipIrr-platform/pipIrr-mw/pipIrr-mw-rtu/src/main/java/com/dy/rtuMw/server/upgrade/UpgradeUnit.java

@@ -3,9 +3,8 @@
import com.dy.common.mw.UnitAdapterInterface;
import com.dy.common.mw.UnitCallbackInterface;
import com.dy.common.mw.UnitInterface;
import com.dy.common.softUpgrade.state.UpgradeTaskVo;
import com.dy.common.util.Callback;

import java.util.List;

/**
 * @Author: liurunyu
@@ -40,7 +39,7 @@
    }

    /**
     * 初始化上行数据处理任务池
     * 初始化
     */
    @Override
    public void start(UnitCallbackInterface callback) throws Exception {
@@ -57,44 +56,32 @@

    @Override
    public void stop(UnitCallbackInterface callback) throws Exception {
        stopUpgradeTask() ;
        forceOverUpgradeTask() ;
    }



    /**
     * 设置升级任务
     * @param softFileName 升级程序文件名
     * @param softStoreAddr 升级程序存放地址
     * @param softStartAddr 程序覆盖起始地址
     * @param softFileData 升级程序字节数组
     * @param softBytesCalculate 升级程序字节数(按公式计算)
    * @param rtuAddrList 升级RTU
     * @param vo UpgradeTaskVo 升级任务对象
     * @throws Exception
     */
    public void setUpgradeTask(String softFileName,
                               String softStoreAddr,
                               String softStartAddr,
                               byte[] softFileData,
                               Integer softBytesCalculate,
                               List<String> rtuAddrList) throws Exception {
    public void setUpgradeTask(UpgradeTaskVo vo) throws Exception {
        if(manager != null ){
            manager.setUpgradeTask(softFileName,
                    softStoreAddr,
                    softStartAddr,
                    softFileData,
                    softBytesCalculate,
                    rtuAddrList) ;
            manager.setUpgradeTask(vo) ;
        }
    }

    /**
     * 停止当前升级任务
     * 结束当前升级任务
     * @throws Exception
     * @return null：结束任务成功，否则返回失败原因
     */
    public void stopUpgradeTask() throws Exception {
    public String forceOverUpgradeTask() throws Exception {
        if(manager != null ){
            manager.stopUpgradeTask() ;
            return manager.forceOverUpgradeTask() ;
        }else{
            return "通信中间件内部错误" ;
        }
    }

@@ -104,9 +91,9 @@
     * @param code
     * @param callback
     */
    public void trigger(String rtuAddr, String code, String protocolName, Short protocolVersion, Callback callback){
    public void trigger(String rtuAddr, String code, String protocolName, Short protocolVersion, Callback callback, Object ...objects){
        if(manager != null ){
            manager.trigger(rtuAddr, code, protocolName, protocolVersion, callback);
            manager.trigger(rtuAddr, code, protocolName, protocolVersion, callback, objects);
        }
    }

@@ -118,37 +105,44 @@
    /**
     * 当前升级状态
     * @return
     */
    public UpgradeState currentUpgradeState() {
        if(manager != null ){
            return manager.currentUpgradeState();
        }
        return null ;
    }
    }*/

    /**
     * Rtu升级信息
     * @param rtuAddr
     * @return
     */
    public UpgradeRtu upgradeInfos(String rtuAddr){
    public UpgradeRtuDev upgradeRtuInfo(String rtuAddr){
        if(manager != null ){
            return manager.upgradeInfos(rtuAddr);
        }
        return null ;
    }
    }*/

    /**
     * Rtu升级信息
     * @param rtuAddrList
     * @return
     */
    public List<UpgradeRtu> upgradeInfos(List<String> rtuAddrList){
    public List<UpgradeRtuDev> upgradeRtuInfos(List<String> rtuAddrList){
        if(manager != null ){
            return manager.upgradeInfos(rtuAddrList);
        }
        return null ;
    }
    }*/

    /**
     * Rtu升级信息
     * @return
    public List<UpgradeRtuDev> upgradeRtuInfoAll(){
        if(manager != null ){
            return manager.upgradeInfoAll();
        }
        return null ;
    }*/

}