import com.alibaba.fastjson.JSON;
import com.schinta.util.DateTimeUtil;
import lombok.extern.slf4j.Slf4j;
import org.activiti.engine.*;
import org.activiti.engine.history.*;
import org.activiti.engine.impl.identity.Authentication;
import org.activiti.engine.repository.Deployment;
import org.activiti.engine.runtime.ProcessInstance;
import org.activiti.engine.task.Comment;
import org.activiti.engine.task.Task;
import org.junit.jupiter.api.Test;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.util.CollectionUtils;
import java.util.*;
//spring boot2 集成activiti6 一系列異常文檔  https://www.jianshu.com/p/77fa5f932f4f
@Slf4j
@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
class WebApplicationTests {
    @Autowired
    private ProcessEngine processEngine;
    private RepositoryService repositoryService;
    private RuntimeService runtimeService;
    private TaskService taskService;
    private HistoryService historyService;
    @Test
    public void deployProcess() {
        //部署模板
        Deployment deploy = repositoryService.createDeployment()
                .addClasspathResource("processes/wh.bpmn20.xml")
                .deploy();
        System.out.println(deploy.getId());
    }
    public void start() {
        String instanceKey = "wh";
        log.info("開啟請假流程...");
        Map<String, Object> map = new HashMap<>();
        //在wh.bpmn中,填寫請假單的任務(wù)辦理人為動(dòng)態(tài)傳入的userId,此處模擬一個(gè)id
        map.put("user1", 1);
        map.put("user2", 2);
        Authentication.setAuthenticatedUserId("1");
        ProcessInstance instance = runtimeService.startProcessInstanceByKey(instanceKey, map);
        log.info("啟動(dòng)流程實(shí)例成功:{}", instance);
        log.info("流程實(shí)例ID:{}", instance.getId());
        log.info("流程定義ID:{}", instance.getProcessDefinitionId());
    public void taskQuery() {
        //查詢自己發(fā)起的全部的審批
        //List<HistoricProcessInstance> historicProcessInstanceList = historyService.createHistoricProcessInstanceQuery().startedBy(userId).list();
        //根據(jù)流程定義的key,負(fù)責(zé)人assignee來實(shí)現(xiàn)  當(dāng)前用戶的 待辦任務(wù)列表查詢
        List<Task> list = taskService.createTaskQuery()
                .processDefinitionKey(instanceKey)
                .taskAssignee("2")
                .list();
        if (list != null && list.size() > 0) {
            for (Task task : list) {
                System.out.println("任務(wù)ID:" + task.getId());
                System.out.println("任務(wù)名稱:" + task.getName());
                System.out.println("任務(wù)的創(chuàng)建時(shí)間:" + task.getCreateTime());
                System.out.println("任務(wù)的辦理人:" + task.getAssignee());
                System.out.println("流程實(shí)例ID：" + task.getProcessInstanceId());
                System.out.println("執(zhí)行對象ID:" + task.getExecutionId());
                System.out.println("流程定義ID:" + task.getProcessDefinitionId());
                System.out.println("getOwner:" + task.getOwner());
                System.out.println("getCategory:" + task.getCategory());
                System.out.println("getDescription:" + task.getDescription());
                System.out.println("getFormKey:" + task.getFormKey());
                Map<String, Object> map = task.getProcessVariables();
                for (Map.Entry<String, Object> m : map.entrySet()) {
                    System.out.println("key:" + m.getKey() + " value:" + m.getValue());
                }
                for (Map.Entry<String, Object> m : task.getTaskLocalVariables().entrySet()) {
            }
        }
    /**
     * 審批
     */
    public void employeeApply() {
        String instanceId = "130001"; //  執(zhí)行流程實(shí)例id
        Task task = taskService.createTaskQuery().processInstanceId(instanceId).singleResult();
        //是否同意 0 同意， 1 駁回
        map.put("status", "0");
        taskService.addComment(task.getId(), instanceId, "測試評論34");
        taskService.complete(task.getId(), map);
        log.info("流程推動(dòng)到下環(huán)節(jié)");
     * 實(shí)例詳情
    public void queryHistoryTask() {
        List<HistoricTaskInstance> list = historyService.createHistoricTaskInstanceQuery() // 創(chuàng)建歷史活動(dòng)實(shí)例查詢
                .processInstanceId(instanceId) // 執(zhí)行流程實(shí)例id
                .orderByTaskCreateTime()
                .asc()
        for (HistoricTaskInstance hai : list) {
            System.out.println("===================");
            System.out.println("活動(dòng)ID:" + hai.getId());
            System.out.println("流程實(shí)例ID:" + hai.getProcessInstanceId());
            System.out.println("活動(dòng)名稱：" + hai.getName());
            System.out.println("辦理人：" + hai.getAssignee());
            System.out.println("開始時(shí)間：" + hai.getStartTime());
            System.out.println("結(jié)束時(shí)間：" + hai.getEndTime());
            List<Comment> comments = taskService.getTaskComments(hai.getId());
            System.out.println("評論內(nèi)容：" + JSON.toJSONString(comments));
}