package com.dy.common.mw.protocol;

import java.util.Collection;
import java.util.HashMap;

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


public class ProtocolUnit implements UnitInterface {

	private static final ProtocolUnit instance = new ProtocolUnit() ;
	
	public ProtocolUnitAdapter adapter ;
	
	private ProtocolUnit(){}
	
	public static ProtocolUnit getInstance(){
		return instance ;
	}
	
	@Override
	public void setAdapter(UnitAdapterInterface adapter) throws Exception {
		if(adapter == null){
			throw new Exception("协议模块适配器对象不能为空！") ;
		}
		this.adapter = (ProtocolUnitAdapter)adapter ;
		
		ProtocolConfigVo vo = this.adapter.getConfig() ;
		if(vo == null){
			throw new Exception("协议模块配置对象不能为空！") ;
		}
		if(vo.centerAddr < 0 ||  vo.centerAddr > 4){//云控制中心地址是0
			throw new Exception("协议模块配置对象属性中心地址只能是0、1、2、3、4 ！") ;
		}
	}
	
	/**
	 * 启动模块
	 */
	public void start(UnitStartedCallbackInterface callback) throws Exception {
		//得到唯一实例， 并在生成唯一实例时，扫描注解类
		AnnotationScan.getIntance() ;
		
		//各个协议驱动类扫描自己的功能码注解
		HashMap<String, AnnotationDriverVo> drivers =  ProtocolCache.getDriverMap() ;
		Collection<String> colDrivers = drivers.keySet() ;
		StringBuilder totalProtocols = new StringBuilder() ;
		for(String protocolName : colDrivers){
			if(!totalProtocols.isEmpty()){
				totalProtocols.append("，") ;
			}
			totalProtocols.append(protocolName) ;
			Driver dri = ProtocolCache.getDriver(protocolName) ;
			if(dri != null){
				dri.scanAnnotationCode();
			}
		}
		if(adapter.getConfig().showStartInfo){
			System.out.println("协议模块成功启动，"
							+ "支持的协议：" + totalProtocols  );
		}
		callback.call(null);
	}
	
	/**
	 * 是否只有一个协议
	 * @return 结果
	 */
	@SuppressWarnings("unused")
	public boolean isOnlyOneProtocol(){
		HashMap<String, AnnotationDriverVo> drivers =  ProtocolCache.getDriverMap() ;
		return drivers.size() == 1 ;
	}

	@Override
	public void stop(UnitStartedCallbackInterface callback) {
	}
	
	/*
	public static void main(String[] args) throws Exception{
		ProtocolUnit protoUnit = ProtocolUnit.getInstance();
		protoUnit.start(new UnitStartedCallbackInterface(){
			@Override
			public void call(Object obj) {
			}
		});
	}
	*/

}