package com.dy.rtuMw.server.upgrade;
|
|
import com.dy.common.mw.UnitAdapterInterface;
|
import com.dy.common.mw.UnitCallbackInterface;
|
import com.dy.common.mw.UnitInterface;
|
import com.dy.common.util.Callback;
|
|
import java.util.List;
|
|
/**
|
* @Author: liurunyu
|
* @Date: 2024/11/4 14:16
|
* @Description
|
*/
|
public class UpgradeUnit implements UnitInterface {
|
|
private static UpgradeUnit instance = new UpgradeUnit() ;
|
|
public static UpgradeUnitAdapter adapter ;
|
public static UpgradeUnitConfigVo confVo ;
|
|
private static UpgradeManager manager ;
|
|
private UpgradeUnit(){} ;
|
|
public static UpgradeUnit getInstance(){
|
return instance ;
|
}
|
|
@Override
|
public void setAdapter(UnitAdapterInterface adapter) throws Exception {
|
if(adapter == null){
|
throw new Exception("RTU远程升级模块适配器对象不能为空！") ;
|
}
|
UpgradeUnit.adapter = (UpgradeUnitAdapter)adapter ;
|
UpgradeUnit.confVo = UpgradeUnit.adapter.getConfig() ;
|
if(UpgradeUnit.confVo == null){
|
throw new Exception("RTU远程升级模块配置对象不能为空！") ;
|
}
|
}
|
|
/**
|
* 初始化上行数据处理任务池
|
*/
|
@Override
|
public void start(UnitCallbackInterface callback) throws Exception {
|
if(confVo.enable){
|
manager = UpgradeManager.getInstance() ;
|
manager.initOption(confVo);
|
callback.call(null) ;
|
System.out.println("RTU远程升级模块成功启动");
|
}else{
|
System.out.println("RTU远程升级模块配置不启动");
|
}
|
|
}
|
|
@Override
|
public void stop(UnitCallbackInterface callback) throws Exception {
|
stopUpgradeTask() ;
|
}
|
|
|
|
/**
|
* 设置升级任务
|
* @param softFileName 升级程序文件名
|
* @param softStoreAddr 升级程序存放地址
|
* @param softStartAddr 程序覆盖起始地址
|
* @param softFileData 升级程序字节数组
|
* @param softBytesCalculate 升级程序字节数(按公式计算)
|
* @param rtuAddrList 升级RTU
|
* @throws Exception
|
*/
|
public void setUpgradeTask(String softFileName,
|
String softStoreAddr,
|
String softStartAddr,
|
byte[] softFileData,
|
Integer softBytesCalculate,
|
List<String> rtuAddrList) throws Exception {
|
if(manager != null ){
|
manager.setUpgradeTask(softFileName,
|
softStoreAddr,
|
softStartAddr,
|
softFileData,
|
softBytesCalculate,
|
rtuAddrList) ;
|
}
|
}
|
|
/**
|
* 停止当前升级任务
|
* @throws Exception
|
*/
|
public void stopUpgradeTask() throws Exception {
|
if(manager != null ){
|
manager.stopUpgradeTask() ;
|
}
|
}
|
|
/**
|
* RTU有上行数据了，触发下发升级数据
|
* @param rtuAddr
|
* @param code
|
* @param callback
|
*/
|
public void trigger(String rtuAddr, String code, String protocolName, Short protocolVersion, Callback callback){
|
if(manager != null ){
|
manager.trigger(rtuAddr, code, protocolName, protocolVersion, callback);
|
}
|
}
|
|
////////////////////////////////////////////////////
|
//
|
// 查询升级状态信息
|
//
|
////////////////////////////////////////////////////
|
/**
|
* 当前升级状态
|
* @return
|
*/
|
public UpgradeState currentUpgradeState() {
|
if(manager != null ){
|
return manager.currentUpgradeState();
|
}
|
return null ;
|
}
|
|
/**
|
* Rtu升级信息
|
* @param rtuAddr
|
* @return
|
*/
|
public UpgradeRtu upgradeInfos(String rtuAddr){
|
if(manager != null ){
|
return manager.upgradeInfos(rtuAddr);
|
}
|
return null ;
|
}
|
|
/**
|
* Rtu升级信息
|
* @param rtuAddrList
|
* @return
|
*/
|
public List<UpgradeRtu> upgradeInfos(List<String> rtuAddrList){
|
if(manager != null ){
|
return manager.upgradeInfos(rtuAddrList);
|
}
|
return null ;
|
}
|
|
}
|
