package foundation.icall;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

import foundation.action.ActionBucket;
import foundation.action.ActionContext;
import foundation.action.ActionMeta;
import foundation.action.ActionProvider;
import foundation.dao.DataPackage;
import foundation.dao.bizlogic.IActionProvider;
import foundation.data.mapping.Mappings;
import foundation.data.mapping.MappingsRuntime;
import foundation.icall.callout.CallMethod;
import foundation.icall.callout.Fields;
import foundation.icall.callout.IRemoteSource;
import foundation.icall.callout.RemoteDBCallProvider;
import foundation.icall.callout.RemoteSourceBucket;
import foundation.icall.log.ICallLogger;
import foundation.util.Util;


public class ICall {
	
    protected static Logger logger;
	private static RemoteSourceBucket sourceBucket;

	private ICallMeta meta;
	private IRemoteSource remoteSource;
	private Class<?> actionClass;
	private ICallDirection direction;
	
	
	static {
		logger = LogManager.getLogger(ICall.class);
	}
	
	public ICall(ICallMeta meta) {
		this.meta = meta;
		this.direction = ICallDirection.Unknown;
		
		init();
	}
	

	public static ICall getInstance(String name) {
		ICallBucket bucket = ICallBucket.getInstance();
		return bucket.getOne(name);
	}

	private void init() {
		//1. remote source
		String sourceName = meta.getSourceName();
		sourceBucket = RemoteSourceBucket.getInstance();
		remoteSource = sourceBucket.getOne(sourceName);
		direction = remoteSource.getDirection();
	}

	public void sendRemoteServerCall(ActionContext context, OutboundResult result) throws Exception {
		String actionName = meta.getActionName();
		if (Util.isEmpty(actionName)) {
			logger.error("iCall send remote server call error, empty action");
			return;
		}
		
		//1. 创建  action provider 
		ActionBucket actionBucket = ActionBucket.getInstance();
		ActionMeta actionMeta = actionBucket.get(actionName);
		IActionProvider provider = actionMeta.createProvider();
		
		//2. 创建 context
		RemoteContext remoteContext = new RemoteContext(this);
		ActionContext newContext = context.newInstance();
		newContext.addContext(remoteContext);
		
		if (provider instanceof ActionProvider) {
			ActionProvider actionProvider = (ActionProvider)provider;
			actionProvider.setContext(newContext);
		}
		
		//3. 运行
		String method = actionMeta.getMethodName();
		provider.exec(newContext, method);

	}

	public void sendRemoteDBCall(ActionContext context, OutboundResult result) throws Exception {
		//1. 创建  action provider 
		String actionName = meta.getActionName();
		IActionProvider provider = null; ActionMeta actionMeta = null;
		
		if (!Util.isEmpty(actionName)) {
			ActionBucket actionBucket = ActionBucket.getInstance();
			actionMeta = actionBucket.get(actionName);
			provider = actionMeta.createProvider();
		}
		else {
			provider = new RemoteDBCallProvider();
		}
		
		//2. 创建 context
		RemoteContext remoteContext = new RemoteContext(this);
		remoteContext.setOutboundResult(result);
		ActionContext newContext = context.newInstance();
		newContext.addContext(remoteContext);
		
		if (provider instanceof ActionProvider) {
			ActionProvider actionProvider = (ActionProvider)provider;
			actionProvider.setContext(newContext);
		}

		//3. 运行
		if (actionMeta != null) {
			String method = actionMeta.getMethodName();
			provider.exec(newContext, method);
		}
		else {
			((RemoteDBCallProvider)provider).doExec(newContext);
		}

		ICallLogger.endAction(remoteContext.getLogRecord(), remoteContext.getResponse());
	}
	
	@SuppressWarnings("unchecked")
	public <T> T getAction() throws InstantiationException, IllegalAccessException {
		
		if (actionClass == null) {
			return null;
		}
		
		Object obj = actionClass.newInstance();
		return (T)obj;
	}

	@SuppressWarnings("unchecked")
	public <T extends IRemoteSource> T remoteSource() {
		return (T)remoteSource;
	}
	
	public String getId() {
		return meta.getId();
	}

	public ICallMeta getMeta() {
		return meta;
	}

	public String getURL() {
		return meta.getURL();
	}
	
	public String getRemoteFilter() {
		return meta.getRemoteFilter();
	}
	
	public String getDataName() {
		return meta.getDataName();
	}

	public String getName() {
		return meta.getName();
	}

	public ICallDirection getType() {
		return direction;
	}

	public Mappings getMappings() {
		// TODO Auto-generated method stub
		return null;
	}

	public MappingsRuntime getMappingsRuntime(DataPackage dataPackage) {
		// TODO Auto-generated method stub
		return null;
	}

	public CallMethod getCallMethod() {
		// TODO Auto-generated method stub
		return null;
	}

	public IRemoteSource getRemoteSource() { 
		return remoteSource;
	}

	public String getSourceName() { 
		return meta.getSourceName();
	}

	public boolean isPermitEmptyStamp() {
		return meta.isPermitEmptyStamp();
	}

	public String getHistoryTableName() {
		return meta.getHistoryTableName();
	}

	public Fields getIdFields() {
		return meta.getIdFields();
	}
	
	public String getStampField() {
		return meta.getStampField();
	}
	
	public String getOrderByField() {
		return meta.getOrderByField();
	}

	public String getIOTaskName() {
		return meta.getIOTaskName();
	}

	public boolean isPageActive() {
		return meta.isPageActive();
	}

	public String getRoute() {
		return meta.getRoute();
	}
	
	public String getMonitorId() {
		return meta.getMonitorId();
	}

	public String getTitle() {
		return meta.getTitle();
	}

}