public class ExeUtils {
    private ExeUtils() {
    }
    private ExecutorService exe;

    private ExecutorService getExe() {
        return exe;
    }

    private ExeUtils setExe(ExecutorService exe) {
        this.exe = exe;
        return this;
    }

    public static void go(Runnable runnable) {
        ExeUtils eu = new ExeUtils().setExe(Executors.newSingleThreadExecutor());
        eu.getExe().submit(runnable);
        eu.shutdown();
    }
    public static void go(Callable<Object> callable) {
        ExeUtils eu = new ExeUtils().setExe(Executors.newSingleThreadExecutor());
        eu.getExe().submit(callable);
        eu.shutdown();
    }

    private void shutdown() {
        try {
            System.out.println("try to shut down【"+exe+"】");
            exe.shutdown();
        } catch (Exception  e) {
            e.printStackTrace();
        }finally {
            try {
                if(!exe.awaitTermination(10,TimeUnit.SECONDS)){
                    System.out.println("10秒检测器");
                    if(!exe.isTerminated()){
                        System.out.println("【"+exe+"】超时未关闭");
                        exe.shutdownNow();
                        System.out.println("【"+exe+"】被强制关闭");
                    }

                }else{
                    System.out.println("【"+exe+"】已被正确关闭啦");
                }
            } catch (InterruptedException e) {
                e.printStackTrace();
                exe.shutdownNow();
            }

        }
    }

}

public Runnable testThread(Map testObj) {
        Runnable r = () -> {
            System.out.println("异步线程原来的："+testObj.getString("is_work"));
//            JDO jdo = new JDO();
            try {
                Thread.sleep(5000);
                testObj.set("is_work","2");
                System.out.println("异步线程set后的："+testObj.getString("is_work"));
//                jdo.update(testObj);
            } catch (Exception e) {
                e.printStackTrace();
//                jdo.rollbackAll();
            }finally {
//                jdo.close();
            }
//            System.out.println("原来的："+testObj);
        };
        return r;
    }

public void testThreadMethod(){

        ReentrantLock lock = new ReentrantLock();
        try {
            lock.lockInterruptibly();
            Map t = new HashMap();
            ExeUtils.go(testThread(t));
            while (t.getString("is_work").equals("1")){
                    lock.newCondition().await();
                }
            System.out.println(t.getString("is_work"));
        } catch (Exception e) {
            e.printStackTrace();
        }finally {
            lock.unlock();
        }
    }

Cookie sessionIdCookie = getCookieByName("oaSessionId");
        if (sessionIdCookie != null) {
            String historySessionId = sessionIdCookie.getValue();
            if(StringUtils.isNotBlank(historySessionId)){
                HttpSession historySession = 	  SystemConstant.SESSION_MAP.get(historySessionId);
                if(historySession!=null){
                    AuthorityInfo userInfoHistory = (AuthorityInfo)   historySession.getAttribute("authorityInfo");
                    //如果userInfoHistory为null，可以考虑到持久化存储种再获取一次。
                    //现在这种写法受制于session的生命周期
                    //如果用户信息不为空，讲历史信息写入到当前session中，并返回管理页面
                    if(userInfoHistory != null){
                        this._request.getSession().setAttribute("authorityInfo",userInfoHistory);
                        //更新cookie的生命周期和历史sessiond的值
                        Cookie cookie = new Cookie("oaSessionId", this._request.getSession().getId());
                        cookie.setPath("/");
                        cookie.setMaxAge(60 * 60);
                        ActionHandler.currentActionHandler()._response.addCookie(cookie);

                        //更新全局sessionmap中的历史session信息
                        SystemConstant.SESSION_MAP.remove(historySessionId);
                        SystemConstant.SESSION_MAP.put(this._request.getSession().getId(),this._request.getSession());
                        this._nextUrl = "/index.jsp";//自定义跳转jsp地址
                        return;//重定向返回
                    }
                }
            }
        }

/**
 * Description: provide for mybatis-test-space.
 *
 * @author William.He
 * @version 1.0
 * @since 2018/4/18 17:55
 */
public enum DBTypeEnum {
    one("dataSource_one"), two("dataSource_two");
    private String value;

    DBTypeEnum(String value) {
        this.value = value;
    }

    public String getValue() {
        return value;
    }
}

/**
 * Description: provide for mybatis-test-space.
 *
 * @author William.He
 * @version 1.0
 * @since 2018/4/18 17:56
 */
public class DbContextHolder {

    private static final ThreadLocal<String> contextHolder = new ThreadLocal<>();

    /**
     * 设置数据源
     * @param dbTypeEnum 数据源枚举
     */
    public static void setDbType(DBTypeEnum dbTypeEnum) {
        contextHolder.set(dbTypeEnum.getValue());
    }

    /**
     * 取得当前数据源
     *
     * @return 数据源枚举值，对应targetDataSources的key
     */
    static String getDbType() {
        return contextHolder.get();
    }

    /**
     * 清除上下文数据,即清空数据源
     */
    public static void clearDbType() {
        contextHolder.remove();
    }
}

/**
 * Description: provide for mybatis-test-space.
 * 动态切换数据源
 * @author William.He
 * @version 1.0
 * @since 2018/4/18 17:53
 */
public class DynamicDataSource extends AbstractRoutingDataSource {

    /**
     * 取得当前使用哪个数据源
     * @return datasource bean
     */
    @Override
    protected Object determineCurrentLookupKey() {
        return DbContextHolder.getDbType();
    }
}

/**
 * Description: provide for mybatis-test-space.
 *
 * @author William.He
 * @version 1.0
 * @since 2018/4/17 15:37
 */
@Configuration
@MapperScan(basePackages = {"com.pax.dal.dao"})//扫描接口
public class MybatisPlusConfig {

    @Resource(name = "dataSource")
    private DataSource dataSource;

    @Resource(name = "dataSource2")
    private DataSource dataSource2;

//    @Resource(name = "dynamicDataSource")
//    private DynamicDataSource dynamicDataSource;

    @Bean("mybatisSqlSession")
    public SqlSessionFactory sqlSessionFactory(DynamicDataSource dynamicDatasource, ResourceLoader resourceLoader, GlobalConfiguration globalConfiguration) throws Exception {
        MybatisSqlSessionFactoryBean sqlSessionFactory = new MybatisSqlSessionFactoryBean();
        sqlSessionFactory.setDataSource(dynamicDatasource);//Dynamic动态的
        sqlSessionFactory.setTypeAliasesPackage("com.pax.dal.dao");//扫描model类
        //获取自定义mapper文件的位置
        sqlSessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath*:com.pax.dal.sqlMapper/*.xml"));
        MybatisConfiguration configuration = new MybatisConfiguration();
        configuration.setDefaultScriptingLanguage(MybatisXMLLanguageDriver.class);
        configuration.setJdbcTypeForNull(JdbcType.NULL);
        sqlSessionFactory.setConfiguration(configuration);
        sqlSessionFactory.setPlugins(new Interceptor[]{
//                new PaginationInterceptor(),
                //性能分析，慢查询报警
                new PerformanceInterceptor(),
                //乐观锁
                new OptimisticLockerInterceptor(),
                //分页插件，源生通用的
                pageInterceptor()
        });
        sqlSessionFactory.setGlobalConfig(globalConfiguration);
        return sqlSessionFactory.getObject();
    }

    @Bean
    public GlobalConfiguration globalConfiguration() {
        GlobalConfiguration conf = new GlobalConfiguration(new LogicSqlInjector());
        conf.setLogicDeleteValue("-1");
        conf.setLogicNotDeleteValue("1");
        //全局主键默认类型，优先级次于@tableid注解
        conf.setIdType(2);
        //下划线支持
        conf.setDbColumnUnderline(true);
//        conf.setMetaObjectHandler(new H2MetaObjectHandler());//meta元
        return conf;
    }
    
    @Bean
    private DynamicDataSource dynamicDataSource(){
        DynamicDataSource control = new DynamicDataSource();
        control.setDefaultTargetDataSource(dataSource);
        Map<Object,Object> targetDataSources = new HashMap<>();
        targetDataSources.put("dataSource_one",dataSource);
        targetDataSources.put("dataSource_two",dataSource2);
        control.setTargetDataSources(targetDataSources);
        return control;
    }
    
    private PageInterceptor pageInterceptor() {
        PageInterceptor pageInterceptor = new PageInterceptor();
        Properties properties = new Properties();
        properties.put("helperDialect", "mysql");
        pageInterceptor.setProperties(properties);
        return pageInterceptor;
    }

@Bean(name = "txManager")
    public DataSourceTransactionManager dataSourceTransactionManager(DynamicDataSource dynamicDatasource) {
        DataSourceTransactionManager dataSourceTransactionManager = new DataSourceTransactionManager();
        dataSourceTransactionManager.setDataSource(dynamicDatasource);
        return dataSourceTransactionManager;
    }

@Test
   public void testMysql(){
       //切换数据源
       DbContextHolder.setDbType(DBTypeEnum.one);
       //System.out.println(pax);
       //int i = pax.deleteByAutoId(7);
       List<User> users = pax.selectList(new EntityWrapper<User>());
       System.out.println(users);
   }

/**
 * Description: provide for thirdpay-park-arena.
 *
 * @author William.He
 * @version 1.0
 * @since 09/04/2018 12:00 PM
 */
public class Singleton {
    private Singleton() {}
    private static class PePeHolder{
        private static Singleton singleton = new Singleton();
    }

    public static Singleton getInstance(){
        return PePeHolder.singleton;
    }
}