devbox
菜鸟追梦旅行
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

springboot集成activity6.0.0_activiti-app中复制用户任务怎么节点id是一样的

作者：菜鸟追梦旅行 | 2024-06-11 16:15:31

赞

踩

activiti-app中复制用户任务怎么节点id是一样的

个人博客地址：www.wzbjsz.cn

在线浏览地址：activiti.wzbjsz.cn

什么是工作流？

工作流(Workflow)，就是通过计算机对业务流程自动化执行管理。它主要解决的是“使在多个参与者之间按照某种预定义的规则自动进行传递文档、信息或任务的过程，从而实现某个预期的业务目标，或者促使此目标的实现”。

什么是Activiti？

Alfresco软件在2010年5月17日宣布Activiti业务流程管理（BPM）开源项目的正式启动，其首席架构师由业务流程管理BPM的专家 Tom Baeyens担任，Tom Baeyens就是原来jbpm的架构师，而jbpm是一个非常有名的工作流引擎，当然activiti也是一个工作流引擎。

Activiti是一个工作流引擎， activiti可以将业务系统中复杂的业务流程抽取出来，使用专门的建模语言（BPMN2.0）进行定义，业务系统按照预先定义的流程进行执行，实现了业务系统的业务流程由activiti进行管理，减少业务系统由于流程变更进行系统升级改造的工作量，从而提高系统的健壮性，同时也减少了系统开发维护成本。

什么是BPMN?

BPMN（Business Process Model And Notation）- 业务流程模型和符号 是由BPMI（Business Process Management Initiative）开发的一套标准的业务流程建模符号，使用BPMN提供的符号可以创建业务流程。 2004年5月发布了BPMN1.0规范.BPMI于2005年9月并入OMG（The Object Management Group对象管理组织)组织。OMG于2011年1月发布BPMN2.0的最终版本。

 

具体发展历史如下:


BPMN 是目前被各 BPM 厂商广泛接受的 BPM 标准。Activiti 就是使用 BPMN 2.0 进行流程建模、流程执行管理，它包括很多的建模符号，比如：

Event 用一个圆圈表示，它是流程中运行过程中发生的事情。


活动用圆角矩形表示，一个流程由一个活动或多个活动组成

 

一个bpmn图形的例子：

Bpmn图形其实是通过xml表示业务流程，上边的.bpmn文件使用文本编辑器打开：

一：在项目pom.xml文件中添加activity依赖。

  1.         <dependency>
  2.             <groupId>org.activiti</groupId>
  3.             <artifactId>activiti-spring-boot-starter-basic</artifactId>
  4.             <version>6.0.0</version>
  5.         </dependency>

二：修改启动类。

@SpringBootApplication(exclude={org.activiti.spring.boot.SecurityAutoConfiguration.class})

三：流程文件。
在src/main/java/resources目录下新建processes目录，并在该目录下新增一个业务流程文件(默认以.bpmn20.xml或.bpmn为后缀名)（activity默认校验resources下的processes文件夹里的流程文件，如果没有processes目录并且目录下没有流程文件会报错class path resource [processes/] cannot be resolved to URL because it does not exist），
可以在配置文件中配置spring.activiti.check-process-definitions=false，设置为不校验，这样就不会报错。
四：修改activity默认的id生成策略。
1.activiti默认的ID生成策略在高并发场景下会出现ID重复的情况，因此在高并发场景下建议采用UUID的策略。
2.传统的spring在配置文件中添加idGenerator属性：

  1.     <bean id="processEngineConfiguration" class="org.activiti.spring.SpringProcessEngineConfiguration">
  2.         <!-- UUID作为主键生成策略 -->
  3.         <property name="idGenerator" ref="idGenerator" />
  4.     </bean>

3.springboot中在配置类中修改idGenerator。
需要写一个类实现IdGenerator，并重写getNextId()方法；
activity也内置了一个实现类org.activiti.engine.impl.persistence.StrongUuidGenerator，生成的uuid是带'-'的

  1. package com.mycompany.myapp.config;
  2.  
  3. import org.activiti.spring.SpringProcessEngineConfiguration;
  4. import org.activiti.spring.boot.ProcessEngineConfigurationConfigurer;
  5. import org.springframework.context.annotation.Configuration;
  6.  
  7. import com.mycompany.myapp.utils.idGenerator;
  8.  
  9. /**
  10. * @author www.wzbjsz.cn
  11. * @date 2019-01-09 10:26:47
  12. */
  13. @Configuration
  14. public class ActivitiConfig implements ProcessEngineConfigurationConfigurer {
  15.  
  16.     @Override
  17.     public void configure(SpringProcessEngineConfiguration springProcessEngineConfiguration) {
  18.         springProcessEngineConfiguration.setIdGenerator(new idGenerator());
  19.     }
  20.  
  21. }
  1. package com.mycompany.myapp.utils;
  2.  
  3. import java.util.UUID;
  4.  
  5. import org.activiti.engine.impl.cfg.IdGenerator;
  6.  
  7. /**
  8. * @author www.wzbjsz.cn
  9. * @date 2019-01-09 10:47:59
  10. */
  11. public class idGenerator implements IdGenerator{
  12.  
  13.     /**
  14.      * 封装JDK自带的UUID, 通过Random数字生成, 中间无-分割.
  15.      */
  16.     public static String uuid() {
  17.         return UUID.randomUUID().toString().replaceAll("-", "");
  18.     }
  19.  
  20.     /**
  21.      * Activiti ID 生成
  22.      */
  23.     @Override
  24.     public String getNextId() {
  25.         return IdGen.uuid();
  26.     }
  27.  
  28. }

五：配置文件属性：
1.spring.activiti.database-schema-update

spring.activiti.database-schema-update=true

databaseSchemaUpdate配置项可以设置流程引擎启动和关闭时数据库执行的策略。 databaseSchemaUpdate有以下四个值：

  1. false：false为默认值，设置为该值后，Activiti在启动时，会对比数据库表中保存的版本，如果版本不匹配时，将在启动时抛出异常。
  2. true：设置为该值后，Activiti会对数据库中所有的表进行更新，如果表不存在，则Activiti会自动创建。
  3. create-drop：Activiti启动时，会执行数据库表的创建操作，在Activiti关闭时，执行数据库表的删除操作。
  4. drop-create：Activiti启动时，执行数据库表的删除操作在Activiti关闭时，会执行数据库表的创建操作。

设置为true后启动应用，会在数据库里创建28张表，表创建好之后停止应用，设置为false，每次应用启动不检查Activiti数据表是否存在及版本号是否匹配，以提升应用启动速度。
2.spring.activiti.history-level

  1. #保存历史数据级别设置为full最高级别，便于历史数据的追溯
  2. spring.activiti.history-level=full

对于历史数据，保存到何种粒度，Activiti提供了history-level属性对其进行配置。history-level属性有点像log4j的日志输出级别，该属性有以下四个值：

  1. none：不保存任何的历史数据，因此，在流程执行过程中，这是最高效的。
  2. activity：级别高于none，保存流程实例与流程行为，其他数据不保存。
  3. audit：除activity级别会保存的数据外，还会保存全部的流程任务及其属性。audit为history的默认值。
  4. full：保存历史数据的最高级别，除了会保存audit级别的数据外，还会保存其他全部流程相关的细节数据，包括一些流程参数等。

3.spring.activiti.check-process-definitions

  1. #关闭activiti自动部署（使用流程设计器部署，不使用具体文件访问方式）
  2. spring.activiti.check-process-definitions=false

六：集成在线流程设计器Activiti Modeler。
1.pom文件添加activiti-modeler依赖。

  1.         <!-- https://mvnrepository.com/artifact/org.activiti/activiti-modeler -->
  2.         <dependency>
  3.             <groupId>org.activiti</groupId>
  4.             <artifactId>activiti-modeler</artifactId>
  5.             <version>5.22.0</version>
  6.             <exclusions>
  7.                 <exclusion>
  8.                         <groupId>org.activiti</groupId>
  9.                         <artifactId>activiti-bpmn-model</artifactId>
  10.                 </exclusion>
  11.             </exclusions>
  12.         </dependency>

2.下载activiti5.22.0源码https://github.com/Activiti/Activiti/tree/activiti-5.22.0。
3.复制Activiti 5.22.0中Activiti\modules\activiti-webapp-explorer2\src\main\webapp中的diagram-viewer、editor-app两个文件夹和modeler.html文件到Spring Boot项目resources目录下的static文件夹下。

image.png

 

image.png


4.修改resource/static/editor-app/app-cfg.js。

image.png


改为：

 

  1. var ACTIVITI = ACTIVITI || {};
  2.  
  3. ACTIVITI.CONFIG = {
  4.     'contextRoot' : '/service',
  5. };

5.复制Activiti\modules\activiti-webapp-explorer2\src\main\resources中的stencilset.json文件到Spring Boot项目中的resources目录下,activiti自带是英文的。
6.将Activiti 5.22.0源码中activiti-modeler中的下列3个java文件复制到自己的项目中，并在三个java类上添加注解@RequestMapping("/service")。（/service与上面app-cfg.js中保持一致）

 

image.png

 

image.png

 

7.修改ModelSaveRestResource.java文件：

  1. /* Licensed under the Apache License, Version 2.0 (the "License");
  2.  * you may not use this file except in compliance with the License.
  3.  * You may obtain a copy of the License at
  4.  *
  5.  *      http://www.apache.org/licenses/LICENSE-2.0
  6.  *
  7.  * Unless required by applicable law or agreed to in writing, software
  8.  * distributed under the License is distributed on an "AS IS" BASIS,
  9.  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  10.  * See the License for the specific language governing permissions and
  11.  * limitations under the License.
  12.  */
  13. package com.mycompany.myapp.modeler.editor.model;
  14.  
  15. import java.io.ByteArrayInputStream;
  16. import java.io.ByteArrayOutputStream;
  17. import java.io.InputStream;
  18.  
  19. import org.activiti.editor.constants.ModelDataJsonConstants;
  20. import org.activiti.engine.ActivitiException;
  21. import org.activiti.engine.RepositoryService;
  22. import org.activiti.engine.repository.Model;
  23. import org.apache.batik.transcoder.TranscoderInput;
  24. import org.apache.batik.transcoder.TranscoderOutput;
  25. import org.apache.batik.transcoder.image.PNGTranscoder;
  26. import org.slf4j.Logger;
  27. import org.slf4j.LoggerFactory;
  28. import org.springframework.beans.factory.annotation.Autowired;
  29. import org.springframework.http.HttpStatus;
  30. import org.springframework.web.bind.annotation.PathVariable;
  31. import org.springframework.web.bind.annotation.RequestMapping;
  32. import org.springframework.web.bind.annotation.RequestMethod;
  33. import org.springframework.web.bind.annotation.ResponseStatus;
  34. import org.springframework.web.bind.annotation.RestController;
  35.  
  36. import com.fasterxml.jackson.databind.ObjectMapper;
  37. import com.fasterxml.jackson.databind.node.ObjectNode;
  38.  
  39. /**
  40.  * @author Tijs Rademakers
  41.  */
  42. @RestController
  43. @RequestMapping("/service")
  44. public class ModelSaveRestResource implements ModelDataJsonConstants {
  45.  
  46.       protected static final Logger LOGGER = LoggerFactory.getLogger(ModelSaveRestResource.class);
  47.  
  48.       @Autowired
  49.       private RepositoryService repositoryService;
  50.  
  51.       @Autowired
  52.       private ObjectMapper objectMapper;
  53.  
  54.       @RequestMapping(value="/model/{modelId}/save", method = RequestMethod.PUT)
  55.       @ResponseStatus(value = HttpStatus.OK)
  56.       public void saveModel(@PathVariable String modelId
  57.               , String name, String description
  58.               , String json_xml, String svg_xml) {
  59.         try {
  60.  
  61.           Model model = repositoryService.getModel(modelId);
  62.  
  63.           ObjectNode modelJson = (ObjectNode) objectMapper.readTree(model.getMetaInfo());
  64.  
  65.           modelJson.put(MODEL_NAME, name);
  66.           modelJson.put(MODEL_DESCRIPTION, description);
  67.           model.setMetaInfo(modelJson.toString());
  68.           model.setName(name);
  69.  
  70.           repositoryService.saveModel(model);
  71.  
  72.           repositoryService.addModelEditorSource(model.getId(), json_xml.getBytes("utf-8"));
  73.  
  74.           InputStream svgStream = new ByteArrayInputStream(svg_xml.getBytes("utf-8"));
  75.           TranscoderInput input = new TranscoderInput(svgStream);
  76.  
  77.           PNGTranscoder transcoder = new PNGTranscoder();
  78.           // Setup output
  79.           ByteArrayOutputStream outStream = new ByteArrayOutputStream();
  80.           TranscoderOutput output = new TranscoderOutput(outStream);
  81.  
  82.           // Do the transformation
  83.           transcoder.transcode(input, output);
  84.           final byte[] result = outStream.toByteArray();
  85.           repositoryService.addModelEditorSourceExtra(model.getId(), result);
  86.           outStream.close();
  87.  
  88.         } catch (Exception e) {
  89.           LOGGER.error("Error saving model", e);
  90.           throw new ActivitiException("Error saving model", e);
  91.         }
  92.       }
  93. }

8.测试创建模型。

  1.     /**
  2.      * 新建一个空模型
  3.      * @return
  4.      * @throws UnsupportedEncodingException
  5.      */
  6.     @GetMapping("/create")
  7.     public void newModel(HttpServletRequest request,HttpServletResponse response) throws Exception {
  8.         //初始化一个空模型
  9.         Model model = repositoryService.newModel();
  10.  
  11.         //设置一些默认信息
  12.         String name = "new-process";
  13.         String description = "";
  14.         int revision = 1;
  15.         String key = "process";
  16.  
  17.         ObjectNode modelNode = objectMapper.createObjectNode();
  18.         modelNode.put(ModelDataJsonConstants.MODEL_NAME, name);
  19.         modelNode.put(ModelDataJsonConstants.MODEL_DESCRIPTION, description);
  20.         modelNode.put(ModelDataJsonConstants.MODEL_REVISION, revision);
  21.  
  22.         model.setName(name);
  23.         model.setKey(key);
  24.         model.setMetaInfo(modelNode.toString());
  25.  
  26.         repositoryService.saveModel(model);
  27.         String id = model.getId();
  28.  
  29.         //完善ModelEditorSource
  30.         ObjectNode editorNode = objectMapper.createObjectNode();
  31.         editorNode.put("id", "canvas");
  32.         editorNode.put("resourceId", "canvas");
  33.         ObjectNode stencilSetNode = objectMapper.createObjectNode();
  34.         stencilSetNode.put("namespace",
  35.                 "http://b3mn.org/stencilset/bpmn2.0#");
  36.         editorNode.set("stencilset", stencilSetNode);
  37.         repositoryService.addModelEditorSource(id,editorNode.toString().getBytes("utf-8"));
  38.         response.sendRedirect("/modeler.html?modelId="+id);
  39.     }

9.请求创建模型接口后，显示如下页面表示成功:

image.png


10.去掉Activiti Afresco的logo标题栏，并且把样式上的空白栏去掉。
1)修改modeler.html中的以下内容，注意不要把该文本删除，建议加style=”display:none”,删除后其会造成底层下的一些内容有40个像数的东西显示不出来，也可以直接删除掉。

 

  1.     <div style="display:none" class="navbar navbar-fixed-top navbar-inverse" role="navigation" id="main-header">
  2.         <div class="navbar-header">
  3.             <a href="" ng-click="backToLanding()" class="navbar-brand"
  4.                title="{{'GENERAL.MAIN-TITLE' | translate}}"><span
  5.                     class="sr-only">{{'GENERAL.MAIN-TITLE' | translate}}</span></a>
  6.         </div>
  7.     </div>

2)在editor-app/css/style-common.css中，把以下样式的padding-top部分改为0px;

  1. .wrapper.full {
  2.     padding: 0px 0px 0px 0px;
  3.     overflow: hidden;
  4.     max-width: 100%;
  5.     min-width: 100%;
  6. }

11.保存模型如果报错获取不到参数。(http://www.wzbjsz.cn)，添加过滤器：

  1. package com.mycompany.myapp.config;
  2.  
  3. import javax.servlet.annotation.WebFilter;
  4.  
  5. import org.springframework.core.annotation.Order;
  6. import org.springframework.stereotype.Component;
  7. import org.springframework.web.filter.HttpPutFormContentFilter;
  8.  
  9. /**
  10. * @author www.wzbjsz.cn
  11. * @date 2019-01-20 15:47:39
  12. */
  13. @Component
  14. @WebFilter(urlPatterns = "/*", filterName = "putFilter")
  15. @Order(Integer.MIN_VALUE)
  16. public class PutFilter extends HttpPutFormContentFilter {
  17.  
  18. }
  19.

七.modeler相关方法的封装。

  1. package com.lhtc.jv.vo;
  2.  
  3. import java.io.Serializable;
  4.  
  5. import javax.validation.constraints.NotNull;
  6.  
  7. import lombok.Data;
  8.  
  9. /**
  10. * @author www.wzbjsz.cn
  11. * @date 2019-01-21 14:38:54
  12. */
  13. @Data
  14. public class ActModelVO implements Serializable{
  15.  
  16.     /**
  17.      *
  18.      */
  19.     private static final long serialVersionUID = 1L;
  20.  
  21.     private String id;//模型id
  22.  
  23.     @NotNull
  24.     private String name;//模型名称
  25.  
  26.     @NotNull
  27.     private String key;//模型标识
  28.  
  29.     private String description;//模型描述
  30.  
  31.     private String category;//模型分类
  32.  
  33.     
  34.  
  35. }
  1. package com.lhtc.jv.service;
  2.  
  3. import java.io.ByteArrayInputStream;
  4. import java.io.IOException;
  5. import java.io.UnsupportedEncodingException;
  6. import java.util.List;
  7.  
  8. import javax.servlet.http.HttpServletResponse;
  9.  
  10. import org.activiti.bpmn.converter.BpmnXMLConverter;
  11. import org.activiti.bpmn.model.BpmnModel;
  12. import org.activiti.editor.constants.ModelDataJsonConstants;
  13. import org.activiti.editor.language.json.converter.BpmnJsonConverter;
  14. import org.activiti.engine.RepositoryService;
  15. import org.activiti.engine.repository.Deployment;
  16. import org.activiti.engine.repository.Model;
  17. import org.activiti.engine.repository.ModelQuery;
  18. import org.activiti.engine.repository.ProcessDefinition;
  19. import org.apache.commons.io.IOUtils;
  20. import org.springframework.beans.factory.annotation.Autowired;
  21. import org.springframework.data.domain.Page;
  22. import org.springframework.data.domain.PageImpl;
  23. import org.springframework.data.domain.Pageable;
  24. import org.springframework.stereotype.Service;
  25. import org.springframework.transaction.annotation.Transactional;
  26.  
  27. import com.fasterxml.jackson.databind.ObjectMapper;
  28. import com.fasterxml.jackson.databind.node.ObjectNode;
  29. import com.lhtc.jv.vo.ActModelVO;
  30.  
  31. /**
  32.  * 流程模型service
  33.  * @author www.wzbjsz.cn
  34.  * @date 2019-01-21 11:28:38
  35.  */
  36. @Service
  37. @Transactional(readOnly = true)
  38. public class ActModelService {
  39.  
  40.     @Autowired
  41.     private RepositoryService repositoryService;
  42.     @Autowired
  43.     private ObjectMapper objectMapper;
  44.  
  45.     /**
  46.      * 创建模型
  47.      * @param actModelVO
  48.      * @return
  49.      * @throws UnsupportedEncodingException
  50.      */
  51.     @Transactional(readOnly = false)
  52.     public Model createModel(ActModelVO actModelVO) throws UnsupportedEncodingException{
  53.         //初始化一个空模型
  54.         Model model = repositoryService.newModel();
  55.         model.setKey(actModelVO.getKey());
  56.         model.setName(actModelVO.getName());
  57.         model.setCategory(actModelVO.getCategory());
  58.         model.setVersion(Integer.parseInt(String.valueOf(repositoryService.createModelQuery().modelKey(model.getKey()).count()+1)));
  59.  
  60.         ObjectNode modelNode = objectMapper.createObjectNode();
  61.         modelNode.put(ModelDataJsonConstants.MODEL_NAME, model.getName());
  62.         modelNode.put(ModelDataJsonConstants.MODEL_REVISION, model.getVersion());
  63.         modelNode.put(ModelDataJsonConstants.MODEL_DESCRIPTION, actModelVO.getDescription());
  64.  
  65.         model.setMetaInfo(modelNode.toString());
  66.         repositoryService.saveModel(model);
  67.  
  68.         //完善ModelEditorSource
  69.         ObjectNode editorNode = objectMapper.createObjectNode();
  70.         editorNode.put("id", "canvas");
  71.         editorNode.put("resourceId", "canvas");
  72.  
  73.         ObjectNode stencilSetNode = objectMapper.createObjectNode();
  74.         stencilSetNode.put("namespace","http://b3mn.org/stencilset/bpmn2.0#");
  75.         editorNode.set("stencilset", stencilSetNode);
  76.  
  77.         repositoryService.addModelEditorSource(model.getId(),editorNode.toString().getBytes("utf-8"));
  78.         return model;
  79.     }
  80.  
  81.     /**
  82.      * 根据模型id查询
  83.      * @param modelId 模型id
  84.      * @return
  85.      */
  86.     public Model getModelById(String modelId){
  87.         return repositoryService.getModel(modelId);
  88.     }
  89.  
  90.     /**
  91.      * 查询模型列表
  92.      * @param pageable
  93.      * @return
  94.      */
  95.     public Page<Model> getAllModels(Pageable pageable){
  96.         ModelQuery modelQuery = repositoryService.createModelQuery().latestVersion().orderByLastUpdateTime().desc();
  97.         return new PageImpl<>(modelQuery.listPage(pageable.getPageNumber()*pageable.getPageSize(), pageable.getPageSize()), pageable, modelQuery.count());
  98.     }
  99.  
  100.     /**
  101.      * 部署模型
  102.      * @param modelId 模型id
  103.      * @return
  104.      * @throws IOException
  105.      */
  106.     @Transactional(readOnly = false)
  107.     public List<ProcessDefinition> deployModel(String modelId) throws IOException{
  108.         Model modelData = repositoryService.getModel(modelId);
  109.         BpmnJsonConverter jsonConverter = new BpmnJsonConverter();
  110.         ObjectNode editorNode = (ObjectNode) new ObjectMapper().readTree(repositoryService.getModelEditorSource(modelData.getId()));
  111.         BpmnModel bpmnModel = jsonConverter.convertToBpmnModel(editorNode);
  112.         BpmnXMLConverter xmlConverter = new BpmnXMLConverter();
  113.         byte[] bpmnBytes = xmlConverter.convertToXML(bpmnModel);
  114.         ByteArrayInputStream in = new ByteArrayInputStream(bpmnBytes);
  115.         Deployment deployment = repositoryService.createDeployment().name(modelData.getName())
  116.                 .addInputStream(modelData.getKey()+".bpmn20.xml", in).enableDuplicateFiltering().deploy();
  117.         return repositoryService.createProcessDefinitionQuery().deploymentId(deployment.getId()).list();
  118.     }
  119.  
  120.     /**
  121.      * 删除模型
  122.      * @param modelId 模型id
  123.      */
  124.     @Transactional(readOnly = false)
  125.     public void deleteModel(String modelId){
  126.         repositoryService.deleteModel(modelId);
  127.     }
  128.  
  129.     /**
  130.      * 导出模型xml文件
  131.      * @param modelId 模型id
  132.      * @param response HttpServletResponse
  133.      * @throws IOException
  134.      */
  135.     public void exportModel(String modelId, HttpServletResponse response) throws IOException{
  136.         Model modelData = repositoryService.getModel(modelId);
  137.         BpmnJsonConverter jsonConverter = new BpmnJsonConverter();
  138.         ObjectNode editorNode = (ObjectNode) new ObjectMapper().readTree(repositoryService.getModelEditorSource(modelData.getId()));
  139.         BpmnModel bpmnModel = jsonConverter.convertToBpmnModel(editorNode);
  140.         BpmnXMLConverter xmlConverter = new BpmnXMLConverter();
  141.         byte[] bpmnBytes = xmlConverter.convertToXML(bpmnModel);
  142.         ByteArrayInputStream in = new ByteArrayInputStream(bpmnBytes);
  143.         IOUtils.copy(in, response.getOutputStream());
  144.         String filename = bpmnModel.getMainProcess().getId() + ".bpmn20.xml";
  145.         response.setHeader("Content-Disposition", "attachment; filename=" + java.net.URLEncoder.encode(filename, "UTF-8"));
  146.         response.flushBuffer();
  147.     }
  148.  
  149. }
  1. package com.lhtc.jv.web.rest.activiti;
  2.  
  3. import java.io.IOException;
  4. import java.io.UnsupportedEncodingException;
  5. import java.net.URI;
  6. import java.net.URISyntaxException;
  7. import java.util.List;
  8. import java.util.Optional;
  9.  
  10. import javax.servlet.http.HttpServletResponse;
  11. import javax.validation.Valid;
  12.  
  13. import org.activiti.engine.repository.Model;
  14. import org.activiti.engine.repository.ProcessDefinition;
  15. import org.slf4j.Logger;
  16. import org.slf4j.LoggerFactory;
  17. import org.springframework.beans.factory.annotation.Autowired;
  18. import org.springframework.data.domain.Page;
  19. import org.springframework.data.domain.Pageable;
  20. import org.springframework.http.HttpHeaders;
  21. import org.springframework.http.HttpStatus;
  22. import org.springframework.http.ResponseEntity;
  23. import org.springframework.util.CollectionUtils;
  24. import org.springframework.web.bind.annotation.DeleteMapping;
  25. import org.springframework.web.bind.annotation.GetMapping;
  26. import org.springframework.web.bind.annotation.PathVariable;
  27. import org.springframework.web.bind.annotation.PostMapping;
  28. import org.springframework.web.bind.annotation.PutMapping;
  29. import org.springframework.web.bind.annotation.RequestBody;
  30. import org.springframework.web.bind.annotation.RequestMapping;
  31. import org.springframework.web.bind.annotation.RequestParam;
  32. import org.springframework.web.bind.annotation.RestController;
  33.  
  34. import com.lhtc.jv.service.ActModelService;
  35. import com.lhtc.jv.vo.ActModelVO;
  36. import com.lhtc.jv.web.rest.util.HeaderUtil;
  37. import com.lhtc.jv.web.rest.util.PaginationUtil;
  38.  
  39. import io.github.jhipster.web.util.ResponseUtil;
  40.  
  41. /**
  42.  * 流程模型controller
  43.  * @author www.wzbjsz.cn
  44.  * @date 2019-01-21 13:39:47
  45.  */
  46. @RestController
  47. @RequestMapping("/api")
  48. public class ActModelResource {
  49.  
  50.     private final Logger log = LoggerFactory.getLogger(ActModelResource.class);
  51.  
  52.     private static final String ENTITY_NAME = "model";
  53.  
  54.     @Autowired
  55.     private ActModelService actModelService;
  56.  
  57.     /**
  58.      * 创建模型
  59.      * @param actModelVO
  60.      * @return the ResponseEntity with status 201 (Created) and with body the new model
  61.      * @throws UnsupportedEncodingException
  62.      * @throws URISyntaxException if the Location URI syntax is incorrect
  63.      */
  64.     @PostMapping("/models")
  65.     public ResponseEntity<Model> createModel(@Valid @RequestBody ActModelVO actModelVO) throws UnsupportedEncodingException, URISyntaxException{
  66.         log.debug("REST request to save Model : {}", actModelVO);
  67.         Model result = actModelService.createModel(actModelVO);
  68.         return ResponseEntity.created(new URI("/act/models/" + result.getId()))
  69.                 .headers(HeaderUtil.createEntityCreationAlert(ENTITY_NAME, result.getId().toString()))
  70.                 .body(result);
  71.     }
  72.  
  73.     /**
  74.      * 根据模型id查询
  75.      * @param modelId 模型id
  76.      * @return
  77.      */
  78.     @GetMapping("/models/{modelId}")
  79.     public ResponseEntity<Model> getModel(@PathVariable String modelId){
  80.         log.debug("REST request to get Model : {}", modelId);
  81.         return ResponseUtil.wrapOrNotFound(Optional.ofNullable(actModelService.getModelById(modelId)));
  82.     }
  83.  
  84.     /**
  85.      * 查询模型列表
  86.      * @param pageable the pagination information
  87.      * @return the ResponseEntity with status 200 (OK) and with body all models
  88.      */
  89.     @GetMapping("/models")
  90.     public ResponseEntity<List<Model>> getAllModels(Pageable pageable) {
  91.         final Page<Model> page = actModelService.getAllModels(pageable);
  92.         HttpHeaders headers = PaginationUtil.generatePaginationHttpHeaders(page, "/act/models");
  93.         return new ResponseEntity<>(page.getContent(), headers, HttpStatus.OK);
  94.     }
  95.  
  96.     /**
  97.      * 部署模型
  98.      * @param modelId 模型id
  99.      * @return
  100.      */
  101.     @PutMapping("/models/deploy")
  102.     public ResponseEntity<Void> deployModel(@RequestBody ActModelVO actModelVO){
  103.         String modelId = actModelVO.getId();
  104.         log.debug("REST request to deploy Model : {}", modelId);
  105.         try {
  106.             List<ProcessDefinition> processDefinitions = actModelService.deployModel(modelId);
  107.             if(!CollectionUtils.isEmpty(processDefinitions)){
  108.                 return ResponseEntity.ok().headers(HeaderUtil.createAlert("A " + ENTITY_NAME + " is deployed with identifier " + modelId, modelId)).build();
  109.             }
  110.         } catch (Exception e) {
  111.             e.printStackTrace();
  112.         }
  113.         return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).headers(HeaderUtil.createFailureAlert(ENTITY_NAME, modelId,"A " + ENTITY_NAME + " failed to deploy with identifier " + modelId)).build();
  114.     }
  115.  
  116.     /**
  117.      * 删除模型
  118.      * @param modelId 模型id
  119.      * @return
  120.      */
  121.     @DeleteMapping("/models/{modelId}")
  122.     public ResponseEntity<Void> deleteModel(@PathVariable String modelId) {
  123.         log.debug("REST request to delete Model: {}", modelId);
  124.         actModelService.deleteModel(modelId);
  125.         return ResponseEntity.ok().headers(HeaderUtil.createEntityDeletionAlert(ENTITY_NAME, modelId)).build();
  126.     }
  127.  
  128.     /**
  129.      * 导出模型xml文件
  130.      * @param modelId 模型id
  131.      * @param response HttpServletResponse
  132.      * @throws IOException
  133.      */
  134.     @GetMapping("/models/export")
  135.     public void exportModel(@RequestParam("modelId")String modelId, HttpServletResponse response) throws IOException{
  136.         actModelService.exportModel(modelId, response);
  137.     }
  138.  
  139. }


 

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/菜鸟追梦旅行/article/detail/703890
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号