package com.jntech.config;

import com.jntech.common.utils.CustomLog;
import org.activiti.engine.delegate.event.ActivitiEventListener;
import org.activiti.spring.SpringProcessEngineConfiguration;
import org.activiti.spring.boot.AbstractProcessEngineAutoConfiguration;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.autoconfigure.jdbc.DataSourceBuilder;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.io.Resource;
import org.springframework.core.io.support.ResourcePatternResolver;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.util.CollectionUtils;

import javax.sql.DataSource;
import java.io.IOException;
import java.util.*;


@Configuration
//@MapperScan(basePackages = "com.jntech.dao.mysql", sqlSessionTemplateRef = "mysqlSqlSessionTemplate")
//@PropertySource("classpath:application.properties")
public class DataSourceActivitiConfig extends AbstractProcessEngineAutoConfiguration {
@Autowired
private ResourcePatternResolver resourceLoader;

@Bean(name = "activitiDataSource")
@ConfigurationProperties(prefix = "spring.datasource.local")
//@Primary
public DataSource testDataSource() {
return DataSourceBuilder.create().build();
}

@Bean(name = "activitiSqlSessionFactory")
// @Primary
public SpringProcessEngineConfiguration springProcessEngineConfiguration(@Qualifier("activitiDataSource") DataSource dataSource,@Qualifier("activitiTransactionManager") PlatformTransactionManager transactionManager) throws IOException {
SpringProcessEngineConfiguration configuration = new SpringProcessEngineConfiguration();
configuration.setDataSource(dataSource);//配置数据源
configuration.setTransactionManager(transactionManager);//配置transaction
configuration.setDatabaseSchemaUpdate("true");//每次项目启动是否更新数据库表(第一次运行项目需要设为true，activiti将在数据库建表)
configuration.setAsyncExecutorActivate(true);//是否激活异步执行器
configuration.setHistory("audit");//流程历史记录登录
configuration.setCreateDiagramOnDeploy(true);//部署流程定义时是否生成图片（新流程部署时或数据库初始化时）
configuration.setActivityFontName("\\u5b8b\\u4f53");//字体 下面内容为转成unicode的'宋体'
configuration.setLabelFontName("\\u5b8b\\u4f53");//字体 下面内容为转成unicode的'宋体'
//设置指定的流程图文件资源
List<Resource> procDefResources = discoverProcessDefinitionResources("classpath*:/processes/", Arrays.asList("**.bpmn20.xml", "**.bpmn"),true);
configuration.setDeploymentResources(procDefResources.toArray(new Resource[procDefResources.size()]));
//设置流程监听器
Map<String, List<ActivitiEventListener>> typedListeners = new HashMap<>();
/*typedListeners.put("ENTITY_CREATED", Collections.singletonList(entityCreatedListener));
typedListeners.put("TASK_CREATED", Collections.singletonList(taskCreatedListener));
typedListeners.put("TASK_COMPLETED", Collections.singletonList(taskCompletedListener));*/
configuration.setTypedEventListeners(typedListeners);

return configuration;
}

@Bean(name = "activitiTransactionManager")
//@Primary
public DataSourceTransactionManager testTransactionManager(@Qualifier("activitiDataSource") DataSource dataSource) {
return new DataSourceTransactionManager(dataSource);
}

/**
* 获取指定的流程图文件资源
* @param prefix 路径前缀
* @param suffixes 文件后缀
* @param checkPDs 如果checkProcessDefinitions为true，则发布新版流程定义，后续可能根据流程定义文件MD5等判断是否真正变化而进行发布
* @return
* @throws IOException
*/
private List<Resource> discoverProcessDefinitionResources(String prefix, List<String> suffixes, boolean checkPDs) throws IOException {
if (checkPDs) {
List<Resource> result = new ArrayList();
for (String suffix : suffixes) {
String path = prefix + suffix;
Resource[] resources = resourceLoader.getResources(path);
if (resources != null && resources.length > 0) {
CollectionUtils.mergeArrayIntoCollection(resources, result);
}
}
if (result.isEmpty()) {
CustomLog.getInstance().createLogger("No process definitions were found for autodeployment");
}
return result;
}
return new ArrayList<>();
}

}