Activiti(二) springBoot2集成activiti,集成activiti在线设计器

  • 摘要

    本篇随笔主要记录springBoot2集成activiti流程引擎,而且嵌入activiti的在线设计器,能够经过浏览器直接编辑出咱们须要的流程,不须要经过eclipse或者IDEA的actiBpm插件设计流程再直接部署到项目下,页面保存流程后可直接发布、发起流程。javascript

  • 所需软件版本
    springBoot  2.0.1.RELEASE
    activiti 5.22.0    官网下载地址
    activiti-webapp-explorer2   个人github上的explorer项目

  • 集成方法
    activiti支持多种数据库,自己还有个h2的内存数据库,我这里用的是Mysql
    一、pom.xml引入依赖,这里主要是activiti的依赖包,${activiti.version}为5.22.0

    <!--spring activiti start-->
            <dependency>
                <groupId>org.activiti</groupId>
                <artifactId>activiti-spring-boot-starter-basic</artifactId>
                <version>${activiti.version}</version>
                <exclusions>
                    <exclusion>
                        <groupId>org.springframework.boot</groupId>
                        <artifactId>spring-boot-starter-actuator</artifactId>
                    </exclusion>
                    <exclusion>
                        <groupId>org.springframework.boot</groupId>
                        <artifactId>spring-boot-starter-web</artifactId>
                    </exclusion>
                    <exclusion>
                        <groupId>org.springframework.security</groupId>
                        <artifactId>spring-security-config</artifactId>
                    </exclusion>
                </exclusions>
            </dependency>
            <dependency>
                <groupId>org.activiti</groupId>
                <artifactId>activiti-spring-boot-starter-actuator</artifactId>
                <version>${activiti.version}</version>
                <exclusions>
                    <exclusion>
                        <groupId>org.springframework.boot</groupId>
                        <artifactId>spring-boot-starter-web</artifactId>
                    </exclusion>
                </exclusions>
            </dependency>
            <dependency>
                <groupId>org.activiti</groupId>
                <artifactId>activiti-rest</artifactId>
                <version>${activiti.version}</version>
                <exclusions>
                    <exclusion>
                        <groupId>org.springframework.security</groupId>
                        <artifactId>spring-security-config</artifactId>
                    </exclusion>
                </exclusions>
            </dependency>
            <dependency>
                <groupId>org.activiti</groupId>
                <artifactId>activiti-explorer</artifactId>
                <version>${activiti.version}</version>
                <exclusions>
                    <exclusion>
                        <groupId>com.vaadin</groupId>
                        <artifactId>vaadin</artifactId>
                    </exclusion>
                    <exclusion>
                        <groupId>org.vaadin.addons</groupId>
                        <artifactId>dcharts-widget</artifactId>
                    </exclusion>
                    <exclusion>
                        <groupId>activiti-simple-workflow</groupId>
                        <artifactId>org.activiti</artifactId>
                    </exclusion>
                </exclusions>
            </dependency>
            <dependency>
                <groupId>org.activiti</groupId>
                <artifactId>activiti-diagram-rest</artifactId>
                <version>${activiti.version}</version>
            </dependency>
            <dependency>
                <groupId>org.activiti</groupId>
                <artifactId>activiti-simple-workflow</artifactId>
                <version>${activiti.version}</version>
            </dependency>
            <dependency>
                <groupId>org.activiti</groupId>
                <artifactId>activiti-spring</artifactId>
                <version>${activiti.version}</version>
            </dependency>
            <dependency>
                <groupId>org.apache.xmlgraphics</groupId>
                <artifactId>batik-codec</artifactId>
                <version>1.7</version>
            </dependency>
            <dependency>
                <groupId>org.apache.xmlgraphics</groupId>
                <artifactId>batik-css</artifactId>
                <version>1.7</version>
            </dependency>
            <dependency>
                <groupId>org.apache.xmlgraphics</groupId>
                <artifactId>batik-svg-dom</artifactId>
                <version>1.7</version>
            </dependency>
            <dependency>
                <groupId>org.apache.xmlgraphics</groupId>
                <artifactId>batik-svggen</artifactId>
                <version>1.7</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.security</groupId>
                <artifactId>spring-security-config</artifactId>
                <version>4.1.3.RELEASE</version>
            </dependency>
    
            <!--spring activiti end-->

     二、拷贝项目资源
      解压activiti-webapp-explorer2,把webapp下面的diagram-viewer、editor-app、modeler.html复制到springboot项目下的static下,这是activiti的在线设计器,modeler.html就是设计的主界面,复制resources下stencilset.json到本身的resources下。
      


      解压activiti-5.22.0的包,将libs下的activiti-modeler-5.22.0-sources.jar解压出来,把org\activiti\rest\editor路径下的main、model文件夹复制到springboot项目的源码路径下,里面有三个类,主要用于读取stencilset.json。




    三、修改拷贝过来的资源文件
      修改StencilsetRestResource.java、ModelEditorJsonRestResource.java、ModelSaveRestResource.java3个controller,加上@RequestMapping("/service")



      修改editor-app下的app-cfg.js,把contextRoot后面改为
    /service,和controller里面加的requestMapping要一致
    css

  • var ACTIVITI = ACTIVITI || {}; ACTIVITI.CONFIG = { 'contextRoot' : '/service', };

     

    4、新增service、controller
      service实现,这里只放实现类,接口就不放了,本身能够根据实现类本身添加接口方法,这个service实现了把流程和自定义表单结合的功能,completeTask方法经过java反射执行不一样任务节点执行不一样form
    html

    package com.djkj.activiti.service.Impl; import com.djkj.activiti.bean.ActivitiVariable; import com.djkj.activiti.common.BusinessTaskUtil; import com.djkj.activiti.service.ActivitiService; import com.djkj.activiti.service.ActivitiVariableService; import org.activiti.bpmn.model.BpmnModel; import org.activiti.engine.HistoryService; import org.activiti.engine.RepositoryService; import org.activiti.engine.RuntimeService; import org.activiti.engine.TaskService; import org.activiti.engine.delegate.DelegateExecution; import org.activiti.engine.history.HistoricActivityInstance; import org.activiti.engine.history.HistoricProcessInstance; import org.activiti.engine.impl.cfg.ProcessEngineConfigurationImpl; import org.activiti.engine.impl.persistence.entity.ProcessDefinitionEntity; import org.activiti.engine.impl.pvm.PvmTransition; import org.activiti.engine.impl.pvm.process.ActivityImpl; import org.activiti.engine.runtime.ProcessInstance; import org.activiti.engine.task.Task; import org.activiti.image.ProcessDiagramGenerator; import org.apache.log4j.Logger; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import sun.misc.BASE64Encoder; import javax.imageio.ImageIO; import java.awt.image.BufferedImage; import java.io.ByteArrayOutputStream; import java.io.File; import java.io.FileOutputStream; import java.io.InputStream; import java.lang.reflect.Method; import java.util.*; @Service public class ActivitiServiceImpl implements ActivitiService { @Autowired private RuntimeService runtimeService; @Autowired private TaskService taskService; @Autowired private HistoryService historyService; @Autowired private RepositoryService repositoryService; @Autowired private ProcessEngineConfigurationImpl processEngineConfiguration; @Autowired private ActivitiVariableService activitiVariableService; private static final Logger logger=Logger.getLogger(ActivitiServiceImpl.class); /** * 启动流程 */ @Override public void startProcesses(String id,String business_key) { ProcessInstance pi = runtimeService.startProcessInstanceByKey(id, business_key);//流程图id,业务表id
            System.out.println("流程启动成功,流程id:"+pi.getId()); } /** * * <p>描述: 根据用户id查询待办任务列表</p> * @author 范相如 * @date 2018年2月25日 */ @Override public List<Task> findTasksByUserId(String userId) { List<Task> resultTask = taskService.createTaskQuery().processDefinitionKey("process").taskCandidateOrAssigned(userId).list(); return resultTask; } @Override public Task findTaskById(String taskId){ List<Task> resultTask = taskService.createTaskQuery().taskId(taskId).list(); if(resultTask!=null){ return resultTask.get(0); } return null; } /** * * <p>描述:任务审批 (经过/拒接) </p> * @author 范相如 * @date 2018年2月25日 * @param taskId 任务id * @param userId 用户id * @param result false OR true */ @Override public void completeTask(String taskId,String userId,String result) { //获取流程实例
     taskService.claim(taskId, userId); //获取任务
            Task task=taskService.createTaskQuery().taskId(taskId).singleResult(); //获取流程实例ID
            String proInsId = task.getProcessInstanceId(); //获取流程实例
            ProcessInstance process = runtimeService.createProcessInstanceQuery().processInstanceId(proInsId).singleResult(); //获取业务外键
            String business_key = process.getBusinessKey(); String[] array = business_key.split(":"); String business_Id = array[1]; //业务处理
            try { Class clazz=BusinessTaskUtil.class; Object obj = clazz.newInstance(); Method method = clazz.getMethod("actBusiness_"+task.getFormKey(),String.class,String.class,String.class); method.invoke(obj,userId,business_Id,result); }catch (Exception e){ e.printStackTrace(); logger.error("执行业务方法错误!"); } taskService.complete(taskId); } /** * 更改业务流程状态#{ActivityDemoServiceImpl.updateBizStatus(execution,"tj")} * @param execution * @param status */ @Override public void updateBizStatus(DelegateExecution execution, String status) { String bizId = execution.getProcessBusinessKey(); //根据业务id自行处理业务表
            System.out.println("业务表["+bizId+"]状态更改为功,状态更改成:"+status); } //流程节点权限用户列表${ActivityDemoServiceImpl.findUsers(execution,sign)}
     @Override public List<String> findUsersForSL(DelegateExecution execution){ return Arrays.asList("sly1","sly2"); } //流程节点权限用户列表${ActivityDemoServiceImpl.findUsers(execution,sign)}
     @Override public List<String> findUsersForSP(DelegateExecution execution){ return Arrays.asList("spy1","uspy2"); } /** * * <p>描述: 生成流程图 * 首先启动流程,获取processInstanceId,替换便可生成</p> * @author 范相如 * @date 2018年2月25日 * @param processInstanceId * @throws Exception */ @Override public void queryProImg(String processInstanceId) throws Exception { //获取历史流程实例
            HistoricProcessInstance processInstance = historyService.createHistoricProcessInstanceQuery().processInstanceId(processInstanceId).singleResult(); //根据流程定义获取输入流
            InputStream is = repositoryService.getProcessDiagram(processInstance.getProcessDefinitionId()); BufferedImage bi = ImageIO.read(is); File file = new File("demo2.png"); if(!file.exists()) file.createNewFile(); FileOutputStream fos = new FileOutputStream(file); ImageIO.write(bi, "png", fos); fos.close(); is.close(); System.out.println("图片生成成功"); List<Task> tasks = taskService.createTaskQuery().taskCandidateUser("userId").list(); for(Task t : tasks) { System.out.println(t.getName()); } } /** * 流程图高亮显示 * 首先启动流程,获取processInstanceId,替换便可生成 * @throws Exception */ @Override public String queryProHighLighted(String processInstanceId) throws Exception { //获取历史流程实例
            HistoricProcessInstance processInstance = historyService.createHistoricProcessInstanceQuery().processInstanceId(processInstanceId).singleResult(); //获取流程图
            BpmnModel bpmnModel = repositoryService.getBpmnModel(processInstance.getProcessDefinitionId()); ProcessDiagramGenerator diagramGenerator = processEngineConfiguration.getProcessDiagramGenerator(); ProcessDefinitionEntity definitionEntity = (ProcessDefinitionEntity)repositoryService.getProcessDefinition(processInstance.getProcessDefinitionId()); List<HistoricActivityInstance> highLightedActivitList = historyService.createHistoricActivityInstanceQuery().processInstanceId(processInstanceId).list(); //高亮环节id集合
            List<String> highLightedActivitis = new ArrayList<String>(); //高亮线路id集合
            List<String> highLightedFlows = getHighLightedFlows(definitionEntity,highLightedActivitList); for(HistoricActivityInstance tempActivity : highLightedActivitList){ String activityId = tempActivity.getActivityId(); highLightedActivitis.add(activityId); } //配置字体
            InputStream imageStream = diagramGenerator.generateDiagram(bpmnModel, "png", highLightedActivitis, highLightedFlows,"宋体","微软雅黑","黑体",null,2.0); BufferedImage bi = ImageIO.read(imageStream); // File file = new File("demo2.png"); // if(!file.exists()) file.createNewFile(); // FileOutputStream fos = new FileOutputStream(file);
            ByteArrayOutputStream bos= new ByteArrayOutputStream(); ImageIO.write(bi, "png", bos); byte[] bytes = bos.toByteArray();//转换成字节
            BASE64Encoder encoder = new BASE64Encoder(); String png_base64 =  encoder.encodeBuffer(bytes);//转换成base64串
            png_base64 = png_base64.replaceAll("\n", "").replaceAll("\r", "");//删除 \r\n
     bos.close(); imageStream.close(); return png_base64; } /** * 获取须要高亮的线 * @param processDefinitionEntity * @param historicActivityInstances * @return
         */
        private List<String> getHighLightedFlows( ProcessDefinitionEntity processDefinitionEntity, List<HistoricActivityInstance> historicActivityInstances) { List<String> highFlows = new ArrayList<String>();// 用以保存高亮的线flowId
            for (int i = 0; i < historicActivityInstances.size() - 1; i++) {// 对历史流程节点进行遍历
                ActivityImpl activityImpl = processDefinitionEntity .findActivity(historicActivityInstances.get(i) .getActivityId());// 获得节点定义的详细信息
                List<ActivityImpl> sameStartTimeNodes = new ArrayList<ActivityImpl>();// 用以保存后需开始时间相同的节点
                ActivityImpl sameActivityImpl1 = processDefinitionEntity .findActivity(historicActivityInstances.get(i + 1) .getActivityId()); // 将后面第一个节点放在时间相同节点的集合里
     sameStartTimeNodes.add(sameActivityImpl1); for (int j = i + 1; j < historicActivityInstances.size() - 1; j++) { HistoricActivityInstance activityImpl1 = historicActivityInstances .get(j);// 后续第一个节点
                    HistoricActivityInstance activityImpl2 = historicActivityInstances .get(j + 1);// 后续第二个节点
                    if (activityImpl1.getStartTime().equals( activityImpl2.getStartTime())) { // 若是第一个节点和第二个节点开始时间相同保存
                        ActivityImpl sameActivityImpl2 = processDefinitionEntity .findActivity(activityImpl2.getActivityId()); sameStartTimeNodes.add(sameActivityImpl2); } else { // 有不相同跳出循环
                        break; } } List<PvmTransition> pvmTransitions = activityImpl .getOutgoingTransitions();// 取出节点的全部出去的线
                for (PvmTransition pvmTransition : pvmTransitions) { // 对全部的线进行遍历
                    ActivityImpl pvmActivityImpl = (ActivityImpl) pvmTransition .getDestination(); // 若是取出的线的目标节点存在时间相同的节点里,保存该线的id,进行高亮显示
                    if (sameStartTimeNodes.contains(pvmActivityImpl)) { highFlows.add(pvmTransition.getId()); } } } return highFlows; } }
    View Code

     

      controller实现,我写了两个controller,主要当时写的时候没有写在一块儿,大家能够把这两部分的内容合并在一块儿
    java

    package com.djkj.activiti.controller; import com.fasterxml.jackson.databind.JsonNode; import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.databind.node.ObjectNode; import org.activiti.bpmn.converter.BpmnXMLConverter; import org.activiti.bpmn.model.BpmnModel; import org.activiti.editor.constants.ModelDataJsonConstants; import org.activiti.editor.language.json.converter.BpmnJsonConverter; import org.activiti.engine.ProcessEngine; import org.activiti.engine.RepositoryService; import org.activiti.engine.repository.Deployment; import org.activiti.engine.repository.Model; import org.apache.commons.lang3.StringUtils; import org.apache.log4j.Logger; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Controller; import org.springframework.ui.ModelMap; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.ResponseBody; import org.springframework.web.bind.annotation.RestController; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import java.io.IOException; import java.io.UnsupportedEncodingException; import java.util.List; @Controller @RequestMapping("/models") public class MyActivitiController { private static final Logger LOGGER = Logger.getLogger(MyActivitiController.class); @Autowired private RepositoryService repositoryService; @Autowired private ObjectMapper objectMapper; @RequestMapping("/modelList") public String modelList(org.springframework.ui.Model model,HttpServletRequest request){ LOGGER.info("-------------列表页-------------"); List<Model> models = repositoryService.createModelQuery().orderByCreateTime().desc().list(); model.addAttribute("models",models); String info = request.getParameter("info"); if(StringUtils.isNotEmpty(info)){ model.addAttribute("info",info); } return "model/list"; } @RequestMapping("/create") public void newModel(HttpServletRequest request, HttpServletResponse response) throws UnsupportedEncodingException { try { //初始化一个空模型
               Model model = repositoryService.newModel(); //设置一些默认信息
               String name = "new-process"; String description = ""; int revision = 1; String key = "process"; ObjectNode modelNode = objectMapper.createObjectNode(); modelNode.put(ModelDataJsonConstants.MODEL_NAME, name); modelNode.put(ModelDataJsonConstants.MODEL_DESCRIPTION, description); modelNode.put(ModelDataJsonConstants.MODEL_REVISION, revision); model.setName(name); model.setKey(key); model.setMetaInfo(modelNode.toString()); repositoryService.saveModel(model); String id = model.getId(); //完善ModelEditorSource
               ObjectNode editorNode = objectMapper.createObjectNode(); editorNode.put("id", "canvas"); editorNode.put("resourceId", "canvas"); ObjectNode stencilSetNode = objectMapper.createObjectNode(); stencilSetNode.put("namespace", "http://b3mn.org/stencilset/bpmn2.0#"); editorNode.put("stencilset", stencilSetNode); repositoryService.addModelEditorSource(id, editorNode.toString().getBytes("utf-8")); response.sendRedirect(request.getContextPath() + "/static/modeler.html?modelId=" + id); }catch (IOException e){ e.printStackTrace(); LOGGER.info("模型建立失败!"); } } @RequestMapping("/delete/{id}") public @ResponseBody String deleteModel(@PathVariable("id")String id){ repositoryService.deleteModel(id); return "删除成功!"; } @RequestMapping("/deployment/{id}") public @ResponseBody String deploy(@PathVariable("id")String id) throws Exception { //获取模型
            Model modelData = repositoryService.getModel(id); byte[] bytes = repositoryService.getModelEditorSource(modelData.getId()); if (bytes == null) { return "模型数据为空,请先设计流程并成功保存,再进行发布。"; } JsonNode modelNode = new ObjectMapper().readTree(bytes); BpmnModel model = new BpmnJsonConverter().convertToBpmnModel(modelNode); if(model.getProcesses().size()==0){ return "数据模型不符要求,请至少设计一条主线流程。"; } byte[] bpmnBytes = new BpmnXMLConverter().convertToXML(model); //发布流程
            String processName = modelData.getName() + ".bpmn20.xml"; Deployment deployment = repositoryService.createDeployment() .name(modelData.getName()) .addString(processName, new String(bpmnBytes, "UTF-8")) .deploy(); modelData.setDeploymentId(deployment.getId()); repositoryService.saveModel(modelData); return "流程发布成功"; } @RequestMapping("/start/{id}") public @ResponseBody String startProcess(@PathVariable("id") String id){ try { }catch (Exception e){ e.printStackTrace(); return "流程启动失败!"; } return "流程启动成功"; } }
    View Code

     

    显示全部流程列表,以及流程的增删改node

    package com.djkj.activiti.controller; import com.djkj.activiti.bean.ActivitiVariable; import com.djkj.activiti.bean.FormData; import com.djkj.activiti.service.ActivitiService; import com.djkj.activiti.service.ActivitiVariableService; import org.activiti.engine.HistoryService; import org.activiti.engine.TaskService; import org.activiti.engine.task.Task; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Controller; import org.springframework.ui.ModelMap; import org.springframework.web.bind.annotation.PathVariable; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.ResponseBody; import org.springframework.web.servlet.mvc.support.RedirectAttributesModelMap; import javax.annotation.Resource; import java.util.Date; import java.util.HashMap; import java.util.List; import java.util.Map; @Controller @RequestMapping("/activiti") public class ActivitiProcessController { @Resource private ActivitiService activitiServiceImpl; @Autowired private TaskService taskService; @Autowired private HistoryService historyService; @Autowired private ActivitiVariableService activitiVariableService; // private static final String business = "testtask"; //启动流程---215001
        @RequestMapping("/start/{key}") public String startProcess(@PathVariable("key") String key, RedirectAttributesModelMap modelMap) { // Map<String,Object> map = new HashMap<String,Object>(); // map.put("userId",userIdSl); // map.put("businessKey",business_key); // String business_key = key + ":" + key;
            ActivitiVariable activitiVariable = new ActivitiVariable(); int resul=activitiVariableService.insert(activitiVariable); if(resul==1){ modelMap.addFlashAttribute("info","流程启动成功!"); String business_key = key+":"+activitiVariable.getId(); activitiServiceImpl.startProcesses(key,business_key); }else{ modelMap.addFlashAttribute("info","流程启动失败!"); } return "redirect:/models/modelList"; } //获取受理员任务列表
        @RequestMapping("/queryTaskSl") public String findTasksForSL(ModelMap modelMap,FormData formData) { List<Task> lists = activitiServiceImpl.findTasksByUserId(formData.getUserId()); modelMap.addAttribute("tasks",lists); modelMap.addAttribute("userId",formData.getUserId()); return "model/taskList"; } @RequestMapping("/form") public String form(FormData formData,ModelMap modelMap){ Task task=activitiServiceImpl.findTaskById(formData.getId()); modelMap.addAttribute("data",formData); modelMap.addAttribute("task",task); if(StringUtils.isNotEmpty(task.getFormKey())){ return "activitiForm/"+task.getFormKey(); } return "model/form"; } //受理员受理数据
        @RequestMapping("/completeTaskSl") public String completeTasksForSL(ModelMap modelMap,FormData formData) { activitiServiceImpl.completeTask(formData.getId(), formData.getUserId(), formData.getAttr1());//受理后,任务列表数据减小
            return findTasksForSL(modelMap,formData); } //    //获取审批员任务列表 // @RequestMapping("/queryTaskSp") // public void findTasksForSP() { // List<Task> lists = activitiServiceImpl.findTasksByUserId(userIdSp); // System.out.println("任务列表:"+lists);//任务列表:[Task[id=220004, name=审批]] // } //
    //    //审批员经过审核 // @RequestMapping("/completeTaskSp/{id}") // public void completeTasksForSP(@PathVariable("id")String id) { // activitiServiceImpl.completeTask(id, userIdSp, "true");//审批后,任务列表数据减小 // } //设置流程变量 //设置流程变量【基本类型】
        public void setTasksVar() { List<Task> lists = activitiServiceImpl.findTasksByUserId("sly1"); for(Task task : lists) {//不知为什么,变量保存成功,但数据表只有请假天数含有任务id,单获取流程变量时,根据任务id都可获取到(以下一测试)
                taskService.setVariable(task.getId(), "请假人", "sly1"); taskService.setVariableLocal(task.getId(), "请假天数",3); taskService.setVariable(task.getId(), "请假日期", new Date()); } } //    //获取流程变量 // @Test // public void getTasksVar() { // List<Task> lists = activitiServiceImpl.findTasksByUserId("sly1"); // for(Task task : lists) { //            //获取流程变量【基本类型】 // String person = (String) taskService.getVariable(task.getId(), "请假人"); // Integer day = (Integer) taskService.getVariableLocal(task.getId(), "请假天数"); // Date date = (Date) taskService.getVariable(task.getId(), "请假日期"); //
    // System.out.println("流程变量:"+person+"||"+day+"||"+date+"||"); // } // } //
    //    //设置流程变量【实体】 // @Test // public void setTasksVarEntity() { // List<Task> lists = activitiServiceImpl.findTasksByUserId("sly1"); // for(Task task : lists) { // Person p = new Person(); // p.setName("翠花"); // p.setId(20); // p.setDate();; // p.setNote("回去探亲,一块儿吃个饭123"); // taskService.setVariable(task.getId(), "人员信息(添加固定版本)", p); //
    // System.out.println("设置流程变量成功!"); // } // } //
    //    //获取流程变量【实体】 实体必须序列化 // @Test // public void getTasksVarEntity() { // List<Task> lists = activitiServiceImpl.findTasksByUserId("sly1"); // for(Task task : lists) { //            // 2.获取流程变量,使用javaBean类型 // Person p = (Person)taskService.getVariable(task.getId(), "人员信息(添加固定版本)"); // System.out.println(" 请假人: "+p.getName()+" 请假天数: "+p.getId()+" 请假时间:"+ p.getDate()+ " 请假缘由: "+p.getNote()); // } // } //
    //
    //    //生成流程图---232501 // @RequestMapping("/queryProImg") // public void queryProImg() throws Exception { // activitiServiceImpl.queryProImg("232501"); // } //生成流程图(高亮)---232501
        @RequestMapping("/queryProHighLighted") public @ResponseBody String queryProHighLighted(String proInsId) throws Exception { String imageByteArray = activitiServiceImpl.queryProHighLighted(proInsId); return imageByteArray; } //
    // /** // * 查询流程变量的历史表,能够根据变量名称查询该变量的全部历史信息 // */ // @Test // public void findHistoryProcessVariables(){ // List<HistoricVariableInstance> list = historyService.createHistoricVariableInstanceQuery()//建立一个历史的流程变量查询对象 // .variableName("请假天数") // .list(); // if (list!=null &&list.size()>0) { // for (HistoricVariableInstance hvi : list) { // System.out.println(hvi.getId()+" "+hvi.getProcessInstanceId()+" "+hvi.getVariableName() // +" "+hvi.getVariableTypeName()+" "+hvi.getValue()); // System.out.println("########################################"); // } // } //
    // } //
    //
    // /** // * 历史流程实例查询 // * http://blog.csdn.net/luckyzhoustar/article/details/48652783
    // */ // @Test // public void findHistoricProcessInstance() { //        // 查询已完成的流程 // List<HistoricProcessInstance> datas = historyService // .createHistoricProcessInstanceQuery().finished().list(); // System.out.println("使用finished方法:" + datas.size()); //        // 根据流程定义ID查询 // datas = historyService.createHistoricProcessInstanceQuery() // .processDefinitionId("processDefinitionId").list(); // System.out.println("使用processDefinitionId方法: " + datas.size()); //        // 根据流程定义key(流程描述文件的process节点id属性)查询 // datas = historyService.createHistoricProcessInstanceQuery() // .processDefinitionKey("processDefinitionKey").list(); // System.out.println("使用processDefinitionKey方法: " + datas.size()); //        // 根据业务主键查询 // datas = historyService.createHistoricProcessInstanceQuery() // .processInstanceBusinessKey("processInstanceBusinessKey").list(); // System.out.println("使用processInstanceBusinessKey方法: " + datas.size()); //        // 根据流程实例ID查询 // datas = historyService.createHistoricProcessInstanceQuery() // .processInstanceId("processInstanceId").list(); // System.out.println("使用processInstanceId方法: " + datas.size()); //        // 查询没有完成的流程实例 // historyService.createHistoricProcessInstanceQuery().unfinished().list(); // System.out.println("使用unfinished方法: " + datas.size()); // } //
    // /** // * 历史任务查询 // * @throws ParseException // */ // @Test // public void findHistoricTasks() throws ParseException { // SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); //
    //        //历史数据查询 // List<HistoricTaskInstance> datas = historyService.createHistoricTaskInstanceQuery() // .finished().list(); // System.out.println("使用finished方法查询:" + datas.size()); // datas = historyService.createHistoricTaskInstanceQuery() // .processDefinitionId("processDefinitionId").list(); // System.out.println("使用processDefinitionId方法查询:" + datas.size()); // datas = historyService.createHistoricTaskInstanceQuery() // .processDefinitionKey("testProcess").list(); // System.out.println("使用processDefinitionKey方法查询:" + datas.size()); // datas = historyService.createHistoricTaskInstanceQuery() // .processDefinitionName("testProcess2").list(); // System.out.println("使用processDefinitionName方法查询:" + datas.size()); // datas = historyService.createHistoricTaskInstanceQuery() // .processFinished().list(); // System.out.println("使用processFinished方法查询:" + datas.size()); // datas = historyService.createHistoricTaskInstanceQuery() // .processInstanceId("processInstanceId").list(); // System.out.println("使用processInstanceId方法查询:" + datas.size()); // datas = historyService.createHistoricTaskInstanceQuery() // .processUnfinished().list(); // System.out.println("使用processUnfinished方法查询:" + datas.size()); // datas = historyService.createHistoricTaskInstanceQuery() // .taskAssignee("crazyit").list(); // System.out.println("使用taskAssignee方法查询:" + datas.size()); // datas = historyService.createHistoricTaskInstanceQuery() // .taskAssigneeLike("%zy%").list(); // System.out.println("使用taskAssigneeLike方法查询:" + datas.size()); // datas = historyService.createHistoricTaskInstanceQuery() // .taskDefinitionKey("usertask1").list(); // System.out.println("使用taskDefinitionKey方法查询:" + datas.size()); // datas = historyService.createHistoricTaskInstanceQuery() // .taskDueAfter(sdf.parse("2020-10-11 06:00:00")).list(); // System.out.println("使用taskDueAfter方法查询:" + datas.size()); // datas = historyService.createHistoricTaskInstanceQuery() // .taskDueBefore(sdf.parse("2022-10-11 06:00:00")).list(); // System.out.println("使用taskDueBefore方法查询:" + datas.size()); // datas = historyService.createHistoricTaskInstanceQuery() // .taskDueDate(sdf.parse("2020-10-11 06:00:00")).list(); // System.out.println("使用taskDueDate方法查询:" + datas.size()); // datas = historyService.createHistoricTaskInstanceQuery() // .unfinished().list(); // System.out.println("使用unfinished方法查询:" + datas.size()); // } // /** // * 历史行为查询 // * 流程在进行过程当中,往往走一个节点,都会记录流程节点的信息,包括节点的id,名称、类型、时间等,保存到ACT_HI_ACTINST表中。 // * @throws ParseException // */ // @Test // public void findHistoricActivityInstance() { // SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); //
    //        //查询数据 // List<HistoricActivityInstance> datas = historyService.createHistoricActivityInstanceQuery() // .activityId("endevent1").list(); // System.out.println("使用activityId查询:" + datas.size()); // datas = historyService.createHistoricActivityInstanceQuery() // .activityInstanceId(datas.get(0).getId()).list(); // System.out.println("使用activityInstanceId查询:" + datas.size()); // datas = historyService.createHistoricActivityInstanceQuery() // .activityType("intermediateSignalCatch").list(); // System.out.println("使用activityType查询:" + datas.size()); // datas = historyService.createHistoricActivityInstanceQuery() // .executionId("executionId").list(); // System.out.println("使用executionId查询:" + datas.size()); // datas = historyService.createHistoricActivityInstanceQuery().finished().list(); // System.out.println("使用finished查询:" + datas.size()); // datas = historyService.createHistoricActivityInstanceQuery() // .processInstanceId("processInstanceId").list(); // System.out.println("使用processInstanceId查询:" + datas.size()); // datas = historyService.createHistoricActivityInstanceQuery() // .taskAssignee("crazyit").list(); // System.out.println("使用taskAssignee查询:" + datas.size()); // datas = historyService.createHistoricActivityInstanceQuery().unfinished().list(); // System.out.println("使用unfinished查询:" + datas.size()); // } //
    // /** // * 历史流程明细查询 // * 在流程进行的过程当中,会产生许多明细数据,只有将History设置为最高级别的时候,才会被记录到ACT_HI_DETAIL表中。 // * @throws ParseException // */ // @Test // public void findHistoricDetail() { //        // 查询历史行为 // HistoricActivityInstance act = historyService.createHistoricActivityInstanceQuery() // .activityName("First Task").finished().singleResult(); // List<HistoricDetail> datas = historyService.createHistoricDetailQuery() // .activityInstanceId(act.getId()).list(); // System.out.println("使用activityInstanceId方法查询:" + datas.size()); // datas = historyService.createHistoricDetailQuery().excludeTaskDetails().list(); // System.out.println("使用excludeTaskDetails方法查询:" + datas.size()); // datas = historyService.createHistoricDetailQuery().formProperties().list(); // System.out.println("使用formProperties方法查询:" + datas.size()); // datas = historyService.createHistoricDetailQuery().processInstanceId("processInstanceId").list(); // System.out.println("使用processInstanceId方法查询:" + datas.size()); // datas = historyService.createHistoricDetailQuery().taskId("taskId").list(); // System.out.println("使用taskId方法查询:" + datas.size()); // datas = historyService.createHistoricDetailQuery().variableUpdates().list(); // System.out.println("使用variableUpdates方法查询:" + datas.size()); // }
     }
    View Code

    启动流程、用户任务task查询、业务处理、流程进度查看等等,历史流程查看功能没有验证过,这部分代码是注释掉的



    5、页面实现
      在templates放置显示页面,可本身根据喜爱放置,我这里主要是跟controller里返回的路径对应


      model文件夹下放的是模型列表页和用户任务列表页,form.html已经废弃,改成上面的activitiForm里面的form页面,不一样的页面对应不一样流程节点


      
    list.html模型列表页
    jquery

  • <!DOCTYPE html>
    <html lang="zh" xmlns:th="http://www.thymeleaf.org">
    <head>
        <meta charset="UTF-8">
        <title>Title</title>
        <script src="/static/js/jquery.min.js"></script>
        <script th:inline="javascript">
            function deployment(obj){ var id=obj.attributes['objectid'].nodeValue; $.ajax({ url:"/models/deployment/"+id, type:"GET", success:function(res){ alert(res); } }); } function deleteProcess(obj){ var id=obj.attributes['objectid'].nodeValue; $.ajax({ url:"/models/delete/"+id, type:"GET", success:function(res){ alert(res); } }); } function start(obj){ var id=obj.attributes['objectid'].nodeValue; $.ajax({ url:'/models/start/'+id, type:'GET', success:function(res){ alert(res); } }); } function taskList(){ $("#taskList").submit(); } </script>
    </head>
    <body>
    <div class="info"><span th:text="${info}"></span></div>
    <a href="/models/create">新建</a>
    <form id="taskList" action="/activiti/queryTaskSl">
    <div>
        <div style="float:left;width:50%;">
            <select id="userId" name="userId">
                <option value="userzhou">userzhou</option>
                <option value="usertest">usertest</option>
            </select>
        </div>
        <div style="width:50%;">
            <button onclick="taskList();">任务列表</button>
        </div>
    </div>
    </form>
    
    <table class="table">
        <thead>
        <tr>
            <th>ID</th>
            <th>模型名称</th>
            <th>key</th>
            <th>版本</th>
            <th>部署ID</th>
            <th>建立时间</th>
            <th>最后更新时间</th>
            <th>操做</th>
        </tr>
        </thead>
        <tbody>
        <tr th:each="data : ${models}">
            <td th:text="${data.id}"></td>
            <td><a th:href="@{/static/modeler.html(modelId=${data.id})}" class="font-blue" th:text="${data.name}"></a>
            </td>
            <td th:text="${data.key}"></td>
            <td th:text="${data.version}"></td>
            <td th:text="${data.deploymentId}"></td>
            <td th:text="${data.createTime}"> 2018-02-25 17:28:35</td>
            <td th:text="${data.lastUpdateTime}"> 2018-02-25 17:28:35</td>
            <td><a href="javascript:void(0);" onclick="deployment(this);" th:attrappend="objectId=${data.id}" lass="font-blue deployBtn">发布</a>
                <a th:href="${'/activiti/start/'+data.key}" th:attrappend="objectId=${data.id}" lass="font-blue deployBtn">发起流程</a>
                <a th:href="@{/crm/model/export/{modelId}(modelId=${data.id})}" class="font-blue">导出</a>
                <a href="javascript:void(0);" onclick="deleteProcess(this);" th:attrappend="objectId=${data.id}" class="font-blue delBtn">删除</a></td>
        </tr>
        </tbody>
    </table>
    </body>
    </html>
    View Code



    taskList.html任务列表页

    git

    <!DOCTYPE html>
    <html lang="zh" xmlns:th="http://www.thymeleaf.org">
    <head>
        <meta charset="UTF-8">
        <title>Title</title>
        <script src="/static/js/jquery.min.js"></script>
    </head>
    <body>
    <a href="/models/modelList"><button>返回模型列表页</button></a>
    <div>
        <span th:text="'用户:'+${userId}"></span>
        <table>
            <thead>
            <tr>
                <th>ID</th>
                <th>任务名称</th>
                <th>受理人</th>
                <th>任务ID</th>
                <th>流程ID</th>
                <th>建立时间</th>
                <th>操做</th>
            </tr>
            </thead>
            <tbody>
            <tr th:each="data : ${tasks}">
                <td th:text="${data.id}">LeaveBill:1:4</td>
                <td th:text="${data.name}"></td>
                <td th:text="${data.assignee}">1</td>
                <td th:text="${data.taskDefinitionKey}"></td>
                <td th:text="${data.processDefinitionId}"></td>
                <td th:text="${data.createTime}"> 2018-02-25 17:28:35</td>
                <td>
                    <a th:href="${'/activiti/form?id='+data.id+'&userId='+data.assignee}" th:attrappend="objectId=${data.id}" lass="font-blue deployBtn">处理</a>
                </td>
            </tr>
            </tbody>
        </table>
    </div>
    </body>
    </html>
    View Code



    applyForm.html任务列表页
    github

    <!DOCTYPE html>
    <html lang="zh" xmlns:th="http://www.thymeleaf.org">
    <head>
        <meta charset="UTF-8">
        <title>申请页面</title>
        <script src="/static/js/jquery.min.js"></script>
        <style> .title{ text-align: center;
            }
        </style>
        <script>
            function showProcessImg(processInstanceId) { $.ajax({ url:'/activiti/queryProHighLighted', type:'POST', data:{ proInsId:processInstanceId }, success:function(res){ $("#processImg").attr('src',"data:image/png;base64,"+res); } }) } function returnBack(userId){ var form = $("<form></form>"); form.attr("action","/activiti/queryTaskSl"); form.attr("method","post"); var input = $("<input type='text' name='userId'/>") input.attr("value",userId); form.append(input); form.appendTo("body"); form.css("display","none"); form.submit(); } </script>
    </head>
    <body>
    <div class="title">申请表单</div>
    <a th:onclick="'javascript:returnBack(\''+${data.userId}+'\');'"><button>返回用户任务列表</button></a>
    <a href="javascript:void(0);" th:onclick="'javascript:showProcessImg(\''+${task.processInstanceId}+'\')'"><button>查看流程图</button></a>
    <form action="/activiti/completeTaskSl">
        <input type="hidden" id="id" name="id" th:value="${data.id}"/>
        <input type="hidden" id="userId" name="userId" th:value="${data.userId}"/>
        <input type="text" id="attr1" name="attr1"/>
        <button type="submit">提交</button>
        <button>取消</button>
    </form>
    <img src="" id="processImg"/>
    </body>
    </html>
    View Code

      

    approveForm.html任务列表页
    web

    <!DOCTYPE html>
    <html lang="zh" xmlns:th="http://www.thymeleaf.org">
    <head>
        <meta charset="UTF-8">
        <title>审批页面</title>
        <script src="/static/js/jquery.min.js"></script>
        <style> .title{ text-align: center;
            }
        </style>
        <script>
            function showProcessImg(processInstanceId) { $.ajax({ url:'/activiti/queryProHighLighted', type:'POST', data:{ proInsId:processInstanceId }, success:function(res){ $("#processImg").attr('src',"data:image/png;base64,"+res); } }) } function returnBack(userId){ var form = $("<form></form>"); form.attr("action","/activiti/queryTaskSl"); form.attr("method","post"); var input = $("<input type='text' name='userId'/>") input.attr("value",userId); form.append(input); form.appendTo("body"); form.css("display","none"); form.submit(); } </script>
    </head>
    <body>
    <div class="title">审批表单</div>
    <a th:onclick="'javascript:returnBack(\''+${data.userId}+'\');'"><button>返回任务列表</button></a>
    <a href="javascript:void(0);" th:onclick="'javascript:showProcessImg(\''+${task.processInstanceId}+'\')'"><button>查看流程图</button></a>
    <form action="/activiti/completeTaskSl">
        <input type="hidden" id="id" name="id" th:value="${data.id}"/>
        <input type="hidden" id="userId" name="userId" th:value="${data.userId}"/>
        <input type="text" id="attr1" name="attr1"/>
        <button type="submit">提交</button>
        <button>取消</button>
    </form>
    <img src="" id="processImg"/>
    </body>
    </html>
    View Code


  • 运行界面以下
    list.html列表页


    新建页面



    这里主要注意连个地方,assignments表示当前节点的处理人的id,我本身定义了两个用户userzhou和usertest,form key填写处理当前节点所用的form表单,也就是以前的applyForm和approveForm








  • 须要注意的地方

    一、去除activiti的security校验,修改application启动类
     @SpringBootApplication(scanBasePackages = {"com.djkj","org.activiti"} , exclude = { org.springframework.boot.autoconfigure.security.servlet.SecurityAutoConfiguration.class, org.activiti.spring.boot.SecurityAutoConfiguration.class,}) 
    这是按照网上的写的,但仍是存在校验,最后没办法在act_id_user里面加了一条数据,你们有解决的办法能够在下方给我评论,谢谢。

    springboot配置文件添加security.basic.enabled=false,未验证

    二、访问静态资源的时候,可能会被dispatcherservlet 给拦截掉,我是添加了个资源处理器,拦截static静态资源

    package com.djkj.activiti.common; import groovy.util.logging.Slf4j; import org.springframework.context.annotation.Configuration; import org.springframework.web.servlet.config.annotation.EnableWebMvc; import org.springframework.web.servlet.config.annotation.ResourceHandlerRegistry; import org.springframework.web.servlet.config.annotation.WebMvcConfigurer; @Configuration @Slf4j @EnableWebMvc public class StaticResourceConfig implements WebMvcConfigurer { @Override public void addResourceHandlers(ResourceHandlerRegistry registry) { registry.addResourceHandler("/static/**").addResourceLocations("classpath:/static/"); } }
    View Code

    三、关闭编辑器的时候能够自定义返回的页面
      修改editor-app\configuration下的toolbar-default-actions.js,有俩个地方closeEditor方法和$scope.saveAndClose方法,一个是关闭一个是保存并关闭,能够修改放回路径,对应的是controller里的路径

    closeEditor: function(services) { window.location.href = "/models/modelList"; }, $scope.saveAndClose = function () { $scope.save(function() { window.location.href = "/models/modelList"; }); };

 

源码已经发到码云,各位能够去拉取
地址: https://gitee.com/zhouyun123/springBoot-activiti-modelerajax

相关文章
相关标签/搜索