package org.jeecg.common.config;

import com.google.common.collect.Lists;

import org.activiti.engine.*;
import org.activiti.spring.ProcessEngineFactoryBean;
import org.activiti.spring.SpringProcessEngineConfiguration;
import org.jeecg.modules.activiti.manage.CustomGroupEntityManager;
import org.jeecg.modules.activiti.manage.CustomUserEntityManager;
import org.jeecg.modules.apply.lisener.CustomEventListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Lazy;
import org.springframework.transaction.PlatformTransactionManager;

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

/**
 * 工作流配置
 *
 * @author len
 * @date 2019/06/13
 */
@Configuration
public class ActivitiConfig {

    @Autowired
    private CustomUserEntityManager customUserEntityManager;

    @Autowired
    private CustomGroupEntityManager customGroupEntityManager;

    @Autowired
    private CustomEventListener customEventListener;


    /**
     * 核心流程引擎类
     *
     * @param transactionManager transactionManager
     * @param dataSource         dataSource
     * @return ProcessEngine
     */
    @Bean
    public ProcessEngine processEngine(PlatformTransactionManager transactionManager, DataSource dataSource)
            throws IOException {
        SpringProcessEngineConfiguration processEngineConfiguration = new SpringProcessEngineConfiguration();
        // 自动部署已有的流程文件
//        Resource[] resources = new PathMatchingResourcePatternResolver()
//                .getResources(ResourceLoader.CLASSPATH_URL_PREFIX + "processes/*.bpmn");
//        Resource[] resources2 = new PathMatchingResourcePatternResolver()
//                .getResources(ResourceLoader.CLASSPATH_URL_PREFIX + "processes/*.bpmn20.xml");
//        ArrayList<Resource> arrayList = new ArrayList(Arrays.asList(resources));
//        arrayList.addAll(Arrays.asList(resources2));
//        Resource[] arr =new Resource[arrayList.size()];
//        Resource[] resources1 = arrayList.toArray(arr);
//        processEngineConfiguration.setDeploymentResources(resources1);
//        processEngineConfiguration.setDeploymentName("系统自动部署流程");

        processEngineConfiguration.setTransactionManager(transactionManager);
        processEngineConfiguration.setDataSource(dataSource);
        processEngineConfiguration.setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_FALSE);
//        processEngineConfiguration.setDatabaseSchema("tcore_dev");
//        processEngineConfiguration.setDatabaseTablePrefix("ACT");
        // 自定义用户和组
//        processEngineConfiguration.setUserEntityManager(customUserEntityManager);
//        processEngineConfiguration.setGroupEntityManager(customGroupEntityManager);

        processEngineConfiguration.setActivityFontName("SimHei");
        processEngineConfiguration.setAnnotationFontName("SimHei");
        processEngineConfiguration.setLabelFontName("SimHei");


        //自定义事件监听配置
        processEngineConfiguration.setEventListeners(Lists.newArrayList(customEventListener));
        return processEngineConfiguration.buildProcessEngine();

    }

    /**
     * 流程仓库Service，用于管理流程仓库，例如部署、删除、读取流程资源
     *
     * @param processEngine processEngine
     * @return RepositoryService
     */
    @Bean
    public RepositoryService repositoryService(ProcessEngine processEngine) {
        return processEngine.getRepositoryService();
    }

    /**
     * 运行时Service，可以也拿过来处理所有正在运行状态的流程实例、任务等
     *
     * @param processEngine processEngine
     * @return RuntimeService
     */
    @Bean
    public RuntimeService runtimeService(ProcessEngine processEngine) {
        return processEngine.getRuntimeService();
    }

    /**
     * 任务Service，用于管理和查询任务，例如签收、办理、指派等
     *
     * @param processEngine processEngine
     * @return ApprovalTaskService
     */
    @Bean
    public TaskService taskService(ProcessEngine processEngine) {
        return processEngine.getTaskService();
    }

    /**
     * 历史Service，用于查询所有历史数据，例如流程实例、任务、活动、变量、附件
     *
     * @param processEngine processEngine
     * @return HistoryService
     */
    @Bean
    public HistoryService historyService(ProcessEngine processEngine) {
        return processEngine.getHistoryService();
    }

    /**
     * 引擎管理Service，和具体业务无关，主要可以查询引擎配置、数据库、作业等
     *
     * @param processEngine processEngine
     * @return ManagementService
     */
    @Bean
    public ManagementService managementService(ProcessEngine processEngine) {
        return processEngine.getManagementService();
    }

    /**
     * 身份Service，用于管理和查询用户、组之间的关系
     *
     * @param processEngine processEngine
     * @return IdentityService
     */
    @Bean
    public IdentityService identityService(ProcessEngine processEngine) {
        return processEngine.getIdentityService();
    }

    /**
     * 表单Service，用于读取流程、任务相关的表单数据
     *
     * @param processEngine processEngine
     * @return FormService
     */
    @Bean
    public FormService formService(ProcessEngine processEngine) {
        return processEngine.getFormService();
    }

    /**
     * 一个新增的服务，用于动态修改流程中的一些参数信息等，是引擎中的一个辅助的服务
     *
     * @param processEngine processEngine
     * @return DynamicBpmnService
     */
    @Bean
    public DynamicBpmnService dynamicBpmnService(ProcessEngine processEngine) {
        return processEngine.getDynamicBpmnService();
    }
}