package com.dy.rtuMw.server.rtuData;

import com.dy.common.mw.UnitAdapterInterface;
import com.dy.common.mw.UnitInterface;
import com.dy.common.mw.UnitStartedCallbackInterface;

public class RtuDataUnit  implements UnitInterface {

	private static RtuDataUnit instance = new RtuDataUnit() ;
	
	public static RtuDataUnitAdapter adapter ;
	public static RtuDataUnitConfigVo confVo ;

	private RtuDataUnit(){} ;
	
	public static RtuDataUnit getInstance(){
		return instance ;
	}
	
	@Override
	public void setAdapter(UnitAdapterInterface adapter) throws Exception {
		if(adapter == null){
			throw new Exception("RTU数据处理模块适配器对象不能为空！") ;
		}
		RtuDataUnit.adapter = (RtuDataUnitAdapter)adapter ; 
		RtuDataUnit.confVo = RtuDataUnit.adapter.getConfig() ;
		if(RtuDataUnit.confVo == null){
			throw new Exception("RTU数据处理模块配置对象不能为空！") ;
		}
	}

	/**
	 * 初始化上行数据处理任务池
	 */
	@Override
	public void start(UnitStartedCallbackInterface callback) throws Exception {
		TaskPool.setTaskTreeCofig(new TreeParse().parseConfig(confVo.resourceLoader));
		callback.call(null) ;
		System.out.println("RTU数据处理模块成功启动");
	}

	@Override
	public void stop(UnitStartedCallbackInterface callback) throws Exception {
	}

}