|  |  |  | 
|---|
|  |  |  | 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 | 
|---|
|  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 初始化上行数据处理任务池 | 
|---|
|  |  |  | * 初始化 | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public void start(UnitCallbackInterface callback) throws Exception { | 
|---|
|  |  |  | 
|---|
|  |  |  |  | 
|---|
|  |  |  | @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 "通信中间件内部错误" ; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | * @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); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 当前升级状态 | 
|---|
|  |  |  | * @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 ; | 
|---|
|  |  |  | }*/ | 
|---|
|  |  |  |  | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|