package com.vci.server.base.utility;

import org.apache.commons.lang3.StringUtils;

import com.vci.common.ServiceNames;
import com.vci.common.log.ServerWithLog4j;
import com.vci.common.resource.IceClientProperties;
import com.vci.corba.common.VCIError;
import com.vci.corba.bofactory.BOFactoryServicePrx;
import com.vci.corba.framework.FrameworkServicePrx;
import com.vci.corba.log.LogServicePrx;
import com.vci.corba.omd.OMDServicePrx;
import com.vci.corba.portal.PortalServicePrx;
import com.vci.corba.query.ObjectQueryServicePrx;
import com.vci.corba.volume.VolumeServicePrx;
import com.vci.corba.workflow.WorkflowServicePrx;
import com.zeroc.Ice.Communicator;
import com.zeroc.Ice.Current;
import com.zeroc.Ice.ObjectPrx;

public final class ServerServiceProvider {
	
	private static final ThreadLocal<Current> threadLocal = new ThreadLocal<Current>();

	public static void setCurrent(Current current) {
		threadLocal.set(current);
	}
	/**
	 * 获取系统该框架服务代理
	 * @return
	 */
	public static FrameworkServicePrx getFrameService(Current current)  {
		try {
			ObjectPrx prx = getObjectByName(current.adapter.getCommunicator(), ServiceNames.FRAMESERVICE);
			
			FrameworkServicePrx prxTemp = FrameworkServicePrx.uncheckedCast(prx);
			return prxTemp.ice_context(current.ctx);
		} catch (Exception e) {
			//e.printStackTrace();
			ServerWithLog4j.logger.error(e);
		}
		
		return null;
	}
	
	/**
	 * 获取系统该框架服务代理
	 * @return
	 * @throws Exception 
	 */
	public static FrameworkServicePrx getFrameService() throws VCIError  {
		try {
			Current current = threadLocal.get();
			if (current == null)
				throw new VCIError("ServerServiceProvider-0001", new String[] {"获取当前上下文失败！"});
			
			ObjectPrx prx = getObjectByName(current.adapter.getCommunicator(), ServiceNames.FRAMESERVICE);
			
			FrameworkServicePrx prxTemp = FrameworkServicePrx.uncheckedCast(prx);
			return prxTemp.ice_context(current.ctx);
		} catch (VCIError e) {
			//e.printStackTrace();
			ServerWithLog4j.logger.error(e);
			throw e;
		}
	}
	
	/**
	 * 获取系统该框架服务代理
	 * @return
	 */
	public static LogServicePrx getLogService(Current current)  {
		try {
			ObjectPrx prx = getObjectByName(current.adapter.getCommunicator(), ServiceNames.LOGSERVICE);
			
			LogServicePrx prxTemp = LogServicePrx.uncheckedCast(prx);
			return prxTemp.ice_context(current.ctx);
		} catch (Exception e) {
			//e.printStackTrace();
			ServerWithLog4j.logger.error(e);
		}
		
		return null;
	}
	
	/**
	 * 获取系统该框架服务代理
	 * @return
	 * @throws Exception 
	 */
	public static LogServicePrx getLogService() throws VCIError  {
		try {
			Current current = threadLocal.get();
			if (current == null)
				throw new VCIError("ServerServiceProvider-0001", new String[] {"获取当前上下文失败！"});
			
			ObjectPrx prx = getObjectByName(current.adapter.getCommunicator(), ServiceNames.LOGSERVICE);
			
			LogServicePrx prxTemp = LogServicePrx.uncheckedCast(prx);
			return prxTemp.ice_context(current.ctx);
		} catch (VCIError e) {
			//e.printStackTrace();
			ServerWithLog4j.logger.error(e);
			throw e;
		}
	}	
	/**
	 * 获取系统授权认证框架服务代理
	 * @return
	 */
//	public static Auth2ServicePrx getAuth2Service(Current current)  {
//		try {
//			ObjectPrx prx = getObjectByName(current.adapter.getCommunicator(), ServiceNames.AUTH2SERVICE);
//			
//			Auth2ServicePrx prxTemp = Auth2ServicePrx.uncheckedCast(prx);
//			return prxTemp.ice_context(current.ctx);
//		} catch (Exception e) {
//			//e.printStackTrace();
//			ServerWithLog4j.logger.error(e);
//		}
//		
//		return null;
//	}
	
	/**
	 * 获取系统授权认证框架服务代理
	 * @return
	 * @throws Exception 
	 */
//	public static Auth2ServicePrx getAuth2Service() throws VCIError  {
//		try {
//			Current current = threadLocal.get();
//			if (current == null)
//				throw new VCIError("ServerServiceProvider-0002", new String[] {"获取当前上下文失败！"});
//			
//			ObjectPrx prx = getObjectByName(current.adapter.getCommunicator(), ServiceNames.AUTH2SERVICE);
//			
//			Auth2ServicePrx prxTemp = Auth2ServicePrx.uncheckedCast(prx);
//			return prxTemp.ice_context(current.ctx);
//		} catch (Exception e) {
//			//e.printStackTrace();
//			ServerWithLog4j.logger.error(e);
//			
//			throw e;
//		}
//	}
	
	/**
	 * 获取缓存服务代理
	 * @return
	 */
//	public static CacheServicePrx getCacheService(Current current)  {
//		try {
//			ObjectPrx prx = getObjectByName(current.adapter.getCommunicator(), ServiceNames.CACHESERVICE);
//			
//			CacheServicePrx prxTemp = CacheServicePrx.uncheckedCast(prx);
//			return prxTemp.ice_context(current.ctx);
//		} catch (Exception e) {
//			//e.printStackTrace();
//			ServerWithLog4j.logger.error(e);
//		}
//		
//		return null;
//	}
	
	/**
	 * 获取缓存服务代理
	 * @return
	 * @throws Exception 
	 */
//	public static CacheServicePrx getCacheService() throws VCIError  {
//		try {
//			Current current = threadLocal.get();
//			if (current == null)
//				throw new VCIError("ServerServiceProvider-0003", new String[] {"获取当前上下文失败！"});
//			
//			ObjectPrx prx = getObjectByName(current.adapter.getCommunicator(), ServiceNames.CACHESERVICE);
//			
//			CacheServicePrx prxTemp = CacheServicePrx.uncheckedCast(prx);
//			return prxTemp.ice_context(current.ctx);
//		} catch (Exception e) {
//			//e.printStackTrace();
//			ServerWithLog4j.logger.error(e);
//			throw e;
//		}
//	}
	
	/**
	 * 获取都西昂模型定义服务代理
	 * @return
	 * @throws Exception 
	 */
	public static OMDServicePrx getOMDService() throws VCIError  {
		try {
			Current current = threadLocal.get();
			if (current == null)
				throw new VCIError("ServerServiceProvider-0004", new String[] {"获取当前上下文失败！"});
			
			ObjectPrx prx = getObjectByName(current.adapter.getCommunicator(), ServiceNames.OMDSERVICE);
			
			OMDServicePrx prxTemp = OMDServicePrx.uncheckedCast(prx);
			return prxTemp.ice_context(current.ctx);
		} catch (Exception e) {
			//e.printStackTrace();
			ServerWithLog4j.logger.error(e);
			throw e;
		}
	}
	
	/**
	 * 获取都西昂模型定义服务代理
	 * @return
	 */
	public static OMDServicePrx getOMDService(Current current)  {
		try {
			ObjectPrx prx = getObjectByName(current.adapter.getCommunicator(), ServiceNames.OMDSERVICE);
			
			OMDServicePrx prxTemp = OMDServicePrx.uncheckedCast(prx);
			return prxTemp.ice_context(current.ctx);
		} catch (Exception e) {
			//e.printStackTrace();
			ServerWithLog4j.logger.error(e);
		}
		
		return null;
	}
	
	/**
	 * 获取业务对象工厂服务代理
	 * @return
	 */
	public static BOFactoryServicePrx getBOFService(Current current)  {
		try {
			ObjectPrx prx = getObjectByName(current.adapter.getCommunicator(), ServiceNames.BOFSERVICE);
			
			BOFactoryServicePrx prxTemp = BOFactoryServicePrx.uncheckedCast(prx);
			return prxTemp.ice_context(current.ctx);
		} catch (Exception e) {
			//e.printStackTrace();
			ServerWithLog4j.logger.error(e);
		}
		
		return null;
	}

	public static BOFactoryServicePrx getBOFService() throws VCIError  {
		try {
			Current current = threadLocal.get();
			if (current == null)
				throw new VCIError("ServerServiceProvider-0005", new String[] {"获取当前上下文失败！"});
			
			ObjectPrx prx = getObjectByName(current.adapter.getCommunicator(), ServiceNames.BOFSERVICE);
			
			BOFactoryServicePrx prxTemp = BOFactoryServicePrx.uncheckedCast(prx);
			return prxTemp.ice_context(current.ctx);
		} catch (Exception e) {
			//e.printStackTrace();
			ServerWithLog4j.logger.error(e);
			throw e;
		}
	}

	/**
	 * 获取查询模板定义服务代理
	 * @return
	 */
//	public static QTDServicePrx getQTDService(Current current)  {
//		try {
//			ObjectPrx prx = getObjectByName(current.adapter.getCommunicator(), ServiceNames.QTDSERVICE);
//			
//			QTDServicePrx prxTemp = QTDServicePrx.uncheckedCast(prx);
//			return prxTemp.ice_context(current.ctx);
//		} catch (Exception e) {
//			//e.printStackTrace();
//			ServerWithLog4j.logger.error(e);
//		}
//		
//		return null;
//	}

//	public static QTDServicePrx getQTDService() throws VCIError  {
//		try {
//			Current current = threadLocal.get();
//			if (current == null)
//				throw new VCIError("ServerServiceProvider-0006", new String[] {"获取当前上下文失败！"});
//			
//			ObjectPrx prx = getObjectByName(current.adapter.getCommunicator(), ServiceNames.QTDSERVICE);
//			
//			QTDServicePrx prxTemp = QTDServicePrx.uncheckedCast(prx);
//			return prxTemp.ice_context(current.ctx);
//		} catch (Exception e) {
//			//e.printStackTrace();
//			ServerWithLog4j.logger.error(e);
//			throw e;
//		}
//	}

	/**
	 * 获取对象查询服务代理
	 * @return
	 */
	public static ObjectQueryServicePrx getOQService(Current current)  {
		try {
			ObjectPrx prx = getObjectByName(current.adapter.getCommunicator(), ServiceNames.OQSERVICE);
			
			ObjectQueryServicePrx prxTemp = ObjectQueryServicePrx.uncheckedCast(prx);
			return prxTemp.ice_context(current.ctx);
		} catch (Exception e) {
			//e.printStackTrace();
			ServerWithLog4j.logger.error(e);
		}
		
		return null;
	}
	
	public static ObjectQueryServicePrx getOQService() throws VCIError  {
		try {
			Current current = threadLocal.get();
			if (current == null)
				throw new VCIError("ServerServiceProvider-0007", new String[] {"获取当前上下文失败！"});
			
			ObjectPrx prx = getObjectByName(current.adapter.getCommunicator(), ServiceNames.OQSERVICE);
			
			ObjectQueryServicePrx prxTemp = ObjectQueryServicePrx.uncheckedCast(prx);
			return prxTemp.ice_context(current.ctx);
		} catch (Exception e) {
			//e.printStackTrace();
			ServerWithLog4j.logger.error(e);
			throw e;
		}
	}

	/**
	 * 获取参考对象查询服务代理
	 * @return
	 */
//	public static RefQueryServicePrx getRQService(Current current)  {
//		try {
//			ObjectPrx prx = getObjectByName(current.adapter.getCommunicator(), ServiceNames.RQSERVICE);
//			
//			RefQueryServicePrx prxTemp = RefQueryServicePrx.uncheckedCast(prx);
//			return prxTemp.ice_context(current.ctx);
//		} catch (Exception e) {
//			//e.printStackTrace();
//			ServerWithLog4j.logger.error(e);
//		}
//		
//		return null;
//	}
//	
//	public static RefQueryServicePrx getRQService() throws VCIError  {
//		try {
//			Current current = threadLocal.get();
//			if (current == null)
//				throw new VCIError("ServerServiceProvider-0008", new String[] {"获取当前上下文失败！"});
//			
//			ObjectPrx prx = getObjectByName(current.adapter.getCommunicator(), ServiceNames.RQSERVICE);
//			
//			RefQueryServicePrx prxTemp = RefQueryServicePrx.uncheckedCast(prx);
//			return prxTemp.ice_context(current.ctx);
//		} catch (Exception e) {
//			//e.printStackTrace();
//			ServerWithLog4j.logger.error(e);
//			throw e;
//		}
//	}

	/**
	 * 获取UI服务服务代理
	 * @return
	 */
	public static PortalServicePrx getUIService(Current current)  {
		try {
			ObjectPrx prx = getObjectByName(current.adapter.getCommunicator(), ServiceNames.UISERVICE);
			
			PortalServicePrx prxTemp = PortalServicePrx.uncheckedCast(prx);
			return prxTemp.ice_context(current.ctx);
		} catch (Exception e) {
			//e.printStackTrace();
			ServerWithLog4j.logger.error(e);
		}
		
		return null;
	}
	
	public static PortalServicePrx getUIService() throws VCIError  {
		try {
			Current current = threadLocal.get();
			if (current == null)
				throw new VCIError("ServerServiceProvider-0009", new String[] {"获取当前上下文失败！"});
			
			ObjectPrx prx = getObjectByName(current.adapter.getCommunicator(), ServiceNames.UISERVICE);
			
			PortalServicePrx prxTemp = PortalServicePrx.uncheckedCast(prx);
			return prxTemp.ice_context(current.ctx);
		} catch (VCIError e) {
			//e.printStackTrace();
			ServerWithLog4j.logger.error(e);
			throw e;
		}
	}
	
	/**
	 * 获取工作流服务代理
	 * @return
	 */
	public static WorkflowServicePrx getWFService(Current current)  {
		try {
			ObjectPrx prx = getObjectByName(current.adapter.getCommunicator(), ServiceNames.WFSERVICE);
			
			WorkflowServicePrx prxTemp = WorkflowServicePrx.uncheckedCast(prx);
			return prxTemp.ice_context(current.ctx);
		} catch (Exception e) {
			//e.printStackTrace();
			ServerWithLog4j.logger.error(e);
		}
		
		return null;
	}
	
	public static WorkflowServicePrx getWFService() throws VCIError  {
		try {
			Current current = threadLocal.get();
			if (current == null)
				throw new VCIError("ServerServiceProvider-0010", new String[] {"获取当前上下文失败！"});
			
			ObjectPrx prx = getObjectByName(current.adapter.getCommunicator(), ServiceNames.WFSERVICE);
			
			WorkflowServicePrx prxTemp = WorkflowServicePrx.uncheckedCast(prx);
			return prxTemp.ice_context(current.ctx);
		} catch (VCIError e) {
			//e.printStackTrace();
			ServerWithLog4j.logger.error(e);
			throw e;
		}
	}
	
	/**
	 * 获取卷服务服务代理
	 * @return
	 */
//	public static VolumeManagerPrx getVolumeManager(Current current)  {
//		try {
//			ObjectPrx prx = getObjectByName(current.adapter.getCommunicator(), ServiceNames.VOLUMEMANAGER);
//			
//			VolumeManagerPrx prxTemp = VolumeManagerPrx.uncheckedCast(prx);
//			return prxTemp.ice_context(current.ctx);
//		} catch (Exception e) {
//			//e.printStackTrace();
//			ServerWithLog4j.logger.error(e);
//		}
//		
//		return null;
//	}
//	
//	public static VolumeManagerPrx getVolumeManager() throws VCIError  {
//		try {
//			Current current = threadLocal.get();
//			if (current == null)
//				throw new VCIError("ServerServiceProvider-0011", new String[] {"获取当前上下文失败！"});
//			
//			ObjectPrx prx = getObjectByName(current.adapter.getCommunicator(), ServiceNames.VOLUMEMANAGER);
//			
//			VolumeManagerPrx prxTemp = VolumeManagerPrx.uncheckedCast(prx);
//			return prxTemp.ice_context(current.ctx);
//		} catch (VCIError e) {
//			//e.printStackTrace();
//			ServerWithLog4j.logger.error(e);
//			throw e;
//		}
//	}
	
	/**
	 * 获取系统该框架服务代理
	 * @return
	 */
	public static VolumeServicePrx getVolumeService(Current current, String volService)  {
		try {
			if (StringUtils.isBlank(volService))
				volService = ServiceNames.VOLUMESERVICE;
			
			ObjectPrx prx = getObjectByName(current.adapter.getCommunicator(), volService);
			
			VolumeServicePrx prxTemp = VolumeServicePrx.uncheckedCast(prx);
			return prxTemp.ice_context(current.ctx);
		} catch (Exception e) {
			//e.printStackTrace();
			ServerWithLog4j.logger.error(e);
			throw e;
		}
	}
	

	
 	/**
 	 * 获取服务对象代理
 	 * @param name
 	 * @return
 	 * @throws Exception
 	 */
	private static ObjectPrx getObjectByName(Communicator communicator, String name)
	{
		String proxyLocator = name + ":" + IceClientProperties.Endpoints();
		
		return communicator.stringToProxy(proxyLocator);
	}
	
}