package com.artfess.base.datasource;

import com.artfess.base.constants.DataSourceConsts;
import com.artfess.base.datasource.impl.DefaultDatabaseContext;
import com.artfess.base.handler.MultiTenantHandler;
import com.artfess.base.interceptor.MasterSlaveAutoRoutingPlugin;
import com.artfess.base.util.AppUtil;
import org.springframework.jdbc.core.JdbcTemplate;

import com.baomidou.dynamic.datasource.toolkit.DynamicDataSourceContextHolder;


/**
 * 切换数据源的结果
 * <p>
 * 这里实现了AutoCloseable接口，当系统中切换数据源动作在try()中执行时，执行完后会调用close方法，close中切换回原来的数据源。
 * </p>
 * @company 阿特菲斯信息技术有限公司
 * @author heyifan
 * @email heyf@jee-soft.cn
 * @date 2020年4月22日
 */
public class DatabaseSwitchResult implements AutoCloseable{
	/**
	 * 切换前的数据源
	 */
	private String previewDsAlias;
	/**
	 * 当前数据源
	 */
	private String currentDsAlias;
	/**
	 * 当前切换数据源的数据库类型
	 */
	private String dbType;
	
	public DatabaseSwitchResult(String previewDsAlias, String currentDsAlias, String dbType) {
		this.setPreviewDsAlias(previewDsAlias);
		this.setCurrentDsAlias(currentDsAlias);
		this.setDbType(dbType);
	}
	
	@Override
	public void close() throws Exception {
		if(DataSourceConsts.LOCAL_DATASOURCE.equals(previewDsAlias) && DataSourceConsts.LOCAL_DATASOURCE.equals(currentDsAlias)) {
			return;
		}
		// 清空当前切换的数据源
		DynamicDataSourceContextHolder.clear();
		DefaultDatabaseContext context = AppUtil.getBean(DefaultDatabaseContext.class);
		context.clear();
		JdbcTemplate jdbcTemplate = AppUtil.getBean(JdbcTemplate.class);
		// 设置回默认的数据源
		jdbcTemplate.setDataSource(context.getDataSource());
		// 告诉读写分离路由器：离开外部数据源了
		MasterSlaveAutoRoutingPlugin.removeInExternalDatasource();
		// 告诉多租户：离开外部数据源了
		MultiTenantHandler.removeThreadLocalIgnore();
	}

	public String getPreviewDsAlias() {
		return previewDsAlias;
	}

	public void setPreviewDsAlias(String previewDsAlias) {
		this.previewDsAlias = previewDsAlias;
	}

	public String getCurrentDsAlias() {
		return currentDsAlias;
	}

	public void setCurrentDsAlias(String currentDsAlias) {
		this.currentDsAlias = currentDsAlias;
	}

	public String getDbType() {
		return dbType;
	}

	public void setDbType(String dbType) {
		this.dbType = dbType;
	}
}