@Configuration
public class ActivitiConfiguration {
    @Autowired
    private DataSource dataSource;
    @Autowired
    private PlatformTransactionManager platformTransactionManager;

    @Autowired
    private ProcessEngineFactoryBean processEngine;

    @Bean
    public SpringProcessEngineConfiguration springProcessEngineConfiguration(){
        SpringProcessEngineConfiguration spec = new SpringProcessEngineConfiguration();
        spec.setDataSource(dataSource);
        spec.setTransactionManager(platformTransactionManager);
        spec.setDatabaseSchemaUpdate(ProcessEngineConfiguration.DB_SCHEMA_UPDATE_FALSE);
        Resource[] resources = null;
        // 启动自动部署流程
        try {
            resources = new PathMatchingResourcePatternResolver().getResources("classpath*:bafy.bpmn");
        } catch (IOException e) {
            e.printStackTrace();
        }
        spec.setDeploymentResources(resources);
        return spec;
    }


    /**
     * Activiti 中每一个不同版本的业务流程的定义都需要使用一些定义文件，部署文件和支持数据 ( 例如 BPMN2.0 XML 文件，表单定义文件，流程定义图像文件等 )，
     * 这些文件都存储在 Activiti 内建的 Repository 中。Repository Service 提供了对 repository 的存取服务
     * @return
     * @throws Exception
     */
    @Bean
    public RepositoryService repositoryService() throws Exception{
        return processEngine.getObject().getRepositoryService();
    }
    /**
     * 在 Activiti 中，每当一个流程定义被启动一次之后，都会生成一个相应的流程对象实例。Runtime Service 提供了启动流程、查询流程实例、设置获取流程实例变量等功能。
     * 此外它还提供了对流程部署，流程定义和流程实例的存取服务
     * @return
     * @throws Exception
     */
    @Bean
    public RuntimeService runtimeService() throws Exception{
        return processEngine.getObject().getRuntimeService();
    }
    /**
     *  Activiti 中业务流程定义中的每一个执行节点被称为一个 Task，对流程中的数据存取，状态变更等操作均需要在 Task 中完成。Task Service 提供了对用户 Task 和
     *  Form 相关的操作。它提供了运行时任务查询、领取、完成、删除以及变量设置等功能
     * @return
     * @throws Exception
     */
    @Bean
    public TaskService taskService() throws Exception{
        return processEngine.getObject().getTaskService();
    }
    /**
     * 用于获取正在运行或已经完成的流程实例的信息，与 Runtime Service 中获取的流程信息不同，历史信息包含已经持久化存储的永久信息，并已经被针对查询优化
     * @return
     * @throws Exception
     */
    @Bean
    public HistoryService historyService() throws Exception{
        return processEngine.getObject().getHistoryService();
    }

    /**
     * 用于获取组任务相关记录
     * @return
     * @throws Exception
     */
    @Bean
    public IdentityService identityService() throws Exception {
        return processEngine.getObject().getIdentityService();
    }
}

@Slf4j
@RestController
@RequestMapping("/askForLeave")
public class askForLeaveController {

    @Autowired
    private RuntimeService runtimeService;

    @Autowired
    private TaskService taskService;

    private final RepositoryService repositoryService;

    public askForLeaveController(RepositoryService repositoryService) {
        this.repositoryService = repositoryService;
        repositoryService.createDeployment()
        .name("请假申请流程")
        .addClasspathResource("processes/test.bpmn20.xml")
        .addClasspathResource("processes/test.bpmn20.png")
        .deploy();
    }


    @GetMapping("/submit")
    public void submit(String username) {
        Map map = CollUtil.newHashMap();
        map.put("worker", "zhangsan");
        //"askForLeave"是流程定义id（processDefinitionKey），即xml文件中<process>标签的id，可通过xml配置，每修改一次xml并重启，则会对流程定义（processDefinition）生成一个新的版本，可在act_re_procdef表中查看
        ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("askForLeave", username, map);
        log.info("processInstance is: {}", processInstance);
    }

    @GetMapping("/projectManager")
    public List<Map> projectManager(String username) {
        List<Task> tasks = taskService.createTaskQuery().processInstanceBusinessKey(username).taskAssignee("zhangsan").list();
        Map map = CollUtil.newHashMap();
        map.put("workers", CollUtil.newArrayList("lisi", "wangwu"));
        //总经理审批的处理人不能放到部门经理去设置，可能是因为部门经理审批是个会签
        map.put("worker", "zhaoliu");
        for (Task task : tasks) {
            taskService.complete(task.getId(), map);
        }
        return toMap(tasks);
    }

    @GetMapping("/departmentManagerLisi")
    public List<Map> departmentManagerLisi(String username) {
        List<Task> tasks = taskService.createTaskQuery().processInstanceBusinessKey(username).taskAssignee("lisi").list();
        Map map = CollUtil.newHashMap();
        for (Task task : tasks) {
            taskService.complete(task.getId(), map);
        }
        return toMap(tasks);
    }

    @GetMapping("/departmentManagerWangwu")
    public List<Map> departmentManagerWangwu(String username) {
        List<Task> tasks = taskService.createTaskQuery().processInstanceBusinessKey(username).taskAssignee("wangwu").list();
        Map map = CollUtil.newHashMap();
        for (Task task : tasks) {
            taskService.complete(task.getId(), map);
        }
        return toMap(tasks);
    }

    @GetMapping("/generalManager")
    public List<Map> generalManager(String username) {
        List<Task> tasks = taskService.createTaskQuery().processInstanceBusinessKey(username).taskAssignee("zhaoliu").list();
        for (Task task : tasks) {
            taskService.complete(task.getId());
        }
        return toMap(tasks);
    }

    /**
     * 由于task是接口，无法直接返回给前端，通过map转换一下
     * @param list
     * @return
     */
    public List<Map> toMap(List<Task> list) {
        List<Map> result = CollUtil.newArrayList();
        for (Task task : list) {
            Map map = CollUtil.newHashMap();
            map.put("user", task.getAssignee());
            map.put("name", task.getName());
            result.add(map);
        }
        return result;
    }
}