java中jbpm工作流_安卓框架

java中jbpm工作流_安卓框架JBPM工作流框架应用导入jar包jbpm案例中获取配置文件,并配置本地数据库创建流程,并进行相关修改流程及流程内任务等的草操作importjava.io.File;importjava.io.FileInputStream;importjava.io.FileOutputStream;importjava.io.IOException;importj

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE使用 1年只要46元 售后保障 童叟无欺

JBPM工作流框架应用

  • 导入jar包
    导入jar包
  • jbpm案例中获取配置文件,并配置本地数据库
    从下载的jbpm案例中拷配置文件
    配置文件配置本地数据库
  • 创建流程,并进行相关修改
    创建流程01
    创建流程02
    创建流程03
    创建流程04
    创建流程05
  • 流程及流程内任务等的草操作
import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.Set;
import java.util.zip.ZipInputStream;

import org.jbpm.api.Configuration;
import org.jbpm.api.NewDeployment;
import org.jbpm.api.ProcessDefinition;
import org.jbpm.api.ProcessDefinitionQuery;
import org.jbpm.api.ProcessEngine;
import org.jbpm.api.ProcessInstance;
import org.jbpm.api.TaskQuery;
import org.jbpm.api.task.Task;
import org.junit.Test;


/** * * @Title: HelloWorld * @Description: 描述 * @Company: 山东九点连线信息技术有限公司 * @ProjectName: JBPMModel * @author fupengpeng * @date 2017年11月14日 上午10:18:34 */
public class HelloWorld { 
   
    ProcessEngine processEngine = Configuration.getProcessEngine();
    /** * 生成18张表 */
    @Test
    public void test1(){
        Configuration conf = new Configuration();//获取配置对象
        conf.setResource("jbpm.cfg.xml");//加载配置文件
        ProcessEngine processEngine = conf.buildProcessEngine();//创建流程引擎对象
    }

    /** * 创建流程引擎对象的方法 */
    @Test
    public void test2(){
        //方式一
        /*Configuration conf = new Configuration(); conf.setResource("jbpm.cfg.xml"); ProcessEngine processEngine = conf.buildProcessEngine();*/

        //方式二 获得的是单例对象
        ProcessEngine processEngine = Configuration.getProcessEngine();
    }

    /** * 部署流程定义 * @throws Exception */
    @Test
    public void test3() throws Exception{
        // 方式一----从类路径下读取文件
        NewDeployment deployment = processEngine.getRepositoryService().createDeployment();//获取部署对象;
        deployment.addResourceFromClasspath("helloworld2.jpdl.xml");//读取xml配置文件
        deployment.addResourceFromClasspath("helloworld2.png");//读取图片文件
        String id = deployment.deploy();//完成部署
        System.out.println(id);
        // 方式二----读取压缩文件流
// NewDeployment deployment = processEngine.getRepositoryService().createDeployment();//获取部署对象;
// deployment.addResourcesFromZipInputStream(new ZipInputStream(new FileInputStream(new File("E:\\MyEclipse\\workspacejavawebtestproject\\JBPMModel\\process\\hello.zip"))));
// String id = deployment.deploy();
// System.out.println("id = " + id );
    }

    /** * 查询流程定义 */
    @Test
    public void test5(){
        //获得流程定义查询对象
        ProcessDefinitionQuery query = processEngine.getRepositoryService().createProcessDefinitionQuery();
        long count = query.count();
        System.out.println("当前系统流程定义的数量 == " + count);
        List<ProcessDefinition> list = query.list();
        for (ProcessDefinition processDefinition : list) {
            String id = processDefinition.getId();
            String name = processDefinition.getName();
            String key = processDefinition.getKey();
            String deploymentId = processDefinition.getDeploymentId();
            System.out.println("id = " + id + " name = " + name + " key = " + key + " deploymentId = " + deploymentId);
        }

    }

    /** * 删除流程定义 */
    @Test
    public void test4(){
        String deploymentId = "1";
        processEngine.getRepositoryService().deleteDeployment(deploymentId);
    }


    /** * 获取流程定义文件 * @throws IOException */
    @Test
    public void test6() throws IOException{
        String deploymentId = "10001";
        //获得一次部署对应的文件名
        Set<String> names = processEngine.getRepositoryService().getResourceNames(deploymentId);
        for (String string : names) {
            System.out.println("string = " + string);
        }

        //获得一次部署对应的文件输入流
        String resourceName = "helloworld.jpdl.xml";
        String resourceNameXml = "helloworld.jpdl.xml";
        InputStream in = processEngine.getRepositoryService().getResourceAsStream(deploymentId, resourceName);
        //通过输出流将文件保存到本地磁盘
        OutputStream out = new FileOutputStream(new File("E:\\test\\" + resourceName));
        byte[] b = new byte[1024];
        int len = 0;
        while ((len = in.read(b)) != -1) {
            out.write(b,0,len);
        }
        out.close();
        in.close();
    }

    /** * 启动一个流程 */
    @Test
    public void test7(){
// String processDefinitionId = "请假流程-2";
// ProcessInstance processInstance = processEngine.getExecutionService().startProcessInstanceById(processDefinitionId);

        String key = "请假流程";
        //启动流程后,产生流程实例对象
        ProcessInstance processInstance = processEngine.getExecutionService().startProcessInstanceByKey(key);
        String id = processInstance.getId();
        String name = processInstance.getName();
        System.out.println("id = " + id + " name = " + name + " key = " + key);

    }

    /** * 查询我的任务列表 */
    @Test
    public void test8(){
        String userId = "李四";
        //启动流程后,产生流程实例对象
        TaskQuery query = processEngine.getTaskService().createTaskQuery();
        query.assignee(userId);  // 添加查询的过滤条件
        List<Task> list = query.list();
        for (Task task : list) {
            String executionId = task.getExecutionId();  //用于特殊情况,不需要李四审批时,查到他的所要执行的任务id,传递给test10,根据传入的id,越过此审批。
            System.out.println("id = " + task.getId() + " name = " + task.getName()+" executionId = " + executionId );
            //id = 30002 name = 提交申请
        }
    }

    /** * 办理任务 */
    @Test
    public void test9(){

        String taskId = "90002";
        processEngine.getTaskService().completeTask(taskId);

    }

    /** * 直接跳转到下一步,越过此步 */
    @Test
    public void test10(){
        String executionId = "请假流程.90001";
        processEngine.getExecutionService().signalExecutionById(executionId,"to task3");

        //流程实例查询对象
// ProcessInstanceQuery query = processEngine.getExecutionService().createProcessInstanceQuery();
// List<ProcessInstance> list = query.list();


        //部署查询对象
// DeploymentQuery query = processEngine.getRepositoryService().createDeploymentQuery();
// List<Deployment> list = query.list();
// for (Deployment d : list) { 
   
// System.out.println("d.getId = " + d.getId() + " " + d.getName());
// }

    }

    /** * 查询对象的使用方式 */
    @Test
    public void test11(){
        //创建流程定义查询对象
        ProcessDefinitionQuery query = processEngine.getRepositoryService().createProcessDefinitionQuery();
        //添加过滤条件
        query.processDefinitionKey("请假流程");
        //添加排序条件
        query.orderAsc(ProcessDefinitionQuery.PROPERTY_VERSION);
        //添加分页条件
        query.page(0, 10);
// query.page(10, 20);
        List<ProcessDefinition> list = query.list();
        for (ProcessDefinition pd : list) {
            System.out.println("pd.getId = " + pd.getId()   + " name = " + pd.getName() + " key = " + pd.getKey());
        }

    }

    /** * 获取最新版本的流程定义 */
    @Test
    public void test12(){
        //获取所有的流程定义
        ProcessDefinitionQuery query = processEngine.getRepositoryService().createProcessDefinitionQuery();
        query.orderAsc(ProcessDefinitionQuery.PROPERTY_VERSION);
        List<ProcessDefinition> list = query.list();
        Map<String, ProcessDefinition> map = new HashMap<String, ProcessDefinition>();
        for (ProcessDefinition pd : list) {
            String id = pd.getId();
            String key = pd.getKey();
            String name = pd.getName();
            int version = pd.getVersion();
// System.out.println("Id = " + id + " version = " + version + " key = " + key);
            map.put(key, pd);
        }

        List<ProcessDefinition> pdList = new ArrayList<ProcessDefinition>(map.values());
        for (ProcessDefinition pd : pdList) {
            String id = pd.getId();
            String key = pd.getKey();
            String name = pd.getName();
            int version = pd.getVersion();
            System.out.println("Id = " + id   + " version = " + version + " key = " + key);

        }

    }

}

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/195806.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

  • Android源码学习「建议收藏」

    Android源码学习「建议收藏」作为一名程序员,肯定不仅仅限于使用API文档,因为浮于表面是远远不够的。进阶学习的阶段,需要我们保持一颗好奇的心,深入阅读Android源码,学习优秀的代码风格和设计思想,知其然并且知其所以然。引用Google的一张框架图:Applications层,和用户直接交互的就是这些应用程序,它们都是用Java开发的。 JavaFramework层,这一层大部分用Java语言编写。它是An…

  • 把数据库中的静态图片遍历在前端页面上[通俗易懂]

    把数据库中的静态图片遍历在前端页面上[通俗易懂]把数据库中的静态图片遍历在前端页面上先上数据库中数据其次是后端的接口(把所有数据封装到List集合中发送过去):@RequestMapping(value=”/scenicSpots”,method=RequestMethod.GET)publicActionResultfindScenicSpots(){List<ScenicSpots>scenicSpots=scenicSpotService.QueryScenicSpots();

  • leetcode-49字母异位词分组(map)[通俗易懂]

    leetcode-49字母异位词分组(map)[通俗易懂]原题链接给定一个字符串数组,将字母异位词组合在一起。字母异位词指字母相同,但排列不同的字符串。示例:输入: [“eat”, “tea”, “tan”, “ate”, “nat”, “bat”]输出:[ [“ate”,”eat”,”tea”], [“nat”,”tan”], [“bat”]]说明:所有输入均为小写字母。不考虑答案输出的顺序。tclass Solution {public: vector<vector<string>> g

  • 安装python时出现的错误0x80072efd及0x80072f7d的解决方法

    安装python时出现的错误0x80072efd及0x80072f7d的解决方法0x80072efd:是下载不了dubuggingsymbols和debugbinaries的问题。要翻墙。或者把2个Download的安装选项取消,就可以完成了。0x80072f7d:修改了EXE文件名称安装成功感觉问题解决的十分不靠谱,感谢https://blog.csdn.net/quantum7/article/details/81738839,脑残丞相的提醒,他安装时也…

    2022年10月25日
  • findstr 用法

    findstr 用法http://bathome.l3.wuyou.com/thread-11159-1-6.html/B在一行的开始配对模式。——只在行开头搜索。/E在一行的结尾配对模式。——只在行结尾搜索。/L按字使用搜索字符串。——具体不详,可以与/r参数替换测试。

    2022年10月26日

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号