Springboot整合Activity7:任务,历史任务,UEL表达式(三)

简介: Springboot整合Activity7:任务,历史任务,UEL表达式(三)

历史任务
介绍
1.当一个实例任务完成后,工作流会自动在任务表等会删除这个记录,并保存在历史表
2.历史表操作就用到 HistoryService

    private HistoryService historyService;

    /**
     * 根据用户名查询历史任务
     */
    @Test
    public void gethistoryTaskInstanceByUser(){
        List<HistoricTaskInstance> list = historyService.createHistoricTaskInstanceQuery()
                .taskAssignee("bajie")
                //排序  asc:正序 desc:倒叙
                .orderByHistoricTaskInstanceEndTime().asc()
                .list();
        for (HistoricTaskInstance hi : list) {
            System.out.println(hi.getId());
            System.out.println(hi.getName());
            System.out.println(hi.getAssignee());
            System.out.println(hi.getProcessInstanceId());

        }
    }

    /**
     * 通过流程实例id查询历史任务
     */
    @Test
    public void gethistoryTaskInstanceByInstance(){
        List<HistoricTaskInstance> list = historyService.createHistoricTaskInstanceQuery()
                .processInstanceId("实例id")
                //排序  asc:正序 desc:倒叙
                .orderByHistoricTaskInstanceEndTime().asc()
                .list();
        for (HistoricTaskInstance hi : list) {
            System.out.println(hi.getId());
            System.out.println(hi.getName());
            System.out.println(hi.getAssignee());
            System.out.println(hi.getProcessInstanceId());

        }
    }

UEL表达式
介绍

  1. 又称统一表达语言,就是在

    1. uel表达式:在启动流程实例,任务完成时可以使用uel表达式携带参数
      基本概述
      运行时的相关数据库
      ————————————————
      ```@Autowired
      private RuntimeService runtimeService;

      @Autowired
      private TaskService taskService;

      /**

      • 启动流程实例时,执行执行人
        */
        @Test
        public void initProcessInstanceWithArgs(){
        //流程变量 //${ZhiXingRen}
        Map variables = new HashMap<>();
        //可以添加多个参数
        variables.put("ZhiXingRen","wukong");

        ProcessInstance processInstance = runtimeService

            .startProcessInstanceByKey("myProcess_UEL_V1","bket01"
            ,variables);
        

        System.out.println("流程实例id:" + processInstance.getProcessDefinitionId());
        }
        /**

      • 完成任务带参数 指定流程变量
        */
        @Test
        public void completeTaskWithArgs(){
        Map variables = new HashMap<>();
        //可以添加多个参数
        variables.put("pay","101");

// taskService.complete("实例id",null);
taskService.complete("60a326bd-8138-11ed-a774-f85ea0a4be6e",variables);
System.out.println("完成任务");
}
/**

 * 启动流程实例携带参数,使用实体类
 */
@Test
public void  initProcessInstanceWithClassArgs(){
    //流程变量实体类
    UEL_POJO uel_pojo = new UEL_POJO();
    uel_pojo.setZhixingren("bajie");

    Map<String,Object> variables = new HashMap<>();
    //可以添加多个参数
    variables.put("uelpojo",uel_pojo);

    ProcessInstance processInstance = runtimeService
            .startProcessInstanceByKey("myProcess_uelv3","bket01"
                    ,variables);
    System.out.println("流程实例id:" + processInstance.getProcessDefinitionId());
}
/**
 * 任务完成带参数,指定多个候选人
 * 01125c1c-813a-11ed-bf93-f85ea0a4be6e
 */
@Test
public void  initProcessInstanceWithCandidataArgs(){
    Map<String,Object> variables = new HashMap<>();
    //可以添加多个参数
    variables.put("houxuanren","wukong,tangseng");

// taskService.complete("实例id",null);
taskService.complete("01125c1c-813a-11ed-bf93-f85ea0a4be6e",variables);
System.out.println("完成任务");
}

/**
 * 直接指定流程变量
 */
@Test
public void  otherArgs(){
    runtimeService.setVariable("实例id","流程变量key","流程变量value");

// runtimeService.setVariables();
}
/**

 * 局部变量
 */
@Test
public void  otherLocalArgs(){
    runtimeService.setVariableLocal("实例id","流程变量key","流程变量value");

// runtimeService.setVariablesLocal();
}

```

相关文章
|
9月前
|
Java 关系型数据库 MySQL
springboot项目集成dolphinscheduler调度器 实现datax数据同步任务
springboot项目集成dolphinscheduler调度器 实现datax数据同步任务
861 2
|
10月前
|
SQL JSON Java
|
9月前
|
人工智能 安全 Java
Spring Boot 中使用 Function 和异步线程池处理列表拆分任务并汇总结果
在Java开发中,处理大规模数据时常常需要将列表拆分为多个子列表进行异步处理并汇总结果。本文介绍如何在Spring Boot中使用Function和异步线程池实现高效且可维护的代码,涵盖结果封装、线程池配置、列表拆分处理及结果汇总等关键步骤。
374 0
|
10月前
|
Java Spring
如何优雅的实现 SpringBoot 并行任务
我是小假 期待与你的下一次相遇 ~
204 1
|
分布式计算 大数据 Java
springboot项目集成大数据第三方dolphinscheduler调度器 执行/停止任务
springboot项目集成大数据第三方dolphinscheduler调度器 执行/停止任务
216 0
|
Java 调度 数据库
SpringBoot整合XXL-JOB【05】- 任务分片
在实际业务中,批量定时任务可能因上一批任务未完成而影响业务。为解决此问题,本文介绍如何使用Xxl-job对批量任务进行分片处理,通过分片广播形式调度集群机器并行执行任务,大幅提升执行效率。具体步骤包括环境准备、添加依赖和配置、声明实体类与查询类,以及改造业务逻辑实现分片查询。测试结果显示,分片处理将两千条数据的执行时间从30秒缩短至15秒,性能提升显著。
2045 13
SpringBoot整合XXL-JOB【05】-  任务分片
|
前端开发 Java API
SpringBoot整合Flowable【07】- 驳回节点任务
本文通过绩效流程的业务场景,详细介绍了如何在Flowable工作流引擎中实现任务驳回功能。具体步骤包括:获取目标任务节点和当前任务节点信息,进行必要的判空和逻辑校验,调用API完成节点回退,并清理相关脏数据(如历史任务和变量)。最后通过测试验证了驳回功能的正确性,确保流程能够成功回退到指定节点并清除中间产生的冗余数据。此功能在实际业务中非常有用,能够满足上级驳回自评等需求。
2522 0
SpringBoot整合Flowable【07】- 驳回节点任务
|
安全 Java 编译器
springboot 整合表达式计算引擎 Aviator 使用示例详解
本文详细介绍了Google Aviator 这款高性能、轻量级的 Java 表达式求值引擎
2216 6
|
消息中间件 缓存 监控
【Java笔记+踩坑】SpringBoot基础3——开发。热部署+配置高级+整合NoSQL/缓存/任务/邮件/监控
springboot的热部署、配置的宽松绑定和校验、任务、邮件、监控、springboot整合JdbcTemplate,h2等sql技术、整合redis,mongodb,es等nosql技术、整合redis,Memcached,jetcache,j2cache等缓存技术、整合ActiveMQ,RabbitMQ,RocketMQ,Kafka等消息的中间件的入门、整合缓存/任务/邮件/监控
【Java笔记+踩坑】SpringBoot基础3——开发。热部署+配置高级+整合NoSQL/缓存/任务/邮件/监控
|
SQL Java 调度
实时计算 Flink版产品使用问题之使用Spring Boot启动Flink处理任务时,使用Spring Boot的@Scheduled注解进行定时任务调度,出现内存占用过高,该怎么办
实时计算Flink版作为一种强大的流处理和批处理统一的计算框架,广泛应用于各种需要实时数据处理和分析的场景。实时计算Flink版通常结合SQL接口、DataStream API、以及与上下游数据源和存储系统的丰富连接器,提供了一套全面的解决方案,以应对各种实时计算需求。其低延迟、高吞吐、容错性强的特点,使其成为众多企业和组织实时数据处理首选的技术平台。以下是实时计算Flink版的一些典型使用合集。