package com.vci.client.common.providers;

import com.vci.common.ServiceNames;
import com.vci.common.log.ServerWithLog4j;
import com.vci.common.util.IceProxyUtility;
//import com.vci.corba.auth2.Auth2ServicePrx;
import com.vci.corba.bofactory.BOFactoryServicePrx;
import com.vci.corba.framework.FrameworkServicePrx;
import com.vci.corba.log.LogServicePrx;
//import com.vci.corba.framework.method.VolumeManagerPrx;
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.ObjectPrx;
import com.vci.client.mw.ClientProxyUtility;

public class ServiceProvider {
	
	private static ServiceProvider _provider = null;
	
	private IceProxyUtility _proxyUtil = null;

	private static ServiceProvider getInstance(){
		if(_provider == null){
			_provider = new ServiceProvider();
		}
		
		return _provider;
	}
	
	/**
	 * 获取系统该框架服务代理
	 * @return
	 */
	public static FrameworkServicePrx getFrameService()  {
		FrameworkServicePrx service = getInstance().getFrameServiceImpl();
		if (service == null) {
			String error = "获取 Frame Service 服务异常";
			System.out.println(error);
		}
		
		return service;
	}
	
	/**
	 * 获取系统该框架服务代理
	 * @return
	 */
	public static LogServicePrx getLogService()  {
		LogServicePrx service = getInstance().getLogServiceImpl();
		if (service == null) {
			String error = "获取 Log Service 服务异常";
			System.out.println(error);
		}
		
		return service;
	}
	
	/**
	 * 获取系统授权认证框架服务代理
	 * @return
	 */
//	public static Auth2ServicePrx getAuth2Service()  {
//		Auth2ServicePrx service = getInstance().getAuth2ServiceImpl();
//		if (service == null) {
//			String error = "获取 Auth2Service 服务异常";
//			System.out.println(error);
//		}
//		
//		return service;
//	}
	
	/**
	 * 获取缓存服务代理
	 * @return
	 */
//	public static CacheServicePrx getCacheService()  {
//		CacheServicePrx service = getInstance().getCacheServiceImpl();
//		if (service == null) {
//			String error = "获取 CacheService 服务异常";
//			System.out.println(error);
//		}
//		
//		return service;
//	}
	
	/**
	 * 获取都西昂模型定义服务代理
	 * @return
	 */
	public static OMDServicePrx getOMDService()  {
		OMDServicePrx service =  getInstance().getOMDServiceImpl();
		if (service == null) {
			String error = "获取 OMDService 服务异常";
			System.out.println(error);
		}
		
		return service;
	}
	
	/**
	 * 获取业务对象工厂服务代理
	 * @return
	 */
	public static BOFactoryServicePrx getBOFService()  {
		BOFactoryServicePrx service = getInstance().getBOFServiceImpl();
		if (service == null) {
			String error = "获取 BOFactoryService 服务异常";
			System.out.println(error);
		}
		
		return service;
	}

	/**
	 * 获取查询模板定义服务代理
	 * @return
	 */
//	public static QTDServicePrx getQTDService()  {
//		QTDServicePrx service = getInstance().getQTDServiceImpl();
//		if (service == null) {
//			String error = "获取 QTDService 服务异常";
//			System.out.println(error);
//		}
//		
//		return service;
//	}

	/**
	 * 获取对象查询服务代理
	 * @return
	 */
	public static ObjectQueryServicePrx getOQService()  {
		ObjectQueryServicePrx service = getInstance().getBOQueryServiceImpl();
		if (service == null) {
			String error = "获取 QTService 服务异常";
			System.out.println(error);
		}
		
		return service;
	}

	/**
	 * 获取参考对象查询服务代理
	 * @return
	 */
//	public static RefQueryServicePrx getRQService()  {
//		RefQueryServicePrx service = getInstance().getRQServiceImpl();
//		if (service == null) {
//			String error = "获取 RefQueryService 服务异常";
//			System.out.println(error);
//		}
//		
//		return service;
//	}

	/**
	 * 获取UI服务服务代理
	 * @return
	 */
	public static PortalServicePrx getUIService()  {
		PortalServicePrx service = getInstance().getUIServiceImpl();
		if (service == null) {
			String error = "获取 PortalService 服务异常";
			System.out.println(error);
		}
		
		return service;
	}
	
	/**
	 * 获取工作流服务代理
	 * @return
	 * @throws Exception 
	 */
	public static WorkflowServicePrx getWFService()  {
		WorkflowServicePrx service = getInstance().getWFServiceImpl();
		if (service == null) {
			String error = "获取 WorkflowService 服务异常";
			System.out.println(error);
			//throw new Exception(error);
		}
		
		return service;
	}
	
	/**
	 * 获取卷服务服务代理
	 * @return
	 */
//	public static VolumeManagerPrx getVolumeManager()  {
//		VolumeManagerPrx service = getInstance().getVolumeFactoryImpl();
//		if (service == null) {
//			String error = "获取 VolumeFactory 服务异常";
//			System.out.println(error);
//		}
//		
//		return service;
//	}
	
	/**
	 * 获取系统该框架服务代理
	 * @return
	 */
	public static VolumeServicePrx getVolumeService(String vol)  {
		VolumeServicePrx service = getInstance().getVolumeServiceImpl(vol);
		if (service == null) {
			String error = "获取 VolumeService 服务异常";
			System.out.println(error);
		}
		
		return service;
	}
	
	private ServiceProvider() {
		InitIceUtil();
	}
	
	private void InitIceUtil() {
		if (_proxyUtil != null)
			return;
		
		_proxyUtil = new ClientProxyUtility();
		
		_proxyUtil.InitCommunicator(new String[0]);

	}

	
//	private Auth2ServicePrx _authService = null;
//	private Auth2ServicePrx getAuth2ServiceImpl() {
//		try {
//			if(_authService != null){
//				return _authService;
//			}
//			
//			if (_proxyUtil == null) {
//				InitIceUtil();
//			}
//			
//			// added by xf 增加客户端时区的注入
//			System.setProperty("user.timezone", "GMT+8");
//			_authService = Auth2ServicePrx.checkedCast(_proxyUtil.getObjectByName(ServiceNames.AUTH2SERVICE));
//		} catch (Exception e) {
//			//e.printStackTrace();
//			ServerWithLog4j.logger.error(e);
//		}
//		return _authService;
//	}
	
	
	private FrameworkServicePrx _frameService = null;
	private FrameworkServicePrx getFrameServiceImpl() {
		try {
			if(_frameService != null){
				return _frameService;
			}
			
			if (_proxyUtil == null) {
				InitIceUtil();
			}
			
			ObjectPrx prx = _proxyUtil.getObjectByName(ServiceNames.FRAMESERVICE, ServiceNames.FRAMESERVICEREP);
			
			_frameService = FrameworkServicePrx.checkedCast(prx);
		} catch (Exception e) {
			
			ServerWithLog4j.logger.error(e);
		}
		return _frameService;
	}
	
	private LogServicePrx _logService = null;
	private LogServicePrx getLogServiceImpl() {
		try {
			if(_logService != null){
				return _logService;
			}
			
			if (_proxyUtil == null) {
				InitIceUtil();
			}
			
			ObjectPrx prx = _proxyUtil.getObjectByName(ServiceNames.LOGSERVICE, ServiceNames.LOGSERVICEREP);
			
			_logService = LogServicePrx.checkedCast(prx);
		} catch (Exception e) {
			
			ServerWithLog4j.logger.error(e);
		}
		return _logService;
	}


//	private CacheServicePrx _cacheService = null;
//	private CacheServicePrx getCacheServiceImpl() {
//		try {
//			if(_cacheService != null){
//				return _cacheService;
//			}
//			
//			if (_proxyUtil == null) {
//				InitIceUtil();
//			}
//			
//			_cacheService = CacheServicePrx.checkedCast(_proxyUtil.getObjectByName(ServiceNames.CACHESERVICE));
//		} catch (Exception e) {
//			//e.printStackTrace();
//			ServerWithLog4j.logger.error(e);
//		}
//		return _cacheService;
//	}

	
	private BOFactoryServicePrx _bofService = null;
	private BOFactoryServicePrx getBOFServiceImpl() {
		try {
			if(_bofService != null){
				return _bofService;
			}
			
			if (_proxyUtil == null) {
				InitIceUtil();
			}
			
			_bofService = BOFactoryServicePrx.checkedCast(_proxyUtil.getObjectByName(ServiceNames.BOFSERVICE, ServiceNames.BOFSERVICEREP));
		} catch (Exception e) {
			//e.printStackTrace();
			ServerWithLog4j.logger.error(e);
		}
		return _bofService;
	}

//	private QTDServicePrx _qtdService = null;
//	private QTDServicePrx getQTDServiceImpl(){
//		try {
//			if(_qtdService != null){
//				return _qtdService;
//			}
//			
//			if (_proxyUtil == null) {
//				InitIceUtil();
//			}
//			
//			_qtdService = QTDServicePrx.checkedCast(_proxyUtil.getObjectByName(ServiceNames.QTDSERVICE));
//		} catch (Exception e) {
//			//e.printStackTrace();
//			ServerWithLog4j.logger.error(e);
//		}
//		return _qtdService;
//	}

	private ObjectQueryServicePrx _oqService = null;
	private ObjectQueryServicePrx getBOQueryServiceImpl(){
		try {
			if(_oqService != null){
				return _oqService;
			}
			
			if (_proxyUtil == null) {
				InitIceUtil();
			}
			
			_oqService = ObjectQueryServicePrx.checkedCast(_proxyUtil.getObjectByName(ServiceNames.OQSERVICE, ServiceNames.OQSERVICEREP));
		} catch (Exception e) {
			//e.printStackTrace();
			ServerWithLog4j.logger.error(e);
		}
		return _oqService;
	}
	
	
//	private RefQueryServicePrx _rqService = null;
//	private RefQueryServicePrx getRQServiceImpl() {
//		try {
//			if(_rqService != null){
//				return _rqService;
//			}
//			
//			if (_proxyUtil == null) {
//				InitIceUtil();
//			}
//			
//			_rqService = RefQueryServicePrx.checkedCast(_proxyUtil.getObjectByName(ServiceNames.RQSERVICE));
//		} catch (Exception e) {
//			//e.printStackTrace();
//			ServerWithLog4j.logger.error(e);
//		}
//		return _rqService;
//	}


	private PortalServicePrx _uiService = null;
	private PortalServicePrx getUIServiceImpl(){
		try {
			if(_uiService != null){
				return _uiService;
			}
			
			if (_proxyUtil == null) {
				InitIceUtil();
			}
			
			_uiService = PortalServicePrx.checkedCast(_proxyUtil.getObjectByName(ServiceNames.UISERVICE, ServiceNames.UISERVICEREP));
		} catch (Exception e) {
			//e.printStackTrace();
			ServerWithLog4j.logger.error(e);
		}
		return _uiService;
	}


	private OMDServicePrx _omdService = null;
	private OMDServicePrx getOMDServiceImpl(){
		try {
			if(_omdService != null){
				return _omdService;
			}
			
			if (_proxyUtil == null) {
				InitIceUtil();
			}

			_omdService = OMDServicePrx.checkedCast(_proxyUtil.getObjectByName(ServiceNames.OMDSERVICE, ServiceNames.OMDSERVICEREP));
		} catch (Exception e) {
			//e.printStackTrace();
			ServerWithLog4j.logger.error(e);
		}
		return _omdService;
	}
	
	private WorkflowServicePrx _wfService = null;
	private WorkflowServicePrx getWFServiceImpl(){
		try {
			if(_wfService != null){
				return _wfService;
			}
			
			if (_proxyUtil == null) {
				InitIceUtil();
			}

			_wfService = WorkflowServicePrx.checkedCast(_proxyUtil.getObjectByName(ServiceNames.WFSERVICE, ServiceNames.WFSERVICEREP));
		} catch (Exception e) {
			//e.printStackTrace();
			ServerWithLog4j.logger.error(e);
		}
		return _wfService;
	}
	
//	private VolumeManagerPrx getVolumeFactoryImpl(){
//		try {
//			if (_proxyUtil == null) {
//				InitIceUtil();
//			}
//			
//			return VolumeManagerPrx.checkedCast(_proxyUtil.getObjectByName(ServiceNames.VOLUMEMANAGER));
//		} catch (Exception e) {
//			//e.printStackTrace();
//			ServerWithLog4j.logger.error(e);
//		}
//		return null;
//	}
	
	private VolumeServicePrx _defaultVolService = null;
	private VolumeServicePrx getVolumeServiceImpl(String vol){
		try {
			if (_defaultVolService != null)
				return _defaultVolService;
			
			if (_proxyUtil == null) {
				InitIceUtil();
			}
			
			_defaultVolService = VolumeServicePrx.checkedCast(_proxyUtil.getObjectByName(ServiceNames.VOLUMESERVICE, ServiceNames.VOLUMESERVICEREP));
		} catch (Exception e) {
			//e.printStackTrace();
			ServerWithLog4j.logger.error(e);
		}
		return _defaultVolService;
	}
}