package com.greenery.activity_demo;

import org.activiti.engine.*;
import org.activiti.engine.repository.ProcessDefinition;
import org.activiti.engine.runtime.ProcessInstance;
import org.activiti.engine.task.Task;
import org.junit.jupiter.api.Test;

/**
 * @author xxx
 * @date 2022/9/3 15:24
 */
public class ActivitiBusinessDemo {
    

    /**
     * 添加业务key到Activiti表
     */
    @Test
    public void addBusinessKey(){
    
        //    1.获取流程引擎
        ProcessEngine defaultProcessEngine = ProcessEngines.getDefaultProcessEngine();
        //    2.获取RuntimeService
        RuntimeService runtimeService = defaultProcessEngine.getRuntimeService();
        //    3.启动流程的过程中添加businesskey
        // 第一个参数流程定义的key
        // 第二个参数为businessKey 存出差申请单的id
        // 该businessKey 添加到了 ACT_RU_EXECUTION表
        ProcessInstance processInstance = runtimeService.startProcessInstanceByKey("myEvection", "1001");
        //    4.输出
        System.out.println("businessKey="+processInstance.getBusinessKey());
      }

    /**
     * 全部流程的挂起与激活
     */
    @Test
    public void suspendAllProcessInstance(){
    
    //    1.获取流程引擎
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        //    2.获取RespositoryService
        RepositoryService repositoryService = processEngine.getRepositoryService();
        //    3.查询流程定义,获取流程定义查询对象
        ProcessDefinition processDefinition = repositoryService.createProcessDefinitionQuery()
                .processDefinitionKey("myEvection")
                .singleResult();

        //    4.获取当前流程定义的实例是否都是挂起状态
        boolean suspended = processDefinition.isSuspended();
        //    5.获取流程定义的id
        String definitionId = processDefinition.getId();
        //    6.如果是挂起状态，改为激活状态
        if(suspended){
    
            //如果是挂起，可以执行激活的操作，参数1：流程定义id,参数2：是否激活；参数3:激活时间
            repositoryService.activateProcessDefinitionById(definitionId,true,null);
            System.out.println("流程定义id="+definitionId+"已激活");
        }else{
    
            //    7.如果是激活状态，改为挂起状态 参数1:流程定义id,参数2:是否挂起,参数3:挂起时间
            repositoryService.suspendProcessDefinitionById(definitionId,true,null);
            System.out.println("流程定义id="+definitionId+"已挂起");
        }

    }

    /**
     * 挂起或激活单个实例
     */
    @Test
    public void suspendSingleProcessInstance(){
    
    //    1.获取流程引擎
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        //    2.获取RuntimeService
        RuntimeService runtimeService = processEngine.getRuntimeService();
        //    3.通过RuntimeService获取流程实例对象
        ProcessInstance processInstance = runtimeService.createProcessInstanceQuery()
                .processInstanceId("20001")
                .singleResult();
        //    4.获取当前流程实例的状态
        boolean suspended = processInstance.isSuspended();
        //    5.获取流程实例id
        String instanceId = processInstance.getId();
        //    6.判断是否已经暂停，如果已经暂停，执行激活操作
        if(suspended){
    
            runtimeService.activateProcessInstanceById(instanceId);
            System.out.println("流程实例id="+instanceId+"已激活");
        }else{
    
            //    7.如果是激活状态，执行挂起操作
            runtimeService.suspendProcessInstanceById(instanceId);
            System.out.println("流程实例id="+instanceId+"已挂起");
        }

    }

    /**
     * 完成个人任务
     */
    @Test
    public void completeTask(){
    
    //    1.获取流程引擎
        ProcessEngine processEngine = ProcessEngines.getDefaultProcessEngine();
        //    2.获取TaskServie
        TaskService taskService = processEngine.getTaskService();
        //    3.使用TaskService获取任务
        Task task = taskService.createTaskQuery()
                .processInstanceId("20001")
                .taskAssignee("zhangsan")
                .singleResult();
        System.out.println("流程实例id="+task.getProcessInstanceId());
        System.out.println("流程任务id"+task.getId());
        System.out.println("负责人="+task.getAssignee());
        System.out.println("任务名称="+task.getName());
        //    4.根据任务的id完成任务
        taskService.complete(task.getId());
    }
}